教程：将示例数据加载到 Azure Cosmos DB 中 Cassandra 表的 API 中

适用于： 卡珊德拉

作为开发人员，你可能具有使用键/值对的应用程序。 可以使用 Azure Cosmos DB 中 Cassandra 帐户的 API 来存储和管理密钥/值数据。 本教程介绍如何使用 Java 应用程序将示例用户数据加载到 Azure Cosmos DB 中 Cassandra 帐户的 API 中的表。 Java 应用程序使用 Java 驱动程序 并加载用户数据，例如用户 ID、用户名和用户城市。

本教程涵盖以下任务：

Prerequisites

• 如果没有 Azure 订阅，请在开始之前创建一个免费帐户。
• 本文属于多部分教程。 在开始本文之前，请确保 为 Cassandra 帐户、密钥空间和表创建 API。

将数据加载到表中

若要将数据加载到用于 Cassandra 表的 API 中，请执行以下步骤：

1. 打开 UserRepository.java 文件夹下 src\main\java\com\azure\cosmosdb\cassandra 的文件。 追加代码以在表中插入user_id和user_nameuser_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 的文件。 此类包含 main 方法，该方法调用前面定义的 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。 你现在可以继续学习下一篇文章：