Spring 트랜잭션을 다른 쓰레드로 전파하는 방법은 무엇입니까?

Question

아마도 뭔가 잘못하고 있지만 다음과 같은 상황에서 좋은 방법을 찾을 수 없습니다.

작업을 실행하기 위해 Spring Batch 아래에있는 서비스를 단위 테스트하고 싶습니다. 작업은 별도의 스레드에 미리 구성된 AsyncTaskExecutor을 통해 실행됩니다. 내 단위 테스트에서 나는 싶습니다 : 작업이

사용 DAO에 완료 될 때까지

이

1. 이 작업을
2. 대기를 시작합니다 서비스 메소드를 호출 몇 도메인 객체를 생성하고 DAO
3. 그들을 통해 지속 도메인 객체를 검색하고 분명히 자신의 상태

을 확인, 무엇보다도 하나의 트랜잭션 내에서 실행되어야하지만 불행하게도, transactions are not propagated to new threads는 (나는이 뒤에 근거를 이해). 내 마음에 온

아이디어 :

• 단계 (1) 후 트랜잭션 # 1을 커밋합니다. 단위 테스트 후에 DB 상태를 롤백해야하므로 좋지 않습니다.
• 작업 구성에 Isolation.READ_UNCOMMITTED을 사용하십시오. 그러나이를 위해서는 테스트와 생산을위한 두 가지 구성이 필요합니다.

Answer 1

가장 간단한 해결책은 테스트 실행 중 SyncTaskExecutor를 사용하여 JobLauncher를 구성하는 것입니다.이 방법은 테스트와 동일한 스레드에서 작업이 실행되고 트랜잭션을 공유합니다.

작업 실행자 구성을 별도의 스프링 구성 XML 파일로 이동할 수 있습니다. 두 가지 버전이 있습니다. 하나는 테스트 중에 사용되는 SyncTaskExecutor이고 다른 하나는 프로덕션 실행에 사용되는 AsyncTaskExecutor입니다.

Answer 2

별도의 구성을 원한다면 구성에 템플릿 정책을 적용하고 속성 파일에서 해당 값을 가져와 테스팅을위한 다양한 Spring 구성을 사용하지 않는 것이 좋습니다. 찌르다.

하지만 동일한 정책 제작 사용을 사용하는 것이 가장 좋습니다. 고정 장치 데이터가 얼마나 방대하고 롤백에 의존 할 필요가 없도록 setUp() 단계가 데이터를 날려 버리고 다시 작성했는지 (데이터가 많은 경우 스냅 샷에서 가져온 것일 수 있음) 얼마나 나쁠까요?

Answer 3

귀하의 질문에 대한 진정한 해결책은 아니지만, 나는 새로운 트랜잭션을 작업자 스레드에서 수동으로 시작할 수 있음을 발견했습니다. 어떤 경우에는 이것이 충분할 수도 있습니다.

출처 : Spring programmatic transactions.

예 :

@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); 
    } 
}