Merge pull request #8 from freezemage0/feature/support_transaction_api

Implemented support for transaction API.

Author: freezemage0

src/Exceptions/DriverException.php

@@ -3,7 +3,12 @@
 namespace Tnapf\Driver\Exceptions;
 
 use Exception;
+use PDOException;
 
 class DriverException extends Exception
 {
+    public static function createFromPdo(PDOException $e): DriverException
+    {
+        return new DriverException($e->getMessage(), $e->getCode());
+    }
 }

src/Interfaces/DriverInterface.php

@@ -2,6 +2,8 @@
 
 namespace Tnapf\Driver\Interfaces;
 
+use Tnapf\Driver\Exceptions\DriverException;
+
 interface DriverInterface
 {
     /**
@@ -34,4 +36,32 @@ public function connect(): void;
      * Disconnect the driver from the database.
      */
     public function disconnect(): void;
+
+    /**
+     * Begins a transactions.
+     *
+     * Some DBMS may create implicit COMMIT on DML queries.
+     *
+     * @throws DriverException on failure.
+     */
+    public function begin(): void;
+
+    /**
+     * Rolls back a transaction.
+     *
+     * @throws DriverException on failure.
+     */
+    public function rollback(): void;
+
+    /**
+     * Commits a transaction.
+     *
+     * @throws DriverException on failure.
+     */
+    public function commit(): void;
+
+    /**
+     * Returns whether a transaction is active.
+     */
+    public function inTransaction(): bool;
 }

src/Interfaces/PreparedQueryInterface.php

@@ -2,20 +2,26 @@
 
 namespace Tnapf\Driver\Interfaces;
 
+use Tnapf\Driver\Exceptions\QueryException;
+
 interface PreparedQueryInterface extends QueryInterface
 {
     /**
      * Bind a value to a named parameter in the prepared statement.
      *
      * @param string $name The name of the parameter.
      * @param mixed $value The value to bind to the parameter.
+     *
+     * @throws QueryException on failure.
      */
     public function bindValue(string $name, mixed $value): void;
 
     /**
      * Bind an array of values to their corresponding named parameters in the prepared statement.
      *
      * @param array $values An associative array of parameter names and their corresponding values.
+     *
+     * @throws QueryException on failure.
      */
     public function bindValues(array $values): void;
 }

src/Interfaces/QueryInterface.php

@@ -2,12 +2,14 @@
 
 namespace Tnapf\Driver\Interfaces;
 
+use Tnapf\Driver\Exceptions\QueryException;
+
 interface QueryInterface
 {
     /**
      * QueryInterface constructor.
      *
-     * @param string $query The SQL query to execute or prepare.
+     * @param string $query           The SQL query to execute or prepare.
      * @param DriverInterface $driver The driver instance to use for this query.
      */
     public function __construct(string $query, DriverInterface $driver);
@@ -16,6 +18,8 @@ public function __construct(string $query, DriverInterface $driver);
      * Execute the query and return a QueryResponseInterface instance.
      *
      * @return QueryResponseInterface The response object containing the results of the query execution.
+     *
+     * @throws QueryException on failure.
      */
     public function execute(): QueryResponseInterface;
 }

src/PDODriver.php

@@ -12,7 +12,6 @@
 class PDODriver implements DriverInterface
 {
     public readonly PDO $pdo;
-    protected static self $instance;
 
     /**
      * @throws DriverException
@@ -49,7 +48,7 @@ public function connect(): void
         try {
             $this->pdo = new PDO($this->dsn, $this->username, $this->password, $this->options);
         } catch (PDOException $e) {
-            throw new DriverException($e->getMessage(), $e->getCode());
+            throw DriverException::createFromPdo($e);
         }
     }
 
@@ -62,4 +61,51 @@ public function isConnected(): bool
     {
         return isset($this->pdo);
     }
+
+    /**
+     * @throws DriverException
+     */
+    public function begin(): void
+    {
+        try {
+            if (!$this->pdo->beginTransaction()) {
+                throw new DriverException('Failed to begin transaction.');
+            }
+        } catch (PDOException $e) {
+            throw DriverException::createFromPdo($e);
+        }
+    }
+
+    /**
+     * @throws DriverException
+     */
+    public function commit(): void
+    {
+        try {
+            if (!$this->pdo->commit()) {
+                throw new DriverException('Failed to commit transaction.');
+            }
+        } catch (PDOException $e) {
+            throw DriverException::createFromPdo($e);
+        }
+    }
+
+    /**
+     * @throws DriverException
+     */
+    public function rollback(): void
+    {
+        try {
+            if (!$this->pdo->rollBack()) {
+                throw new DriverException('Failed to rollback transaction.');
+            }
+        } catch (PDOException $e) {
+            throw DriverException::createFromPdo($e);
+        }
+    }
+
+    public function inTransaction(): bool
+    {
+        return $this->pdo->inTransaction();
+    }
 }