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] =?UTF-8?q?=E5=85=BC=E5=AE=B9document=E6=95=B0=E6=8D=AE?=
 =?UTF-8?q?=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);