チュートリアル: Azure Cosmos DB 内の Cassandra 用 API テーブルにサンプル データを読み込む

  • [アーティクル]

適用対象: Cassandra

開発者は、キー/値ペアを使用するアプリケーションを持っていることがあります。 Azure Cosmos DB の Cassandra 用 API アカウントを使用して、キー/値データを格納して管理できます。 このチュートリアルでは、Java アプリケーションを使用して、Azure Cosmos DB の Cassandra 用 API アカウント内のテーブルにサンプル ユーザー データを読み込む方法を示します。 この Java アプリケーションでは、Java ドライバーを使用して、ユーザー ID、ユーザー名、ユーザー所在地などのユーザー データを読み込みます。

このチュートリアルに含まれるタスクは次のとおりです。

  • Cassandra テーブルへのデータの読み込み
  • アプリを実行する

Azure サブスクリプションがない場合は、開始する前に無料アカウントを作成してください。

前提条件

テーブルにデータを読み込む

次の手順を使用して、Cassandra 用 API テーブルにデータを読み込みます。

  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 メソッドを呼び出すメイン メソッドが含まれています。 ここで、Cassandra 用 API テーブルにサンプル データを挿入する次のコードを追加します。

    //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" コマンドを実行してターゲット フォルダー内に cassandra-examples.jar ファイルを生成し、アプリケーションを実行します。

cd "cassandra-demo"

mvn clean install

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

これで､Azure portal でデータ エクスプローラーを開きユーザー情報がテーブルに追加されていることを確認できます｡

次の手順

このチュートリアルでは、Azure Cosmos DB の Cassandra 用 API アカウントにサンプル データを読み込む方法を学習しました。 次の記事に進むことができます。

Cassandra 用 API アカウントからデータのクエリを実行する