seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-sqlserver/src/main/java/org/apache/seatunnel/datasource/plugin/sqlserver/jdbc/SqlServerDataSourceChannel.java [176:195]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            DatabaseMetaData metaData = connection.getMetaData();
            String primaryKey = getPrimaryKey(metaData, dbName, schemaName, tableName);
            try (ResultSet resultSet = metaData.getColumns(dbName, schemaName, tableName, null)) {
                while (resultSet.next()) {
                    TableField tableField = new TableField();
                    String columnName = resultSet.getString("COLUMN_NAME");
                    tableField.setPrimaryKey(false);
                    if (StringUtils.isNotBlank(primaryKey) && primaryKey.equals(columnName)) {
                        tableField.setPrimaryKey(true);
                    }
                    tableField.setName(columnName);
                    String typeString = resultSet.getString("TYPE_NAME");
                    String[] parts = typeString.split(" ");
                    String baseType = parts.length > 0 ? parts[0] : "";
                    tableField.setType(baseType);
                    tableField.setComment(resultSet.getString("REMARKS"));
                    Object nullable = resultSet.getObject("IS_NULLABLE");
                    boolean isNullable = convertToBoolean(nullable);
                    tableField.setNullable(isNullable);
                    tableFields.add(tableField);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



seatunnel-datasource/seatunnel-datasource-plugins/datasource-sqlserver-cdc/src/main/java/org/apache/seatunnel/datasource/plugin/cdc/sqlserver/SqlServerCDCDataSourceChannel.java [210:229]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            DatabaseMetaData metaData = connection.getMetaData();
            String primaryKey = getPrimaryKey(metaData, dbName, schemaName, tableName);
            try (ResultSet resultSet = metaData.getColumns(dbName, schemaName, tableName, null)) {
                while (resultSet.next()) {
                    TableField tableField = new TableField();
                    String columnName = resultSet.getString("COLUMN_NAME");
                    tableField.setPrimaryKey(false);
                    if (StringUtils.isNotBlank(primaryKey) && primaryKey.equals(columnName)) {
                        tableField.setPrimaryKey(true);
                    }
                    tableField.setName(columnName);
                    String typeString = resultSet.getString("TYPE_NAME");
                    String[] parts = typeString.split(" ");
                    String baseType = parts.length > 0 ? parts[0] : "";
                    tableField.setType(baseType);
                    tableField.setComment(resultSet.getString("REMARKS"));
                    Object nullable = resultSet.getObject("IS_NULLABLE");
                    boolean isNullable = convertToBoolean(nullable);
                    tableField.setNullable(isNullable);
                    tableFields.add(tableField);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -