zwjcool commented on issue #10323:
URL: https://github.com/apache/seatunnel/issues/10323#issuecomment-3743145417

   @zhangshenghang 
   需要修改以下内容(我目前测试正常运行)
   
   1.  connector-cdc-sqlserver-2.3.12.jar 
   2.  connector-jdbc-2.3.12.jar 
   
   # 更新jar
   **(1) 更新 connector-cdc-sqlserver**
   jar -uvf connector-cdc-sqlserver-2.3.12.jar 
org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerCatalog.class
   jar -uvf connector-cdc-sqlserver-2.3.12.jar 
org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/utils/TableDiscoveryUtils.class
   
   
   
   **// 
org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerCatalog.class
 改了93行:**
   ```
   protected String getListTableSql(String databaseName) {
       return "SELECT TABLE_SCHEMA, TABLE_NAME FROM [" + databaseName+ 
"].INFORMATION_SCHEMA.TABLES WHERE TABLE_TYPE = 'BASE TABLE'";
     }
   ```
     
   
//org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/utils/TableDiscoveryUtils.class
 改了65行 (connector-cdc-sqlserver.jar 和 connector-jdbc.jar 都要):
   ```
   for (String dbname: databaseNames) {
         try {
           paramJdbcConnection.query("SELECT * FROM [" + dbname+ 
"].INFORMATION_SCHEMA.TABLES WHERE TABLE_TYPE = 'BASE TABLE';", paramResultSet 
-> {
                 while (paramResultSet.next()) {
   ```
   
   
   **(2)更新connector -jdbc 否则sink 报错**
   
   jar -uvf connector-jdbc-2.3.12.jar  \
   
org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerCatalog.class
   
   ---请斧正---


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to