快速掌握Hibernate中悲觀鎖和樂觀鎖
我們在使用Hibernate中經(jīng)常用到當(dāng)多個(gè)人對同一數(shù)據(jù)同時(shí)進(jìn)行修改的時(shí)候,會(huì)發(fā)生臟數(shù)據(jù),造成數(shù)據(jù)的不一致性,解決辦法是可以通過悲觀鎖和樂觀鎖來實(shí)現(xiàn)。
Hibernate悲觀鎖:在數(shù)據(jù)有加載的時(shí)候就給其進(jìn)行加鎖,直到該鎖被釋放掉,其他用戶才可以進(jìn)行修改,優(yōu)點(diǎn):數(shù)據(jù)的一致性保持得很好,缺點(diǎn):不適合多個(gè)用戶并發(fā)訪問。當(dāng)一個(gè)鎖住的資源不被釋放掉的時(shí)候,這個(gè)資源永遠(yuǎn)不會(huì)被其他用戶進(jìn)行修改,容易造成無限期的等待。
Hibernate樂觀鎖:就是在對數(shù)據(jù)進(jìn)行修改的時(shí)候,對數(shù)據(jù)才去版本或者時(shí)間戳等方式來比較,數(shù)據(jù)是否一致性來實(shí)現(xiàn)加鎖。優(yōu)點(diǎn)比較好。
一、在Hibernate悲觀鎖中,只要在加載的時(shí)候,才去session中的load方法,進(jìn)行枷鎖,session.load(****.class,1,LockMode.UPDATE);
Hibernate將事務(wù)管理委托給底層的JDBC或者JTA,默認(rèn)是基于JDBC Transaction的。Hibernate支持“悲觀鎖(Pessimistic Locking)”和“樂觀鎖(Optimistic Locking)”。
Hibernate悲觀鎖對數(shù)據(jù)被外界修改持保守態(tài)度,因此,在整個(gè)數(shù)據(jù)處理過程中,將數(shù)據(jù)處于鎖定狀態(tài)。Hibernate悲觀鎖的實(shí)現(xiàn),往往依靠數(shù)據(jù)庫提供的鎖機(jī)制。Hibernate通過使用數(shù)據(jù)庫的for update子句實(shí)現(xiàn)了悲觀鎖機(jī)制。
Hibernate的加鎖模式有:
1. LockMode.NONE:無鎖機(jī)制
2. LockMode.WRITE:Hibernate在Insert和Update記錄的時(shí)候會(huì)自動(dòng)獲取
3. LockMode.READ:Hibernate在讀取記錄的時(shí)候會(huì)自動(dòng)獲取
4. LockMode.UPGRADE:利用數(shù)據(jù)庫的for update子句加鎖
5. LockMode.UPGRADE_NOWAIT:Oracle的特定實(shí)現(xiàn),利用Oracle的for update nowait子句實(shí)現(xiàn)加鎖
二、樂觀鎖大多是基于數(shù)據(jù)版本(Version)記錄機(jī)制實(shí)現(xiàn)。Hibernate在其數(shù)據(jù)訪問引擎中內(nèi)置了Hibernate樂觀鎖實(shí)現(xiàn),可以通過class描述符的optimistic-lock屬性結(jié)合version描述符指定。optimistic-lock屬性有如下可選取值:
1. none:無樂觀鎖
2. version:通過版本機(jī)制實(shí)現(xiàn)樂觀鎖
3. dirty:通過檢查發(fā)生變動(dòng)過的屬性實(shí)現(xiàn)樂觀鎖
4. all:通過檢查所有屬性實(shí)現(xiàn)樂觀鎖
例子:
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);
- }
- }
可以設(shè)置另外類似的方法,不枷鎖,先對上面的測試代碼設(shè)置斷點(diǎn),點(diǎn)debug一部分,再運(yùn)行不枷鎖的,可以看到,如果上面方法不釋放鎖的話,下面的數(shù)據(jù)就會(huì)造成無限期的等待。
2、Hibernate樂觀鎖:
1>在悲觀鎖的基礎(chǔ)上加入private int version;和相關(guān)的setter、getter方法。
2>映射文件配置在class標(biāo)簽里面加入optimistic-lock="version",然后在的id標(biāo)簽后面加入<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);
- }
- }
在初始數(shù)據(jù)的時(shí)候,version為0,在沒更新一次version都會(huì)在原來的基礎(chǔ)上加1,通過version的版本來實(shí)現(xiàn)Hibernate樂觀鎖。
在上面的測試方法里面復(fù)制成另外一個(gè)方法,對上面的方法進(jìn)行設(shè)置斷點(diǎn),然后單步調(diào)試幾部,到***1行的時(shí)候暫停,此時(shí)對復(fù)制的另外方法運(yùn)行,然后再運(yùn)行完上面的方法,就會(huì)拋出異常,所以,在實(shí)際的項(xiàng)目開發(fā)中,可以通過對異常進(jìn)行出來,這樣就會(huì)實(shí)現(xiàn)并發(fā)訪問。
【編輯推薦】