github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-02 04:59:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge 8509d56fe2 into 0824b45c5e

Browse Source
This commit is contained in:
hzy9981 2025-04-10 16:21:37 +08:00 committed by GitHub
commit 969e16d69f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 5 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);

3
mongodbwriter/src/main/java/com/alibaba/datax/plugin/writer/mongodbwriter/MongoDBWriter.java
View File

@ -156,6 +156,9 @@ public class MongoDBWriter extends Writer{
for(int i = 0; i < record.getColumnNumber(); i++) { for(int i = 0; i < record.getColumnNumber(); i++) {
String type = columnMeta.getJSONObject(i).getString(KeyConstant.COLUMN_TYPE); String type = columnMeta.getJSONObject(i).getString(KeyConstant.COLUMN_TYPE);
if(type==null) {
type = "string";
}
//空记录处理 //空记录处理
if (Strings.isNullOrEmpty(record.getColumn(i).asString())) { if (Strings.isNullOrEmpty(record.getColumn(i).asString())) {
if (KeyConstant.isArrayType(type.toLowerCase())) { if (KeyConstant.isArrayType(type.toLowerCase())) {