SQLServer Writer¶
SqlServerWriter 插件实现了写入数据到 SQL Server 库表的功能。
配置样例¶
这里使用一份从内存产生到 SQL Server 导入的数据。
{
"job": {
"setting": {
"speed": {
"channel": 1,
"bytes": -1
}
},
"content": {
"reader": {},
"writer": {
"name": "sqlserverwriter",
"parameter": {
"username": "root",
"password": "root",
"column": [
"db_id",
"db_type",
"db_ip",
"db_port",
"db_role",
"db_name",
"db_username",
"db_password",
"db_modify_time",
"db_modify_user",
"db_description",
"db_tddl_info"
],
"connection": [
{
"table": [
"db_info_for_writer"
],
"jdbcUrl": "jdbc:sqlserver://[HOST_NAME]:PORT;DatabaseName=[DATABASE_NAME]"
}
],
"preSql": [
"delete from @table where db_id = -1;"
],
"postSql": [
"update @table set db_modify_time = now() where db_id = 1;"
]
}
}
}
}
}
参数说明¶
配置项 | 是否必须 | 默认值 | 描述 |
---|---|---|---|
jdbcUrl | 是 | 无 | 对端数据库的JDBC连接信息,jdbcUrl按照RDBMS官方规范,并可以填写连接附件控制信息 |
username | 是 | 无 | 数据源的用户名 |
password | 否 | 无 | 数据源指定用户名的密码 |
writeMode | 否 | insert | 写入方式,支持 insert, update,详见下文 |
table | 是 | 无 | 所选取的需要同步的表名,使用JSON数据格式,当配置为多张表时,用户自己需保证多张表是同一表结构 |
column | 是 | 无 | 所配置的表中需要同步的列名集合,详细描述见 rdbmswriter |
splitPk | 否 | 无 | 使用splitPk代表的字段进行数据分片,详细描述见 rdbmsreader |
preSql | 否 | 无 | 数据写入前先执行的sql语句 |
postSql | 否 | 无 | 数据写入完成后,再执行的SQL语句 |
batchSize | 否 | 1024 | 定义了插件和数据库服务器端每次批量数据获取条数,调高该值可能导致 Addax 出现OOM |
writeMode¶
默认情况下, 采取 insert into
语法写入 SQL Server 表,如果你希望采取主键存在时更新,不存在则写入的方式,也就是 SQL Server 的 MERGE INTO
语法, 可以使用 update
模式。 假定表的主键为 id
,则 writeMode
配置方法如下:
{
"writeMode": "update(id)"
}
如果是联合唯一索引,则配置方法如下:
{
"writeMode": "update(col1, col2)"
}
注: update
模式在 4.0.8
版本首次增加,之前版本并不支持。
类型转换¶
类似 SqlServerReader ,目前 SqlServerWriter 支持大部分 SqlServer 类型,但也存在部分个别类型没有支持的情况,请注意检查你的类型。