UI方式

1. 進入元數據管理頁面。

   1. 登錄實時計算控制臺，單擊目標工作空間操作列下的控制臺。

   2. 單擊元數據管理。

2. 單擊創建Catalog，選擇StarRocks，單擊下一步。

3. 填寫參數配置信息。

   重要

   Catalog創建完成后，以下配置信息都不支持修改。如果需要修改，則您需要刪除掉已創建的Catalog，重新進行創建。

   

   配置項	說明	是否必填	備注
   catalog name	StarRocks Catalog名稱。	是	僅支持小寫字母a-z和數字0-9，不含大寫字母、中劃線（-）、下劃線（_）等特殊字符。
   endpoint	StarRocks的FE（Front End）訪問地址。	是	指定FE的IP和JDBC端口，格式為jdbc:mysql://ip:port。一般為9030。
   dbname	訪問StarRocks的默認數據庫名稱。	是	無。
   username	訪問StarRocks的用戶名。	是	無。
   password	訪問StarRocks的密碼。	是	為了避免您的密碼泄露，建議您通過密鑰管理的方式填寫密碼取值，詳情請參見變量和密鑰管理。

4. 單擊確定。

5. 在左側元數據區域，查看創建的Catalog。

SQL命令

1. 在查詢腳本文本編輯區域，輸入創建StarRocks Catalog的命令。

   CREATE CATALOG <catalogname> WITH (
     'type' = 'starrocks',
     'endpoint' = '<ip>:<port>', 
     'username' = '<userName>',
     'password' = '<password>',
     'dbname' = '<dbname>'
   );

   配置項	說明	是否必填	備注
   catalogname	StarRocks Catalog名稱。	是	僅支持小寫字母a-z和數字0-9，不含大寫字母、中劃線（-）、下劃線（_）等特殊字符。
   type	類型。	是	固定值為starrocks。
   endpoint	StarRocks的FE（Front End）訪問地址。	是	指定FE的IP和JDBC端口，格式為jdbc:mysql://ip:port。一般為9030。
   username	訪問StarRocks的用戶名。	是	無。
   password	訪問StarRocks的密碼。	是	為了避免您的密碼泄露，建議您通過密鑰管理的方式填寫密碼取值，詳情請參見變量和密鑰管理。
   dbname	訪問StarRocks的默認數據庫名稱。	是	無。

2. 選中創建Catalog的代碼后，單擊左側代碼行數上的運行。

   

從StarRocks表中讀取數據

INSERT INTO ${other_sink_table}
SELECT ...
FROM `${catalog_name}`.`${db_name}`.`${table_name}`
    /*+
        OPTIONS('connector' = 'starrocks', 'jdbc-url' = 'jdbc:mysql://ip:port', 'scan-url' = 'ip:port')
    */

寫入結果數據至StarRocks表

INSERT INTO `${catalog_name}`.`${db_name}`.`${table_name}`
 /*+
        OPTIONS('connector' = 'starrocks', 'jdbc-url' = 'jdbc:mysql://ip:port', 'load-url' = 'ip:port', 'sink.buffer-flush.interval-ms' = '5000','sink.properties.row_delimiter' = '\x02',
'sink.properties.column_separator' = '\x01')
    */
SELECT ... 
FROM ${other_source_table}

作為CTAS&CDAS的目標端Catalog

use catalog sr_catalog;

CREATE TABLE IF NOT EXISTS `${table_name}`
WITH (
  ...
) AS TABLE ${other_source_table};


CREATE DATABASE IF NOT EXISTS `${db_name}`
WITH (
 ...
) AS DATABASE ${other_source_database};

詳情請參見基于實時計算Flink使用CTAS&CDAS功能同步MySQL數據至StarRocks。

UI方式

1. 進入元數據管理頁面。

   1. 登錄實時計算控制臺。

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

   3. 單擊元數據管理。

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

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

4. 左側元數據區域下，查看目標Catalog是否已刪除。

SQL命令方式

1. 在查詢腳本文本編輯區域，輸入以下命令。

   DROP CATALOG `<catalog name>`;

   其中，<catalog name>是您StarRocks Catalog的名稱。

   重要

   刪除StarRocks Catalog不會影響已運行的作業，但對未上線或者作業需要暫停恢復的作業均產生影響，請您謹慎操作。

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

3. 在左側元數據區域，查看目標Catalog是否已刪除。