使用 Nativequery 删除/更新 JTA 中的记录

Question

我一度陷入非常艰难的境地。

问题是：我必须使用 NativeQuery 来删除和/或更新 JTA 上下文 (EJB) 中的一些数据库记录。

我的 JPA persistence.xml 看起来像：

<persistence-unit name="OzsscJPANBPU" transaction-type="JTA">
    <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>
    <jta-data-source>jdbc/postgres_ozssc</jta-data-source>
    <mapping-file>com/longz/ozssc/model/PostcodeEntity.xml</mapping-file>
    <class>com.longz.ozssc.model.CustomerEntity</class>
 ......

如果我以这种方式使用删除语句：

@Override
public void remove(SmsdOutboxEntity toberemoved){
    em.createNativeQuery("Delete from outbox where \"ID\" = " + toberemoved.getId()).executeUpdate();

TransactionRequiredException 抛出：

root cause

javax.persistence.TransactionRequiredException: 
Exception Description: No transaction is currently active

这样不存在交易。

如果我们手动使用事务：

@Override
public void remove(SmsdOutboxEntity toberemoved){
    em.getTransaction().begin();
    em.createNativeQuery("Delete from outbox where \"ID\" = " + toberemoved.getId()).executeUpdate();
    /*em.flush();*/
    em.getTransaction().commit();

抛出 IllegalStateException：

root cause

javax.ejb.EJBException: EJB Exception: ; nested exception is: 
java.lang.IllegalStateException: The method public abstract javax.persistence.EntityTransaction javax.persistence.EntityManager.getTransaction() cannot be invoked in the context of a JTA EntityManager.

看来我不能手动使用事务，因为 JTA 会自己管理事务。

所以我的问题是：如何使用 Native Query 删除/更新 JTA 托管上下文中的记录？

请指教。

Answer 1

对于 JTA，事务由容器提供，您不应该自己创建它。要在 JTA 中获取事务，您必须将其作为资源访问：

@Resource public UserTransaction utx;
@Resource public EntityManagerFactory factory;

@Override
public void remove(SmsdOutboxEntity toberemoved){
   EntityManager em = factory.createEntityManager();
try {
   em.createNativeQuery("Delete from outbox where \"ID\" = " + toberemoved.getId()).executeUpdate();
   utx.commit();

catch (RuntimeException e) {
    if (utx != null) utx.rollback();
    throw e; // or display error message
}
finally {
    em.close();
}

如果你想省略你自己提交/回滚事务的部分，你需要让你的事务由像 EJB3 这样的容器管理。为此，您可以使用无状态/有状态 ejb bean。

更新：

对于 WebLogic，请尝试使用其用户 weblogic.transaction.UserTransaction 而不是 javax.transaction.UserTransaction。正如文档所说：

此接口定义了特定于 WebLogic 的扩展 javax.transaction.UserTransaction.