MySQL 什么是PDO，如何使用它进行MySQL交易

MySQL是一个流行的关系型数据库管理系统，它也是多个Web应用程序的后台。在多用户场景下，数据库的交互是如何保证数据的一致性的？PDO通过提交和回滚交易来提供一个答案。在本文中，我们将了解什么是PDO，如何使用它进行MySQL交易，包括事务的ACID特性和常见的MySQL错误处理。

阅读更多：MySQL 教程

PDO简介

PDO是PHP数据对象的缩写，它允许我们使用面向对象的方法去操作MySQL数据库和其他关系型数据库。PDO使用预处理语句，可靠地处理SQL注入，还支持一些基本的SQL查询，如数据选择、插入、更新和删除。

使用PDO可以将MySQL服务器连接到PHP程序中，使用以下代码：

try {
     $pdo = new PDO('mysql:host=localhost;dbname=mydatabase', 'myusername', 'mypassword'); } catch (PDOException$ e) {
    die($e->getMessage());
}

PDO连接需要三个参数：host是MySQL服务器主机名，dbname是要连接到的数据库名称，username和password是连接到MySQL服务器的用户名和密码。连接成功后，$pdo变量就能够使用数据库查询，执行以下代码测试连接是否正确：

$stmt = $pdo->query('SELECT * FROM users');
$users = $stmt->fetchAll(PDO::FETCH_ASSOC);
print_r($users);

这个程序使用query方法向MySQL服务器发送查询请求。当查询成功时，会返回一个Statement对象，然后调用fetch方法来获取相关数据。

使用PDO进行MySQL交易

您可能会想知道什么是交易。交易或交易集合是一组可表示一个数据库更改的SQL语句。当这些更改都成功时，这些更改被提交到数据库中，否则所有的更改将被回滚到原始状态。假设我们有以下代码，使用PDO实现MySQL交易：

try {
     $pdo->beginTransaction();$ pdo->exec("UPDATE account SET balance = balance + 500 WHERE id = 1");
     $pdo->exec("INSERT INTO transactions (account_id, amount, date) VALUES (1, 500, NOW())");$ pdo->commit();
} catch (PDOException  $e) {$ pdo->rollback();
    echo $e->getMessage();
}

此代码使用beginTransaction方法启动MySQL交易，然后改变一个账户的余额和插入一条新事务的记录。如果这些更改都成功，我们调用commit方法提交所有更改，否则执行rollback方法返回到原始状态。

这样的交易处理方式主要解决了数据库中数据的一致性和安全性。故障或随机错误的情况下，如果交易不能成功完成，交易可以被回滚并返回到未提交交易之前的状态，确保数据的一致性不受影响。

MySQL错误处理

PDO提供了一些方便的方法，用于检测MySQL交易中发生的错误。这些方法包括：PDO::errorInfo、PDOStatement::errorInfo和PDOStatement::errorCode。

PDO::errorInfo: 方法返回一组由错误编码、错误码和错误信息组成的数组。
PDOStatement::errorInfo: 返回一组由错误编码、错误码和错误信息组成的数组。
PDOStatement::errorCode: 返回执行分区操作时产生的错误编码。

这里有一个例子来说明这些方法如何使用：

$stmt = $pdo->prepare("INSERT INTO users (name, email) VALUES (:name, :email)");
$stmt->bindParam(':name', $name);
$stmt->bindParam(':email', $email);

$name = 'John Smith';
$email = 'john.smith@example.com';
$stmt->execute();

if ($stmt->errorCode() != '00000') {
    $errorInfo = $stmt->errorInfo();
    echo 'MySQL error ' . $errorInfo[1] . ': ' . $errorInfo[2];
}

这个例子向users表添加了一条记录。在执行后，我们运行errorCode方法来检查是否有错误发生。如果有，我们可以调用errorInfo方法来获取更多的信息。

当然，我们也可以使用try/catch块来处理MySQL错误，如下所示：

try {
     $pdo->beginTransaction();$ pdo->exec("UPDATE account SET balance = balance + 500 WHERE id = 1");
     $pdo->exec("INSERT INTO transactions (account_id, amount, date) VALUES (1, 500, NOW())");$ pdo->commit();
} catch (PDOException  $e) {$ pdo->rollback();
    echo 'MySQL error ' .  $e->getCode() . ': ' .$ e->getMessage();
}

在这个例子中，我们使用try/catch块来捕捉所有可能的MySQL错误。如果我们在try块中遇到问题，我们会调用rollback方法来回滚交易，然后输出MySQL错误的信息。