Add DbConnection adapters

Author: antonkomarev

src/DbConnection/DbConnectionInterface.php

@@ -0,0 +1,24 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Cog\DbLocker\DbConnection;
+
+interface DbConnectionInterface
+{
+    /**
+     * Execute a SQL query and return the first column of the first row.
+     *
+     * @param string $sql The SQL query to execute
+     * @param array<string, mixed> $parameters Parameters to bind to the query
+     * @return mixed The value from the first column of the first row
+     */
+    public function executeAndFetchColumn(string $sql, array $parameters = []): mixed;
+
+    /**
+     * Check if the connection is currently inside a transaction.
+     *
+     * @return bool True if inside a transaction, false otherwise
+     */
+    public function isInTransaction(): bool;
+}

src/DbConnection/DoctrineDbConnection.php

@@ -0,0 +1,50 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Cog\DbLocker\DbConnection;
+
+use Doctrine\DBAL\Connection;
+use Doctrine\DBAL\Exception;
+use RuntimeException;
+
+/**
+ * Doctrine DBAL adapter for unified database connection interface.
+ *
+ * This adapter wraps a Doctrine DBAL Connection instance and provides
+ * a consistent interface for database operations across different database drivers.
+ */
+final class DoctrineDbConnection implements
+    DbConnectionInterface
+{
+    public function __construct(
+        private Connection $connection,
+    ) {}
+
+    /**
+     * @inheritDoc
+     */
+    public function executeAndFetchColumn(string $sql, array $parameters = []): mixed
+    {
+        try {
+            return $this->connection->fetchOne($sql, $parameters);
+        } catch (Exception $e) {
+            throw new RuntimeException(
+                sprintf(
+                    'Doctrine DBAL error while executing SQL query: %s. Error: %s',
+                    $sql,
+                    $e->getMessage(),
+                ),
+                previous: $e,
+            );
+        }
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function isInTransaction(): bool
+    {
+        return $this->connection->isTransactionActive();
+    }
+}

src/DbConnection/EloquentDbConnection.php

@@ -0,0 +1,62 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Cog\DbLocker\DbConnection;
+
+use Illuminate\Database\Connection;
+use Illuminate\Database\QueryException;
+use RuntimeException;
+
+/**
+ * Eloquent Database adapter for unified database connection interface.
+ *
+ * This adapter wraps an Illuminate\Database\Connection instance and provides
+ * a consistent interface for database operations across different database drivers.
+ */
+final class EloquentDbConnection implements
+    DbConnectionInterface
+{
+    public function __construct(
+        private Connection $connection,
+    ) {}
+
+    /**
+     * @inheritDoc
+     */
+    public function executeAndFetchColumn(string $sql, array $parameters = []): mixed
+    {
+        try {
+            // Convert named parameters to positional parameters for Eloquent
+            $bindings = array_values($parameters);
+
+            $result = $this->connection->selectOne($sql, $bindings);
+
+            if ($result === null) {
+                return null;
+            }
+
+            // Convert stdClass to array and get first value
+            $resultArray = (array)$result;
+
+            return reset($resultArray) ?: null;
+        } catch (QueryException $e) {
+            throw new RuntimeException(
+                sprintf(
+                    'Eloquent Database error while executing SQL query: %s. Error: %s',
+                    $sql,
+                    $e->getMessage(),
+                ),
+                previous: $e,
+            );
+        }
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function isInTransaction(): bool
+    {
+        return $this->connection->transactionLevel() > 0;
+    }
+}

src/DbConnection/PdoDbConnection.php

@@ -0,0 +1,99 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Cog\DbLocker\DbConnection;
+
+use PDO;
+use PDOStatement;
+use RuntimeException;
+
+/**
+ * PDO adapter for unified database connection interface.
+ *
+ * This adapter wraps a PDO instance and provides a consistent interface
+ * for database operations across different database drivers.
+ */
+final class PdoDbConnection implements
+    DbConnectionInterface
+{
+    public function __construct(
+        private PDO $pdo,
+    ) {}
+
+    /**
+     * @inheritDoc
+     */
+    public function executeAndFetchColumn(string $sql, array $parameters = []): mixed
+    {
+        $statement = $this->prepareAndExecute($sql, $parameters);
+
+        $result = $statement->fetchColumn(0);
+
+        // PDO fetchColumn returns false when no rows are found
+        // We need to distinguish between false as a value and no result
+        if ($result === false && $statement->rowCount() === 0) {
+            return null;
+        }
+
+        return $result;
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function isInTransaction(): bool
+    {
+        return $this->pdo->inTransaction();
+    }
+
+    /**
+     * Prepare and execute a SQL statement with parameters.
+     *
+     * @param string $sql The SQL query to execute
+     * @param array<string, mixed> $parameters Parameters to bind to the query
+     * @return PDOStatement The executed statement
+     * @throws RuntimeException If statement preparation or execution fails
+     */
+    private function prepareAndExecute(string $sql, array $parameters): PDOStatement
+    {
+        try {
+            $statement = $this->pdo->prepare($sql);
+
+            if ($statement === false) {
+                $errorInfo = $this->pdo->errorInfo();
+                throw new RuntimeException(
+                    sprintf(
+                        'Failed to prepare SQL statement: %s. Error: %s',
+                        $sql,
+                        $errorInfo[2] ?? 'Unknown error',
+                    ),
+                );
+            }
+
+            $success = $statement->execute($parameters);
+
+            if (!$success) {
+                $errorInfo = $statement->errorInfo();
+                throw new RuntimeException(
+                    sprintf(
+                        'Failed to execute SQL statement: %s. Error: %s',
+                        $sql,
+                        $errorInfo[2] ?? 'Unknown error',
+                    ),
+                );
+            }
+
+            return $statement;
+        } catch (\PDOException $e) {
+            throw new RuntimeException(
+                sprintf(
+                    'PDO error while executing SQL statement: %s. Error: %s',
+                    $sql,
+                    $e->getMessage(),
+                ),
+                previous: $e,
+            );
+        }
+    }
+}