spring-data-jpa更新数据InvalidDataAccessApiUsageException:Executing an update/delete query

@Modifying
@Query("update Xxx set success=:success,costMs=:costMs,updateTimestamp=:updateTimestamp where traceId=:traceId")
void updateXxx(@Param("traceId") String traceId, @Param("success") Boolean success, @Param("costMs") Integer costMs, @Param("updateTimestamp") Timestamp updateTimestamp);

日志异常提示如下:

 org.springframework.dao.InvalidDataAccessApiUsageException: Executing an update/delete query; nested exception is javax.persistence.TransactionRequiredException: Executing an update/delete query
	at org.springframework.orm.jpa.EntityManagerFactoryUtils.convertJpaAccessExceptionIfPossible(EntityManagerFactoryUtils.java:413)
	at org.springframework.orm.jpa.vendor.HibernateJpaDialect.translateExceptionIfPossible(HibernateJpaDialect.java:227)
	at org.springframework.orm.jpa.AbstractEntityManagerFactoryBean.translateExceptionIfPossible(AbstractEntityManagerFactoryBean.java:417)
	at org.springframework.dao.support.ChainedPersistenceExceptionTranslator.translateExceptionIfPossible(ChainedPersistenceExceptionTranslator.java:59)
	at org.springframework.dao.support.DataAccessUtils.translateIfNecessary(DataAccessUtils.java:213)
	at org.springframework.dao.support.PersistenceExceptionTranslationInterceptor.invoke(PersistenceExceptionTranslationInterceptor.java:147)
	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
	at org.springframework.data.jpa.repository.support.CrudMethodMetadataPostProcessor$CrudMethodMetadataPopulatingMethodInterceptor.invoke(CrudMethodMetadataPostProcessor.java:133)
	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
	at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
	at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:208)

解决方式:方法加上@Transactional(rollbackFor = Exception.class)注解。

@Transactional(rollbackFor = Exception.class)
@Modifying
@Query("update Xxx set success=:success,costMs=:costMs,updateTimestamp=:updateTimestamp where traceId=:traceId")
void updateXxx(@Param("traceId") String traceId, @Param("success") Boolean success, @Param("costMs") Integer costMs, @Param("updateTimestamp") Timestamp updateTimestamp);

注:如果在Service中调用Repository,一般Service的类或方法上会使用@Transactional,这里是在mq的Listener中直接调用Repository,因此在Repository的方法中加注解。


参考:https://blog.csdn.net/snow_7/article/details/88356084

原文地址:https://www.cnblogs.com/cdfive2018/p/13843632.html