저장소(Repository) 예제

<!--resource가 DB일 경우 xml에 등록 -->
<job id="jdbcCursorIoJob" xmlns="http://www.springframework.org/schema/batch">
  <step id="jdbcCursorIoStep1">
    <tasklet>
      <chunk reader="itemReaderDB" processor="itemProcessor" writer="itemWriterDB" commit-interval="2" />
    </tasklet>
  </step>
</job>
        
<!--resource가 파일일 경우 xml에 등록 또는 JobParameter에 등록 -->
<job id="delimitedIoJob" xmlns="http://www.springframework.org/schema/batch">
<step id="delimitedIostep1">
  <tasklet>
    <chunk reader="itemReaderFile" processor="itemProcessor" writer="itemWriterFile" commit-interval="2"/>
  </tasklet>
</step>
</job>

@ContextConfiguration(locations = {
        "/egovframework/batch/simple-job-launcher-context.xml",
        "/egovframework/batch/jobs/repositoryJob.xml" })
public class EgovRepositoryFunctionalTests {

  @Test
  public void testUpdateCredit() throws Exception {
    // 1. resource가 DB인 Job 실행
    JobExecution jobExecution = jobLauncher.run(jobRegistry.getJob("jdbcCursorIoJob"),getUniqueJobParameters("jdbcCursorIoJob"));
    assertEquals(BatchStatus.COMPLETED, jobExecution.getStatus());

    // 2. resource가 file 인 Job 실행
    jobExecution = jobLauncher.run(jobRegistry.getJob("delimitedIoJob"),getUniqueJobParameters("delimitedIoJob"));
    assertEquals(BatchStatus.COMPLETED, jobExecution.getStatus());
  }

  /**
   * 잡파라미터를 설정하기 위한 메소드
   */
  protected JobParameters getUniqueJobParameters(String jobName) {

    JobParametersBuilder builder = new JobParametersBuilder();
    // Job 파라미터로 등록 가능
    builder.addString("inputFile",	"/egovframework/data/input/delimited.csv");
    builder.addParameter("timestamp", new JobParameter(new Date().getTime()));

    JobParameters jobParameters = builder.toJobParameters();
    return jobParameters;
  }
}