文档首页/ 数据湖探索 DLI/ Flink SQL语法参考/ Flink Opensource SQL1.10语法参考/ 数据定义语句DDL/ 创建结果表/ JDBC结果表
更新时间：2024-06-24 GMT+08:00
查看PDF
分享

JDBC结果表

功能描述

DLI将Flink作业的输出数据输出到关系型数据库中。

前提条件

  • 要与实例建立增强型跨源连接，且用户可以根据实际所需设置相应安全组规则。
  • 如何建立增强型跨源连接，请参考《数据湖探索用户指南》中增强型跨源连接章节。
  • 如何设置安全组规则，请参见《虚拟私有云用户指南》中“安全组”章节。

语法格式

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
 
create table jdbcSink (
  attr_name attr_type 
  (',' attr_name attr_type)* 
  (','PRIMARY KEY (attr_name, ...) NOT ENFORCED)
)
with (
  'connector.type' = 'jdbc',
  'connector.url' = '',
  'connector.table' = '',
  'connector.driver' = '',
  'connector.username' = '',
  'connector.password' = ''
);

参数说明

表1 参数说明

参数

是否必选

说明

connector.type

是

数据源类型，‘jdbc’表示使用JDBC connector，必须为jdbc

connector.url

是

数据库的URL

connector.table

是

读取数据库中的数据所在的表名

connector.driver

否

连接数据库所需要的驱动。若未配置，则会自动通过URL提取

connector.username

否

访问数据库所需要的账号

connector.password

否

访问数据库所需要的密码

connector.write.flush.max-rows

否

写数据时，刷新数据的最大行数。默认值为5000

connector.write.flush.interval

否

刷新数据的时间间隔，单位可以为ms、milli、millisecond/s、sec、second/min、minute等。不填写则默认不根据时间刷新

connector.write.max-retries

否

写数据失败时的最大尝试次数。默认值为3

connector.write.exclude-update-columns

否

默认值为空（默认忽略primary key字段），表示更新主键值相同的数据时，忽略指定字段的更新

注意事项

无

示例

将流jdbcSink的数据输出到MySQL数据库中。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
 
create table jdbcSink(
  car_id STRING,
  car_owner STRING,
  car_brand STRING,
  car_speed INT
)
with (
  'connector.type' = 'jdbc',
  'connector.url' = 'jdbc:mysql://xx.xx.xx.xx:3306/xx',
  'connector.table' = 'jdbc_table_name',
  'connector.driver' = 'com.mysql.jdbc.Driver',
  'connector.username' = 'xxx',
  'connector.password' = 'xxxxxx'
);
父主题： 创建结果表

相关文档