[feature] add doris

XiaoJiang521 · Oct 26, 2023 · 9a26af4 · 9a26af4
1 parent efcde6e
commit 9a26af4
Show file tree

Hide file tree

Showing 13 changed files with 14 additions and 688 deletions.
diff --git a/...lient/src/main/java/org/apache/seatunnel/datasource/classloader/DatasourceLoadConfig.java b/...lient/src/main/java/org/apache/seatunnel/datasource/classloader/DatasourceLoadConfig.java
@@ -95,11 +95,6 @@ public class DatasourceLoadConfig {
         classLoaderFactoryName.put(
                 "DORIS",
                 "com.apache.seatunnel.datasource.plugin.doris.jdbc.DorisJdbcDataSourceFactory");
-        classLoaderFactoryName.put(
-                "MONGODB", "com.apache.seatunnel.datasource.plugin.mongodb.MongoDataSourceFactory");
-        classLoaderFactoryName.put(
-                "MONGODB-CDC",
-                "com.apache.seatunnel.datasource.plugin.mongodbcdc.MongodbCDCDataSourceFactory");
 
         classLoaderJarName.put("JDBC-ORACLE", "datasource-jdbc-oracle-");
         classLoaderJarName.put("JDBC-CLICKHOUSE", "datasource-jdbc-clickhouse-");
@@ -120,8 +115,6 @@ public class DatasourceLoadConfig {
         classLoaderJarName.put("S3-REDSHIFT", "datasource-s3redshift-");
         classLoaderJarName.put("JDBC-STARROCKS", "datasource-jdbc-starrocks-");
         classLoaderJarName.put("DORIS", "datasource-jdbc-doris-");
-        classLoaderJarName.put("MONGODB", "datasource-mongodb-");
-        classLoaderJarName.put("MONGODB-CDC", "datasource-mongodbcdc-");
     }
 
     public static final Set<String> pluginSet =
@@ -139,9 +132,7 @@ public class DatasourceLoadConfig {
                     "S3",
                     "SqlServer-CDC",
                     "Doris",
-                    "StarRocks",
-                    "MongoDB",
-                    "MongoDB-CDC");
+                    "StarRocks");
 
     public static Map<String, DatasourceClassLoader> datasourceClassLoaders = new HashMap<>();
 

diff --git a/seatunnel-datasource/seatunnel-datasource-plugins/datasource-mongodb/pom.xml b/seatunnel-datasource/seatunnel-datasource-plugins/datasource-mongodb/pom.xml
diff --git a/.../src/main/java/com/apache/seatunnel/datasource/plugin/mongodb/MongoDataSoueceChannel.java b/.../src/main/java/com/apache/seatunnel/datasource/plugin/mongodb/MongoDataSoueceChannel.java
diff --git a/.../src/main/java/com/apache/seatunnel/datasource/plugin/mongodb/MongoDataSourceFactory.java b/.../src/main/java/com/apache/seatunnel/datasource/plugin/mongodb/MongoDataSourceFactory.java
diff --git a/...mongodb/src/main/java/com/apache/seatunnel/datasource/plugin/mongodb/MongoOptionRule.java b/...mongodb/src/main/java/com/apache/seatunnel/datasource/plugin/mongodb/MongoOptionRule.java
diff --git a/...src/main/java/com/apache/seatunnel/datasource/plugin/mongodb/MongoRequestParamsUtils.java b/...src/main/java/com/apache/seatunnel/datasource/plugin/mongodb/MongoRequestParamsUtils.java