zoukankan      html  css  js  c++  java
  • 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);
    	}
    
  • 相关阅读:
    BZOJ 3924: [Zjoi2015]幻想乡战略游戏
    codevs 4244 平衡树练习
    BZOJ 2002: [Hnoi2010]Bounce 弹飞绵羊
    BZOJ 2038: [2009国家集训队]小Z的袜子
    luogu P3709 大爷的字符串题
    BZOJ 2120: 数颜色
    luogu P2056 采花
    luogu P2709 小B的询问
    BZOJ 1878: [SDOI2009]HH的项链
    Codeforces 221d D. Little Elephant and Array
  • 原文地址:https://www.cnblogs.com/hello-daocaoren/p/6740331.html
Copyright © 2011-2022 走看看