java - 如何使用 hibernate 设置UserTransaction

我有一个用于管理用户信息的mySQL数据库，我正在使用JTA数据源来管理mySQL数据库，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="SensorCloudPU" transaction-type="JTA">
      <jta-data-source>java:/SensorCloudPU</jta-data-source>
<!--      <non-jta-data-source>java:/SensorCloudPU</non-jta-data-source> -->
      <class>com.sensorhound.common.domain.impl.AnomalousInfo</class>
      <class>com.sensorhound.common.domain.impl.Code</class>
      <class>com.sensorhound.common.domain.impl.Device</class>
      <class>com.sensorhound.common.domain.impl.Executable</class>
      <class>com.sensorhound.common.domain.impl.Group</class>
      <class>com.sensorhound.common.domain.impl.GroupAlert</class>
      <class>com.sensorhound.common.domain.impl.GroupRule</class>
      <class>com.sensorhound.common.domain.impl.GroupRuleDefinition</class>
      <class>com.sensorhound.common.domain.impl.GroupRuleStatus</class>
      <class>com.sensorhound.common.domain.impl.Node</class>
      <class>com.sensorhound.common.domain.impl.NodeAlert</class>
      <class>com.sensorhound.common.domain.impl.NodeRule</class>
      <class>com.sensorhound.common.domain.impl.NodeRuleDefinition</class>
      <class>com.sensorhound.common.domain.impl.Organization</class>
      <class>com.sensorhound.common.domain.impl.PastGroupStatus</class>
      <class>com.sensorhound.common.domain.impl.Trace</class>
      <class>com.sensorhound.common.domain.impl.TrainingSession</class>
      <class>com.sensorhound.common.domain.impl.User</class>
      <class>com.sensorhound.common.domain.impl.Role</class>
      <exclude-unlisted-classes>true</exclude-unlisted-classes>
      <properties>
         <property name="hibernate.dialect" value="org.hibernate.dialect.MySQLDialect"/>
         <property name="hibernate.hbm2ddl.auto" value="update"/>
         <property name="hibernate.show_sql" value = "false" />
         <property name="hibernate.connection.autocommit" value="true" />
         <property name="hibernate.event.merge.entity_copy_observer" value="allow"/>
         <property name="transaction.factory_class" value="org.hibernate.transaction.JTATransactionFactory"/>
         <property name="jta.UserTransaction" value="java:jboss/UserTransaction"/>
      </properties>
   </persistence-unit>
</persistence>

我有一个这样的终点：

@Path("/delete")
  @POST
  @Consumes(MediaType.APPLICATION_FORM_URLENCODED)
  @Produces(MediaType.APPLICATION_JSON)
  public Response deleteUser(@FormParam("organization_id") Integer organizationId,
      @FormParam("username") String username) throws JsonProcessingException, NotSupportedException,
      SystemException, SecurityException, IllegalStateException, RollbackException,
      HeuristicMixedException, HeuristicRollbackException, NamingException {
    Organization org = organizationDAO.getByOrganizationId(organizationId);
    userDao.deleteUserByUserNameAndOrganization(username, org);
    return Response.status(Response.Status.OK).build();
  }

刀是这样的：

public class userDAO {
  @PersistenceContext(unitName = "SensorCloudPU")
  protected EntityManager em;

  @Resource
  protected UserTransaction utx;

  public void deleteUserByUserNameAndOrganization(String userName, Organization org)
          throws NotSupportedException, SystemException, SecurityException, IllegalStateException,
          RollbackException, HeuristicMixedException, HeuristicRollbackException {
        Query q = this.em.createNamedQuery(User.Q_GET_BY_USERNAME_AND_ORGANIZATION);
        q.setParameter("organization", org);
        q.setParameter("user_name", userName);
        User u = this.executeQueryForSingleResult(q);
        if (u == null) {
          return;
        }
        utx.begin();
        this.em.remove(u);
        utx.commit();
      }
}

但每次加载页面并尝试从数据库中删除时，都会出现以下错误：
注入资源查找失败：java:jboss/UserTransaction]
UserTransaction[根异常是java.lang.IllegalStateException:WFLYEJB0137:只有具有bean管理的事务划分的会话和消息驱动bean才允许访问UserTransaction]

最佳答案

因为您主要关心事务管理，所以我建议您将DAO转换为一个EJB。只需要一行：

@Stateless
public class userDAO {

    @PersistenceContext(unitName = "SensorCloudPU")
    protected EntityManager em;

    public void deleteUserByUserNameAndOrganization(String userName, Organization org) {
        Query q = this.em.createNamedQuery(User.Q_GET_BY_USERNAME_AND_ORGANIZATION);
        q.setParameter("organization", org);
        q.setParameter("user_name", userName);
        User u = this.executeQueryForSingleResult(q);
        if (u != null) {
            this.em.remove(u);
        }
    }
}

你可以看到它大大简化了事情。ejb免费为您提供JTA事务划分（并在需要时回滚）。
即使你正在建立一个仅限战争的部署，这也会起作用。
如果需要，还可以将@Stateless添加到JAX-RS端点。至少你会得到更多的监控。

关于java - 如何使用 hibernate 设置UserTransaction，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/45423923/