add meta

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

@@ -12,7 +12,7 @@ public class ConfigModel {
     private String id;
 
     /**
-     * connector/mapping/tableGroup
+     * connector/mapping/tableGroup/meta
      *
      * @see ConfigConstant
      */
@@ -67,4 +67,4 @@ public class ConfigModel {
         this.updateTime = updateTime;
         return this;
     }
-}
+}

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

@@ -0,0 +1,65 @@
+package org.dbsyncer.parser.model;
+
+import java.util.Map;
+import java.util.concurrent.atomic.AtomicInteger;
+
+/**
+ * <p>驱动同步元信息</p>
+ * <pre>
+ *     全量同步: 存放分页数
+ *     增量同步:定时>时间戳; 日志>binlogFileName/binlogPosition/主从节点信息等
+ * </pre>
+ *
+ * @author AE86
+ * @version 1.0.0
+ * @date 2020/04/21 16:19
+ */
+public class Meta extends ConfigModel {
+
+    private AtomicInteger total;
+    private AtomicInteger success;
+    private AtomicInteger fail;
+    private Map<String, String> map;
+
+    public Meta() {
+    }
+
+    public Meta(AtomicInteger total, AtomicInteger success, AtomicInteger fail, Map<String, String> map) {
+        this.total = total;
+        this.success = success;
+        this.fail = fail;
+        this.map = map;
+    }
+
+    public AtomicInteger getTotal() {
+        return total;
+    }
+
+    public void setTotal(AtomicInteger total) {
+        this.total = total;
+    }
+
+    public AtomicInteger getSuccess() {
+        return success;
+    }
+
+    public void setSuccess(AtomicInteger success) {
+        this.success = success;
+    }
+
+    public AtomicInteger getFail() {
+        return fail;
+    }
+
+    public void setFail(AtomicInteger fail) {
+        this.fail = fail;
+    }
+
+    public Map<String, String> getMap() {
+        return map;
+    }
+
+    public void setMap(Map<String, String> map) {
+        this.map = map;
+    }
+}

dbsyncer-storage/src/main/java/org/dbsyncer/storage/constant/ConfigConstant.java

@@ -23,5 +23,6 @@ public class ConfigConstant {
     public static final String CONNECTOR = "connector";
     public static final String MAPPING = "mapping";
     public static final String TABLE_GROUP = "tableGroup";
+    public static final String META = "meta";
 
 }