Question

怎么每次从队列里取出1000条数据并用事物提交

如题,我有一个LinkedBlockingQueue队列用于生产者消费者模式中上传数据到数据库,每一条数据取出都会调用一系列方法,最终用insert插入数据库.怎么才能一次取出1000条数据,用事务提交.消费者是一个单线程

Answer 1

你的问题是 一次性取出1000条数据还是如何使用事务

追问

如何对每取出的1000条数据使用事务

追答

假定已经有这么多条数据了，然后

try
{
    //插入1000条数据
    commit()
}
catch
{
    rollback()
}

追问

这个commit()和rollback()要配置吗?还有我循环1000次UpdateInformation updateInformation = updateMessage.take();将队列里的数据取出可以吗

追答

private Connection conn = null;  
private PreparedStatement ps = null;  
try 
{  
    conn.setAutoCommit(false);  //将自动提交设置为false  
    ps.executeInsert("插入SQL");//执行插入操作       
    conn.commit();              //当操作成功后手动提交  
}
catch (Exception e) 
{  
    conn.rollback();    
}

之前是取一条数据插入一条，现在是取一条放进队列里，等到满了1000条后，再用个for循环插入数据库，接着就是conn.commit();就好了

追问

谢谢,我从队列里拿出来的数据不能直接插入数据库的,它们要调用很多个程序,里面包括一个入库的程序,里面就有数据库连接,操作,断开的,近似于调用一个insert的biz,这样不知道怎么用

追答

这中间的所有操作都要一起提交吗？

追问

是的,都包括在提交里

追答

那就要采用JTA事务了，具体我也没做过

追问

好的,大哥谢谢,我之前选你为最佳答案的时候选错了,要不你在我其他问题下面随便按个啥,我把财富值给你

追答

没啥呢，也没帮到什么忙

Answer 2

此队列按 FIFO（先进先出）排序元素。队列的头部 是在队列中时间最长的元素。队列的尾部 是在队列中时间最短的元素。
新元素插入到队列的尾部，并且队列检索操作会获得位于队列头部的元素。链接队列的吞吐量通常要高于基于数组的队列，
但是在大多数并发应用程序中，其可预知的性能要低。
可选的容量范围构造方法参数作为防止队列过度扩展的一种方法。
如果未指定容量，则它等于 Integer.MAX_VALUE。除非插入节点会使队列超出容量，否则每次插入后会动态地创建链接节点。
1:如果未指定容量，默认容量为Integer.MAX_VALUE ，容量范围可以在构造方法参数中指定作为防止队列过度扩展。
2:此对象是 线程阻塞-安全的
3：不接受 null 元素
4:它实现了BlockingQueue接口。
5:实现了 Collection 和 Iterator 接口的所有可选 方法。
6：在JDK5/6中，LinkedBlockingQueue和ArrayBlocingQueue等对象的poll(long timeout, TimeUnit unit)存在内存泄露Leak的对象AbstractQueuedSynchronizer.Node，据称JDK5会在Update12里Fix，JDK6会在Update2里Fix

追问

大哥,别瞎答

追答

哈哈啊哈