gusdn85554

작성한 질문수 47

0

예제 프로젝트 (spring-tx)에서 추가해 실행해봤던 허접한 테스트입니다.

@Slf4j
@SpringBootTest
public class BasicTxTest {

	//...


	@Test
	void inner_inner_rollback() {
		log.info("외부 트랜잭션 시작");
		TransactionStatus outer = txManager.getTransaction(new DefaultTransactionAttribute());
		log.info("outer.isNewTransaction()={}", outer.isNewTransaction());  //true

		log.info("내부 트랜잭션 시작");
		TransactionStatus inner = txManager.getTransaction(new DefaultTransactionAttribute());
		log.info("inner.isNewTransaction()={}", inner.isNewTransaction());  //true



		log.info("내부-내부 트랜잭션 시작");
		TransactionStatus innerInner = txManager.getTransaction(new DefaultTransactionAttribute());
		log.info("innerInner.isNewTransaction()={}", innerInner.isNewTransaction());  //true
		log.info("내부-내부 트랜잭션 롤백");
		txManager.rollback(innerInner);  //rollback-only 표시

		log.info("내부 트랜잭션 커밋");
		txManager.commit(inner);

		log.info("외부 트랜잭션 커밋");
		assertThatThrownBy(() -> txManager.commit(outer))
				.isInstanceOf(UnexpectedRollbackException.class);
	}

	@Test
	void inner_inner_rollback_requires_new() {
		log.info("외부 트랜잭션 시작");
		TransactionStatus outer = txManager.getTransaction(new DefaultTransactionAttribute());
		log.info("outer.isNewTransaction()={}", outer.isNewTransaction());  //true

		log.info("내부 트랜잭션 시작");
		DefaultTransactionAttribute definition = new DefaultTransactionAttribute();
		definition.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
		TransactionStatus inner = txManager.getTransaction(definition);
		log.info("inner.isNewTransaction()={}", inner.isNewTransaction());  //true

		log.info("내부-내부 트랜잭션 시작");
		TransactionStatus innerInner = txManager.getTransaction(new DefaultTransactionAttribute());
		log.info("innerInner.isNewTransaction()={}", innerInner.isNewTransaction());  //true
		log.info("내부-내부 트랜잭션 롤백");
		txManager.rollback(innerInner);  //rollback-only 표시

		log.info("내부 트랜잭션 커밋");
		assertThatThrownBy(() -> txManager.commit(inner))
				.isInstanceOf(UnexpectedRollbackException.class);

		log.info("외부 트랜잭션 커밋");
		txManager.commit(outer);  //커밋
	}
}

 

먼저 inner_inner_rollback()의 로그입니다.

inner_inner_rollback_requires_new()의 로그입니다.

 

 

0

안녕하세요. gusdn85554님, 공식 서포터즈 y2gcoder입니다.

말씀해주신 부분을 듣고 생각해봤을 때 이제까지 외부 트랜잭션, 내부 트랜잭션을 나누고 외부와 내부 트랜잭션을 구분할 필요가 있었던 것은 단일 물리 트랜잭션 안에 새로운 논리 트랜잭션을 생성하여 기존 트랜잭션에 참여하는 방식이었기 때문이라고 생각합니다.

반면에 REQUIRES_NEW는 기존 트랜잭션에 참여하는 방식이 아니라, 또 다른 물리 트랜잭션을 만드는 것입니다. 별도의 두 물리 트랜잭션이 작동하는 방식이기 때문에 내부 트랜잭션에 문제가 생겨서 롤백해도, 외부 트랜잭션은 다른 물리 트랜잭션이기 때문에 사실 내부 트랜잭션의 결과가 어떻든 외부 트랜잭션에 영향을 주지 않습니다.

그런 맥락에서 위의 상황에서는 REQUIRED_NEW rollbackonly 옵션을 확인할 필요가 없습니다. 왜냐하면 외부 트랜잭션은 내부 트랜잭션의 결과에 영향을 받지 않는 별개의 물리 트랜잭션이기 때문입니다. rollbackonly라는 옵션은 하나의 물리 트랜잭션 안에 참여한 내부의 논리 트랜잭션이 있을 때, 체크할 필요가 있는 옵션이라고 생각합니다.

감사합니다.