쓰기지연SQL저장소는 정말 스냅샷과 비교하나요?

아래 댓글을 참고하여 수정했습니다.

안녕하세요. 심한수님

부족하지만 제가 알고 있는 지식이 도움이 되었으면 좋겠다는 마음에 답변 드립니다.

먼저 엔티티는 PK로 관리되는것으로 알고 있습니다.

그리고 em.merge()는 준영속(detach) 상태의 엔티티를 통해 영속(managed) 상태의 새로운 엔티티를 반환 해주는 메소드로 알고 있습니다.

merge()를 사용하게 되면 select 쿼리가 발생하고, 조회한 객체를 반환합니다.

즉, merge()로 반환되는 새로운 객체가 영속(managed) 상태 입니다.

풀어서 이야기하면, merge(entity)는 entity를 영속화 시키는 것이아니라, newEntity를 반환하며 newEntity가 영속 상태라는 말씀을 드립니다.

하지만, 심한수님의 경우에는 처음부터 save() 메소드에서 merge()를 실행하게 됩니다.

심한수님의 경우에 save()메소드에서 merge()를 실행하는 이유는 다음과 같습니다.

@Transactional
@Override
public <S extends T> S save(S entity) {

   Assert.notNull(entity, "Entity must not be null.");

   if (entityInformation.isNew(entity)) {
      em.persist(entity);
      return entity;
   } else {
      return em.merge(entity);
   }
}

isNew() 메소드는 엔티티의 PK가 null 이거나 원시타입인 경우는 초기값(0) 인 경우만 true, 그외는 false 처리 됩니다.

따라서 id를 300L로 설정했기 때문에 merge() 메소드를 실행합니다.

(초기값이 null이 아니기 때문입니다.)

merge 메소드 내부를 보면 설정한 id값으로 select 를 하여

해당 엔티티를 조회하고 영속상태의 새로운 엔티티를 반환 합니다.

(fastSessionServices.eventListenerGroup_MERGE.fireEventOnEachListener( event, MergeEventListener::onMerge); 메소드 까지는 어떻게 동작하는지 저도 잘 모르겠습니다. ㅠㅠ)

private Object fireMerge(MergeEvent event) {
   try {
      checkTransactionSynchStatus();
      checkNoUnresolvedActionsBeforeOperation();
      // select 쿼리 실행
      fastSessionServices.eventListenerGroup_MERGE.fireEventOnEachListener( event, MergeEventListener::onMerge );
      checkNoUnresolvedActionsAfterOperation();
   }
   catch ( ObjectDeletedException sse ) {
      throw getExceptionConverter().convert( new IllegalArgumentException( sse ) );
   }
   catch ( MappingException e ) {
      throw getExceptionConverter().convert( new IllegalArgumentException( e.getMessage(), e ) );
   }
   catch ( RuntimeException e ) {
      //including HibernateException
      throw getExceptionConverter().convert( e );
   }

   return event.getResult();
}

간단한 테스트를 예제로 보여드리겠습니다.

TestEntity

@Entity
@Setter @Getter
public class TestEntity {

    @Id
    private String id;
    private String name;
}

SaveTest

@SpringBootTest
public class saveTest {

    @Autowired
    TestEntityRepository repository;

    @Test
    void jpaSaveTest() {
        // uuid 생성
        String id = UUID.randomUUID().toString();

        TestEntity testEntity = new TestEntity();
        testEntity.setId(id);
        testEntity.setName("비영속상태 객체 생성");

        /**
         * merge를 실행합니다.(persist가 실행되지 않습니다.)
         *
         * save() 메소드에 있는
         * isNew() 메소드는
         * 엔티티의 PK가 null 이거나
         * 원시타입인 경우는 초기값(0)인 경우만 true,
         * 그외는 false 처리 됩니다.
         */
        TestEntity newEntity = repository.save(testEntity);
        System.out.println("name1="+newEntity.getName());

        /**
         * newEntity 영속(managed) 상태가 아닙니다.
         * 그 이유는 save() 이후 커밋을 완료했기 때문입니다.
         * save()를 보면 @Transactional이 있는 것을 확인할 수 있습니다.
         * 따라서 save() 즉, merge()를 통해 반환되는 newEntity는 비영속(new) 상태 입니다.
         * 그 결과 변경감지가 일어나지 않습니다.
         */
        newEntity.setName("변경감지 확인");
        System.out.println("name2="+newEntity.getName());
    }
}

결과

Hibernate: 
    select
        testentity0_.id as id1_5_0_,
        testentity0_.name as name2_5_0_ 
    from
        test_entity testentity0_ 
    where
        testentity0_.id=?

Hibernate: 
    insert 
    into
        test_entity
        (name, id) 
    values
        (?, ?)

name1=비영속상태 객체 생성
name2=변경감지 확인

감사합니다.^^