php + mysql 分佈式事務

事務(Transaction)是訪問並可能更新數據庫中各類數據項的一個程序執行單元；

事務應該具備4個屬性：原子性、一致性、隔離性、持續性

原子性（atomicity）。一個事務是一個不可分割的工做單位，事務中包括的諸操做要麼都作，要麼都不作。 
一致性（consistency）。事務必須是使數據庫從一個一致性狀態變到另外一個一致性狀態。一致性與原子性是密切相關的。

隔離性（isolation）。一個事務的執行不能被其餘事務干擾。即一個事務內部的操做及使用的數據對併發的其餘事務是隔離的，併發執行的各個事務之間不能互相干擾。 
持久性（durability）。持續性也稱永久性（permanence），指一個事務一旦提交，它對數據庫中數據的改變就應該是永久性的。接下來的其餘操做或故障不該該對其有任何影響。

分佈式事務：分佈式事務的參與者、資源管理器、事務管理器等位於不用的節點上，這些不一樣的節點相互協做共同完成一個具備邏輯完整性的事務。

糾正本身對mysql的一個誤解，mysql從5.0開始支持XA DataSource。Connector/J 版本要使用5.0版本，5.0如下的不支持。

　　XA協議由Tuxedo首先提出的，並交給X/Open組織，做爲資源管理器（數據庫）與事務管理器的接口標準。目前，Oracle、Informix、DB2和Sybase等各大數據庫廠家都提供對XA的支持。XA協議採用兩階段提交方式來管理分佈式事務。XA接口提供資源管理器與事務管理器之間進行通訊的標準接口。XA協議包括兩套函數，以xa_開頭的及以ax_開頭的。 
　　如下的函數使事務管理器能夠對資源管理器進行的操做： 
　　1）xa_open,xa_close：創建和關閉與資源管理器的鏈接。 
　　2）xa_start,xa_end：開始和結束一個本地事務。 
　　3）xa_prepare,xa_commit,xa_rollback：預提交、提交和回滾一個本地事務。 
　　4）xa_recover：回滾一個已進行預提交的事務。 
　　5）ax_開頭的函數使資源管理器能夠動態地在事務管理器中進行註冊，並能夠對XID(TRANSACTION IDS)進行操做。 
　　6）ax_reg,ax_unreg；容許一個資源管理器在一個TMS(TRANSACTION MANAGER SERVER)中動態註冊或撤消註冊。

MySQL XA分爲兩類，內部XA與外部XA;內部XA用於同一實例下跨多個引擎的事務，由你們熟悉的Binlog做爲協調者;外部XA用於跨多MySQL實例的分 布式事務，須要應用層介入做爲協調者(崩潰時的懸掛事務，全局提交仍是回滾，須要由應用層決定，對應用層的實現要求較高);

　Binlog做爲內部XA的協調者，在binlog中出現的內部xid，在crash recover時，由binlog負責提交。(這是由於，binlog不進行prepare， 只進行commit，所以在binlog中出現的內部xid，必定可以保證其在底層各存儲引擎中已經完成prepare)。

MySQL數據庫外部XA能夠用在分佈式數據庫代理層，實現對MySQL數據庫的分佈式事務支持，例如開源的代理工具：網易的DDB，淘寶的TDDL，B2B的Cobar等等。

示例

 1 public function testAction(){
 2         $goods_id=1;
 3         $goods_name = "大西瓜";
 4         $num = 1;
 5         $rs_order = $this->test->createorder($goods_id,$goods_name,$num);
 6         $rs_goods = $this->test->deduction($goods_id,$num);
 7         if($rs_order['status'] =="success" && $rs_goods['status']=="success"){
 8             $this->test->commitdb($rs_order['XA']);
 9             $this->test->commitdb1($rs_goods['XA']);
10         }else{
11             $this->test->rollbackdb($rs_order['XA']);
12             $this->test->rollbackdb1($rs_goods['XA']);
13         }
14 
15         print_r($rs_order);
16         echo "<br />";
17         print_r($rs_goods);
18         die("dddd");
19     }
20     public function createorder($goods_id,$goods_name,$num){
21         $XA = uniqid("");
22         $this->_db->query("XA START '$XA'");
23         $_rs = true;
24         try {
25             $data = array();
26             $data['order_id'] = "V".date("YmdHis");
27             $data['goods_name'] = $goods_name;
28             $data['goods_num'] = $num;
29             $this->_db->insert("temp_orders",$data);
30             $rs =  $this->_db->lastInsertId();
31             if($rs){
32                 $_rs = true;
33             }else{
34                 $_rs = false;
35             }
36         } catch (Exception $e) {
37             $_rs = false;
38         }
39         $this->_db->query("XA END '$XA'");
40          if($_rs){
41                  $this->_db->query("XA PREPARE '$XA'");
42                  return array("status"=>"success","XA"=>$XA);
43          }else{
44                  return array("status"=>"nosuccess","XA"=>$XA);
45          }
46     }
47      public function deduction($id){
48         $XA = uniqid("");
49         $this->db1->query("XA START '$XA'");
50         $last_rs = true;
51         try {
52                 $sql = "select * from temp_goods where id = '$id' and goods_num>0";
53                 $rs = $this->db1->fetchRow($sql);
54                 if(!empty($rs)){
55                     $sql = "update temp_goods set goods_num = goods_num-1 where id = '$id'";
56                     $rd = $this->db1->query($sql);
57                     if($rd){
58                         $last_rs = true;
59                     }else{
60                         $last_rs = false;
61                     }
62                 }else{
63                         $last_rs = false;;
64                 }
65         } catch (Exception $e) {
66              $last_rs = false;;
67         }
68          $this->db1->query("XA END '$XA'");
69          if($last_rs){
70                  $this->db1->query("XA PREPARE '$XA'");
71                  return array("status"=>"success","XA"=>$XA);
72          }else{
73                  return array("status"=>"nosuccess","XA"=>$XA);
74          }
75 
76     }
77     //提交事務！
78     public function commitdb($xa){
79         return $this->_db->query("XA COMMIT '$xa'");
80     }
81 
82     //回滾事務
83     public function rollbackdb($xa){
84         return $this->_db->query("XA ROLLBACK '$xa'");
85     }
86 
87     //提交事務！
88     public function commitdb1($xa){
89         return $this->db1->query("XA COMMIT '$xa'");
90     }
91      //回滾事務
92     public function rollbackdb1($xa){
93         return $this->db1->query("XA ROLLBACK '$xa'");
94     }