Mysql事务处理（一个转账程序）

1. header("Content-Type:text/html;charset=utf-8");
2. $mysqli=new mysqli("localhost","root","","test");
3. if(mysqli_connect_errno())
4. {
5. printf("连接失败:%s
   ",mysqli_connect_error());
6. exit();
7. }
9. $success=TRUE;
10. $price=8000;
11. $result=$mysqli->query("select cash from account where name='userA'");
12. while($row=$result->fetch_assoc())
13. {
14. $value=$row["cash"];
15. echo $value;
16. }
17. $mysqli->autocommit(0);
18. if($value>=$price){
19. $result=$mysqli->query("UPDATE account set cash=cash-$price where name='userA'");
20. }else {
21. echo '余额不足';
22. exit();
23. }
24. if(!$result or $mysqli->affected_rows!=1)
25. {
26. $success=FALSE;
27. }
29. $result=$mysqli->query("UPDATE account set cash=cash+$price where name='userB'");
30. if(!result or $mysqli->affected_rows!=1){
31. $success=FALSE;
32. }
34. if($success)
35. {
36. $mysqli->commit();
37. echo '转账成功!';
38. }else
39. {
40. $mysqli->rollback();
41. echo "转账失败!";
42. }
43. $mysqli->autocommit(1);
44. $query="select cash from account where name=?";
45. $stmt=$mysqli->prepare($query);
46. $stmt->bind_param('s',$name);
47. $name='userA';
48. $stmt->execute();
49. $stmt->store_result();
50. $stmt->bind_result($cash);
51. while($stmt->fetch())
52. echo "用户userA的值为：".$cash;
54. $mysqli->close();
55. ?>
59. &&&&&&&&&&&&&&&&&&
61. create table account{
62. userID smallint unsigned not null auto_increment,
63. name varchar(45) not null,
64. cash decimal(9,2) not null,
65. primary key(userID)
66. )type=InnoDB;
68. insert into account(name,cash) values ('userA','2000');
69. insert into account(name,cash) values ('userB','10000');

复制代码