假定在MySQL实例1上有表

create table person(

id int,

name varchar(32)

)

MySQL实例2上也有一张同样的表，现在从实例1中的 person 表中删除一条数据，并把这条数据插入到实例2的表中，这两个操作在同一个事务中，因为跨越了数据库实例，涉及到了分布式事务。

MySQL实现了分布式事务，查看数据库是否启用了 XA 事务：

show variables like 'innodb_support_xa';

MySQL 关于xa的命令：

xa start 'a';

sql 语句;

xa end 'a';

xa prepare 'a';

xa commit 'a';

与正常事务相比，XA 命令多了 prepare，询问是否准备好，事务管理器根据 prepare 返回的结果进行操作。

以上命令是分布式事务的操作方法，在一个命令行中输入上述命令，并不是真实的分布式事务。可以使用 JTA 来控制MySQL的 XA：

public class JTA_MySQL {

public static void main(String[] args) {

XADataSource xaDs1 = JTA_MySQL.getDataSource(

"jdbc:mysql://172.30.60.126:3306/db_zhang", "root",

"root");

XAConnection xaCon1 = null;

XAResource xaRes1 = null;

Connection conn1 = null;

Statement stmt1 = null;

XADataSource xaDs2 = JTA_MySQL.getDataSource(

"jdbc:mysql://172.30.60.124:3306/db_zhang", "root",

"root");

XAConnection xaCon2 = null;

XAResource xaRes2 = null;

Connection conn2 = null;

Statement stmt2 = null;

int ret1 = 0;

int ret2 = 0;

Xid xid1 = new MyXid(100, new byte[] { 0x01 }, new byte[] { 0x02 });

Xid xid2 = new MyXid(100, new byte[] { 0x01 }, new byte[] { 0x03 });

try {

xaCon1 = getXAConnetion(xaDs1);

conn1 = getConnection(xaCon1);

stmt1 = conn1.createStatement();

xaRes1 = xaCon1.getXAResource();

xaCon2 = getXAConnetion(xaDs2);

conn2 = getConnection(xaCon2);

stmt2 = conn2.createStatement();

xaRes2 = xaCon2.getXAResource();

xaRes1.start(xid1, XAResource.TMNOFLAGS);

stmt1.execute("delete from person where id=1");

xaRes1.end(xid1, XAResource.TMSUCCESS);

xaRes2.start(xid2, XAResource.TMNOFLAGS);

stmt2.execute("insert into person select 1, 'zhang'");

xaRes2.end(xid2, XAResource.TMSUCCESS);

ret1 = xaRes1.prepare(xid1);

ret2 = xaRes2.prepare(xid2);

if (XAResource.XA_OK == ret1 && XAResource.XA_OK == ret2) {

xaRes1.commit(xid1, false);

xaRes2.commit(xid2, false);

System.out.println("提交分布式事务");

} else {

xaRes1.rollback(xid1);

xaRes2.rollback(xid2);

System.out.println("回退分布式事务");

}

} catch (SQLException e) {

e.printStackTrace();

} catch (XAException e) {

e.printStackTrace();

}

}

private static XADataSource getDataSource(String url, String user,

String password) {

MysqlXADataSource dataSource = new MysqlXADataSource();

dataSource.setUrl(url);

dataSource.setUser(user);

dataSource.setPassword(password);

return dataSource;

}

public static XAConnection getXAConnetion(XADataSource dataSource) {

XAConnection XAConn = null;

try {

XAConn = dataSource.getXAConnection();

} catch (SQLException e) {

e.printStackTrace();

}

return XAConn;

}

public static Connection getConnection(XAConnection XAConn) {

Connection conn = null;

try {

conn = XAConn.getConnection();

} catch (SQLException e) {

e.printStackTrace();

}

return conn;

}

public static void closeConnection(Connection conn) {

try {

conn.close();

} catch (SQLException e) {

System.out.println("连接关闭失败");

}

}

}

MyXid 类：

public class MyXid implements Xid {

private int formatId;

private byte[] globalTid;

private byte[] branchQ;

public MyXid(int formatId, byte[] globalTid, byte[] branchQ) {

this.formatId = formatId;

this.globalTid = globalTid;

this.branchQ = branchQ;

}

public byte[] getBranchQualifier() {

return this.branchQ;

}

public int getFormatId() {

return formatId;

}

public byte[] getGlobalTransactionId() {

return this.globalTid;

}

}

Mysql分布式事务

关于Mysql分布式事务介绍,可参考:http://blog.csdn.net/luckyjiuyi/article/details/46955337 分为两个阶段:准备和执行阶段.有两个角色:事务的 ...

mysql 分布式事务

php + mysql 分布式事务 事务(Transaction)是访问并可能更新数据库中各种数据项的一个程序执行单元: 事务应该具有4个属性:原子性.一致性.隔离性.持续性 原子性(atomicit ...

详解Mysql分布式事务XA(跨数据库事务)

详解Mysql分布式事务XA(跨数据库事务) 学习了:http://blog.csdn.net/soonfly/article/details/70677138 mysql执行XA事物的时候,mysq ...

Spring+JTA+Atomikos+mybatis分布式事务管理

我们平时的工作中用到的Spring事务管理是管理一个数据源的.但是如果对多个数据源进行事务管理该怎么办呢?我们可以用JTA和Atomikos结合Spring来实现一个分布式事务管理的功能.了解JTA可 ...

php + mysql 分布式事务(转)

事务(Transaction)是访问并可能更新数据库中各种数据项的一个程序执行单元: 事务应该具有4个属性:原子性.一致性.隔离性.持续性 原子性(atomicity).一个事务是一个不可分割的工作单 ...

php + mysql 分布式事务

事务(Transaction)是访问并可能更新数据库中各种数据项的一个程序执行单元: 事务应该具有4个属性:原子性.一致性.隔离性.持续性 原子性(atomicity).一个事务是一个不可分割的工作单 ...

了解一下Mysql分布式事务及优缺点、使用案例(php+mysql)

在开发中,为了降低单点压力,通常会根据业务情况进行分表分库,将表分布在不同的库中(库可能分布在不同的机器上),但是一个业务场景可能会同时处理两个表的操作.在这种场景下,事务的提交会变得相对复杂,因为多 ...

分布式事务(三)mysql对XA协议的支持

系列目录 分布式事务(一)原理概览 分布式事务(二)JTA规范 分布式事务(三)mysql对XA协议的支持 分布式事务(四)简单样例 分布式事务(五)源码详解 分布式事务(六)总结提高 引子 从Mys ...

【分布式事务】使用atomikos+jta解决分布式事务问题

一.前言 分布式事务,这个问题困惑了小编很久,在3个月之前,就间断性的研究分布式事务.从MQ方面,数据库事务方面,jta方面.近期终于成功了,使用JTA解决了分布式事务问题.先写一下心得,后面的二级提 ...

随机推荐

Javascript的自执行函数

自执行函数其实也就是"立即执行的函数",它有四个特点:提高性能.利于压缩.避免冲突.依赖加载: 1.减少作用域查找 JS代码: // Anonymous function that ...

转载~kxcfzyk：Linux C语言多线程库Pthread中条件变量的的正确用法逐步详解

Linux C语言多线程库Pthread中条件变量的的正确用法逐步详解   多线程c语言linuxsemaphore条件变量 (本文的读者定位是了解Pthread常用多线程API和Pthread互斥锁 ...

RPM 包下载 GCC 4.8安装

http://ftp.scientificlinux.org/linux/scientific/ http://www.rpmfind.net/linux/rpm2html/search.php?qu ...

【MVC】ASP.NET MVC中实现多个按钮提交的几种方法

有时候会遇到这种情况:在一个表单上需要多个按钮来完成不同的功能,比如一个简单的审批功能. 如果是用webform那不需要讨论,但asp.net mvc中一个表单只能提交到一个Action处理,相对比较 ...

S3C2440 TFTLCD驱动详解

S3C2440自带有LCD控制器,该控制器主要有以下接口 仅仅说TFT显示器,TFT显示器的时序如下 TFT显示器的驱动是以行列的形式逐点扫描过来的,驱动时钟有三种,一种是行时钟,一种是列时钟,还有一 ...

C# IE浏览器

引用Microsoft HTML Object Library 引用 -> com -> Microsoft HTML Object Library 引用后,显示如图 1.判断ie浏览器是 ...

win8.1 AMD 屏幕亮度无法调整

lenovo z465  AMD处理器. win8.1 pro系统   屏幕亮度无法调整解决办法:   1:当然是先去本地服务里禁用"Sensor Monitoring Service&qu ...

Java笔记(三)异常

异常 一.概念 一)为什么会有Java异常机制 在没有Java异常机制的情况下,唯一的退出机制就是返回值,判断是否异常的方法就是 返回值.方法根据是否异常返回不同的返回值,调用者根据不同的返回值进行判 ...

SQLite在Android程序中的使用方法，SQLite的增删查改方法

Sqlite: 1.一款用来实现本地数据存储的轻量级数据管理工具,是众多用来实现数据库管理的工具之一. 2.Android已经将SQLite的代码功能吸收在它的系统中,我们可以直接在Android程序 ...