瀏覽代碼

修复表字段映射关系为空

AE86 2 年之前
父節點
當前提交
46cb23bf93

+ 3 - 0
dbsyncer-connector/src/main/java/org/dbsyncer/connector/AbstractConnector.java

@@ -75,6 +75,9 @@ public abstract class AbstractConnector {
         for (Map row : config.getData()) {
             // 根据目标字段类型转换值
             for (Field f : config.getFields()) {
+                if(null == f){
+                    continue;
+                }
                 // 根据字段类型转换值
                 final ValueMapper valueMapper = mappers.get(f.getType());
                 if (null != valueMapper) {

+ 2 - 2
dbsyncer-parser/src/main/java/org/dbsyncer/parser/model/Picker.java

@@ -78,10 +78,10 @@ public class Picker {
     }
 
     public List<Field> getTargetFields() {
-        return targetFields;
+        return targetFields.stream().filter(f -> null != f).collect(Collectors.toList());
     }
 
     public Map<String, Field> getTargetFieldMap() {
-        return targetFields.stream().collect(Collectors.toMap(Field::getName, f -> f, (k1, k2) -> k1));
+        return getTargetFields().stream().collect(Collectors.toMap(Field::getName, f -> f, (k1, k2) -> k1));
     }
 }