feat(database): add closable connection wrapper for PDO connection (#875)

Author: blackshadev

src/Tempest/Database/src/CachedConnectionInitializer.php

@@ -0,0 +1,35 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Tempest\Database;
+
+use Tempest\Container\Container;
+use Tempest\Container\Initializer;
+use Tempest\Container\Singleton;
+
+/**
+ * Reuses the same connection instance based on a static variable instead of the container.
+ *
+ * Used in testing where each test can have its own container instance.
+ */
+final class CachedConnectionInitializer implements Initializer
+{
+    private static Connection|null $instance = null;
+
+    public function __construct(private readonly ConnectionInitializer $initializer)
+    {
+    }
+
+    #[Singleton]
+    public function initialize(Container $container): Connection
+    {
+        if (self::$instance !== null) {
+            return self::$instance;
+        }
+
+        self::$instance = $this->initializer->initialize($container);
+
+        return self::$instance;
+    }
+}

src/Tempest/Database/src/Connection.php

@@ -0,0 +1,24 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Tempest\Database;
+
+use PDOStatement;
+
+interface Connection
+{
+    public function beginTransaction(): bool;
+
+    public function commit(): bool;
+
+    public function rollback(): bool;
+
+    public function lastInsertId(): false|string;
+
+    public function prepare(string $sql): false|PDOStatement;
+
+    public function close(): void;
+
+    public function connect(): void;
+}

src/Tempest/Database/src/ConnectionInitializer.php

@@ -0,0 +1,23 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Tempest\Database;
+
+use Tempest\Container\Container;
+use Tempest\Container\Initializer;
+use Tempest\Container\Singleton;
+
+final class ConnectionInitializer implements Initializer
+{
+    #[Singleton]
+    public function initialize(Container $container): Connection
+    {
+        $databaseConfig = $container->get(DatabaseConfig::class);
+
+        $connection = new PDOConnection($databaseConfig->connection());
+        $connection->connect();
+
+        return $connection;
+    }
+}

…pest/Database/src/DatabaseConnection.php …e/src/Connections/DatabaseConnection.phpsrc/Tempest/Database/src/DatabaseConnection.php renamed to src/Tempest/Database/src/Connections/DatabaseConnection.php src/Tempest/Database/src/DatabaseConnection.php renamed to src/Tempest/Database/src/Connections/DatabaseConnection.php

@@ -2,8 +2,9 @@
 
 declare(strict_types=1);
 
-namespace Tempest\Database;
+namespace Tempest\Database\Connections;
 
+use Tempest\Database\DatabaseDialect;
 use Tempest\Database\Tables\NamingStrategy;
 
 interface DatabaseConnection

…se/src/DatabaseConnectionInitializer.php …ctions/DatabaseConnectionInitializer.phpsrc/Tempest/Database/src/DatabaseConnectionInitializer.php renamed to src/Tempest/Database/src/Connections/DatabaseConnectionInitializer.php src/Tempest/Database/src/DatabaseConnectionInitializer.php renamed to src/Tempest/Database/src/Connections/DatabaseConnectionInitializer.php

@@ -2,11 +2,12 @@
 
 declare(strict_types=1);
 
-namespace Tempest\Database;
+namespace Tempest\Database\Connections;
 
 use Tempest\Container\Container;
 use Tempest\Container\Initializer;
 use Tempest\Container\Singleton;
+use Tempest\Database\DatabaseConfig;
 
 final class DatabaseConnectionInitializer implements Initializer
 {

src/Tempest/Database/src/Connections/MySqlConnection.php

@@ -5,7 +5,6 @@
 namespace Tempest\Database\Connections;
 
 use SensitiveParameter;
-use Tempest\Database\DatabaseConnection;
 use Tempest\Database\DatabaseDialect;
 use Tempest\Database\Tables\NamingStrategy;
 use Tempest\Database\Tables\PluralizedSnakeCaseStrategy;

src/Tempest/Database/src/Connections/PostgresConnection.php

@@ -5,7 +5,6 @@
 namespace Tempest\Database\Connections;
 
 use SensitiveParameter;
-use Tempest\Database\DatabaseConnection;
 use Tempest\Database\DatabaseDialect;
 use Tempest\Database\Tables\NamingStrategy;
 use Tempest\Database\Tables\PluralizedSnakeCaseStrategy;

src/Tempest/Database/src/Connections/SQLiteConnection.php

@@ -5,7 +5,6 @@
 namespace Tempest\Database\Connections;
 
 use SensitiveParameter;
-use Tempest\Database\DatabaseConnection;
 use Tempest\Database\DatabaseDialect;
 use Tempest\Database\Tables\NamingStrategy;
 use Tempest\Database\Tables\PluralizedSnakeCaseStrategy;

src/Tempest/Database/src/DatabaseConfig.php

@@ -4,6 +4,8 @@
 
 namespace Tempest\Database;
 
+use Tempest\Database\Connections\DatabaseConnection;
+
 final class DatabaseConfig
 {
     private array $migrations = [];

src/Tempest/Database/src/DatabaseDialectInitializer.php

@@ -6,6 +6,7 @@
 
 use Tempest\Container\Container;
 use Tempest\Container\Initializer;
+use Tempest\Database\Connections\DatabaseConnection;
 
 final readonly class DatabaseDialectInitializer implements Initializer
 {