通过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() 加载表格存储 JDBC 驱动。

   表格存储 JDBC 驱动名称为 com.alicloud.openservices.tablestore.jdbc.OTSDriver。

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

2. 使用 JDBC 连接表格存储实例。

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

   参数说明如下。

   参数	说明
   url	表格存储JDBC的URL。格式为jdbc:ots:schema://[accessKeyId:accessKeySecret@]endpoint/instanceName[?param1=value1&...&paramN=valueN]。主要字段说明如下： schema（必选）：表格存储JDBC驱动使用的协议，一般设置为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();

完整示例

以下示例用于查询表格存储实例中 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();
    }
}

配置项

表格存储 JDBC 驱动基于 Java SDK 实现，支持通过 URL 参数或 Properties 修改配置项。

数据类型转换

表格存储支持 Integer、Double、String、Binary 和 Boolean 五种数据类型。JDBC 驱动在 Java 类型和表格存储数据类型之间自动转换。

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);    // 不支持，抛出异常
}