Unverified Commit 53b55dbe authored by 金鑫's avatar 金鑫 Committed by GitHub

修复sqlservercdc时decimal是base64的bug (#1026)

* Update cdcsource_statements.md

cdcsource增加支持多目标库同步功能。

* sqlserver优化字段属性类型解析.
sqlserver字段sql查询语句优化增加获取字段长度.
Co-authored-by: 's avatar金鑫 <jinyanhui@huansi.net>
parent 39e61435
......@@ -56,8 +56,8 @@ public class SqlServerCDCBuilder extends AbstractCDCBuilder implements CDCBuilde
String database = config.getDatabase();
Properties debeziumProperties = new Properties();
// 为部分转换添加默认值
//debeziumProperties.setProperty("bigint.unsigned.handling.mode", "long");
//debeziumProperties.setProperty("decimal.handling.mode", "string");
debeziumProperties.setProperty("bigint.unsigned.handling.mode", "long");
debeziumProperties.setProperty("decimal.handling.mode", "string");
for (Map.Entry<String, String> entry : config.getDebezium().entrySet()) {
if (Asserts.isNotNullString(entry.getKey()) && Asserts.isNotNullString(entry.getValue())) {
debeziumProperties.setProperty(entry.getKey(), entry.getValue());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment