From 5734d3109549c0e10aed91bc506bac170d0f0240 Mon Sep 17 00:00:00 2001
From: "zhenyu.han" <478715809@qq.com>
Date: Thu, 7 Jul 2022 11:39:51 +0800
Subject: [PATCH 1/2] =?UTF-8?q?=E5=A6=82=E6=9E=9C=E7=94=A8=E6=88=B7?=
 =?UTF-8?q?=E6=B2=A1=E6=9C=89=E5=AE=9A=E4=B9=89=E5=AD=97=E6=AE=B5=E7=B1=BB?=
 =?UTF-8?q?=E5=9E=8B=E4=BF=9D=E7=95=99=E4=B8=80=E4=B8=AA=E9=BB=98=E8=AE=A4?=
 =?UTF-8?q?=E5=80=BC=E4=B8=BAstring?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../datax/plugin/writer/mongodbwriter/MongoDBWriter.java       | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/mongodbwriter/src/main/java/com/alibaba/datax/plugin/writer/mongodbwriter/MongoDBWriter.java b/mongodbwriter/src/main/java/com/alibaba/datax/plugin/writer/mongodbwriter/MongoDBWriter.java
index 66c75078..28f4245c 100644
--- a/mongodbwriter/src/main/java/com/alibaba/datax/plugin/writer/mongodbwriter/MongoDBWriter.java
+++ b/mongodbwriter/src/main/java/com/alibaba/datax/plugin/writer/mongodbwriter/MongoDBWriter.java
@@ -156,6 +156,9 @@ public class MongoDBWriter extends Writer{
                 for(int i = 0; i < record.getColumnNumber(); i++) {
 
                     String type = columnMeta.getJSONObject(i).getString(KeyConstant.COLUMN_TYPE);
+                    if(type==null) {
+                        type = "string";
+                    }
                     //空记录处理
                     if (Strings.isNullOrEmpty(record.getColumn(i).asString())) {
                         if (KeyConstant.isArrayType(type.toLowerCase())) {

From 8509d56fe2110d65b2689c1f068419c65469296e Mon Sep 17 00:00:00 2001
From: hanzhenyu <478715809@qq.com>
Date: Fri, 22 Jul 2022 17:04:17 +0800
Subject: [PATCH 2/2] =?UTF-8?q?=E5=85=BC=E5=AE=B9document=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E7=B1=BB=E5=9E=8B=E7=9A=84=E8=AF=BB=E5=86=99?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../datax/plugin/reader/mongodbreader/MongoDBReader.java        | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/mongodbreader/src/main/java/com/alibaba/datax/plugin/reader/mongodbreader/MongoDBReader.java b/mongodbreader/src/main/java/com/alibaba/datax/plugin/reader/mongodbreader/MongoDBReader.java
index ba7f07f4..bc7c9b2b 100644
--- a/mongodbreader/src/main/java/com/alibaba/datax/plugin/reader/mongodbreader/MongoDBReader.java
+++ b/mongodbreader/src/main/java/com/alibaba/datax/plugin/reader/mongodbreader/MongoDBReader.java
@@ -162,6 +162,8 @@ public class MongoDBReader extends Reader {
                         record.addColumn(new LongColumn((Integer) tempCol));
                     }else if (tempCol instanceof Long) {
                         record.addColumn(new LongColumn((Long) tempCol));
+                    }else if (tempCol instanceof Document) {//兼容document数据类型
+                        record.addColumn(new StringColumn(((Document) tempCol).toJson()));
                     } else {
                         if(KeyConstant.isArrayType(column.getString(KeyConstant.COLUMN_TYPE))) {
                             String splitter = column.getString(KeyConstant.COLUMN_SPLITTER);