JTA 三 (XADataSource)

前一节中，我们是使用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的好处，比如事务的恢复等).