php实现基于pdo的事务处理方法示例

以下是“php实现基于pdo的事务处理方法示例”的完整攻略。

前置知识

在学习事务处理方法之前，需要先了解PDO和MySQL数据库中的事务概念。PDO是PHP提供的一个数据库抽象层，它提供了一种通用的接口，可以连接不同种类的数据库，是一种支持prepared statement的安全的数据库处理方式。而MySQL中的事务是对多个操作同时进行时，以一种类似于批处理的方式进行或回滚的一种数据处理机制。

PDO事务处理基本流程

PDO中的事务处理包括以下几个步骤：

1. 连接数据库：使用PDO连接到MySQL数据库。
2. 开始事务：使用PDO开始一个事务。
3. 执行操作：在事务中执行数据库操作，包括INSERT、UPDATE、DELETE等语句。
4. 提交事务：如果所有操作都没有错误，则提交整个事务。
5. 回滚事务：如果操作中出现错误，则回滚整个事务，回滚前的数据不会被保留。

示例一：插入数据

下面是一个实现PDO事务处理的示例，该示例将向两个表中同时插入数据，并使用到了事务处理的功能。具体步骤如下：

1. 创建两个表

先在数据库中创建两个表users和messages。

CREATE TABLE users (
    id INT(10) UNSIGNED AUTO_INCREMENT PRIMARY KEY,
    username VARCHAR(50) NOT NULL
);

CREATE TABLE messages (
    id INT(10) UNSIGNED AUTO_INCREMENT PRIMARY KEY,
    user_id INT(10) UNSIGNED NOT NULL,
    message TEXT NOT NULL,
    FOREIGN KEY (user_id) REFERENCES users(id)
);

2. 连接数据库

在PHP代码中使用PDO连接到MySQL数据库。这里使用的是本地服务器上的数据库：

$db_host = 'localhost';
$db_name = 'test_db';
$db_user = 'root';
$db_pass = '';

try {
    $pdo = new PDO("mysql:host=$db_host;dbname=$db_name;charset=utf8", $db_user, $db_pass);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
} catch(PDOException $e) {
    echo "连接数据库失败: " . $e->getMessage();
    exit;
}

3. 开始事务

在代码中使用PDO的beginTransaction()方法开始一个事务：

$pdo->beginTransaction();

4. 执行操作

在事务中执行INSERT语句将数据插入到users和messages表中：

// 插入数据到users表中
$stmt = $pdo->prepare("INSERT INTO users (username) VALUES (:username)");
$stmt->bindParam(':username', $username);
$username = 'user1';
$stmt->execute();
$user_id = $pdo->lastInsertId();

// 插入数据到messages表中
$stmt = $pdo->prepare("INSERT INTO messages (user_id, message) VALUES (:user_id, :message)");
$stmt->bindParam(':user_id', $user_id, PDO::PARAM_INT);
$stmt->bindParam(':message', $message);
$message = 'hello world';
$stmt->execute();

5. 提交事务

如果上一步的操作都没有错误，则使用PDO的commit()方法提交整个事务：

$pdo->commit();

6. 处理异常

如果在执行操作的过程中出现了异常，如SQL语句写错、插入数据重复等，则使用PDO的rollBack()方法回滚整个事务，并输出错误信息：

catch(PDOException $e) {
    $pdo->rollBack();
    echo "Error: " . $e->getMessage();
    exit;
}

示例二：更新数据

下面是另一个实现PDO事务处理的示例，该示例将在事务中同时更新两个表中的数据。具体步骤如下：

1. 准备测试数据

先在users和messages表中插入一条数据：

$stmt = $pdo->prepare("INSERT INTO users (username) VALUES (:username)");
$stmt->bindParam(':username', $username);
$username = 'user1';
$stmt->execute();
$user_id = $pdo->lastInsertId();

$stmt = $pdo->prepare("INSERT INTO messages (user_id, message) VALUES (:user_id, :message)");
$stmt->bindParam(':user_id', $user_id, PDO::PARAM_INT);
$stmt->bindParam(':message', $message);
$message = 'hello world';
$stmt->execute();

2. 开始事务

$pdo->beginTransaction();

3. 执行操作

分别对users和messages表中的数据进行更新操作：

// 更新users表中的数据
$stmt = $pdo->prepare("UPDATE users SET username = :newusername WHERE id = :user_id");
$stmt->bindParam(':newusername', $new_username);
$stmt->bindParam(':user_id', $user_id, PDO::PARAM_INT);
$new_username = 'newuser';
$stmt->execute();

// 更新messages表中的数据
$stmt = $pdo->prepare("UPDATE messages SET message = :newmessage WHERE user_id = :user_id");
$stmt->bindParam(':newmessage', $new_message);
$stmt->bindParam(':user_id', $user_id, PDO::PARAM_INT);
$new_message = 'hello pdo';
$stmt->execute();

4. 提交事务

$pdo->commit();

5. 处理异常

catch(PDOException $e) {
    $pdo->rollBack();
    echo "Error: " . $e->getMessage();
    exit;
}

以上就是“php实现基于pdo的事务处理方法示例”的完整攻略。