시나리오 번호 | 설명 | 전파 속성 & 옵션 | 결과 |
1 | 포인트 적립에서 예외가 발생했을 때 포인트 적립은 롤백되고 주문로직은 커밋 | REQUIRED → REQUIRES_NEW | 기본 로직 롤백 X |
2 | 결제 실패 시 주문도 롤백 | REQUIRED → REQUIRED | 기본 로직 롤백 O |
3 | Checked Exception은 기본적으로 롤백되지 않음 | REQUIRED → REQUIRED
rollbackFor 옵션 | 롤백 X (기본설정)
rollbackFor 옵션으로 달라짐 |
4 | 포인트 적립에서 예외가 발생하고 부모 트랜잭션에서 try-catch | REQUIRED → REQUIRED | 롤백 O |
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void processOrder(Long orderId) {
Order order = orderRepository.findById(orderId).orElseThrow();
// 재고 차감
productService.decreaseOrderItemsStock(order.getOrderItems());
log.info("decrease stock success");
// 결제 진행
paymentService.pay(order);
log.info("pay success");
// 포인트 추가
try {
pointService.increasePoint(order.getMember(), 100);
log.info("increase point success");
} catch (RuntimeException e) {
log.error("error : {}", e.getMessage());
}
}포인트 적립에서 예외가 발생했을 때 포인트 적립은 롤백되고 주문로직은 커밋되어야 한다.
//테스트 로직
@Test
@DisplayName("포인트 적립이 실패했을 때 전체 주문 로직은 커밋되어야 한다.")
@Transactional(propagation = Propagation.NOT_SUPPORTED)
void point_fail_does_not_rollback_payment_and_stock() {
log.info("handle test");
// given
doThrow(new RuntimeException("포인트 적립 실패"))
.when(pointService).increasePoint(any(), anyInt());
// when
Assertions.assertDoesNotThrow(() -> orderService.processOrder(order.getId()));
// then
// 1. 재고 차감 확인
List<Product> products = order.getOrderItems().stream()
.map(item -> productRepository.findById(item.getProduct().getId()).orElseThrow())
.toList();
int[] originalStocks = order.getOrderItems().stream()
.mapToInt(item -> item.getProduct().getStock())
.toArray();
Assertions.assertAll("재고 차감 확인",
() -> {
for (int i = 0; i < products.size(); i++) {
int expectedStock = originalStocks[i] - order.getOrderItems().get(i).getQuantity();
int actualStock = productRepository.findById(products.get(i).getId()).orElseThrow().getStock();
Assertions.assertEquals(expectedStock, actualStock,
"Product " + products.get(i).getId() + " stock mismatch");
}
}
);
// 2. Money 차감 확인
List<OrderItem> orderItems = order.getOrderItems();
long expectMemberMoney = order.getMember().getMoney();
for (OrderItem orderItem : orderItems) {
expectMemberMoney -= (long) orderItem.getProduct().getPrice() * orderItem.getQuantity();
}
Member member = memberRepository.findById(order.getMember().getId()).orElseThrow();
Assertions.assertEquals(expectMemberMoney, member.getMoney());
}//PointService
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void increasePoint(Member member, int point) {
member.increasePoint(point);
}
increasePoint() 는 새로운 트랜잭션 환경에서 실행되므로, 부모 트랜잭션과 분리된다.결제 실패 시 주문도 롤백되어야 한다.
@Test
@DisplayName("결제 실패 시 주문도 롤백되어야 한다 (분리된 트랜잭션 검증)")
@Transactional(propagation = Propagation.NOT_SUPPORTED)
void should_rollback_order_when_payment_fails() {
// given
order.getPayment().setPaymentStatus(PaymentStatus.COMPLETED);
doThrow(new AlreadyProcessOrderException())
.when(paymentService).pay(any());
// when
Assertions.assertThrows(AlreadyProcessOrderException.class, () -> {
orderService.processOrder(order.getId());
});
// then: 서비스 트랜잭션이 끝나고 롤백되었는지 검증
// product 재고 롤백 검증
int initialStock = order.getOrderItems().get(0).getProduct().getStock();
Product product = productRepository.findById(order.getOrderItems().get(0).getProduct().getId())
.orElseThrow();
Assertions.assertEquals(initialStock, product.getStock(), "재고가 롤백되지 않았습니다");
} @Transactional(propagation = Propagation.REQUIRED)
public void pay(Order order) {
if (!order.getPayment().getPaymentStatus().equals(PaymentStatus.PENDING)) {
throw new AlreadyProcessOrderException();
}
Member member = memberRepository.findById(order.getMember().getId()).orElseThrow();
Payment payment = paymentRepository.findById(order.getPayment().getId()).orElseThrow();
long totalRequiredMoney = 0L;
for (OrderItem orderItem : order.getOrderItems()) {
totalRequiredMoney += (long) orderItem.getProduct().getPrice() * orderItem.getQuantity();
}
member.decreaseMoney(totalRequiredMoney);
payment.setPaymentStatus(PaymentStatus.COMPLETED);
}AlreadyProcessOrderException 이 발생한다.
pay 메서드는 REQUIRED 전파 속성을 가지므로, 호출 시 트랜잭션이 존재하지 않으면 새 트랜잭션을 생성하고, 이미 존재하는 경우에는 해당 트랜잭션에 참여한다. 따라서 pay 내부에서 예외가 발생하면 트랜잭션은 rollback-only 상태로 마킹되고, 최종적으로 호출자에서 커밋을 시도할 때 전체 트랜잭션이 롤백된다.REQUIRED 전파 속성은 기존 트랜잭션이 존재하면 해당 트랜잭션에 참여하고, 없으면 새 트랜잭션을 생성한다.rollback-only로 마킹된다. 이는 실제 롤백이 발생하는 것이 아니라, 향후 커밋 시점에 해당 트랜잭션은 더 이상 커밋이 불가능함을 나타내는 마킹일 뿐이다.rollback-only로 설정된 트랜잭션은 커밋을 시도할 경우, 스프링은 이를 감지하고 UnexpectedRollbackException을 발생시키며 강제로 롤백을 수행한다. 따라서 내부 메서드에서 예외가 발생해도 외부에서 잡지 않으면 전체 트랜잭션이 함께 롤백된다.Checked Exception은 기본적으로 롤백되지 않는다.
Checked Exception은 컴파일 시점에 반드시 예외 처리를 강제하는 예외이며, RuntimeException을 포함한 Unchecked Exception은 예외 처리를 강제하지 않는 예외이다.@Transactional은 기본적으로 RuntimeException이나 Error가 발생했을 때만 트랜잭션을 롤백한다. 반면, Checked Exception이 발생하면 트랜잭션은 롤백되지 않고 정상적으로 커밋된다.rollbackFor 속성을 별도로 지정하지 않으면, Checked Exception에 대해서는 스프링이 트랜잭션을 롤백 대상으로 인식하지 않기 때문이다. 예를 들어, @Transactional(rollbackFor = MessagingException.class)와 같이 명시해야 롤백이 수행된다. @Test
@DisplayName("Checked Exception 이 발생했을 때 커밋되어야 한다.")
@Transactional(propagation = Propagation.NOT_SUPPORTED)
void should_commit_checked_exception() {
// given
// when
Assertions.assertThrows(MessagingException.class, () -> {
orderService.processOrderV2(order.getId());
});
// then
// product 재고 롤백 검증
List<Product> products = order.getOrderItems().stream()
.map(item -> productRepository.findById(item.getProduct().getId()).orElseThrow())
.toList();
int[] originalStocks = order.getOrderItems().stream()
.mapToInt(item -> item.getProduct().getStock())
.toArray();
Assertions.assertAll("재고 차감 확인",
() -> {
for (int i = 0; i < products.size(); i++) {
int expectedStock = originalStocks[i] - order.getOrderItems().get(i).getQuantity();
int actualStock = productRepository.findById(products.get(i).getId()).orElseThrow().getStock();
Assertions.assertEquals(expectedStock, actualStock,
"Product " + products.get(i).getId() + " stock mismatch");
}
}
);
}
@Test
@DisplayName("이메일 전송 오류 시 롤백이 되어야 한다 (rollbackFor 테스트)")
@Transactional(propagation = Propagation.NOT_SUPPORTED)
void should_rollback_checked_exception() throws MessagingException {
// given
doThrow(new MessagingException("이메일 전송 오류")).when(emailService).sendEmail(anyString());
// when
Assertions.assertThrows(MessagingException.class, () -> {
orderService.processOrderV3(order.getId());
});
// then
// product 재고 롤백 검증
int initialStock = order.getOrderItems().getFirst().getProduct().getStock();
Product product = productRepository.findById(order.getOrderItems().getFirst().getProduct().getId()).orElseThrow();
Assertions.assertEquals(initialStock, product.getStock(), "재고가 롤백되지 않았습니다");
}// V2
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void processOrderV2(Long orderId) throws MessagingException {}
// V3
@Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = MessagingException.class)
public void processOrderV3(Long orderId) throws MessagingException {}
포인트 적립에서 예외가 발생하고 부모 트랜잭션에서 try-catch로 예외를 처리했을 때도 오류가 발생한다. (REQUIRED → REQUIRED)
우아한형제들 기술블로그 |응? 이게 왜 롤백되는거지? | 우아한형제들 기술블로그
응? 이게 왜 롤백되는거지? | 우아한형제들 기술블로그
이 글은 얼마 전 에러로그 하나에 대한 호기심과 의문으로 시작해서 스프링의 트랜잭션 내에서 예외가 어떻게 처리되는지를 이해하기 위해 삽질을 해본 경험을 토대로 쓰여졌습니다. 스프링의 트랜잭션의 세부적인 동작방식을 살펴보기 때문에 코드가 많고 설명이 조금 긴 편입니다. 상황재현과 테스트를 위해 작성한 코드는 github에 있습니다. 테스트에 사용한 버전은 SpringBoot 2.1.2, MySQL 5.7입니다. 때는 지난 12월의 어느날 beta서버에서 에러로그가
우아한형제들 기술블로그 |@Test
@DisplayName("부모 트랜잭션에서 try catch로 자식 트랜잭션에서 발생한 예외를 잡았어도 롤백이 되어야 한다.")
@Transactional(propagation = Propagation.NOT_SUPPORTED)
void shouldRollbackParent_whenChildSetsRollbackOnly_evenIfExceptionCaught() {
// given
// when
Assertions.assertThrows(RuntimeException.class, () -> {
orderService.processOrderV4(order.getId());
});
// then
// product 재고 롤백 검증
int initialStock = order.getOrderItems().getFirst().getProduct().getStock();
Product product = productRepository.findById(order.getOrderItems().getFirst().getProduct().getId()).orElseThrow();
Assertions.assertEquals(initialStock, product.getStock(), "재고가 롤백되지 않았습니다");
} @Transactional(propagation = Propagation.REQUIRED)
public void increasePointV2(Member member, int point) {
member.increasePoint(point);
throw new RuntimeException();
}increasePointV2 에서 RuntimeException 이 발생한다.
lushlife99