mysql 跨庫事務XA

前一段時間在工做中遇到了跨庫事務問題,後來在網上查詢了一下,如今作一下整理和總結。mysql

1、首先要確保mysql開啓XA事務支持
SHOW VARIABLES LIKE '%XA%'

若是innodb_support_xa的值是ON就說明mysql已經開啓對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'");//準備事務2

try {
    //$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();

?>

XA的性能很低。一個數據庫的事務和多個數據庫間的XA事務性能對比可發現,性能差10倍左右sql

相關文章
相關標籤/搜索