spring在集成测试中启动并行事务

在过去,我通过创建不同的EntityManager / Session并稍后注入它们来测试vanilla Spring.我不确定如何从Spring集成测试中做到这一点,但它可能会引发一个想法.

在下面的代码中,Account是一个版本化的小对象.如果可以使用自定义实体管理器实例化Spring Integration流(或任何调用的流),则可以实现相同的目标.

public void shouldThrowOptimisticLockException() {
      EntityManager em1 = emf().createEntityManager();
      EntityManager em2 = emf().createEntityManager();
      EntityTransaction tx1 = em1.getTransaction();
      tx1.begin();

      Account account = new Account();
      account.setName("Jack");
      account.updateAudit("Tim");

      em1.persist(account);
      tx1.commit();


      tx1.begin();
      Account account1 = em1.find(Account.class,1L);
      account1.setName("Peter");

      EntityTransaction tx2 = em2.getTransaction();
      tx2.begin();
      Account account2 = em2.find(Account.class,1L);
      account2.setName("Clark");

      tx2.commit();
      em2.close();

      tx1.commit(); //exception is thrown here
      em1.close();
}