php利用事务处理转账问题

这篇文章主要介绍了php利用事务处理转账问题的方法,实例分析了php处理事务的提交与回滚的技巧,需要的朋友可以参考下

本文实例讲述了php+Mysqli利用事务处理转账问题的方法。分享给大家供大家参考

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('数据库连接失败'.$mysqli->connect_error);  
9. }  
10.  
11. $mysqli->autocommit(false); //自动提交模式设为false  
12. $flag = true; //事务是否成功执行的标志  
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 '转账成功';  
31. } else {  
32. $mysqli->rollback();  
33. echo '转账失败';  
34. }  
35.  
36. $mysqli->autocommit(true); //重新设置事务为自动提交  
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);//设置异常处理模式  
6. $pdo->setAttribute(PDO::ATTR_AUTOCOMMIT,0);//关闭自动提交  
7. }catch(PDOException $e){  
8. echo "数据库连接失败";  
9. exit;  
10. }  
11.  
12. try{  
13. $age=10;  
14. $pdo->beginTransaction();//开始事务  
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'");//随意更改使之执行成功或失败  
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("加入错误");  
26. if(!$affected_rows2)  
27. throw new PDOException("减少错误");  
28. echo "操作成功";  
29. $pdo->commit();//如果执行到此处前面两个更新sql语句执行成功，整个事务执行成功  
30. }catch(PDOException $e){  
31. echo "操作失败：".$e->getMessage();  
32. $pdo->rollback();//执行事务中的语句出了问题，整个事务全部撤销  
33. }  
34. $pdo->setAttribute(PDO::ATTR_AUTOCOMMIT,1);  
35. //测试是否成功  
36. echo "/n操作结果为:/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. ?> 

以上所述就是本文的全部内容了，希望大家能够喜欢。