PHP PDO事务处理

前面我们介绍了 MySQL 中的事务处理，其实在 PDO 中也是支持事务的，而且在 PDO 中使用事务很容易。前面我们已经介绍了构建和执行 SQL 语句的方式，当需要使用事务时，只要在执行 SQL 语句前使用 PDO::beginTransaction() 方法来启动事务即可。如果数据库底层驱动不支持事务，则抛出一个 PDOException 异常。事务一旦启动，可以使用 PDO::commit() 方法来提交事务，或者使用 PDO::rollBack() 方法来回滚事务。

PDO::beginTransaction() 方法的作用是启动一个事务；当事务中的所有 SQL 语句全部执行成功后，可以使用 PDO::commit() 方法来结束并提交一个事务；如果事务中某个 SQL 语句执行失败了，那么可以使用 PDO::rollBack() 方法来结束并回滚事务，事务中的所有 SQL 语句都将无效。注意，事务中的 SQL 语句要么全部成功执行，要么根本就不执行。

事务通常是通过把一批要执行的 SQL 语句 积蓄 起来，然后使之同时生效而，这样做的好处就是可以大大地提高这些 SQL 语句的执行的效率。换句话说，事务可以使脚本更快，而且更加健壮。

需要注意的是，并非每种数据库都支持事务，因此当第一次打开连接时，PDO 需要在 自动提交 模式下运行。自动提交模式意味着，如果数据库支持，运行的每个查询都有它自己的隐式事务，如果数据库不支持事务，则没有。

提示：PDO 仅在驱动层检查是否具有事务处理能力。如果某些运行时条件意味着事务不可用，且数据库服务接受请求去启动一个事务，PDO::beginTransaction() 将仍然返回 TRUE 而且没有错误。

当脚本结束或连接即将被关闭时，如果尚有未完成的事务，那么 PDO 将自动回滚这个事务。这种安全措施有可以避免在脚本意外终止时出现数据不一致的情况。也就是说，如果没有显式地提交事务，那么当某个地方出错时，将执行回滚来保证数据安全。

下面通过一个简单示例来演示以下 PDO 中事务的使用。假设有 userA 和 userB 两个银行账户，现在使用 userA 账户向 userB 账号中转账，使用事务来保证 userA 账户中转出一定金额的同时，userB 账户中转入相等的金额。

存放 userA 和 userB 两个账户的数据表的表结构如下所示：

DROP TABLE IF EXISTS `account`;
CREATE TABLE `account`  (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 用户ID ,
  `name` varchar(45) CHARACTER SET utf8 COLLATE utf8_unicode_ci NOT NULL COMMENT 用户名 ,
  `cash` decimal(9, 2) NOT NULL COMMENT 账户余额 ,
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 3 CHARACTER SET = utf8 COLLATE = utf8_unicode_ci ROW_FORMAT = Dynamic;

INSERT INTO `account` VALUES (1, userA , 100000.00);
INSERT INTO `account` VALUES (2, userB , 90000.00);

具体的实现代码如下所示：

 ?php

 $dsn = mysql:dbname=testdb;host=localhost 

 $user = root 

 $password = root 

 $dbh = new PDO($dsn, $user, $password);

 //使用事务之前，要先关闭自动提交。不关闭的话，出现异常的时候没法回滚。

 //据手册描述，ATTR_AUTOCOMMIT 属性只在 mysql、OCI(oracle)、firebird 三种数据库中可用

 $dbh- setAttribute(PDO::ATTR_AUTOCOMMIT, 0);

 $price = 996;

 try {

 $dbh- beginTransaction();

 //用户A账户扣除指定的金额

 $sqlcmd = UPDATE account SET cash=cash-$price WHERE name= userA 

 $affected_rows = $dbh- exec($sqlcmd);

 if ($affected_rows 0) {

 echo 用户A账户扣除成功 . br 

 } else {

 throw new Exception( 用户A账户扣除失败 

 //用户B账户增加指定的金额

 $affected_rows = $dbh- exec( UPDATE account SET cash=cash+$price WHERE name= userB 

 if ($affected_rows 0) {

 echo 用户B账户增加成功 . br 

 } else {

 throw new Exception( 用户B账户增加失败 

 echo 转账成功 

 //若前面两个步骤都成功，则提交事务

 $dbh- commit();

 }catch (PDOException $e) //若前面两个步骤中出现了异常，则回滚

 echo $e- getMessage();

 $dbh- rollback();

 //对事务的使用结束之后，重新开启自动提交

 $dbh- setAttribute(PDO::ATTR_AUTOCOMMIT, 1);

? 

24060.html

mysqlphp