PHP怎么实现单元工作模式_PHP数据库事务管理技巧【方法】-php教程-PHP中文网

php中可落地的单元工作模式是手动实现的协调器，用于跟踪实体增删改并在事务中统一刷写sql，核心含unitofwork类、entityinterface和repository，需显式管理脏状态与事务安全。

php怎么实现单元工作模式_php数据库事务管理技巧【方法】

PHP 中没有内置的“单元工作模式”（Unit of Work），这是领域驱动设计（DDD）里的概念，需手动实现；而数据库事务管理是它的基础支撑——但直接用 PDO::beginTransaction() 或 mysqli_begin_transaction() 并不能自动解决对象状态跟踪、变更集收集等问题。

什么是 PHP 里能落地的“单元工作模式”

它本质是一个协调器：记录实体（如 $user、$order）的创建、修改、删除操作，在提交时统一生成 SQL 并执行事务。不是框架专利，也不依赖 Doctrine —— 你可以用几十行代码搭出最小可用版本。

核心组件只有三个：UnitOfWork 类（负责注册/差异比对/刷写）、EntityInterface（约定 isDirty()、getChanges() 等方法）、Repository（接管 persist()/remove() 调用）
不推荐在 Laravel/Eloquent 里强行套用：Eloquent 的 save() 已隐含单实体事务语义，叠加 UoW 容易引发重复提交或状态错乱
真正适合的场景是：需要批量处理异构实体（比如同时更新用户 + 日志 + 配额记录），且要求“全成功或全回滚”，又不想写大段 try/catch 嵌套

用 PDO 实现事务安全的变更刷写

UoW 的“刷写”（flush）阶段必须运行在事务内，否则无法保证原子性。别只调 beginTransaction() 就完事——PDO 默认 autocommit 开启，且某些 MySQL 驱动（如 mysqlnd）在 prepare 失败时不会自动 rollback。

btpanel phpsite 宝塔面板PHP网站

宝塔面板 PHP 网站管理：站点创建、删除、启停、PHP 版本切换、域名管理、SSL证书管理、伪静态管理、数据库管理

下载

显式关闭 autocommit：$pdo->setAttribute(PDO::ATTR_AUTOCOMMIT, false)，避免 INSERT 后意外提交
所有 SQL 必须用预处理语句，防止脏数据混入事务（例如未转义的 $name 直接拼进 "UPDATE user SET name='$name'" 可能导致语法错误中断事务）
捕获 PDOException 后必须手动 $pdo->rollback()，PHP 不会自动回滚未完成事务（哪怕脚本 exit）

示例关键片段：

try {
    $pdo->beginTransaction();
    foreach ($unitOfWork->getInserts() as $entity) {
        $stmt = $pdo->prepare("INSERT INTO user (name, email) VALUES (?, ?)");
        $stmt->execute([$entity->name, $entity->email]);
    }
    $pdo->commit();
} catch (PDOException $e) {
    $pdo->rollback();
    throw $e;
}

容易被忽略的状态同步陷阱

UoW 要可靠，必须让实体自己管理“是否已修改”。PHP 没有属性监听机制，所以不能靠魔术方法自动感知赋值变化——$user->name = 'new' 不会触发 markAsDirty()。

强制使用 setter：$user->setName('new') 内部调用 $this->setDirty('name')，禁止 public 属性直写
构造函数或从 DB 加载时，要调用 $entity->setClean() 清空初始脏标记，否则新加载的实体也会被当成待更新
关联对象（如 $order->addLineItem($item)）需在方法体内显式标记父对象为 dirty，否则 UoW 刷写时会漏掉这条变更
注意浮点数和 null 比较：用 === 判断字段是否真变化，避免 0 == false 导致误判

真正的难点不在事务开启或 SQL 拼写，而在于实体生命周期和内存状态的一致性维护——一旦某个 setter 忘记标记 dirty，或者从数组重建对象时没调用 setClean()，整个 UoW 就会静默失效。先跑通单实体测试，再加关联，最后压测并发写入。