spring - 在 cron 作业中具有多个事务的休眠会话管理？

Question

在 spring/hibernate 应用程序中，我每晚都会运行一些 cronjobs。其中一个应该像这样在多个事务中完成它的工作：

@Scheduled(cron = "...")
public void cron ( ) 
{
    batchJob();
}

@Transactional(propagation = Propagation.NEVER)
public void batchJob ( )
{
    List<Customer> customers = getCustomers();
    for (Customer customer : customers
    {
        doSomething(customer);
    }
}

@Transactional(readOnly = true)
protected List<Customer> getCustomers ( )
{
    return customerRepository.getCustomers();
}

@Transactional
protected void doSomething (Customer customer )
{
         // LazyInitializationException 
         customer.getAddress();
         // ...
}

我的 spring 配置的一部分：

<!-- Transaction -->
<tx:annotation-driven mode="aspectj" />

<bean id="transactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
    <property name="sessionFactory" ref="sessionFactory" />
</bean>

这里的关键点是我不想有一个长时间运行的事务。因此，首先我获取所有客户并为每个客户调用一个事务方法。 （希望贴出的代码足以理解问题）

当然，我得到一个 LazyInitializationException，因为当围绕“getCustomer”的事务被提交时，Spring 正在关闭会话。

我能想到的可能解决方案：

• 我可以使用 OpenSessionInViewInterceptor，但这是一个 Web 组件

• 我可以使用 session.merge(customer) 重新附加分离的对象

• 这是 Propagation.Nestedtransaction 的情况吗？嵌套事务的语义是什么？大多数数据库没有嵌套事务（postgresql有但我没用过，叫两阶段提交

• 我可以重写方法来消费 customerId 并在第二个事务中再次加载客户

现在我有两个关于我的问题的问题：

1. 如何编写测试来重现上述错误？

2. 我怎样才能轻松地围绕这个问题跨越一个开放的会话，或者在多个事务中完成大量工作的最佳方法是什么？

Answer 1

我不太明白你关于重现它的测试的第一个问题，据我了解，你只需要在非事务性测试中调用 cron()。

关于可能的解决方案，我认为最好的解决方案是在初始查询中加载 id（只要您获得每个 Customer 的新实例进行处理并不重要）。

请注意，merge() 的解决方案与 id 的解决方案相比没有优势，它只会增加内存使用量和网络带宽消耗。另外据我所知，JpaTransactionManager 不支持嵌套事务。

从理论上讲，在这种情况下，您可以使用 extended 持久性上下文而不是 事务性 一种，但我认为不可能以这种方式配置 Spring Data JPA。

编辑： 如果您不喜欢它的外观，可以封装低级细节以将您的业务逻辑与它们分离，如下所示：

interface CustomerProcessor {
    public void process(Customer c);
}

public void processCustomersInBatchJob(CustomerProcessor processor) {
    List<Long> ids = ...;
    for (Long id: ids) {
        processCustomer(id, processor);
    }
}

@Transactional
protected void processCustomer(Long id, CustomerProcessor processor) {
    Customer c = getCustomer(id);
    processor.process(c);
}