Add support for unlogged tables in PostgreSQL

src/Platforms/PostgreSQLPlatform.php

@@ -821,7 +821,9 @@ protected function _getCreateTableSQL($name, array $columns, array $options = []
             $queryFields .= ', PRIMARY KEY(' . implode(', ', $keyColumns) . ')';
         }
 
-        $query = 'CREATE TABLE ' . $name . ' (' . $queryFields . ')';
+        $unlogged = isset($options['unlogged']) && $options['unlogged'] === true ? ' UNLOGGED' : '';
+
+        $query = 'CREATE' . $unlogged . ' TABLE ' . $name . ' (' . $queryFields . ')';
 
         $sql = [$query];
 

src/Schema/PostgreSQLSchemaManager.php

@@ -733,6 +733,7 @@ protected function fetchTableOptionsByTable(string $databaseName, ?string $table
     {
         $sql = <<<'SQL'
 SELECT c.relname,
+       CASE c.relpersistence WHEN 'u' THEN true ELSE false END as unlogged,
        obj_description(c.oid, 'pg_class') AS comment
 FROM pg_class c
      INNER JOIN pg_namespace n

tests/Functional/Driver/DBAL6044Test.php

@@ -0,0 +1,52 @@
+<?php
+
+namespace Doctrine\DBAL\Tests\Functional\Driver;
+
+use Doctrine\DBAL\Schema\Table;
+use Doctrine\DBAL\Tests\FunctionalTestCase;
+use Doctrine\DBAL\Tests\TestUtil;
+
+class DBAL6044Test extends FunctionalTestCase
+{
+    protected function setUp(): void
+    {
+        parent::setUp();
+
+        if (TestUtil::isDriverOneOf('pdo_pgsql', 'pgsql')) {
+            return;
+        }
+
+        self::markTestSkipped('This test requires the pdo_pgsql or the pgsql driver.');
+    }
+
+    public function testUnloggedTables(): void
+    {
+        $unloggedTable = new Table('my_unlogged');
+        $unloggedTable->addOption('unlogged', true);
+        $unloggedTable->addColumn('foo', 'string');
+        $this->dropAndCreateTable($unloggedTable);
+
+        $loggedTable = new Table('my_logged');
+        $loggedTable->addColumn('foo', 'string');
+        $this->dropAndCreateTable($loggedTable);
+
+        $schemaManager = $this->connection->createSchemaManager();
+
+        $validationSchema        = $schemaManager->introspectSchema();
+        $validationUnloggedTable = $validationSchema->getTable($unloggedTable->getName());
+        $this->assertTrue($validationUnloggedTable->getOption('unlogged'));
+        $validationLoggedTable = $validationSchema->getTable($loggedTable->getName());
+        $this->assertFalse($validationLoggedTable->getOption('unlogged'));
+
+        $sql  = 'SELECT relpersistence FROM pg_class WHERE relname = ?';
+        $stmt = $this->connection->prepare($sql);
+
+        $stmt->bindValue(1, $unloggedTable->getName());
+        $unloggedTablePersistenceType = $stmt->executeQuery()->fetchOne();
+        $this->assertEquals('u', $unloggedTablePersistenceType);
+
+        $stmt->bindValue(1, $loggedTable->getName());
+        $loggedTablePersistenceType = $stmt->executeQuery()->fetchOne();
+        $this->assertEquals('p', $loggedTablePersistenceType);
+    }
+}

tests/Platforms/PostgreSQLPlatformTest.php

@@ -187,6 +187,18 @@ public function testGenerateTableWithAutoincrement(): void
         );
     }
 
+    public function testGenerateUnloggedTable(): void
+    {
+        $table = new Table('mytable');
+        $table->addOption('unlogged', true);
+        $table->addColumn('foo', 'string');
+
+        self::assertEquals(
+            ['CREATE UNLOGGED TABLE mytable (foo VARCHAR(255) NOT NULL)'],
+            $this->platform->getCreateTableSQL($table),
+        );
+    }
+
     /** @return mixed[][] */
     public static function serialTypes(): iterable
     {