Catch TableNotFoundException in MySQL delete

symfony · Mar 14, 2024 · c69d1ff · c69d1ff
1 parent c9bce39
commit c69d1ff
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/Connection.php b/src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/Connection.php
@@ -161,6 +161,10 @@ public function get(): ?array
                 $this->driverConnection->delete($this->configuration['table_name'], ['delivered_at' => '9999-12-31 23:59:59']);
             } catch (DriverException $e) {
                 // Ignore the exception
+            } catch (TableNotFoundException) {
+                if ($this->autoSetup) {
+                    $this->setup();
+                }
             }
         }