Catch TableNotFoundException in MySQL delete

acbramley · fabpot · commit 410bcceb1898 · 2024-03-17T15:02:26.000Z
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 $e) {
+                if ($this->autoSetup) {
+                    $this->setup();
+                }
             }
         }
 

Original file line number	Diff line number	Diff line change
`@@ -161,6 +161,10 @@ public function get(): ?array`
`161`	`161`	`$this->driverConnection->delete($this->configuration['table_name'], ['delivered_at' => '9999-12-31 23:59:59']);`
`162`	`162`	`} catch (DriverException $e) {`
`163`	`163`	`// Ignore the exception`
	`164`	`+ } catch (TableNotFoundException $e) {`
	`165`	`+ if ($this->autoSetup) {`
	`166`	`+ $this->setup();`
	`167`	`+ }`
`164`	`168`	`}`
`165`	`169`	`}`
`166`	`170`