修改查询表字段数据选择库

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

@@ -214,6 +214,7 @@ public class MysqlJdbcDataSourceChannel implements DataSourceChannelExt {
             String sql =
                     "SELECT * FROM information_schema.tables WHERE table_schema='" + database + "'";
             Statement statement = connection.createStatement();
+            statement.execute("use " + database);
             ResultSet resultSet = statement.executeQuery(sql);
 
             while (resultSet.next()) {
@@ -260,6 +261,7 @@ public class MysqlJdbcDataSourceChannel implements DataSourceChannelExt {
                             + database
                             + "'";
             Statement statement = connection.createStatement();
+            statement.execute("use " + database);
             ResultSet resultSet = statement.executeQuery(sql);
             ResultSetMetaData metaData = resultSet.getMetaData();
             // 字段的个数

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

@@ -268,6 +268,7 @@ public class OracleDataSourceChannel implements DataSourceChannelExt {
                             + database
                             + "'";
             Statement statement = connection.createStatement();
+            statement.execute("use " + database);
             ResultSet resultSet = statement.executeQuery(sql);
             ResultSetMetaData metaData = resultSet.getMetaData();
             // 字段的个数

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

@@ -146,6 +146,7 @@ public class SqlServerDataSourceChannel implements DataSourceChannelExt {
                             + table
                             + "'";
             Statement statement = connection.createStatement();
+            statement.execute("use " + database);
             ResultSet resultSet = statement.executeQuery(sql);
             while (resultSet.next()) {
                 TableField tableField = new TableField();