diff --git a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/HibernateCursorItemReader.java b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/HibernateCursorItemReader.java index 6552b3d76..070a6f8c5 100644 --- a/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/HibernateCursorItemReader.java +++ b/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/HibernateCursorItemReader.java @@ -220,13 +220,14 @@ public class HibernateCursorItemReader extends AbstractItemCountingItemStream @Override protected void doClose() throws Exception { - initialized = false; + if(initialized) { + if (cursor != null) { + cursor.close(); + } - if (cursor != null) { - cursor.close(); + helper.close(); } - helper.close(); - + initialized = false; } }