在Hibernate中处理批量更新和批量删除
批量更新是指在一個(gè)事務(wù)中更新大批量數(shù)據(jù),批量刪除是指在一個(gè)事務(wù)中刪除大批量數(shù)據(jù)。以下程序直接通過Hibernate API批量更新CUSTOMERS表中年齡大于零的所有記錄的AGE字段: 如果CUSTOMERS表中有1萬條年齡大于零的記錄,那么Session的find()方法會(huì)一下子加載1萬個(gè)Customer對(duì)象到內(nèi)存。當(dāng)執(zhí)行tx.commit()方法時(shí),會(huì)清理緩存,Hibernate執(zhí)行1萬條更新CUSTOMERS表的update語句:
view plaincopy to clipboardprint?
update CUSTOMERS set AGE=? …. where ID=i;?? update CUSTOMERS set AGE=? …. where ID=j;?? ……?? update CUSTOMERS set AGE=? …. where ID=k;?? update CUSTOMERS set AGE=? …. where ID=i;update CUSTOMERS set AGE=? …. where ID=j;……update CUSTOMERS set AGE=? …. where ID=k;
以上批量更新方式有兩個(gè)缺點(diǎn): (1)占用大量?jī)?nèi)存,必須把1萬個(gè)Customer對(duì)象先加載到內(nèi)存,然后一一更新它們。
(2)執(zhí)行的update語句的數(shù)目太多,每個(gè)update語句只能更新一個(gè)Customer對(duì)象,必須通過1萬條update語句才能更新一萬個(gè)Customer對(duì)象,頻繁的訪問數(shù)據(jù)庫,會(huì)大大降低應(yīng)用的性能。為了迅速釋放1萬個(gè)Customer對(duì)象占用的內(nèi)存,可以在更新每個(gè)Customer對(duì)象后,就調(diào)用Session的evict()方法立即釋放它的內(nèi)存:
view plaincopy to clipboardprint?
tx = session.beginTransaction();?? Iterator customers=session.find("from Customer c where c.age>0").iterator();?? while(customers.hasNext()){?? Customer customer=(Customer)customers.next();?? customer.setAge(customer.getAge()+1);?? session.flush();?? session.evict(customer);?? }????tx.commit();?? session.close();?? tx = session.beginTransaction();Iterator customers=session.find("from Customer c where c.age>0").iterator();while(customers.hasNext()){Customer customer=(Customer)customers.next();customer.setAge(customer.getAge()+1);session.flush();session.evict(customer);} tx.commit();session.close();
在以上程序中,修改了一個(gè)Customer對(duì)象的age屬性后,就立即調(diào)用Session的flush()方法和evict()方法,flush()方法使Hibernate立刻根據(jù)這個(gè)Customer對(duì)象的狀態(tài)變化同步更新數(shù)據(jù)庫,從而立即執(zhí)行相關(guān)的update語句;evict()方法用于把這個(gè)Customer對(duì)象從緩存中清除出去,從而及時(shí)釋放它占用的內(nèi)存。 但evict()方法只能稍微提高批量操作的性能,因?yàn)椴还苡袥]有使用evict()方法,Hibernate都必須執(zhí)行1萬條update語句,才能更新1萬個(gè)Customer對(duì)象,這是影響批量操作性能的重要因素。假如Hibernate能直接執(zhí)行如下SQL語句: update CUSTOMERS set AGE=AGE+1 where AGE>0; 那么,以上一條update語句就能更新CUSTOMERS表中的1萬條記錄。但是Hibernate并沒有直接提供執(zhí)行這種update語句的接口。應(yīng)用程序必須繞過Hibernate API,直接通過JDBC API來執(zhí)行該SQL語句:
view plaincopy to clipboardprint?
tx = session.beginTransaction();?? Connection con=session.connection();?? PreparedStatement stmt=con.prepareStatement("update CUSTOMERS set AGE=AGE+1 "??+"where AGE>0 ");?? stmt.executeUpdate();?? tx.commit();?? tx = session.beginTransaction();Connection con=session.connection();PreparedStatement stmt=con.prepareStatement("update CUSTOMERS set AGE=AGE+1 "+"where AGE>0 ");stmt.executeUpdate();tx.commit();
以上程序演示了繞過Hibernate API,直接通過JDBC API訪問數(shù)據(jù)庫的過程。應(yīng)用程序通過Session的connection()方法獲得該Session使用的數(shù)據(jù)庫連接,然后通過它創(chuàng)建PreparedStatement對(duì)象并執(zhí)行SQL語句。值得注意的是,應(yīng)用程序仍然通過Hibernate的Transaction接口來聲明事務(wù)邊界。
轉(zhuǎn)載于:https://www.cnblogs.com/soundcode/archive/2010/12/20/1911941.html
總結(jié)
以上是生活随笔為你收集整理的在Hibernate中处理批量更新和批量删除的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 为何中国大陆的电视剧的集数,需要考虑受限
- 下一篇: [解决]eclipse中android自