Realtime Compute for Apache Flink：管理MySQL Catalog

UI方式（推薦）

1. 進入資料管理頁面。

   1. 登入Realtime Compute控制台，單擊目標工作空間操作列下的控制台。

   2. 在左側導覽列，單擊資料管理。

2. 單擊建立Catalog，選擇MySQL，單擊下一步。

3. 填寫參數配置資訊。

   重要

   Catalog建立完成後不支援修改以下配置資訊。如需修改，請刪除已建立的Catalog後重新建立。

   參數	說明	是否必填
   catalogname	自訂MySQL Catalog名稱。	是
   hostname	MySQL資料庫的IP地址或者Hostname。 說明 跨VPC或公網訪問時需要打通網路，詳情請參見網路連通性。	是
   port	MySQL資料庫服務的連接埠號碼，預設值為3306。	否
   default-database	預設的MySQL資料庫名稱。	是
   username	MySQL資料庫服務的使用者名稱。	是
   password	MySQL資料庫服務的密碼。 為了避免AK明文等風險，建議通過變數方式填寫（圖片樣本使用了名為mysqlpw的變數），詳情請參見新增變數。	是

4. 單擊確定。

   在左側中繼資料地區，可以查看建立的Catalog。

SQL命令

1. 進入資料查詢頁面。

   1. 登入Realtime Compute控制台，單擊目標工作空間操作列下的控制台。

   2. 在左側導覽列，單擊資料開發 > 資料查詢。

2. 單擊，單擊建立查詢指令碼，填寫檔案名稱和儲存位置後，單擊儲存。

3. 填寫如下代碼。

   CREATE CATALOG YourCatalogName WITH(
     'type' = 'mysql',
     'hostname' = 'rm-bp1gcn0q0j0******.mysql.rds.aliyuncs.com',
     'port' = '3306',
     'username' = 'usertest',
     'password' = '${secret_values.mysqlpw}',
     'default-database' = 'flinktest',
     'catalog.table.metadata-columns'='table_name'
   );

   參數	說明	是否必填
   YourCatalogName	自訂MySQL Catalog名稱。	是
   type	類型，固定值為mysql。	是
   hostname	MySQL資料庫的IP地址或者Hostname。 說明 跨VPC或公網訪問時需要打通網路，詳情請參見網路連通性。	是
   port	MySQL資料庫服務的連接埠號碼，預設值為3306。	否
   default-database	預設的MySQL資料庫名稱。	是
   username	MySQL資料庫服務的使用者名稱。	是
   password	MySQL資料庫服務的密碼。 為了避免AK明文等風險，建議通過變數方式填寫（樣本使用了名為mysqlpw的變數），詳情請參見新增變數。	是
   property-version	Catalog的參數版本。填寫值為0（預設值）或1（推薦）。 不同參數版本可用的參數集合和參數的預設值可能不同，區別詳情會在具體參數的說明部分描述。 說明 僅VVR 8.0.6及以上版本支援配置該參數。 VVR 11.1及以上版本預設值為1。	否
   catalog.table.metadata-columns	指定擷取資料表時，表的Schema需要添加MySQL CDC源表的中繼資料列。預設不添加中繼資料列。 多個中繼資料列使用英文分號（;）分隔，例如：op_ts;table_name;database_name。 說明 僅Realtime Compute引擎VVR 6.0.5及以上版本支援該參數。 當配置該參數時，返回的表Schema會額外添加指定的中繼資料列，這些列只適用於MySQL CDC源表，所以該Catalog返回的表只能用作資料來源表，不可以用作結果表或維表。	否
   catalog.table.treat-tinyint1-as-boolean	擷取資料表Schema時，是否將MySQL的TinyInt(1)和Boolean類型映射為Flink Boolean類型。參數取值如下： true：映射為Boolean類型。 false：映射為TINYINT類型。 參數預設值： property-version=0時，預設值為true； property-version=1時，預設值為false。 說明 僅Realtime Compute引擎VVR 8.0.4及以上版本支援配置該參數。 不建議MySQL使用TinyInt(1)儲存0和1以外的數值，請選擇合適的資料類型做映射，參見類型映射。	否

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

   返回The following statement has been executed successfully!表示建立成功。

   編輯器中的SQL代碼為CREATE CATALOG myCatalog語句，配置參數包括type=mysql、hostname=rm-bp1gcn0q0j0**.mysql.rds.aliyuncs.com、port=3306、username=usertest、password=${secret_values.mysqlpw}（通過密鑰引用）、default-database=flinktest以及catalog.table.metadata-columns=table_name。

UI方式（推薦）

在資料管理頁面，單擊Catalog列表下查看已建立的Catalog名稱和類。

• 查看：單擊目標Catalog名稱對應操作列的查看，查看Catalog下的資料庫和表資訊。

  表結構詳情暫不展示欄位comment資訊。

• 刪除：單擊目標Catalog名稱對應操作列的刪除。

  刪除操作僅刪除建立的Catalog，不會在相應服務中刪除這些表。刪除Catalog後使用該Catalog下表的已運行作業不受影響，但重新部署或啟動時會報錯（無法找到該表），請您謹慎操作。

SQL命令

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

   --查看Catalog下表在Flink中對應的Schema資訊，暫不支援展示欄位comment資訊。
   DESCRIBE `<catalogname>`.`<dbname>`.`<tablename>`;
   --刪除Catalog
   DROP CATALOG `<catalogname>`;

   說明

   刪除操作僅刪除建立的Catalog，不會在相應服務中刪除這些表。刪除Catalog後使用該Catalog下表的已運行作業不受影響，但重新部署或啟動時會報錯（無法找到該表），請您謹慎操作。

2. 選中對應的命令，滑鼠右鍵選擇運行。

   執行 DESCRIBE 語句後，返回 orders_1 表的結構資訊，包含欄位 orderkey、custkey、order_status、total_price 及其對應的資料類型和屬性。