Java中ResultSet多结果集处理与邮件批量发送教程

public UserDto getEmail() {
    // ... 省略连接和查询代码 ...
    searchResultSet = preparedStatement.executeQuery();
    return getEmail(searchResultSet); // 调用私有方法，最终也只返回一个UserDto
}

private UserDto getEmail(ResultSet searchResultSet) throws SQLException {
    List<UserDto> result = new ArrayList<>();
    UserDto userDto = null;
    while (searchResultSet.next()) {
        userDto = new UserDto();
        userDto.setEmailAddress(searchResultSet.getString(1));
        result.add(userDto);
    }
    // 问题所在：只返回列表中的第一个元素
    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 类如下
class UserDto {
    private String emailAddress;

    public String getEmailAddress() {
        return emailAddress;
    }

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

// 假设 Delegate 类包含 getConnection() 方法
class Delegate {
    protected Connection getConnection() throws SQLException {
        // 实际的数据库连接逻辑
        // 示例：
        // return DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb", "user", "password");
        throw new UnsupportedOperationException("getConnection() not implemented in example");
    }

    public void sendNotification(String from, String subject, String to, String cc, String bcc, String replyTo, String body) {
        System.out.println("Sending email to: " + to + " with body: " + body);
        // 实际的邮件发送逻辑
    }

    /**
     * 公共方法：从数据库获取所有符合条件的邮箱地址列表。
     * @return 包含所有UserDto对象的列表，每个对象含一个邮箱地址。
     * @throws RuntimeException 如果发生数据库操作异常。
     */
    public List<UserDto> getEmails() { // 方法名改为 getEmails 更具语义
        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();
            return extractEmailsFromResultSet(searchResultSet); // 调用私有方法提取所有邮箱
        } catch (Exception e) {
            throw new RuntimeException("Error retrieving emails from database", e);
        } finally {
            // 确保资源被关闭
            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<>();
        while (searchResultSet.next()) { // 关键：循环遍历所有行
            UserDto userDto = new UserDto();
            // 使用列名或索引获取数据，这里使用索引1（第一列）
            userDto.setEmailAddress(searchResultSet.getString(1));
            result.add(userDto);
        }
        return result; // 返回完整的列表
    }
}

// Delegate Delegate = new Delegate(); // 假设 Delegate 实例已创建
// UserDto userDto = delegate.getEmail(); // 只获取一个UserDto
// String toEmail = userDto.getEmailAddress();
// delegate.sendNotification("****", "****", toEmail, "", "", "", body);

public class EmailSenderService {
    public static void main(String[] args) {
        Delegate delegate = new Delegate(); // 实例化 Delegate
        String emailBody = "这是一封测试邮件。"; // 邮件正文

        try {
            // 获取所有邮箱地址列表
            List<UserDto> users = delegate.getEmails();

            if (users != null && !users.isEmpty()) {
                System.out.println("开始批量发送邮件...");
                for (UserDto user : users) {
                    String toEmail = user.getEmailAddress();
                    if (toEmail != null && !toEmail.trim().isEmpty()) {
                        delegate.sendNotification(
                                "sender@example.com", // 发件人
                                "重要通知",             // 邮件主题
                                toEmail,               // 收件人
                                "",                    // 抄送
                                "",                    // 密送
                                "",                    // 回复地址
                                emailBody              // 邮件正文
                        );
                        System.out.println("邮件已发送至: " + toEmail);
                    } else {
                        System.out.println("发现空邮箱地址，跳过发送。");
                    }
                }
                System.out.println("批量邮件发送完成。");
            } else {
                System.out.println("未从数据库获取到任何邮箱地址，无需发送邮件。");
            }
        } catch (RuntimeException e) {
            System.err.println("邮件发送过程中发生错误: " + e.getMessage());
            e.printStackTrace();
        }
    }
}