Java中中Hibernate的批量插入的批量插入
Hibernate完全以面向对象的方式来操作数据库,当程序里以面向对象的方式操作持久化对象时,将被自动转换为对数据
库的操作。例如我们调用Session的delete()方法,来删除持久化对象,Hibernate将负责删除对应的数据记录;当我们执行持
久化对象的setter方法时,Hibernate将自动转换为底层的update语句,修改数据库的对应记录。
问题是:如果我们需要同时更新100000条记录,是不是要逐一加载100000条记录,然后依次调用setter方法——这样不
仅烦琐,数据访问的性能也十分糟糕。为了面对这种批量处理的场景,Hibernate提供了批量处理的解决方案。下面分别从批
量插入、批量更新和批量删除三个方面介绍如何面对这种批量处理的情形。
批量插入
如果需要将100000条记录插入数据库,通过Hibernate可能会采用如下做法:
1.Session session = sessionFactory.openSession();
2.Transaction tx = session.beginTransaction();
3.//循环100000次来插入100000条记录
4.for ( int i=0; i<100000; i++ )
5.{
6. User u = new User (…..);
7. session.save(u);
8.}
9.tx.commit();
10.session.close();
但随着这个程序的运行,总会在某个时候运行失败,并且抛出OutOfMemoryException(内存溢出异常)。这是因为
Hibernate的Session持有一个必选的一级缓存,所有的User实例都将在Session级别的缓存区进行了缓存的缘故。
为了解决这个问题,有个非常简单的思路:定时将Session缓存的数据刷入数据库,而不是一直在Session级别缓存。可
以考虑设计一个累加器,每保存一个User实例,累加器增加1。根据累加器的值决定是否需要将Session缓存中的数据刷入数
据库。
下面是增加100000个User实例的代码片段。
程序清单:codes66.3atchInsertsrcleeUserManager.java
1.private void addUsers()throws Exception
2.{
3. //打开Session
4. Session session = HibernateUtil.currentSession();
5. //开始事务
6. Transaction tx = session.beginTransaction();
7. //循环100000次,插入100000条记录
8. for (int i = 0 ; i < 100000 ; i++ )
9. {
10. //创建User实例
11. User u1 = new User();
12. u1.setName("xxxxx" + i);
13. u1.setAge(i);
14. u1.setNationality("china");
15. //在Session级别缓存User实例
16. session.save(u1);
17. //每当累加器是20的倍数时,将Session中数据刷入数据库,
18. //并清空Session缓存。
19. if (i % 20 == 0)
20. {
21. session.flush();
22. session.clear();
23. }
24. }
25. //提交事务
26. tx.commit();
27. //关闭事务
28. HibernateUtil.closeSession();
29.}
上面的代码中当i % 20 == 0时,手动将Session处缓存的数据写入数据,并且清空Session缓存里的数据。除了要对
评论0