Usertransaction在Oracle DB的Wildfly中不起作用

问题描述

我认为事务在Wildfly 8.2和oracle 12.2上不起作用,以下是我尝试运行的代码

public static void checkTransaction() throws Exception {

    Statement stmt = null; // Non-transactional statement
    Statement stmtx = null;

    InitialContext initialContext = new InitialContext();

    DataSource ds = (DataSource) initialContext.lookup("jdbc/myDataSource");

    Connection conn = ds.getConnection("USERENAME","PASSWORD");

    UserTransaction txn = (UserTransaction) new 
    InitialContext().lookup("java:jboss/UserTransaction");


    try {
        stmt = conn.createStatement(); // non-tx statement

        try {
            stmt.executeUpdate("DROP TABLE test_table");
        } catch (Exception e) {
            e.printstacktrace();
            
        }

        try {
            stmt.executeUpdate("CREATE TABLE test_table (a INTEGER,b INTEGER)");
        } catch (Exception e) {
            throw new RuntimeException(e);
        }

        try {
            System.out.println("Starting top-level tranasction.");

            txn.begin();

            stmtx = conn.createStatement(); // will be a tx-statement

            stmtx.executeUpdate("INSERT INTO test_table (a,b) VALUES (1,2)");

            // First,we try to roll back changes

            txn.rollback(); // rollback 

            txn.begin(); // start second tranaction

            stmtx = conn.createStatement();

            stmtx.executeUpdate("INSERT INTO test_table (a,b) VALUES (3,4)");

            txn.commit(); // committing the second transaction
        } catch (Exception ex) {
            throw new RuntimeException(ex);

        }
    } catch (Exception sysEx) {
        sysEx.printstacktrace();
        
    }
}

数据源配置如下:

 <datasources>
<datasource enabled="true" jndi-name="java:/jdbc/myDataSource" pool-name="DataSourcePool" use-ccm="true">
    <connection-url>jdbc:oracle:thin:@(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=host)(PORT=1521))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME=serviceId)))</connection-url>
    <driver>oracle</driver>
    <pool>
        <min-pool-size>4</min-pool-size>
        <max-pool-size>18</max-pool-size>
    </pool>
    <security>
        <security-domain>EncryptedDBPassword</security-domain>
    </security>
    <validation>
        <valid-connection-checker class-name="org.jboss.jca.adapters.jdbc.extensions.oracle.OracleValidConnectionChecker"/>
        <check-valid-connection-sql>select 1 from dual</check-valid-connection-sql>
        <validate-on-match>true</validate-on-match>
        <background-validation>true</background-validation>
        <background-validation-millis>30000</background-validation-millis>
        <stale-connection-checker class-name="org.jboss.jca.adapters.jdbc.extensions.oracle.OracleStaleConnectionChecker"/>
        <exception-sorter class-name="org.jboss.jca.adapters.jdbc.extensions.oracle.OracleExceptionSorter"/>
    </validation>
    <timeout>
        <set-tx-query-timeout>true</set-tx-query-timeout>
        <blocking-timeout-millis>10000</blocking-timeout-millis>
        <idle-timeout-minutes>1</idle-timeout-minutes>
        <query-timeout>120</query-timeout>
        <use-try-lock>0</use-try-lock>
        <allocation-retry>0</allocation-retry>
        <allocation-retry-wait-millis>0</allocation-retry-wait-millis>
    </timeout>
    <statement>
        <share-prepared-statements>false</share-prepared-statements>
    </statement>
</datasource>
<drivers>
    <driver module="com.h2database.h2" name="h2">
        <xa-datasource-class>org.h2.jdbcx.JdbcDataSource</xa-datasource-class>
    </driver>
    <driver module="com.oracle.ojdbc" name="oracle">
        <driver-class>oracle.jdbc.OracleDriver</driver-class>
    </driver>
</drivers>

发生了什么事

代码中可以预期,test_table将仅具有一个条目,即(3,4),因为回滚了先前插入(1,2)的事务,但实际上该表包含2行,并且两者sql已提交。任何原因导致此交易无法正常进行? 这是我遵循此代码链接

https://access.redhat.com/documentation/en-us/red_hat_jboss_enterprise_application_platform/7.1/html/development_guide/java_transaction_api_jta#jta_transaction_example

我还假设jta的认值在数据源中为true,并且不需要显式添加

解决方法

我能够找出解决该问题的方法,即针对异步线程。 解决方法是在完成UserTransaction.begin()之后从数据源获取连接。 这与Wildfly文档不一致,该示例显示该示例可以在Transaction.begin()之前获取连接,但不适用于异步线程方案(尽管在Wildfly托管Bean方案中也可以正常工作)。

链接到Wildfly交易示例:https://access.redhat.com/documentation/en-us/jboss_enterprise_application_platform/6/html/development_guide/jta_transaction_example

,

我有一个类似的问题。但是,上面的内容在我通过Servlet命中时。 当我尝试在非EE线程中使用事务时出现问题。它不会引发任何异常,但是即使我使用了Usertransaction.rollback(),数据库事务仍会提交。 根据Wildfly 8文档,使用 java:jboss / UserTransaction 来获取应该存在的用户事务,并且代码确实获得了Usertransaction对象,但实际上并不控制数据库更改,如上所述。 我的感觉是,我的非EE线程某种程度上不是Wildfly托管事务的一部分,但是周围没有任何文档。 这里的任何输入都会很棒。