Realtime Compute for Apache Flink：Kelola Katalog AnalyticDB untuk MySQL

Batasan

• Hanya Realtime Compute for Apache Flink yang menggunakan Ververica Runtime (VVR) 6.0.2 atau lebih baru yang memungkinkan Anda mengonfigurasi katalog AnalyticDB untuk MySQL.

• Anda tidak dapat memodifikasi pernyataan DDL yang terkait dengan katalog.

• Anda hanya dapat menanyakan tabel data menggunakan katalog AnalyticDB untuk MySQL. Anda tidak dapat membuat, memodifikasi, atau menghapus database dan tabel menggunakan katalog AnalyticDB untuk MySQL.

• Anda hanya dapat menggunakan tabel dalam katalog AnalyticDB untuk MySQL sebagai tabel dimensi dan tabel hasil. Anda tidak dapat menggunakan tabel tersebut sebagai tabel sumber.

Buat katalog AnalyticDB untuk MySQL

1. Di editor kode pada tab Scripts di halaman SQL Editor, masukkan pernyataan berikut untuk membuat katalog AnalyticDB untuk MySQL:

   CREATE CATALOG <catalogName> WITH (
     'type' = 'adb3.0',
     'hostName' = '<hostname>',
     'port' = '<port>',
     'userName' = '<username>',
     'password' = '<password>',
     'defaultDatabase' = '<dbname>'
   );

   Parameter	Tipe Data	Deskripsi	Diperlukan
   catalogName	STRING	Nama katalog AnalyticDB untuk MySQL.	Ya
   type	STRING	Tipe katalog. Atur nilainya menjadi adb3.0.	Ya
   hostName	STRING	Alamat IP atau nama host dari database AnalyticDB untuk MySQL.	Ya
   port	INTEGER	Nomor port yang digunakan untuk mengakses database AnalyticDB untuk MySQL. Nilai default: 3306.	Tidak
   userName	STRING	Nama pengguna yang digunakan untuk mengakses database AnalyticDB untuk MySQL.	Ya
   password	STRING	Kata sandi yang digunakan untuk mengakses database AnalyticDB untuk MySQL.	Ya
   defaultDatabase	STRING	Nama database AnalyticDB untuk MySQL default.	Ya

2. Pilih kode yang digunakan untuk membuat katalog dan klik Run yang muncul di sebelah kiri kode.

   

Lihat metadata dalam katalog AnalyticDB untuk MySQL

Setelah membuat katalog AnalyticDB untuk MySQL, Anda dapat melakukan langkah-langkah berikut untuk melihat metadata AnalyticDB untuk MySQL.

1. Pergi ke halaman Katalog.

   1. Masuk ke Konsol Realtime Compute for Apache Flink.

   2. Di tab Fully Managed Flink, temukan ruang kerja yang ingin Anda kelola dan klik Console di kolom Actions.

   3. Di panel navigasi di sebelah kiri, klik Catalogs.

2. Di halaman Catalog List, temukan katalog yang diinginkan dan lihat kolom Catalog Name dan Type dari katalog tersebut.

   Catatan

   Untuk melihat database dan tabel dalam katalog, klik View di kolom Actions.

Gunakan katalog AnalyticDB untuk MySQL

• Gunakan tabel dalam katalog AnalyticDB untuk MySQL sebagai tabel dimensi.

  INSERT INTO ${other_sink_table}
  SELECT ...
  FROM ${other_source_table} AS e
  JOIN `${adb_mysql_catalog}`.`${db_name}`.`${table_name}` FOR SYSTEM_TIME AS OF e.proctime AS w
  ON e.id = w.id;

• Gunakan tabel dalam katalog AnalyticDB untuk MySQL sebagai tabel hasil.

  INSERT INTO `${adb_mysql_catalog}`.`${db_name}`.`${table_name}`
  SELECT ...
  FROM ${other_source_table}

  Jika Anda perlu menentukan parameter lain dalam klausa WITH saat menggunakan tabel dalam katalog AnalyticDB untuk MySQL, kami sarankan Anda menggunakan petunjuk SQL untuk menambahkan parameter. Untuk informasi lebih lanjut tentang parameter lainnya, lihat Konektor AnalyticDB untuk MySQL V3.0. Contoh kode berikut memberikan contoh cara menambahkan parameter replaceMode ke tabel hasil AnalyticDB untuk MySQL V3.0:

  INSERT INTO `${adb_mysql_catalog}`.`${db_name}`.`${table_name}` /*+ OPTIONS('replaceMode'='true') */
  SELECT ...
  FROM ${other_source_table}

Hapus katalog AnalyticDB untuk MySQL

Anda dapat menghapus katalog AnalyticDB untuk MySQL di UI atau menggunakan pernyataan SQL. Kami sarankan Anda menghapus katalog AnalyticDB untuk MySQL di UI.

Hapus katalog AnalyticDB untuk MySQL di UI

1. Pergi ke halaman Katalog.

   1. Masuk ke Konsol Realtime Compute for Apache Flink.

   2. Di tab Fully Managed Flink, temukan ruang kerja yang ingin Anda kelola dan klik Console di kolom Actions.

   3. Di panel navigasi di sebelah kiri, klik Catalogs.

2. Di halaman Catalog List, temukan katalog yang diinginkan dan klik Delete di kolom Actions.

3. Di pesan yang muncul, klik Delete.

4. Lihat panel Catalogs di sebelah kiri halaman Daftar Katalog untuk memeriksa apakah katalog telah dihapus.

Hapus katalog AnalyticDB untuk MySQL menggunakan pernyataan SQL

1. Di editor kode pada tab Scripts di halaman SQL Editor, masukkan pernyataan berikut:

   DROP CATALOG <catalogName>;

   Dalam pernyataan di atas, ganti catalogName dengan nama katalog AnalyticDB untuk MySQL yang ingin Anda hapus.

2. Klik kanan pernyataan yang digunakan untuk menghapus katalog dan pilih Run.

3. Lihat panel Catalogs di sebelah kiri halaman Daftar Katalog untuk memeriksa apakah katalog telah dihapus.