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

Updated HibernateItemReaderHelper to use reflection for Session#close()

Browse Source 
Hibernate 5 changed the signature of the Session#close() method from
returning a Connection to being void.  To support both verions, we've
moved to making the call via reflection.

This commit also upgrades the ActiveMQ version used in testing to be
compliant with the Spring IO Platform.

Resolves BATCH-2496
This commit is contained in:
Michael Minella
2016-04-19 12:38:45 -05:00
parent ade242f2c4
commit 7d2c1a1eca
5 changed files with 23 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-batch-infrastructure/src/main/java/org/springframework/batch/item/database/HibernateItemReaderHelper.java
View File

@@ -15,6 +15,7 @@
*/
package org.springframework.batch.item.database;
import java.lang.reflect.Method;
import java.util.Collection;
import java.util.List;
import java.util.Map;
@@ -28,6 +29,7 @@ import org.hibernate.StatelessSession;
import org.springframework.batch.item.database.orm.HibernateQueryProvider;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.util.Assert;
import org.springframework.util.ReflectionUtils;
import org.springframework.util.StringUtils;
/**
@@ -197,7 +199,9 @@ public class HibernateItemReaderHelper<T> implements InitializingBean {
statelessSession = null;
}
if (statefulSession != null) {
statefulSession.close();
Method close = ReflectionUtils.findMethod(Session.class, "close");
ReflectionUtils.invokeMethod(close, statefulSession);
statefulSession = null;
}
}