Бөлісу құралы:

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

  • Мақала

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

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

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

  • Загрузка данных в таблицу Cassandra
  • Выполнить приложение

Если у вас еще нет подписки Azure, создайте бесплатную учетную запись, прежде чем начинать работу.

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

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

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

  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 для 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, чтобы убедиться, что сведения о пользователе добавлены в таблицу.

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

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

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