fix h2 sql error

WenchaoZeng · Dec 6, 2023 · 95a33cb · 95a33cb
1 parent 04b1080
commit 95a33cb
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 5 deletions.
diff --git a/note.txt b/note.txt
@@ -1,7 +1,6 @@
 待开发功能:
     针对常见的错误, 直接在控制台显示具体的错误, 不需要打印调用栈
     子查询模式下, 检查子查询的长度(只有第一个select才需要指定列名称, 后续select不需要指定列名称)
-    去掉h2数据库的支持?
 
 代码重构:
     Sql, 根据不同的语句类型, 拆分成不同的子类.

diff --git a/src/main/java/com/zwc/sqldataprocessor/SqlExecutor.java b/src/main/java/com/zwc/sqldataprocessor/SqlExecutor.java
@@ -159,7 +159,7 @@ static String renderSql(String sql, Map<String, DataList> tables, String databas
                         execRawSql(createTempTableSql, databaseName);
 
                         // 分批导入数据
-                        List<DataList> dataLists = table.split(10000);
+                        List<DataList> dataLists = table.split(1000);
                         for (DataList dataList : dataLists) {
                             String dataInsertSql = "insert into " + tempTableName + " ";
                             dataInsertSql += renderSelectSql(dataList, databaseName);
@@ -287,7 +287,7 @@ static String renderSelectSql(List<String> rowValues, DataList table) {
                     selectColumnFormat = "%s as `%s`";
                 } else {
                     value = value.replace("\\", "\\\\");
-                    value = value.replace("'", "\\'");
+                    value = value.replace("'", "''");
                     selectColumnFormat = "'%s' as `%s`";
                 }
             }
@@ -354,8 +354,7 @@ static String renderValueClause(List<String> rowValues, DataList table) {
                 if (value == null) {
                     values.add(null);
                 } else {
-                    value = value.replace("\\", "\\\\");
-                    value = value.replace("'", "\\'");
+                    value = value.replace("'", "''");
                     values.add("'" + value + "'");
                 }
             }