Я использую Spring/Spring-data-JPA и обнаружил, что мне нужно вручную принудительно выполнить фиксацию в модульном тесте. Мой вариант использования заключается в том, что я выполняю многопоточный тест, в котором я должен использовать данные, которые сохраняются до создания потоков.
К сожалению, учитывая, что тест выполняется в транзакции @Transactional
, даже flush
не делает его доступным для порожденных потоков.
@Transactional
public void testAddAttachment() throws Exception{
final Contract c1 = contractDOD.getNewTransientContract(15);
contractRepository.save(c1);
// Need to commit the saveContract here, but don't know how!
em.getTransaction().commit();
List<Thread> threads = new ArrayList<>();
for( int i = 0; i < 5; i++){
final int threadNumber = i;
Thread t = new Thread( new Runnable() {
@Override
@Transactional
public void run() {
try {
// do stuff here with c1
// sleep to ensure that the thread is not finished before another thread catches up
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
});
threads.add(t);
t.start();
}
// have to wait for all threads to complete
for( Thread t : threads )
t.join();
// Need to validate test results. Need to be within a transaction here
Contract c2 = contractRepository.findOne(c1.getId());
}
Я пытался использовать диспетчер сущностей, но получаю сообщение об ошибке, когда делаю:
org.springframework.dao.InvalidDataAccessApiUsageException: Not allowed to create transaction on shared EntityManager - use Spring transactions or EJB CMT instead; nested exception is java.lang.IllegalStateException: Not allowed to create transaction on shared EntityManager - use Spring transactions or EJB CMT instead
at org.springframework.orm.jpa.EntityManagerFactoryUtils.convertJpaAccessExceptionIfPossible(EntityManagerFactoryUtils.java:293)
at org.springframework.orm.jpa.aspectj.JpaExceptionTranslatorAspect.ajc$afterThrowing$org_springframework_orm_jpa_aspectj_JpaExceptionTranslatorAspect$1$18a1ac9(JpaExceptionTranslatorAspect.aj:33)
Есть ли способ зафиксировать транзакцию и продолжить ее? Мне не удалось найти какой-либо метод, позволяющий мне вызывать commit()
.
@Transactional
, возврат из метода фиксирует транзакцию. Так почему бы просто не вернуться из метода? - person Raedwald   schedule 21.06.2014