Spring Batch - 19. JobParameters 증가 JobParametersIncrementer

출처

• 해당 포스트는 정수원 강사님의 스프링 배치 - Spring Boot 기반으로 개발하는 Spring Batch 강의를 바탕으로 작성 됐습니다.

목차

• Spring Batch - 24. FlowJob
• Post not found: spring/spring-batch/tasklet/spring-batch-23-JobStep
• Spring Batch - 22. Tasklet 기반 Step
• Spring Batch - 21. TaskletStep
• Spring Batch - 20. StepBuilderFactory 와 StepBuilder
• Spring Batch - 19. JobParameters 증가 JobParametersIncrementer
• Spring Batch - 18. Job 의 재시작 방지 preventRestart
• Spring Batch - 17. JobParameters 검증 JobParametersValidator
• Spring Batch - 16. SimpleJob 와 SimpleJobLauncher
• Spring Batch - 15. JobBuilderFactory & JobBuilder
• Spring Batch - 14. 배치 초기화 설정 (application.properties)
• Spring Batch - 13. JobLauncher
• Spring Batch - 12. JobRepository
• Spring Batch - 11. ExecutionContext
• Spring Batch - 10. StepContribution
• Spring Batch - 09. StepExecution 와 STEP_EXECUTION 테이블
• Spring Batch - 08. Step
• Spring Batch - 07. JobExecution 와 JOB_EXECUTION 테이블
• Spring Batch - 06. JobParameter 와 JOB_EXECUTION_PARAM 테이블
• Spring Batch - 05. JobInstance 와 JOB_INSTANCE 테이블
• Spring Batch - 04. JobLauncher
• Spring Batch - 03. Job
• Spring Batch - 02. Batch 에서 사용하는 Table
• Spring Batch - 01. @EnableBatchProcessing

JobParameters 증가 - JobParametersIncrementer

JobParameters 의 변경없이 Job 을 여러번 재시작 하고 싶은 경우 설정

JobParameters 의 필요한 값을 증가시켜 다음에 사용될 JobParameters 객체를 반환합니다.

기존의 JobParameters 의 변경없이 Job 을 여러번 재시작 하고 싶은 경우 설정합니다.

RunIdIncrementer 구현체를 지원하며 필요에 따라 JobParametersIncrementer 인터페이스를 직접 구현할 수 있습니다.

JobParametersIncrementer 인터페이스

public interface JobParametersIncrementer {

    JobParameters getNext(@Nullable JobParameters parameters);
}

public class CustomJobParametersIncrementer implements JobParametersIncrementer {

    static final SimpleDateFormat format = new SimpleDateFormat("yyyyMMdd-hhmmss");

    public JobParameters getNext(JobParameters parameters) {

        String id = format.format(new Date());

        return new JobParametersBuilder().addString("run.id", id).toJobParameters();
    }
}

RunIdIncrementer - JobParametersIncrementer 구현체

public class RunIdIncrementer implements JobParametersIncrementer {

    private static String RUN_ID_KEY = "run.id";

    private String key = RUN_ID_KEY;

    public void setKey(String key) {
        this.key = key;
    }

    @Override
    public JobParameters getNext(@Nullable JobParameters parameters) {

        JobParameters params = (parameters == null) ? new JobParameters() : parameters;
        JobParameter runIdParameter = params.getParameters().get(this.key);
        long id = 1;
        if (runIdParameter != null) {
            try {
                id = Long.parseLong(runIdParameter.getValue().toString()) + 1;
            }
            catch (NumberFormatException exception) {
                throw new IllegalArgumentException("Invalid value for parameter "
                        + this.key, exception);
            }
        }
        return new JobParametersBuilder(params).addLong(this.key, id).toJobParameters();
    }
}