낙관적 락에 대해 질문이 있습니다.

Hibernate는 @Version을 사용하고,

Lock 옵션을 @Lock(LockModeType.OPTIMISTIC)을 사용할 경우에

NONE 모드와 다르게 엔티티를 수정하지 않고 단순히 조회만 해도 버전을 확인한다고 강사님 JPA 책에 작성되어있습니다.

실제 코드로 구현해보니 버전만 확인하는거 같더라구요

그 사이에 다른 트랜잭션이 해당 엔티티를 수정하여 버전이 변경되어도

ObjectOptimisticLockingFailureException 예외가 발생하지 않습니다.

간단하게 로직을 설명드리면

트랜잭션 A가 옵티미스틱 락 모드로 회원을 조회합니다. version = 0

트랜잭션 A를 5초 대기합니다.

트랜잭션 B가 회원을 수정하여 버전이 변경됩니다. version = 1

트랜잭션 B가 종료됩니다.

5초가 지나 트랜잭션 A가 종료됩니다.

트랜잭션 A가 종료될 때 옵티미스틱 락 모드라서 마지막에 버전을 확인합니다.

select version as version_ from member where id=?

그런데 트랜잭션 A가 종료될때에 회원 버전이 다르지만 예외가 발생하지 않습니다.

이러면 OPTIMISTIC의 용도가 트랜잭션을 커밋할 때 버전 정보를 조회해서 현재 엔티티의 버전과 같은지 검증한다. 만약 같지 않으면 예외가 발생한다고 작성되어있는데 예외가 발생하지 않는다면

강사님께서 설명해주신 조회한 엔티티는 트랜잭션이 끝날 때까지 다른 트랜잭션에 의해 변경되지 않아야한다. 조회 시점부터 트랜잭션이 끝날때까지 조회한 엔티티가 변경되지 않음을 보장한다.

이 말의 다른 의미가 어떤건지 궁금합니다 !

아니면 제가 테스트를 잘못하고 있는 걸까요..?

아래는 로직에 대한 간단한 코드입니다.

도메인

package org.example.stock_rt_1.domain;

import jakarta.persistence.*;
import lombok.Getter;
import lombok.NoArgsConstructor;

@Entity
@Getter
@NoArgsConstructor
public class Member {

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

    private long personId;
    private int age;
    @Version
    private Long version;

    public Member(long personId, int age) {
        this.personId = personId;
        this.age = age;
    }

    public void addAge() {
        ++this.age;
    }
}

리포지토리

package org.example.stock_rt_1.repository;

import jakarta.persistence.LockModeType;
import org.example.stock_rt_1.domain.Member;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Lock;

import java.util.Optional;

public interface MemberRepository extends JpaRepository<Member, Long> {

    @Lock(LockModeType.OPTIMISTIC)
    Optional<Member> findByPersonId(Long id);

}

서비스

package org.example.stock_rt_1.service;

import lombok.RequiredArgsConstructor;
import org.example.stock_rt_1.domain.Member;
import org.example.stock_rt_1.repository.MemberRepository;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Optional;

@Service
@RequiredArgsConstructor
public class MemberService {
    public final MemberRepository memberRepository;

    @Transactional
    public void addAge(long personId) {
        sleep(500); //findMember가 먼저 실행되야하기 때문에 넣었습니다.
        Member member = memberRepository.findByPersonId(personId).orElseThrow();
        member.addAge();
    }

    @Transactional
    public void findMember(long personId) {
        memberRepository.findByPersonId(personId);
        sleep(5000);
    }

    private void sleep(long mills) {
        try {
            Thread.sleep(mills);
        } catch (InterruptedException e) {
            System.out.println("e = " + e.getMessage());
        }
    }
}

테스트코드

package org.example.stock_rt_1.service;

import org.example.stock_rt_1.domain.Member;
import org.example.stock_rt_1.repository.MemberRepository;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;


@SpringBootTest
class MemberServiceTest {

    @Autowired
    private MemberService memberService;
    @Autowired
    private MemberRepository memberRepository;
    
    @Test
    @DisplayName("회원 정보를 조회중 다른 트랜잭션에서 정보를 변경했다.")
    void addAge() throws InterruptedException {
        // given
        int personId = 5555;
        memberRepository.save(new Member(personId,15));
        
        // when
        Thread selectThread = new Thread(() -> 
                                 memberService.findMember(personId),"트랜잭션-A");
        selectThread.start();
        Thread updateThread = new Thread(() -> 
                                 memberService.addAge(personId),"트랜잭션-B");
        updateThread.start();

        selectThread.join();
        updateThread.join();
    }
}

로그

[트랜잭션-A] : select m1_0.id,m1_0.age,m1_0.person_id,m1_0.version from member m1_0 where m1_0.person_id=? Hibernate: select m1_0.id,m1_0.age,m1_0.person_id,m1_0.version from member m1_0 where m1_0.person_id=?
[트랜잭션-B] : select m1_0.id,m1_0.age,m1_0.person_id,m1_0.version from member m1_0 where m1_0.person_id=? Hibernate: select m1_0.id,m1_0.age,m1_0.person_id,m1_0.version from member m1_0 where m1_0.person_id=?
[트랜잭션-B] : update member set age=?,person_id=?,version=? where id=? and version=?
[트랜잭션-B] : select version as version_ from member where id=?
[트랜잭션-A] : select version as version_ from member where id=?