From 2229aae7559967170976bfc95c458b7fa7a21e74 Mon Sep 17 00:00:00 2001 From: liquanyu Date: Thu, 31 Aug 2017 15:42:49 +0800 Subject: [PATCH] update code --- .../operate/web/inteceptor/MybatisSqlInterceptor.java | 1 + .../lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java | 11 ++++------- 2 files changed, 5 insertions(+), 7 deletions(-) diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MybatisSqlInterceptor.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MybatisSqlInterceptor.java index 6f7815d..9d8c1e2 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MybatisSqlInterceptor.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MybatisSqlInterceptor.java @@ -137,6 +137,7 @@ public class MybatisSqlInterceptor implements Interceptor { { sql = sql.replaceFirst("\\(","(ID,"); sql = sql.substring(0,sql.lastIndexOf("(")+1)+list.get(0)+","+sql.substring(sql.lastIndexOf("(")+1,sql.length()); + System.out.println("add sync sql = "+sql); //发送要同步的sql SendMysqlSyncDatUtil.addSqlToQueue(sql, sqlId); sql = null; diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java index 3ddaea2..633abfd 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java @@ -63,13 +63,10 @@ public class SendMysqlSyncDatUtil implements InitializingBean { */ @Override public void afterPropertiesSet() throws Exception { - if ("2".equals(run_mode)) - { - System.out.println("init ........."); - Thread thread = new HandleThread(); - thread.setName("syncMysqlThread"); - thread.start(); - } + System.out.println("init ........."); + Thread thread = new HandleThread(); + thread.setName("syncMysqlThread"); + thread.start(); } -- 1.8.3.1