hibernate批量修改，批量刪除

在Hibernate應用中如何處理批量更新和批量刪除？

批量更新是指在一個事務中更新大批量數據，批量刪除是指在一個事務中刪除大批量數據。如下程序直接經過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對象到內存。當執行tx.commit()方法時，會清理緩存，Hibernate執行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) 佔用大量內存，必須把1萬個Customer對象先加載到內存，而後一一更新它們。
(2) 執行的update語句的數目太多，每一個update語句只能更新一個Customer對象，必須經過1萬條update語句才能更新一萬個Customer對象，頻繁的訪問數據庫，會大大下降應用的性能。

爲了迅速釋放1萬個Customer對象佔用的內存，能夠在更新每一個Customer對象後，就調用Session的evict()方法當即釋放它的內存：

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屬性後，就當即調用Session的flush()方法和evict()方法，flush()方法使Hibernate馬上根據這個Customer對象的狀態變化同步更新數據庫，從而當即執行相關的update語句；evict()方法用於把這個Customer對象從緩存中清除出去，從而及時釋放它佔用的內存。

但evict()方法只能稍微提升批量操做的性能，由於無論有沒有使用evict()方法，Hibernate都必須執行1萬條update語句，才能更新1萬個Customer對象，這是影響批量操做性能的重要因素。假如Hibernate能直接執行以下SQL語句：

update CUSTOMERS set AGE=AGE+1 where AGE>0;

那麼以上一條update語句就能更新CUSTOMERS表中的1萬條記錄。可是Hibernate並無直接提供執行這種update語句的接口。應用程序必須繞過Hibernate API，直接經過JDBC API來執行該SQL語句：

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訪問數據庫的過程。應用程序經過Session的connection()方法得到該Session使用的數據庫鏈接，而後經過它建立PreparedStatement對象並執行SQL語句。值得注意的是，應用程序仍然經過Hibernate的Transaction接口來聲明事務邊界。

若是底層數據庫（如Oracle）支持存儲過程，也能夠經過存儲過程來執行批量更新。存儲過程直接在數據庫中運行，速度更加快。在Oracle數據庫中能夠定義一個名爲batchUpdateCustomer()的存儲過程，代碼以下：

create or replace procedure batchUpdateCustomer(p_age in number) as
begin
update CUSTOMERS set AGE=AGE+1 where AGE>p_age;
end;

以上存儲過程有一個參數p_age，表明客戶的年齡，應用程序可按照如下方式調用存儲過程：

tx = session.beginTransaction();
Connection con=session.connection();

String procedure = "{call batchUpdateCustomer(?) }";
CallableStatement cstmt = con.prepareCall(procedure);
cstmt.setInt(1,0); //把年齡參數設爲0
cstmt.executeUpdate();
tx.commit();

從上面程序看出，應用程序也必須繞過Hibernate API，直接經過JDBC API來調用存儲過程。

Session的各類重載形式的update()方法都一次只能更新一個對象，而delete()方法的有些重載形式容許以HQL語句做爲參數，例如：

session.delete("from Customer c where c.age>0");

若是CUSTOMERS表中有1萬條年齡大於零的記錄，那麼以上代碼能刪除一萬條記錄。可是Session的delete()方法並無執行如下delete語句：

delete from CUSTOMERS where AGE>0;

Session的delete()方法先經過如下select語句把1萬個Customer對象加載到內存中：

select * from CUSTOMERS where AGE>0;

接下來執行一萬條delete語句，逐個刪除Customer對象：

delete from CUSTOMERS where ID=i;
delete from CUSTOMERS where ID=j;
……
delete from CUSTOMERS where ID=k;

因而可知，直接經過Hibernate API進行批量更新和批量刪除都不值得推薦。而直接經過JDBC API執行相關的SQL語句或調用相關的存儲過程，是批量更新和批量刪除的最佳方式，這兩種方式都有如下優勢：

(1) 無需把數據庫中的大批量數據先加載到內存中，而後逐個更新或修改它們，所以不會消耗大量內存。
(2) 能在一條SQL語句中更新或刪除大批量的數據。

 

http://blog.csdn.net/budongheshang/article/details/3594409