mysql 跨庫事務XA


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

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倍左右

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM