Realtime Compute for Apache Flink:Manage AnalyticDB for MySQL (ADB) catalogs

Batasan

• Hanya Realtime Compute for Apache Flink yang menjalankan VVR 6.0.2 atau versi lebih baru yang mendukung catalog AnalyticDB for MySQL.

• Catalog tidak dapat dimodifikasi setelah dibuat.

• Anda hanya dapat melakukan kueri terhadap tabel data. Anda tidak dapat membuat, memodifikasi, atau menghapus database atau tabel.

• Tabel hanya dapat digunakan sebagai tabel dimensi dan tabel hasil, bukan sebagai tabel sumber.

• Catalog tidak mendukung koneksi SSL. Untuk menggunakan koneksi SSL, definisikan tabel temporary guna mengakses AnalyticDB for MySQL.

Create an AnalyticDB for MySQL catalog

1. Untuk membuat catalog AnalyticDB for MySQL, masukkan pernyataan berikut di editor Scripts.

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

   Parameter	Type	Description	Required
   catalogName	String	Nama catalog AnalyticDB for MySQL.	Yes
   type	String	Jenis catalog. Nilainya tetap adb3.0.	Yes
   hostName	String	Alamat IP atau hostname instans AnalyticDB for MySQL.	Yes
   port	Integer	Nomor port instans AnalyticDB for MySQL. Default: 3306.	No
   userName	String	Username untuk instans AnalyticDB for MySQL.	Yes
   password	String	Password untuk instans AnalyticDB for MySQL.	Yes
   defaultDatabase	String	Nama database AnalyticDB for MySQL default.	Yes

2. Pilih pernyataan tersebut dan klik Run di sisi kiri kode.

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

View an AnalyticDB for MySQL catalog

Setelah catalog AnalyticDB for MySQL dikonfigurasi, ikuti langkah-langkah berikut untuk melihat metadata AnalyticDB for MySQL:

1. Buka halaman Catalogs.

   1. Masuk ke Realtime Compute for Apache Flink console.

   2. Pada kolom Actions ruang kerja target, klik Console.

   3. Di panel navigasi sebelah kiri, klik Catalogs.

2. Pada halaman Catalog List, lihat Name dan Type.

   Catatan

   Untuk melihat database dan tabel dalam suatu catalog, klik View.

Use an AnalyticDB for MySQL catalog

• Gunakan tabel dari catalog AnalyticDB for 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 dari catalog AnalyticDB for MySQL sebagai tabel hasil

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

  Jika Anda perlu menentukan parameter WITH tambahan saat menggunakan tabel dari catalog AnalyticDB for MySQL, gunakan SQL hint untuk menambahkan parameter tersebut. Untuk informasi selengkapnya tentang parameter tersebut, lihat WITH parameters. Contoh berikut menunjukkan cara menambahkan parameter replaceMode ke tabel hasil AnalyticDB for MySQL 3.0.

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

Delete an AnalyticDB for MySQL catalog

Anda dapat menghapus catalog AnalyticDB for MySQL melalui UI atau pernyataan SQL. Kami merekomendasikan menghapus catalog AnalyticDB for MySQL melalui UI.

UI

1. Buka halaman Catalogs.

   1. Masuk ke Realtime Compute for Apache Flink console.

   2. Pada kolom Actions ruang kerja target, klik Console.

   3. Di panel navigasi sebelah kiri, klik Catalogs.

2. Pada halaman Catalog List, temukan catalog yang ingin dihapus dan klik Delete pada kolom Actions.

3. Pada kotak dialog konfirmasi, klik Delete.

4. Di panel Catalogs sebelah kiri, verifikasi bahwa catalog telah dihapus.

SQL statement

1. Di editor Scripts, masukkan pernyataan berikut.

   DROP CATALOG <catalogName>;

   Ganti <catalogName> dengan nama catalog AnalyticDB for MySQL yang ingin dihapus.

2. Pilih pernyataan tersebut, klik kanan, lalu pilih Run.

3. Di panel Catalogs sebelah kiri, verifikasi bahwa catalog telah dihapus.