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

EntityTransaction与资源类型为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 
  }
}