11. 何使用Java代码执行JOIN查询？如何处理多个结果集？

在Java中，使用JDBC可以执行JOIN查询，并处理返回的结果集。JOIN查询用于从多个表中选择数据，根据某些条件将它们组合在一起。在执行JOIN查询时，JDBC将返回一个结果集（ResultSet），其中包含所有满足查询条件的数据。

1. 编写JOIN查询的SQL语句

首先，编写你想要执行的JOIN查询的SQL语句。以下是一个示例，假设有两个表：orders 和 customers，我们希望通过customer_id将它们关联起来，以查询每个订单的详细信息以及相关客户的姓名。

SELECT orders.order_id, orders.order_date, customers.customer_name
FROM orders
JOIN customers ON orders.customer_id = customers.customer_id;

2. 使用Java代码执行JOIN查询

在Java中，你可以使用JDBC的Statement或PreparedStatement对象来执行SQL查询。以下是一个执行JOIN查询并处理结果集的示例代码。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class JoinQueryExample {

    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/mydatabase?useSSL=false&serverTimezone=UTC";
        String username = "root";
        String password = "password";

        Connection connection = null;
        Statement statement = null;
        ResultSet resultSet = null;

        try {
            // 1. 建立数据库连接
            connection = DriverManager.getConnection(url, username, password);
            System.out.println("Connected to the database successfully.");

            // 2. 创建Statement对象
            statement = connection.createStatement();

            // 3. 执行JOIN查询
            String query = "SELECT orders.order_id, orders.order_date, customers.customer_name " +
                           "FROM orders " +
                           "JOIN customers ON orders.customer_id = customers.customer_id";
            resultSet = statement.executeQuery(query);

            // 4. 处理结果集
            while (resultSet.next()) {
                int orderId = resultSet.getInt("order_id");
                String orderDate = resultSet.getString("order_date");
                String customerName = resultSet.getString("customer_name");

                System.out.println("Order ID: " + orderId);
                System.out.println("Order Date: " + orderDate);
                System.out.println("Customer Name: " + customerName);
                System.out.println("------------");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            // 5. 关闭资源
            try {
                if (resultSet != null) resultSet.close();
                if (statement != null) statement.close();
                if (connection != null) connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

3. 处理多个结果集

在某些情况下，执行存储过程或批处理查询时，可能会返回多个结果集。要处理多个结果集，可以使用Statement或PreparedStatement对象的getMoreResults()方法。

以下是一个处理多个结果集的示例：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class MultipleResultSetsExample {

    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/mydatabase?useSSL=false&serverTimezone=UTC";
        String username = "root";
        String password = "password";

        Connection connection = null;
        Statement statement = null;
        ResultSet resultSet = null;

        try {
            // 1. 建立数据库连接
            connection = DriverManager.getConnection(url, username, password);
            System.out.println("Connected to the database successfully.");

            // 2. 创建Statement对象
            statement = connection.createStatement();

            // 3. 执行查询返回多个结果集
            String multiQuery = "SELECT * FROM orders; SELECT * FROM customers;";
            boolean hasMoreResults = statement.execute(multiQuery);

            // 4. 处理多个结果集
            while (hasMoreResults) {
                resultSet = statement.getResultSet();

                if (resultSet != null) {
                    // 处理当前结果集
                    while (resultSet.next()) {
                        // 例如：打印结果集中的某些列
                        int id = resultSet.getInt(1); // 获取第一列的数据
                        System.out.println("ID: " + id);
                    }
                }

                // 检查是否有更多的结果集
                hasMoreResults = statement.getMoreResults();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            // 5. 关闭资源
            try {
                if (resultSet != null) resultSet.close();
                if (statement != null) statement.close();
                if (connection != null) connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

总结

• 执行JOIN查询：使用JDBC的Statement或PreparedStatement对象执行JOIN查询，通过ResultSet对象处理结果集。
• 处理多个结果集：使用Statement的getMoreResults()方法来处理可能返回的多个结果集。

通过以上步骤和示例代码，你可以在Java中轻松执行JOIN查询，并处理从数据库中返回的一个或多个结果集。