多线程来查询数据库并组装结果

在Java中，可以使用多线程来查询数据库并组装结果。以下是一个简单的示例代码：

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

public class DatabaseQueryThread implements Runnable {
    private String query;
    private ResultSet resultSet;

    public DatabaseQueryThread(String query) {
        this.query = query;
    }

    @Override
    public void run() {
        try {
            Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/database", "username", "password");
            Statement statement = connection.createStatement();
            resultSet = statement.executeQuery(query);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public ResultSet getResultSet() {
        return resultSet;
    }
}

public class Main {
    public static void main(String[] args) {
        List<DatabaseQueryThread> threads = new ArrayList<>();

        // 创建多个线程来查询数据库
        threads.add(new DatabaseQueryThread("SELECT * FROM table1"));
        threads.add(new DatabaseQueryThread("SELECT * FROM table2"));

        // 启动线程
        for (DatabaseQueryThread thread : threads) {
            Thread t = new Thread(thread);
            t.start();
        }

        // 等待所有线程完成
        for (Thread t : threads) {
            try {
                t.join();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        // 处理查询结果
        List<ResultSet> resultSets = new ArrayList<>();
        for (DatabaseQueryThread thread : threads) {
            resultSets.add(thread.getResultSet());
        }

        // 组装结果
        // ...
    }
}

在上述代码中，我们创建了名为DatabaseQueryThread的自定义线程类来执行数据库查询操作。每个线程实例都包含一个ResultSet对象来存储查询结果。

在主方法中，我们创建了多个线程来执行不同的查询语句，并将它们添加到一个列表中。然后，我们依次启动每个线程，并使用join()方法等待所有线程完成。

最后，可以将每个线程的查询结果存储在一个列表中，并根据需要进行后续的结果处理和组装。

请注意，在实际应用中，你需要替换数据库连接信息和查询语句，以适应你的具体情况。此外，你还需要注意数据库连接的资源管理，例如关闭连接、释放资源等。