本文为您介绍如何创建云原生数据仓库AnalyticDB MySQL版2.0结果表，以及云原生数据仓库AnalyticDB MySQL版和实时计算Flink版字段类型之间的映射关系。

注意
  • 本文仅适用于Blink 1.4.5及以上版本。
  • 云原生数据仓库AnalyticDB MySQL版2.0数据库支持自增主键。如果实时计算Flink版写入数据支持自增主键，则在DDL中不声明该自增字段。例如，ID是自增字段，实时计算Flink版DDL不声明该自增字段，则数据库在一行数据写入过程中会自动填补相关自增字段。

什么是云原生数据仓库AnalyticDB MySQL版

云原生数据仓库AnalyticDB MySQL版是阿里巴巴自主研发的海量数据实时高并发在线分析（Realtime OLAP）云计算服务，支持在毫秒级单位时间内，对千亿级数据进行实时地多维分析透视和业务探索。

DDL定义

说明 云原生数据仓库AnalyticDB MySQL版3.0结果表DDL请参见创建云原生数据仓库AnalyticDB MySQL版3.0结果表。
实时计算Flink版支持使用云原生数据仓库AnalyticDB MySQL版2.0作为结果输出。示例代码如下。 
CREATE TABLE stream_test_hotline_agent (
id INTEGER,
len BIGINT,
content VARCHAR，
PRIMARY KEY(id)
) WITH (
type='ads',
url='yourDatabaseURL',
tableName='<yourDatabaseTableName>',
userName='<yourDatabaseUserName>',
password='<yourDatabasePassword>',
batchSize='20'
);
说明
  • 建议使用存储注册功能，详情请参见注册云原生数据仓库AnalyticDB MySQL版。
  • 云原生数据仓库AnalyticDB MySQL版结果表声明中的主键要和云原生数据仓库AnalyticDB MySQL版里的主键保持一致，大小写敏感。如果不一致，则会导致数组索引越界的异常现象。

WITH参数

参数 说明 备注
type 结果表类型 固定值为ads。
url JDBC连接地址 云原生数据仓库AnalyticDB MySQL版数据库地址。示例：url ='jdbc:mysql://databaseName****-cn-shenzhen-a.ads.aliyuncs.com:10014/databaseName'。其中参数解释如下：
  • URI地址查询步骤如下：
    1. 登录AnalyticDB控制台。
    2. 单击对应的集群名称，进入基本信息页面。
    3. 在连接信息中查看相应的连接地址。
  • 云原生数据仓库AnalyticDB MySQL版数据库名称（databaseName）即云原生数据仓库AnalyticDB MySQL版实例名称。
tableName 表名 无
username 账号 无
password 密码 无
maxRetryTimes 写入重试次数 可选，默认值为10。
bufferSize 流入多少条数据后开始去重 可选，默认值为5000，表示输入的数据达到5000条就开始输出。
batchSize 一次批量写入的条数 可选，默认值为1000。
说明 云原生数据仓库AnalyticDB MySQL版批量写入数据的总大小不能超过1 MB，否则会报错误码20015。如果遇到该错误码，您需要调小batchSize的参数值。
batchWriteTimeoutMs 写入超时时间 可选，单位为毫秒，默认值为5000。表示如果缓存中的数据在等待5秒后，依然没有达到输出条件，系统会自动输出缓存中的所有数据。
connectionMaxActive 单连接池最大连接数 可选，默认值为30。
ignoreDelete 是否忽略delete操作 默认值为false。

类型映射

建议使用云原生数据仓库AnalyticDB MySQL版和实时计算Flink版字段类型对应关系进行DDL声明。
云原生数据仓库AnalyticDB MySQL版字段类型 实时计算Flink版字段类型
BOOLEAN BOOLEAN
TINYINT INT
SMALLINT
INT
BIGINT BIGINT
DOUBEL DOUBLE
VARCHAR VARCHAR
DATE DATE
TIME TIME
TIMESTAMP TIMESTAMP