Lindorm:Gunakan ApsaraDB for HBase API untuk Java untuk mengembangkan aplikasi

Prasyarat

• Java Development Kit (JDK) versi 1.8 atau yang lebih baru telah diinstal.

• Alamat IP klien Anda telah ditambahkan ke daftar putih instans Lindorm. Untuk informasi selengkapnya, lihat Konfigurasi daftar putih.

• ApsaraDB for HBase SDK untuk Java telah diinstal. Untuk informasi selengkapnya, lihat Instal ApsaraDB for HBase SDK untuk Java.

Prosedur

1. Buat objek konfigurasi dan atur titik akhir, nama pengguna, serta kata sandi yang digunakan untuk terhubung ke LindormTable.

   // Buat objek konfigurasi.
   Configuration conf = HBaseConfiguration.create();
   // Tentukan titik akhir yang digunakan untuk terhubung ke LindormTable dengan menggunakan ApsaraDB for HBase SDK untuk Java.
   conf.set("hbase.zookeeper.quorum", "host:port");
   // xml_template.comment.hbaseue.username_password.default
   conf.set("hbase.client.username", "Username");
   conf.set("hbase.client.password", "Password");

   Parameter	Contoh	Cara memperoleh nilai parameter
   host:port	ld-bp17j28j2y7pm****-proxy-lindorm-pub.lindorm.rds.aliyuncs.com:30020	Titik akhir LindormTable yang ditampilkan setelah memilih Access by Using HBase Java API pada tab Mesin Tabel Lebar di Konsol Lindorm. Penting Jika aplikasi Anda dideploy pada instans Elastic Compute Service (ECS), kami menyarankan agar Anda terhubung ke instans Lindorm melalui Virtual Private Cloud (VPC) untuk keamanan yang lebih tinggi dan latensi jaringan yang lebih rendah. Untuk informasi selengkapnya tentang cara memperoleh titik akhir LindormTable untuk VPC, lihat Lihat titik akhir. Jika aplikasi Anda dideploy pada server lokal dan perlu terhubung ke instans Lindorm melalui Internet, Anda dapat mengaktifkan titik akhir publik untuk instans tersebut di Konsol Lindorm dengan langkah-langkah berikut: Di panel navigasi sebelah kiri, pilih Database Connections > Wide Table Engine. Pada tab Wide Table Engine, klik Enable Public Endpoint.
   Username	testuser	Username dan password yang Anda gunakan untuk terhubung ke instans Lindorm. Jika lupa password, Anda dapat mengubahnya di sistem manajemen kluster LindormTable. Untuk informasi selengkapnya, lihat Ubah password pengguna.
   Password	password

2. Gunakan objek konfigurasi yang dibuat pada Langkah 1 untuk membuat koneksi.

   Connection connection = ConnectionFactory.createConnection(conf);

   Catatan

   Koneksi hanya dibuat satu kali selama siklus hidup program. Koneksi bersifat thread-safe dan dapat digunakan bersama oleh semua thread. Setelah program berhenti berjalan, tutup objek Connection untuk mencegah kebocoran koneksi. Anda juga dapat menggunakan pernyataan try-finally untuk mencegah kebocoran koneksi.

3. Setelah koneksi berhasil dibuat, gunakan ApsaraDB for HBase API untuk Java untuk mengakses LindormTable. Anda dapat menggunakan contoh kode Java berikut.

   • Operasi DDL

     try (Admin admin = connection.getAdmin()){
         // Buat tabel.
         HTableDescriptor htd = new HTableDescriptor(TableName.valueOf("tablename"));
         htd.addFamily(new HColumnDescriptor(Bytes.toBytes("family")));
         // Buat tabel dengan hanya satu partisi.
         // Jika Anda membuat tabel di lingkungan produksi, kami menyarankan agar Anda melakukan partisi terlebih dahulu berdasarkan karakteristik data.
         admin.createTable(htd);
     
         // Nonaktifkan tabel.
         admin.disableTable(TableName.valueOf("tablename"));
     
         // Hapus semua data dalam tabel. Anda harus menonaktifkan tabel terlebih dahulu sebelum menghapus semua datanya.
         admin.truncateTable(TableName.valueOf("tablename"), true);
     
         // Hapus tabel. Anda harus menonaktifkan tabel terlebih dahulu sebelum menghapusnya.
         admin.deleteTable(TableName.valueOf("tablename"));
     }

   • Operasi DML

     // Objek tabel tidak bersifat thread-safe. Saat sebuah thread melakukan operasi pada tabel, thread tersebut harus memperoleh tabel yang diperlukan dari objek Connection.
     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);
     
         // Lakukan pemindaian data dalam rentang tertentu.
         Scan scan = new Scan(Bytes.toBytes("startRow"), Bytes.toBytes("endRow"));
         ResultScanner scanner = table.getScanner(scan);
         for (Result result : scanner) {
             // Proses hasilnya.
             System.out.println(result.toString());
         }
         scanner.close();
     }