如何使用Spring Data JPA发出修改查询以通过其ID删除一组实体?

Man*_*anu 3 java spring jpa spring-data spring-data-jpa

我试图从我的数据库中删除大量的记录.每个记录都有一个外键级联,这样,当通过JPA一次删除一条记录时,每次删除需要大约5秒.

所以我决定写一个像这样的JPQL查询:

@Repository
public interface MyTableRepository extends JpaRepository<MyTable, Long> {
    @Query("delete from MyTable where id in :ids")
    void deleteAllIds(@Param("ids") Long[] ids);
}
Run Code Online (Sandbox Code Playgroud)

当我运行它或等效时void deleteAllIds(@Param("ids") Set<Long> ids);,我得到以下内容:

org.springframework.web.util.NestedServletException: Request processing failed; nested exception is org.springframework.dao.InvalidDataAccessApiUsageException: org.hibernate.hql.internal.QueryExecutionRequestException: Not supported for DML operations [delete from com.lh.clte.domain.content.business.Hotel where id in (:ids_0_, :ids_1_, :ids_2_, :ids_3_, ... for the entire array size)]
    org.springframework.orm.jpa.EntityManagerFactoryUtils.convertJpaAccessExceptionIfPossible(EntityManagerFactoryUtils.java:293)
    org.springframework.orm.jpa.AbstractEntityManagerFactoryBean.translateExceptionIfPossible(AbstractEntityManagerFactoryBean.java:403)
    org.springframework.dao.support.ChainedPersistenceExceptionTranslator.translateExceptionIfPossible(ChainedPersistenceExceptionTranslator.java:59)
    org.springframework.dao.support.DataAccessUtils.translateIfNecessary(DataAccessUtils.java:213)
    org.springframework.dao.support.PersistenceExceptionTranslationInterceptor.invoke(PersistenceExceptionTranslationInterceptor.java:147)
    org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
    org.springframework.data.jpa.repository.support.CrudMethodMetadataPostProcessor$CrudMethodMetadataPopulatingMethodIntercceptor.invoke(CrudMethodMetadataPostProcessor.java:111)
    org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
    org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
    org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
    org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:207)
    com.sun.proxy.$Proxy72.deleteAllId(Unknown Source)
Run Code Online (Sandbox Code Playgroud)

我怎样才能实现目标?

Oli*_*ohm 6

要执行修改查询,您需要使用参考文档中的@Modifying描述来注释该方法.

请注意,发出删除查询不会导致调用受影响实体的任何生命周期回调,因为该语句是直接对数据库执行的.为了获得名为issue的回调,findAll(…)给定标识符列表ad将结果输入到deleteAll(…).

如果您不管理上述任何层中的事务,请确保您还使用,@Transactional以便在JPA要求的事务中运行查询.

  • 另外,`delete`方法必须用`@Transactional`注释. (2认同)