Java 中怎么使用 CachedRowSet 在断开连接时修改数据-java教程-PHP中文网

cachedrowset 是 java 中断开连接的 rowset 实现，先通过 execute() 缓存数据，再离线修改（updaterow/insertrow/deleterow），最后用 acceptchanges(connection) 同步变更；需主键、注意内存占用与事务控制。

java 中怎么使用 cachedrowset 在断开连接时修改数据

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注释规范Skills

当用户要求为 Java 代码添加注释、修改注释、审查注释、整理注释格式，或要求按照代码注释规范处理 Java 文件时，使用本技能。本技能用于统一生成和维护 Java 类注释模板、按 Git 对比 release 判断版本号、补充每行代码上方中文块注释、调整注释空行规则，并保持 Java 文件 UTF-8 无 BOM 编码。典型触发场景包括：补充类注释、更新 @version、检查 @author 来源、整理行尾注释、把注释放到代码上一行、检查注释是否符合规范、构建前检查 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 结果集直接同步：多表关联结果通常无明确主键，同步易失败，建议只对单表、含主键的查询使用
内存占用：全部数据驻留内存，大数据量慎用；可配合分页查询控制大小