From 285a46cd655b1c55fd0c7704e2c46f6660a5964a Mon Sep 17 00:00:00 2001
From: dengyixiang <dengyixiang@qq.com>
Date: Tue, 4 Jul 2023 15:10:43 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=AF=E6=8C=81json=E7=B1=BB=E5=9E=8B?=
 =?UTF-8?q?=E5=90=8C=E6=AD=A5?=
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 4d129a5a..14d4f179 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
@@ -173,6 +173,8 @@ public class MongoDBReader extends Reader {
                                 String tempArrayStr = Joiner.on(splitter).join(array);
                                 record.addColumn(new StringColumn(tempArrayStr));
                             }
+                        }else if ("json".equalsIgnoreCase(column.getString("type"))) {
+                            record.addColumn(new StringColumn(JSON.toJSONString(tempCol)));
                         } else {
                             record.addColumn(new StringColumn(tempCol.toString()));
                         }