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

RESOLVED - BATCH-590: broken rollback/buffering in JdbcCursorItemReader

Browse Source 
fixed the buffering issue and added a more thorough rollback test for all readers
This commit is contained in:
robokaso
2008-04-16 12:41:54 +00:00
parent 3d30a64f0b
commit cbad1565d3
2 changed files with 23 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
spring-batch-infrastructure/src/test/java/org/springframework/batch/item/CommonItemReaderTests.java
View File

@@ -1,10 +1,9 @@
package org.springframework.batch.item;
import org.springframework.batch.item.sample.Foo;
import org.springframework.util.Assert;
import junit.framework.TestCase;
import org.springframework.batch.item.sample.Foo;
/**
* Common tests for {@link ItemReader} implementations. Expected input is five
* {@link Foo} objects with values 1 to 5.
@@ -50,18 +49,33 @@ public abstract class CommonItemReaderTests extends TestCase {
*/
public void testReset() throws Exception {
Foo foo1 = (Foo) tested.read();
assertEquals(1, foo1.getValue());
tested.mark();
Foo foo2 = (Foo) tested.read();
Assert.state(!foo2.equals(foo1));
assertEquals(2, foo2.getValue());
Foo foo3 = (Foo) tested.read();
Assert.state(!foo2.equals(foo3));
assertEquals(3, foo3.getValue());
tested.reset();
assertEquals(foo2, tested.read());
assertEquals(foo3, tested.read());
Foo foo4 = (Foo) tested.read();
assertEquals(4, foo4.getValue());
tested.mark();
Foo foo5 = (Foo) tested.read();
assertEquals(5, foo5.getValue());
assertNull(tested.read());
}
}