如何将Spring事务传播到另一个线程？

Question

也许，我做错了什么，但对于以下情况我找不到好的出路。

我想对一个使用 Spring Batch 执行作业的服务进行单元测试。这些作业通过预先配置的 AsyncTaskExecutor 在单独的线程中执行。在我的单元测试中，我想：

1. 创建一些域对象并通过 DAO 保存它们
2. 调用服务方法来启动作业
3. 等待作业完成
4. 使用 DAO 检索域对象并检查它们的状态

显然，以上所有内容都应该在一笔交易，但不幸的是，交易不会传播到新线程（我了解其背后的原理）。

我想到的想法：

• 在步骤 (1) 之后提交事务#1。不好，因为单元测试后应该回滚数据库状态。
• 在作业配置中使用Isolation.READ_UNCOMMITTED。但这需要两种不同的配置用于测试和生产。

Answer 1

我认为最简单的解决方案是在测试执行期间使用 SyncTaskExecutor 配置 JobLauncher - 这样作业就在与测试相同的线程中执行并共享事务。

任务执行器配置可以移动到单独的 spring 配置 xml 文件中。它有两个版本 - 一个是在测试期间使用的 SyncTaskExecutor，另一个是用于生产运行的 AsyncTaskExecutor。

Answer 2

尽管这不是您问题的真正解决方案，但我发现可以在工作线程内手动启动新事务。在某些情况下，这可能就足够了。

来源： Spring 程序化事务。

例子：

@PersistenceContext
private EntityManager entityManager;
@Autowired
private PlatformTransactionManager txManager;

/* in a worker thread... */
public void run() {
    TransactionStatus tx = txManager.getTransaction(new DefaultTransactionDefinition());
    try {
        entityManager.find(...)
        ...
        entityManager.flush(...)
        etc...
        txManager.commit(tx);
    } catch (RuntimeException e) {
        txManager.rollback(tx);
    }
}

Answer 3

如果您确实需要单独的配置，我建议您在配置中对隔离策略进行模板化，并从属性文件中获取其值，这样您就不会得到一组不同的 Spring 配置用于测试和生产。

但我同意使用与生产用途相同的政策是最好的。您的夹具数据有多大，如果有一个 setUp() 步骤会破坏并重建您的数据（可能是快照，如果数据很多的话），那么情况会有多糟糕不必依赖回滚？