optimize code

dbsyncer-connector/src/main/java/org/dbsyncer/connector/database/setter/RealSetter.java

@@ -0,0 +1,15 @@
+package org.dbsyncer.connector.database.setter;
+
+import org.dbsyncer.connector.database.AbstractSetter;
+
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+
+public class RealSetter extends AbstractSetter {
+
+    @Override
+    protected void set(PreparedStatement ps, int i, Object val) throws SQLException {
+        ps.setFloat(i, Float.parseFloat(String.valueOf(val)));
+    }
+
+}

dbsyncer-connector/src/main/java/org/dbsyncer/connector/enums/SetterEnum.java

@@ -30,7 +30,8 @@ public enum SetterEnum {
     // 很少使用
     TINYINT(Types.TINYINT, new TinyintSetter()),
     DOUBLE(Types.DOUBLE, new DoubleSetter()),
-    FLOAT(Types.FLOAT, new FloatSetter());
+    FLOAT(Types.FLOAT, new FloatSetter()),
+    REAL(Types.REAL, new RealSetter());
 
     private int type;
 

dbsyncer-manager/src/main/java/org/dbsyncer/manager/extractor/impl/FullExtractor.java

@@ -80,7 +80,9 @@ public class FullExtractor extends AbstractExtractor implements ApplicationListe
 
     private void doTask(Task task, Mapping mapping, List<TableGroup> list) {
         // 记录开始时间
-        task.setBeginTime(System.currentTimeMillis());
+        long now = System.currentTimeMillis();
+        task.setBeginTime(now);
+        task.setEndTime(now);
         flush(task);
 
         for (TableGroup t : list) {

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

@@ -232,10 +232,13 @@ public class ParserFactory implements Parser {
         Meta meta = getMeta(task.getId());
         meta.getFail().getAndAdd(fail);
         meta.getSuccess().getAndAdd(success);
+        // print process
+        logger.info("任务:{}, 成功:{}, 失败:{}", task.getId(), meta.getSuccess(), meta.getFail());
 
         // TODO 记录错误日志
 
         // 发布刷新事件给FullExtractor
+        task.setEndTime(System.currentTimeMillis());
         applicationContext.publishEvent(new RefreshEvent(applicationContext, task));
     }