java - 如何使用 hibernate 设置 UserTransaction

Question

我有一个用于管理用户信息的 mySQL 数据库，我正在为我的 mySQL 数据库使用 JTA 数据源，这是 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();
  }

DAO 是这样的:

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();
      }
}

但每次当我加载页面并尝试从数据库中删除时，我都会收到此错误:

注入(inject)资源查找失败:java:jboss/UserTransaction]

UserTransaction [根异常是 java.lang.IllegalStateException: WFLYEJB0137: 只有具有 bean 管理事务划分的 session 和消息驱动 bean 才允许访问 UserTransaction]

Answer 1

您不能在 EJB 中使用 UserTransaction，除非您添加 @TransactionManagement(BEAN)

TransactionManagement 做的是

指定 session bean 或消息驱动的 bean 是否具有容器管理的事务或 bean 管理的事务。如果不使用此注释，则假定该 bean 具有容器管理的事务管理。

@TransactionManagement(BEAN)
public class userDAO {