在许多业务场景中，我们经常需要从数据库中检索出多条记录，并对这些记录进行逐一处理，例如发送批量通知邮件。然而，在实际开发中，开发者可能会遇到仅能处理查询结果集（resultset）中第一条记录的问题。本教程将深入探讨如何正确地从resultset中提取所有查询结果，并将其封装成集合以便后续处理，最终实现对所有查询结果的逐一操作。
问题分析：为何只处理了第一条记录？
原始代码在数据访问层（DAO）中通过getEmail()方法查询数据库，并返回一个ResultSet。私有辅助方法getEmail(ResultSet searchResultSet)负责从ResultSet中提取数据并封装到UserDto对象中。问题在于，尽管ResultSet可能包含多条记录，但该辅助方法的设计目标是返回单个UserDto对象：
// 原始的私有辅助方法
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);
}这段代码虽然使用了while (searchResultSet.next())循环遍历了所有结果，并将它们添加到了result列表中，但最终却只返回了result.get(0)，即列表中的第一个UserDto对象。因此，无论数据库查询返回多少条记录，外部调用方都只能获取到第一个邮箱地址。
解决方案：返回并处理集合数据
要解决这个问题，我们需要对数据访问层的方法进行修改，使其能够返回所有查询到的UserDto对象组成的列表，并在调用方遍历这个列表进行处理。
1. 修改数据访问层方法以返回列表
首先，我们需要调整getEmail()方法及其私有辅助方法，使其返回List
立即学习“Java免费学习笔记（深入）”；
修改后的数据访问类（例如Delegate类中的方法）：
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 List
getEmail(): 公开方法现在返回List 。 - private List
extractEmailsFromResultSet(ResultSet searchResultSet): 私有辅助方法也返回List 。 - 在辅助方法中，while (searchResultSet.next())循环确保遍历所有结果。
- 在循环内部，new UserDto()为每一行数据创建一个独立的UserDto实例。
- result.add(userDto)将每个UserDto添加到列表中。
- 最终返回完整的result列表。
- 注意： searchResultSet.getString("EMAIL") 这种通过列名获取数据的方式比 searchResultSet.getString(1) 更具可读性和健壮性，推荐使用。
2. 在调用方遍历并处理所有邮箱地址
现在，当Delegate类中的getEmail()方法返回一个List
调用方类中的代码：
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();
}
}
}关键修改点：
- List
users = delegate.getEmail();: 接收一个UserDto列表。 - for (UserDto userDto : users): 使用增强for循环遍历列表中的每一个UserDto对象。
- 在循环内部，userDto.getEmailAddress()获取当前用户的邮箱地址，并调用delegate.sendNotification()发送邮件。
总结与注意事项
通过上述修改，我们成功地将数据库查询结果集中的所有邮箱地址提取出来，并逐一进行了处理。这个解决方案的核心在于：
- 返回集合类型： 当预期有多个结果时，数据访问层的方法应返回一个集合（如List）而不是单个对象。
- 正确遍历ResultSet： 使用while (resultSet.next())循环是处理ResultSet中所有记录的标准方式。
- 为每条记录创建新对象： 在循环内部，为每一条从ResultSet中读取的记录创建一个新的Java对象实例，并将其添加到集合中。
注意事项：
- 资源管理： 确保在finally块中关闭ResultSet、PreparedStatement和Connection等数据库资源，以避免资源泄露。在实际应用中，如果使用连接池，connection.close()操作通常是将连接归还给连接池，而不是真正关闭物理连接。
- 异常处理： 合理地捕获和处理SQLException，并将其转换为更具业务意义的异常（如RuntimeException或自定义业务异常），以便上层调用者进行处理。
- 代码可读性： 在ResultSet中通过列名（getString("COLUMN_NAME")）而不是列索引（getString(1)）获取数据，可以提高代码的可读性和维护性。
- 空结果集处理： 在调用方处理返回的列表时，始终检查列表是否为null或为空，以避免NullPointerException和不必要的处理。
遵循这些最佳实践，可以确保您的Java应用程序能够高效、健壮地处理数据库中的多条查询结果。
