为何MySQL事务在PDO环境下无法正常工作？

一、事务未触发回滚的常见原因及排查步骤 #

咱们先把事务回滚失效的问题拆解清楚，这类问题大多是基础配置或流程上的疏漏，按以下顺序排查就行：

1. 检查表的存储引擎
   MySQL的MyISAM引擎完全不支持事务，只有InnoDB（或其他支持事务的引擎）才能配合PDO实现回滚。执行这条SQL查看目标表的引擎：

SHOW CREATE TABLE your_table_name;

确保输出里的Engine字段是InnoDB，如果不是，赶紧修改表引擎：

ALTER TABLE your_table_name ENGINE=InnoDB;

2. 确认PDO的事务模式配置

• 必须关闭PDO的自动提交模式，或者手动调用beginTransaction()开启事务。默认情况下PDO是自动提交，每个查询执行后会立即写入数据库，这时候回滚根本起不到作用。
• 一定要开启PDO的异常错误模式，否则查询失败时只会返回false，不会抛出异常，导致代码直接跳过回滚逻辑。正确的PDO初始化代码如下：

$pdo = new PDO($dsn, $db_user, $db_pass, [
    PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, // 强制抛出异常，确保错误能被捕获
    PDO::ATTR_AUTOCOMMIT => false // 关闭自动提交，交给事务控制
]);

3. 检查事务中是否包含DDL语句
   MySQL执行DDL语句（比如ALTER TABLE、CREATE TABLE、DROP TABLE）时，会自动强制提交当前事务，不管你有没有手动调用commit()。如果你的query1或query2里藏着这类语句，事务早就被提前提交了，后续的回滚操作自然无效。

4. 验证异常捕获逻辑是否完整
   确保你的事务逻辑被完整包裹在try-catch块中，并且catch块里正确调用了rollBack()。另外要注意，如果代码中存在未被捕获的致命错误（比如语法错误），会直接终止脚本，导致rollBack()根本没机会执行。可以开启PHP的错误日志来排查这类隐性问题。示例逻辑：

try {
    $pdo->beginTransaction();
    // 执行query1、query2
    $pdo->commit();
} catch (Exception $e) {
    if ($pdo->inTransaction()) { // 先确认事务还在进行中
        $pdo->rollBack();
        error_log("事务回滚：" . $e->getMessage());
    }
}

二、查询返回受影响行数为0但数据实际变更的问题 #

这个问题通常和PDO的rowCount()特性或数据库触发器有关，咱们逐个排查：

1. 理解PDO rowCount()的特性

• 如果你用PDO::exec()执行查询，返回的是受影响的行数；如果用prepare()+execute()，必须调用$stmt->rowCount()来获取行数。
• 默认情况下，MySQL的UPDATE语句如果修改的值和原数据完全一致，即使匹配到符合条件的行，rowCount()也会返回0（因为没有实际修改数据）。但如果你需要获取匹配到的行数而非实际修改的行数，可以在PDO连接时添加PDO::MYSQL_ATTR_FOUND_ROWS => true参数：

$pdo = new PDO($dsn, $db_user, $db_pass, [
    // 其他配置
    PDO::MYSQL_ATTR_FOUND_ROWS => true
]);

这样rowCount()就会返回匹配到的行数，而不是实际修改的行数。

2. 检查是否存在数据库触发器
   如果你的表关联了UPDATE或INSERT触发器，有可能是触发器在后台偷偷修改了数据，而主查询的rowCount()只统计主语句的受影响行数，不会包含触发器的操作。可以用这条SQL查看表的触发器：

SHOW TRIGGERS LIKE 'your_table_name';

3. 确认事务是否被意外提交
   如果自动提交没关闭，或者代码中存在逻辑漏洞导致commit()被意外调用，即使查询返回0行受影响，数据也会被写入。可以在commit()前加日志，确认它是否被意外执行。

完整的事务示例代码 #

把以上要点整合，一个规范的事务处理代码如下：

try {
    $pdo = new PDO($dsn, $db_user, $db_pass, [
        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
        PDO::ATTR_AUTOCOMMIT => false,
        PDO::MYSQL_ATTR_FOUND_ROWS => true
    ]);

    $pdo->beginTransaction();

    // 执行query1
    $stmt1 = $pdo->prepare("UPDATE table1 SET column1 = ? WHERE id = ?");
    $stmt1->execute(['new_value_1', 1]);
    $rowsAffected1 = $stmt1->rowCount();
    error_log("Query1 匹配/受影响行数：" . $rowsAffected1);

    // 执行query2
    $stmt2 = $pdo->prepare("UPDATE table2 SET column2 = ? WHERE id = ?");
    $stmt2->execute(['new_value_2', 2]);
    $rowsAffected2 = $stmt2->rowCount();
    error_log("Query2 匹配/受影响行数：" . $rowsAffected2);

    // 自定义校验：如果没有匹配到行，主动触发回滚
    if ($rowsAffected1 === 0 || $rowsAffected2 === 0) {
        throw new Exception("一个或多个查询未匹配到任何行");
    }

    $pdo->commit();
    error_log("事务提交成功");
} catch (Exception $e) {
    if ($pdo->inTransaction()) {
        $pdo->rollBack();
        error_log("事务回滚：" . $e->getMessage());
    }
    // 后续错误处理
}

内容的提问来源于stack exchange，提问作者Dymattic