MySQL クロスデータベーストランザクション XA 操作の例

'%XA%' のような変数を表示

innodb_support_xa を ON に設定する

<?PHP
$dbtest1 = new mysqli("172.20.101.17","public","public","dbtest1")またはdie("dbtest1接続に失敗しました");
$dbtest2 = new mysqli("172.20.101.18","public","public","dbtest2")またはdie("dbtest2接続に失敗しました");
//XA トランザクションの ID を指定します。xid は一意の値である必要があります。
$xid = uniqid("");
// 2 つのデータベースは同じトランザクション ID を指定しており、2 つのデータベースの操作が同じトランザクション内にあることを示しています $dbtest1->query("XA START '$xid'"); // トランザクション 1 を準備します
$dbtest2->query("XA START '$xid'"); //トランザクション2を準備する
試す {
  //$dbtest1
  $return = $dbtest1->query("UPDATE member SET name='唐大麦' WHERE id=1");
  戻り値が偽の場合
    throw new Exception("ライブラリ [email protected] でメンバー更新操作が失敗しました!");
  }
  //$dbtest2
  $return = $dbtest2->query("UPDATE memberpoints SET point=point+10 WHERE memberid=1");
  戻り値が偽の場合
    throw new Exception("データベース [email protected] でメンバーポイントの更新操作が失敗しました!");
  }
  //フェーズ 1: $dbtest1 は送信する準備ができています $dbtest1->query("XA END '$xid'");
  $dbtest1->クエリ("XA PREPARE '$xid'");
  //フェーズ 1: $dbtest2 は送信する準備ができています $dbtest2->query("XA END '$xid'");
  $dbtest2->query("XA PREPARE '$xid'");
  //フェーズ 2: 2 つのデータベースを送信します $dbtest1->query("XA COMMIT '$xid'");
  $dbtest2->query("XA COMMIT '$xid'");
}
キャッチ（例外$e）{
  //フェーズ 2: ロールバック $dbtest1->query("XA ROLLBACK '$xid'");
  $dbtest2->query("XA ROLLBACK '$xid'");
  die($e->getMessage());
}
$dbtest1->閉じる();
$dbtest2->close();
?>