本文詳細(xì)分析了Hibernate管理Session和批量操作的用法。分享給大家供大家參考。具體分析如下:
Hibernate管理Session
Hibernate自身提供了三種管理Session對(duì)象的方法
① Session對(duì)象的生命周期與本地線程綁定
② Session對(duì)象的生命周期與JTA事務(wù)綁定
③ Hibernate委托程序管理Session對(duì)象的生命周期
在Hibernate的配置文件中,hibernate.current_session_context_class屬性用于指定Session管理方式,可選值包括:
① thread:Session對(duì)象的生命周期與本地線程綁定
② jta*:Session對(duì)象的生命周期與JTA事務(wù)綁定
③ managed:Hibernate委托程序來(lái)管理Session對(duì)象的生命周期
Session對(duì)象的生命周期與本地線程綁定:
如果把Hibernate配置文件的hibernate.current_session_context_class屬性值設(shè)置為thread,Hibernate就會(huì)按照與本地線程綁定的方式來(lái)管理Session
Hibernate按以下規(guī)則把Session與本地線程綁定:
當(dāng)一個(gè)線程(thread)第一次調(diào)用SessionFactory對(duì)象的getCurrentSession()方法時(shí),該方法會(huì)創(chuàng)建一個(gè)新的Session(sessionA)對(duì)象,把該對(duì)象與threadA綁定,并將session返回
當(dāng)threadA再次調(diào)用SessionFactory對(duì)象的getCurrentSession()方法時(shí),該方法將返回sessionA對(duì)象
當(dāng)threadA提交sessionA對(duì)象關(guān)聯(lián)的事務(wù)時(shí),Hibernate會(huì)自動(dòng)flush sessionA對(duì)象的緩存,然后提交事務(wù),關(guān)閉session隨心。當(dāng)threadA撤銷sessionA對(duì)象關(guān)聯(lián)的事務(wù)時(shí),也會(huì)自動(dòng)關(guān)閉sessionA對(duì)象
若threadA再次調(diào)用SessionFactory對(duì)象的getCurrentSession()方法時(shí),該方法會(huì)又創(chuàng)建一個(gè)新的Session(sessionB)對(duì)象,把該對(duì)象與threadA綁定,并將sessionB返回
批量處理數(shù)據(jù)
批量處理數(shù)據(jù)是指在一個(gè)事務(wù)中處理大量數(shù)據(jù)
在應(yīng)用層進(jìn)程批量操作,主要有以下方式:
① 通過(guò)Session
② 通過(guò)HQL
③ 通過(guò)StatelessSession
④ 通過(guò)JDBC API----推薦此種,因?yàn)樗俣茸羁?/p>
Session進(jìn)行批量操作:
Session的save()及update()方法都會(huì)把處理的對(duì)象存放在自己的緩存中。如果通過(guò)一個(gè)Session對(duì)象來(lái)處理大量持久化對(duì)象,應(yīng)該及時(shí)從緩存中清空已經(jīng)處理完畢并且不會(huì)再訪問(wèn)的對(duì)象。具體的做法是在處理完一個(gè)對(duì)象或小批量對(duì)象后,立即調(diào)用flush()方法刷新緩存,然后再調(diào)用clear()方法情況緩存
通過(guò)Session來(lái)進(jìn)行處理操作會(huì)受到以下約束:
需要在Hibernate配置文件中設(shè)置JDBC單次批量處理的數(shù)目,應(yīng)保證每次向數(shù)據(jù)庫(kù)發(fā)送的批量的SQL語(yǔ)句數(shù)目與batch size屬性一致
若對(duì)象采用"identity"標(biāo)識(shí)生成器,則Hibernate無(wú)法在JDBC曾進(jìn)行批量插入操作
進(jìn)行批量操作時(shí),建議關(guān)閉Hibernate的二級(jí)緩存
批量插入數(shù)據(jù)代碼演示:
News news = null;
for(int i = 0; i < 10000; i++) {
news = new News();
news.setTitle("--" + i);
session.save(news);
if((i + 1) % 20 == 0) {
session.flush();
session.clear();
}
}
批量更新:在進(jìn)行批量更新時(shí),如果一下子把所有對(duì)象都加載到Session緩存,然后再緩存中一一更新,顯然是不可取的
使用可滾動(dòng)的結(jié)果集org.hibernate.ScrollableResults,該對(duì)象中實(shí)際上并不包含任何對(duì)象,只包含用于在線定位記錄的游標(biāo)。只有當(dāng)程序遍歷訪問(wèn)ScrollableResults對(duì)象的特定元素時(shí),它才會(huì)到數(shù)據(jù)庫(kù)中加載相應(yīng)的對(duì)象
org.hibernate.ScrollableResults對(duì)象由Query的scroll方法返回
通過(guò)HQL進(jìn)行批量操作:
注意:HQL只支持INSERT INTO ... SELECT形式的插入語(yǔ)句,但不支持INSERT INTO ... VALUES形式的插入語(yǔ)句。所以使用HQL不能進(jìn)行批量插入操作
通過(guò)StatelessSession進(jìn)行批量操作:
從形式上看,StatelessSession與Session的用法類似。StatelessSession與Session相比,有以下區(qū)別:
StatelessSession沒(méi)有緩存,通過(guò)StatelessSession來(lái)加載、保存或更新后的對(duì)象處于游離狀態(tài)
StatelessSession不會(huì)與Hibernate的二級(jí)緩存交互
當(dāng)調(diào)用StatelessSession的save()、update()或delete()方法時(shí),這些方法會(huì)立即執(zhí)行相應(yīng)的SQL語(yǔ)句,而不會(huì)僅計(jì)劃執(zhí)行一條SQL語(yǔ)句
StatelessSession不會(huì)進(jìn)行臟檢查,因此修改了Customer對(duì)象屬性后,還需要調(diào)用StatelessSession的update()方法來(lái)更新數(shù)據(jù)庫(kù)中數(shù)據(jù)
StatelessSession不會(huì)對(duì)關(guān)聯(lián)的對(duì)象進(jìn)行任何的級(jí)聯(lián)操作
通過(guò)同一個(gè)StatelessSession對(duì)象兩次加載的OID為1的Customer對(duì)象,得到的兩個(gè)對(duì)象內(nèi)存地址不同
StatelessSession所做的操作可以被Interceptor攔截器捕獲到,但是會(huì)被Hibernate的事件處理系統(tǒng)忽略掉
希望本文所述對(duì)大家的Java程序設(shè)計(jì)有所幫助。