Tablestore：JDBC串連Table Store

步驟一：安裝JDBC驅動

步驟二：使用JDBC直連

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

   Table StoreJDBC驅動名稱為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	jdbc:ots:https://myinstance.cn-hangzhou.ots.aliyuncs.com/myinstance	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傳遞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();