- force disconnect in case of connection error

spiral-modules · Nov 5, 2019 · 290060a · 290060a
1 parent 47436af
commit 290060a
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/Driver/Driver.php b/src/Driver/Driver.php
@@ -296,6 +296,8 @@ public function beginTransaction(string $isolationLevel = null, bool $cacheState
                     $e instanceof StatementException\ConnectionException
                     && $this->options['reconnect']
                 ) {
+                    $this->disconnect();
+
                     try {
                         return $this->getPDO()->beginTransaction();
                     } catch (\PDOException $e) {
@@ -527,6 +529,8 @@ private function statement(string $query, array $parameters = [], bool $retry =
                 && $this->tScope->getLevel() === 0
                 && $retry
             ) {
+                $this->disconnect();
+
                 // retrying
                 return $this->statement($query, $parameters, false);
             }