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

Add read from start to integration test

Browse Source
This commit is contained in:
dsyer
2010-03-29 11:06:44 +00:00
parent be46d4e2f3
commit 7dd1a4eea3
1 changed files with 25 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
spring-batch-infrastructure-tests/src/test/java/org/springframework/batch/item/database/JdbcPagingRestartIntegrationTests.java
View File

@@ -81,16 +81,38 @@ public class JdbcPagingRestartIntegrationTests {
jdbcTemplate.update("DELETE from T_FOOS where ID>?", maxId);
}
@Test
public void testReaderFromStart() throws Exception {
ItemReader<Foo> reader = getItemReader();
int total = SimpleJdbcTestUtils.countRowsInTable(jdbcTemplate, "T_FOOS");
ExecutionContext executionContext = new ExecutionContext();
((ItemStream) reader).open(executionContext);
for (int i = 0; i < total; i++) {
Foo item = reader.read();
logger.debug("Item: " + item);
assertNotNull(item);
}
Foo item = reader.read();
logger.debug("Item: " + item);
assertNull(item);
}
@Test
public void testReader() throws Exception {
public void testReaderOnRestart() throws Exception {
ItemReader<Foo> reader = getItemReader();
int total = SimpleJdbcTestUtils.countRowsInTable(jdbcTemplate, "T_FOOS");
int count = (total / pageSize) * pageSize;
if (count >= pageSize) {
count -= pageSize;
int pagesToRead = Math.min(3, total/pageSize);
if (count >= pagesToRead*pageSize) {
count -= pagesToRead*pageSize;
}
ExecutionContext executionContext = new ExecutionContext();