共用方式為

教學課程：將範例數據載入 Azure Cosmos DB 中 Cassandra 數據表的 API

適用於： 卡珊德拉

身為開發人員，您可能有使用索引鍵/值組的應用程式。 您可以使用 Azure Cosmos DB 中 Cassandra 帳戶的 API 來儲存和管理金鑰/值數據。 本教學課程說明如何使用 Java 應用程式，將範例用戶數據載入 Azure Cosmos DB 中 Cassandra 帳戶 API 中的數據表。 Java 應用程式會使用 Java 驅動程式 ，並載入用戶數據，例如使用者識別碼、使用者名稱和使用者城市。

本教學課程涵蓋下列工作：

  • 將數據載入 Cassandra 資料表。
  • 執行應用程式。

先決條件

將資料載入到資料表

若要將數據載入適用於 Cassandra 資料表的 API，請遵循下列步驟：

  1. 在UserRepository.java資料夾下開啟src\main\java\com\azure\cosmosdb\cassandra檔案。 附加程式碼以將 user_id、user_name 和 user_bcity 欄位插入資料表中。

    /**
* Insert a row into user table
*
* @param id   user_id
* @param name user_name
* @param city user_bcity
*/
public void insertUser(PreparedStatement statement, int id, String name, String city) {
     BoundStatement boundStatement = new BoundStatement(statement);
     session.execute(boundStatement.bind(id, name, city));
}

/**
* Create a PrepareStatement to insert a row to user table
*
* @return PreparedStatement
*/
public PreparedStatement prepareInsertStatement() {
   final String insertStatement = "INSERT INTO  uprofile.user (user_id, user_name , user_bcity) VALUES (?,?,?)";
return session.prepare(insertStatement);
}

  2. 在UserProfile.java資料夾下開啟src\main\java\com\azure\cosmosdb\cassandra檔案。 這個類別包含可呼叫您稍早所定義 createKeyspace 和 createTable 方法的主要方法。 現在，附加下列程式碼，以將某些範例資料插入 API for Cassandra 資料表中。

    //Insert rows into user table
PreparedStatement preparedStatement = repository.prepareInsertStatement();
  repository.insertUser(preparedStatement, 1, "JohnH", "Seattle");
  repository.insertUser(preparedStatement, 2, "EricK", "Spokane");
  repository.insertUser(preparedStatement, 3, "MatthewP", "Tacoma");
  repository.insertUser(preparedStatement, 4, "DavidA", "Renton");
  repository.insertUser(preparedStatement, 5, "PeterS", "Everett");

執行應用程式

開啟命令提示字元或終端機視窗，並將資料夾路徑變更為您建立專案的位置。 mvn clean install執行 命令以在目標資料夾內產生cosmosdb-cassandra-examples.jar檔案，並執行應用程式。

cd "cassandra-demo"

mvn clean install

java -cp target/cosmosdb-cassandra-examples.jar com.azure.cosmosdb.cassandra.examples.UserProfile

您現在可以在 Azure 入口網站中開啟數據總管，以確認使用者資訊已新增至數據表。

後續步驟

在本教學課程中，您已瞭解如何將範例數據載入 Azure Cosmos DB 中 Cassandra 帳戶的 API。 您現在可以繼續進行下一篇文章：

從 API for Cassandra 帳戶查詢資料

  • Last updated on