我相信transaction不适用于Wildfli8.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。为什么这个交易不起作用?这是我为这段代码遵循的链接:
我还假设jta的默认值在数据源中为真,不需要显式添加。
发布于 2020-08-31 11:33:27
我找到了这个问题的解决方案,即异步线程。解决方案是在DataSource ()完成之后从UserTransaction.begin()获取连接。这与Wildfly文档不一致,其中示例显示,可以在Transaction.begin()之前获取连接,但它不适用于异步线程场景(不过,它在Wildfly托管bean场景中运行得非常完美)。
发布于 2020-08-28 07:52:17
我也有类似的问题。但是,当我点击via Servlet时,就会看到上面的内容。--当我试图在非EE线程中使用事务时,问题就出现了。它不会抛出任何异常,但是DB事务仍然是提交的,即使我使用了Usertransaction.rollback()。根据Wildfli8文档,使用java:jboss/UserTransaction获取应该存在的用户事务,代码可以获得Usertransaction对象,但实际上并不控制DB的更改,如上面所示。我的感觉是,我的非EE线程在某种程度上不是Wildfly管理事务的一部分,但不能围绕它编写任何文档。这里的任何投入都是很好的。
https://stackoverflow.com/questions/63615307
复制相似问题