#22 - PersistentPDO renamed to ReconnectingPDO

swiftotter · Jun 30, 2022 · 05f6fd7 · 05f6fd7
1 parent 053c764
commit 05f6fd7
Show file tree

Hide file tree

Showing 5 changed files with 9 additions and 9 deletions.
diff --git a/src/Engines/ConnectionInterface.php b/src/Engines/ConnectionInterface.php
@@ -23,7 +23,7 @@ interface ConnectionInterface
 {
     public function isAvailable(): bool;
 
-    public function getConnection(): PersistentPDO;
+    public function getConnection(): ReconnectingPDO;
 
     public function getDSN(): string;
 

diff --git a/src/Engines/ConnectionTrait.php b/src/Engines/ConnectionTrait.php
@@ -8,9 +8,9 @@
 
 trait ConnectionTrait
 {
-    private ?PersistentPDO $connection = null;
+    private ?ReconnectingPDO $connection = null;
 
-    public function getConnection(): PersistentPDO
+    public function getConnection(): ReconnectingPDO
     {
         if (!$this->connection) {
             $options = [
@@ -19,7 +19,7 @@ public function getConnection(): PersistentPDO
                 PDO::ATTR_EMULATE_PREPARES => false
             ];
 
-            $this->connection = new PersistentPDO($this->getDSN(), $this->getUser(), $this->getPassword(), $options);
+            $this->connection = new ReconnectingPDO($this->getDSN(), $this->getUser(), $this->getPassword(), $options);
         }
 
         return $this->connection;

diff --git a/src/Engines/MySql/Transformation.php b/src/Engines/MySql/Transformation.php
@@ -21,7 +21,7 @@
 
 use Driver\Commands\CommandInterface;
 use Driver\Engines\MySql\Sandbox\Utilities;
-use Driver\Engines\PersistentPDO;
+use Driver\Engines\ReconnectingPDO;
 use Driver\Engines\RemoteConnectionInterface;
 use Driver\Pipeline\Environment\EnvironmentInterface;
 use Driver\Pipeline\Transport\Status;
@@ -72,7 +72,7 @@ public function getProperties()
         return $this->properties;
     }
 
-    private function applyTransformationsTo(PersistentPDO $connection, $transformations)
+    private function applyTransformationsTo(ReconnectingPDO $connection, $transformations)
     {
         array_walk($transformations, function ($query) use ($connection) {
             try {

diff --git a/src/Engines/PersistentPDO.php → src/Engines/ReconnectingPDO.php b/src/Engines/PersistentPDO.php → src/Engines/ReconnectingPDO.php
@@ -34,7 +34,7 @@
  * @method array|false pgsqlGetNotify(int $fetchMode = 0, int $timeoutMilliseconds = 0)
  * @method int pgsqlGetPid()
  */
-class PersistentPDO
+class ReconnectingPDO
 {
     private const MYSQL_GENERAL_ERROR_CODE = 'HY000';
     private const SERVER_HAS_GONE_AWAY_ERROR_CODE = 2006;

diff --git a/src/System/LocalConnectionLoader.php b/src/System/LocalConnectionLoader.php
@@ -10,7 +10,7 @@
 use DI\Container;
 use Driver\Engines\ConnectionInterface;
 use Driver\Engines\LocalConnectionInterface;
-use Driver\Engines\PersistentPDO;
+use Driver\Engines\ReconnectingPDO;
 
 class LocalConnectionLoader implements LocalConnectionInterface
 {
@@ -36,7 +36,7 @@ public function __construct(
         $this->container = $container;
     }
 
-    public function getConnection(): PersistentPDO
+    public function getConnection(): ReconnectingPDO
     {
         return $this->get()->getConnection();
     }