List only permanent tables (#113)

shayonj · Apr 13, 2024 · 8f33089 · 8f33089
1 parent 606f26b
commit 8f33089
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/lib/pg_easy_replicate/helper.rb b/lib/pg_easy_replicate/helper.rb
@@ -88,10 +88,12 @@ def list_all_tables(schema:, conn_string:)
       Query
         .run(
           query:
-            "SELECT table_name
-             FROM information_schema.tables
-             WHERE table_schema = '#{schema}' AND
-               table_type = 'BASE TABLE'
+            "SELECT c.relname::information_schema.sql_identifier AS table_name
+             FROM pg_namespace n
+               JOIN pg_class c ON n.oid = c.relnamespace
+             WHERE c.relkind = 'r'
+               AND c.relpersistence = 'p'
+               AND n.nspname::information_schema.sql_identifier = '#{schema}'
              ORDER BY table_name",
           connection_url: conn_string,
           user: db_user(conn_string),