jdbc不直接提供悲观锁或乐观锁api,需通过sql和事务实现:悲观锁用select ... for update加行锁,乐观锁用version字段校验更新。

Java 中 JDBC 本身不直接提供“悲观锁”或“乐观锁”的 API,它们是数据库并发控制的逻辑策略,需通过 SQL 语句和事务配合实现。JDBC 是执行这些语句的工具,关键在于你如何写 SQL、设置事务隔离级别、以及如何处理版本字段或锁提示。
悲观锁:用 SELECT ... FOR UPDATE(或 LOCK IN SHARE MODE)
悲观锁假设冲突频繁,提前加锁阻塞其他事务修改。在 JDBC 中,需在可重复读(REPEATABLE READ)或读已提交(READ COMMITTED)事务中执行带锁的查询,并确保连接不自动提交。
- 开启事务:
connection.setAutoCommit(false) - 执行加锁查询(以 MySQL 为例):
SELECT * FROM account WHERE id = 1 FOR UPDATE;
这会在匹配行上加排他锁,其他事务对该行的UPDATE或FOR UPDATE会被阻塞,直到当前事务提交或回滚。 - 后续执行业务逻辑(如扣款),再
update或delete,最后commit()或rollback() - 注意:
FOR UPDATE在不同数据库语法略有差异(如 PostgreSQL 用SELECT ... FOR UPDATE,Oracle 用SELECT ... FOR UPDATE NOWAIT;SQL Server 用WITH (UPDLOCK))
乐观锁:靠版本号(version)字段 + UPDATE 条件校验
乐观锁假设冲突少,不加锁,而是在更新时检查数据是否被他人改过。JDBC 中只需按常规执行带版本条件的 UPDATE,再判断影响行数。
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
- 表结构需含版本列,如:
version INT DEFAULT 0 - 查询时读出当前 version:
SELECT id, balance, version FROM account WHERE id = 1; - 更新时带上 version 条件:
UPDATE account SET balance = ?, version = version + 1 WHERE id = ? AND version = ?; - 执行后检查
PreparedStatement.executeUpdate()返回值:
若返回 1,说明更新成功;
若返回 0,说明 version 不匹配(已被别人更新),此时应抛异常或重试
事务与隔离级别的配合要点
悲观锁效果依赖事务边界和隔离级别;乐观锁虽不依赖锁,但事务仍需保证原子性。
- 务必显式控制事务:
setAutoCommit(false)→ 执行 SQL →commit()/rollback() - MySQL 默认隔离级别是 REPEATABLE READ,
FOR UPDATE在该级别下会锁住满足条件的行及间隙(防止幻读);若只需行锁,可设为 READ COMMITTED - 不要在高并发场景对全表
SELECT ... FOR UPDATE,易引发死锁或性能瓶颈;尽量让 WHERE 条件走主键或唯一索引
简单示例:乐观锁更新账户余额
假设 Account 表有 id、balance、version 字段:
String sql = "UPDATE account SET balance = ?, version = version + 1 WHERE id = ? AND version = ?";
try (PreparedStatement ps = conn.prepareStatement(sql)) {
ps.setBigDecimal(1, newBalance);
ps.setLong(2, accountId);
ps.setInt(3, oldVersion);
int rows = ps.executeUpdate();
if (rows == 0) {
throw new OptimisticLockException("数据已被修改,请重试");
}
}
不复杂但容易忽略:锁的有效性取决于事务未提交、SQL 正确加锁/校验、以及数据库是否真正支持对应特性(如某些只读从库不支持 FOR UPDATE)。实际使用前建议在目标数据库上验证行为。
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南










