fix CH sql error

ApsaraDB · May 25, 2022 · 8b64fcb · 8b64fcb
1 parent 4121d9a
commit 8b64fcb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/class-3/src/main/java/com/aliyun/polardbx/demo/class3/XCanalCHDemo.java b/class-3/src/main/java/com/aliyun/polardbx/demo/class3/XCanalCHDemo.java
@@ -118,7 +118,7 @@ private static void printColumn(Statement statement, List<Column> columns) {
             System.out.println(column.getName() + " : " + column.getValue() + "    update=" + column.getUpdated());
             nameColumnMap.put(column.getName(), column);
         }
-        String sql = "INSERT INTO test(id, name) values(" + nameColumnMap.get("id").getValue() + ",\"" + nameColumnMap.get("name").getValue() + "\")";
+        String sql = "INSERT INTO test(id, name) values(" + nameColumnMap.get("id").getValue() + ",'" + nameColumnMap.get("name").getValue() + "')";
         try {
             statement.executeUpdate(sql);
             System.out.println("SQL done: " + sql);