[Optimization-3146][CDCSOURCE] Optimized CDCSOURCE from Mysql to Dori…

…s, with support for light_schema_change
DataLinkDC · Feb 6, 2024 · 257b002 · 257b002
1 parent 48f8e3c
commit 257b002
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/debezium/DataBaseType.java b/dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/debezium/DataBaseType.java
@@ -33,7 +33,7 @@ public enum DataBaseType {
     MYSQL("mysql"),
     SQLSERVER("sqlserver"),
     ORACLE("oracle"),
-    PostgresSQL("postgresql");
+    POSTGRESQL("postgresql");
 
     private String type;
 

diff --git a/dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/debezium/DebeziumCustomConverter.java b/dinky-cdc/dinky-cdc-core/src/main/java/org/dinky/cdc/debezium/DebeziumCustomConverter.java
@@ -73,7 +73,7 @@ public void configure(Properties properties) {
             case MYSQL:
             case SQLSERVER:
             case ORACLE:
-            case PostgresSQL:
+            case POSTGRESQL:
                 break;
             default:
                 String errMsg = "Not support " + databaseType + " database type";