Attempt to catch reset by peer errors as well

infinityloop-dev · Oct 24, 2022 · cd2aff3 · cd2aff3
1 parent b73f255
commit cd2aff3
Showing 1 changed file with 14 additions and 1 deletion.
diff --git a/src/Bridge/Nette/Connection.php b/src/Bridge/Nette/Connection.php
@@ -6,7 +6,20 @@
 
 final class Connection extends \Nette\Database\Connection
 {
-    public function query(string $sql, ...$params): \Nette\Database\ResultSet
+    public function connect() : void
+    {
+        try {
+            parent::connect();
+        } catch (\PDOException $e) {
+            if (\str_contains($e->getMessage(), 'reset by peer')) {
+                parent::connect(); // retry
+            }
+
+            throw $e;
+        }
+    }
+
+    public function query(string $sql, ...$params) : \Nette\Database\ResultSet
     {
         try {
             return parent::query($sql, $params);