[Spring Boot] JPA에서 엔티티 수정과 Soft Delete의 트랜잭션 처리 방식

🌱 문제 상황

@RequiredArgsConstructor
@UseCase
public class BidUseCase {

    private final BidRepository bidRepository;
    
    @Transactional
    public void deleteBid(User user, Long bidId) {
        Bid bid = bidRepository.findById(bidId).orElseThrow(() -> NOT_FOUND_BID);
        
        bid.cancel();
        bidRepository.delete(bid);
        
        log.info(bid.getStatus().name());
    }
}

@SQLDelete(sql = "UPDATE bid SET is_deleted = true WHERE id = ? AND version = ?")
@Entity
public class Bid extends BaseTimeEntity {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    @Enumerated(EnumType.STRING)
    @Column(nullable = false)
    private Status status;
    
    @Version
    private Long version;

    private Boolean isDeleted;
    
    ...

    public void cancel() {
        this.status = Status.CANCELLED;
    }
}

설명을 위해 기존보다 간단하게 수정한 코드이다.

 

내가 겪었던 문제는 bid.cancel() 메서드에서 Bid 엔티티의 status를 변경하고, 로그를 통해 상태 변경이 잘 된 것을 확인할 수 있었는데 최종적으로 상태 변경 update 쿼리는 실행되지 않고, SQLDelete에서 정의한 쿼리만 실행되어 상태 변경이 데이터베이스에 적용되지 않는 상황이었다.

 

🌱 문제 원인

이 글을 검색하고 들어온 사람들은 이미 아는 사실이겠지만 @SQLDelete는 엔티티가 삭제될 때 사용자가 정의한 SQL을 실행하도록 한다. 그리고 JPA는 삭제를 처리할 때, 엔티티를 삭제한 것으로 마크하고 플러시 시점에 @SQLDelete에 정의된 SQL을 실행한다.

 

메서드에 트랜잭션을 걸어놨으니 Bid의 상태가 업데이트 됐을 때 Dirty Check되어 트랜잭션이 종료되기 전에 플러시 되어야 하지만, JPA는 삭제된 엔티티에 대해 상태 변경을 별도로 처리하지 않는다. 즉, 삭제된 엔티티는 더 이상 상태 변경이 반영되지 않는 것이다.

 

🌱 해결 방법

원인을 알면 해결방법은 간단하다. delete 되기 전에 상태 변경을 명시적으로 플러시해 변경된 상태가 먼저 데이터베이스에 반영되도록 하면 된다.

 

주의할 점은 여기서 bidRepository.save(bid); 를 통해 엔티티의 상태 변경을 저장하려는 경우 제대로 동작하지 않는다.

이는 플러시 전략 때문인데 JPA에서는 기본적으로 설정되어 있는 FlushModeType.AUTO 는 트랜잭션이 커밋될 때 또는 쿼리가 실행되기 전에 영속성 컨텍스트가 플러시 된다.

// 플러시 모드 확인 방법
FlushModeType flushModeType = entityManager.getFlushMode();
log.info("flushMode: " + flushModeType);

// flushMode: AUTO

 

따라서 flush를 명시적으로 호출해 영속성 컨텍스트의 변경 사항을 데이터베이스에 즉시 반영해야 한다.

@RequiredArgsConstructor
@UseCase
public class BidUseCase {
    
    private final BidRepository bidRepository;

    @Transactional
    public void deleteBid(User user, Long bidId) {
        Bid bid = bidRepository.findById(bidId).orElseThrow(() -> NOT_FOUND_BID);
        
        bid.cancel();
        bidRepository.flush();    // 추가!!
        
        bidRepository.delete(bid);
    }
}