Add introspection for unlogged PostgreSQL tables

f-lombardo · Jun 6, 2023 · 3378413 · 3378413
1 parent 5402a56
commit 3378413
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/src/Schema/PostgreSQLSchemaManager.php b/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

diff --git a/tests/Functional/Driver/DBAL6044Test.php b/tests/Functional/Driver/DBAL6044Test.php
@@ -32,9 +32,11 @@ public function testUnloggedTables(): void
 
         $schemaManager = $this->connection->createSchemaManager();
 
-        $validationSchema = $schemaManager->introspectSchema();
-        $validationTable  = $validationSchema->getTable($unloggedTable->getName());
-        $this->assertEquals($unloggedTable->getName(), $validationTable->getName());
+        $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);