文档章节

JTA 三 (XADataSource)

 独行侠
发布于 2016/04/14 16:11
字数 496
阅读 31
收藏 0

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


© 著作权归作者所有

共有 人打赏支持
粉丝 1
博文 19
码字总数 9797
作品 0
成都
【分布式事务系列】提出疑问和研究过程

分布式事务 【分布式事务系列】提出疑问和研究过程 对于我们这种初学者,可能会使用Spring带给我们的@Transactional,可能了解JTA,可能会使用jotm、atomikos,又会遇到一些名词XA,支持XA的...

陶邦仁
2015/12/09
418
0
Java分布式事务概念与实现示例

在java中有如下三种事务, 简单的JDBC级的事务 JTA - 在EJB环境下,用户得到事务并进行控制CMP - 完全由容器控制事务,用户通过Bean配置文件来定义事务行为 二三种都支持分布式事务,但只支持...

职通网
2011/04/28
0
3
深入Java 事务的原理与应用

一、什么是JAVA事务 通常的观念认为,事务仅与数据库相关。 事务必须服从ISO/IEC所制定的ACID原则。ACID是原子性(atomicity)、一致性(consistency)、隔离性 (isolation)和持久性(dur...

wf王帆
2016/06/01
12
0
分布式事务系列(开篇)提出疑问和研究过程

1 前言 系列目录 - 分布式事务系列(开篇)提出疑问和研究过程- 分布式事务系列(1.1)Spring事务管理器PlatformTransactionManager源码分析- 分布式事务系列(1.2)Spring事务体系- 分布式事...

乒乓狂魔
2015/05/12
0
6
Spring-boot Mybatis多数据源事务配置

使用Atomikos需要可以包含 spring-boot-starter-jta-atomikos 依赖 接下来配置两个数据源 配置信息如下: Java Properties 然后要配置数据源, 需要用XADataSource 第二个数据源配置差不多 不贴...

ForeverX
2016/05/16
5K
1

没有更多内容

加载失败,请刷新页面

加载更多

linux运维人员必会运维工具

linux运维人员必会开源运维工具体系 说明:不同的技术人员,不同的阶段确定知识边界非常重要,否则,就像马拉车,不知道终点在哪,累死也达不到目标。例如拿8K要学多少,拿15K要学多少。一个...

寰宇01
5分钟前
1
0
10大PHP比特币开源项目

如果你是一个Phper,如果你希望学习区块链,那么本文列出的 10个开源的Php比特币项目,将有助于你了解在自己的应用中 如何加入对比特币的支持。 如果你希望快速掌握使用Php对接比特币钱包的方...

汇智网教程
25分钟前
0
0
springclould feign客户端添加全局参数

用springclould feign作为调用服务的客户端,一般来说参数可以写在feignclient的方法参数里 有时需要所有feign请求都统一添加一些参数,例如token用于鉴权等,可以这样做: 添加一个配置类,...

canneljls
26分钟前
0
0
win32截屏并rgb24转yuv420

//最终f的内存布局为BGRA格式,需要保证buf长度足够(>w*h*4)void ScreenCap(void* buf, int w, int h){ HWND hDesk = GetDesktopWindow(); HDC hScreen = GetDC(hDesk); ......

styleman
今天
1
0
php输出mysql取出的中文为??的问题

解决方法: @ $db=new mysqli(DB_HOST,DB_USER,DB_PASSWORD,DB_DB); $db->query("set names utf8");//添加此语句,可以解决问题...

Aomo
今天
1
2

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部