web datasource-postgresql-cdc] support web add pg cdc dadasourcehttps…

…://github.com/apache/seatunnel/issues/7437
apache · Aug 20, 2024 · 11553dd · 11553dd
1 parent 14a939c
commit 11553dd
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 13 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
@@ -30,18 +30,18 @@ public class DatasourceLoadConfig {
     public static final Map<String, String> classLoaderJarName;
     public static final String[] DEFAULT_PARENT_FIRST_PATTERNS =
             new String[] {
-                "java.",
-                "javax.xml",
-                "org.xml",
-                "org.w3c",
-                "scala.",
-                "javax.annotation.",
-                "org.slf4j",
-                "org.apache.log4j",
-                "org.apache.seatunnel.api",
-                "org.apache.logging",
-                "org.apache.commons",
-                "com.fasterxml.jackson"
+                    "java.",
+                    "javax.xml",
+                    "org.xml",
+                    "org.w3c",
+                    "scala.",
+                    "javax.annotation.",
+                    "org.slf4j",
+                    "org.apache.log4j",
+                    "org.apache.seatunnel.api",
+                    "org.apache.logging",
+                    "org.apache.commons",
+                    "com.fasterxml.jackson"
             };
 
     static {
@@ -78,6 +78,9 @@ public class DatasourceLoadConfig {
         classLoaderFactoryName.put(
                 "MYSQL-CDC",
                 "org.apache.seatunnel.datasource.plugin.cdc.mysql.MysqlCDCDataSourceFactory");
+        classLoaderFactoryName.put(
+                "POSTGRES-CDC",
+                "org.apache.seatunnel.datasource.plugin.cdc.postgresql.PostgresCDCDataSourceFactory");
         classLoaderFactoryName.put(
                 "S3", "org.apache.seatunnel.datasource.plugin.s3.S3DataSourceFactory");
         classLoaderFactoryName.put(
@@ -114,7 +117,7 @@ public class DatasourceLoadConfig {
 
         classLoaderJarName.put("SQLSERVER-CDC", "datasource-sqlserver-cdc-");
         classLoaderJarName.put("MYSQL-CDC", "datasource-mysql-cdc-");
-
+        classLoaderJarName.put("POSTGRES-CDC", "datasource-postgresql-cdc-");
         classLoaderJarName.put("ELASTICSEARCH", "datasource-elasticsearch-");
         classLoaderJarName.put("S3", "datasource-s3-");
         classLoaderJarName.put("HIVE", "datasource-hive-");
@@ -140,6 +143,7 @@ public class DatasourceLoadConfig {
                     "JDBC-TiDB",
                     "Kafka",
                     "MySQL-CDC",
+                    "POSTGRES-CDC",
                     "S3",
                     "SqlServer-CDC",
                     "StarRocks",

diff --git a/seatunnel-datasource/seatunnel-datasource-plugins/pom.xml b/seatunnel-datasource/seatunnel-datasource-plugins/pom.xml
@@ -48,6 +48,8 @@
         <module>datasource-jdbc-db2</module>
         <module>datasource-fakesource</module>
         <module>datasource-console</module>
+        <module>datasource-postgresql-cdc</module>
+
     </modules>
 
 </project>