【Hibernate框架】批量操作Batch总结

在我们做.net系统的时候，所做的最常见的批量操作就是批量导入、插入、更新、删除等等，以前我们怎么做呢？基本上有以下几种方式：

1、利用循环调用insert方法，一条条插入。

[java] view plain copy

print?





public boolean insertStudent(List<Student> studentList)

{

try{

if(studentList.count !=0){

for(int i=0;i<studentList.count;i++){

//调用save方法

}

return true;

}

}catch(Exception ex){

throw New Exception("插入失败，请重试！")

return false;

}

}

2、利用循环做sql语句拼接，然后批量执行sql语句。

[java] view plain copy

print?





public boolean insertStudent(List<Student> studentList)

{

try{

if(studentList.count !=0){

stringBuffer strSqltxt="";

for(int i=0;i<studentList.count;i++){

strSqltxt.append("insert into TableName (……) values (……);"

}

cmd.executesql(strSqltxt.toString());

}

}catch(Exception ex){

throw New Exception("插入失败，请重试！")

return false;

}

}

可是，对于封装比较完善的hibernate持久层，我们又能怎么做呢?

最常见的，也是利用循环来批量操作，但是，这里有一个必须要注意的点，就是缓存或者说是session区的空间是有限的，禁不起我们无限制的存放，所以，当我们执行以下操作时，会抛异常，内存溢出OutOfMemoryException！

[java] view plain copy

print?





Session session = sessionFactory.openSession();

Transaction tx = session.beginTransaction();

for ( int i=0; i<100000; i++ ) {

Customer customer = new Customer(.....);

session.save(customer);

}

tx.commit();

session.close();

这样是不可以的，但是在这时，hibernate也给我们提供了解决方法，就是我们可以通过设置JDBC的批量抓去数量参数（batch size）来设置一个合适的值，比如说10-50-100不等，配置：

[html] view plain copy

print?





<span style="font-size:18px;"><property name="hibernate.jdbc.batch_size">100</property></span>

另外，我们还可以显示的禁用二级缓存，以前我们也提到过：

<property name="hibernate.cache.use_second_level_cache">false</property>

正确代码：

[java] view plain copy

print?





Session session = sessionFactory.openSession();

Transaction tx = session.beginTransaction();

for ( int i=0; i<100000; i++ ) {

Customer customer = new Customer(.....);

session.save(customer);

if(i%100==0){//100, 和配置的JDBC batch size一样

session.fulsh();//刷出并同步到底层持久化， 批量的插入并且释放内存:

session.clear(); //完全清除session

}

}

tx.commit();

session.close();

这样就能解决我们的那个内存溢出的问题，因为当你的存储对象数超过你设定的能接受的合理值的时候，程序会自动将持久化对象flush进数据缓存起来，然后清空session，进行下一轮存储，待所有数据全部完成，执行commit进行提交，数据库更新数据，说的简单，这样的效率是不咋地的，不信你可以试试，你想想，先发出sql，100一轮，执行1000轮用来缓存sql语句，然后数据库统一执行sql，时间啊！

StatelessSession（无状态session）接口

但是这不是问题，因为hibernate还给我们提供了一个StatelessSession（无状态session）接口，作为选择，Hibernate提供了基于命令的API：

1、可以用detached object（托管对象）的形式把数据以流的方法加入到数据库，或从数据库输出。

2、StatelessSession没有持久化上下文，也不提供多少高层的生命周期语义。

3、无状态session不实现第一级cache；

4、也不和第二级缓存交互，也不和查询缓存交互。

5、它不实现事务化写，也不实现脏数据检查。

6、用stateless session进行的操作甚至不级联到关联实例。

7、stateless session忽略集合类(Collections)。

8、通过stateless session进行的操作不触发Hibernate的事件模型和拦截器。

9、无状态session对数据的混淆现象免疫，因为它没有第一级缓存。

10、无状态session是低层的抽象，和低层JDBC相当接近。换句话说，它可以直接操作数据。

[java] view plain copy

print?





StatelessSession session = sessionFactory.openStatelessSession();

Transaction tx = session.beginTransaction();

ScrollableResults customers = session.getNamedQuery("GetCustomers")

.scroll(ScrollMode.FORWARD_ONLY);

while ( customers.next() ) {

Customer customer = (Customer) customers.get(0);

customer.updateStuff(...);

session.update(customer);

}

tx.commit();

session.close();

DML（Data Manipulation Language数据操作语言）风格操作

再有就是特殊服务（业务需求）需要我们采用DML（Data Manipulation Language数据操作语言）风格操作，从一张表导入另一张表数据，比方说从学生表（T_Studeng）里面往大三学生表(T_ThreeStudent)里面倒数据.

[java] view plain copy

print?





Session session = sessionFactory.openSession();

Transaction tx = session.beginTransaction();

String hqlInsert = "insert into ThreeStudent(id, name) select s.id, s.name from Student s where ...";

int createdEntities = s.createQuery( hqlInsert )

.executeUpdate();

tx.commit();

session.close();

以上就是对批量操作的一点总结，万望对大家能有点帮助