[TIL-20260124] Spring Batch Reader 구현

 

👩🏻‍💻 Today I Lean ...

Kotlin/Spring 정산 시스템 파트 강의에서 Reader 구현 내용을 복습했다.

 

 

Reader 구현 

@Configuration
class DeliveryCompletedItemReaderConfig {
    companion object {
        const val CHUNK_SIZE = 500
        fun getStartDateTime(): ZonedDateTime =
            ZonedDateTime.of(LocalDate.now(), LocalTime.MIN, ZoneId.of("Asia/Seoul"))

        fun getEndDateTime(): ZonedDateTime =
            ZonedDateTime.of(LocalDate.now().plusDays(1), LocalTime.MIN, ZoneId.of("Asia/Seoul"))
    }

    @Bean
    @StepScope
    fun deliveryCompletedJpaItemReader(orderItemRepository: OrderItemRepository): RepositoryItemReader<OrderItem> =
        RepositoryItemReaderBuilder<OrderItem>()
            .name("deliveryCompletedJpaItemReader")
            .repository(orderItemRepository)
            .methodName("findByShippedCompletedAtBetween")
            .arguments(getStartDateTime(), getEndDateTime())
            .pageSize(CHUNK_SIZE)
            .sorts(mapOf("shippedCompletedAt" to Sort.Direction.ASC))
            .build()
}

 

 

RepositoryItemReader

• Spring Batch에서 제공하는 ItemReader(데이터를 한 건씩 읽어오는 인터페이스) 구현체
• JPARepository를 사용해서 데이터를 읽어온다.

 

@StepScope

• Job 실행 시점에 Bean을 생성하는  Spring Batch 스코프

 

강의 내용에는 Scope가  없었는데 (Sigletone) , 이렇게 되면 날짜 함수애플리케이션 처음 실행되는 시점의 날짜로 고정되어버린다고 한다. 그래서 @StepScope 어노테이션을 추가하여 Step마다 Bean을 생성하는 방식으로 수정했다.

추후 강의에 리팩토링 내용이 포함되어 있던데, 그때 다시 Reader 생성 구현 부분 정리해봐야겠다.