Tablestore:JDBC 直接接続による SQL クエリの使用

前提条件

• AccessKey ペア (RAM ユーザーには "Action": "ots:SQL*" 権限が必要です)

• データテーブルとそのマッピングテーブル (DDL 操作)

ステップ 1： JDBC ドライバーのインストール

ドライバーは、Maven 依存関係またはスタンドアロンの JAR として利用できます。

<dependency>
  <groupId>com.aliyun.openservices</groupId>
  <artifactId>tablestore-jdbc</artifactId>
  <version>5.17.0</version>
</dependency>

ステップ 2： JDBC 直接接続の使用

ドライバーをロードし、インスタンスに接続してから、SQL ステートメントを実行します。

1. Class.forName() を使用して 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);

   接続パラメーターについては、次の表で説明します。

   パラメーター	説明
   url	Tablestore JDBC の URL です。形式： jdbc:ots:schema://[accessKeyId:accessKeySecret@]endpoint/instanceName[?param1=value1&...&paramN=valueN]。URL の各フィールドは次のとおりです。 schema (必須)：プロトコルです。https に設定します。 accessKeyId:accessKeySecret (オプション)：Alibaba Cloud アカウントまたは RAM ユーザーの AccessKey ID と AccessKey Secret。 endpoint (必須)：インスタンスのエンドポイント。 instanceName (必須)：インスタンスの名前。 その他の設定項目については、「設定」をご参照ください。
   user	Alibaba Cloud アカウントまたは RAM ユーザーの AccessKey ID。
   password	Alibaba Cloud アカウントまたは RAM ユーザーの AccessKey Secret。

   URL または Properties オブジェクトを介して AccessKey ペアと設定を渡します。次の例では、インターネット経由で China (Hangzhou) リージョンの myinstance インスタンスに接続します。

   URL

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

   Properties

   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 を使用してクエリを実行します。

   createStatement

   String sql = "SELECT pk1, col_a FROM test_table";
   Statement stmt = conn.createStatement();
   ResultSet rs = stmt.executeQuery(sql);
   while (rs.next()) {
       System.out.println(rs.getString("pk1") + ", " + rs.getLong("col_a"));
   }
   rs.close();
   stmt.close();

   prepareStatement

   String sql = "SELECT * FROM test_table WHERE pk = ?";
   PreparedStatement stmt = conn.prepareStatement(sql);
   stmt.setLong(1, 1);
   ResultSet rs = stmt.executeQuery();
   ResultSetMetaData meta = rs.getMetaData();
   while (rs.next()) {
       for (int i = 1; i <= meta.getColumnCount(); i++) {
           System.out.println(meta.getColumnName(i) + " = " + rs.getString(i));
       }
   }
   rs.close();
   stmt.close();

完全な例

次の例では、Tablestore インスタンスの test_table からデータを照会します。

public class Demo {
    public static void main(String[] args) throws Exception {
        Class.forName("com.alicloud.openservices.tablestore.jdbc.OTSDriver");

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

        Statement stmt = conn.createStatement();
        ResultSet rs = stmt.executeQuery("SELECT * FROM test_table");
        ResultSetMetaData meta = rs.getMetaData();
        int colCount = meta.getColumnCount();
        while (rs.next()) {
            for (int i = 1; i <= colCount; i++) {
                System.out.print(meta.getColumnName(i) + "=" + rs.getString(i) + "\t");
            }
            System.out.println();
        }

        rs.close();
        stmt.close();
        conn.close();
    }
}

設定

Tablestore JDBC ドライバーは Java SDK に基づいて構築されており、URL パラメーターまたは Properties を使用して設定できます。

データ型変換

Tablestore は、Integer、Double、String、Binary、Boolean の 5 つのデータ型をサポートしています。JDBC ドライバーは、Java 型と Tablestore データ型との間の変換を自動的に行います。

PreparedStatement stmt = conn.prepareStatement("SELECT * FROM t WHERE pk = ?");
stmt.setLong(1, 1);                                // サポート対象
stmt.setURL(1, new URL("https://aliyun.com/"));    // サポート対象外 — 例外がスローされます

Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT count(*) FROM t");
while (rs.next()) {
    rs.getLong(1);               // サポート対象
    rs.getCharacterStream(1);    // サポート対象外 — 例外がスローされます
}