你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

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

适用对象： Cassandra

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

本教程涵盖以下任务：

• 将数据加载到 Cassandra 表
• 运行应用程序

如果还没有 Azure 订阅，可以在开始前创建一个免费帐户。

先决条件

• 本文是由多个部分组成的教程。 在开始使用本文档之前，请确保创建 API for Cassandra 帐户、密钥空间和表。

将数据加载到表中

通过以下步骤将数据加载到 API for Cassandra 表中：

1. 打开“src\main\java\com\azure\cosmosdb\cassandra”文件夹下的“UserRepository.java”文件并追加代码，以将 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. 打开“src\main\java\com\azure\cosmosdb\cassandra”文件夹下的“UserProfile.java”文件。 此类包含调用你早前定义的 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 中的 API for Cassandra 帐户。 你现在可以继续学习下一篇文章：

从 API for Cassandra 帐户查询数据