import javax.transaction.xa.XAResource; //導(dǎo)入方法依賴的package包/類

public void testSuspendableTx() throws Exception {

if (!versionMeetsMinimum(5, 0)) {

return;

}

Connection conn1 = null;

MysqlXADataSource suspXaDs = new MysqlXADataSource();

suspXaDs.setUrl(BaseTestCase.dbUrl);

suspXaDs.setPinGlobalTxToPhysicalConnection(true);

suspXaDs.setRollbackOnPooledClose(true);

XAConnection xaConn1 = null;

Xid xid = createXid();

try {

/*

* -- works using RESUME

* xa start 0x123,0x456;

* select * from foo;

* xa end 0x123,0x456;

* xa start 0x123,0x456 resume;

* select * from foo;

* xa end 0x123,0x456;

* xa commit 0x123,0x456 one phase;

*/

xaConn1 = suspXaDs.getXAConnection();

XAResource xaRes1 = xaConn1.getXAResource();

conn1 = xaConn1.getConnection();

xaRes1.start(xid, XAResource.TMNOFLAGS);

conn1.createStatement().execute("SELECT 1");

xaRes1.end(xid, XAResource.TMSUCCESS);

xaRes1.start(xid, XAResource.TMRESUME);

conn1.createStatement().execute("SELECT 1");

xaRes1.end(xid, XAResource.TMSUCCESS);

xaRes1.commit(xid, true);

xaConn1.close();

/*

*

* -- fails using JOIN

* xa start 0x123,0x456;

* select * from foo;

* xa end 0x123,0x456;

* xa start 0x123,0x456 join;

* select * from foo;

* xa end 0x123,0x456;

* xa commit 0x123,0x456 one phase;

*/

xaConn1 = suspXaDs.getXAConnection();

xaRes1 = xaConn1.getXAResource();

conn1 = xaConn1.getConnection();

xaRes1.start(xid, XAResource.TMNOFLAGS);

conn1.createStatement().execute("SELECT 1");

xaRes1.end(xid, XAResource.TMSUCCESS);

xaRes1.start(xid, XAResource.TMJOIN);

conn1.createStatement().execute("SELECT 1");

xaRes1.end(xid, XAResource.TMSUCCESS);

xaRes1.commit(xid, true);

} finally {

if (xaConn1 != null) {

xaConn1.close();

}

}

}

總結(jié)

以上是生活随笔為你收集整理的Java commit()_Java XAResource.commit方法代码示例的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。