mysql跨庫事務(wù)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事務(wù)指定一個(gè)id，xid 必須是一個(gè)唯一值。
$xid = uniqid("");
//兩個(gè)庫指定同一個(gè)事務(wù)id，表明這兩個(gè)庫的操作處于同一事務(wù)中
$dbtest1->query("XA START '$xid'");//準(zhǔn)備事務(wù)1
$dbtest2->query("XA START '$xid'");//準(zhǔn)備事務(wù)2
try {
  //$dbtest1
  $return = $dbtest1->query("UPDATE member SET name='唐大麥' WHERE id=1") ;
  if($return == false) {
    throw new Exception("庫dbtest1@172.20.101.17執(zhí)行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執(zhí)行update memberpoints操作失?。?);
  }
  //階段1：$dbtest1提交準(zhǔn)備就緒
  $dbtest1->query("XA END '$xid'");
  $dbtest1->query("XA PREPARE '$xid'");
  //階段1：$dbtest2提交準(zhǔn)備就緒
  $dbtest2->query("XA END '$xid'");
  $dbtest2->query("XA PREPARE '$xid'");
  //階段2：提交兩個(gè)庫
  $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();
?>