Tablestore:Use SQL queries with a direct JDBC connection

Pré-requisitos

• Um par de AccessKey (usuários RAM exigem a permissão "Action": "ots:SQL*")

• Uma tabela de dados e sua tabela de mapeamento (Operações DDL)

Etapa 1: Instale o driver JDBC

O driver está disponível como uma dependência Maven ou um JAR independente.

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

Etapa 2: Use uma conexão JDBC direta

Carregue o driver, conecte-se a uma instância e execute instruções SQL.

1. Carregue o driver JDBC do Tablestore com Class.forName().

   O nome da classe do driver é com.alicloud.openservices.tablestore.jdbc.OTSDriver.

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

2. Conecte-se a uma instância do Tablestore com JDBC.

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

   A tabela a seguir descreve os parâmetros de conexão.

   Parâmetro	Descrição
   url	A URL JDBC do Tablestore. Formato: jdbc:ots:schema://[accessKeyId:accessKeySecret@]endpoint/instanceName[?param1=value1&...&paramN=valueN]. Os campos da URL são: schema (obrigatório): O protocolo. Defina este campo como https. accessKeyId:accessKeySecret (opcional): O AccessKey ID e o AccessKey Secret da sua conta Alibaba Cloud ou usuário RAM. endpoint (obrigatório): O endpoint da instância. instanceName (obrigatório): O nome da instância. Para outros itens de configuração, consulte Configuração.
   user	O AccessKey ID da sua conta Alibaba Cloud ou usuário RAM.
   password	O AccessKey Secret da sua conta Alibaba Cloud ou usuário RAM.

   Forneça seu par de AccessKey e configurações por meio da URL ou de um objeto Properties. Os exemplos a seguir conectam-se à instância myinstance na região China (Hangzhou) pela Internet.

   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. Execute instruções SQL.

   Utilize createStatement ou prepareStatement para executar consultas.

   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();

Exemplo completo

O exemplo a seguir consulta dados da tabela test_table em uma instância do Tablestore.

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();
    }
}

Configuração

O driver JDBC do Tablestore é construído sobre o Java SDK e suporta configuração por meio de parâmetros de URL ou Properties.

Conversão de tipos de dados

O Tablestore suporta cinco tipos de dados: Integer, Double, String, Binary e Boolean. O driver JDBC converte automaticamente entre tipos Java e tipos de dados do Tablestore.

PreparedStatement stmt = conn.prepareStatement("SELECT * FROM t WHERE pk = ?");
stmt.setLong(1, 1);                                // Supported
stmt.setURL(1, new URL("https://aliyun.com/"));    // Not supported — throws an exception

Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT count(*) FROM t");
while (rs.next()) {
    rs.getLong(1);               // Supported
    rs.getCharacterStream(1);    // Not supported — throws an exception
}