Spring Batch Test
ํตํฉ ํ
์คํธ
pom.xml
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
gradle
dependencies {
testImplementation 'org.springframework.boot:spring-boot-starter-test'
testImplementation 'org.springframework.batch:spring-batch-test'
}
์คํ๋ง ๋ถํธ ๋ฐฐ์น ํ
์คํธ ์ฌ์ฉ์ ์์กด์ฑ์ ๋ฐ๋์ spring-boot-starter-test
๊ฐ ํฌํจ๋์ด ์์ด์ผํ๋ค.
@RunWith(SpringRunner.class)
@SpringBatchTest
@SpringBootTest(classes={BatchJpaTestConfiguration.class, TestBatchConfig.class})
public class BatchIntegrationTestJobConfigurationTest {
@Autowired
private JobLauncherTestUtils jobLauncherTestUtils; // (2)
@Autowired
private SalesRepository salesRepository;
@Autowired
private SalesSumRepository salesSumRepository;
@After
public void tearDown() throws Exception {
salesRepository.deleteAllInBatch();
salesSumRepository.deleteAllInBatch();
}
@Test
public void ๊ธฐ๊ฐ๋ด_Sales๊ฐ_์ง๊ณ๋์ด_SalesSum์ด๋๋ค() throws Exception {
//given
LocalDate orderDate = LocalDate.of(2019,10,6);
int amount1 = 1000;
int amount2 = 500;
int amount3 = 100;
salesRepository.save(new Sales(orderDate, amount1, "1"));
salesRepository.save(new Sales(orderDate, amount2, "2"));
salesRepository.save(new Sales(orderDate, amount3, "3"));
JobParameters jobParameters = new JobParametersBuilder()
.addString("orderDate", orderDate.format(FORMATTER))
.toJobParameters();
//when
JobExecution jobExecution = jobLauncherTestUtils.launchJob(jobParameters); // (3)
//then
assertThat(jobExecution.getStatus()).isEqualTo(BatchStatus.COMPLETED);
List<SalesSum> salesSumList = salesSumRepository.findAll();
assertThat(salesSumList.size()).isEqualTo(1);
assertThat(salesSumList.get(0).getOrderDate()).isEqualTo(orderDate);
assertThat(salesSumList.get(0).getAmountSum()).isEqualTo(amount1+amount2+amount3);
}
}
@SpringBatchTest
: ์๋์ผ๋ก ApplicatonContext์ ํ ์คํธ์ ํ์ํ ์ฌ๋ฌ ์ ํธ Bean์ ๋ฑ๋กํด์ค๋ค.Util์ค๋ชํ ์คํธ ๋จ์JobLauncherTestUtils
์คํ๋ง ๋ฐฐ์น ํ ์คํธ์ ํ์ํ ์ ๋ฐ์ ์ธ ์ ํธ ๊ธฐ๋ฅ๋ค ์ง์
ํตํฉ ํ ์คํธ
JobRepositoryTestUtils
DB์ ์์ฑ๋ JobExecution์ ์ฝ๊ฒ ์์ฑ/์ญ์ ๊ฐ๋ฅํ๋๋ก ์ง์
ํตํฉ ํ ์คํธ
StepScopeTestExecutionListener
๋ฐฐ์น ๋จ์ ํ ์คํธ์
@StepScope
์ปจํ ์คํธ๋ฅผ ์์ฑ ํด๋น ์ปจํ ์คํธ๋ฅผ ํตํด JobParameter๋ฑ์ ๋จ์ ํ ์คํธ์์ DI ๋ฐ์ ์ ์๋ค.๋จ์ ํ ์คํธ
JobScopeTestExecutionListener
๋ฐฐ์น ๋จ์ ํ ์คํธ์
@JobScope
์ปจํ ์คํธ๋ฅผ ์์ฑ ํด๋น ์ปจํ ์คํธ๋ฅผ ํตํด JobParameter๋ฑ์ ๋จ์ ํ ์คํธ์์ DI ๋ฐ์ ์ ์๋ค.๋จ์ ํ ์คํธ
@SpringBootTest
: ํตํฉ ํ ์คํธ ์คํ์ ์ฌ์ฉํ Java์ค์ ๋ค์ ์ ํBatchJpaTestConfiguration
์ ํ ์คํธํ Batch JobTestBatchConfig
: ๋ฐฐ์น ํ ์คํธ ํ๊ฒฝ
jobLauncherTestUtils.launchJob(jobParameters)
:JobParameters
์ ํจ๊ป Job์ ์คํํ๋ค.ํด๋น Job์ ๊ฒฐ๊ณผ๋
JobExecution
์ ๋ด๊ฒจ ๋ฐํ๋๋ค.jobExecution.getStatus()
๋ก ์ฑ๊ณต์ ์ผ๋ก ์ํ๋์๋์ง ๊ฒ์ฆํ๋ค.
@Configuration
@EnableAutoConfiguration
@EnableBatchProcessing // ๋ฐฐ์น ํ๊ฒฝ์ ์๋ ์ค์
public class TestBatchConfig {
}
@EnableBatchProcessing
: ์คํ๋ง๋ถํธ ๋ฐฐ์น ์คํํฐ์ ๋ฏธ๋ฆฌ ์ ์๋ ์ค์ ๋ค์ ์คํ์ํค๋ ์ด๋ ธํ ์ด์ ์ผ๋ก JobBuilder, StepBuilder ๋ฑ ๋ค์ํ ์ค์ ์ฃผ์
์ฐธ๊ณ
Last updated
Was this helpful?