import javax.transaction.xa.XAResource; //导入方法依赖的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();

}

}

}