Merge pull request #546 from utopia-php/feat-pool-adapter

Feat pool adapter

Author: abnegate

.github/workflows/tests.yml

@@ -77,6 +77,7 @@ jobs:
             Postgres,
             SQLite,
             Mirror,
+            Pool,
             SharedTables/MariaDB,
             SharedTables/MySQL,
             SharedTables/Postgres,

README.md

@@ -49,11 +49,10 @@ The database document interface only supports primitives types (`strings`, `inte
 Below is a list of supported databases, and their compatibly tested versions alongside a list of supported features and relevant limits.
 
 | Adapter  | Status | Version |
-| -------- | ------ | ------- |
+|----------|--------|---------|
 | MariaDB  | ✅      | 10.5    |
 | MySQL    | ✅      | 8.0     |
 | Postgres | ✅      | 13.0    |
-| MongoDB  | ✅      | 5.0     |
 | SQLite   | ✅      | 3.38    |
 
 ` ✅  - supported `

composer.json

@@ -37,7 +37,8 @@
         "ext-pdo": "*",
         "ext-mbstring": "*",
         "utopia-php/framework": "0.33.*",
-        "utopia-php/cache": "0.12.*"
+        "utopia-php/cache": "0.12.*",
+        "utopia-php/pools": "0.8.*"
     },
     "require-dev": {
         "fakerphp/faker": "1.23.*",

composer.lock

@@ -20,6 +20,8 @@ abstract class Adapter
 
     protected bool $tenantPerDocument = false;
 
+    protected int $timeout = 0;
+
     protected int $inTransaction = 0;
 
     /**
@@ -275,13 +277,18 @@ public function resetMetadata(): static
      * and an appropriate error or exception will be raised to handle the timeout condition.
      *
      * @param int $milliseconds The timeout value in milliseconds for database queries.
-     * @param string $event     The event the timeout should fire fore
+     * @param string $event     The event the timeout should fire for
      * @return void
      *
      * @throws Exception The provided timeout value must be greater than or equal to 0.
      */
     abstract public function setTimeout(int $milliseconds, string $event = Database::EVENT_ALL): void;
 
+    public function getTimeout(): int
+    {
+        return $this->timeout;
+    }
+
     /**
      * Clears a global timeout for database queries.
      *
@@ -963,22 +970,22 @@ abstract public function getCountOfIndexes(Document $collection): int;
      *
      * @return int
      */
-    abstract public static function getCountOfDefaultAttributes(): int;
+    abstract public function getCountOfDefaultAttributes(): int;
 
     /**
      * Returns number of indexes used by default.
      *
      * @return int
      */
-    abstract public static function getCountOfDefaultIndexes(): int;
+    abstract public function getCountOfDefaultIndexes(): int;
 
     /**
      * Get maximum width, in bytes, allowed for a SQL row
      * Return 0 when no restrictions apply
      *
      * @return int
      */
-    abstract public static function getDocumentSizeLimit(): int;
+    abstract public function getDocumentSizeLimit(): int;
 
     /**
      * Estimate maximum number of bytes required to store a document in $collection.

src/Database/Adapter.php

@@ -2312,6 +2312,8 @@ public function setTimeout(int $milliseconds, string $event = Database::EVENT_AL
             throw new DatabaseException('Timeout must be greater than 0');
         }
 
+        $this->timeout = $milliseconds;
+
         $seconds = $milliseconds / 1000;
 
         $this->before($event, 'timeout', function ($sql) use ($seconds) {

src/Database/Adapter/MariaDB.php

@@ -25,6 +25,9 @@ public function setTimeout(int $milliseconds, string $event = Database::EVENT_AL
         if ($milliseconds <= 0) {
             throw new DatabaseException('Timeout must be greater than 0');
         }
+
+        $this->timeout = $milliseconds;
+
         $this->before($event, 'timeout', function ($sql) use ($milliseconds) {
             return \preg_replace(
                 pattern: '/SELECT/',