Tablestore：Gunakan PrestoDB untuk mengakses Tablestore

Langkah 1: Hubungkan PrestoDB ke Tablestore

Setelah menginstal PrestoDB, Anda harus mengonfigurasi katalog dan skema PrestoDB untuk menghubungkan PrestoDB ke Tablestore. File konfigurasi katalog disimpan di jalur etc/catalog/tablestore.properties.

Langkah 2: Jalankan SQL CLI Presto

Setelah Tablestore terhubung ke PrestoDB, Anda dapat memulai server Presto dan mengeksekusi pernyataan SQL.

1. Peroleh program yang dapat dieksekusi untuk menginstal klien PrestoDB.

   1. Unduh paket instalasi klien PrestoDB.

      Dalam contoh ini, paket presto-cli-0.280-executable.jar diunduh.

   2. Simpan paket instalasi klien PrestoDB ke direktori bin di bawah direktori tempat PrestoDB diinstal.

   3. Jalankan perintah berikut di direktori bin untuk mendapatkan program yang dapat dieksekusi untuk menginstal klien PrestoDB.

      # Ubah nama paket instalasi klien PrestoDB menjadi presto. Ganti presto-cli-0.280-executable.jar dengan nama versi aktual klien PrestoDB. 
      mv presto-cli-0.280-executable.jar presto
      # Berikan izin kepada pengguna untuk melakukan operasi pada file presto. 
      chmod +x presto

      Gambar berikut menunjukkan direktori tempat program yang dapat dieksekusi untuk menginstal klien PrestoDB berada.

      

2. Jalankan perintah berikut di direktori bin untuk memulai server Presto.

   Penting

   Saat memulai server Presto, Anda harus memulai koordinator dan setidaknya satu worker secara terpisah.

   # Anda dapat menjalankan server Presto di latar belakang atau latar depan. Jika Anda menjalankan server Presto di latar depan, Anda dapat melihat log operasi dengan cara yang lebih mudah. 
   # Metode 1: Jalankan server Presto di latar belakang
   ./launcher start
   # Metode 2: Jalankan server Presto di latar depan
   ./launcher run

3. Jalankan perintah berikut di direktori bin untuk memulai SQL CLI.

   Catatan

   • Secara default, PrestoDB berjalan di port 8080. Jika ingin memodifikasi konfigurasi port, ubah nilai parameter http-server.http.port dalam file etc/config.properties.

   • Setelah memodifikasi konfigurasi tertentu, Anda harus memulai ulang server Presto agar konfigurasi baru berlaku.

   • ./presto dalam perintah menunjukkan jalur relatif program yang dapat dieksekusi untuk menginstal klien PrestoDB dalam direktori bin.

   ./presto --server localhost:8080 --catalog tablestore --schema default

   Tabel berikut menjelaskan parameter dalam perintah.

   Parameter	Contoh	Diperlukan	Deskripsi
   --server	localhost:8080	Ya	URI server Presto. Ganti nilainya dengan URI aktual server Presto Anda. Nilai parameter ini harus sama dengan nilai parameter discovery.uri dalam file etc/config.properties di direktori tempat PrestoDB diinstal.
   --catalog	tablestore	Ya	Nama file konfigurasi katalog. Dalam contoh ini, parameter disetel ke tablestore.
   --schema	default	Ya	Konfigurasi skema. Pertahankan konfigurasi default.

Langkah 3: Buat skema dan tabel pemetaan

Jika Anda mengonfigurasi skema dalam mode konfigurasi dinamis berdasarkan tabel metadata, Anda harus membuat dan menggunakan skema secara manual untuk mengonfigurasi instance Tablestore yang terhubung ke PrestoDB dan mengotentikasi izin pengguna. Lalu, Anda dapat membuat tabel pemetaan untuk tabel Tablestore untuk mengakses dan menganalisis data.

1. Eksekusi pernyataan berikut untuk membuat skema:

   Contoh pernyataan SQL berikut menunjukkan cara membuat skema bernama testdb untuk mengakses instance Tablestore bernama myinstance.

   CREATE SCHEMA tablestore.testdb
   WITH (
     endpoint = 'https://myinstance.cn-hangzhou.ots.aliyuncs.com',
     instance_name = 'myinstance',
     access_id = '************************',
     access_key = '********************************'
   );

   Tabel berikut menjelaskan parameter-parameter yang digunakan.

   Parameter	Contoh	Diperlukan	Deskripsi
   endpoint	https://myinstance.cn-hangzhou.ots.aliyuncs.com	Ya	Titik akhir instance Tablestore. Untuk informasi lebih lanjut, lihat Endpoints.
   instance_name	myinstance	Ya	Nama instance Tablestore yang terhubung. Untuk informasi lebih lanjut, lihat Instance.
   access_id	************************	Ya	ID AccessKey akun Alibaba Cloud Anda atau pengguna RAM.
   access_key	********************************	Ya	Rahasia AccessKey akun Alibaba Cloud Anda atau pengguna RAM.

2. Eksekusi pernyataan use <SCHEMA_NAME>; untuk menggunakan skema yang telah dibuat.

   Ganti <SCHEMA_NAME> dengan nama skema yang telah dibuat. Anda dapat mengeksekusi pernyataan show schemas; untuk melihat daftar skema.

3. Eksekusi pernyataan berikut untuk membuat tabel pemetaan untuk tabel Tablestore.

   Penting

   Saat membuat tabel pemetaan, perhatikan hal-hal berikut:

   • Pastikan bahwa tipe data kolom dalam tabel pemetaan dipetakan ke tipe data dalam tabel Tablestore. Untuk informasi lebih lanjut, lihat bagian Pemetaan Tipe Data dari topik "Akses Tablestore menggunakan PrestoDB".

   • Nama tabel pemetaan harus sama dengan nama sebenarnya dari tabel Tablestore.

   • Tabel yang ditentukan oleh parameter table_name dalam pernyataan CREATE TABLE dipetakan ke tabel sebenarnya di Tablestore. Anda dapat membuat beberapa tabel pemetaan untuk tabel Tablestore yang sama.

   • Tabel pemetaan harus berisi semua kolom kunci utama dari tabel Tablestore, tetapi hanya kolom atribut tertentu.

   • Nama dan urutan kolom kunci utama dalam tabel pemetaan harus sama dengan yang ada di tabel Tablestore. Anda dapat memetakan setiap kolom atribut dalam tabel pemetaan ke nama kolom dalam tabel Tablestore sebenarnya dengan menentukan parameter origin_name.

   Dalam contoh ini, tabel main_table Tablestore yang berisi dua kolom kunci utama bernama gid dan uid serta tiga kolom atribut bernama col1, col2, dan col3 digunakan.

   Contoh pernyataan SQL berikut memberikan contoh cara membuat tabel pemetaan dengan nama yang sama dengan tabel main_table Tablestore:

   CREATE TABLE if not exists main_table
   (
      gid bigint,
      uid bigint,
      c1 boolean with (origin_name = 'col1'),
      c2 bigint with (origin_name = 'col2'),
      c3 varchar with (origin_name = 'col3')
   ) WITH (
      table_name = 'main_table'
   );

Langkah 4: Eksekusi pernyataan SQL untuk melakukan operasi pada data

Eksekusi pernyataan SQL untuk mengakses konfigurasi skema dan metadata tabel pemetaan, serta membaca data dari dan menulis data ke tabel Tablestore. Untuk informasi lebih lanjut tentang contoh pernyataan SQL, lihat bagian "Contoh Pernyataan SQL Umum" dari topik Konfigurasikan Server Presto dan Eksekusi Contoh Pernyataan SQL.

1. Akses konfigurasi skema.

   • Akses daftar skema

     show schemas;

   • Akses daftar tabel dalam skema tertentu

     show tables;

2. Akses metadata tabel tertentu

   Ganti <TABLE_NAME> dengan nama aktual tabel.

   describe <TABLE_NAME>;

3. Lakukan operasi pada data.

   Baca dan tulis data Tablestore.

   • Tulis data

     • Sisipkan satu baris data

       Contoh pernyataan SQL berikut memberikan contoh cara menyisipkan satu baris data ke dalam tabel main_table:

       insert into main_table values(10001,10001,true,100,'hangzhou');

     • Impor beberapa catatan data secara bersamaan

       Penting

       Sebelum mengimpor beberapa catatan data secara bersamaan, pastikan bahwa tabel tujuan telah dibuat dan skema tabel tujuan sama dengan skema tabel sumber.

       Contoh pernyataan SQL berikut memberikan contoh cara mengimpor kolom gid, uid, c1, c2, dan c3 dari baris-baris di mana nilai kolom gid lebih besar dari 0 dan nilai kolom uid kurang dari 10000 dari tabel main_table ke tabel sampletable:

       insert into sampletable select gid, uid, c1, c2, c3 from main_table where gid > 0 and uid < 100000;

   • Baca data

     Contoh pernyataan SQL berikut memberikan contoh cara mengakses baris-baris di mana nilai kolom gid lebih besar dari 0, nilai kolom uid kurang dari 10, dan nilai kolom c1 adalah true dalam tabel sampletable:

     select * from sampletable where gid > 0 and uid < 10 and c1 = true;