2015-01-12 88 views
0

海兰家伙,春批,单元测试,JPA事务和Hibernate延迟加载:IllegalTransactionStateException

我想运行一个春天批处理作业,然后就导致数据的一些测试,但我需要使用Hibernate延迟加载。所以我需要一个打开的事务来保持会话活着。

但我得到这个异常:IllegalTransactionStateException:发现预绑定的JDBC连接!

我可以编写方法直接获取我想测试的关联对象,但是我不想仅为测试编写方法,并且不会释放hibernate的优势。

有没有办法做到这一点?我已经尝试在jobRepositoy中将validateStateTransaction设置为false,但它不起作用(实际上它只能在像MapJobRepository这样的内存元数据存储库中工作)

我在寻找几天但。没有什么工作

你能帮我请感谢

我的代码在这里:

<bean id="jobRepository" 
    class="org.springframework.batch.core.repository.support.JobRepositoryFactoryBean"> 
    <property name="databaseType"> 
     <value>POSTGRES</value> 
    </property> 
    <property name="dataSource" ref="databasePool" /> 
    <property name="transactionManager" ref="transactionManager" /> 
    <property name="isolationLevelForCreate" value="ISOLATION_DEFAULT" /> 
    <property name="tablePrefix" value="#{ schema }.BATCH_" /> 
    <property name="validateTransactionState" value="false" /> 
</bean> 

@Test 
@Transactional 
public void test() { 

    /* 
    * ===================RUN JOB====================== 
    */ 
    JobParameters jobParameters = new JobParametersBuilder(); 

    int returnCode = runJob("job_name", jobParameters); 
    assertEquals("returnCode must be 0.", 0, returnCode); 

    /* 
    * ===============END JOB============================= 
    */ 

    /* 
    * ===============TEST ON DATA========================== 
    */ 
    ObjectToTest obj = objectDao.findById("1"); 

    assertNotNull(obj.getSomeCollection().get(1)); 

    /* 
    * =================END TEST================== 
    */ 

} 

这里是个例外:

org.springframework.transaction.IllegalTransactionStateException: Pre-bound JDBC Connection found! JpaTransactionManager does not support running within DataSourceTransactionManager if told to manage the DataSource itself. It is recommended to use a single JpaTransactionManager for all transactions on a single DataSource, no matter whether JPA or JDBC access. 
at org.springframework.orm.jpa.JpaTransactionManager.doBegin(JpaTransactionManager.java:359) 
at org.springframework.transaction.support.AbstractPlatformTransactionManager.getTransaction(AbstractPlatformTransactionManager.java:373) 
at org.springframework.transaction.interceptor.TransactionAspectSupport.createTransactionIfNecessary(TransactionAspectSupport.java:438) 
at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:261) 
at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:95) 
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179) 
at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:207) 
at com.sun.proxy.$Proxy113.getLastJobExecution(Unknown Source) 
at org.springframework.batch.core.launch.support.SimpleJobLauncher.run(SimpleJobLauncher.java:98) 
at org.springframework.batch.core.launch.support.CommandLineJobRunner.start(CommandLineJobRunner.java:362) 
at org.springframework.batch.core.launch.support.CommandLineJobRunner.main(CommandLineJobRunner.java:590) 
at fr.insee.harmonica.commun.batch.CommandLineJobRunnerTest.runJob(CommandLineJobRunnerTest.java:143) 
at fr.insee.harmonica.commun.batch.CommandLineJobRunnerTest.execute(CommandLineJobRunnerTest.java:420) 

我已经尝试把测试部分,将使用@Transactional来anotated另一种方法,但后来我得到一个LazyInitializationException中......

编辑:

我使用事务管理器的org.springframework.orm.jpa.JpaTransactionManager实现。

这里是我的Spring配置:

<bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager"> 
    <property name="entityManagerFactory" ref="myEmf" /> 
</bean> 

<tx:annotation-driven transaction-manager="transactionManager"/> 

我有搜索的方式来手动打开的事务,但我没有找到它尚未

+0

简短的回答是,'@ Transactional'和Spring Batch的不玩好的,因为一起Spring Batch的手动处理事务。话虽如此,你还没有发布你的事务管理器配置,并且Exception明确指出要使用'JpaTransactionManager'。你是? –

+0

感谢您的回答。我在下一分钟编辑我的消息 – Philippe

+0

有人有解决方案吗? – Philippe

回答

0

好,我找到了解决方案(没有任何帮助,终于)。

为此,您必须在作业结束后手动打开交易。

你可以做这样的事情:

@Autowired 
protected PlatformTransactionManager transactionManager; 

@Test 
public void test() { 

/* 
* ===================RUN JOB====================== 
*/ 
JobParameters jobParameters = new JobParametersBuilder(); 

int returnCode = runJob("job_name", jobParameters); 
assertEquals("returnCode must be 0.", 0, returnCode); 

/* 
* ===============END JOB============================= 
*/ 

/* 
* ===============TEST ON DATA========================== 
*/ 
(new TransactionTemplate(transactionManager)).execute(new TransactionCallback() { 
     @Override 
     public Object doInTransaction(TransactionStatus status) { 

      ObjectToTest obj = objectDao.findById("1"); 

      assertNotNull(obj.getSomeCollection().get(1)); 
} 
}); 

/* 
* =================END TEST================== 
*/ 




}