修改jdbc 主键bug

seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-access/src/main/java/org/apache/seatunnel/datasource/plugin/access/jdbc/AccessJdbcDataSourceChannel.java

@@ -160,7 +160,7 @@ public class AccessJdbcDataSourceChannel implements DataSourceChannelExt {
         List<TableField> tableFields = new ArrayList<>();
         try (Connection connection = getConnection(requestParams, database)) {
             DatabaseMetaData metaData = connection.getMetaData();
-          //  String primaryKey = getPrimaryKey(metaData, database, table);
+            //  String primaryKey = getPrimaryKey(metaData, database, table);
 
             String sql =
                     "select * from INFORMATION_SCHEMA.SYSTEM_columns where TABLE_NAME='"
@@ -172,9 +172,10 @@ public class AccessJdbcDataSourceChannel implements DataSourceChannelExt {
                 TableField tableField = new TableField();
                 String columnName = resultSet.getString("COLUMN_NAME");
                 tableField.setPrimaryKey(false);
-//                if (StringUtils.isNotBlank(primaryKey) && primaryKey.equals(columnName)) {
-//                    tableField.setPrimaryKey(true);
-//                }
+                //                if (StringUtils.isNotBlank(primaryKey) &&
+                // primaryKey.equals(columnName)) {
+                //                    tableField.setPrimaryKey(true);
+                //                }
                 tableField.setType(resultSet.getString("TYPE_NAME"));
                 if (typeList.contains(tableField.getType().toLowerCase())) {
                     if (tableField.getType().toLowerCase().indexOf("text") < 0) {

seatunnel-datasource/seatunnel-datasource-plugins/datasource-jdbc-dameng/src/main/java/org/apache/seatunnel/datasource/plugin/demeng/jdbc/DamengJdbcDataSourceChannel.java

@@ -167,7 +167,7 @@ public class DamengJdbcDataSourceChannel implements DataSourceChannelExt {
         List<TableField> tableFields = new ArrayList<>();
         try (Connection connection = getConnection(requestParams, database)) {
             DatabaseMetaData metaData = connection.getMetaData();
-          //  String primaryKey = getPrimaryKey(metaData, database, table);
+            //  String primaryKey = getPrimaryKey(metaData, database, table);
 
             String sql =
                     " select * from  SYSCOLUMNS where id in (select id from  SYSOBJECTS where name='"
@@ -180,9 +180,10 @@ public class DamengJdbcDataSourceChannel implements DataSourceChannelExt {
                 String columnName = resultSet.getString("NAME");
                 tableField.setPrimaryKey(false);
 
-//                if (StringUtils.isNotBlank(primaryKey) && primaryKey.equals(columnName)) {
-//                    tableField.setPrimaryKey(true);
-//                }
+                //                if (StringUtils.isNotBlank(primaryKey) &&
+                // primaryKey.equals(columnName)) {
+                //                    tableField.setPrimaryKey(true);
+                //                }
                 tableField.setType(resultSet.getString("TYPE$"));
                 if (typeList.contains(tableField.getType().toLowerCase())) {
                     if (tableField.getType().toLowerCase().indexOf("text") < 0) {