Merge pull request #530 from utopia-php/feat-expose-reconnect

Expose reconnect

Author: abnegate

src/Database/Adapter.php

@@ -390,6 +390,11 @@ protected function trigger(string $event, mixed $query): mixed
      */
     abstract public function ping(): bool;
 
+    /**
+     * Reconnect Database
+     */
+    abstract public function reconnect(): void;
+
     /**
      * Create Database
      *
@@ -904,6 +909,8 @@ abstract public function getSupportForUpserts(): bool;
      */
     abstract public function getSupportForCacheSkipOnFailure(): bool;
 
+    abstract public function getSupportForReconnection(): bool;
+
     /**
      * Get current attribute count from collection document
      *

src/Database/Adapter/Mongo.php

@@ -100,6 +100,11 @@ public function ping(): bool
         return $this->getClient()->query(['ping' => 1])->ok ?? false;
     }
 
+    public function reconnect(): void
+    {
+        $this->client->connect();
+    }
+
     /**
      * Create Database
      *
@@ -1843,6 +1848,11 @@ public function getSupportForUpserts(): bool
         return false;
     }
 
+    public function getSupportForReconnection(): bool
+    {
+        return false;
+    }
+
     /**
      * Get current attribute count from collection document
      *

src/Database/Adapter/SQL.php

@@ -132,6 +132,11 @@ public function ping(): bool
             ->execute();
     }
 
+    public function reconnect(): void
+    {
+        $this->getPDO()->reconnect();
+    }
+
     /**
      * Check if Database exists
      * Optionally check if collection exists in Database
@@ -881,6 +886,11 @@ public function getSupportForRelationships(): bool
         return true;
     }
 
+    public function getSupportForReconnection(): bool
+    {
+        return true;
+    }
+
     /**
      * @param mixed $stmt
      * @param Query $query
@@ -1155,7 +1165,7 @@ public function getSQLConditions(array $queries = [], string $separator = 'AND')
             }
         }
 
-        $tmp = implode(' '. $separator .' ', $conditions);
+        $tmp = implode(' ' . $separator . ' ', $conditions);
         return empty($tmp) ? '' : '(' . $tmp . ')';
     }
 

src/Database/Database.php

@@ -1072,6 +1072,11 @@ public function ping(): bool
         return $this->adapter->ping();
     }
 
+    public function reconnect(): void
+    {
+        $this->adapter->reconnect();
+    }
+
     /**
      * Create the database
      *

tests/e2e/Adapter/Base.php

@@ -17734,9 +17734,13 @@ public function testEvents(): void
                 Database::EVENT_INDEX_DELETE,
                 Database::EVENT_DOCUMENT_PURGE,
                 Database::EVENT_DOCUMENT_DELETE,
+                Database::EVENT_DOCUMENT_PURGE,
+                Database::EVENT_DOCUMENT_PURGE,
                 Database::EVENT_DOCUMENTS_DELETE,
-                Database::EVENT_ATTRIBUTE_DELETE,
                 Database::EVENT_DOCUMENT_PURGE,
+                Database::EVENT_ATTRIBUTE_DELETE,
+                Database::EVENT_COLLECTION_DELETE,
+                Database::EVENT_DATABASE_DELETE,
                 Database::EVENT_DOCUMENT_PURGE,
                 Database::EVENT_DOCUMENTS_DELETE,
                 Database::EVENT_DOCUMENT_PURGE,