ApsaraDB for HBase：Gunakan API Java ApsaraDB for HBase untuk mengakses instance ApsaraDB for HBase Performance-enhanced Edition

// Buat objek Configuration sebagai klien.
Configuration conf = HBaseConfiguration.create();
// Tentukan titik akhir instance ApsaraDB for HBase Anda. Di konsol ApsaraDB for HBase, navigasikan ke halaman detail instance dan klik Koneksi Database. Di bagian Informasi Koneksi, Anda dapat memperoleh titik akhir publik atau titik akhir yang menghadap VPC. Jika Anda terhubung ke instance melalui Internet, gunakan titik akhir publik. Jika Anda terhubung ke instance melalui VPC, gunakan titik akhir yang menghadap VPC.
conf.set("hbase.zookeeper.quorum", "ld-xxxx-proxy-hbaseue.hbaseue.xxx.rds.aliyuncs.com:30020");
// Tentukan nama pengguna dan kata sandi yang digunakan untuk mengakses instance. Secara default, nama pengguna dan kata sandi adalah root. Anda dapat mengubahnya sesuai kebutuhan.
conf.set("hbase.client.username", "root");
conf.set("hbase.client.password", "root");

// Jika Anda menambahkan dependensi alihbase-client dalam proyek pengembangan Anda, Anda tidak perlu mengonfigurasi parameter connection.impl. Jika Anda menambahkan dependensi alihbase-connector dalam proyek pengembangan Anda, Anda harus mengonfigurasi parameter connection.impl.
//conf.set("hbase.client.connection.impl", AliHBaseUEClusterConnection.class.getName());

Buat objek Connection untuk menghubungkan objek Configuration ke instance ApsaraDB for HBase.

// Buat koneksi ke instance ApsaraDB for HBase. Anda hanya perlu membuat satu koneksi selama siklus hidup klien. Koneksi ini aman secara thread dan dapat dibagikan oleh semua thread. 
// Setelah klien menyelesaikan beban kerja, objek Connection harus ditutup untuk mencegah kebocoran koneksi. 
// Anda juga dapat mengeksekusi pernyataan try finally untuk mencegah kebocoran koneksi.
Connection connection = ConnectionFactory.createConnection(conf);

• Pernyataan DDL

  try (Admin admin = connection.getAdmin()){
      // Buat tabel.
      HTableDescriptor htd = new HTableDescriptor(TableName.valueOf("tablename"));
      htd.addFamily(new HColumnDescriptor(Bytes.toBytes("family")));
      // Buat tabel yang hanya memiliki satu partisi.
      // Kami merekomendasikan agar Anda melakukan pre-split tabel berdasarkan data yang akan disimpan saat Anda membuat tabel di lingkungan produksi.
      admin.createTable(htd);
        
      // Nonaktifkan tabel.
      admin.disableTable(TableName.valueOf("tablename"));
        
      // Potong tabel.
      admin.truncateTable(TableName.valueOf("tablename"), true);
        
      // Hapus tabel.
      admin.deleteTable(TableName.valueOf("tablename"));
  }

• Pernyataan DML

  // Tabel adalah objek yang tidak aman secara thread. Saat sebuah thread melakukan operasi pada tabel, thread tersebut harus mendapatkan objek tabel yang diperlukan dari koneksi.
  try (Table table = connection.getTable(TableName.valueOf("tablename"))) {
      // Masukkan data.
      Put put = new Put(Bytes.toBytes("row"));
      put.addColumn(Bytes.toBytes("family"), Bytes.toBytes("qualifier"), Bytes.toBytes("value"));
      table.put(put);
  
      // Baca satu baris data.
      Get get = new Get(Bytes.toBytes("row"));
      Result res = table.get(get);
  
      // Hapus satu baris data.
      Delete delete = new Delete(Bytes.toBytes("row"));
      table.delete(delete);
  
      // Pindai data dalam rentang tertentu.
      Scan scan = new Scan(Bytes.toBytes("startRow"), Bytes.toBytes("endRow"));
      ResultScanner scanner = table.getScanner(scan);
      for (Result result : scanner) {
          // Proses hasil.
          // ...
      }
      scanner.close();
  }