步骤一：安装JDBC驱动

步骤二：使用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:ots:https://myinstance.cn-hangzhou.ots.aliyuncs.com/myinstance	表格存储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传递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表中pk为指定值的数据为例介绍，请根据实际需要设置。
   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();