src/Hitso/Bundle/CommonBundle/Monitor/SlowQueryLogger.php line 50

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  3. /**
  4.  * @author Maciej Kaczmarek <maciej.kaczmarek@autentika.pl>
  5.  */
  7. namespace Hitso\Bundle\CommonBundle\Monitor;
  9. use Doctrine\DBAL\Logging\DebugStack;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Symfony\Component\HttpKernel\KernelEvents;
  13. class SlowQueryLogger implements EventSubscriberInterface
  14. {
  16.     /**
  17.      * @var string
  18.      */
  19.     private $logPath;
  21.     /**
  22.      * @var bool
  23.      */
  24.     private $debug;
  26.     /**
  27.      * @var bool
  28.      */
  29.     private $registered = false;
  30.     /**
  31.      * @var DebugStack
  32.      */
  33.     private $logger;
  35.     /**
  36.      * SlowQueryLogger constructor.
  37.      *
  38.      * @param string     $logPath
  39.      * @param string     $lockPath
  40.      * @param bool       $debug
  41.      * @param DebugStack $logger
  42.      */
  43.     public function __construct($logPath, $lockPath, $debug, DebugStack $logger = null)
  44.     {
  45.         $this->logger  = $logger;
  46.         $this->logPath = $logPath;
  47.         $this->debug   = $debug;
  48.     }
  50.     public function onRequest()
  51.     {
  52.         if (!$this->registered && !$this->debug && $this->logger && $this->logger->enabled) {
  53.             $this->registered = true;
  55.             register_shutdown_function(function () {
  56.                 foreach ($this->logger->queries as $query) {
  57.                     if ($query['executionMS'] > 0.2) {
  58.                         $entry = [
  59.                             'stamp'  => time(),
  60.                             'time'   => round($query['executionMS'] * 1000),
  61.                             'query'  => $query['sql'],
  62.                             'params' => $query['params'],
  63.                             'errors' => false,
  64.                         ];
  66.                         file_put_contents($this->logPath, base64_encode(serialize($entry)) . PHP_EOL, FILE_APPEND);
  67.                     }
  68.                 }
  69.             });
  70.         }
  71.     }
  73.     public function getSlowQueries()
  74.     {
  75.         if (!file_exists($this->logPath)) {
  76.             return [];
  77.         }
  79.         $logs = array_filter(file($this->logPath));
  80.         unlink($this->logPath);
  82.         $logs = array_map(
  83.             function ($entry) {
  84.                 return unserialize(base64_decode($entry));
  85.             },
  86.             $logs
  87.         );
  89.         return array_filter($logs);
  90.     }
  92.     /**
  93.      * {@inheritdoc}
  94.      */
  95.     public static function getSubscribedEvents()
  96.     {
  97.         return [
  98.             KernelEvents::REQUEST => ['onRequest', 512],
  99.         ];
  100.     }
  102. }