fix(database): postgres support (#1259)

Author: brendt

.github/workflows/integration-tests.yml

@@ -5,6 +5,10 @@ on:
   workflow_dispatch:
   schedule:
     - cron: '0 0 * * *'
+env:
+  POSTGRES_USER: runner
+  POSTGRES_PASSWORD: ''
+  POSTGRES_DB: postgres
 
 jobs:
   vitest:
@@ -28,7 +32,7 @@ jobs:
         uses: shivammathur/setup-php@v2
         with:
           php-version: ${{ matrix.php }}
-          extensions: dom, curl, libxml, mbstring, pcntl, fileinfo, pdo, sqlite, pdo_sqlite, pdo_mysql, intl, ftp, zip
+          extensions: dom, curl, libxml, mbstring, pcntl, fileinfo, pdo, sqlite, pdo_sqlite, pdo_mysql, pdo_pgsql intl, ftp, zip
           coverage: pcov
 
       - name: Setup Bun
@@ -60,6 +64,9 @@ jobs:
         stability:
           - prefer-stable
           - prefer-lowest
+        exclude:
+          - os: windows-latest
+            database: postgres
 
     name: "Run tests: PHP ${{ matrix.php }} - ${{ matrix.database }} - ${{ matrix.stability }} - ${{ matrix.os }}"
 
@@ -94,7 +101,10 @@ jobs:
         uses: ankane/setup-postgres@v1
 
       - name: Set database config - ${{ matrix.database }}
-        run: php -r "file_exists('tests/Fixtures/Config/database.config.php') || copy('tests/Fixtures/Config/database.${{ matrix.database }}.php', 'tests/Fixtures/Config/database.config.php');"
+        run: php -r "copy('tests/Fixtures/Config/database.${{ matrix.database }}.php', 'tests/Fixtures/Config/database.config.php');"
+
+      - name: Tempest about
+        run: php ./tempest about
 
       - name: List discovered locations
         run: php ./tempest discovery:status

packages/container/src/GenericContainer.php

@@ -30,7 +30,7 @@ public function __construct(
         private ArrayIterator $singletons = new ArrayIterator(),
 
         /** @var ArrayIterator<array-key, class-string> $initializers */
-        private ArrayIterator $initializers = new ArrayIterator(),
+        public ArrayIterator $initializers = new ArrayIterator(),
 
         /** @var ArrayIterator<array-key, class-string> $dynamicInitializers */
         private ArrayIterator $dynamicInitializers = new ArrayIterator(),

packages/database/src/Builder/QueryBuilders/UpdateQueryBuilder.php

@@ -34,7 +34,7 @@ public function __construct(
         );
     }
 
-    public function execute(mixed ...$bindings): Id
+    public function execute(mixed ...$bindings): ?Id
     {
         return $this->build()->execute(...$bindings);
     }

packages/database/src/Config/DatabaseDialect.php

@@ -4,6 +4,8 @@
 
 namespace Tempest\Database\Config;
 
+use PDOException;
+
 enum DatabaseDialect: string
 {
     case SQLITE = 'sqlite';
@@ -18,4 +20,13 @@ public function tableNotFoundCode(): string
             self::SQLITE => 'HY000',
         };
     }
+
+    public function isTableNotFoundError(PDOException $exception): bool
+    {
+        return match ($this) {
+            self::MYSQL => $exception->getCode() === '42S02' && str_contains($exception->getMessage(), 'table'),
+            self::SQLITE => $exception->getCode() === 'HY000' && str_contains($exception->getMessage(), 'table'),
+            self::POSTGRESQL => $exception->getCode() === '42P01' && str_contains($exception->getMessage(), 'relation'),
+        };
+    }
 }

packages/database/src/Config/PostgresConfig.php

@@ -32,7 +32,7 @@ public function __construct(
         #[SensitiveParameter]
         public string $port = '5432',
         #[SensitiveParameter]
-        public string $username = '',
+        public string $username = 'postgres',
         #[SensitiveParameter]
         public string $password = '',
         #[SensitiveParameter]

packages/database/src/Connection/CachedConnectionInitializer.php

@@ -16,7 +16,7 @@ public function rollback(): bool;
 
     public function lastInsertId(): false|string;
 
-    public function prepare(string $sql): false|PDOStatement;
+    public function prepare(string $sql): PDOStatement;
 
     public function close(): void;
 

packages/database/src/Connection/Connection.php

@@ -8,6 +8,7 @@
 use PDOStatement;
 use Tempest\Database\Config\DatabaseConfig;
 use Tempest\Database\Exceptions\ConnectionClosed;
+use Throwable;
 
 final class PDOConnection implements Connection
 {
@@ -53,13 +54,37 @@ public function lastInsertId(): false|string
         return $this->pdo->lastInsertId();
     }
 
-    public function prepare(string $sql): false|PDOStatement
+    public function prepare(string $sql): PDOStatement
     {
         if ($this->pdo === null) {
             throw new ConnectionClosed();
         }
 
-        return $this->pdo->prepare($sql);
+        $statement = $this->pdo->prepare($sql);
+
+        if ($statement === false) {
+            throw new ConnectionClosed();
+        }
+
+        return $statement;
+    }
+
+    public function ping(): bool
+    {
+        try {
+            $statement = $this->prepare('SELECT 1');
+            $statement->execute();
+
+            return true;
+        } catch (Throwable) {
+            return false;
+        }
+    }
+
+    public function reconnect(): void
+    {
+        $this->close();
+        $this->connect();
     }
 
     public function close(): void
@@ -74,9 +99,9 @@ public function connect(): void
         }
 
         $this->pdo = new PDO(
-            $this->config->dsn,
-            $this->config->username,
-            $this->config->password,
+            dsn: $this->config->dsn,
+            username: $this->config->username,
+            password: $this->config->password,
         );
     }
 }

packages/database/src/Connection/PDOConnection.php

@@ -8,7 +8,7 @@ interface Database
 {
     public function execute(Query $query): void;
 
-    public function getLastInsertId(): Id;
+    public function getLastInsertId(): ?Id;
 
     public function fetch(Query $query): array;
 

packages/database/src/Database.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace Tempest\Database;
+
+use Tempest\Container\Container;
+use Tempest\Container\Initializer;
+use Tempest\Database\Config\DatabaseConfig;
+use Tempest\Database\Config\DatabaseDialect;
+
+final class DatabaseDialectInitializer implements Initializer
+{
+    public function initialize(Container $container): DatabaseDialect
+    {
+        return $container->get(DatabaseConfig::class)->dialect;
+    }
+}