如何使用weblogic和JPA处理Spring中的事务

Question

我正在用JPA在Spring中实现一个应用程序，并将其部署在weblogic服务器中。我想知道如何处理交易。对于数据库配置，我配置了persistence.xml将事务类型声明为JTA。在我的持久性逻辑中，当更新一些东西时，我使用这个逻辑：

entityManager.getTransaction().commit();

但它抛出了一个例外。如果我不提交，数据库表中的数据就不会更新。即使我尝试在方法级别声明@Transactional，它也不起作用。有没有人能告诉我如何处理交易，以及我是否正确使用它们。

这是我的档案。

DAO类：

  @Override
        @Transactional
        public void updateBpm(User user) {
            EntityManager entityManager=null;
            try{
             entityManager=entityManagerFactory.createEntityManager();
            String  query="update com_tt_bpm_batch set status = 'FAILED' where  seqNo="+user.getSeqNo();
            entityManager.createNativeQuery(query);
            System.out.println("table updated Successfully..");

                }
            catch(Exception e){
                logger.error(e.getStackTrace());

            }

        }

这是我的spring配置文件：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:mvc="http://www.springframework.org/schema/mvc" 
    xmlns:batch="http://www.springframework.org/schema/batch"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:task="http://www.springframework.org/schema/task" xmlns:util="http://www.springframework.org/schema/util"
    xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/batch
    http://www.springframework.org/schema/batch/spring-batch-2.2.xsd
    http://www.springframework.org/schema/beans 
    http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
    http://www.springframework.org/schema/mvc
    http://www.springframework.org/schema/mvc/spring-mvc-3.2.xsd
    http://www.springframework.org/schema/context
    http://www.springframework.org/schema/context/spring-context-3.2.xsd
    http://www.springframework.org/schema/task
        http://www.springframework.org/schema/task/spring-task-3.2.xsd
        http://www.springframework.org/schema/util 
        http://www.springframework.org/schema/util/spring-util-3.2.xsd
        http://www.springframework.org/schema/jdbc 
        http://www.springframework.org/schema/jdbc/spring-jdbc-3.2.xsd
        http://www.springframework.org/schema/tx
        http://www.springframework.org/schema/tx/spring-tx-3.2.xsd
    ">
    <tx:annotation-driven />
    <context:annotation-config/>
    <mvc:annotation-driven/>
     <context:component-scan base-package="com.tcs" /> 


        <bean id="entityManagerFactory"
            class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
             <property name="persistenceXmlLocation" value="/WEB-INF/META-INF/persistence.xml" /> 
             <property name="persistenceUnitName" value="Mypersist" /> 
            <!--  <property name="dataSource" ref="dataSource" /> -->
             <property name="jpaVendorAdapter" ref="jpaVendorAdapter" />
             <property name="jpaDialect" ref="jpaDialect" />
             <property name="jpaProperties">
            <props>
                <prop key="hibernate.transaction.manager_lookup_class">org.hibernate.transaction.WeblogicTransactionManagerLookup
                </prop>
            </props>
        </property> 
        </bean>

      <bean id="baseTransactionProxy" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean"
    abstract="true">
    <property name="transactionManager" ref="transactionManager"/>
    <property name="transactionAttributes">
      <props>
        <prop key="updateBpm">PROPAGATION_REQUIRED</prop>
        <prop key="getforBpm">PROPAGATION_REQUIRED</prop>
      </props>
    </property>
  </bean>
        <bean id="jpaVendorAdapter" class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter">
          <!--  <property name="database" value="oracle" /> -->
           <property name="databasePlatform" value="org.hibernate.dialect.Oracle10gDialect" />
       </bean>

<bean id="jpaDialect" class="org.springframework.orm.jpa.vendor.HibernateJpaDialect" />



 <bean id="transactionManager"
    class="org.springframework.transaction.jta.WebLogicJtaTransactionManager">
    <property name="transactionManagerName"
      value="javax.transaction.TransactionManager"/>
  </bean>


    <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
        <property name="prefix" value="/WEB-INF/pages/" />
        <property name="suffix" value=".jsp"/>
    </bean>

</beans>

这是我的坚持。xml

<?xml version="1.0" encoding="UTF-8"?>
<persistence xmlns="http://java.sun.com/xml/ns/persistence"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://java.sun.com/xml/ns/persistence
    http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd"
    version="1.0">

    <persistence-unit name="Mypersist" transaction-type="JTA">
        <provider>org.hibernate.ejb.HibernatePersistence</provider>
         <jta-data-source>MCDataSource</jta-data-source>

    </persistence-unit>


</persistence>

Answer 1

我认为最好在服务层处理事务（适用于您的服务使用多个dao方法的情况）。您应该创建一次实体管理器，而不是为每个dao方法创建。

这是我如何处理jpa事务的例子。

道层：

@PersistenceContext
private EntityManager entityManager;

@Override
public String create(Brand brand) throws DaoException {
    try {
        entityManager.persist(brand);
    } catch (HibernateException e) {
        throw new DaoException(e);
    }
    return brand.getId();
}

服务层示例：

@Service
@Transactional(readOnly = false, propagation = Propagation.REQUIRES_NEW)
public class BrandServiceImpl implements IBrandService {

    @Autowired
    private IBrandDao brandDao;

    @Override
    public TransportObject create(Brand brand) {
        TransportObject transportObject = null;
        try {
           // some code here
        } catch (DaoException e) {

        }
        return transportObject;
}

和配置示例：

<bean id="jpaVendorAdapter" class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter">
        <property name="showSql" value="false"/>
        <property name="generateDdl" value="false"/>
        <property name="databasePlatform" value="org.hibernate.dialect.MySQLDialect"/>
    </bean>

    <bean id="myEmf" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
        <property name="dataSource" ref="dataSource"/>
        <property name="packagesToScan">
            <value>package path</value>
        </property>
        <property name="jpaVendorAdapter" ref="jpaVendorAdapter"/>
    </bean>

    <tx:annotation-driven transaction-manager="txManager" />
    <bean id="txManager" class="org.springframework.orm.jpa.JpaTransactionManager">
        <property name="entityManagerFactory" ref="myEmf" />
    </bean>

Answer 2

您正在创建查询：

entityManager.createNativeQuery(query);

但您没有执行它：http://docs.oracle.com/javaee/6/api/javax/persistence/Query.html#executeUpdate（）