Java中从ResultSet提取并处理多个查询结果的教程

// 原始的私有辅助方法
private UserDto getEmail(ResultSet searchResultSet) throws SQLException {
    List<UserDto> result = new ArrayList<UserDto>(); // 创建了一个列表
    UserDto userDto = null;
    while (searchResultSet.next()) { // 遍历ResultSet
        userDto = new UserDto();
        userDto.setEmailAddress(searchResultSet.getString(1));
        result.add(userDto);
    }
    // 问题：这里只返回了列表中的第一个元素，或者在列表为空时返回null
    return result == null ? null : result.size() == 0 ? null : result.get(0);
}

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

// 假设UserDto是一个包含emailAddress属性的简单JavaBean
class UserDto {
    private String emailAddress;

    public String getEmailAddress() {
        return emailAddress;
    }

    public void setEmailAddress(String emailAddress) {
        this.emailAddress = emailAddress;
    }

    @Override
    public String toString() {
        return "UserDto{emailAddress='" + emailAddress + "'}";
    }
}

// 假设Delegate类中包含数据库连接和发送通知的方法
public class Delegate {

    // 假设这是一个获取数据库连接的辅助方法
    private Connection getConnection() throws SQLException {
        // 实际应用中应使用连接池
        // 示例：DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb", "user", "password");
        throw new UnsupportedOperationException("getConnection() not implemented. Please provide actual DB connection logic.");
    }

    /**
     * 从数据库中获取所有符合条件的邮箱地址列表。
     *
     * @return 包含所有UserDto对象的列表，每个对象包含一个邮箱地址。
     * @throws RuntimeException 如果发生SQL或其他异常。
     */
    public List<UserDto> getEmail() {
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet searchResultSet = null;
        try {
            connection = getConnection();
            preparedStatement = connection.prepareStatement(
                    "SELECT EMAIL FROM USER WHERE USER.U_SEQ IN ('1','650')");
            searchResultSet = preparedStatement.executeQuery();

            // 调用私有辅助方法，现在它返回一个List<UserDto>
            return extractEmailsFromResultSet(searchResultSet);

        } catch (Exception e) {
            // 捕获并包装所有异常为RuntimeException
            throw new RuntimeException("Error retrieving emails from database", e);
        } finally {
            // 确保PreparedStatement和Connection资源被关闭
            try {
                if (searchResultSet != null) searchResultSet.close();
                if (preparedStatement != null) preparedStatement.close();
                if (connection != null) connection.close(); // 实际应用中，连接池的连接是归还而不是关闭
            } catch (SQLException e) {
                System.err.println("Error closing database resources: " + e.getMessage());
            }
        }
    }

    /**
     * 从ResultSet中提取所有邮箱地址并封装到UserDto列表中。
     *
     * @param searchResultSet 数据库查询结果集。
     * @return 包含所有UserDto对象的列表。
     * @throws SQLException 如果访问ResultSet发生错误。
     */
    private List<UserDto> extractEmailsFromResultSet(ResultSet searchResultSet) throws SQLException {
        List<UserDto> result = new ArrayList<>(); // 初始化一个空的UserDto列表

        while (searchResultSet.next()) { // 循环遍历ResultSet中的每一行
            UserDto userDto = new UserDto(); // 为每一行创建一个新的UserDto对象
            // 从当前行获取EMAIL列的值（假设EMAIL是第一列或通过列名获取）
            userDto.setEmailAddress(searchResultSet.getString("EMAIL")); // 推荐使用列名获取
            // userDto.setEmailAddress(searchResultSet.getString(1)); // 或者使用列索引
            result.add(userDto); // 将UserDto添加到列表中
        }
        return result; // 返回包含所有UserDto的列表
    }

    /**
     * 模拟发送通知邮件的方法。
     *
     * @param from 发件人。
     * @param subject 邮件主题。
     * @param toEmail 收件人邮箱。
     * @param ccEmail 抄送人邮箱。
     * @param bccEmail 密送人邮箱。
     * @param attachmentPath 附件路径。
     * @param body 邮件正文。
     */
    public void sendNotification(String from, String subject, String toEmail, String ccEmail,
                                 String bccEmail, String attachmentPath, String body) {
        System.out.println("Sending email from: " + from + ", to: " + toEmail + ", subject: " + subject);
        System.out.println("Body: " + body);
        // 实际邮件发送逻辑
    }
}

public class NotificationService {

    public static void main(String[] args) {
        Delegate delegate = new Delegate(); // 实例化Delegate类

        try {
            // 调用修改后的getEmail方法，现在它返回一个UserDto列表
            List<UserDto> users = delegate.getEmail();

            if (users != null && !users.isEmpty()) {
                // 遍历获取到的所有UserDto对象
                for (UserDto userDto : users) {
                    String toEmail = userDto.getEmailAddress(); // 获取当前UserDto的邮箱地址

                    // 为每个邮箱地址发送通知
                    delegate.sendNotification(
                            "noreply@example.com", // 发件人
                            "Important Update",     // 邮件主题
                            toEmail,                // 收件人
                            "",                     // 抄送
                            "",                     // 密送
                            "",                     // 附件路径
                            "Dear user, this is an important update for you." // 邮件正文
                    );
                }
                System.out.println("All notifications sent successfully.");
            } else {
                System.out.println("No email addresses found to send notifications.");
            }
        } catch (RuntimeException e) {
            System.err.println("Failed to send notifications: " + e.getMessage());
            e.printStackTrace();
        }
    }
}