基于原生DDL语句创建元表

背景信息

元表是在原生DDL开发上更高一层的逻辑概念，元表是通过数据管理的跨存储类型表。开发过程中所用到的输入表、输出表、维表可以通过创建元表方式来进行创建和管理，以支持您通过引用元表的方式来创建其他数据表。有效解决原生DDL开发方式的研发路径复杂，密码明文记录，安全性差，研发效率低等问题。更多信息，请参见Flink_SQL任务开发方式。

步骤一：新建Flink SQL任务

1. 请参见数据开发入口，进入数据开发页面。

2. 按照下图操作指引，进入新建Flink_SQL任务对话框。

   

3. 在新建Flink_SQL任务对话框，配置参数。

   参数	说明
   任务名称	名称的命名规则如下：  只能包含小写英文字母、数字、下划线（_）。 名称的长度范围为3~62个字符。 项目内的名称不支持重复。 名称仅支持以英文字母开头。
   生产环境集群	选择Flink SQL任务所在集群。
   生产环境引擎版本	选择生产环境下任务运行的引擎版本。 说明 若您的项目空间为Basic模式，该配置项为引擎版本。
   开发环境集群及引擎版本	支持选择系统默认配置或自行配置。 系统默认配置：默认选择，使用与生产环境相同的环境集群与引擎版本。 自行配置：您可自行选择开发环境任务运行的环境集群及引擎版本。 说明 若您的项目空间为Basic模式，则无需配置该配置项。
   存储目录	默认选择为代码管理，同时您也可以在计算任务页面创建目标文件夹后，选择该目标文件夹为Flink SQL任务的目录。
   使用模板	开启后可引用已创建的实时模板。
   描述	填写对Flink SQL任务的简单描述。

步骤二：编写DDL原生语句

1. 在Flink SQL任务代码页面，编写DDL原生语句。示例代码如下：

   CREATE TEMPORARY TABLE `mysql_jdbc` (
     `id` BIGINT NOT NULL
     ,`name` VARCHAR
     ,PRIMARY KEY (`id`) NOT ENFORCED
   ) WITH (
     'connector' = 'jdbc'
     ,'password' = 'Data*****3'
     ,'username' = 'dataphin'
     ,'url' = 'jdbc:mysql://rm-uf6t0*******150.mysql.rds.aliyuncs.com:3306/dataphin'
     ,'table-name' = 'test_s_01_bigint'
   );

2. Dataphin识别到DDL原生语句后，按照以下操作步骤进入创建元表对话框。

   

步骤三：创建元表

1. 在创建元表对话框，配置相关参数。

   以创建MySQL数据源类型的元表为例。

   参数	描述
   元表名称	填写元表名称。仅支持英文字符、数字、下划线，且首字母不能为数字。
   数据源	选择创建元表的来源数据源。 说明 Dataphin将自动根据您的DDL语句自动识别数据源类型，您可以在数据源下拉选项中，选择对应数据源。
   来源表	选择数据源后，在来源表下拉选项中选择对应的来源表。
   Connector	Dataphin将根据代码自动识别所需配置的Connector，不同数据源类型所需配置的Connector不同。具体说明，请参见附录：实时数据源配置信息说明。
   字段信息获取	支持以DDL中定义为准和以数据源中来源表为准。 以DDL中定义为准：元表的字段信息为DDL中定义的字段。 以数据源中来源表为准：元表的字段信息为数据源中来源表定义的字段。
   选择目录	默认为表管理。同时您也可以在表管理页面创建目标文件夹后，选择该目标文件夹为元表的目录。
   描述	填写元表的简单描述。

2. 单击创建，即可完成元表创建。

   若您需要同时创建元表并提交到发布中心，您可以单击创建并发布。

后续说明

• 完成元表创建后，在Dataphin中将生成对应的元表。如下图所示：

  

• 创建元表的DDL语句将被注释。DML中的表将自动替换为新建的元表名。如下图所示：