mysql跨库事务XA操作示例

SHOW VARIABLES LIKE '%XA%'

SET innodb_support_xa = ON

<?PHP$dbtest1 = new mysqli("172.20.101.17","public","public","dbtest1")or die("dbtest1 连接失败");$dbtest2   = new mysqli("172.20.101.18","public","public","dbtest2")or die("dbtest2 连接失败");//为XA事务指定一个id，xid 必须是一个唯一值。$xid = uniqid("");//两个库指定同一个事务id，表明这两个库的操作处于同一事务中$dbtest1->query("XA START '$xid'");//准备事务1$dbtest2->query("XA START '$xid'");//准备事务2try {  //$dbtest1  $return = $dbtest1->query("UPDATE member SET name='唐大麦' WHERE id=1") ;  if($return == false) {    throw new Exception("库dbtest1@172.20.101.17执行update member操作失败！");  }  //$dbtest2  $return = $dbtest2->query("UPDATE memberpoints SET point=point+10 WHERE memberid=1") ;  if($return == false) {    throw new Exception("库dbtest1@172.20.101.18执行update memberpoints操作失败！");  }  //阶段1：$dbtest1提交准备就绪  $dbtest1->query("XA END '$xid'");  $dbtest1->query("XA PREPARE '$xid'");  //阶段1：$dbtest2提交准备就绪  $dbtest2->query("XA END '$xid'");  $dbtest2->query("XA PREPARE '$xid'");  //阶段2：提交两个库  $dbtest1->query("XA COMMIT '$xid'");  $dbtest2->query("XA COMMIT '$xid'");}catch (Exception $e) {  //阶段2：回滚  $dbtest1->query("XA ROLLBACK '$xid'");  $dbtest2->query("XA ROLLBACK '$xid'");  die($e->getMessage());}$dbtest1->close();$dbtest2->close();?>