快速掌握Hibernate中悲观锁和乐观锁
我们在使用Hibernate中经常用到当多个人对同一数据同时进行修改的时候,会发生脏数据,造成数据的不一致性,解决办法是可以通过悲观锁和乐观锁来实现。
Hibernate悲观锁:在数据有加载的时候就给其进行加锁,直到该锁被释放掉,其他用户才可以进行修改,优点:数据的一致性保持得很好,缺点:不适合多个用户并发访问。当一个锁住的资源不被释放掉的时候,这个资源永远不会被其他用户进行修改,容易造成无限期的等待。
Hibernate乐观锁:就是在对数据进行修改的时候,对数据才去版本或者时间戳等方式来比较,数据是否一致性来实现加锁。优点比较好。
一、在Hibernate悲观锁中,只要在加载的时候,才去session中的load方法,进行枷锁,session.load(****.class,1,LockMode.UPDATE);
Hibernate将事务管理委托给底层的JDBC或者JTA,默认是基于JDBC Transaction的。Hibernate支持“悲观锁(Pessimistic Locking)”和“乐观锁(Optimistic Locking)”。
Hibernate悲观锁对数据被外界修改持保守态度,因此,在整个数据处理过程中,将数据处于锁定状态。Hibernate悲观锁的实现,往往依靠数据库提供的锁机制。Hibernate通过使用数据库的for update子句实现了悲观锁机制。
Hibernate的加锁模式有:
1. LockMode.NONE:无锁机制
2. LockMode.WRITE:Hibernate在Insert和Update记录的时候会自动获取
3. LockMode.READ:Hibernate在读取记录的时候会自动获取
4. LockMode.UPGRADE:利用数据库的for update子句加锁
5. LockMode.UPGRADE_NOWAIT:Oracle的特定实现,利用Oracle的for update nowait子句实现加锁
二、乐观锁大多是基于数据版本(Version)记录机制实现。Hibernate在其数据访问引擎中内置了Hibernate乐观锁实现,可以通过class描述符的optimistic-lock属性结合version描述符指定。optimistic-lock属性有如下可选取值:
1. none:无乐观锁
2. version:通过版本机制实现乐观锁
3. dirty:通过检查发生变动过的属性实现乐观锁
4. all:通过检查所有属性实现乐观锁
例子:
1)Hibernate悲观锁:
1>POJO类
public class PersimisticLocking { private int id; private String Item; private int price; //省略setter、getter方法 }
2>、POJO类的映射文件
<?xml version="1.0"?> <!DOCTYPE hibernate-mapping PUBLIC "-//Hibernate/Hibernate Mapping DTD 3.0//EN" "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd"> <hibernate-mapping package="org.apple.hibernate"> <class name="PersimisticLocking" table="t_persimisticLocking"> <id name="id"> <generator class="native"/> </id> <property name="item"/> <property name="price"/> </class> </hibernate-mapping>
3>、加载测试方法
public void testLoad1() { Session session = null; try { session = HibernateUtil.getSession(); session.beginTransaction(); OptimisticLocking o = (OptimisticLocking)session.load(OptimisticLocking.class, 1); System.out.println("o.item="+o.getItem()); System.out.println("o.price="+o.getPrice()); System.out.println("o.version="+o.getVersion()); o.setPrice(o.getPrice()-10); session.update(o); session.beginTransaction().commit(); } catch (Exception e) { // TODO: handle exception e.printStackTrace(); session.beginTransaction().rollback(); }finally{ HibernateUtil.closeSession(session); } }
可以设置另外类似的方法,不枷锁,先对上面的测试代码设置断点,点debug一部分,再运行不枷锁的,可以看到,如果上面方法不释放锁的话,下面的数据就会造成无限期的等待。
2、Hibernate乐观锁:
1>在悲观锁的基础上加入private int version;和相关的setter、getter方法。
2>映射文件配置在class标签里面加入optimistic-lock="version",然后在的id标签后面加入<version name="version"/>
3>测试方法:
public void testLoad1() { Session session = null; try { session = HibernateUtil.getSession(); session.beginTransaction(); OptimisticLocking o = (OptimisticLocking)session.load(OptimisticLocking.class, 1); System.out.println("o.item="+o.getItem()); System.out.println("o.price="+o.getPrice()); System.out.println("o.version="+o.getVersion()); o.setPrice(o.getPrice()-10); session.update(o); session.beginTransaction().commit(); } catch (Exception e) { // TODO: handle exception e.printStackTrace(); session.beginTransaction().rollback(); }finally{ HibernateUtil.closeSession(session); } }