网站的系统帮助,杭州雄飞网站建设网络公司,电脑软件推广联盟,微网站开发 付费阅读JDBCRead组件
组件说明
使用JDBC驱动向任意类型的关系型数据库读取数据。
计算引擎
flink
有界性
Scan Source: Bounded
Lookup Source: Sync Mode
组件分组
Jdbc
端口
Inport#xff1a;默认端口
outport#xff1a;默认端口
组件属性
名称展示名称默认值允许…JDBCRead组件
组件说明
使用JDBC驱动向任意类型的关系型数据库读取数据。
计算引擎
flink
有界性
Scan Source: Bounded
Lookup Source: Sync 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密码。123456tableNameSCHEMA“”无是连接到JDBC表的名称。testconnectionMaxRetryTimeoutConnectionMaxRetryTimeout60s无否最大重试超时时间以秒为单位且不应该小于 1 秒。60sfetchSizeFetchSize“”无否每次循环读取时应该从数据库中获取的行数。如果指定的值为 ‘0’则该配置项会被忽略。500tableDefinitionTableDefinition“”无是Flink table定义。propertiesPROPERTIES“”无否连接器其他配置。
JDBCRead示例配置
{flow: {name: JDBCReadTest,uuid: 1234,stops: [{uuid: 0000,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: 2222,name: ShowData1,bundle: cn.piflow.bundle.flink.common.ShowData,properties: {showNumber: 100}}],paths: [{from: JDBCRead1,outport: ,inport: ,to: ShowData1}]}
}示例说明
本示例演示了通过JDBCRead从数据库test中读取test表数据并使用ShowData组件将数据打印在控制台。
演示DEMO
