인프런 커뮤니티 질문&답변

안녕하세요~ 강사님 강의를 보고 스프링 배치 입문해서 열심히 이론부터 실습까지 잘 배우고 있습니다.
몇 가지 궁금한 점이 있어서 이렇게 질문을 드리게 되었습니다.

1.

ItemReader 중에 Repositoryitemreader라는 구현체가 있어서 이게 Spring Data JPA를 지원해 줘서 사용해 보았는데요. 이해가 가지 않는 부분이 있어서 질문드리고자 합니다.

    @Bean(name = STEP_NAME)
    @JobScope
    public Step step1(@Value("#{jobParameters[chunkSize]}") Long chunkSize) {
        return stepBuilderFactory.get(STEP_NAME)
                .<HistoryEntity, HistoryEntity>chunk(chunkSize.intValue())
                .reader(itemReader(null))
                .processor(itemProcessor())
                .writer(itemWriter())
                .build();
    }

  @Bean(name = JOB_NAME + "_reader")
    @StepScope
    public RepositoryItemReader<HistoryEntity> itemReader(@Value("#{jobParameters[chunkSize]}") Long chunkSize) {

        LocalDateTime now = LocalDateTime.now();

        return new RepositoryItemReaderBuilder<HistoryEntity>()
                .name(JOB_NAME + "_reader")
                .repository(HistoryPagingCrudRepository)
                .methodName("findByLeaveDtLessThanEqual")
                .pageSize(chunkSize.intValue())
                .arguments(List.of(now))
                .sorts(Collections.singletonMap("leaveDt", Sort.Direction.DESC))
                .build();
    }

위와 같은 step과 특정 날짜의 데이터를 조회하는 ItemReader를 구현한 후 아래 ItemWriter 에서

 @Bean(name = JOB_NAME + "_writer")
    @StepScope
    public ItemWriter<HistoryEntity> itemWriter() {

        return item -> {
            item.forEach(historyEntity -> {
                       // Id 값을 null로 만드는 메소드
                       historyEntity.updateRemoveId(); 
                    }
            );
        };
    }

Entity의 값을 변경하게 되면 당연히 하나의 chunk 단위에서는 하나의 트랜잭션 이기 때문에 JPA의 dirty check로 인한 Id 값을 지우는 update 쿼리가 나갈거라고 생각했는데 그렇지 않더라고요.

다만,

 @Bean(name = JOB_NAME + "_writer")
    @StepScope
    public ItemWriter<HistoryEntity> itemWriter() {

        return item -> {
            item.forEach(historyEntity -> {
                       // Id 값을 null로 만드는 메소드
                       historyEntity.updateRemoveId(); 
                       historyPagingCrudRepository.save(historyEntity) 
                    }
            );
        };
    }

위 코드 historyPagingCrudRepository.save(historyEntity) 를 추가하면 merge가 진행되면서 update 쿼리가 실행되긴 하지만 select 쿼리가 한 번 더 실행돼서 비효율적인거 같다는 생각이 들었습니다.

질문을 정리하자면 ItemReader에서 조회한 Entity가 ItemWriter에서도 영속 상태이기 때문에 Dirty Checking 대상이라고 생각했는데 그렇지 않은 이유가 무엇인가요??

혹시 ItemReader 로 데이터 조회 후 ChunkProvider를 통해 Chunk<I> 를 itemProcessor 또는 ItemWriter로 전달하는 과정에서 준영속 상태가 되는것일까요??

2.

jpaPagingItemReader 으로 데이터 조회 후, ItemWriter 에서 jpaPagingItemReader 의 where 절에 해당하는 컬럼의 값을 수정했을 때 offset(page)로 인해 일부 데이터가 읽히지 않는 문제가 있는것으로 알고있습니다. 이 경우 getPage() 메소드를 override 해서 항상 offset을 0으로 고정시키는 방법으로 해결이 가능한데 Repositoryitemreader 구현체 사용 시 어떤식으로 해결이 가능할까요??