标签：style blog java color 使用 os 文件 数据
如题，有两种方法
1）使用FLUSH
2）使用JDBC
分别来解释：
1）hibernate在进行数据库操作的时候，都要有事务支持的。可能你曾遇到过，没有加事务，程序会报错的情况。
而事务每次提交的时候，都会和数据库交互，即让数据库执行SQL语句。
在说到hibernate中的save() 或者saveOrUpdate()方法，其实，它们都是利用hibernate的一级缓存，在事务没有提交的时候，所有对象，并没有写入数据库。而是保存在内存中。在事务提交的时候，hibernate会把这些对象持久化到数据库中。另一方面，hibernate提供了一个显式的API来强制写数据库。就是FLUSH。当程序执行session.flush()，就会持久化数据，而不必等到事务提交时才执行。
本人写了一个DEMO，一个线程产生USER，一个保存USER。
生产者代码如下：
package com.baidu.test; import java.util.ArrayList; import java.util.Collections; import java.util.List; import com.baidu.model.User; public class test extends Thread { public static int count = 0; public static List<User> userlist = Collections.synchronizedList(new ArrayList()); public User user; public static void main(String[] args) { new test().start(); new HandleThread().start(); } public static int usercount=0; @Override public void run() { while (true) { try { Thread.sleep(2000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } User t = new User(); t.setId(usercount); t.setUsername("name_" + usercount); userlist.add(t); System.out.println("生产出一个user_"+usercount); usercount++; } } }
消费者代码如下：
package com.baidu.test; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.Transaction; import org.hibernate.cfg.Configuration; import com.baidu.model.User; public class HandleThread extends Thread { @Override public void run() { boolean flag=false; Configuration config = new Configuration(); config.configure(); SessionFactory factory = config.buildSessionFactory(); Session session = factory.openSession(); while (true) { if (test.userlist.size() > 0) { for (int i = 0; i < test.userlist.size(); i++) { System.out.println("处理了" + test.userlist.get(i).getId()); insert(test.userlist.get(i),session); } test.userlist.clear(); } try { Thread.sleep(3000); } catch (InterruptedException e) { e.printStackTrace(); } if(flag) break; } session.close(); } public void insert(User user,Session session) { Transaction tran = session.beginTransaction(); session.save(user); if (test.count++ % 10 == 0) { System.out.println(test.count); session.flush(); session.clear(); } tran.commit(); } }
if (test.count++ % 10 == 0) {
System.out.println(test.count);
session.flush();
session.clear();
}
这段代码就是执行批量操作的核心。当然这个需要在hibernate配置文件中配置下
<property name="hibernate.jdbc.batch_size">10</property>
这个值，从网上得到的说法是一次推送SQL语句的条数。暂且相信了，后续我将验证（通过抓包）。
至此，第一种批量处理已经完成。
2） to be continue...
hibernate 批量插入数据,布布扣,bubuko.com
标签：style blog java color 使用 os 文件 数据
原文地址：http://www.cnblogs.com/shenghaishiweini/p/3865901.html
