JTA EntityManager不能使用getTransaction（）

Question

如何在我的非 ejb 应用程序中使用以下代码。代码有效。

@Override
public void saveItems(Collection<T> items) {
    synchronized (em) {
        EntityTransaction tx = em.getTransaction();
        try {
            tx.begin();
            for (T item : items) {
                saveItem_((Class<T>) null, item);
            }
            tx.commit();
        } finally {
            if (tx.isActive()) {
                tx.rollback();
            }
        }
    }
}

在一个新的应用程序中，我使用EJB3 JSF，并希望重用包含上述代码的库。我的新应用程序的死亡单元如下所示:

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

我的新应用程序在遇到此行时会引发异常：

    EntityTransaction tx = em.getTransaction();

例外情况是：

A JTA EntityManager cannot use getTransaction()

这是足够清楚的。问题是如何将代码转换为由容器管理事务。大概我的bean方法需要适当地注释……问题是如何注释？

Answer 1

只是总结一下在Jboss EAP6和Hibernate上适用于我的代码4.2.18.Final.

可以为某人节省时间。

persistence.xml

<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_2_0.xsd"
         version="2.0">
<persistence-unit name="myApp" transaction-type="JTA">
<provider>org.hibernate.ejb.HibernatePersistence</provider>
<jta-data-source>jdbc/MySQLConnection</jta-data-source>
<properties>
        <property name="hibernate.dialect" value="org.hibernate.dialect.MySQL5Dialect"/>
        <property name="hibernate.transaction.manager_lookup_class" value="org.hibernate.transaction.JBossTransactionManagerLookup"/>
        <!--
        <property name="hibernate.show_sql" value="true" />
        -->
    </properties>
</persistence-unit>

爪哇

 import javax.annotation.Resource;
 import javax.persistence.EntityManager;
 import javax.transaction.UserTransaction;

public class MyClass {
@PersistenceContext(unitName = "myApp")
protected EntityManager em;
@Resource
UserTransaction utx;

public void execute(..) throws Exception {
    try {
        utx.begin();
        em.remove(..);
        em.merge(..);
        em.persist(..);
        utx.commit();
    } catch (Exception ex) {
        try {
            utx.rollback();
        } catch (Exception re) {
            throw new RollbackFailureException("An error occurred attempting to roll back the transaction.", re);
        }
        throw ex;
    }
}

}

pom.xml

    <dependency>
        <groupId>org.hibernate</groupId>
        <artifactId>hibernate-entitymanager</artifactId>
        <version>${hibernate.version}</version>
        <scope>provided</scope>
    </dependency>

链接：

应用程序托管实体管理器 https://docs.oracle.com/cd/E19798-01/821-1841/bnbra/index.html

UserTransaction和EntityManager是如何交互的？

Answer 2

在最简单的情况下-它只是工作。如果您将EntityManager注入到EJB中，并且没有使用特殊注释，则事务将在输入的第一个EJB方法中打开（这意味着如果EjbA调用EjbB，而EjbB又调用EjbC，则所有EJB方法中只会使用一个事务）。如果要修改事务的控制方式，请查找@Transaction。

执行回滚的最简单方法是抛出一个标记为@ApplicationException的异常(rollback=true)

我可能错了，但从您的代码来看，您应该阅读EXTENDED和NORMAL EntityManager之间的区别。看起来您使用扩展em的方式非常尴尬（将循环移出事务将帮助您最终摆脱）。

小编辑：如果您尝试使用UserTransaction，正如另一篇文章所建议的，您会收到错误，因为标准EntityManager（您可能正在使用）使用所谓的CMT（容器管理事务）。不要碰它，除非您了解三个基本选项（如果您愿意，我可以详细说明，但坦率地说，您不需要它）：

• 容器托管的实体管理器与应用程序管理的实体管理器，
• 容器管理事务与应用程序管理事务，
• NORMAL EntityManager 和 Extended EntityManager。

Answer 3

EntityTransaction与resource local类型的实体管理器一起使用。如果要使用JTA，则必须使用UserTransaction接口。

来自文档:EntityTransaction -用于控制资源上的事务的接口-本地实体管理器。EntityManager.getTransaction()方法返回EntityTransaction接口。

编辑：添加了伪代码。

@Resource
private SessionContext sessionContext;

void execute(){

UserTransaction userTxn = sessionContext.getUserTransaction();

try{

 userTxn.begin();
 /**
  *  do-something
  */
 userTxn.commit();

  } catch(Throwable e){
   userTxn.rollback(); //-- Include this in try-catch 
  }
}