vendor/symfony/doctrine-bridge/Logger/DbalLogger.php line 21

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Symfony\Bridge\Doctrine\Logger;
  14. use Doctrine\DBAL\Logging\SQLLogger;
  15. use Psr\Log\LoggerInterface;
  16. use Symfony\Component\Stopwatch\Stopwatch;
  18. /**
  19.  * @author Fabien Potencier <fabien@symfony.com>
  20.  */
  21. class DbalLogger implements SQLLogger
  22. {
  23.     public const MAX_STRING_LENGTH = 32;
  24.     public const BINARY_DATA_VALUE = '(binary value)';
  26.     protected $logger;
  27.     protected $stopwatch;
  29.     public function __construct(LoggerInterface $logger = null, Stopwatch $stopwatch = null)
  30.     {
  31.         $this->logger = $logger;
  32.         $this->stopwatch = $stopwatch;
  33.     }
  35.     /**
  36.      * {@inheritdoc}
  37.      *
  38.      * @return void
  39.      */
  40.     public function startQuery($sql, array $params = null, array $types = null)
  41.     {
  42.         if (null !== $this->stopwatch) {
  43.             $this->stopwatch->start('doctrine', 'doctrine');
  44.         }
  46.         if (null !== $this->logger) {
  47.             $this->log($sql, null === $params ? [] : $this->normalizeParams($params));
  48.         }
  49.     }
  51.     /**
  52.      * {@inheritdoc}
  53.      *
  54.      * @return void
  55.      */
  56.     public function stopQuery()
  57.     {
  58.         if (null !== $this->stopwatch) {
  59.             $this->stopwatch->stop('doctrine');
  60.         }
  61.     }
  63.     /**
  64.      * Logs a message.
  65.      */
  66.     protected function log(string $message, array $params)
  67.     {
  68.         $this->logger->debug($message, $params);
  69.     }
  71.     private function normalizeParams(array $params): array
  72.     {
  73.         foreach ($params as $index => $param) {
  74.             // normalize recursively
  75.             if (\is_array($param)) {
  76.                 $params[$index] = $this->normalizeParams($param);
  77.                 continue;
  78.             }
  80.             if (!\is_string($params[$index])) {
  81.                 continue;
  82.             }
  84.             // non utf-8 strings break json encoding
  85.             if (!preg_match('//u', $params[$index])) {
  86.                 $params[$index] = self::BINARY_DATA_VALUE;
  87.                 continue;
  88.             }
  90.             // detect if the too long string must be shorten
  91.             if (self::MAX_STRING_LENGTH < mb_strlen($params[$index], 'UTF-8')) {
  92.                 $params[$index] = mb_substr($params[$index], 0, self::MAX_STRING_LENGTH - 6, 'UTF-8').' [...]';
  93.                 continue;
  94.             }
  95.         }
  97.         return $params;
  98.     }
  99. }