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 は、整数、Double、文字列、バイナリ、ブール値の 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);    // サポートされていません — 例外をスローします
}