diff --git a/src/main/java/com/example/springbatch/batch/SecondBatch.java b/src/main/java/com/example/springbatch/batch/SecondBatch.java index 64dfa42..1c966d4 100644 --- a/src/main/java/com/example/springbatch/batch/SecondBatch.java +++ b/src/main/java/com/example/springbatch/batch/SecondBatch.java @@ -1,26 +1,34 @@ package com.example.springbatch.batch; import com.example.springbatch.entity.WinEntity; +import com.example.springbatch.repository.WinRepository; import org.springframework.batch.core.Job; import org.springframework.batch.core.Step; import org.springframework.batch.core.job.builder.JobBuilder; import org.springframework.batch.core.repository.JobRepository; import org.springframework.batch.core.step.builder.StepBuilder; +import org.springframework.batch.item.ItemProcessor; import org.springframework.batch.item.data.RepositoryItemReader; +import org.springframework.batch.item.data.RepositoryItemWriter; import org.springframework.batch.item.data.builder.RepositoryItemReaderBuilder; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; +import org.springframework.data.domain.Sort; import org.springframework.transaction.PlatformTransactionManager; +import java.util.Map; + @Configuration public class SecondBatch { private final JobRepository jobRepository; private final PlatformTransactionManager platformTransactionManager; + private final WinRepository winRepository; - public SecondBatch(JobRepository jobRepository, PlatformTransactionManager platformTransactionManager) { + public SecondBatch(JobRepository jobRepository, PlatformTransactionManager platformTransactionManager, WinRepository winRepository) { this.jobRepository = jobRepository; this.platformTransactionManager = platformTransactionManager; + this.winRepository = winRepository; } @Bean @@ -43,6 +51,23 @@ public class SecondBatch { public RepositoryItemReader winReader() { return new RepositoryItemReaderBuilder() - .name("") + .name("winReader") + .pageSize(10) + .methodName("findByWinGreaterThanEqual") + .repository(winRepository) + .sorts(Map.of("id", Sort.Direction.ASC)) + .build(); + } + + @Bean + public ItemProcessor trueProcessor() { + + + } + + @Bean + public RepositoryItemWriter winWriter() { + + } }