在循环中执行插入时的javax.persistence.TransactionRequiredException

Question

我有一个使用Spring,Hibernate和JTA的应用程序.

我们收到了一个数据大于预期的请求(10000个元素),一般请求是10-100个元素.

在处理此请求时,我们尝试在DB中为每个元素插入一条记录,并在for循环中完成

伪代码:

processRecords( list){

for (Element element: list){

dao.findBy -- This takes around 100 ms

-- some other checks and logic

dao.add(element); -- This takes around 150 ms
dao.flush();
 }

}

这个块花了很多时间来处理记录然后我得到*

"javax.persistence.TransactionRequiredException:没有正在进行的事务"

*

我尝试将flush从for循环移出,没有帮助,我尝试研究hibernate的批量插入,但这是一个包含大量自定义的巨大应用程序,我不认为这是一个选项,因为它会影响整个应用程序,此外,我尝试找到配置的交易持续时间在哪里,只有我能找到的地方是在weblogic上的JTA,它被设置为480秒.

任何关于如何解决这种情况的指标都将非常感激.

编辑:增加weblogic中的JTA Timeout暂时解决了问题,但是我把它设置为一个非常大的值5000秒,无论如何都有提高性能,因为我只是插入8K记录(我知道批处理是一个选项,但是在自定义"框架"中存在一些限制)

Answer 1

使用@Transactional来控制事务.

1. 确保不会使用PROPAGATION_NEVER自动启动交易
2. 通过使用REQUIRES_NEW调用服务方法,为列表中的每个项目(或列表中的项目子集)启动新事务.

在第二步中,您可能希望调用另一个bean,以便实际拾取事务注释,不记得这是否适用于同一对象上的方法.