Get Connection Id

src/Database/Adapter.php

@@ -854,6 +854,13 @@ abstract public function getSupportForBatchOperations(): bool;
      */
     abstract public function getSupportForAttributeResizing(): bool;
 
+    /**
+     * Is get connection id supported?
+     *
+     * @return bool
+     */
+    abstract public function getSupportForGetConnectionId(): bool;
+
     /**
      * Get current attribute count from collection document
      *
@@ -1001,4 +1008,11 @@ public function escapeWildcards(string $value): string
      * @throws Exception
      */
     abstract public function increaseDocumentAttribute(string $collection, string $id, string $attribute, int|float $value, string $updatedAt, int|float|null $min = null, int|float|null $max = null): bool;
+
+    /**
+     * Returns the connection ID identifier
+     *
+     * @return string
+     */
+    abstract public function getConnectionId(): string;
 }

src/Database/Adapter/MariaDB.php

@@ -2398,4 +2398,13 @@ protected function processException(PDOException $e): void
 
         throw $e;
     }
+
+    /**
+     * @return string
+     */
+    public function getConnectionId(): string
+    {
+        $stmt = $this->getPDO()->query("SELECT CONNECTION_ID();");
+        return $stmt->fetchColumn();
+    }
 }

src/Database/Adapter/Mongo.php

@@ -1777,6 +1777,16 @@ public function getSupportForBatchOperations(): bool
         return false;
     }
 
+    /**
+     * Is get connection id supported?
+     *
+     * @return bool
+     */
+    public function getSupportForGetConnectionId(): bool
+    {
+        return false;
+    }
+
     /**
      * Get current attribute count from collection document
      *
@@ -1926,4 +1936,9 @@ public function getMaxIndexLength(): int
     {
         return 0;
     }
+
+    public function getConnectionId(): string
+    {
+        return '0';
+    }
 }

src/Database/Adapter/Postgres.php

@@ -2392,4 +2392,13 @@ protected function processException(PDOException $e): void
 
         throw $e;
     }
+
+    /**
+     * @return string
+     */
+    public function getConnectionId(): string
+    {
+        $stmt = $this->getPDO()->query("SELECT pg_backend_pid();");
+        return $stmt->fetchColumn();
+    }
 }

src/Database/Adapter/SQL.php

@@ -387,6 +387,16 @@ public function getSupportForBatchOperations(): bool
         return true;
     }
 
+    /**
+     * Is get connection id supported?
+     *
+     * @return bool
+     */
+    public function getSupportForGetConnectionId(): bool
+    {
+        return true;
+    }
+
     /**
      * Get current attribute count from collection document
      *

src/Database/Adapter/SQLite.php

@@ -897,6 +897,16 @@ public function getSupportForAttributeResizing(): bool
         return false;
     }
 
+    /**
+     * Is get connection id supported?
+     *
+     * @return bool
+     */
+    public function getSupportForGetConnectionId(): bool
+    {
+        return false;
+    }
+
     /**
      * Get SQL Index Type
      *

src/Database/Database.php

@@ -493,6 +493,17 @@ public function silent(callable $callback, array $listeners = null): mixed
         }
     }
 
+    /**
+     * Get getConnection Id
+     *
+     * @return string
+     * @throws Exception
+     */
+    public function getConnectionId(): string
+    {
+        return $this->adapter->getConnectionId();
+    }
+
     /**
      * Skip relationships for all the calls inside the callback
      *

tests/e2e/Adapter/Base.php

@@ -99,6 +99,16 @@ public function testUpdateDeleteCollectionNotFound(): void
         }
     }
 
+    public function testGetCollectionId(): void
+    {
+        if (!static::getDatabase()->getAdapter()->getSupportForGetConnectionId()) {
+            $this->expectNotToPerformAssertions();
+            return;
+        }
+
+        $this->assertIsString(static::getDatabase()->getConnectionId());
+    }
+
     public function testDeleteRelatedCollection(): void
     {
         if (!static::getDatabase()->getAdapter()->getSupportForRelationships()) {