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 ++++--
src/main/resources/application-dev.yml | 3 ++-
src/main/resources/application-prod.yml | 2 +-
src/main/resources/application-test.yml | 3 ++-
4 files changed, 9 insertions(+), 5 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) + "'");
diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml
index cc6ab57..5b05fb3 100644
--- a/src/main/resources/application-dev.yml
+++ b/src/main/resources/application-dev.yml
@@ -60,7 +60,8 @@
username: root
password: 1qaz@WSX3edc
db: jczz # 监听数据库
- table: jczz_house,jczz_household,jczz_place
+ table: jczz_house,jczz_household,jczz_house_rental,jczz_user_house_label,jczz_label,jczz_place,jczz_place_check,jczz_place_door,jczz_place_ext,jczz_place_poi_label,jczz_place_practitioner,jczz_police_affairs_grid,jczz_task_label_reporting_event,jczz_patrol_group,jczz_patrol_group_item,jczz_patrol_record,blade_attach_data,jczz_category,jczz_grid,jczz_backblast_pub_record,jczz_backblast_warn_han_rec,jczz_dispute_record,jczz_police_alarm_records,jczz_task_residence_permit_apply
+ # table: blade_attach_data
enabled: false
# 目标数据库
from:
diff --git a/src/main/resources/application-prod.yml b/src/main/resources/application-prod.yml
index 71b0796..e591993 100644
--- a/src/main/resources/application-prod.yml
+++ b/src/main/resources/application-prod.yml
@@ -47,7 +47,7 @@
username: root
password: 1qaz@WSX3edc
db: jczz # 监听数据库
- table: jczz_house,jczz_household,jczz_house_rental,jczz_user_house_label,jczz_label,jczz_place,jczz_place_check,jczz_place_door,jczz_place_ext,jczz_place_poi_label,jczz_place_practitioner,jczz_police_affairs_grid,jczz_task_label_reporting_event,jczz_patrol_group,jczz_patrol_group_item,jczz_patrol_record,blade_attach_data,jczz_category,jczz_grid
+ table: jczz_house,jczz_household,jczz_house_rental,jczz_user_house_label,jczz_label,jczz_place,jczz_place_check,jczz_place_door,jczz_place_ext,jczz_place_poi_label,jczz_place_practitioner,jczz_police_affairs_grid,jczz_task_label_reporting_event,jczz_patrol_group,jczz_patrol_group_item,jczz_patrol_record,blade_attach_data,jczz_category,jczz_grid,jczz_backblast_pub_record,jczz_backblast_warn_han_rec,jczz_dispute_record,jczz_police_alarm_records,jczz_task_residence_permit_apply
# table: blade_attach_data
enabled: true
# 目标数据库
diff --git a/src/main/resources/application-test.yml b/src/main/resources/application-test.yml
index 0939969..a1de872 100644
--- a/src/main/resources/application-test.yml
+++ b/src/main/resources/application-test.yml
@@ -48,7 +48,8 @@
username: root
password: root
db: jczz_test
- table: jczz_house,jczz_household,jczz_place,jczz_place_ext,blade_attach_data
+ table: jczz_house,jczz_household,jczz_house_rental,jczz_user_house_label,jczz_label,jczz_place,jczz_place_check,jczz_place_door,jczz_place_ext,jczz_place_poi_label,jczz_place_practitioner,jczz_police_affairs_grid,jczz_task_label_reporting_event,jczz_patrol_group,jczz_patrol_group_item,jczz_patrol_record,blade_attach_data,jczz_category,jczz_grid,jczz_backblast_pub_record,jczz_backblast_warn_han_rec,jczz_dispute_record,jczz_police_alarm_records,jczz_task_residence_permit_apply
+ # table: blade_attach_data
enabled: true
# 目标数据库
from:
--
Gitblit v1.9.3