前一节中,我们是使用jotm的类,将一个非XA的Resource封装为了一个XAResource,下面我们将使用h2提供的XA接口的实现
org.h2.jdbcx.JdbcDataSource xaDataSource=new org.h2.jdbcx.JdbcDataSource();
xaDataSource.setUser("sa");
xaDataSource.setPassword("");
xaDataSource.setURL("jdbc:h2:tcp://localhost/~/test");
javax.sql.XAConnection dbXAConnection=xaDataSource.getXAConnection();
javax.transaction.xa.XAResource dbXAResource=dbXAConnection.getXAResource();
java.sql.Connection conn=dbXAConnection.getConnection();
以上就是h2的XADataSource的代码,这样子,我们就可以使用真正数据库厂商实现的XADatasource而不是jotm提供的方式,
而之后的事务操作,就与前一节的操作完全一样了。我将不再重复。
在网上看到,有人抱怨jotm的XAPool问题多多,所以我们最好是可以使用厂商自己的数据库的XADatasource实现,而不是封装一个伪XADatasource
如果说,jotm的XAPool问题多多的话,也可以去尝试一下commons dbcp1.4的BasicManagedDataSource(如下)
Jotm jotm=new Jotm(true,false);
TransactionManager transactionManager=jotm.getTransactionManager();
JdbcDataSource xaDataSource=new JdbcDataSource();
xaDataSource.setUser("sa");
xaDataSource.setPassword("");
xaDataSource.setURL("jdbc:h2:tcp://localhost/~/test");
BasicManagedDataSource ds=new BasicManagedDataSource();
ds.setTransactionManager(transactionManager);
ds.setXaDataSourceInstance(xaDataSource);
//按照官方文档说,可以直接设置ds.setXADataSource("org.h2.jdbcx.JdbcDataSource")的类名,
//也是可以的,但是我在此例中,没有成功,debug代码发现在h2获得连接的时候,url参数是空的
//如果有人解决了,或者知道,给我说一下,谢谢
transactionManager.begin();
Connection conn=ds.getConnection();
Statement sta=conncreateStatement();
sta.executeUpdate("insert into test(id,name)values(4,'wang')");
transactionManager.commit();
注:在上面的代码中不同的是,我们不用再将XAResource放入到Transaction中,因为在ds.setTransactionManager(transactionManager)之后,每个从ds获得的Connection相关的XAResouce都被当前事务所管理.
如果我们以下方式
BasicManagedDataSource ds=new BasicManagedDataSource();
ds.setUsername("sa")
ds.setPassword("")
ds.setDriverClassName("jdbc:h2.Driver")
ds.setUrl("jdbc:h2:tcp://localhost/~/test")
ds.setTransactionManager(tm);
那么也将创建一个伪XA的Resouce,与上一节的类似(这种可以在我们做简单的测试的时候使用,或者将一个非xa的资源要被JTA管理的时候使用,但是这个伪XA资源将不能享受到JTA的好处,比如事务的恢复等).