posts - 40, comments - 187, trackbacks - 0

阅读了Hibernate的Reference之后，可以采用批量处理的方法，当插入的数据超过10000时，就flush session并且clear。

下面是一个测试method。

1 /** */ /**
2      * 测试成批插入数据的事务处理，返回是否成功
3      *
4      * @param objPO Object
5      * @return boolean
6       */
7      public boolean insertBatch( final Object objPO) {
8          boolean isSuccess = false ;
9         Transaction transaction = null ;
10         Session session = openSession();
11          try {
12             transaction = session.beginTransaction();
13              for ( int i = 0 ; i < 100000 ; i ++ ) {
14                 session.save(objPO);
15                  if (i % 50 == 0 ) {
16                      // flush a batch of inserts and release memory
17                     session.flush();
18                     session.clear();
19                 }
20             }
21             transaction.commit();
22             logger.info( " transaction.wasCommitted: "
23                      + transaction.wasCommitted());
24             isSuccess = true ;
25         } catch (HibernateException ex) {
26              if (transaction != null ) {
27                  try {
28                     transaction.rollback();
29                     logger.error( " transaction.wasRolledBack: "
30                              + transaction.wasRolledBack());
31                 } catch (HibernateException ex1) {
32                     logger.error(ex1.getMessage());
33                     ex1.printStackTrace();
34                 }
35             }
36             logger.error( " Insert Batch PO Error: " + ex.getMessage());
37             ex.printStackTrace();
38         } finally {
39              if (transaction != null ) {
40                 transaction = null ;
41             }
42             session.close();
43         }
44          return isSuccess;
45     }
46

这只是简单的测试，实际项目中遇到的问题，要比这个复杂得多。
这时候，我们可以让Spring来控制Transaction，自己来控制Hibernate的Session，随时更新数据。
首先，利用HibernateDaoSupport类来自定义个方法打开Session；

1public Session openSession(){
2
3        return getHibernateTemplate().getSessionFactory().openSession();
4
5    }

然后，用打开的Session处理你的数据；

1protected void doBusiness(Session session) {
2
3        while (true) {
4            //do your business with the opening session
5            someMethod(session);
6            session.flush();
7            session.clear();
8            logger.info("good job!");
9        }
10}

每做一次数据操作，就更新一次Session，这样可以保证每次数据操作都成功，否则就让Spring去控制它roll back吧。

最后，记得关闭Session。

Session session = openSession();
2

doBusiness(session);
3

session.close(); // 关闭session

至于处理速度呢，不会慢到哪儿去的，已经试验过了。; - )

还等什么，赶快试试吧！

THE END

posted on 2007-01-11 17:12 小立飞刀阅读(4876) 评论(3) 编辑收藏所属分类: Hibernate

FeedBack:

# re: Hibernate大数据量操作解决方案

2007-01-13 22:54 | 小车马

请问楼主,你们在项目中也是这么做的吗回复更多评论

# re: Hibernate大数据量操作解决方案

2007-01-15 10:46 | 小雪飞刀

不错，我在项目中就是按照这个思路做的回复更多评论

# re: Hibernate大数据量操作解决方案

2010-12-04 10:25 | 潇湘振宇

这个解决方案还是有问题的，我测试过通过这种方式插入20万的数据量，还勉强能够接受，完成此操作我的PC耗时1分多钟，服务层的处理很快，慢还是慢在Spring的事务提交。
如果插入25万及以上的数据量时，就会出现内存溢出了！回复更多评论

新用户注册刷新评论列表


只有注册用户登录后才能发表评论。




网站导航: 博客园 IT新闻 Chat2DB C++博客博问管理
相关文章: Hibernate Cannot release connection 了，有办法解决！又見“ORA-01461: 仅可以为插入 LONG 列的 LONG 值赋值”！使用Hibernate Annotations 维护多对多关系的心得 Hibernate不听话了-- could not initialize proxy - the owning Session was closed Hibernate3.2中Ehcache的llegalAccessError Hibernate中双向关联加载排序的解决方案 Hibernate中双向关联的加载顺序问题 Hibernate大数据量操作解决方案

2010年12月

日

一

二

三

四

五

六

生存或毁灭，这是个必答之问题：是否应默默的忍受坎苛命运之无情打击，还是应与深如大海之无涯苦难奋然为敌，并将其克服。此二抉择，究竟是哪个较崇高？

常用链接

留言簿(12)

随笔分类(43)

相册

收藏夹(7)

朋友的博客

电子资料

搜索

积分与排名

最新评论

阅读排行榜

评论排行榜