Java结果集遍历案例如何编写

wen java案例 2026-06-30 29

本文目录导读：

Java结果集遍历案例如何编写

文章标题：Java结果集遍历案例编写：从基础到优化的完整指南
引言：为什么结果集遍历是Java开发的基石？
核心概念：结果集（ResultSet）与遍历机制解析
基础案例：使用while循环遍历ResultSet
进阶案例：基于分页与批量处理的遍历优化
常见错误与性能陷阱（附问答）
最佳实践：结合Lambda与Stream的现代遍历方式
总结与SEO优化关键词

Java结果集遍历案例编写：从基础到优化的完整指南

目录导读

引言：为什么结果集遍历是Java开发的基石？
核心概念：结果集（ResultSet）与遍历机制解析
基础案例：使用while循环遍历ResultSet
进阶案例：基于分页与批量处理的遍历优化
常见错误与性能陷阱（附问答）
最佳实践：结合Lambda与Stream的现代遍历方式
总结与SEO优化关键词

引言：为什么结果集遍历是Java开发的基石？

在Java企业级开发（如Spring Boot、JDBC、MyBatis）中，结果集遍历是数据库操作的核心环节，无论你是查询用户列表、生成报表，还是执行数据迁移，都需要将数据库返回的ResultSet（结果集）转换为Java对象或数据进行后续处理，许多开发者仍在使用低效或易出错的遍历方式（如不关闭资源、未处理空结果集）,导致内存溢出或性能瓶颈。

本文目标：通过5个真实案例（从简单到现代），覆盖Statement、PreparedStatement、分页查询及Java 8 Stream，帮你掌握健壮、高性能的结果集遍历写法。

核心概念：结果集（ResultSet）与遍历机制解析

ResultSet 是JDBC中表示数据库查询结果的对象，本质是一个游标（Cursor），指向结果集的第一行前，遍历时，通过next()方法将游标向下移动一行，并返回boolean值（是否有下一行）。

关键属性：

只进（Forward-only）：默认只能向前遍历,不可回退。
可更新（Updatable）：若创建ResultSet时指定CONCUR_UPDATABLE,可修改当前行数据。
可滚动（Scrollable）：通过TYPE_SCROLL_INSENSITIVE实现跳转（如absolute(5)跳转到第5行）。

遍历方式对比： | 方式 | 适用场景 | 性能 | 可读性 | |------|---------|------|--------| | while + next() | 小数据量（<万行） | 高 | 中 | | 分页遍历 | 大数据量（>10万行） | 极高 | 高 | | Stream API | 集合操作（已加载内存） | 中等 | 高 | | 批量处理 | 插入/更新操作 | 极高 | 中 |

基础案例：使用while循环遍历ResultSet

场景：查询用户表的所有记录,并打印姓名和邮箱。

代码示例：

try (Connection conn = DriverManager.getConnection(url, user, password);
     Statement stmt = conn.createStatement();
     ResultSet rs = stmt.executeQuery("SELECT name, email FROM users")) {
    while (rs.next()) {
        String name = rs.getString("name");
        String email = rs.getString("email");
        System.out.println("Name: " + name + ", Email: " + email);
    }
} catch (SQLException e) {
    e.printStackTrace();
}

关键点：

try-with-resources：自动关闭Connection、Statement、ResultSet,防止资源泄漏。
rs.next()：必须调用此方法才能访问第一行数据,且每次调用都会移动游标。
列名 vs 索引：建议使用列名（rs.getString("name")）而非索引,提高代码可读性。

进阶案例：基于分页与批量处理的遍历优化

1 分页遍历（适合大数据量）

问题：一次查询返回100万行，内存直接溢出？
解决方案：使用SQL分页（如MySQL的LIMIT）+ 循环遍历。

代码示例：

int pageSize = 1000;
int offset = 0;
boolean hasMore = true;
while (hasMore) {
    String sql = "SELECT id, data FROM large_table LIMIT ? OFFSET ?";
    try (PreparedStatement pstmt = conn.prepareStatement(sql)) {
        pstmt.setInt(1, pageSize);
        pstmt.setInt(2, offset);
        try (ResultSet rs = pstmt.executeQuery()) {
            while (rs.next()) {
                // 处理每行数据
                processRow(rs.getInt("id"), rs.getString("data"));
            }
            offset += pageSize;
            hasMore = !rs.isLast(); // 检查是否到达最后一行
        }
    }
}

优化点：

使用PreparedStatement防止SQL注入。
分页大小根据内存设置（通常500-2000行/页）。
注意isLast()仅在TYPE_FORWARD_ONLY游标下有效。

2 批量处理（适合数据写入）

场景：从结果集读取数据后批量插入新表。

代码示例：

try (PreparedStatement insertStmt = conn.prepareStatement("INSERT INTO new_users (name) VALUES (?)")) {
    String querySql = "SELECT name FROM old_users";
    try (Statement stmt = conn.createStatement();
         ResultSet rs = stmt.executeQuery(querySql)) {
        int batchSize = 0;
        while (rs.next()) {
            insertStmt.setString(1, rs.getString("name"));
            insertStmt.addBatch();
            batchSize++;
            if (batchSize % 500 == 0) { // 每500条执行一次批量插入
                insertStmt.executeBatch();
                batchSize = 0;
            }
        }
        if (batchSize > 0) {
            insertStmt.executeBatch(); // 执行剩余批次
        }
    }
}

性能提升：批量操作比逐行INSERT快10-50倍。

常见错误与性能陷阱（附问答）

问答1：为什么我的while循环只遍历了第一行？

问题：忘记在循环内调用rs.next()，或误将next()放在条件外。
正确写法：

while (rs.next()) { // next()必须作为循环条件
    // 处理当前行
}

问答2：大数据量遍历时程序内存暴涨，怎么办？

原因：未使用分页，或误将整个ResultSet装入内存（如写入List）。
解决方案：使用游标式遍历（仅逐行处理），或结合LIMIT分页。
反例（内存爆炸）：

List<User> users = new ArrayList<>();
while (rs.next()) {
    users.add(new User(rs.getString("name"))); // 加载全部到内存
}

问答3：ResultSet遍历时抛出“ResultSet is closed”？

原因：在Statement关闭后仍访问ResultSet（如使用try-with-resources作用域不当）。
修复：确保创建ResultSet的Statement生命周期覆盖遍历过程。

最佳实践：结合Lambda与Stream的现代遍历方式

在Java 8+中，若结果集已转换为集合（如List）,可用Stream进行声明式遍历。

案例：将用户列表按邮箱域名分组

List<User> users = queryAllUsers(); // 假设已调用JDBC并填充List
Map<String, List<User>> groupedByDomain = users.stream()
    .filter(user -> user.getEmail() != null)
    .collect(Collectors.groupingBy(
        user -> user.getEmail().substring(user.getEmail().indexOf("@") + 1)
    ));
groupedByDomain.forEach((domain, userList) -> {
    System.out.println("Domain: " + domain + ", Users: " + userList.size());
});

注意：Stream方式不直接操作ResultSet，仅适用于数据已在内存的场景，若数据量极大,仍需用传统游标遍历。