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 501a200..dc8ed53 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 @@ -129,10 +129,7 @@ public class MybatisSqlInterceptor implements Interceptor { } else { if (obj != null) { value = obj.toString(); - } else if ("java.util.Date".equals(javaType)){ - value = "null"; - } - else + } else { value = "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 c78f4a2..6641efd 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 @@ -17,13 +17,15 @@ import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.TimeUnit; /** - * Created by Administrator on 2017-04-25. + * Created by lqy + * on 2017-04-25. */ @Component public class SendMysqlSyncDatUtil implements InitializingBean { private static BlockingQueue syncSqlQueue = new LinkedBlockingQueue(); + //配置文件中配置的要同步的区域的url地址 private static Set urls = new HashSet<>(); static { @@ -38,6 +40,11 @@ public class SendMysqlSyncDatUtil implements InitializingBean { } } + /** + * 把要同步的sql添加到阻塞队列中 + * @param sql + * @param sqlId + */ public static void addSqlToQueue(String sql ,String sqlId) { SqlRequest request = new SqlRequest(); @@ -46,14 +53,24 @@ public class SendMysqlSyncDatUtil implements InitializingBean { syncSqlQueue.add(request); } + /** + * 初始化启动发送sql的线程 + * @throws Exception + */ @Override public void afterPropertiesSet() throws Exception { System.out.println("init ........."); - new HandleThread().start(); + Thread thread = new HandleThread(); + thread.setName("syncMysqlThread"); + thread.start(); } + /** + * 从队列中取出一个个取出来发送 + */ private class HandleThread extends Thread { + @Override public void run() { SqlRequest request = null;