add readNum

dbsyncer-biz/src/main/java/org/dbsyncer/biz/checker/AbstractChecker.java

@@ -6,7 +6,7 @@ import org.dbsyncer.biz.PluginService;
 import org.dbsyncer.common.util.CollectionUtils;
 import org.dbsyncer.common.util.JsonUtil;
 import org.dbsyncer.connector.config.Filter;
-import org.dbsyncer.parser.convert.Convert;
+import org.dbsyncer.parser.model.Convert;
 import org.dbsyncer.parser.model.AbstractConfigModel;
 import org.dbsyncer.parser.model.ConfigModel;
 import org.dbsyncer.plugin.config.Plugin;

dbsyncer-manager/src/main/java/org/dbsyncer/manager/template/impl/OperationTemplate.java

@@ -76,7 +76,7 @@ public final class OperationTemplate extends AbstractTemplate {
 
         // 2、持久化
         Map<String, Object> params = ConfigModelUtil.convertModelToMap(model);
-        logger.info("params:{}", params);
+        logger.debug("params:{}", params);
         Handler handler = config.getHandler();
         Assert.notNull(handler, "Handler can not be null.");
         handler.execute(new OperationCallBack(storageService, StorageConstant.CONFIG, params));
@@ -98,7 +98,7 @@ public final class OperationTemplate extends AbstractTemplate {
         cacheService.putIfAbsent(groupId, new Group());
         Group group = cacheService.get(groupId, Group.class);
         group.addIfAbsent(id);
-        logger.info("Put the model [{}] for {} group into cache.", id, groupId);
+        logger.debug("Put the model [{}] for {} group into cache.", id, groupId);
     }
 
     public void remove(OperationConfig config) {

dbsyncer-parser/src/main/java/org/dbsyncer/parser/ParserFactory.java

@@ -13,7 +13,7 @@ import org.dbsyncer.connector.config.*;
 import org.dbsyncer.connector.enums.ConnectorEnum;
 import org.dbsyncer.connector.enums.FilterEnum;
 import org.dbsyncer.connector.enums.OperationEnum;
-import org.dbsyncer.parser.convert.Convert;
+import org.dbsyncer.parser.model.Convert;
 import org.dbsyncer.parser.enums.ConvertEnum;
 import org.dbsyncer.parser.enums.ParserEnum;
 import org.dbsyncer.parser.model.*;

dbsyncer-parser/src/main/java/org/dbsyncer/parser/enums/ConvertEnum.java

@@ -21,7 +21,7 @@ public enum ConvertEnum {
     /**
      * 默认系统时间
      */
-    DEFAULT_SYSTEM_TIMESTAMP("DEFAULT_SYSTEM_TIMESTAMP", "系统时间", 0, new DefaultTimestampHandler()),
+    DEFAULT_SYSTEM_TIMESTAMP("DEFAULT_SYSTEM_TIMESTAMP", "默认系统时间", 0, new DefaultTimestampHandler()),
     /**
      * 替换
      */

dbsyncer-parser/src/main/java/org/dbsyncer/parser/model/AbstractConfigModel.java

@@ -1,7 +1,6 @@
 package org.dbsyncer.parser.model;
 
 import org.dbsyncer.connector.config.Filter;
-import org.dbsyncer.parser.convert.Convert;
 import org.dbsyncer.plugin.config.Plugin;
 
 import java.util.List;

dbsyncer-parser/src/main/java/org/dbsyncer/parser/convert/Convert.java → dbsyncer-parser/src/main/java/org/dbsyncer/parser/model/Convert.java

@@ -1,4 +1,4 @@
-package org.dbsyncer.parser.convert;
+package org.dbsyncer.parser.model;
 
 import org.dbsyncer.parser.enums.ConvertEnum;
 

dbsyncer-parser/src/main/java/org/dbsyncer/parser/model/Mapping.java

@@ -40,10 +40,10 @@ public class Mapping extends AbstractConfigModel {
     // 元信息ID
     private String metaId;
 
-    // 一次最多读取数
+    // 每次读取数
     private int readNum = 10000;
 
-    // 批量数
+    // 每次写入数
     private int batchNum = 200;
 
     // 线程数

dbsyncer-parser/src/main/java/org/dbsyncer/parser/util/ConvertUtil.java

@@ -1,7 +1,7 @@
 package org.dbsyncer.parser.util;
 
 import org.dbsyncer.common.util.CollectionUtils;
-import org.dbsyncer.parser.convert.Convert;
+import org.dbsyncer.parser.model.Convert;
 import org.dbsyncer.parser.enums.ConvertEnum;
 
 import java.util.List;

dbsyncer-parser/src/main/java/org/dbsyncer/parser/util/PickerUtil.java

@@ -2,7 +2,6 @@ package org.dbsyncer.parser.util;
 
 import org.dbsyncer.common.util.CollectionUtils;
 import org.dbsyncer.connector.config.Field;
-import org.dbsyncer.parser.convert.Convert;
 import org.dbsyncer.parser.model.FieldMapping;
 import org.dbsyncer.parser.model.Picker;
 

dbsyncer-web/src/main/resources/templates/mapping/editFull.html

@@ -7,6 +7,12 @@
 
     <div class="form-group">
         <div class="row">
+            <div class="col-md-4">
+                <label class="col-sm-3 control-label text-right">读取<strong class="driverVerifcateRequired">*</strong></label>
+                <div class="col-sm-9">
+                    <input type="number" name="readNum" class="form-control" min="1" dbsyncer-valid="require" th:value="${mapping?.readNum}">
+                </div>
+            </div>
             <div class="col-md-4">
                 <label class="col-sm-3 control-label text-right">线程<strong class="driverVerifcateRequired">*</strong></label>
                 <div class="col-sm-9">
@@ -14,7 +20,7 @@
                 </div>
             </div>
             <div class="col-md-4">
-                <label class="col-sm-3 control-label text-right">批量<strong class="driverVerifcateRequired">*</strong></label>
+                <label class="col-sm-3 control-label text-right">写入<strong class="driverVerifcateRequired">*</strong></label>
                 <div class="col-sm-9">
                     <input type="number" name="batchNum" class="form-control" min="1" dbsyncer-valid="require" th:value="${mapping?.batchNum}">
                 </div>