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];
 

tests/Functional/Driver/PDO/PgSQL/DBAL6044Test.php

@@ -0,0 +1,51 @@
+<?php
+
+namespace Doctrine\DBAL\Tests\Functional\Driver\PDO\PgSQL;
+
+use Doctrine\DBAL\Schema\Table;
+use Doctrine\DBAL\Tests\FunctionalTestCase;
+use Doctrine\DBAL\Tests\TestUtil;
+
+/** @requires extension pdo_pgsql */
+class DBAL6044Test extends FunctionalTestCase
+{
+    protected function setUp(): void
+    {
+        parent::setUp();
+
+        if (TestUtil::isDriverOneOf('pdo_pgsql')) {
+            return;
+        }
+
+        self::markTestSkipped('This test requires the pdo_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();
+        $validationTable  = $validationSchema->getTable($unloggedTable->getName());
+        $this->assertEquals($unloggedTable->getName(), $validationTable->getName());
+
+        $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
     {