J2EE - JPA - EJB3 - MDB 方法中的事务

Question

我在 JBoss 5.1.0 部署了资源本地数据源（Oracle9i）：

<datasources>
  <local-tx-datasource>
    <jndi-name>OracleDS</jndi-name>
    <connection-url>jdbc:oracle:thin:@IP_ADDRESS:1521:inv9i</connection-url>
    <driver-class>oracle.jdbc.driver.OracleDriver</driver-class>
    <user-name>***</user-name>
    <password>***</password>
    <exception-sorter-class-name>org.jboss.resource.adapter.jdbc.vendor.OracleExceptionSorter</exception-sorter-class-name>
    <metadata>
        <type-mapping>Oracle9i</type-mapping>
    </metadata>
  </local-tx-datasource>
</datasources>

持久化单元：

<persistence version="1.0" 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_1_0.xsd">
    <persistence-unit name="myEJB" transaction-type="RESOURCE_LOCAL">
        <provider>org.hibernate.ejb.HibernatePersistence</provider>
        <non-jta-data-source>java:OracleDS</non-jta-data-source>
        <class>hr.bel.model.Instrument</class>
        <class>hr.bel.model.Order</class>
        <class>hr.bel.model.OrderAdditionalData</class>
        <class>hr.bel.model.OrderCondition</class>
        <class>hr.bel.model.Trade</class>
        <class>hr.bel.model.TradeAdditionalData</class>
        <class>hr.bel.model.Tradeticker</class>
        <properties>
            <property name="hibernate.dialect" value="org.hibernate.dialect.Oracle9iDialect"/>
            <property name="hibernate.hbm2ddl.auto" value="none" />
            <property name="hibernate.show_sql" value="true" />
        </properties>
    </persistence-unit>
</persistence>

在 MDB 中，调用 onMessage 方法时，我尝试持久化一个 bean 并通过命名查询获取该类型的最新 5 个 bean：

@PersistenceContext
    EntityManager em = null;
    public void onMessage(MyMessage msg) {
        Map message = msg.getMessageTree(false);
        Instrument instrument = em.find(Instrument.class, 55);      

        Tradeticker tt = createTradeticker(message);
        tt.setInstrument(instrument);

        log.info("Persisting tradeticker: " + tt.getTradeType());               
        em.persist(tt);             
        log.info("Tradeticker persisted...");

        List<Tradeticker> last5 = em.createNamedQuery("getLast5").setParameter(1,instrument.getInstrumentId()).setMaxResults(5).getResultList();
        log.info("Persisted tradetickers size: " + last5.size());
    }

我的问题是没有任何错误痕迹，但我的 Oracle 数据库中仍然没有任何持久对象。在大量消息调用后，last5.size() 返回 0。日志非常干净。

我发现 MDB 的唯一限制是我必须在方法上使用 REQUIRED 或 NOT_SUPPORTED 事务属性。我的 onMessage 没有注释，因此它使用 REQUIRED 作为默认值。另外，我在 MDB 类上没有任何注释，因此 bean 应该使用容器管理的事务。

我做错了什么？

Answer 1

使用非 jta 数据源时，您不应该自己管理事务吗？也就是拿到一个事务，自己提交数据？我把这类事情留给 JTA 自己，但是当我正确阅读 this 时，它看起来就像你的情况一样，你需要明确承诺。

Answer 2

好的。这就是我解决问题的方法，首先定义 tx 数据源，第二定义 jta 模型和 persistence.xml 中的 jta 数据源。

新的数据源定义：

<datasources>
  <xa-datasource>
    <jndi-name>OracleDS</jndi-name>
    <isSameRM-override-value>false</isSameRM-override-value>
    <xa-datasource-class>oracle.jdbc.xa.client.OracleXADataSource</xa-datasource-class>
    <xa-datasource-property name="URL">jdbc:oracle:thin:@IP_ADDRESS:1521:inv9i</xa-datasource-property>
    <xa-datasource-property name="User">***</xa-datasource-property>
    <xa-datasource-property name="Password">***</xa-datasource-property>
    <exception-sorter-class-name>org.jboss.resource.adapter.jdbc.vendor.OracleExceptionSorter</exception-sorter-class-name>
    <no-tx-separate-pools/>
    <metadata>
      <type-mapping>Oracle9i</type-mapping>
    </metadata>
  </xa-datasource>

jboss:service=事务管理器

新的 persistence.xml：

<persistence version="1.0" 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_1_0.xsd">
    <persistence-unit name="myEJB" transaction-type="JTA">
        <provider>org.hibernate.ejb.HibernatePersistence</provider>
        <jta-data-source>java:OracleDS</jta-data-source>
        <class>hr.bel.model.Instrument</class>
        <class>hr.bel.model.Order</class>
        <class>hr.bel.model.OrderAdditionalData</class>
        <class>hr.bel.model.OrderCondition</class>
        <class>hr.bel.model.Trade</class>
        <class>hr.bel.model.TradeAdditionalData</class>
        <class>hr.bel.model.Tradeticker</class>

        <properties>
            <property name="hibernate.dialect" value="org.hibernate.dialect.Oracle9iDialect"/>
            <property name="hibernate.hbm2ddl.auto" value="none" />
            <property name="hibernate.show_sql" value="true" />
        </properties>
    </persistence-unit>
</persistence>

我的 java 代码是相同的，现在我正在持久化我的对象！在与使用 mysql dbms 的同事讨论后，我们发现 Oracle 及其 tx 和 no-tx 数据源对数据源的使用方式和位置进行了严格的限制。
谢谢大家！

Answer 3

顺便说一句：一种常见的模式是将业务逻辑放入 SLSB 中并从 MDB 中调用它 - 允许逻辑的其他用途。不过应该对你的问题没有什么影响。

我希望默认事务属性是必需的。我看不出这会失败的原因。

我会做这些事情：

1）。对业务逻辑进行尝试/捕获。是否抛出任何异常？

2）。删除查询，我不明白为什么它会失败，但让我们消除它可能干扰插入的任何可能性。让我们依靠数据库。在几条消息通过后，使用命令行 SQL 语句或其他实用程序查看数据库中的内容。

3）。再次检查日志，是否有任何地方出现错误？