src/EventSubscriber/DbKeepAliveSubscriber.php line 35

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\EventSubscriber;
  7. use Doctrine\DBAL\Connection;
  8. use Doctrine\Persistence\ManagerRegistry;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use Symfony\Component\HttpKernel\Event\RequestEvent;
  11. use Symfony\Component\HttpKernel\KernelEvents;
  13. final class DbKeepAliveSubscriber implements EventSubscriberInterface
  14. {
  15.     private ManagerRegistry $doctrine;
  17.     public function __construct(ManagerRegistry $doctrine)
  18.     {
  19.         $this->doctrine = $doctrine;
  20.     }
  22.     public static function getSubscribedEvents(): array
  23.     {
  24.         // Très tôt pour précéder les accès DB (ChannelResolver, etc.)
  25.         return [KernelEvents::REQUEST => ['onKernelRequest', 2048]];
  26.     }
  28.     public function onKernelRequest(RequestEvent $event): void
  29.     {
  30.         // Symfony >=5.3
  31.         if (method_exists($event, 'isMainRequest') && !$event->isMainRequest()) {
  32.             return;
  33.         }
  34.         // Compat <5.3
  35.         if (method_exists($event, 'isMasterRequest') && !$event->isMasterRequest()) {
  36.             return;
  37.         }
  39.         foreach ($this->doctrine->getConnections() as $connection) {
  40.             $this->pingOrReconnect($connection);
  41.             // (optionnel) poser quelques paramètres de session utiles :
  42.             $this->initMysqlSession($connection);
  43.         }
  44.     }
  46.     private function pingOrReconnect(Connection $conn): void
  47.     {
  48.         try {
  49.             if (method_exists($conn, 'ping')) {
  50.                 if (!$conn->ping()) {
  51.                     $conn->close();
  52.                     $conn->connect();
  53.                 }
  54.             } else {
  55.                 // fallback vieux DBAL
  56.                 $conn->executeQuery('SELECT 1');
  57.             }
  58.         } catch (\Throwable $e) {
  59.             $conn->close();
  60.             $conn->connect();
  61.         }
  62.     }
  64.     private function initMysqlSession(Connection $conn): void
  65.     {
  66.         try {
  67.             // Sécurisé: commandes simples et indépendantes
  68.             $conn->executeStatement("SET NAMES 'utf8mb4' COLLATE 'utf8mb4_unicode_ci'");
  69.             // Si autorisé côté serveur, augmente les timeouts session
  70.             $conn->executeStatement("SET SESSION wait_timeout = 28800");
  71.             $conn->executeStatement("SET SESSION interactive_timeout = 28800");
  72.         } catch (\Throwable $e) {
  73.             // ignorer si non supporté par l'hébergeur
  74.         }
  75.     }
  76. }