1. <?php
2. header(‘content-type:text/html;charset=utf-8‘);
3. try{
4. //最後是關閉自動提交
5. $pdo=new pdo("mysql:host=127.0.0.1;dbname=exam", "root", "root");
6. //這個是通過設置屬性方法進行關閉自動提交
7. $pdo->setAttribute(PDO::ATTR_AUTOCOMMIT, 0);
8. //開啟異常處理
9. $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
10. }
11. catch(PDOException $e){
12. echo "數據庫連接失敗：".$e->getMessage();
13. exit;
14. }
15. /*
16. * 事務處理
17. *
18. * 張三從李四那裏買了一臺 2000 元的電腦
19. * 從張三帳號中扣出 2000元
20. * 向李四賬號中加入 2000元
21. * 從商品表中減少一臺電腦
22. * MyIsAM InnoDB
23. */
24. try{
25. $pdo->beginTransaction();//開啟事務處理
26. $price=500;
27. $sql="update goods set good_price=good_price-{$price} where id=3";
28. $affected_rows=$pdo->exec($sql);
29. if(!$affected_rows)
30. throw new PDOException("張三轉出失敗");//那個錯誤拋出異常
31. $sql="update goods set good_price=good_price+{$price} where id=1";
32. $affected_rows=$pdo->exec($sql);
33. if(!$affected_rows)
34. throw new PDOException("向李四轉入失敗");
35. echo "交易成功！";
36. $pdo->commit();//交易成功就提交
37. }
38. catch(PDOException $e){
39. echo $e->getMessage();
40. $pdo->rollback();
41. }
42. //自動提交，如果最後不自動提交，轉賬是不成功的
43. $pdo->setAttribute(PDO::ATTR_AUTOCOMMIT, 1);
44. //設置錯誤報告模式 ERRMODE_SILENT ERRMODE_WARNING

PDO 事務處理