Tablestore：Gunakan JDBC untuk mengakses Tablestore dengan mengeksekusi pernyataan SQL

Langkah 1: Instal driver JDBC

Langkah 2: Akses Tablestore menggunakan JDBC

1. Muat driver JDBC untuk Tablestore menggunakan Class.forName().

   Nama driver JDBC untuk Tablestore adalah com.alicloud.openservices.tablestore.jdbc.OTSDriver.

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

2. Akses instance Tablestore menggunakan JDBC.

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

   Tabel berikut menjelaskan parameter yang harus dikonfigurasi untuk mengakses instance Tablestore menggunakan JDBC.

   Parameter	Contoh	Deskripsi
   url	jdbc:ots:https://myinstance.cn-hangzhou.ots.aliyuncs.com/myinstance	URL driver JDBC untuk Tablestore dalam format jdbc:ots:schema://[accessKeyId:accessKeySecret@]endpoint/instanceName[?param1=value1&...&paramN=valueN]. URL tersebut mencakup bidang-bidang berikut: schema: Bidang ini wajib dan menentukan protokol yang digunakan oleh driver JDBC untuk Tablestore. Pada umumnya, bidang ini disetel ke https. accessKeyId:accessKeySecret: Bidang ini opsional dan menentukan ID AccessKey dan Rahasia AccessKey akun Alibaba Cloud atau pengguna RAM Anda. endpoint: Bidang ini wajib dan menentukan titik akhir instance. Untuk informasi lebih lanjut, lihat Titik Akhir. instanceName: Bidang ini wajib dan menentukan nama instance. Untuk informasi lebih lanjut tentang item konfigurasi lainnya, lihat Item Konfigurasi.
   user	************************	ID AccessKey akun Alibaba Cloud Anda atau pengguna RAM.
   password	********************************	Rahasia AccessKey akun Alibaba Cloud Anda atau pengguna RAM.

   Anda dapat meneruskan pasangan AccessKey dan item konfigurasi menggunakan URL atau parameter Properties. Contoh berikut menunjukkan cara mengakses instance myinstance di wilayah China (Hangzhou) melalui Internet.

   • Teruskan pasangan AccessKey dan item konfigurasi menggunakan URL

     DriverManager.getConnection("jdbc:ots:https://************************:********************************@myinstance.cn-hangzhou.ots.aliyuncs.com/myinstance?enableRequestCompression=true");

   • Teruskan pasangan AccessKey dan item konfigurasi menggunakan parameter 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. Eksekusi pernyataan SQL.

   Anda dapat menggunakan metode createStatement atau prepareStatement untuk membuat pernyataan SQL.

   Catatan

   Untuk informasi tentang pernyataan SQL yang didukung, lihat Fitur SQL.

   Gunakan metode createStatement untuk membuat pernyataan SQL

   // Buat pernyataan SQL berdasarkan kebutuhan bisnis Anda. Kode sampel berikut menunjukkan cara mengkueri data di kolom id dan name dalam tabel test_table: 
   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();

   Gunakan metode prepareStatement untuk membuat pernyataan SQL

   // Buat pernyataan SQL berdasarkan kebutuhan bisnis Anda. Kode sampel berikut menunjukkan cara mengkueri data dengan kunci utama tertentu dalam tabel test_table: 
   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();