Java中动态SQL参数传递：从查询结果到方法调用

public static List<Map<String, Object>> getResultInMapList(
    String urlString, String driverr, String usernameString, String password,
    String sqlQuery, Object... params) throws SQLException, IOException {
    // ... 方法实现 ...
}

import java.sql.*;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

// 假设 'conn' 是一个已建立并活动的数据库连接实例
// 并且 createConn(), closeConn() 和 run.query() 方法已在其他地方定义

public class QueryParameterProcessor {

    // 假设 getResultInMapList 方法定义如下（为简洁省略了连接管理部分）
    public static List<Map<String, Object>> getResultInMapList(
            String urlString, String driverr, String usernameString, String password,
            String sqlQuery, Object... params) throws SQLException, IOException {
        Connection conn = null; // 实际应用中应从 createConn 获取
        try {
            // 示例：此处假设 conn 已经通过 createConn 获取并是可用的
            // createConn(urlString, driverr, usernameString, password);
            // conn = ... 获取连接实例 ...

            // 假设 run 是一个 DbUtils QueryRunner 实例
            org.apache.commons.dbutils.QueryRunner run = new org.apache.commons.dbutils.QueryRunner();

            if (params == null || params.length == 0) {
                return run.query(conn, sqlQuery, new org.apache.commons.dbutils.handlers.MapListHandler());
            } else {
                return run.query(conn, sqlQuery, new org.apache.commons.dbutils.handlers.MapListHandler(), params);
            }
        } finally {
            // closeConn(); // 实际应用中关闭连接
        }
    }

    public static void main(String[] args) {
        String urlString = "jdbc:mysql://localhost:3306/testdb";
        String driverr = "com.mysql.cj.jdbc.Driver";
        String usernameString = "user";
        String password = "password";

        // 假设 conn 是一个已建立的连接
        Connection conn = null;
        try {
            Class.forName(driverr);
            conn = DriverManager.getConnection(urlString, usernameString, password);

            List<Object> paramList = new ArrayList<>();
            String sqlQuery2 = "select name from fake_table"; // 辅助查询，获取动态参数

            try (Statement statement = conn.createStatement();
                 ResultSet results = statement.executeQuery(sqlQuery2)) {
                while (results.next()) {
                    // 假设 sqlQuery2 只返回一列数据，且类型为 String
                    paramList.add(results.getString(1));
                }
            } catch (SQLException e) {
                System.err.println("执行辅助查询失败: " + e.getMessage());
                e.printStackTrace();
                return; // 错误处理
            }

            // 步骤二：将收集到的结果转换为 Object 数组
            Object[] dynamicParams = paramList.toArray();

            // 步骤三：将 Object 数组作为参数传递给目标方法
            String mainSqlQuery = "select id, name, value from main_table where name IN (?, ?, ?)"; // 示例主查询
            // 注意：主查询的占位符数量应与 dynamicParams 的长度匹配，
            // 或者使用动态生成占位符的逻辑。这里为了演示，假设匹配。

            List<Map<String, Object>> resultSet = getResultInMapList(
                urlString, driverr, usernameString, password, mainSqlQuery, dynamicParams
            );

            // 打印结果集 (示例)
            if (resultSet != null) {
                System.out.println("主查询结果:");
                for (Map<String, Object> row : resultSet) {
                    System.out.println(row);
                }
            }

        } catch (ClassNotFoundException e) {
            System.err.println("数据库驱动未找到: " + e.getMessage());
        } catch (SQLException e) {
            System.err.println("数据库连接或操作失败: " + e.getMessage());
            e.printStackTrace();
        } catch (IOException e) {
            System.err.println("IO错误: " + e.getMessage());
            e.printStackTrace();
        } finally {
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    System.err.println("关闭连接失败: " + e.getMessage());
                }
            }
        }
    }
}