From d0dfe97bb4ee408872c4bb356a9a96baa27ac87a Mon Sep 17 00:00:00 2001 From: liquanyu Date: Sat, 28 Apr 2018 13:03:18 +0800 Subject: [PATCH] update --- .../com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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 4d1a6f8..aec9e4f 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 @@ -56,14 +56,15 @@ public class SendMysqlSyncDatUtil implements InitializingBean { public static void addSqlToQueue(String sql ,String sqlId) { SqlRequest request = new SqlRequest(); - request.setSql(sql); try { - request.setSqlId(Base64.encodeBase64String(sqlId.getBytes("utf-8"))); + request.setSql(Base64.encodeBase64String(sql.getBytes("utf-8"))); + request.setSqlId(sqlId); syncSqlQueue.add(request); System.out.println("syncSqlQueue size = " + syncSqlQueue.size()); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } + } -- 1.8.3.1