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(); } + }