待连接数据库的用户。该数据库用户需要有数据表的读写权限，以及对元数据的读取权限。 cdm 密码 用户名密码。 - 使用Agent Agent功能待下线，无需配置。 - Agent Agent功能待下线，无需配置。 - 引用符号 可选参数，连接引用表名或列名时的分隔符号，参考对应数据库的产品文档进行配置。 " 驱动版本

查看更多 →

模型采集 > 数据源”，单击“创建数据源”，进入创建数据源页面。接着选择“MySQL”类型的数据源，创建方式选择 “创建数据源”，然后在数据源输入框中输入数据源名称。 在页面中配置数据源的连接信息，如下表所示。 表1 数据源连接信息 参数 配置说明 数据源名称 填写数据源的名称，根

查看更多 →

数据源”，单击“创建数据源”，进入创建数据源页面。接着选择“MySQL”类型的数据源，单击“下一步”。 在页面中配置数据源的连接信息，如下表所示。 表1 数据源连接信息 参数 配置说明 数据源名称 填写数据源的名称，根据规划自定义。建议您按照一定的命名规则填写数据源名称，方便您快速识别和查找。 描述 填写数据源的描述信息。

查看更多 →

图2 切换到创建的Catalog 查看映射过来的数据库。 show databases; 图3 查看数据库 使用数据库。 use 数据库名; 图4 使用数据库 查看数据库表。 show tables; 图5 查看数据库表 父主题： 数据读写类

查看更多 →

访问MySQL集群填写"数据库名.表名"，访问PostGre集群填写"模式名.表名"。 说明： 如果数据库和表不存在，请先创建数据库和表，否则系统会报错并且运行失败。 user RDS数据库用户名。 password RDS数据库用户名对应密码。 driver jdbc驱动类名，访问MySQL集群请填写："com

查看更多 →

单击“下一步”，进入“输入设置”界面，设置数据源信息。 表2 输入设置参数 参数名 说明 示例 架构名称 “表方式”模式下存在，数据库模式名。 public 表名 “表方式”模式下存在，数据库表名。 test SQL语句 “SQL方式”模式下存在，配置要查询的SQL语句，使Loader可通过SQL语句查询结

查看更多 →

<staging-table-name> 创建一个与导入目标表同样数据结构的表，将所有数据先存放在该表中，然后由该表通过一次事务将结果写入到目标表中。 该参数是用来保证在数据导入关系数据库表的过程中的事务安全性，如果在导入的过程中可能会有多个事务，则一个事务失败会影响到其它事务。如果导入的数据会出现错误或出现重复的记

查看更多 →

<staging-table-name> 创建一个与导入目标表同样数据结构的表，将所有数据先存放在该表中，然后由该表通过一次事务将结果写入到目标表中。 该参数是用来保证在数据导入关系数据库表的过程中的事务安全性，因为在导入的过程中可能会有多个事务，那么一个事务失败会影响到其它事务，比如导入的数据会出现错误或出现重复的

查看更多 →

dialect.identifierEnclose 否 String 引用符号，连接引用表名或列名时的分隔符号，参考对应数据库的产品文档进行配置。 父主题： 连接参数说明

查看更多 →

“连接器管理”，单击“创建”，在弹出的界面配置创建连接器的参数，配置完成后单击“确定”。 测试功能为数据源连通性及密码正确性的检查测试。 图3 创建连接器（以RDS服务为例） 表1 参数说明 参数名 描述 连接器类型 “连接器类型”选择Hive连接时，需要选择Hive版本，当前仅支持 MRS 2

查看更多 →

待连接数据库的用户。该数据库用户需要有数据表的读写权限，以及对元数据的读取权限。 cdm 密码 用户名密码。 - 使用Agent Agent功能待下线，无需配置。 - Agent Agent功能待下线，无需配置。 - 引用符号 可选参数，连接引用表名或列名时的分隔符号，参考对应数据库的产品文档进行配置。 " 驱动版本

查看更多 →

请求消息 无。 响应消息 参数说明 表2 参数说明 名称 参数类型 是否必选 描述 collections Array of objects 是 集合列表，列表中每个元素表示一个集合。 total_count Integer 是 集合总数。 表3 参数说明 名称 参数类型 是否必选

查看更多 →

ext_info 是 String json格式存放键值对形式配置信息 响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 - String 状态码： 500 表4 响应Body参数 参数 参数类型 描述 - String 请求示例 测试连接器(MRS) post

查看更多 →

“连接器管理”，单击“创建”，在弹出的界面配置创建连接器的参数，配置完成后单击“确定”。 测试功能为数据源连通性及密码正确性的检查测试。 图3 创建连接器（以RDS服务为例） 表1 参数说明 参数名 描述 连接器类型 “连接器类型”选择Hive连接时，需要选择Hive版本，当前仅支持MRS2

查看更多 →

介绍创建拆分库时如何合理选择逻辑库分片。 广播表和单表的使用场景 介绍广播表和单表的常用场景。 DDM事务模型 介绍DDM的事务模型。 DDM SQL使用规范 介绍DDM中的SQL使用规范。 如何将单RDS数据整库迁移至DDM 介绍将单RDS库中的数据整库迁移到DDM实例单库中。 如何将Mycat数据整库迁移至DDM

查看更多 →

JDBC 功能描述 JDBC连接器是Flink内置的Connector，提供了对MySQL、PostgreSQL等常见数据库的读写支持。表类型支持源表、结果表和维表。 表1 支持类别 类别 详情 支持表类型 源表、维表、结果表 前提条件 要与实例建立增强型跨源连接，且用户可以根据实际所需设置相应安全组规则。

查看更多 →

配置为要连接的数据库的端口。 3306 数据库名称 配置为要连接的数据库名称。 dbname 用户名 待连接数据库的用户。 数据库用户名。新建分库连接时，此配置对数据源列表中所有未配置用户名密码的后端连接生效；编辑分库连接时，如需修改已存在的后端连接，请在数据源列表中单独指定用户名密码。

查看更多 →

。MySQL中该类型不能超过255字节，超过长度限制后，在严格模式下会报错，在宽松模式下会对数据进行截断并告警。 输入格式：不支持转义字符输入，不支持""双引号输入。 输出格式：对于'\0'字符，查询结果表现为“\000”，使用JDBC驱动的getBytes接口获取表现为'\0'字符。

查看更多 →

。MySQL中该类型不能超过255字节，超过长度限制后，在严格模式下会报错，在宽松模式下会对数据进行截断并告警。 输入格式：不支持转义字符输入，不支持""双引号输入。 输出格式：对于'\0'字符，查询结果表现为“\000”，使用JDBC驱动的getBytes接口获取表现为'\0'字符。

查看更多 →

报错。MySQL中该类型不能超过255字节，超过长度限制后，在严格模式下会报错，在宽松模式下会对数据进行截断并告警。 输入格式：不支持转义字符输入，不支持""双引号输入。 输出格式：对于'\0'字符，查询结果表现为“\000”，使用JDBC驱动的getBytes接口获取表现为'\0'字符。

查看更多 →

报错。MySQL中该类型不能超过255字节，超过长度限制后，在严格模式下会报错，在宽松模式下会对数据进行截断并告警。 输入格式：不支持转义字符输入，不支持""双引号输入。 输出格式：对于'\0'字符，查询结果表现为“\000”，使用JDBC驱动的getBytes接口获取表现为'\0'字符。

查看更多 →