CachedRowSet 是 Java 中断开连接的 RowSet 实现,先通过 execute() 缓存数据,再离线修改(updateRow/insertRow/deleteRow),最后用 acceptChanges(Connection) 同步变更;需主键、注意内存占用与事务控制。

CachedRowSet 是 Java 中 javax.sql.rowset 包提供的一个“断开连接”的 RowSet 实现,它把数据从数据库中一次性读取到内存中,之后即使关闭了数据库连接,依然可以遍历、修改、插入、删除数据。等需要同步回数据库时,再通过 acceptChanges(Connection) 方法批量提交变更。
1. 创建并填充 CachedRowSet(断开连接前)
必须先用有效的数据库连接获取数据,并将结果集“缓存”到 CachedRowSet 中。推荐使用 RowSetProvider.newRowSet()(Java 7+),它会自动返回标准实现(如 sun.jdbc.rowset.CachedRowSetImpl):
CachedRowSet crs = RowSetProvider.newRowSet();
crs.setUrl("jdbc:mysql://localhost:3306/test");
crs.setUsername("user");
crs.setPassword("pass");
crs.setCommand("SELECT id, name, age FROM users WHERE age > ?");
crs.setInt(1, 18); // 设置参数
crs.execute(); // 执行查询,此时连接被隐式打开并关闭 → 数据已缓存,连接断开
执行完 execute() 后,crs 已脱离数据库连接,后续所有操作都不依赖 JDBC 连接。
2. 在断开状态下修改数据
CachedRowSet 支持游标定位和行列更新,但需注意:所有修改操作必须在调用 next() 定位到某一行后进行;且增删改操作本身不会立即影响底层数据,只是标记变更状态(pending changes)。
当用户要求为 Java 代码添加注释、修改注释、审查注释、整理注释格式,或要求按照代码注释规范处理 Java 文件时,使用本技能。本技能用于统一生成和维护 Java 类注释模板、按 Git 对比 release 判断版本号、补充每行代码上方中文块注释、调整注释空行规则,并保持 Java 文件 UTF-8 无 BOM 编码。典型触发场景包括:补充类注释、更新 @version、检查 @author 来源、整理行尾注释、把注释放到代码上一行、检查注释是否符合规范、构建前检查 Java 注释风格。
立即学习“Java免费学习笔记(深入)”;
-
更新某列值:先
crs.next()定位,再用updateXXX(colIndex/colName, value),最后调用updateRow() -
插入新行:调用
moveToInsertRow()→updateXXX(...)→insertRow()→moveToCurrentRow() -
删除当前行:定位后直接调用
deleteRow()
crs.beforeFirst();
while (crs.next()) {
if ("Alice".equals(crs.getString("name"))) {
crs.updateInt("age", 25);
crs.updateRow(); // 提交本次更新到缓存行
}
}
crs.moveToInsertRow();
crs.updateString("name", "Bob");
crs.updateInt("age", 30);
crs.insertRow(); // 新行加入缓存
3. 将修改同步回数据库(重新建立连接)
修改完成后,调用 acceptChanges(Connection conn) 将所有待提交的变更(INSERT/UPDATE/DELETE)生成对应 SQL 并执行。该方法内部会尝试构建主键信息(依赖元数据或显式设置)、生成语句、批处理执行:
try (Connection conn = DriverManager.getConnection(url, user, pass)) {
crs.acceptChanges(conn); // ✅ 关键:传入新连接对象
} catch (SyncProviderException e) {
// 可能因冲突(如乐观锁失败、外键约束、唯一键冲突)抛出此异常
System.err.println("同步失败:" + e.getReason());
// 可选:调用 crs.restoreOriginal() 回滚缓存中的修改
}
⚠️ 注意:acceptChanges() 不会自动重连或管理事务。你需要自己控制连接生命周期,并建议包裹在事务中(conn.setAutoCommit(false)),失败时手动 rollback()。
4. 补充要点与常见问题
-
主键要求:
acceptChanges()需要能唯一标识每行(如主键或可推导的唯一列),否则 UPDATE/DELETE 可能出错。若查询未包含主键,可通过crs.setKeyColumns(new int[]{1})显式指定第1列为键列 -
原始值快照:
CachedRowSet内部保存原始值(用于对比变更),因此restoreOriginal()可撤销未同步的修改 - 不支持 JOIN 结果集直接同步:多表关联结果通常无明确主键,同步易失败,建议只对单表、含主键的查询使用
- 内存占用:全部数据驻留内存,大数据量慎用;可配合分页查询控制大小
只要确保初始化时完成数据加载、修改时正确调用更新方法、同步时提供有效连接并处理异常,CachedRowSet 的离线编辑流程就非常清晰可靠。

















