Tablestore：通過JDBC直連使用SQL查詢

前提條件

• 已擷取 AccessKey，RAM 使用者需具備 "Action": "ots:SQL*" 許可權。

• 已建立資料表和映射表，詳見DDL 操作。

步驟一：安裝 JDBC 驅動

可通過以下兩種方式安裝 JDBC 驅動。

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

步驟二：使用 JDBC 直連

1. 使用 Class.forName() 載入Table Store JDBC 驅動。

   Table Store JDBC 驅動名稱為 com.alicloud.openservices.tablestore.jdbc.OTSDriver。

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

2. 使用 JDBC 串連Table Store執行個體。

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

   參數說明如下。

   參數	說明
   url	Table StoreJDBC的URL。格式為jdbc:ots:schema://[accessKeyId:accessKeySecret@]endpoint/instanceName[?param1=value1&...&paramN=valueN]。主要欄位說明如下： schema（必選）：Table StoreJDBC驅動使用的協議，一般設定為https。 accessKeyId:accessKeySecret（可選）：阿里雲帳號或者RAM使用者的AccessKey ID和AccessKey Secret。 endpoint（必選）：執行個體的服務地址。 instanceName（必選）：執行個體名稱。 其他常用配置項的說明詳見配置項。
   user	阿里雲帳號或者RAM使用者的AccessKey ID。
   password	阿里雲帳號或者RAM使用者的AccessKey Secret。

   可通過 URL 或 Properties 方式傳遞 AccessKey 和配置項。以下以通過公網訪問華東1（杭州）地區下 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();

完整樣本

以下樣本用於查詢Table Store執行個體中 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();
    }
}

配置項

Table Store JDBC 驅動基於 Java SDK 實現，支援通過 URL 參數或 Properties 修改配置項。

資料類型轉換

Table Store支援 Integer、Double、String、Binary 和 Boolean 五種資料類型。JDBC 驅動在 Java 類型和Table Store資料類型之間自動轉換。

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);    // 不支援，拋出異常
}