From 9bb35f73c242431171f8e065c971e0ae81ddbd27 Mon Sep 17 00:00:00 2001 From: liquanyu Date: Tue, 24 Apr 2018 16:46:36 +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 --- .../lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 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 f49c643..4d1a6f8 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 @@ -12,6 +12,7 @@ import org.springframework.beans.factory.InitializingBean; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; +import java.io.UnsupportedEncodingException; import java.util.HashSet; import java.util.Set; import java.util.concurrent.BlockingQueue; @@ -56,9 +57,13 @@ public class SendMysqlSyncDatUtil implements InitializingBean { { SqlRequest request = new SqlRequest(); request.setSql(sql); - request.setSqlId(sqlId); - syncSqlQueue.add(request); - System.out.println("syncSqlQueue size = " + syncSqlQueue.size()); + try { + request.setSqlId(Base64.encodeBase64String(sqlId.getBytes("utf-8"))); + syncSqlQueue.add(request); + System.out.println("syncSqlQueue size = " + syncSqlQueue.size()); + } catch (UnsupportedEncodingException e) { + e.printStackTrace(); + } } -- 1.8.3.1