From 553dd70b13f6aa0194db34d3b686235d2a5dfd29 Mon Sep 17 00:00:00 2001
From: zhongrj <646384940@qq.com>
Date: Mon, 01 Apr 2024 17:14:55 +0800
Subject: [PATCH] 表同步修改
---
src/main/java/org/springblade/binlog/listener/TourBinLogListener.java | 6 ++++--
1 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/src/main/java/org/springblade/binlog/listener/TourBinLogListener.java b/src/main/java/org/springblade/binlog/listener/TourBinLogListener.java
index 4434f25..eb39319 100644
--- a/src/main/java/org/springblade/binlog/listener/TourBinLogListener.java
+++ b/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) + "'");
--
Gitblit v1.9.3