Realtime Compute for Apache Flink：管理AnalyticDB for MySQL（ADB）Catalog

使用限制

• 僅Realtime Compute引擎VVR 6.0.2及以上版本支援配置AnalyticDB for MySQL Catalog。

• 不支援修改Catalog。

• 僅支援查詢資料表，不支援建立、修改和刪除資料庫和表。

• 僅支援作為維表和結果表，不支援作為源表。

建立AnalyticDB for MySQL Catalog

1. 在查詢指令碼文本編輯地區，輸入配置AnalyticDB for MySQL Catalog的命令。

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

   參數	類型	說明	是否必填
   catalogName	String	AnalyticDB for MySQL Catalog名稱。	是
   type	String	Catalog類型，固定值為adb3.0。	是
   hostName	String	AnalyticDB for MySQL資料庫的IP地址或者Hostname。	是
   port	Integer	AnalyticDB for MySQL資料庫服務的連接埠號碼，預設值為3306。	否
   userName	String	AnalyticDB for MySQL資料庫服務的使用者名稱。	是
   password	String	AnalyticDB for MySQL資料庫服務的密碼。	是
   defaultDatabase	String	預設的AnalyticDB for MySQL資料庫名稱。	是

2. 選中建立Catalog的代碼後，單擊左側程式碼數上的運行。

   

查看AnalyticDB for MySQL Catalog

AnalyticDB for MySQL Catalog配置成功後，您可以通過以下步驟查看AnalyticDB for MySQL中繼資料。

1. 進入中繼資料管理頁面。

   1. 登入Realtime Compute控制台。

   2. 單擊目標工作空間操作列下的控制台。

   3. 單擊中繼資料管理。

2. 在Catalog列表頁面，查看Catalog名稱和類型。

   說明

   如果您需要查看目標Catalog下的資料庫和表，請單擊查看。

使用AnalyticDB for MySQL Catalog

• AnalyticDB for MySQL Catalog提供的表作為維表使用

  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;

• AnalyticDB for MySQL Catalog提供的表作為結果表使用

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

  如果AnalyticDB for MySQL Catalog的表使用時需要指定其他WITH參數，則建議使用SQL Hints方式來添加其他參數。其他參數的詳情請參見WITH參數。以AnalyticDB for MySQL 3.0結果表中添加replaceMode參數為例，程式碼範例如下。

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

刪除AnalyticDB for MySQL Catalog

支援UI與SQL命令兩種方式刪除AnalyticDB for MySQL Catalog，推薦通過UI方式刪除AnalyticDB for MySQL Catalog。

UI方式

1. 進入中繼資料管理頁面。

   1. 登入Realtime Compute控制台。

   2. 單擊目標工作空間操作列下的控制台。

   3. 單擊中繼資料管理。

2. 在Catalog列表頁面，單擊目標Catalog名稱對應操作列下的刪除。

3. 在彈出的提示頁面中，單擊刪除。

4. 在左側中繼資料地區下，查看目標Catalog是否已被刪除。

SQL命令方式

1. 在查詢指令碼文本編輯地區，輸入以下命令。

   DROP CATALOG <catalogName>;

   其中，catalogName為您要刪除的目標AnalyticDB for MySQL Catalog名稱。

2. 選中刪除Catalog的命令，滑鼠右鍵選擇運行。

3. 在左側中繼資料地區，查看目標Catalog是否已刪除。