Fixed ping() does not works.

Author: limingxinleo

src/MySQLReplication/Repository/MySQLRepository.php

@@ -8,7 +8,7 @@
 use MySQLReplication\BinLog\BinLogException;
 use MySQLReplication\Exception\MySQLReplicationException;
 
-class MySQLRepository implements RepositoryInterface
+class MySQLRepository implements RepositoryInterface, PingableConnection
 {
     private $connection;
 
@@ -47,7 +47,7 @@ public function getFields(string $database, string $table): FieldDTOCollection
 
     private function getConnection(): Connection
     {
-        if (false === $this->connection->ping()) {
+        if (false === $this->ping($this->connection)) {
             $this->connection->close();
             $this->connection->connect();
         }
@@ -95,4 +95,14 @@ public function getMasterStatus(): MasterStatusDTO
 
         return MasterStatusDTO::makeFromArray($data);
     }
+
+    public function ping(Connection $connection): bool
+    {
+        try {
+            $connection->executeQuery($connection->getDatabasePlatform()->getDummySelectSQL());
+            return true;
+        } catch (Exception $e) {
+            return false;
+        }
+    }
 }

src/MySQLReplication/Repository/PingableConnection.php

@@ -0,0 +1,20 @@
+<?php
+declare(strict_types=1);
+
+namespace MySQLReplication\Repository;
+
+use Doctrine\DBAL\Connection;
+
+/**
+ * An interface for connections which support a "native" ping method.
+ */
+interface PingableConnection
+{
+    /**
+     * Pings the database server to determine if the connection is still
+     * available. Return true/false based on if that was successful or not.
+     *
+     * @return bool
+     */
+    public function ping(Connection $connection): bool;
+}