修改表字段内容

seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-mysql/src/main/java/org/apache/seatunnel/datasource/plugin/mysql/jdbc/MysqlJdbcDataSourceChannel.java

@@ -139,6 +139,10 @@ public class MysqlJdbcDataSourceChannel implements DataSourceChannelExt {
                     tableField.setLen(resultSet.getString("NUMERIC_PRECISION"));
                     tableField.setScale(resultSet.getString("NUMERIC_SCALE"));
                 }
+                String extra = resultSet.getString("EXTRA");
+                if(StringUtils.isNotBlank(extra)) {
+                    tableField.setHasAutoIncrement(true);
+                }
 
                 tableField.setName(columnName);
                 tableField.setComment(resultSet.getString("COLUMN_COMMENT"));

seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-oracle/src/main/java/org/apache/seatunnel/datasource/plugin/oracle/jdbc/OracleDataSourceChannel.java

@@ -154,6 +154,11 @@ public class OracleDataSourceChannel implements DataSourceChannelExt {
                     tableField.setLen(resultSet.getString("LEN"));
                     tableField.setScale(resultSet.getString("DATA_SCALE"));
                 }
+
+//                String extra = resultSet.getString("EXTRA");
+//                if(StringUtils.isNotBlank(extra)) {
+//                    tableField.setHasAutoIncrement(true);
+//                }
                 tableField.setName(columnName);
                 tableField.setType(resultSet.getString("TYPE_NAME"));
                 tableField.setComment(resultSet.getString("REMARKS"));

seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-postgresql/src/main/java/org/apache/seatunnel/datasource/plugin/postgresql/jdbc/PostgresqlDataSourceChannel.java

@@ -135,6 +135,11 @@ public class PostgresqlDataSourceChannel implements DataSourceChannelExt {
                         tableField.setLen(resultSet.getString("NUMERIC_PRECISION"));
                         tableField.setScale(resultSet.getString("NUMERIC_SCALE"));
                     }
+
+                    String extra = resultSet.getString("EXTRA");
+                    if(StringUtils.isNotBlank(extra)) {
+                        tableField.setHasAutoIncrement(true);
+                    }
                     tableField.setName(columnName);
 
                     tableField.setComment(resultSet.getString("REMARKS"));

seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-sqlserver/src/main/java/org/apache/seatunnel/datasource/plugin/sqlserver/jdbc/SqlServerDataSourceChannel.java

@@ -125,7 +125,8 @@ public class SqlServerDataSourceChannel implements DataSourceChannelExt {
                             + "\tB.scale AS COLUMN_SCALE,\n"
                             + "\tC.value AS REMARKS,\n"
                             + "\tD.name AS TYPE_NAME,\n"
-                            + "CASE\n"
+                            + "\tB.is_identity AS IS_IDENTITY,\n"
+                            + " CASE\n"
                             + "\t\tA.type \n"
                             + "\t\tWHEN 'u' THEN\n"
                             + "\t\t'用户定义表' \n"
@@ -155,6 +156,12 @@ public class SqlServerDataSourceChannel implements DataSourceChannelExt {
                 tableField.setLen(resultSet.getString("COLUMN_LENGTH"));
                 tableField.setScale(resultSet.getString("COLUMN_SCALE"));
                 tableField.setName(columnName);
+
+                String extra = resultSet.getString("IS_IDENTITY");
+                if(StringUtils.isNotBlank(extra)) {
+                    tableField.setHasAutoIncrement(true);
+                }
+
                 tableField.setType(resultSet.getString("TYPE_NAME"));
                 tableField.setComment(resultSet.getString("REMARKS"));
                 Object nullable = resultSet.getObject("IS_NULLABLE");

seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-tidb/src/main/java/org/apache/seatunnel/datasource/plugin/tidb/jdbc/TidbJdbcDataSourceChannel.java

@@ -137,6 +137,11 @@ public class TidbJdbcDataSourceChannel implements DataSourceChannelExt {
                     tableField.setLen(resultSet.getString("NUMERIC_PRECISION"));
                     tableField.setScale(resultSet.getString("NUMERIC_SCALE"));
                 }
+
+                String extra = resultSet.getString("EXTRA");
+                if(StringUtils.isNotBlank(extra)) {
+                    tableField.setHasAutoIncrement(true);
+                }
                 tableField.setName(columnName);
                 tableField.setComment(resultSet.getString("COLUMN_COMMENT"));
                 Object nullable = resultSet.getObject("IS_NULLABLE");

seatunnel-datasource/seatunnel-datasource-plugins/datasource-plugins-api/src/main/java/org/apache/seatunnel/datasource/plugin/api/model/TableField.java

@@ -36,6 +36,7 @@ public class TableField {
 
     private Boolean nullable;
 
+    private Boolean  hasAutoIncrement;
     private Map<String, String> properties;
 
     private Boolean unSupport;