PHP 使用PDO进行数据库事务
示例
数据库事务确保只有在每条语句成功后，一组数据更改才会被永久保留。可以捕获事务期间发生的任何查询或代码故障，然后您可以选择回滚尝试的更改。
PDO提供了用于开始，提交和回滚事务的简单方法。
$pdo = new PDO(
$dsn,
$username,
$password,
array(PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION)
);
try {
$statement = $pdo->prepare("UPDATE user SET name = :name");
$pdo->beginTransaction();
$statement->execute(["name"=>'Bob']);
$statement->execute(["name"=>'Joe']);
$pdo->commit();
}
catch (\Exception $e) {
if ($pdo->inTransaction()) {
$pdo->rollback();
//如果我们到达这里，我们的两个数据更新不在数据库中
}
throw $e;
}在事务期间，所做的任何数据更改仅对活动连接可见。 SELECT语句将返回更改的更改，即使它们尚未提交到数据库也是如此。
注意：有关事务支持的详细信息，请参见数据库供应商文档。某些系统根本不支持事务。有些支持嵌套事务，而另一些则不支持。
通过PDO使用事务的实际示例
下一节演示了一个实际的实际示例，其中使用事务确保数据库的一致性。
设想以下情况，假设您正在为一个电子商务网站构建购物车，并且决定将订单保留在两个数据库表中。一位叫orders与领域order_id，name，address，telephone和created_at。还有第二个orders_products用字段命名order_id，product_id和quantity。第一个表包含订单的元数据，第二个表包含已订购的实际产品。
将新订单插入数据库
要将新订单插入数据库，您需要做两件事。首先，你需要INSERT里面一个新的记录orders表将包含元数据的顺序（name，address，等）。然后，对于订单中包含的每种产品，您都需要INSERT在orders_products表中记录一条记录。
您可以通过执行类似以下操作来做到这一点：
//将订单的元数据插入数据库
$preparedStatement = $db->prepare(
'INSERT INTO `orders` (`name`, `address`, `telephone`, `created_at`)
VALUES (:name, :address, :telephone, :created_at)'
);
$preparedStatement->execute([
'name' => $name,
'address' => $address,
'telephone' => $telephone,
'created_at' => time(),
]);
//获取生成的`order_id`
$orderId = $db->lastInsertId();
//构造查询以插入订单产品
$insertProductsQuery = 'INSERT INTO `orders_products` (`order_id`, `product_id`, `quantity`) VALUES';
$count = 0;
foreach ( $products as $productId => $quantity ) {
$insertProductsQuery .= ' (:order_id' . $count . ', :product_id' . $count . ', :quantity' . $count . ')';
$insertProductsParams['order_id' . $count] = $orderId;
$insertProductsParams['product_id' . $count] = $productId;
$insertProductsParams['quantity' . $count] = $quantity;
++$count;
}
//将订单中包含的产品插入数据库
$preparedStatement = $db->prepare($insertProductsQuery);
$preparedStatement->execute($insertProductsParams);这对于将新订单插入数据库非常有用，直到发生意外情况并且由于某种原因第二个INSERT查询失败。如果发生这种情况，您将在orders表内获得一个新订单，该订单将没有任何关联的产品。幸运的是，此修复非常简单，您要做的就是以单个数据库事务的形式进行查询。
通过事务将新订单插入数据库
要使用PDO所有事务来启动事务，是beginTransaction在对数据库执行任何查询之前调用该方法。然后，您可以通过执行INSERT和/或UPDATE查询对数据进行任何更改。最后，您调用对象的commit方法PDO以使更改永久生效。在调用该commit方法之前，到目前为止，您对数据所做的每项更改都尚未永久生效，只需调用对象的rollback方法即可轻松地将其还原PDO。
在下面的示例中，演示了如何使用事务将新订单插入数据库，同时确保数据的一致性。如果两个查询之一失败，所有更改将被还原。
//在此示例中，我们使用MySQL，但这适用于任何支持事务的数据库
$db = new PDO('mysql:host=' . $host . ';dbname=' . $dbname . ';charset=utf8', $username, $password);
//确保在发生错误的情况下PDO会引发异常，以使错误处理更加容易
$db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
try {
//从这一点开始，直到提交事务，对数据库的所有更改都可以还原
$db->beginTransaction();
//将订单的元数据插入数据库
$preparedStatement = $db->prepare(
'INSERT INTO `orders` (`order_id`, `name`, `address`, `created_at`)
VALUES (:name, :address, :telephone, :created_at)'
);
$preparedStatement->execute([
'name' => $name,
'address' => $address,
'telephone' => $telephone,
'created_at' => time(),
]);
//获取生成的`order_id`
$orderId = $db->lastInsertId();
//构造查询以插入订单产品
$insertProductsQuery = 'INSERT INTO `orders_products` (`order_id`, `product_id`, `quantity`) VALUES';
$count = 0;
foreach ( $products as $productId => $quantity ) {
$insertProductsQuery .= ' (:order_id' . $count . ', :product_id' . $count . ', :quantity' . $count . ')';
$insertProductsParams['order_id' . $count] = $orderId;
$insertProductsParams['product_id' . $count] = $productId;
$insertProductsParams['quantity' . $count] = $quantity;
++$count;
}
//将订单中包含的产品插入数据库
$preparedStatement = $db->prepare($insertProductsQuery);
$preparedStatement->execute($insertProductsParams);
//永久更改数据库
$db->commit();
}
catch ( PDOException $e ) {
//无法将订单插入数据库，因此我们回滚所有更改
$db->rollback();
throw $e;
}