View difference between Paste ID: rkv9N7SQ and uW4hDbvM

 <?php
 /**
 
   Нужно поднять 2 инстанса базы и в обоих создать базу:
 
   create table some_table (id int(10) NOT NULL AUTO_INCREMENT, `field` varchar(255) not null, `value` varchar(255), PRIMARY KEY (`id`)) type = InnoDB;
 
   Запускаем скрипт, скрипт останавливается ожидая ввода пользователя. останавливаем один сервер, нажимаем Enter (2 раза)
 
  */
 
 
 function waitUser() {
   echo "Sleep. Press enter...\n";
   $line = trim(fgets(STDIN));
   fscanf(STDIN, "\n");
   echo "Done. Commiting.\n";
 }
 
 class MysqlConnect
 {
 
   protected $link = null;
   protected $host = null;
 
   public function __construct($host, $database, $username, $password)
   {
     $this->host = $host;
     $this->link = mysql_connect($host, $username, $password, true);
     mysql_select_db($database, $this->link);
   }
 
   private function log($message) {
     echo "[{$this->host}] {$message}\n";
   }
 
   public function query($query)
   {
     $this->log($query);
     $res = mysql_query($query, $this->link) or $this->log("ERROR: " . mysql_error());
 
     return $res;
   }
 
   public function fetchAll($query)
   {
     $res = $this->query($query);
 
     $result = array();
     while ($row = mysql_fetch_assoc($res)) {
       $result[] = $row;
     }
     return $res;
   }
 
   public function insert($table, $data)
   {
     if (!count($data))
       return false;
 
     list($row) = $data;
     $cols = array();
     foreach ($row as $key => $value) {
       $cols[] = $key;
     }
     $cols = implode(", ", $cols);
 
     $values = array();
     foreach ($data as $row) {
       $values[] = "'" . implode("', '", $row) . "'";
     }
 
     $values = "(" . implode("), (", $values) . ")";
 
     $query = "INSERT INTO `{$table}` ($cols) VALUES {$values}";
 
     $this->query($query);
   }
 }
 
 class ConnectManager
 {
   protected $connections = array();
   protected $firstConnection = null;
 
   protected $lastTxId = null;
 
   public function __construct($connections)
   {
     $this->connections = $connections;
     $this->firstConnection = array_shift($connections);
   }
 
   public function query($query)
   {
     foreach ($this->connections as $connection) {
       $connection->query($query);
     }
   }
 
   public function fetchAll($query)
   {
     foreach ($this->connections as $connection) {
       $connection->fetchAll($query);
     }
   }
 
   public function insert($table, $data)
   {
     foreach ($this->connections as $connection) {
       $connection->insert($table, $data);
     }
   }
 
   protected function getTxIdent()
   {
     return uniqid("tx-", true);
   }
 
   public function txBegin()
   {
     $tid = $this->getTxIdent();
     $this->lastTxId = $tid;
     foreach ($this->connections as $connection) {
       $connection->query("XA START '{$tid}'");
     }
   }
 
   public function txCommit()
   {
     $tid = $this->lastTxId;
     foreach ($this->connections as $connection) {
 //    $connection = $this->firstConnection;
       $connection->query("XA END '{$tid}'");
       $connection->query("XA PREPARE '{$tid}'");
     }
 
     waitUser();
 
     foreach ($this->connections as $connection) {
       $connection->query("XA COMMIT '{$tid}'");
     }
   }
 
   public function txRollback()
   {
     $tid = $this->lastTxId;
     foreach ($this->connections as $connection) {
       $connection->query("XA END '{$tid}'");
       $connection->query("XA RALLBACK '{$tid}'");
     }
   }
 
 }
 
 $int = rand(0, 999);
 echo "LAST INT: {$int}\n";
 
 $c1 = new MysqlConnect("localhost", "xa_test", "user", "password");
 $c2 = new MysqlConnect("192.168.56.10", "xa_test", "user", "password");
 
 $man = new ConnectManager(array($c1, $c2));
 $man->txBegin();
 
 $i = $int;
 $c1->insert("some_table", array(array("field" => "field {$i}", "value" => rand(0, 999))));
 $c2->insert("some_table", array(array("field" => "field {$i}", "value" => rand(0, 999))));
 
 $man->txCommit();