在Java中将SQL查询结果作为方法参数的动态传递实践

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

List<Map<String, Object>> resultSet = getResultInMapList(urlString, driverr, usernameString, password, sqlQuery, "323");

// 这是一个错误的尝试！
// List<Map<String, Object>> resultSet = getResultInMapList(..., sqlQuery, "select name from fake_table");

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

// 假设 conn 已经是一个有效的数据库连接
Connection conn = null; // 实际应用中应从连接池或createConn方法获取

List<Object> paramList = new ArrayList<>();
String sqlQuery2 = "select name from fake_table"; // 示例查询

try (Statement statement = conn.createStatement()) { // 使用 try-with-resources 确保资源关闭
    ResultSet results = statement.executeQuery(sqlQuery2);
    while (results.next()) {
        // 根据 sqlQuery2 的具体结构，获取相应的列值
        // 假设 'name' 是第一列，且类型为字符串
        paramList.add(results.getString(1)); 
    }
} catch (SQLException e) {
    e.printStackTrace();
    // 适当的错误处理
}

// 此时 paramList 中包含了 sqlQuery2 查询到的所有 'name' 值

Object[] paramsArray = paramList.toArray();
// 此时 paramsArray 包含了所有从 sqlQuery2 获取到的参数值

// 假设 urlString, driverr, usernameString, password, sqlQuery 已经定义
String sqlQuery = "SELECT * FROM another_table WHERE some_column IN (?)"; // 示例：如果 paramsArray 只有一个值
// 或者如果 sqlQuery 使用了多个占位符，例如 "SELECT * FROM another_table WHERE name = ? OR name = ?"
// 那么 paramsArray 中的元素数量应与占位符数量匹配

List<Map<String, Object>> finalResultSet = null;
try {
    finalResultSet = getResultInMapList(urlString, driverr, usernameString, password, sqlQuery, paramsArray);
} catch (SQLException | IOException e) {
    e.printStackTrace();
    // 适当的错误处理
}

// finalResultSet 现在包含了使用 sqlQuery2 结果作为参数执行 sqlQuery 后的数据

import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.MapListHandler;

public class SqlParameterDynamicPasser {

    private static Connection conn; // 假设连接是静态的，实际应通过参数传递或连接池管理

    // 模拟的创建连接方法
    private static void createConn(String url, String driver, String username, String password) throws SQLException, ClassNotFoundException {
        Class.forName(driver);
        conn = DriverManager.getConnection(url, username, password);
    }

    // 模拟的关闭连接方法
    private static void closeConn() throws SQLException {
        if (conn != null && !conn.isClosed()) {
            conn.close();
        }
    }

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

        QueryRunner run = new QueryRunner(); // 假设使用 Apache DbUtils

        try {
            createConn(urlString, driverr, usernameString, password); // 每次调用都创建连接，实际应优化
            if (params == null || params.length == 0) {
                return run.query(conn, sqlQuery, new MapListHandler());
            } else {
                return run.query(conn, sqlQuery, new MapListHandler(), params);
            }
        } catch (SQLException | ClassNotFoundException se) {
            se.printStackTrace();
            return null;
        } finally {
            closeConn();
        }
    }

    public static void main(String[] args) {
        // 数据库连接信息（请替换为实际值）
        String url = "jdbc:mysql://localhost:3306/testdb";
        String driver = "com.mysql.cj.jdbc.Driver";
        String username = "root";
        String password = "password";

        String sqlQueryForParams = "SELECT name FROM fake_table WHERE id < 5"; // 用于生成参数的查询
        String sqlQueryToExecute = "SELECT * FROM real_table WHERE category_name IN (?)"; // 接受参数的查询

        List<Object> paramList = new ArrayList<>();

        try {
            // 步骤一：创建连接并执行参数生成查询
            createConn(url, driver, username, password);
            try (Statement statement = conn.createStatement()) {
                ResultSet results = statement.executeQuery(sqlQueryForParams);
                while (results.next()) {
                    paramList.add(results.getString("name")); // 获取 'name' 列的值
                }
            }
            closeConn(); // 关闭用于参数查询的连接

            // 步骤二：将列表转换为数组
            Object[] paramsArray = paramList.toArray();

            // 步骤三：将数组传递给目标方法
            System.out.println("Generated parameters: " + paramList);

            if (paramsArray.length > 0) {
                // 重新创建连接，因为getResultInMapList会再次创建
                // 实际应用中，应将连接管理抽离，避免重复创建和关闭
                List<Map<String, Object>> finalResult = getResultInMapList(
                        url, driver, username, password, sqlQueryToExecute, paramsArray);

                System.out.println("Final Result Set:");
                if (finalResult != null) {
                    for (Map<String, Object> row : finalResult) {
                        System.out.println(row);
                    }
                } else {
                    System.out.println("No results found or an error occurred.");
                }
            } else {
                System.out.println("No parameters generated from " + sqlQueryForParams);
            }

        } catch (SQLException | IOException | ClassNotFoundException e) {
            e.printStackTrace();
        } finally {
            try {
                closeConn(); // 确保最终关闭连接
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}