臟數(shù)據(jù)檢查:
什么是臟數(shù)據(jù)?臟數(shù)據(jù)并不是廢棄和無用的數(shù)據(jù),而是狀態(tài)前后發(fā)生變化的數(shù)據(jù)。我們看下面的代碼:
Transaction tx=session.beginTransaction();
User user=(User)session.load(User.class,”1”);//從數(shù)據(jù)庫中加載符合條件的數(shù)據(jù)
user.setName(“zx”);//改變了user對象的姓名屬性,此時user對象成為了所謂的“臟數(shù)據(jù)”
tx.commit();
當事務(wù)提交時,Hibernate會對session中的PO(持久化對象)進行檢測,判斷持久化對象的狀態(tài)是否發(fā)生了改變,如果發(fā)生了改變就會將改變更新到數(shù)據(jù)庫中。這里就存在一個問題,Hibernate如何來判斷一個實體對象的狀態(tài)前后是否發(fā)生了變化。也就是說Hibernate是如何檢查出一個數(shù)據(jù)已經(jīng)變臟了。
通常臟數(shù)據(jù)的檢查有如下兩種辦法:
A、數(shù)據(jù)對象監(jiān)控:
數(shù)據(jù)對象監(jiān)控是通過攔截器對數(shù)據(jù)對象的setter方法進行監(jiān)控來實現(xiàn)的,這類似于數(shù)據(jù)庫中的觸發(fā)器的概念,當某一個對象的屬性調(diào)用了setter方法而發(fā)生了改變,這時攔截器會捕獲這個動作,并且將改屬性標志為已經(jīng)改變,在之后的數(shù)據(jù)庫操作時將其更新到數(shù)據(jù)庫中。這個方法的優(yōu)點是提高了數(shù)據(jù)更新的同步性,但是這也是它的缺點,如果一個實體對象有很多屬性發(fā)生了改變,勢必造成大量攔截器回調(diào)方法的調(diào)用,這些攔截器都是通過Dynamic Proxy或者CGLIB實現(xiàn)的,在執(zhí)行時都會付出一定的執(zhí)行代價,所以有可能造成更新操作的較大延時。
B、數(shù)據(jù)版本比對:
這種方法是在持久化框架中保存數(shù)據(jù)對象的最近讀取版本,當提交數(shù)據(jù)時將提交的數(shù)據(jù)與這個保存的版本進行比對,如果發(fā)現(xiàn)發(fā)生了變化則將其同步跟新到數(shù)據(jù)庫中。這種方法降低了同步更新的實時性,但是當一個數(shù)據(jù)對象的很多屬性發(fā)生改變時,由于持久層框架緩存的存在,比對版本時可以充分利用緩存,這反而減少了更新數(shù)據(jù)的延遲。
在Hibernate中是采用數(shù)據(jù)版本比對的方法來進行臟數(shù)據(jù)檢查的,我們結(jié)合下面的代碼來講解Hibernate的具體實現(xiàn)策略。
Transaction tx=session.beginTransaction();
User user=(User)session.load(User.class,”1”);
user.setName(“zx”);
tx.commit();
當調(diào)用tx.commit();時好戲就此開場,commit()方法會調(diào)用session.flush()方法,在調(diào)用flush()方法時,會首先調(diào)用flushEverything()來進行一些預處理(如調(diào)用intercepter,完成級聯(lián)操作等),然后調(diào)用flushEntities()方法,這個方法是進行臟數(shù)據(jù)檢查的關(guān)鍵。
在繼續(xù)講解之前,我要先來介紹一個內(nèi)部數(shù)據(jù)結(jié)構(gòu)EntityEntry,EntityEntry是從屬于SessionImpl(Session接口的實現(xiàn)類)的內(nèi)部類,每一個EntityEntry保存了最近一次與數(shù)據(jù)庫同步的實體原始狀態(tài)信息(如:實體的版本信息,實體的加鎖模式,實體的屬性信息等)。除了EntityEntry結(jié)構(gòu)之外,還存在一個結(jié)構(gòu),這個結(jié)構(gòu)稱為EntityEntries,它也是SessionImpl的內(nèi)部類,而且是一個Map類型,它以”key-value”的形式保存了所有與當前session實例相關(guān)聯(lián)的實體對象和原始狀態(tài)信息,其中key是實體對象,value是EntityEntry。而flushEntities()的工作就是遍歷entityEntities,并將其中的實體對象與原始版本進行對比,判斷實體對象是否發(fā)生來了改變。flushEntities()首先會判斷實體的ID是否發(fā)生了改變,如果發(fā)生了改變則認為發(fā)生了異常,因為當前實體與EntityEntry的對應(yīng)關(guān)系非法。如果沒有發(fā)生異常,而且經(jīng)過版本比對判斷確實實體屬性發(fā)生了改變,則向當前的更新任務(wù)隊列中加入一個新的更新任務(wù),此任務(wù)將在將在session.flush()方法中的execute()方法的調(diào)用中,轉(zhuǎn)化為相應(yīng)的SQL語句交由數(shù)據(jù)庫去執(zhí)行。最后Transaction將會調(diào)用當前session對應(yīng)的JDBC Connection的commit()方法將當前事務(wù)提交。
臟數(shù)據(jù)檢查是發(fā)生在顯示保存實體對象時,所謂顯示保存是指在代碼中明確使用session調(diào)用save,update,saveOrupdate方法對實體對象進行保存,如:session.save(user);但是有時候由于級聯(lián)操作的存在,會產(chǎn)生一個問題,比如當保存一個user對象時,會根據(jù)user對象的狀態(tài)來對他所關(guān)聯(lián)的address對象進行保存,但是此時并沒有根據(jù)級聯(lián)對象的顯示保存語句。此時需要Hibernate能根據(jù)當前對象的狀態(tài)來判斷是否要將級聯(lián)對象保存到數(shù)據(jù)庫中。此時,Hibernate會根據(jù)unsaved-value進行判斷。Hibernate將首先取出目標對象的ID,然后將ID與unsaved-value值進行比較,如果相等,則認為實體對象尚未保存,進而馬上將進行保存,否則,則認為實體對象已經(jīng)保存,而無須再次進行保存。比如,當向一個user對象新加入一個它所關(guān)聯(lián)的address對象后,當進行session.save(user)時,Hibernate會根據(jù)unsaved-value的值判斷出哪個address對象需要保存,對于新加入的address對象它的id尚未賦值,以此為null,與unsaved-value值相等,因此Hibernate會將其視為未保存對象,生成insert語句加以保存。如果想使用unsaved-value必須如下配置address對象的id屬性:
……
<id name=”id” type=”java.lang.Integer” unsaved-value=”null”>
<generator class=”increment”/>
</id>
……