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]