理解问题：从单结果到多结果的处理转变
在数据库操作中，当执行一个可能返回多行记录的查询时（例如 select email from user where ...），java.sql.resultset 对象会包含所有符合条件的记录。然而，如果数据访问层的方法设计为只返回单个对象（如 userdto），那么即使 resultset 中有多个结果，也只有第一条记录会被处理并返回，其余的记录将被忽略。这导致了只能对第一条记录进行操作（例如发送邮件给第一个邮箱地址）的问题。
原始代码示例中，getEmail(ResultSet searchResultSet) 方法的最终返回逻辑是 return result == null ? null : result.size() == 0 ? null : result.get(0);，这明确表示了它只会返回列表中的第一个元素，从而限制了批量处理的能力。
解决方案：改造数据访问层以支持多结果集返回
要解决此问题，核心在于将数据访问层的方法设计为能够返回一个包含所有查询结果的集合（例如 List
1. 修改 getEmail 方法的返回类型和实现
首先，我们需要调整负责执行数据库查询并处理 ResultSet 的方法。
原始代码片段（仅返回第一个结果）：
立即学习“Java免费学习笔记（深入）”；
public UserDto getEmail() {
// ... 省略连接和查询代码 ...
searchResultSet = preparedStatement.executeQuery();
return getEmail(searchResultSet); // 调用私有方法，最终也只返回一个UserDto
}
private UserDto getEmail(ResultSet searchResultSet) throws SQLException {
List 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);
} 修改后的 getEmail 方法（返回所有结果列表）：
我们将 public 和 private 版本的 getEmail 方法都修改为返回 List
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 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 extractEmailsFromResultSet(ResultSet searchResultSet) throws SQLException {
List result = new ArrayList<>();
while (searchResultSet.next()) { // 关键：循环遍历所有行
UserDto userDto = new UserDto();
// 使用列名或索引获取数据，这里使用索引1（第一列）
userDto.setEmailAddress(searchResultSet.getString(1));
result.add(userDto);
}
return result; // 返回完整的列表
}
} 关键改动点：
- public getEmails() 方法的返回类型从 UserDto 变为 List
。 - private extractEmailsFromResultSet(ResultSet) 方法的返回类型从 UserDto 变为 List
。 - 在 extractEmailsFromResultSet 方法中，移除了 return result.get(0) 这样的限制，而是直接返回填充好的 result 列表。
- 为了更好的语义，将方法名从 getEmail 改为 getEmails。
- 在 finally 块中添加了 Connection 的关闭操作，确保所有资源都能被释放。
2. 在业务逻辑层迭代处理邮箱地址
一旦数据访问层能够正确地返回所有邮箱地址的列表，业务逻辑层就可以轻松地遍历这个列表，对每个邮箱地址执行所需的操作，例如发送邮件。
原始业务逻辑（仅处理第一个邮箱）：
// 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 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();
}
}
} 关键改动点：
- 调用 delegate.getEmails() 方法，它现在返回 List
。 - 使用 for 循环（或 forEach 循环）遍历 users 列表。
- 在循环内部，对于每个 UserDto 对象，提取其邮箱地址并调用 sendNotification 方法。
- 增加了空值和空列表检查，提高了代码的健壮性。
注意事项与最佳实践
- 资源管理： 确保数据库连接 (Connection)、预编译语句 (PreparedStatement) 和结果集 (ResultSet) 在使用完毕后都能被正确关闭，通常在 finally 块中进行。这是防止资源泄露的关键。
- 异常处理： 对数据库操作和邮件发送可能发生的异常进行适当的捕获和处理，提高程序的健壮性。
- 日志记录： 在实际应用中，应使用日志框架（如 SLF4J + Logback/Log4j2）记录邮件发送的状态、成功与失败信息，以便于监控和问题排查。
- 批量发送优化： 对于非常大量的邮件发送，直接循环调用 sendNotification 可能会效率低下或触发邮件服务器的限流。可以考虑使用线程池、消息队列（如 Kafka、RabbitMQ）进行异步发送，或者邮件服务提供商的批量发送API。
- 安全性： 在实际生产环境中，邮件内容和收件人列表可能包含敏感信息，需要注意数据加密、访问控制等安全措施。
- 可读性： 适当的方法命名（如 getEmails 替代 getEmail）和注释可以显著提高代码的可读性和可维护性。
总结
通过将数据访问层的方法设计为返回一个集合类型（List
