hibernate4使用原生jdbc进行批处理
Posted 稻草人
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了hibernate4使用原生jdbc进行批处理相关的知识,希望对你有一定的参考价值。
在hibernate中,有一级缓存session和二级缓存sessionFactory这些机制,一方面为编码提供了便利,同时也会有一些副作用。比如有较大的数据量交互的话,缓存反而会降低效率。最近在做一个有关批量更新的程序,在调用session.update()之后,对象会保存在缓存中,如果数据量超过缓存的容量就会出错。解决方法是:在hibernate中调用jdbc批量处理的API,使用原生的jdbc来进行批量操作。
但是这里又出现了新的问题,在hibernate4中,通过session是不能直接获取到jdbc的connection。hibernate4中提供了一个session.dowork()的方法,用来处理原生的jdbc批量操作。work是一个接口,接口方法中的参数提供了jdbc的connection,只要需要用到jdbc,就用session.dowork();然后在这个方法中实现这个接口,我觉得这里的设计非常巧妙,可复用性较高。
public void setStatus(String arrMsgID[]) { //sql语句 String updateSql = "UPDATE tb_msgboard SET status =‘1‘ WHERE msgID =?"; //通过session获取事务 Transaction ts = hbmSession.beginTransaction(); hbmSession.doWork( //实现work接口,work接口中有一个execute方法,connection就是这个方法的参数,也就是在这里获得jdbc的connection new Work(){ @Override public void execute(java.sql.Connection connection) throws SQLException { try { PreparedStatement stmt = connection.prepareStatement(updateSql); //这里进行批量操作 for (int i = 0; i < arrMsgID.length; i++) { stmt.setString(1, arrMsgID[i]); stmt.addBatch(); // 添加到批处理命令 } stmt.executeBatch(); ts.commit(); } catch (Exception e) { e.printStackTrace(); ts.rollback(); HibernateUtil.closeSession(hbmSession); } } }); HibernateUtil.closeSession(hbmSession); }
以上是关于hibernate4使用原生jdbc进行批处理的主要内容,如果未能解决你的问题,请参考以下文章