修复已知问题

oracle-cdc/src/main/java/com/tbyf/cdcengine2/oracle/OracleCdcEngine.java

@@ -4,6 +4,8 @@ import com.tbyf.cdcengine2.core.AbstractCdcEngine;
 import com.tbyf.cdcengine2.core.Constants;
 import io.debezium.connector.oracle.OracleConnector;
 
+import java.sql.Connection;
+import java.sql.SQLException;
 import java.util.Arrays;
 import java.util.HashSet;
 import java.util.stream.Collectors;
@@ -31,10 +33,14 @@ public class OracleCdcEngine extends AbstractCdcEngine<OracleCdcEngine> {
 
         // 开启supplemental logging
         String url = OracleUtils.buildOracleJdbcUrl(props.getHost(), props.getPort(), props.getDbname());
-        SupplementalLoggingUtils.enableDBSupplementalLogging(OracleUtils.getConn(url, props.getUsername(), props.getPassword()));
-        SupplementalLoggingUtils.enableSchemaTablesSupplementalLogging(OracleUtils.getConn(url, props.getUsername(),
-                        props.getPassword()), schema,
+        try (Connection conn = OracleUtils.getConn(url, props.getUsername(), props.getPassword())) {
+
+            SupplementalLoggingUtils.enableDBSupplementalLogging(conn);
+            SupplementalLoggingUtils.enableSchemaTablesSupplementalLogging(conn, schema,
                     new HashSet<>(Arrays.asList(props.getCapturedTables().split(","))));
+        } catch (SQLException ex) {
+            throw new IllegalStateException("开启supplemental logging失败", ex);
+        }
     }
 
 }

sqlserver-cdc/src/main/java/com/tbyf/cdcengine2/sqlserver/SqlServerCdcEngine.java

@@ -37,19 +37,4 @@ public class SqlServerCdcEngine extends AbstractCdcEngine<SqlServerCdcEngine> {
         }
     }
 
-    public static void main(String[] args) {
-        SqlServerCdcEngineProperties props = new SqlServerCdcEngineProperties();
-        props.setHost("192.168.0.85");
-        props.setPort(1433);
-        props.setUsername("sa");
-        props.setPassword("1");
-        props.setDbName("dz_his");
-        props.setCapturedTables("BA_BAJY");
-
-        SqlServerCdcEngine engine = new SqlServerCdcEngine(props);
-        engine.onChange(record -> {
-            System.out.println(record);
-        });
-        engine.start();
-    }
 }