Hibernate悲觀鎖/樂觀鎖
如果需要保證資料訪問的排它性,則需對目標資料加“鎖”,使其無法被其它程式修改
一,悲觀鎖
對資料被外界(包括本系統當前的其它事務和來自外部系統的事務處理)修改持保守態度,通過資料庫提供的鎖機制實現
最常用的,是對查詢進行加鎖(LockMode.UPGRADE和LockMode.UPGRADE_NOWAIT):
public class Test { public static void main(String[] args) { Configuration conf = new Configuration(); SessionFactory sessionFactory = conf.configure().buildSessionFactory(); Session sess = sessionFactory.openSession(); Transaction tran = sess.beginTransaction(); String hql = "from User where id = 1"; Query query = sess.createQuery(hql); query.setLockOptions(LockOptions.UPGRADE); List<User> list = query.list(); for(User user : list){ System.out.print(user.getName()+" "); } System.out.println(); tran.commit(); sess.close(); } }
Hibernate會在生成的SQL後面加上for update子句:
Hibernate: select user0_.id as id0_, user0_.name as name0_, user0_.age as age0_
from TEST_USER user0_ where user0_.id=1 for update
longlong
通過for update子句,這條SQL鎖定了TEST_USER表中符合檢索條件的記錄,本次事務提交前,外界無法修改這些記錄,事務提交時會釋放事務過程中的鎖
Hibernate提供了2個鎖物件,LockMode和LockOptions:
通過LockOptions的原始碼,可以發現LockOptions只是LockMode的簡單封裝(在LockMode的基礎上提供了timeout和scope):
...... /** * NONE represents LockMode.NONE (timeout + scope do not apply) */ public static final LockOptions NONE = new LockOptions(LockMode.NONE); /** * READ represents LockMode.READ (timeout + scope do not apply) */ public static final LockOptions READ = new LockOptions(LockMode.READ); /** * UPGRADE represents LockMode.UPGRADE (will wait forever for lock and * scope of false meaning only entity is locked) */ public static final LockOptions UPGRADE = new LockOptions(LockMode.UPGRADE); public LockOptions(){} public LockOptions( LockMode lockMode) { this.lockMode = lockMode; } ..... public static final int NO_WAIT = 0; /** * Indicates that there is no timeout for the acquisition. * @see #getTimeOut */ public static final int WAIT_FOREVER = -1; private int timeout = WAIT_FOREVER; private boolean scope=false; ......
LockOptions提供的加鎖機制要比LockMode少很多,但是LockMode多出的加鎖機制一般只是供Hibernate內部實現使用的
保證了操作的獨佔性,但嚴重影響資料庫效能
二,樂觀鎖
樂觀鎖大多基於資料版本記錄機制實現,既為資料增加一個版本標識
在資料庫中增加version列,用來記錄每行資料的版本
Hibernate配置檔案中,version節點需要在id節點之後並緊跟id節點
<?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>
<class name="com.po.User"
table="TEST_USER">
<id name="id" column="id" type="java.lang.Integer">
<generator class="assigned"/>
</id>
<version name="version"
column="version"
type="java.lang.Integer"/>
<property name="name"
column="name"
type="java.lang.String"
not-null="true"
unique="true"
length="20"/>
<property name="age"
column="age"
type="java.lang.Integer"
not-null="true"
unique="false"
length="0"/>
</class>
</hibernate-mapping>
每次更新User物件時時,對應行的version欄位都在增加
public class Test {
public static void main(String[] args) {
Configuration conf = new Configuration();
SessionFactory sessionFactory = conf.configure().buildSessionFactory();
Session sess1=sessionFactory.openSession();
Session sess2=sessionFactory.openSession();
try{
User user1 = (User)sess1.get(User.class, 1);
User user2 = (User)sess2.get(User.class, 1);
System.out.println("v1="+user1.getVersion()+"--v2="+user2.getVersion());
Transaction tx1 = sess1.beginTransaction();
Transaction tx2 = sess2.beginTransaction();
user1.setName("ll");
tx1.commit();
System.out.println("v1="+user1.getVersion()+"--v2="+user2.getVersion());
user2.setName("LL");
tx2.commit();
}catch(Exception e){
e.printStackTrace();
}finally{
sess1.close();
sess2.close();
}
}
}
執行結果如下,可以看到由於tx1提交時,version欄位已經被修改,tx2提交時會丟擲異常:
Hibernate: select user0_.id as id0_0_, user0_.version as version0_0_, user0_.name as name0_0_, user0_.age as age0_0_
from TEST_USER user0_ where user0_.id=?
Hibernate: select user0_.id as id0_0_, user0_.version as version0_0_, user0_.name as name0_0_, user0_.age as age0_0_
from TEST_USER user0_ where user0_.id=?
v1=0--v2=0
Hibernate: update TEST_USER set version=?, name=?, age=? where id=? and version=?
v1=1--v2=0
Hibernate: update TEST_USER set version=?, name=?, age=? where id=? and version=?
Exception in thread "main" org.hibernate.StaleObjectStateException: Row was updated or deleted by another transaction
(or unsaved-value mapping was incorrect): [com.po.User#1]
at org.hibernate.persister.entity.AbstractEntityPersister.check(AbstractEntityPersister.java:1932)
at org.hibernate.persister.entity.AbstractEntityPersister.update(AbstractEntityPersister.java:2576)
at org.hibernate.persister.entity.AbstractEntityPersister.updateOrInsert(AbstractEntityPersister.java:2476)
at org.hibernate.persister.entity.AbstractEntityPersister.update(AbstractEntityPersister.java:2803)
at org.hibernate.action.EntityUpdateAction.execute(EntityUpdateAction.java:113)
at org.hibernate.engine.ActionQueue.execute(ActionQueue.java:273)
at org.hibernate.engine.ActionQueue.executeActions(ActionQueue.java:265)
at org.hibernate.engine.ActionQueue.executeActions(ActionQueue.java:185)
at org.hibernate.event.def.AbstractFlushingEventListener.performExecutions(AbstractFlushingEventListener.java:321)
at org.hibernate.event.def.DefaultFlushEventListener.onFlush(DefaultFlushEventListener.java:51)
at org.hibernate.impl.SessionImpl.flush(SessionImpl.java:1216)
at org.hibernate.impl.SessionImpl.managedFlush(SessionImpl.java:383)
at org.hibernate.transaction.JDBCTransaction.commit(JDBCTransaction.java:133)
at com.test.Test.main(Test.java:43)
除了使用version作為版本標識,還可以使用timestamp作為版本標識
timestamp節點沒有type屬性:
<?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>
<class name="com.po.User"
table="TEST_USER">
<id name="id" column="id" type="java.lang.Integer">
<generator class="assigned"/>
</id>
<timestamp name="updatetime"
column="updatetime"/>
<property name="name"
column="name"
type="java.lang.String"
not-null="true"
unique="true"
length="20"/>
<property name="age"
column="age"
type="java.lang.Integer"
not-null="true"
unique="false"
length="0"/>
</class>
</hibernate-mapping>
在某些情況下,不允許修改資料庫的表結構,此時Hibernate也有相應的處理手段:
<?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>
<class name="com.po.User"
table="TEST_USER"
optimistic-lock="all"
dynamic-update="true"
dynamic-insert="true"
>
<id name="id" column="id" type="java.lang.Integer">
<generator class="assigned"/>
</id>
<property name="name"
column="name"
type="java.lang.String"
not-null="true"
unique="true"
length="20"/>
<property name="age"
column="age"
type="java.lang.Integer"
not-null="true"
unique="false"
length="0"/>
</class>
</hibernate-mapping>
此時Hibernate將使用User類的所有欄位作為版本控制資訊
樂觀鎖相較悲觀鎖提高了不少效能,但是有一定的侷限性,由於是在應用層加鎖,如果此時在資料中直接修改資料(或其它應用程式修改資料庫中的資料),應用層是無法感知到這種變化的,需要配合其它技術手段一起使用
相關推薦
Hibernate悲觀鎖/樂觀鎖
如果需要保證資料訪問的排它性,則需對目標資料加“鎖”,使其無法被其它程式修改 一,悲觀鎖 對資料被外界(包括本系統當前的其它事務和來自外部系統的事務處理)修改持保守態度,通過資料庫提供的鎖機制實現 最常用的,是對查詢進行加鎖(LockMode.UPGRADE和LockMod
Hibernate--悲觀鎖&樂觀鎖
悲觀鎖: 悲觀鎖假定當多個事務同時訪問一個資源時,會出現併發問題。因而為了避免這些問題,悲觀鎖假定當多個事務在操作一個資源時,都先把該資源鎖起來,這樣就完全排除了當前事務受其他事務的影響。但是使用悲觀鎖影響併發效能,所以應該謹慎。使用悲觀鎖: 在Hibernate
Hibernate中悲觀鎖樂觀鎖的應用
一個典型的倚賴資料庫的悲觀鎖呼叫: select * from account where name=”Erica” for update 這條sql 語句鎖定了account 表中所有符合檢索條(name=”Erica”)的記錄。本次事務提交之前(事務
Hibernate JPA 悲觀鎖,樂觀鎖
1.悲觀鎖 它指的是對資料被外界修改持保守態度。假定任何時刻存取資料時,都可能有另一個客戶也正在存取同一筆資料,為了保持資料被操作的一致性,於是對資料採取了資料庫層次的鎖定狀態,依靠資料庫提供的鎖機制來實現。 基於jdbc實現的資料庫加鎖如下: selec
hibernate版本控制 樂觀鎖悲觀鎖
//1: 資料庫表 people 加上一列 version int //2: 實體類 people 屬性 ( private int version;) //3: 在hibernate 對映檔案class 之間 在一個表示副 id 之後加上 <version cloumn="vers
談談mysql的悲觀和樂觀鎖
更新失敗 自動 結束 lan 版本號 得到 例如 中一 其他 悲觀鎖與樂觀鎖是兩種常見的資源並發鎖設計思路,也是並發編程中一個非常基礎的概念。之前有寫過一篇文章關於並發的處理思路和解決方案,這裏我單獨將對這兩種常見的鎖機制在數據庫數據上的實現進行比較系統的介紹一次吧。 悲觀
悲觀鎖樂觀鎖實戰
查看 ring 加鎖 starting 讀取 並不是 ava 情況下 有一個 悲觀鎖介紹(百科): 悲觀鎖,正如其名,它指的是對數據被外界(包括本系統當前的其他事務,以及來自外部系統的事務處理)修改持保守態度,因此,在整個數據處理過程中,將數據處於鎖定狀態。悲觀鎖的實現,往
悲觀鎖樂觀鎖簡單整理
處理 業務邏輯 失敗 問題: 多個 處理過程 覆蓋 解決 控制 一:介紹 悲觀鎖,正如其名,具有強烈的獨占和排他特性。它指的是對數據被外界(包括本系統當前的其他事務,以及來自外部系統的事務處理)修改持保守態度,因此,在整個數據處理過程中,將數據處於鎖定狀態。悲觀鎖的實現,往
CAS無鎖演算法:ReentrantLock,synchronized(JDK 1.6),悲觀鎖/樂觀鎖
> 悲觀鎖/樂觀鎖 悲觀鎖:總是假設最壞的情況,每次去拿資料的時候都認為別人會修改,所以每次在拿資料的時候都會上鎖,這樣別人想拿這個資料就會阻塞直到它拿到鎖。傳統的關係型資料庫裡邊就用到了很多這種鎖機制,比如行鎖,表鎖等,讀鎖,寫鎖等,都是在做操作之前先上鎖。再比如J
事務 鎖 悲觀鎖 樂觀鎖 概念 應用場景 使用方式 小記
【部落格園cnblogs筆者m-yb原創(部分引用, 在文末有註明),轉載請加本文部落格連結,筆者github: https://github.com/mayangbo666,公眾號aandb7,QQ群927113708】 https://www.cnblogs.com/m-yb/p/99749
Java併發 行級鎖/欄位鎖/表級鎖 樂觀鎖/悲觀鎖 共享鎖/排他鎖 死鎖[轉]
前言 鎖是防止在兩個事務操作同一個資料來源(表或行)時互動破壞資料的一種機制。 資料庫採用封鎖技術保證併發操作的可序列性。 以Oracle為例: Oracle的鎖分為兩大類:資料鎖(也稱DML鎖)和字典鎖。 字典鎖是Oracle DBMS內部用於對字典表的封鎖。 字典鎖包括語
MySQL資料庫優化(三)——MySQL悲觀鎖&&樂觀鎖(併發控制)
一、悲觀鎖 1、排它鎖,當事務在操作資料時把這部分資料進行鎖定,直到操作完畢後再解鎖,其他事務操作才可操作該部分資料。這將防止其他程序讀取或修改表中的資料。 2、實現:大多數情況下依靠資料庫的鎖機制實現 一般使用 select ...for upd
Redis 事物、悲觀、樂觀鎖 (詳細)
1,概論 事物這東西相信大家都不陌生吧,在學習Spring,Mybatis等框架中, 只要是涉及到資料儲存和修改的,都會有事物的存在, 廢話就不多說了下面我們來簡單的介紹下Redis事物以及鎖。 2,Redis事物簡介? Re
mysql的悲觀和樂觀鎖分析
我們在操作資料庫的時候,可能會由於併發問題而引起的資料的不一致性(資料衝突),這個時候就有了鎖!!! 樂觀鎖顧明思議,想法很樂觀,在更新資料時,認為這波操作不會導致衝突,別的sql也不會對此操作進行更改,所以我線更新資料,等待提交的時候再去判斷是否衝突。 樂觀鎖需要我們自己去實現,資料庫設計上,
獨享鎖/共享鎖+公平鎖/非公平鎖+樂觀鎖/悲觀鎖
本文標題:最全Java鎖詳解:獨享鎖/共享鎖+公平鎖/非公平鎖+樂觀鎖/悲觀鎖 轉載請保留頁面地址:http://youzhixueyuan.com/detailed-explanation-of-java-lock.html 在Java併發場景中,會涉及到各種各樣的鎖如公平鎖,樂觀
最全Java鎖詳解:獨享鎖/共享鎖+公平鎖/非公平鎖+樂觀鎖/悲觀鎖
最全Java鎖詳解:獨享鎖/共享鎖+公平鎖/非公平鎖+樂觀鎖/悲觀鎖 樂觀鎖 VS 悲觀鎖 1.樂觀鎖 2.悲觀鎖 3.總之 公平鎖 VS 非公平鎖 1.公平鎖 2.非公平鎖 3.典型應用
Hibernate各類概念-樂觀鎖原理以及其配置方法
Hibernate使用樂觀鎖來處理髒資料問題首先看不使用樂觀鎖的情況 故意創造一個場景來製造髒資料。 1. 通過session1得到id=1的物件 product1 2. 在product1原來價格的基礎上增加1000 3. 更新product1之前,通過session2得
Hibernate併發控制樂觀鎖實現-Version
通過在表中及POJO中增加一個version欄位來表示記錄的版本,來達到多使用者同時更改一條資料的衝突 資料庫指令碼: createtable studentVersion (id varchar(32),name varchar(32),ver int); POJO package Versio
淺談Oracle鎖機制表鎖行鎖樂觀鎖悲觀鎖
Oracle的鎖機制主要分為行鎖和表鎖,行鎖即鎖定表中的某行資料,表鎖鎖定表中所有資料。鎖定的資料不能插入,更新,刪除,只能查詢,語法 for update。鎖的週期為一次資料提交,一次資料提交中可能會有多條SQL語句。 在大併發中為了保證某些資料的唯
關於高併發 悲觀鎖 樂觀鎖
1、考慮高併發,若不加鎖,操作同一條資料會出現後一次更改覆蓋前一次提交的資料,資料丟失; 2、加鎖分為樂觀鎖、悲觀鎖: 在hibernate情景下: 悲觀鎖的使用-----query