管理MySQL Catalog

UI方式（推荐）

1. 进入数据管理页面。

   1. 登录实时计算控制台，单击目标工作空间操作列下的控制台。

   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. 登录实时计算控制台，单击目标工作空间操作列下的控制台。

   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。 说明 仅实时计算引擎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。 说明 仅实时计算引擎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 及其对应的数据类型和属性。