赛迪网 > IT技术 Java > 架构-与-模式
  IT资讯搜索
 
IT产品搜索
[程序开发][网管世界][网络安全][数据库技术]
[操作系统][嘉宾聊天·在线访谈][活动集锦]
[精彩专题][Symantec专区][订阅IT技术周刊]
[开发论坛][网管论坛][安全论坛][数据库论坛]
[操作系统论坛][Sybase专区][IBM dW技术专区]
[病毒求助][病毒与漏洞播报][文档·源码下载]

Hibernate应用中如何处理批量更新和删除

发布时间:2008.01.14 05:01     来源:赛迪网    作者:huanglz

批量更新是指在一个事务中更新大批量数据,批量删除是指在一个事务中删除大批量数据。以下程序直接通过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语句中更新或删除大批量的数据。 
       (责任编辑:包春林)


[ 发表评论 ] 字体[  ] [ 打印 ] [ 进入博客 ] [ 进入论坛 ]  [ 推荐给朋友 ]
  相关文章
· 高级:Java/J2EE中文问题终极解决之道 (01-11) · 程序人生--非常讨人喜欢的27个原则 (01-11)
· 程序人生--职场里终身受益的3条忠告 (01-11) · 程序员怎么样保证自己的程序没有BUG! (01-11)
· cownew开源-给hibernateTools写个插件 (01-11) · 通过Hibernate_tool生成代码和映射文件 (01-11)
· 进阶:使用浮点数和小数中的技巧和陷阱 (01-11) · 服务器及中间件:JBoss4.0数据源配置大全 (01-11)
· JDK核心API:Java1.5语言新特性简单总结 (01-11) · Java GUI:在Java中监控文本框的变化 (01-11)
  客户需求反馈表
* 姓  名:
更多资料  了解方案  认识厂商
* 单位名称:
* 联系电话:
* 电子邮件:
  赛迪推荐  
  手机·资费 ·新品·导购·评测·手机资费·宽带
手机搜索  诺基亚 N73 MOTO Z6
  IT产品 ·笔记本·台式机·服务器·打印·投影
IT产品搜索 
  IT技术 ·开发·网管·安全·数据库·操作系统
  信息化 ·热点·专题·访谈·周刊·方案案例
· 中小企业网站建设存在弊端 手机实名推波助澜
· CIO应如何克服三个关键错误信念 CIO委屈定理
· 五条黄金准则能够让CIO巧妙加薪 CIO焦虑调查
· 网上书店解决方案 深圳边检指挥中心ITSM项目
  IT博客 ·曾剑秋·项立刚·Java学习·网管
  IT技术论坛 ·开发·网管·安全·数据库·系统