熱點推薦:
您现在的位置: 電腦知識網 >> 編程 >> MySQL >> 正文

用新的PHP插件實現MySQL為基礎的事務

2013-11-23 20:58:59  來源: MySQL 

  事務處理支持很長時間以來一直是大多數MySQL開發者的心願隨著MySQL 的發布這個心願最後終於得以實現MySQL 後不久擁有一個新的MySQL插件的PHP x也發布了這個新插件MySQL Improved使得PHP開發者通過利用本地的PHP函數獲得了這些新的事務處理能力這篇簡短的教程將向你說明怎樣利用這些新的MySQLi函數用PHP實現以MySQL為基礎的事務

  概要

  如果你還不知道那麼我可以告訴你事務只是一組SQL語句通常因為它們是彼此相互依賴的所以要在全有或全無(allornothing)的模式下執行只有當所有組成的語句都執行成功了一個事務才算是成功了任何一個語句中的失敗應該都會導致系統回滾到它先前的狀態以避免數據連接/崩潰問題

  對於這一點兩個銀行帳戶間的轉帳是一個很好的例子在數據庫級這樣的轉帳包括兩個步驟首先從源帳戶中扣除轉帳的金額然後將其加到目標帳戶中如果在第二步中發生了錯誤那麼第一步就必須被取消以避免不相符的情況(和憤怒的客戶聚眾滋事)事務安全系統將自動地撤到系統先前的快照

  大多數數據庫(包括MySQL)通過一個命令的組合來完成這個

  * START TRANSACTION命令標志著一個新的事務組的開始它後面常接一系列的SQL命令

  * COMMIT命令標志著一個事務組的結束表示事務期間做的所有改變應該被提交或者使之永久化

  * ROLLBACK命令標志著一個事務組的結束表示事務期間所做的所有改變應該被撤消

  PHP中的事務處理函數

  PHP中的MySQLi插件引進了新的函數幫助開發者利用MySQL的事務處理能力實質上這些函數對等地被叫做SQL START TRANSACTIONCOMMIT和 ROLLBACK命令列表A為你展示了一個例子

  列表A

  

  // connect to database

  $dbh = mysqli_connect($host, $user, $pass, $db);

  // turn off auto-commit

  mysqli_autocommit($dbh, FALSE);

  // run query 1

  $result = mysqli_query($dbh, $query1);

  if ($result !== TRUE) {

  mysqli_rollback($dbh); // if error, roll back transaction

  }

  // run query 2

  $result = mysqli_query($dbh, $query2);

  if ($result !== TRUE) {

  mysqli_rollback($dbh); // if error, roll back transaction

  }

  // and so on...

  // assuming no errors, commit transaction

  mysqli_commit($dbh);

  // close connection

  mysqli_close($dbh);

  ?>

  在PHP 中執行一項事務有三個基本的步驟:

  * 第一步是始終關掉數據庫的“auto-commit”,它實質上意味著系統在你作出改變時就保存它們。tW.WiNGWiT.Com這一點是很重要的,因為在一個事務處理環境中,你應該只有在確定了所有事務處理的“unit”都成功完成了以後,才保存你所做的改變。你可以通過mysqli_autocommit()函數關掉數據庫的自動提交。

  * 接下來,通過mysqli_query()函數,繼續用通常的方法進行INSERT、UPDATE和/或DELETE查詢。檢驗每一個查詢返回的值,弄清楚它是否成功了是很重要的。如果其中任何一個查詢失敗了,mysqli_rollback()函數就會被用來將系統返回到事務進行之前的狀態。

  * 假設組成事務組的所有命令都成功執行了,就要用mysqli_commit()函數將變化保存到數據庫系統。請注意,一旦這個函數被調用,事務就不能被撤消了。

  工作實例

  要了解這個在實踐中是怎麼工作的,讓我們回到前面討論過的銀行轉帳的例子.我們假設你的任務是建立一個簡單的Web應用程序,讓用戶在他們的銀行帳戶間轉帳。我們再進一步假設一個單獨用戶的帳戶存儲在一個MySQL數據庫中,如下所示:

  mysql> SELECT * FROM accounts;

  +----+------------+---------+

  | id | label | balance |

  +----+------------+---------+

  | 1 | Savings #1 | 1000 |

  | 2 | Current #1 | 2000 |

  | 3 | Current #2 | 3000 |

  +----+------------+---------+

  3 rows in set (0.34 sec)

  現在,需要建立一個簡單的界面,使用戶能夠輸入一個現金數額,實現從一個帳戶到另一個的轉帳。實際的“交易”將用兩個UPDATE語句來執行,一個將轉帳金額從源帳戶取出,即借方,另一個將轉帳金額記入目標帳戶,即貸方。假設我們所做的是在帳戶之間進行轉帳,那麼所有帳戶的可用結余總額($6000)應該一直保持不變。

  列表B顯示了可能的代碼:

  列表 B

  

  // connect to database

  $dbh = mysqli_connect("localhost", "user", "pass", "test") or die("Cannot connect");

  // turn off auto-commit

  mysqli_autocommit($dbh, FALSE);

  // look for a transfer

  if ($_POST['submit'] && is_numeric($_POST['amt'])) {

  // add $$ to target account

  $result = mysqli_query($dbh, "UPDATE accounts SET balance = balance + " . $_POST['amt'] . " WHERE id = " . $_POST['to']);

  if ($result !== TRUE) {

  mysqli_rollback($dbh); // if error, roll back transaction

  }

  // subtract $$ from source account

  $result = mysqli_query($dbh, "UPDATE accounts SET balance = balance - " . $_POST['amt'] . " WHERE id = " . $_POST['from']);

  if ($result !== TRUE) {

  mysqli_rollback($dbh); // if error, roll back transaction

  }

  // assuming no errors, commit transaction

  mysqli_commit($dbh);

  }

  // get account balances

  // save in array, use to generate form

  $result = mysqli_query($dbh, "SELECT * FROM accounts");

  while ($row = mysqli_fetch_assoc($result)) {

  $accounts[] = $row;

  }

  // close connection

  mysqli_close($dbh);

  ?>

  

  

  

  

TRANSFER

  

  Transfer $ from

  

  to

  

  

  

ACCOUNT BALANCES

  

  

  foreach ($accounts as $a) {

  echo "

" . $a['label'] . " " . $a['balance'] . " ";

  }

  ?>

  

  像你所看到的那樣,腳本以連接數據庫和關閉自動提交開始。然後執行一個SELECT查詢,檢索所有帳戶的現金收支,接著構造一個有下拉式界面的表格,選擇交易要用到的來源/目標帳戶。圖表A顯示了最初的表格。

  

  圖表 A

  

  最初的表格

  一旦表格完成並提交後,兩個UPDATE查詢就開始實際執行借和貸操作。注意每一個查詢的尾端都帶有一個mysqli_rollback(),如果查詢失敗的話,它將被激活。假設沒有查詢失敗的話,新的收支表就通過調用mysqli_commit()儲存到數據庫中。那時數據庫連接就被關閉。

  你可以自己試一下,從Savings #1轉$500到Current #2。一旦你執行轉帳之後,你將看到如圖表B所示的平衡表的新結果。

  

  圖表 B

  

  交易完成之後的狀況

  提示:當然,這只是一個簡單的雙命令的事務。通常,當有許多SQL語句要一起執行的時候,你可以用這種事務模型,一個語句的失敗對其他語句有串聯的影響。在這些情況下,你會發現將mysqli_query()mysqli_rollback()的調用壓縮到一個單獨的用戶自定義的函數中,需要的時候調用它會更加簡便。

  正如你所看到的那樣,用PHP和MySQL執行一個事務處理模型可以使你的MySQL數據庫對查詢執行的錯誤更穩固。但是,在你開始動手重寫代碼和使用這個模型之前,值得注意的是,事務確實會增加系統性能管理的消耗,所以,在實現這個模型之前,做一個成本效益分析始終是個好主意。


From:http://tw.wingwit.com/Article/program/MySQL/201311/29388.html
    推薦文章
    Copyright © 2005-2013 電腦知識網 Computer Knowledge   All rights reserved.