(seatunnel) branch dev updated: [Fix][Connector-V2][JDBC] Fix duplicate column error when fetching SQL Server metadata with multiple extended properties (#11374)

[lidongdai]

This is an automated email from the ASF dual-hosted git repository.

davidzollo pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new e907b63ca5 [Fix][Connector-V2][JDBC] Fix duplicate column error when 
fetching SQL Server metadata with multiple extended properties (#11374)
e907b63ca5 is described below

commit e907b63ca529a1fea0e49d3acf850408ce90f15e
Author: zhangweiwen <z...@outlook.com>
AuthorDate: Sat Aug 1 15:17:58 2026 +0800

    [Fix][Connector-V2][JDBC] Fix duplicate column error when fetching SQL 
Server metadata with multiple extended properties (#11374)
    
    Co-authored-by: lyzhangweiw <lyzhangw...@szlanyou.com>
---
 .../connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerCatalog.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerCatalog.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerCatalog.java
index e8576529f9..e6c0966c08 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerCatalog.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerCatalog.java
@@ -54,8 +54,8 @@ public class SqlServerCatalog extends AbstractJdbcCatalog {
                     + "FROM sys.tables tbl\n"
                     + "    INNER JOIN sys.columns col ON tbl.object_id = 
col.object_id\n"
                     + "    LEFT JOIN sys.types types ON col.system_type_id = 
types.user_type_id\n"
-                    + "    LEFT JOIN sys.extended_properties ext ON 
ext.major_id = col.object_id AND ext.minor_id = col.column_id\n"
-                    + "    LEFT JOIN sys.default_constraints def ON 
col.default_object_id = def.object_id AND ext.minor_id = col.column_id AND 
ext.name = 'MS_Description'\n"
+                    + "    LEFT JOIN sys.extended_properties ext ON 
ext.major_id = col.object_id AND ext.minor_id = col.column_id AND ext.name = 
'MS_Description'\n"
+                    + "    LEFT JOIN sys.default_constraints def ON 
col.default_object_id = def.object_id\n"
                     + "WHERE schema_name(tbl.schema_id) = '%s' %s\n"
                     + "ORDER BY tbl.name, col.column_id";