Spring Batch (7) JobRepository

📎 JobRepository

지난 시간에는 Spring Batch의 ExecutionContext에 살펴보았습니다.

ExecutionContext는 Spring Batch 프레임워크에서 지원하는 key/value 형식의 공유 객체로 Job을 실행하면서 필요한 데이터를 저장하는 공간입니다.

서로 다른 Job 간에는 공유가 안되지만, 동일한 Job 내의 서로 다른 Step 사이에는 데이터를 공유할 수 있습니다.

 

따라서 Batch Job 내의 Step 사이에서 데이터 공유 및 조작이 필요하다면 ExecutionContext를 활용할 수 있습니다.

 

 

이번 시간에는 Spring Batch JobRepository에 대해 살펴보겠습니다.

기존에 Job & JobParameters로 데이터베이스를 조회한 후 JobInstance의 여부에 따라 새로 생성하거나 기존에 존재하던 객체를 반환한다고 했었는데요, 이러한 과정을 가능하게 해주는 것이 JobRepository 입니다.

 

또한 Job, Step 등의 작업이 수행될 때 Spring Batch의 메타 데이터 테이블에 데이터를 CRUD하는 것도 JobRepository입니다.

 

 

📌 해당 포스팅의 목표

• Spring Batch JobRepository 파악하기

 

📌 JobRepository

기본 개념

• 인터페이스로 배치 작업 중 정보를 저장하는 저장소 역할
• JobLauncher, Job, Step 구현체에 대한 CRUD 작업
• Job의 수행과 관련된 모든 meta data를 저장
• 구현체는 SimpleJobRepository

 

SimpleJobRepository

SimpleJobRepository에는 각각의 Dao 객체가 존재하여 Job, Step 등이 실행될 때마다 메타 데이터를 저장합니다.

위 ~Dao 객체의 Bean은 JobRepositoryFactoryBean 클래스가 생성합니다.

ㅇ    @Override
    protected JobInstanceDao createJobInstanceDao() throws Exception {
        JdbcJobInstanceDao dao = new JdbcJobInstanceDao();
        dao.setJdbcTemplate(jdbcOperations);
        dao.setJobIncrementer(incrementerFactory.getIncrementer(databaseType, tablePrefix + "JOB_SEQ"));
        dao.setTablePrefix(tablePrefix);
        dao.afterPropertiesSet();
        return dao;
    }
 
    @Override
    protected JobExecutionDao createJobExecutionDao() throws Exception {
        JdbcJobExecutionDao dao = new JdbcJobExecutionDao();
        dao.setJdbcTemplate(jdbcOperations);
        dao.setJobExecutionIncrementer(incrementerFactory.getIncrementer(databaseType, tablePrefix
                + "JOB_EXECUTION_SEQ"));
        dao.setTablePrefix(tablePrefix);
        dao.setClobTypeToUse(determineClobTypeToUse(this.databaseType));
        dao.setExitMessageLength(maxVarCharLength);
        dao.afterPropertiesSet();
        return dao;
    }
 
    @Override
    protected StepExecutionDao createStepExecutionDao() throws Exception {
        JdbcStepExecutionDao dao = new JdbcStepExecutionDao();
        dao.setJdbcTemplate(jdbcOperations);
        dao.setStepExecutionIncrementer(incrementerFactory.getIncrementer(databaseType, tablePrefix
                + "STEP_EXECUTION_SEQ"));
        dao.setTablePrefix(tablePrefix);
        dao.setClobTypeToUse(determineClobTypeToUse(this.databaseType));
        dao.setExitMessageLength(maxVarCharLength);
        dao.afterPropertiesSet();
        return dao;
    }
 
    @Override
    protected ExecutionContextDao createExecutionContextDao() throws Exception {
        JdbcExecutionContextDao dao = new JdbcExecutionContextDao();
        dao.setJdbcTemplate(jdbcOperations);
        dao.setTablePrefix(tablePrefix);
        dao.setClobTypeToUse(determineClobTypeToUse(this.databaseType));
        dao.setSerializer(serializer);
 
        if (lobHandler != null) {
            dao.setLobHandler(lobHandler);
        }
 
        dao.afterPropertiesSet();
        // Assume the same length.
        dao.setShortContextLength(maxVarCharLength);
        return dao;
    }

 

JobRepository 설정

JobRepository 설정은 Spring Batch 설정 어노테이션인 @EnableBatchProcessing를 선언하면 자동으로 JobRepository Bean이 생성이 됩니다. 

@EnableBatchProcessing 어노테이션을 통해 생성되는 과정은 Spring Batch 의존성 설정 포스팅에서 정리를 했었는데 다음과 같습니다.

• @EnableBatchProcessing -> @Import(BatchConfigurationSelector.class) -> SimpleBatchConfiguration

 

JobRepository 커스텀

기존 Spring Batch가 제공하는 설정 외 커스텀 하여 JobRepository Bean을 생성할 경우 BatchConfigurer 인터페이스를 구현하거나, BasicBatchConfigurer 클래스를 상속받아 커스텀 할 수 있습니다.

BatchConfigurer

 

BasicBatchConfigurer

 

 

참고 문서

• https://docs.spring.io/spring-batch/docs/current/reference/html/index-single.html
• https://www.inflearn.com/course/%EC%8A%A4%ED%94%84%EB%A7%81-%EB%B0%B0%EC%B9%98/dashboard