這篇文章主要介紹了php利用事務(wù)處理轉(zhuǎn)賬問題的方法,實(shí)例分析了php處理事務(wù)的提交與回滾的技巧,需要的朋友可以參考下

本文實(shí)例講述了php+Mysqli利用事務(wù)處理轉(zhuǎn)賬問題的方法。分享給大家供大家參考

1. <?php  
2. header("Content-type:text/html; charset=utf-8");  
3.  
4. $mysqli = new mysqli("localhost", "root", "064319", "php");  
5. $mysqli->set_charset("utf8");  
6.  
7. if($mysqli->connect_errno) {  
8. die('數(shù)據(jù)庫連接失敗'.$mysqli->connect_error);  
9. }  
10.  
11. $mysqli->autocommit(false); //自動(dòng)提交模式設(shè)為false  
12. $flag = true; //事務(wù)是否成功執(zhí)行的標(biāo)志  
13.  
14. $query = "update account set balance=balance-1000 where id=3";  
15. $result = $mysqli->query($query);  
16. $affected_count = $mysqli->affected_rows;  
17. if(!result || $affected_count == 0) { //失敗  
18. $flag = false;  
19. }  
20.  
21. $query = "update account set balance=balance+1000 where id=2";  
22. $result = $mysqli->query($query);  
23. $affected_count = $mysqli->affected_rows;  
24. if(!$result || $affected_count == 0) {  
25. $flag = false;  
26. }  
27.  
28. if($flag) {  
29. $mysqli->commit();  
30. echo '轉(zhuǎn)賬成功';  
31. } else {  
32. $mysqli->rollback();  
33. echo '轉(zhuǎn)賬失敗';  
34. }  
35.  
36. $mysqli->autocommit(true); //重新設(shè)置事務(wù)為自動(dòng)提交  
37. $mysqli->close();  
38. ?> 

代碼二：

1. <?php  
2. try{  
3. $pdo=new PDO("mysql:host=localhost;dbname=psp","root","");  
4. $pdo->exec("set names utf8");  
5. $pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);//設(shè)置異常處理模式  
6. $pdo->setAttribute(PDO::ATTR_AUTOCOMMIT,0);//關(guān)閉自動(dòng)提交  
7. }catch(PDOException $e){  
8. echo "數(shù)據(jù)庫連接失敗";  
9. exit;  
10. }  
11.  
12. try{  
13. $age=10;  
14. $pdo->beginTransaction();//開始事務(wù)  
15. $affected_rows1=$pdo->exec("update kfry set k_age=k_age+{$age} where k_name='user1'");  
16. $affected_rows2=$pdo->exec("update kfry set k_age=k_age-{$age} where k_name='user2'");//隨意更改使之執(zhí)行成功或失敗  
17. /* if($affected_rows1&&$affected_rows2)  
18. {  
19. $pdo->commit();  
20. echo "操作成功";  
21. }else{  
22. $pdo->rollback();  
23. } */ 
24. if(!$affected_rows1)  
25. throw new PDOException("加入錯(cuò)誤");  
26. if(!$affected_rows2)  
27. throw new PDOException("減少錯(cuò)誤");  
28. echo "操作成功";  
29. $pdo->commit();//如果執(zhí)行到此處前面兩個(gè)更新sql語句執(zhí)行成功，整個(gè)事務(wù)執(zhí)行成功  
30. }catch(PDOException $e){  
31. echo "操作失敗：".$e->getMessage();  
32. $pdo->rollback();//執(zhí)行事務(wù)中的語句出了問題，整個(gè)事務(wù)全部撤銷  
33. }  
34. $pdo->setAttribute(PDO::ATTR_AUTOCOMMIT,1);  
35. //測試是否成功  
36. echo "/n操作結(jié)果為:/n";  
37. $sql="select * from kfry";  
38. $result=$pdo->query($sql);  
39. foreach($result as $v)  
40. {  
41. echo $v['k_name']." ".$v['k_age']."/n";  
42. }  
43. ?> 

以上所述就是本文的全部內(nèi)容了，希望大家能夠喜歡。