fix

dbsyncer-connector/src/main/java/org/dbsyncer/connector/database/AbstractDatabaseConnector.java

@@ -254,21 +254,6 @@ public abstract class AbstractDatabaseConnector extends AbstractConnector implem
         return "";
     }
 
-    /**
-     * 获取架构名
-     *
-     * @param config
-     * @param quotation
-     * @return
-     */
-    protected String getSchema(DatabaseConfig config, String quotation) {
-        StringBuilder schema = new StringBuilder();
-        if (StringUtil.isNotBlank(config.getSchema())) {
-            schema.append(quotation).append(config.getSchema()).append(quotation).append(".");
-        }
-        return schema.toString();
-    }
-
     /**
      * 获取架构名
      *
@@ -524,6 +509,21 @@ public abstract class AbstractDatabaseConnector extends AbstractConnector implem
         return SqlBuilderEnum.getSqlBuilder(type).buildSql(config);
     }
 
+    /**
+     * 获取架构名
+     *
+     * @param config
+     * @param quotation
+     * @return
+     */
+    private String getSchema(DatabaseConfig config, String quotation) {
+        StringBuilder schema = new StringBuilder();
+        if (StringUtil.isNotBlank(config.getSchema())) {
+            schema.append(quotation).append(config.getSchema()).append(quotation).append(".");
+        }
+        return schema.toString();
+    }
+
     /**
      * 返回表主键
      *
@@ -550,6 +550,8 @@ public abstract class AbstractDatabaseConnector extends AbstractConnector implem
     }
 
     /**
+     * 数据转换
+     *
      * @param connection 连接
      * @param ps         参数构造器
      * @param fields     同步字段，例如[{name=ID, type=4}, {name=NAME, type=12}]

dbsyncer-web/src/main/resources/application.properties

@@ -7,7 +7,7 @@ server.servlet.session.timeout=1800
 server.servlet.context-path=/
 #dbsyncer.common.worker.id=1
 dbsyncer.web.task.scheduler.pool-size=8
-dbsyncer.web.task.executor.core-size=8
+dbsyncer.web.task.executor.core-size=10
 dbsyncer.web.task.executor.queue-capacity=1000
 
 #parser