在Swoole协程中使用数据库事务需确保连接独占与事务完整，1. 使用Swoole\Coroutine\MySQL或协程PDO创建连接；2. 在同一协程内begin、执行SQL、commit/rollback；3. 配合连接池获取独占连接避免频繁创建；4. 禁止跨协程共享连接或事务状态；5. 用try-catch捕获异常并确保rollback。
在Swoole协程环境下使用数据库事务，关键在于保证连接与事务的生命周期一致，避免跨协程复用连接或事务中断。由于Swoole协程是协作式多任务，传统的同步阻塞写法不适用，必须使用支持协程的MySQL客户端（如Swoole\Coroutine\MySQL或基于其封装的PDO协程版本），并遵循协程上下文隔离原则。
直接使用Swoole\Coroutine\MySQL可以精确控制事务流程：
400-7654-355 BEGIN开启事务COMMIT，任一失败立即ROLLBACK
go(function () {
$mysql = new Swoole\Coroutine\MySQL();
$mysql->connect([
'host' => '127.0.0.1',
'port' => 3306,
'user' => 'root',
'password' => 'password',
'database' => 'test'
]);
$mysql->begin();
$result1 = $mysql->query("UPDATE accounts SET balance = balance - 100 WHERE id = 1");
$result2 = $mysql->query("UPDATE accounts SET balance = balance + 100 WHERE id = 2");
if ($result1 && $result2) {
$mysql->commit();
} else {
$mysql->rollback();
}});
使用连接池管理事务连接
在高并发场景下，频繁创建连接影响性能。应结合协程连接池，从池中获取独占连接用于事务：
常见框架如EasySwoole、MixPHP等都提供协程安全的MySQL连接池实现。
多个协程不能共用同一数据库连接进行事务操作。每个协程必须拥有独立连接：
务必使用try-catch捕获SQL异常，并在catch块中执行rollback：
go(function () {
$mysql = // 
... 连接
try {
$mysql->begin();
// 执行多条语句
if (!$mysql->query($sql1)) throw new Exception();
if (!$mysql->query($sql2)) throw new Exception();
$mysql->commit();
} catch (Exception $e) {
$mysql->rollback(); // 确保出错时回滚
echo "Transaction failed: " . $e->getMessage();
}
});
基本上就这些。核心是连接独占、流程完整、异常回滚，再配合连接池提升性能，就能在Swoole协程中安全使用数据库事务。
... 连接
try {
$mysql->begin();
// 执行多条语句
if (!$mysql->query($sql1)) throw new Exception();
if (!$mysql->query($sql2)) throw new Exception();
$mysql->commit();
} catch (Exception $e) {
$mysql->rollback(); // 确保出错时回滚
echo "Transaction failed: " . $e->getMessage();
}
});
