Commit d0dfe97bb4ee408872c4bb356a9a96baa27ac87a
1 parent
0c0d85f2d7
Exists in
master
and in
6 other branches
update
Showing 1 changed file with 3 additions and 2 deletions
platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java
View file @
d0dfe97
| ... | ... | @@ -56,14 +56,15 @@ |
| 56 | 56 | public static void addSqlToQueue(String sql ,String sqlId) |
| 57 | 57 | { |
| 58 | 58 | SqlRequest request = new SqlRequest(); |
| 59 | - request.setSql(sql); | |
| 60 | 59 | try { |
| 61 | - request.setSqlId(Base64.encodeBase64String(sqlId.getBytes("utf-8"))); | |
| 60 | + request.setSql(Base64.encodeBase64String(sql.getBytes("utf-8"))); | |
| 61 | + request.setSqlId(sqlId); | |
| 62 | 62 | syncSqlQueue.add(request); |
| 63 | 63 | System.out.println("syncSqlQueue size = " + syncSqlQueue.size()); |
| 64 | 64 | } catch (UnsupportedEncodingException e) { |
| 65 | 65 | e.printStackTrace(); |
| 66 | 66 | } |
| 67 | + | |
| 67 | 68 | } |
| 68 | 69 | |
| 69 | 70 |