以下程序直接通過Hibernate API批量更新CUSTOMERS表中年齡大于零的所有記錄的AGE字段: 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);} tx.commit();session.close();
如果CUSTOMERS表中有1萬條年齡大于零的記錄,那么Session的find()方法會一下子加載1萬個Customer對象到內(nèi)存。當執(zhí)行tx.commit()方法時,會清理緩存,Hibernate執(zhí)行1萬條更新CUSTOMERS表的update語句: update CUSTOMERS set AGE=? …. where ID=i;update CUSTOMERS set AGE=? …. where ID=j;……update CUSTOMERS set AGE=? …. where ID=k;
以上批量更新方式有兩個缺點: (1)占用大量內(nèi)存,必須把1萬個Customer對象先加載到內(nèi)存,然后一一更新它們。 (2)執(zhí)行的update語句的數(shù)目太多,每個update語句只能更新一個Customer對象,必須通過1萬條update語句才能更新一萬個Customer對象,頻繁的訪問數(shù)據(jù)庫,會大大降低應用的性能。 為了迅速釋放1萬個Customer對象占用的內(nèi)存,可以在更新每個Customer對象后,就調(diào)用Session的evict()方法立即釋放它的內(nèi)存: 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();
在以上程序中,修改了一個Customer對象的age屬性后,就立即調(diào)用Session的flush()方法和evict()方法,flush()方法使Hibernate立刻根據(jù)這個Customer對象的狀態(tài)變化同步更新數(shù)據(jù)庫,從而立即執(zhí)行相關的update語句;evict()方法用于把這個Customer對象從緩存中清除出去,從而及時釋放它占用的內(nèi)存。 但evict()方法只能稍微提高批量操作的性能,因為不管有沒有使用evict()方法,Hibernate都必須執(zhí)行1萬條update語句,才能更新1萬個Customer對象,這是影響批量操作性能的重要因素。假如Hibernate能直接執(zhí)行如下SQL語句: update CUSTOMERS set AGE=AGE+1 where AGE>0;
以上程序演示了繞過Hibernate API,直接通過JDBC API訪問數(shù)據(jù)庫的過程。應用程序通過Session的connection()方法獲得該Session使用的數(shù)據(jù)庫連接,然后通過它創(chuàng)建PreparedStatement對象并執(zhí)行SQL語句。值得注意的是,應用程序仍然通過Hibernate的Transaction接口來聲明事務邊界。 如果底層數(shù)據(jù)庫(如Oracle)支持存儲過程,也可以通過存儲過程來執(zhí)行批量更新。存儲過程直接在數(shù)據(jù)庫中運行,速度更加快。在Oracle數(shù)據(jù)庫中可以定義一個名為batchUpdateCustomer()的存儲過程,代碼如下: create or replace procedure batchUpdateCustomer(p_age in number) asbeginupdate CUSTOMERS set AGE=AGE+1 where AGE>p_age;end;
從上面程序看出,應用程序也必須繞過Hibernate API,直接通過JDBC API來調(diào)用存儲過程。 Session的各種重載形式的update()方法都一次只能更新一個對象,而delete()方法的有些重載形式允許以HQL語句作為參數(shù),例如: session.delete("from Customer c where c.age>0");
如果CUSTOMERS表中有1萬條年齡大于零的記錄,那么以上代碼能刪除一萬條記錄。但是Session的delete()方法并沒有執(zhí)行以下delete語句: delete from CUSTOMERS where AGE>0;
Session的delete()方法先通過以下select語句把1萬個Customer對象加載到內(nèi)存中: select * from CUSTOMERS where AGE>0;
接下來執(zhí)行一萬條delete語句,逐個刪除Customer對象: delete from CUSTOMERS where ID=i;delete from CUSTOMERS where ID=j;……delete from CUSTOMERS where ID=k;