pdo 事务

pdo 事务

2. //pdo 实现mysql 事务处理 简单示例
3. /*
4. 实现向数据库中写入多条数据的事务
5. insert into test values ('test123', 'test123')
6. */
8. $type = 'mysql'; //要连接的数据库类型
9. $host = 'localhost'; //数据库主机
10. $dbname = 'test'; //要选择的数据库名称
11. $password = '';
12. $username = 'root';
14. $dsn = "{$type}:dbname={$dbname};host={$host}";
16. try{
18. //连接数据库
19. $pdo = new PDO($dsn, $username, $password);
21. //编码
22. $pdo->exec("set names utf8");
24. //设置错误提示方式
25. $pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
27. //开启标准事务
28. $pdo->beginTransaction();
30. //构造sql语句
31. //$sql = "insert into test values (?,?)";
32. $sql = "insert into test values (:user, :password)";
33. //或者使用此sql语句 :user :password 与问号功能相似 绑定参数
35. $stmt = $pdo->prepare($sql);
37. //为sql语句中的变量绑定变量
38. $stmt->bindParam(':user', $username);
39. $stmt->bindParam(':password', $password);
41. //为sql语句中的变量 赋值
42. $username = 'test123';
43. $password = '123456';
45. $stmt->execute();
47. $rows = $stmt->rowCount();
49. if($rows //如果失败则抛出异常
50. throw new PDOexception('第一句sql语句执行失败！', '01');
52. }
55. $username = 'hello123';
56. $password = '123456';
58. $stmt->execute();
60. $rows = $stmt->rowCount();
62. if($rows //如果失败则抛出异常
63. throw new PDOexception('第二句sql语句执行失败！', '02');
65. }
68. $username = 'world123';
69. $password = '123456';
71. $stmt->execute();
73. $rows = $stmt->rowCount();
75. if($rows //如果失败则抛出异常
76. throw new PDOexception('第三句sql语句执行失败！', '02');
78. }
80. //如果没有异常被抛出则 sql语句全部执行成功 提交事务
81. $pdo->commit();
84. }catch(PDOexception $e){
86. //如果有异常被抛出 则事务失败 执行事务回滚
87. $pdo->rollback();
89. //输出异常信息
90. echo $e->getCode().'-----'.$e->getMessage();
92. $pdo = null;
94. }
97. ?>

复制代码