{
"job": {
"setting": {
"speed": {
"channel": 4
},
"errorLimit": {
"record": 0,
"percentage": 10
}
},
"content": [
{
"reader": {
"parameter": {
"password": "abc123"
"column": [
"col1",
"col2"
],
"where": "id > 1",
"connection": [
{
"jdbcUrl": [
"jdbc:mysql://172.16.8.104:3306/test?charset=utf8"
],
"table": [
"tb2"
]
}
],
"splitPk": "col1",
"username": "dtstack"
},
"name": "mysqlreader"
},
"writer": {
"name": "sqlserverwriter",
"parameter": {
"batchSize": 2048,
"username": "sa",
"password": "Dtstack201610!",
"column": [
"id",
"v"
],
"preSql": [],
"postSql": [],
"writeMode": "replace",
"connection": [
{
"jdbcUrl": "jdbc:jtds:sqlserver://172.16.10.46:1433;DatabaseName=dq",
"table": [
"tb1"
]
}
]
}
}
}
]
}
}
-
name
-
描述:插件名,此处只能填sqlserverwriter,否则Flinkx将无法正常加载该插件包。
-
必选:是
-
默认值:无
-
-
jdbcUrl
- 描述:针对SQLServer数据库的jdbc连接字符串
jdbcUrl按照SqlServer官方规范,并可以填写连接附件控制信息。具体请参看SqlServer官方文档。
-
必选:是
-
默认值:无
-
username
-
描述:数据源的用户名
-
必选:是
-
默认值:无
-
-
password
-
描述:数据源指定用户名的密码
-
必选:是
-
默认值:无
-
-
column
-
描述:目的表需要写入数据的字段,字段之间用英文逗号分隔。例如: "column": ["id","name","age"]。
-
必选:是
-
默认值:否
-
默认值:无
-
-
preSql
-
描述:写入数据到目的表前,会先执行这里的一组标准语句。
-
必选:否
-
默认值:无
-
-
postSql
-
描述:写入数据到目的表后,会执行这里的一组标准语句。
-
必选:否
-
默认值:无
-
-
table
-
描述:目的表的表名称。目前只支持配置单个表,后续会支持多表。
注意:table 和 jdbcUrl 必须包含在 connection 配置单元中
-
必选:是
-
默认值:无
-
-
writeMode
-
描述:控制写入数据到目标表采用
insert into
或者replace into
或者ON DUPLICATE KEY UPDATE
语句
** 在sqlserver中, 用merge into模拟后两种插入语义。 ** -
必选:是
-
所有选项:insert/replace/update
-
默认值:insert
-
-
batchSize
-
描述:一次性批量提交的记录数大小
-
必选:否
-
默认值:1024
-