github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-03 06:21:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

兼容document数据类型的读写

Browse Source
This commit is contained in:
hanzhenyu 2022-07-22 17:04:17 +08:00
parent 5734d31095
commit 8509d56fe2
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
mongodbreader/src/main/java/com/alibaba/datax/plugin/reader/mongodbreader/MongoDBReader.java
View File

@ -162,6 +162,8 @@ public class MongoDBReader extends Reader {
record.addColumn(new LongColumn((Integer) tempCol)); record.addColumn(new LongColumn((Integer) tempCol));
}else if (tempCol instanceof Long) { }else if (tempCol instanceof Long) {
record.addColumn(new LongColumn((Long) tempCol)); record.addColumn(new LongColumn((Long) tempCol));
}else if (tempCol instanceof Document) {//兼容document数据类型
record.addColumn(new StringColumn(((Document) tempCol).toJson()));
} else { } else {
if(KeyConstant.isArrayType(column.getString(KeyConstant.COLUMN_TYPE))) { if(KeyConstant.isArrayType(column.getString(KeyConstant.COLUMN_TYPE))) {
String splitter = column.getString(KeyConstant.COLUMN_SPLITTER); String splitter = column.getString(KeyConstant.COLUMN_SPLITTER);