sem搜索引擎,济南网站seo优化,域名注册后怎么备案,wordpress更改wp文件夹JDBCWrite组件
组件说明
使用JDBC驱动向任意类型的关系型数据库写入数据。
计算引擎
flink
有界性
Sink: Batch
Sink: Streaming Append Upsert Mode
组件分组
Jdbc
端口
Inport#xff1a;默认端口
outport#xff1a;默认端口
组件属性
名称展示名称默…JDBCWrite组件
组件说明
使用JDBC驱动向任意类型的关系型数据库写入数据。
计算引擎
flink
有界性
Sink: Batch
Sink: Streaming Append Upsert Mode
组件分组
Jdbc
端口
Inport默认端口
outport默认端口
组件属性
名称展示名称默认值允许值是否必填描述例子urlUrl“”无是JDBC数据库url。jdbc:mysql://127.0.0.1:3306/dbnamedriverDriver“”无否用于连接到此URL的JDBC驱动类名如果不设置将自动从URL中推导。com.mysql.cj.jdbc.DriverusernameUsername“”无否JDBC用户名。如果指定了username和password中的任一参数则两者必须都被指定。rootpasswordPassword“”无否JDBC密码。123456tableNameDBTable“”无是连接到JDBC表的名称。testconnectionMaxRetryTimeoutConnectionMaxRetryTimeout60s无否最大重试超时时间以秒为单位且不应该小于 1 秒。60stableDefinitionTableDefinition“”无是Flink table定义。propertiesPROPERTIES“”无否连接器其他配置。
JDBCWrite示例配置
{flow: {name: JDBCWriteTest,uuid: 1234,stops: [{uuid: 0000,name: JDBCExecuteSql1,bundle: cn.piflow.bundle.flink.jdbc.JDBCExecuteSql,properties: {url: jdbc:mysql://127.0.0.1:3306/test?useUnicodetruecharacterEncodingutf8serverTimezoneGMT%2B8useSSLfalseallowMultiQueriestrue,username: root,password: 123456,driver: com.mysql.cj.jdbc.Driver,sql: CREATE TABLE IF NOT EXISTS test (id int DEFAULT NULL,name varchar(20) DEFAULT NULL,age int DEFAULT NULL);}},{uuid: 1111,name: DataGen1,bundle: cn.piflow.bundle.flink.common.DataGen,properties: {schema: [{\filedName\:\id\,\filedType\:\INT\,\kind\:\sequence\,\start\:1,\end\:10000},{\filedName\:\name\,\filedType\:\STRING\,\kind\:\random\,\length\:15},{\filedName\:\age\,\filedType\:\INT\,\kind\:\random\,\max\:100,\min\:1}],count: 100,ratio: 50}},{uuid: 2222,name: JDBCWrite1,bundle: cn.piflow.bundle.flink.jdbc.JDBCWrite,properties: {url: jdbc:mysql://127.0.0.1:3306/test?useUnicodetruecharacterEncodingutf8serverTimezoneGMT%2B8useSSLfalseallowMultiQueriestrue,username: root,password: 123456,tableName: test,tableDefinition: {\catalogName\:null,\dbname\:null,\tableName\:\\,\ifNotExists\:true,\physicalColumnDefinition\:[{\columnName\:\id\,\columnType\:\INT\,\comment\:\id\},{\columnName\:\name\,\columnType\:\STRING\,\comment\:\name\},{\columnName\:\age\,\columnType\:\INT\}],\metadataColumnDefinition\:null,\computedColumnDefinition\:null,\watermarkDefinition\:null},properties: {}}},{uuid: 3333,name: JDBCRead1,bundle: cn.piflow.bundle.flink.jdbc.JDBCRead,properties: {url: jdbc:mysql://127.0.0.1:3306/test?useUnicodetruecharacterEncodingutf8serverTimezoneGMT%2B8useSSLfalseallowMultiQueriestrue,username: root,password: 123456,tableName: test,tableDefinition: {\catalogName\:null,\dbname\:null,\tableName\:\\,\ifNotExists\:true,\physicalColumnDefinition\:[{\columnName\:\id\,\columnType\:\INT\,\comment\:\id\},{\columnName\:\name\,\columnType\:\STRING\,\comment\:\name\},{\columnName\:\age\,\columnType\:\INT\}],\metadataColumnDefinition\:null,\computedColumnDefinition\:null,\watermarkDefinition\:null},properties: {}}},{uuid: 4444,name: ShowData1,bundle: cn.piflow.bundle.flink.common.ShowData,properties: {showNumber: 100}}],paths: [{from: JDBCExecuteSql1,outport: ,inport: ,to: DataGen1},{from: DataGen1,outport: ,inport: ,to: JDBCWrite1},{from: JDBCWrite1,outport: ,inport: ,to: JDBCRead1},{from: JDBCRead1,outport: ,inport: ,to: ShowData1}]}
}示例说明 首先使用JDBCExecuteSql组件执行建表DDL语句往数据库添加表 使用DataGen组件生成100条测试数据 使用JDBCWrite组件将测试数据写入到数据库 验证写入的结果使用JDBCRead组件读取数据并使用ShowData组件将结果打印在控制台。
演示DEMO
