From ddb563f2a4d233823d00bccf209875f1ad1a972f Mon Sep 17 00:00:00 2001 From: liquanyu Date: Thu, 8 Mar 2018 11:31:37 +0800 Subject: [PATCH] =?UTF-8?q?=E5=90=8C=E6=AD=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../platform/operate/web/inteceptor/MysqlDataInterceptor.java | 9 ++++----- .../lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java | 4 +--- 2 files changed, 5 insertions(+), 8 deletions(-) diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MysqlDataInterceptor.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MysqlDataInterceptor.java index 385d8f7..f817795 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MysqlDataInterceptor.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MysqlDataInterceptor.java @@ -3,7 +3,6 @@ package com.lyms.platform.operate.web.inteceptor; import com.lyms.platform.biz.service.SyncDataService; import com.lyms.platform.common.utils.ExceptionUtils; -import com.lyms.platform.operate.web.utils.SendMysqlSyncDatUtil; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang.StringUtils; import org.apache.ibatis.executor.Executor; @@ -78,8 +77,9 @@ public class MysqlDataInterceptor implements Interceptor { if (isSyncTable(sql)) { System.out.println("==============delete or update sync sql = " + sql); + //syncDataService.savePostMysql(sql,sqlId); sql = null; - syncDataService.savePostMysql(sql,sqlId); + } } else if ("insert".equals(sqlCommandType.toLowerCase()) ) @@ -100,10 +100,9 @@ public class MysqlDataInterceptor implements Interceptor { if (returnValue != null && returnValue instanceof ArrayList) { List list = (ArrayList)returnValue; - if (CollectionUtils.isNotEmpty(list)) - { + if (CollectionUtils.isNotEmpty(list)) { System.out.println("============add sync sql = " + sql); - syncDataService.savePostMysql(sql,sqlId); +// syncDataService.savePostMysql(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 633abfd..635e684 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 @@ -14,7 +14,6 @@ import java.util.HashSet; import java.util.Set; import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; -import java.util.concurrent.TimeUnit; /** * Created by lqy @@ -23,9 +22,8 @@ import java.util.concurrent.TimeUnit; @Component public class SendMysqlSyncDatUtil implements InitializingBean { - public static final String run_mode = PropertiesUtils.getPropertyValue("run.mode"); - private static BlockingQueue syncSqlQueue = new LinkedBlockingQueue(500); + private static BlockingQueue syncSqlQueue = new LinkedBlockingQueue(200); //配置文件中配置的要同步的区域的url地址 private static Set urls = new HashSet<>(); -- 1.8.3.1