bug修复

datasync.properties

@@ -3,7 +3,7 @@ source.port=1521
 source.user=datacenter
 source.password=data
 source.dbname=ORCL
-sync.tables=DATACENTER.TEST_SYNC(ID)
+sync.tables=TEST_SYNC(ID)
 dest.host=10.99.44.13
 dest.port=11521
 dest.user=datacenter

src/main/java/com/tbyd/data/datasync/config/DebeziumProperties.java

@@ -2,7 +2,9 @@ package com.tbyd.data.datasync.config;
 
 import java.io.IOException;
 import java.io.InputStream;
+import java.util.Arrays;
 import java.util.Properties;
+import java.util.stream.Collectors;
 
 public class DebeziumProperties {
 
@@ -35,6 +37,10 @@ public class DebeziumProperties {
         debeziumProps.setProperty(DB_USER_KEY, DataSyncProperties.getSourceUser(dataSyncProps));
         debeziumProps.setProperty(DB_PASSWORD_KEY, DataSyncProperties.getSourcePassword(dataSyncProps));
         debeziumProps.setProperty(DB_DBNAME_KEY, DataSyncProperties.getSourceDbname(dataSyncProps));
-        debeziumProps.setProperty(CAPTURED_TABLES_KEY, DataSyncProperties.getSyncTableNames(dataSyncProps));
+        String schema = DataSyncProperties.getSourceUser(dataSyncProps).toUpperCase();
+        String tables = DataSyncProperties.getSyncTableNames(dataSyncProps);
+        String schemaTables = Arrays.stream(tables.split(",")).map(tableName -> schema + "." + tableName).collect(Collectors.joining(","));
+        debeziumProps.setProperty(CAPTURED_TABLES_KEY, schemaTables);
+        debeziumProps.setProperty("schema.include.list", schema);
     }
 }