在此頁面上，您將學到足夠的知識來開始使用NoSQL Apache Cassandra和Java，包括如何安裝，嘗試一些基本命令以及下一步做什么。

要求

要遵循本教程，您應該已經有一個正在運行的Cassandra實例，并且已經在這里進行了10分鐘的演練： http : //planetcassandra.org/create-a-keyspace-and-table/ 。

如果您已經閱讀了第一部分，請務必查看Apache Cassandra和Java Part II入門 。

您應該仍然設置了演示鍵空間和模式，我們將在下面引用它。

設定

對于此演示，我們將創建一個簡單的控制臺應用程序。 打開文本編輯器，并使用“ GettingStarted”類和單個main方法創建一個Java文件。

public class GettingStarted {public static void main(String[] args) {

我們還需要從下載頁面下載驅動程序jar文件。 點擊這里。 下載后，您需要在工作目錄中將其展開。 然后，我們必須確保在編譯.java文件時將其包括在類路徑中。

例如：

javac -classpath cassandra-java-driver-2.0.2/cassandra-driver-core-2.0.2.jar:. GettingStarted.java

當我們運行文件時：

java -classpath cassandra-java-driver-2.0.2/*:cassandra-java-driver-2.0.2/lib/*:. GettingStarted

試試看

我們所有的代碼都將進入我們的main方法。 首先，我們需要創建集群和會話實例字段來保存引用。 一個會話將管理與我們集群的連接。

Cluster cluster; Session session;

使用Cluster.builder方法連接到您的實例。 它將添加一個接觸點并構建一個集群實例。 從您的集群獲取一個會話，并連接到“演示”鍵空間。

// Connect to the cluster and keyspace "demo" cluster = Cluster.builder().addContactPoint("127.0.0.1").build(); session = cluster.connect("demo");

現在您已連接到“演示”鍵空間，讓我們將用戶插入“用戶”表中

// Insert one record into the users table session.execute("INSERT INTO users (lastname, age, city, email, firstname) VALUES ('Jones', 35, 'Austin', 'bob@example.com', 'Bob')");

使用Java驅動程序，我們可以輕松地將用戶撤出

// Use select to get the user we just entered ResultSet results = session.execute("SELECT * FROM users WHERE lastname='Jones'"); for (Row row : results) { System.out.format("%s %d\n", row.getString("firstname"), row.getInt("age")); }

由于是鮑勃（Bob）的生日，我們將更新他的年齡。

// Update the same user with a new age session.execute("update users set age = 36 where lastname = 'Jones'"); // Select and show the change results = session.execute("select * from users where lastname='Jones'"); for (Row row : results) { System.out.format("%s %d\n", row.getString("firstname"), row.getInt("age"));}

現在讓我們從表中刪除Bob。 然后，我們可以打印出所有行。 您會注意到，鮑勃的信息在刪除后不再返回（如果您以前插入過用戶，則其他人可能會回來）。

// Delete the user from the users table session.execute("DELETE FROM users WHERE lastname = 'Jones'"); // Show that the user is gone results = session.execute("SELECT * FROM users"); for (Row row : results) { System.out.format("%s %d %s %s %s\n", row.getString("lastname"), row.getInt("age"), row.getString("city"), row.getString("email"), row.getString("firstname")); }

完成后，請確保連接關閉。

// Clean up the connection by closing it cluster.close();} }

CQL與SQL非常相似，在許多情況下，相同的語法將起作用。 如果您具有關系數據庫的背景知識，這將使查詢數據非常簡單。

您剛剛設法連接到Cassandra集群并針對實時（本地）數據庫執行查詢。 希望這證明了使用Java驅動程序使用Cassandra多么容易。 GitHub上提供了此示例的完整控制臺應用程序的要點。

更多資源

Apache Cassandra和Java Part II入門 。

閱讀Java驅動程序的文檔 。

了解有關安全性和性能的準備好的語句的更多信息。

閱讀有關CQL的更多信息 。

翻譯自: https://www.javacodegeeks.com/2014/11/getting-started-with-apache-cassandra-and-java-part-i.html

總結

以上是生活随笔為你收集整理的Apache Cassandra和Java入门（第一部分）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。