如何解决DoctrineDBAL日志记录的困境？firehed/dbal-logger助你重获自由与掌控！

<code class="bash">composer require firehed/dbal-logger</code>

<pre class="brush:php;toolbar:false;"><?php

namespace App\DbalLogger;

use Firehed\DbalLogger\QueryLogger;
use Psr\Log\LoggerInterface; // 假设你有一个PSR-3兼容的Logger

class MyCustomSqlLogger implements QueryLogger
{
    private LoggerInterface $logger;
    private array $queries = [];

    public function __construct(LoggerInterface $logger)
    {
        $this->logger = $logger;
    }

    public function startQuery(string $sql, array $params = [], array $types = []): void
    {
        $this->queries[] = [
            'sql' => $sql,
            'params' => $params,
            'types' => $types,
            'start' => microtime(true),
        ];
        $this->logger->info('Executing SQL', ['sql' => $sql, 'params' => $params]);
    }

    public function stopQuery(): void
    {
        if (empty($this->queries)) {
            return;
        }
        $lastQuery = array_pop($this->queries);
        $duration = microtime(true) - $lastQuery['start'];

        $this->logger->info('SQL executed successfully', [
            'sql' => $lastQuery['sql'],
            'duration_ms' => round($duration * 1000, 2),
        ]);

        // 这里你可以将日志发送到任何你想要的地方，例如一个性能监控系统
        // sendToTelemetryService($lastQuery['sql'], $duration);
    }
}

<pre class="brush:php;toolbar:false;"><?php

use Doctrine\DBAL\DriverManager;
use Doctrine\DBAL\Configuration;
use Firehed\DbalLogger\Middleware;
use App\DbalLogger\MyCustomSqlLogger;
use Monolog\Logger;
use Monolog\Handler\StreamHandler;

// 假设你有一个PSR-3兼容的Logger实例
$psrLogger = new Logger('dbal');
$psrLogger->pushHandler(new StreamHandler('php://stderr', Logger::DEBUG));

// 实例化你的自定义Logger
$myQueryLogger = new MyCustomSqlLogger($psrLogger);

// 将自定义Logger包装成Middleware
$middleware = new Middleware($myQueryLogger);

// 创建DBAL配置
$config = new Configuration();

// 将Middleware添加到配置中
$config->setMiddlewares([$middleware]);

// 数据库连接参数
$connectionParams = [
    'url' => 'mysql://user:password@localhost/dbname',
];

// 创建数据库连接
$connection = DriverManager::getConnection($connectionParams, $config);

// 现在，所有通过 $connection 执行的SQL查询都将通过你的 MyCustomSqlLogger 进行记录
$connection->executeQuery('SELECT 1');
$connection->executeQuery('SELECT * FROM users WHERE id = ?', [1]);

<pre class="brush:php;toolbar:false;"><?php

use Firehed\DbalLogger\ChainLogger;
use Firehed\DbalLogger\Middleware;
// ... 其他use声明

// 假设你有两个不同的Logger实例
$logger1 = new MyCustomSqlLogger($psrLogger); // 比如记录到文件
$logger2 = new MyTelemetryLogger(); // 比如发送到性能监控服务

// 使用ChainLogger将它们串联起来
$chainLogger = new ChainLogger([$logger1, $logger2]);

// 将ChainLogger包装成Middleware
$middleware = new Middleware($chainLogger);

// ... 然后按照上面的方式添加到DBAL配置中
$config->setMiddlewares([$middleware]);