====== 저장소(Repository) 예제 ====== ===== 개요 ===== 배치 수행 시, 데이터 처리 대상(DB,File등)에 대한 설정을 보여주는 예제이다. EgovRepositoryFunctionalTests 예제는 리소스가 DB 인 jdbcCursorIoJob 과 리소스가 File인 delimitedIoJob의 수행과정을 보여주면서, 데이터가 DB에서 DB로 File 에서 File로 처리 된다. ===== 설명 ===== ==== 설정 ==== === Job 설정 === == 저장소(Repository) 예제의 Job 설정 파일인 repositoryJob.xml 을 확인한다 == Job 의 구성을 보면 리소스 타입에 따라 두 개의 Job으로 구성되어 있고, 각 타입에 따른 Reader와 Writer를 사용하게 된다. * jdbcCursorIoJob : 리소스가 DB인 Job * delimitedIoJob : 리소스가 파일인 Job ==== JunitTest 구성 및 수행 ==== === JunitTest 구성 === == repositoryJob 설정과 관련 클래스들로 Junit Test를 수행한다. 이 때 배치가 수행되고, 관련된 내용을 확인할 수 있다.== ✔ JunitTest 클래스의 구조는 [[egovframework:rte2:brte:batch_example:run_junit_Test|배치실행환경 예제 Junit Test 설명]]을 참고한다. \\ ✔ assertEquals(BatchStatus.COMPLETED, jobExecution.getStatus()) : 배치수행결과가 COMPLETED 인지 확인 \\ ✔ jobLauncher.run(jobRegistry.getJob("jdbcCursorIoJob"), getUniqueJobParameters("jdbcCursorIoJob")) : 이름이 jdbcCursorIoJob 인 Job을 수행 \\ ✔ getUniqueJobParameters에서 JobParameter에 배치에 필요한 입력 리소스, 출력 리소스 위치정보를 넘김 @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; } } ===JunitTest 수행=== == == 수행방법은 [[egovframework:dev2:tst:test_case#Test Case 실행| JunitTest 실행]]을 참고한다. ==== 결과확인 ==== === === * DB의 CUSTOMER 테이블을 보면 Repository 타입이 DB인 데이터 처리 결과를 확인할 수 있다. \\ {{:egovframework:rte2:brte:batch_example:repository_exam_result_db.png|}} \\ \\ * delimitedOutput.csv 파일을 보면 Repository 타입이 File인 데이터 처리 결과를 확인할 수 있다. \\ {{:egovframework:rte2:brte:batch_example:repository_exam_result_file.png|}} \\ \\ ===== 참고자료 ===== * [[egovframework:rte2:brte:batch_core:item_reader|ItemReader]] * [[egovframework:rte2:brte:batch_core:item_writer|ItemWriter]]