如何在Java中复用ResultSet数据，避免重复查询数据库？

这个需求很常见——就是把数据库查询结果一次性加载到内存，避免重复发起DB调用对吧？咱们一步步来解决：

首先得明确：ResultSet本身不能直接长期持有，它依赖于数据库连接，一旦连接/Statement关闭，ResultSet就会失效，而且它是单向只读的，没法反复查询。所以核心思路是把ResultSet里的数据全部读取出来，转成Java对象的集合，之后就可以在内存里任意筛选了。

步骤1：创建对应数据库表的实体类 #

先给你的x表创建一个实体类，比如叫XEntity，每个属性对应表中的列：

public class XEntity {
    private Integer id; // 假设表中有id列
    private Integer foreignkey; // 假设表中有foreignkey列
    // 其他字段根据你的表结构补充...

    // 空构造、带参构造
    public XEntity() {}
    public XEntity(Integer id, Integer foreignkey) {
        this.id = id;
        this.foreignkey = foreignkey;
    }

    // 所有字段的getter/setter方法
    public Integer getId() { return id; }
    public void setId(Integer id) { this.id = id; }
    public Integer getForeignkey() { return foreignkey; }
    public void setForeignkey(Integer foreignkey) { this.foreignkey = foreignkey; }
}

步骤2：一次性读取ResultSet到内存集合 #

执行数据库查询后，把所有数据转成List<XEntity>，之后就可以安全关闭所有数据库资源了：

List<XEntity> xList = new ArrayList<>();
ResultSet rs = null;
Statement stmt = null;
Connection connection = null;

try {
    connection = getYourDatabaseConnection(); // 替换成你的数据库连接获取逻辑
    stmt = connection.createStatement();
    rs = stmt.executeQuery("Select * From x");

    // 遍历ResultSet，把每行数据转成XEntity对象存入集合
    while (rs.next()) {
        XEntity entity = new XEntity();
        entity.setId(rs.getInt("id"));
        entity.setForeignkey(rs.getInt("foreignkey"));
        // 其他字段依次赋值，注意匹配列名和数据类型
        xList.add(entity);
    }
} catch (SQLException e) {
    // 这里可以根据业务需求处理异常，比如打印日志或抛出自定义异常
    e.printStackTrace();
} finally {
    // 务必按顺序关闭数据库资源：ResultSet -> Statement -> Connection
    try { if (rs != null) rs.close(); } catch (SQLException e) {}
    try { if (stmt != null) stmt.close(); } catch (SQLException e) {}
    try { if (connection != null) connection.close(); } catch (SQLException e) {}
}

现在xList就保存了表中所有数据，完全脱离了数据库连接，可以在应用运行期间随时使用。

步骤3：在内存中筛选数据 #

接下来就可以根据不同条件筛选了，推荐用Java 8+的Stream API，简洁高效：

• 筛选id=1的单条数据：

Optional<XEntity> resultById = xList.stream()
    .filter(entity -> entity.getId().equals(1))
    .findFirst();
// 存在则处理
if (resultById.isPresent()) {
    XEntity target = resultById.get();
    // 你的业务逻辑
}

• 筛选foreignkey=25的所有数据：

List<XEntity> resultsByForeignKey = xList.stream()
    .filter(entity -> entity.getForeignkey().equals(25))
    .collect(Collectors.toList());
// 遍历结果集处理即可

如果你的项目还没用到Java 8，也可以用普通for循环筛选：

List<XEntity> resultsByForeignKey = new ArrayList<>();
for (XEntity entity : xList) {
    if (25 == entity.getForeignkey()) {
        resultsByForeignKey.add(entity);
    }
}

额外注意事项 #

• 数据量问题：如果x表的数据量极大（比如几十万条以上），全量缓存可能导致内存溢出。这时候可以考虑只缓存必要字段，或者用Guava Cache、Caffeine这类本地缓存框架设置内存上限和过期时间。
• 数据一致性：如果数据库中的数据会更新，内存缓存就会和DB不一致。如果需要实时性，得考虑缓存更新策略，比如监听DB变更事件、定时刷新缓存等。

内容的提问来源于stack exchange，提问作者Kadir Kalkan