如何从Doctrine中获取当前运行事务的ID？

Doctrine的Connection类本身没有提供跨数据库通用的事务ID获取接口，因为不同数据库的事务ID机制差异很大。不过可以通过以下几种方式实现，避免直接写耦合性过高的原生SQL：

1. 结合数据库原生函数的轻量查询 #

针对不同数据库类型，调用对应的原生函数或查询获取事务ID：

MySQL #

MySQL没有直接返回当前事务ID的函数，但可以通过当前连接ID关联查询事务表：

$connection = $entityManager->getConnection();
// 获取当前数据库连接ID
$connectionId = $connection->executeQuery('SELECT CONNECTION_ID()')->fetchOne();
// 查询该连接对应的事务ID
$trxId = $connection->executeQuery(
    'SELECT trx_id FROM information_schema.INNODB_TRX WHERE trx_mysql_thread_id = ?',
    [$connectionId]
)->fetchOne();

PostgreSQL #

PostgreSQL可直接调用内置函数获取事务ID：

$trxId = $entityManager->getConnection()->executeQuery('SELECT txid_current()')->fetchOne();

2. 调用底层数据库连接句柄 #

通过Doctrine的getWrappedConnection()方法获取底层的数据库连接实例（如PDO），再执行对应操作：

$pdo = $entityManager->getConnection()->getWrappedConnection();
// 以PostgreSQL为例
$stmt = $pdo->query('SELECT txid_current()');
$trxId = $stmt->fetchColumn();

3. 自定义Connection封装通用逻辑 #

如果项目频繁需要获取事务ID，可以扩展Doctrine的Connection类，封装跨数据库的适配逻辑：

use Doctrine\DBAL\Connection;

class CustomConnection extends Connection
{
    public function getTransactionId(): ?string
    {
        switch ($this->getDatabasePlatform()->getName()) {
            case 'postgresql':
                return $this->executeQuery('SELECT txid_current()')->fetchOne();
            case 'mysql':
                $connectionId = $this->executeQuery('SELECT CONNECTION_ID()')->fetchOne();
                return $this->executeQuery(
                    'SELECT trx_id FROM information_schema.INNODB_TRX WHERE trx_mysql_thread_id = ?',
                    [$connectionId]
                )->fetchOne();
            default:
                return null;
        }
    }
}

配置Doctrine使用自定义Connection后，即可直接通过$connection->getTransactionId()获取事务ID。

注意：事务ID仅在事务开启（beginTransaction()执行后）到提交/回滚前有效，失效后无法获取。

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