表同步修改

zhongrj

2024-04-01 553dd70b13f6aa0194db34d3b686235d2a5dfd29

 src/main/java/org/springblade/binlog/listener/TourBinLogListener.java

@@ -97,13 +97,14 @@
      List<String> valueList = new ArrayList<>();
      // 遍历匹配数据
      dataProperty.forEach((key,value)->{
//         log.info("数据类型 " + value.dataType);
         log.info("数据类型 " + value.dataType);
         if(null!=data.get(key)) {
            keyList.add(key);
            if (value.dataType.equals("varchar") ||
               value.getDataType().equals("char")) {
               valueList.add("'" + data.get(key).toString() + "'");
            }else if(value.dataType.equals("text") ||
               value.dataType.equals("geometry") ||
               value.dataType.equals("mediumtext") ||
               value.dataType.equals("longblob")) {
               byte[] bytes = (byte[])data.get(key);
@@ -144,12 +145,13 @@
      List<String> updateList = new ArrayList<>();
      // 遍历匹配数据
      dataProperty.forEach((key,value)->{
//         log.info("数据类型 " + value.dataType);
         log.info("数据类型 " + value.dataType);
         if(null!=data.get(key) && !key.equals("id")) {
            if (value.dataType.equals("varchar") ||
               value.getDataType().equals("char")) {
               updateList.add(key + " = '" + data.get(key).toString() + "'");
            }else if(value.dataType.equals("text") ||
               value.dataType.equals("geometry") ||
               value.dataType.equals("mediumtext")) {
               byte[] bytes = (byte[])data.get(key);
               updateList.add(key + " = '" + new String(bytes) + "'");