always return union for original statement as well

toluaina · Apr 26, 2021 · d68e695 · d68e695
1 parent 77e12b5
commit d68e695
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/pgsync/base.py b/pgsync/base.py
@@ -539,7 +539,7 @@ def _foreign_key_view_statement(
             table_constraints.c.table_name
         )
 
-        unions = []
+        unions = [statement]
         if FOREIGN_KEY_VIEWNAME in views:
             values = self.fetchall(sa.select([
                 sa.column('table_name'),
@@ -580,10 +580,7 @@ def _foreign_key_view_statement(
                 )
             )
 
-        if unions:
-            statement = sa.union(*unions)
-
-        return statement
+        return sa.union(*unions)
 
     def create_views(self, schema, tables, user_defined_fkey_tables):