前一段時間在工作中遇到了跨庫事務問題,后來在網上查詢了一下,現在做一下整理和總結。
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倍左右