[java][db]JAVA分布式事务原理及应用 - JAVA

d(100, new byte[]{0x01}, new byte[]{0x02});
xid2 = new MyXid(100, new byte[]{0x11}, new byte[]{0x22});
xaRes.start(xid1, XAResource.TMNOFLAGS);
stmt.executeUpdate("insert into test_table1 values (100)");
xaRes.end(xid1, XAResource.TMSUCCESS);
xaRes.start(xid2, XAResource.TMNOFLAGS);
ret = xaRes.prepare(xid1);
if (ret == XAResource.XA_OK) {
　xaRes.commit(xid2, false);
}
stmt.executeUpdate("insert into test_table2 values (200)");
xaRes.end(xid2, XAResource.TMSUCCESS);
ret = xaRes.prepare(xid2);
if (ret == XAResource.XA_OK) {
　xaRes.rollback(xid2);
}

　　例5―这个例子说明不同的连接上的事务分支如何连接成为一个单独的分支，如果它们连接到相同的资源管理程序。这个特点改善了分布式事务的效率，因为它减少了两步提交处理的数目。两个连接到数据库服务器上的XA将被创建。每个连接创建它自己的XA资源，正规的JDBC连接和语句。在第二个XA资源开始一个事务分支之前，它将察看是否使用和第一个XA资源使用的是同一个资源管理程序。如果这是实例，它将加入在第一个XA连接上创建的第一个分支，而不是创建一个新的分支。稍后，这个事务分支使用XA资源来准备和提交。

xaDS = getDataSource();
xaCon1 = xaDS.getXAConnection("jdbc_user", "jdbc_password");
xaRes1 = xaCon1.getXAResource();
con1 = xaCon1.getConnection();
stmt1 = con1.createStatement();

xid1 = new MyXid(100, new byte[]{0x01}, new byte[]{0x02});
xaRes1.start(xid1, XAResource.TMNOFLAGS);
stmt1.executeUpdate("insert into test_table1 values (100)");
xaRes1.end(xid, XAResource.TMSUCCESS);
xaCon2 = xaDS.getXAConnection("jdbc_user", "jdbc_password");
xaRes2 = xaCon1.getXAResource();
con2 = xaCon1.getConnection();
stmt2 = con1.createStatement();

if (xaRes2.isSameRM(xaRes1)) {
　xaRes2.start(xid1, XAResource.TMJOIN);
　stmt2.executeUpdate("insert into test_table2 values (100)");

　xaRes2.end(xid1, XAResource.TMSUCCESS);
}
else {
　xid2 = new MyXid(100, new byte[]{0x01}, new byte[]{0x03});
　xaRes2.start(xid2, XAResource.TMNOFLAGS);
　stmt2.executeUpdate("insert into test_table2 values (100)");
　xaRes2.end(xid2, XAResource.TMSUCCESS);
　ret = xaRes2.prepare(xid2);
　if (ret == XAResource.XA_OK) {
　　xaRes2.commit(xid2, false);
　}
}
ret = xaRes1.prepare(xid1);
if (ret == XAResource.XA_OK) {
　xaRes1.commit(xid1, false);
}

　　例6―这个例子说明在错误恢复的阶段，如何恢复准备好的或者快要完成的事务分支。它首先试图返回每个分支；如果它失败了，它尝试着让资源管理程序丢掉关于事务的消息。

MyXid[] xids;
xids = xaRes.recover(XAResource.TMSTARTRSCAN | XAResource.TMENDRSCAN);
for (int i=0; xids!=null && i
　try {
　　xaRes.rollback(xids[i]);
　}
　catch (XAException ex) {
　　try {
　　　xaRes.forget(xids[i]);
　　}
　catch (XAException ex1) {
　　System.out.println("rollback/forget failed: " + ex1.errorCode);
　}
}

}

[java][db]JAVA分布式事务原理及应用(三)