zwjcool commented on issue #10323:
URL: https://github.com/apache/seatunnel/issues/10323#issuecomment-3742488277
@zhangshenghang 我自己对代码进行了修正目前运行还没有测出问题,需要修正2个jdbc包
- connector-cdc-sqlserver-2.3.12.jar
- connector-jdbc-2.3.12.jar
> 因为 connector-cdc-sqlserver-2.3.12.jar 好像 封装了 connector-jdbc-2.3.12.jar
的内容，
> 而 connector-jdbc-2.3.12.jar 是sink 配置需要 使用的jar包，也许是（
plugin-mapping.properties的映射），如果单独修改 connector-cdc-sqlserver-2.3.12.jar
，执行到sink 的时候报同样的错误，
**我的修改如下：**
**（1）对
org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerCatalog.class**改了93行
（connector-cdc-sqlserver-2.3.12.jar 和 connector-jdbc-2.3.12.jar 都要改）
```
protected String getListTableSql(String databaseName) {
return "SELECT TABLE_SCHEMA, TABLE_NAME FROM [" + databaseName+
"].INFORMATION_SCHEMA.TABLES WHERE TABLE_TYPE = 'BASE TABLE'";
}
```
//（2）org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/utils/TableDiscoveryUtils.class
改了63行 （connector-cdc-sqlserver-2.3.12.jar）
for (String dbName : databaseNames) {
try {
jdbc.query("SELECT * FROM [" + dbName +
"].INFORMATION_SCHEMA.TABLES WHERE TABLE_TYPE = 'BASE TABLE';", rs -> {
while (rs.next()) {
----------以上请斧正-----------
--
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]
