diff --git a/src/Engines/ConnectionInterface.php b/src/Engines/ConnectionInterface.php index 51ff076..2dc054e 100644 --- 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 index 7d0c860..37f3c00 100644 --- 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 index 1c344de..6d84201 100644 --- 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 b/src/Engines/ReconnectingPDO.php similarity index 99% rename from src/Engines/PersistentPDO.php rename to src/Engines/ReconnectingPDO.php index 875e293..b8bc2fb 100644 --- a/src/Engines/PersistentPDO.php +++ b/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 index 0bad9b4..559879e 100644 --- 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(); }