将 hibernateTemplate 迁移到 JPA 2 (executeWithNativeSession - doInHibernate)

Question

我正在将我的代码从 hibernate 3（即使用 hibernate 模板）迁移到 JPA 2。我的项目也在使用 Spring。

当前项目使用 hibernatetempate as

hibernateTemplate.executeWithNativeSession(new HibernateCallback<Object>() {
            @Override
            public Object doInHibernate(Session session) throws SQLException {
                Query query = session.getNamedQuery("updateToProcessed");
                query.setParameter("Id", id);
                return query.executeUpdate();
            }
        });

updateToProcessed 是一个简单的更新 hql 查询。请帮助让我知道如何将其转换为 JPA（使用 entityManager）

我尝试过使用

Query query = entityManager.createNamedQuery("updateToProcessed");
        query.setParameter("Id", id);
        query.executeUpdate();

完整的方法是

@Override
    public void updateAllBatchDetails(final String id) {
            Query query = entityManager.createNamedQuery("updateToProcessed");
            query.setParameter("Id", id);
            query.executeUpdate();
    }

但我得到的错误是：

Caused by: javax.persistence.TransactionRequiredException: Executing an update/delete query
    at org.hibernate.jpa.spi.AbstractQueryImpl.executeUpdate(AbstractQueryImpl.java:71)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at org.springframework.orm.jpa.SharedEntityManagerCreator$DeferredQueryInvocationHandler.invoke(SharedEntityManagerCreator.java:333)
    at com.sun.proxy.$Proxy143.executeUpdate(Unknown Source)

我已经在 applicationContext.xml 中配置了 transactionManager，比如

我期待这个答案，我已经在 applicationContext.xml 中配置了它，但我仍然收到该错误

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

    <bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager"
          p:entityManagerFactory-ref="entityManagerFactory"/>

但不知何故，@Transactional 正在工作，我不想使用。

这是 applicationContext.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:c="http://www.springframework.org/schema/c"
       xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-2.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd">

    <context:component-scan base-package="com.batch"/>
    <context:annotation-config/>
    <context:spring-configured/>

    <context:property-placeholder location="classpath:batch.properties"/>

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

    <bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager"
          p:entityManagerFactory-ref="entityManagerFactory"/>

    <aop:aspectj-autoproxy/>

    <import resource="classpath:core/applicationContext.xml"/>
    <import resource="classpath:spring/applicationContext-resources.xml"/>
    <import resource="classpath:spring/applicationContext-batch.xml"/>


    <bean id="entityManagerFactory"
          class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"
          p:persistenceUnitName="default"
          p:jpaVendorAdapter-ref="jpaVendorAdapter"
          p:dataSource-ref="dataSource" />

    <bean id="batchProperties" class="org.springframework.beans.factory.config.PropertiesFactoryBean"
          p:location="classpath:batch.properties"/>


</beans>

Answer 1

要执行批量更新，您应该执行以下操作：

final String updateQuery = "update Person p SET p.name = 'Other Name'";
final int update = entityManager.createQuery(updateQuery).executeUpdate();
System.out.println("updated rows " + update);

Spring 将为您处理提交。 [=

---

编辑：原因：javax.persistence.TransactionRequiredException

您是否配置了事务？要执行更新，您必须打开一个事务。

使用 Spring，您可以在方法中使用注解 @Transactional。

Answer 2

对于这个问题，使用Tasklet 执行查询。
使用TaskletStep 配置步骤，您可以设置“事务管理器”以及“事务属性”，错误应该会消失。