Руководство: Загрузка примеров данных в API для таблицы Cassandra в Azure Cosmos DB

Область применения: Кассандра

Как у разработчика у вас должно быть приложение, использующее пары "ключ-значение". Вы можете использовать API для учетной записи Cassandra в Azure Cosmos DB для хранения данных ключа и значения и управления ими. В этом руководстве показано, как загрузить примеры данных пользователя в таблицу в учетной записи API для Cassandra в Azure Cosmos DB с помощью приложения Java. Приложение Java использует драйвер Java и загружает данные пользователя, такие как идентификатор пользователя, имя пользователя и город пользователя.

В рамках этого руководства рассматриваются следующие задачи:

• Загрузите данные в таблицу Cassandra.
• Запустите приложение.

Необходимые компоненты

• Если у вас нет подписки на Azure, создайте бесплатную учетную запись перед началом.
• Эта статья относится к многочастному учебному курсу. Прежде чем начать работу с этой статьей, создайте API для учетной записи Cassandra, пространства ключей и таблицы.

Загрузка данных в таблицу

Чтобы загрузить данные в таблицу Cassandra для API, выполните следующие действия.

1. UserRepository.java Откройте файл в папкеsrc\main\java\com\azure\cosmosdb\cassandra. Добавьте код для вставки user_iduser_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 для 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, чтобы убедиться, что сведения о пользователе были добавлены в таблицу.

Следующий шаг

В этом руководстве вы узнали, как загрузить примеры данных в учетную запись Cassandra Azure Cosmos DB. Теперь вы можете перейти к следующей статье:

Запрос данных из учетной записи API для Cassandra