Skip to content

Commit a26621f

Browse files
ll076110OT-XY
andauthored
[hotfix-#1512][mongodb] Fix the bug that mongodb supports constants (#1513)
Co-authored-by: OT-XY <[email protected]>
1 parent 8179a6c commit a26621f

File tree

1 file changed

+5
-9
lines changed

1 file changed

+5
-9
lines changed

chunjun-connectors/chunjun-connector-mongodb/src/main/java/com/dtstack/chunjun/connector/mongodb/converter/MongodbColumnConverter.java

Lines changed: 5 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -99,17 +99,13 @@ protected MongoSerializationConverter wrapIntoNullableMongodbExternalConverter(
9999
public RowData toInternal(Document document) {
100100
List<FieldConf> fieldList = commonConf.getColumn();
101101
ColumnRowData result = new ColumnRowData(fieldList.size());
102-
int convertIndex = 0;
103-
for (FieldConf fieldConf : fieldList) {
102+
for (int i = 0; i < fieldList.size(); i++) {
104103
AbstractBaseColumn baseColumn = null;
105-
if (StringUtils.isNullOrWhitespaceOnly(fieldConf.getValue())) {
106-
Object field = document.get(fieldConf.getName());
107-
baseColumn =
108-
(AbstractBaseColumn)
109-
toInternalConverters.get(convertIndex).deserialize(field);
110-
convertIndex++;
104+
if (StringUtils.isNullOrWhitespaceOnly(fieldList.get(i).getValue())) {
105+
Object field = document.get(fieldList.get(i).getName());
106+
baseColumn = (AbstractBaseColumn) toInternalConverters.get(i).deserialize(field);
111107
}
112-
result.addField(assembleFieldProps(fieldConf, baseColumn));
108+
result.addField(assembleFieldProps(fieldList.get(i), baseColumn));
113109
}
114110
return result;
115111
}

0 commit comments

Comments
 (0)