Closed AdolphLv closed 5 days ago
Thank you for your submission! We really appreciate it. Like many open source projects, we ask that you all sign our Contributor License Agreement before we can accept your contribution.
1 out of 2 committers have signed the CLA.
:white_check_mark: AdolphLv
:x: lyang
请签署确认一下 cla,还有这里的优化逻辑需要调整一下 BigDecimal类型的要使用 toPlainString,避免科学计数法,把BigInteger类似单独出来toStgring吧。
修复通过maxwell进行数据同步时, RowMap中对象为BigInteger时提示UnsupportedOperationException问题
MySqlInsertStatement stmt = new MySqlInsertStatement(); stmt.setTableName(new SQLIdentifierExpr(r.getTable())); SQLInsertStatement.ValuesClause valuesClause = new SQLInsertStatement.ValuesClause(); stmt.addValueCause(valuesClause); LinkedHashMap<String, Object> data = r.getData(); for (String k : data.keySet()) { // v可能是BigInteger Object v = data.get(k); stmt.addColumn(new SQLIdentifierExpr(k)); valuesClause.addValue(v); }