修复转换字段缺失问题

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

@@ -280,8 +280,10 @@ public abstract class AbstractDatabaseConnector implements Database {
             // 记录错误数据
             result.getFailData().add(data);
             result.getFail().set(1);
-            result.getError().append(e.getMessage()).append(System.lineSeparator());
-            logger.error(e.getMessage());
+            result.getError().append("sql:").append(sql).append(", ")
+                    .append("data:").append(data).append(", ")
+                    .append("error:").append(e.getMessage()).append(System.lineSeparator());
+            logger.error("sql:{}, data:{}, error:{}", sql, data, e.getMessage());
         } finally {
             // 释放连接
             this.close(jdbcTemplate);

dbsyncer-manager/src/main/java/org/dbsyncer/manager/config/FieldPicker.java

@@ -38,7 +38,7 @@ public class FieldPicker {
         if (!CollectionUtils.isEmpty(list)) {
             Map<String, Object> data = new HashMap<>(indexSize);
             final int size = list.size() - 1;
-            index.parallelStream().forEach(node -> {
+            index.forEach(node -> {
                 if (node.i <= size) {
                     data.put(node.name, list.get(node.i));
                 }

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

@@ -240,7 +240,7 @@ public class ParserFactory implements Parser {
 
     @Override
     public void execute(Mapping mapping, TableGroup tableGroup, RowChangedEvent rowChangedEvent) {
-        logger.info("解析数据=> tableName:{}, event:{}, before:{}, after:{}", rowChangedEvent.getTableName(), rowChangedEvent.getEvent(),
+        logger.info("Table[{}] {}, before:{}, after:{}", rowChangedEvent.getTableName(), rowChangedEvent.getEvent(),
                 rowChangedEvent.getBefore(), rowChangedEvent.getAfter());
         final String metaId = mapping.getMetaId();