Tablestore:SQL 文を実行して Tablestore にアクセスする JDBC を使用する

ステップ 1： JDBC ドライバをインストールする

ステップ 2： JDBC を使用して Tablestore にアクセスする

1. Class.forName() を使用して、Tablestore 用の JDBC ドライバを読み込みます。

   Tablestore 用 JDBC ドライバの名前は、com.alicloud.openservices.tablestore.jdbc.OTSDriver です。

   Class.forName("com.alicloud.openservices.tablestore.jdbc.OTSDriver");

2. JDBC を使用して Tablestore インスタンスにアクセスします。

   String url = "jdbc:ots:https://myinstance.cn-hangzhou.ots.aliyuncs.com/myinstance";
   String user = "************************";
   String password = "********************************";
   Connection conn = DriverManager.getConnection(url, user, password);

   次の表に、JDBC を使用して Tablestore インスタンスにアクセスするために設定する必要があるパラメータを示します。

   パラメータ	例	説明
   url	jdbc:ots:https://myinstance.cn-hangzhou.ots.aliyuncs.com/myinstance	jdbc:ots:schema://[accessKeyId:accessKeySecret@]endpoint/instanceName[?param1=value1&...&paramN=valueN] の形式の Tablestore 用 JDBC ドライバの URL です。URL には、次のフィールドが含まれています。 schema：このフィールドは必須であり、Tablestore 用 JDBC ドライバが使用するプロトコルを指定します。ほとんどの場合、このフィールドは https に設定されます。 accessKeyId:accessKeySecret：このフィールドはオプションであり、Alibaba Cloud アカウントまたは RAM ユーザーの AccessKey ID と AccessKey シークレットを指定します。 endpoint：このフィールドは必須であり、インスタンスのエンドポイントを指定します。詳細については、「エンドポイント」をご参照ください。 instanceName：このフィールドは必須であり、インスタンスの名前を指定します。 その他の設定項目については、「設定項目」をご参照ください。
   user	************************	Alibaba Cloud アカウントまたは RAM ユーザーの AccessKey ID です。
   password	********************************	Alibaba Cloud アカウントまたは RAM ユーザーの AccessKey シークレットです。

   URL または Properties パラメータを使用して、AccessKey ペアと設定項目を渡すことができます。次の例は、インターネット経由で中国（杭州）リージョンの myinstance インスタンスにアクセスする方法を示しています。

   • URL を使用して AccessKey ペアと設定項目を渡す

     DriverManager.getConnection("jdbc:ots:https://************************:********************************@myinstance.cn-hangzhou.ots.aliyuncs.com/myinstance?enableRequestCompression=true");

   • Properties パラメータを使用して AccessKey ペアと設定項目を渡す

     Properties info = new Properties();
     info.setProperty("user", "************************");
     info.setProperty("password", "********************************");
     info.setProperty("enableRequestCompression", "true");
     DriverManager.getConnection("jdbc:ots:https://myinstance.cn-hangzhou.ots.aliyuncs.com/myinstance", info);

3. SQL 文を実行します。

   createStatement メソッドまたは prepareStatement メソッドを使用して、SQL 文を作成できます。

   説明

   サポートされている SQL 文については、「SQL 機能」をご参照ください。

   createStatement メソッドを使用して SQL 文を作成する

   // ビジネス要件に基づいて SQL 文を作成します。次のサンプルコードは、test_table テーブルの id 列と name 列のデータをクエリする方法を示しています。
   String sql = "SELECT id,name FROM test_table";
   
   Statement stmt = conn.createStatement();
   ResultSet resultSet = stmt.executeQuery(sql);
   while (resultSet.next()) {
       String id = resultSet.getString("id");       
       String name = resultSet.getString("name");                 
       System.out.println(id);
       System.out.println(name);
   }
   
   resultSet.close();
   stmt.close();

   prepareStatement メソッドを使用して SQL 文を作成する

   // ビジネス要件に基づいて SQL 文を作成します。次のサンプルコードは、test_table テーブルで指定されたプライマリキーを持つデータをクエリする方法を示しています。
   String sql = "SELECT * FROM test_table WHERE pk = ?";
   
   PreparedStatement stmt = connection.prepareStatement(sql);
   stmt.setLong(1, 1);
   ResultSet resultSet = stmt.executeQuery();
   ResultSetMetaData metaData = resultSet.getMetaData();
   while (resultSet.next()) {
       int columnCount = metaData.getColumnCount();
       for (int i=0; i< columnCount;i++) {
           String columnName = metaData.getColumnName(i+1);
           String columnValue = resultSet.getString(columnName);
           System.out.println(columnName);
           System.out.println(columnValue);
       }
   }
   
   resultSet.close();
   stmt.close();