hibernate中的悲观锁和乐观锁
2017-05-13 19:12
579 查看
悲观锁
11.4. 悲观锁定(Pessimistic Locking)用户其实并不需要花很多精力去担心锁定策略的问题。通常情况下,只要为JDBC连接指定一下隔 离级别,然后让数据库去搞定一切就够了。然而,高级用户有时候希望进行一个排它的悲观锁定, 或者在一个新的事务启动的时候,重新进行锁定。
Hibernate总是使用数据库的锁定机制,从不在内存中锁定对象!
类LockMode 定义了Hibernate所需的不同的锁定级别。一个锁定 可以通过以下的机制来设置:
当Hibernate更新或者插入一行记录的时候,锁定级别自动设置为LockMode.WRITE。
当用户显式的使用数据库支持的SQL格式SELECT … FOR UPDATE 发送SQL的时候,锁定级别设置为LockMod
4000
e.UPGRADE
当用户显式的使用Oracle数据库的SQL语句SELECT … FOR UPDATE NOWAIT 的时候,锁定级别设置LockMode.UPGRADE_NOWAIT
当Hibernate在“可重复读”或者是“序列化”数据库隔离级别下读取数据的时候,锁定模式 自动设置为LockMode.READ。这种模式也可以通过用户显式指定进行设置。
LockMode.NONE 代表无需锁定。在Transaction结束时, 所有的对象都切换到该模式上来。与session相关联的对象通过调用update() 或者saveOrUpdate()脱离该模式。
“显式的用户指定”可以通过以下几种方式之一来表示:
调用 Session.load()的时候指定锁定模式(LockMode)。
调用Session.lock()。
调用Query.setLockMode()。
如果在UPGRADE或者UPGRADE_NOWAIT锁定模式下调 用Session.load(),并且要读取的对象尚未被session载入过,那么对象 通过SELECT … FOR UPDATE这样的SQL语句被载入。如果为一个对象调用 load()方法时,该对象已经在另一个较少限制的锁定模式下被载入了,那 么Hibernate就对该对象调用lock() 方法。
如果指定的锁定模式是READ, UPGRADE 或 UPGRADE_NOWAIT,那么Session.lock()就 执行版本号检查。(在UPGRADE 或者UPGRADE_NOWAIT 锁定模式下,执行SELECT … FOR UPDATE这样的SQL语句。)
如果数据库不支持用户设置的锁定模式,Hibernate将使用适当的替代模式(而不是扔出异常)。 这一点可以确保应用程序的可移植性。
使用悲观锁(mysql)
@Test public void testPessimisticLock() { Session session = sf.openSession(); session.beginTransaction(); Account a = (Account)session.load(Account.class, 1, LockOptions.UPGRADE); session.getTransaction().commit(); session.close(); }
hibernate生成的sql
Hibernate: select account0_.id as id1_0_0_, account0_.balance as balance2_0_0_ from Account account0_ where account0_.id=? for update
乐观锁
实体类(声明version属性,在数据库中也要保存)@Entity public class Account { private int id; private int balance; private int version; @Version public int getVersion() { return version; } public void setVersion(int version) { this.version = version; } @Id @GeneratedValue public int getId() { return id; } public void setId(int id) { this.id = id; } public int getBalance() { return balance; } public void setBalance(int balance) { this.balance = balance; } }
测试代码
@Test public void testOptimisticLock() { Session session = sf.openSession(); Session session2 = sf.openSession(); session.beginTransaction(); Account a1 = (Account) session.load(Account.class, 1); session2.beginTransaction(); Account a2 = (Account) session2.load(Account.class, 1); a1.setBalance(900); a2.setBalance(1100); session.getTransaction().commit(); System.out.println(a1.getVersion()); session2.getTransaction().commit(); System.out.println(a2.getVersion()); session.close(); session2.close(); }
这样在session2.getTransaction().commit()时会报错
org.hibernate.StaleObjectStateException: Row was updated or deleted by another transaction (or unsaved-value mapping was incorrect): [com.bjsxt.hibernate.Account#1] at org.hibernate.persister.entity.AbstractEntityPersister.check(AbstractEntityPersister.java:2509)
可以在实际操作中处理这个异常,先比较版本号(version)是否已经更改,然后再判断是否进行数据的更新操作
相关文章推荐
- hibernate 乐观锁与悲观锁使用
- hibernate乐观锁与悲观锁
- hibernate---->悲观锁和乐观锁
- Hibernate事务与并发问题处理(乐观锁与悲观锁)
- Hibernate的乐观锁与悲观锁
- hibernate 乐观锁与悲观锁使用
- Hibernate事务与并发问题处理(乐观锁与悲观锁)
- Hibernate乐观锁和悲观锁
- hibernate乐观锁和悲观锁
- Hibernate的悲观锁和乐观锁
- Hibernate的悲观锁和乐观锁
- Hibernate的悲观锁和乐观锁
- Hibernate事务与并发问题处理(乐观锁与悲观锁)
- hibernate 乐观锁与悲观锁使用
- Hibernate的乐观锁与悲观锁(转载)
- hibernate---->悲观锁和乐观锁
- Hibernate 性能优化笔记!(遍历、一级/二级/查询/缓存、乐观悲观锁等优化算法)
- hibernate悲观乐观锁 缓存 二级缓存 抓取策略
- hibernate中的悲观锁和乐观锁
- hibernate对悲观锁和乐观锁的支持