Lindorm:Cassandra CQL Java ドライバーを使用した LindormTable への接続

前提条件

• Java Development Kit (JDK) 1.8 以降がインストールされていること。

• Cassandra CQL Java ドライバーがインストールされていること。 Cassandra CQLドライバーのインストールをご参照ください。

• クライアント IP アドレスが Lindorm インスタンスのホワイトリストに追加されていること。 ホワイトリストの設定をご参照ください。

• CQL Connection エンドポイントを取得しておきます。 Lindorm コンソールで、「インスタンス詳細」 > [エンドポイント] > [LindormTable] タブ > [Cassandra 互換アドレス] に移動して、プライベートまたはパブリックアドレスを取得します（デフォルトのユーザー名とパスワード: root）。 エンドポイントの表示もご参照ください。

手順

1. 接続パラメーターを設定します。

    String[] contactPoints = new String[]{
         "<host>"
    };
    Cluster

   説明

   • host: Lindorm コンソールのCQL Connectionアドレスです。例: ld-bp17j28j2y7pm****-proxy-lindorm.lindorm.rds.aliyuncs.com。

   • username： Lindorm インスタンスのアカウント名。 デフォルト： root

   • パスワード: Lindorm インスタンスアカウントのパスワードです。 忘れた場合は、LindormTable の Cluster Management System でリセットします。 ユーザーパスワードの変更。

2. Cassandra CQL Java API を使用して Lindorm ワイドテーブルにアクセスします。

   • DDL 操作

      // キースペースを作成し、そのストラテジとレプリケーション係数を指定します。
         session.execute(
                     "CREATE KEYSPACE IF NOT EXISTS testKeyspace WITH replication "
                             + "= {'class':'SimpleStrategy', 'replication_factor':1};");
      // テーブルを作成し、そのプライマリキーと通常の列を指定します。
         session.execute(
                     "CREATE TABLE IF NOT EXISTS testKeyspace.testTable ("
                             + "id int PRIMARY KEY,"
                             + "name text,"
                             + "age int,"
                             + "address text"
                             + ");");    
      // テーブルを切り捨てます。
         session.execute("TRUNCATE TABLE testKeyspace.testTable;");
      // テーブルを削除します。
         session.execute("DROP TABLE testKeyspace.testTable ");

   • DML 操作

         // 挿入操作を実行します。
         session.execute(
                     "INSERT INTO testKeyspace.testTable (id, name, age, address) "
                             + "VALUES ("
                             + "1,"
                             + "'testname',"
                             + "11,"
                             + "'hangzhou');");
         // 選択操作を実行します。 `select *` はすべての列を取得します。特定の列からデータを取得するには、列名を指定します。
         ResultSet res = session.execute(
                     "SELECT * FROM testKeyspace.testTable ;");
         // 各列からデータを取得します。
         for (Row row : res)
         {
             int id = row.getInt("id");
             String name = row.getString("name");
             int age = row.getInt("age");
             String address = row.getString("address");
         }
         // セッションを閉じます。
         session.close();
         // クラスターを閉じます。
         cluster.close();