Added checking of available columns when receiving a subscription from the database (#437) (#440)

Co-authored-by: aleksvagachev <[email protected]>
(cherry picked from commit 5fa5334)

Co-authored-by: Aleks Vagachev <[email protected]>

Author: patchback[bot]

Diff for: changelogs/fragments/0-postgresql_info.yml

@@ -0,0 +1,2 @@
+minor_changes:
+- postgresql_info - when getting information about subscriptions, check the list of available columns in the pg_subscription table (https://github.com/ansible-collections/community.postgresql/issues/429).

Diff for: plugins/modules/postgresql_info.py

@@ -281,6 +281,8 @@
           - Information about replication subscriptions (available for PostgreSQL 10 and higher)
             U(https://www.postgresql.org/docs/current/logical-replication-subscription.html).
           - Content depends on PostgreSQL server version.
+          - The return values for the superuser and the normal user may differ
+            U(https://www.postgresql.org/docs/current/catalog-pg-subscription.html).
           returned: if configured
           type: dict
           sample:
@@ -679,12 +681,19 @@ def get_pub_info(self):
 
     def get_subscr_info(self):
         """Get subscription statistics."""
-        query = ("SELECT s.*, r.rolname AS ownername, d.datname AS dbname "
+        columns_sub_table = ("SELECT column_name "
+                             "FROM information_schema.columns "
+                             "WHERE table_schema = 'pg_catalog' "
+                             "AND table_name = 'pg_subscription'")
+        columns_result = self.__exec_sql(columns_sub_table)
+        columns = ", ".join(["s.%s" % column[0] for column in columns_result])
+
+        query = ("SELECT %s, r.rolname AS ownername, d.datname AS dbname "
                  "FROM pg_catalog.pg_subscription s "
                  "JOIN pg_catalog.pg_database d "
                  "ON s.subdbid = d.oid "
                  "JOIN pg_catalog.pg_roles AS r "
-                 "ON s.subowner = r.oid")
+                 "ON s.subowner = r.oid" % columns)
 
         result = self.__exec_sql(query)