Spring/spring-batch
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

RESOLVED - BATCH-765: StepExecution should be saved on every commit

Browse Source
This commit is contained in:
robokaso
2008-08-11 13:22:33 +00:00
parent 8dc8d253f5
commit 6d15a371ec
2 changed files with 35 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
spring-batch-core/src/test/java/org/springframework/batch/core/step/item/ItemOrientedStepTests.java
View File

@@ -135,6 +135,23 @@ public class ItemOrientedStepTests extends TestCase {
assertEquals(1, stepExecution.getItemCount().intValue());
}
public void testStepExecutionUpdates() throws Exception {
JobExecution jobExecution = new JobExecution(jobInstance);
StepExecution stepExecution = new StepExecution(itemOrientedStep.getName(), jobExecution);
itemOrientedStep.setStepOperations(new RepeatTemplate());
JobRepositoryStub jobRepository = new JobRepositoryStub();
itemOrientedStep.setJobRepository(jobRepository);
itemOrientedStep.execute(stepExecution);
assertEquals(3, processed.size());
assertEquals(3, stepExecution.getItemCount().intValue());
assertTrue(3 <= jobRepository.updateCount);
}
public void testChunkExecutor() throws Exception {
RepeatTemplate template = new RepeatTemplate();
@@ -780,7 +797,22 @@ public class ItemOrientedStepTests extends TestCase {
return str.indexOf(searchStr) != -1;
}
private class MockRestartableItemReader extends ItemStreamSupport implements ItemReader<String>, StepExecutionListener {
private static class JobRepositoryStub extends JobRepositorySupport {
private int updateCount = 0;
@Override
public void update(StepExecution stepExecution) {
updateCount++;
if (updateCount <= 3) {
assertEquals(Integer.valueOf(updateCount), stepExecution.getItemCount());
}
}
}
private class MockRestartableItemReader extends ItemStreamSupport implements ItemReader<String>,
StepExecutionListener {
private boolean getExecutionAttributesCalled = false;