diff --git a/pkg/cluster/database.go b/pkg/cluster/database.go index 433e4438e..094af4aca 100644 --- a/pkg/cluster/database.go +++ b/pkg/cluster/database.go @@ -46,7 +46,7 @@ const ( createExtensionSQL = `CREATE EXTENSION IF NOT EXISTS "%s" SCHEMA "%s"` alterExtensionSQL = `ALTER EXTENSION "%s" SET SCHEMA "%s"` - getPublicationsSQL = `SELECT p.pubname, string_agg(pt.schemaname || '.' || pt.tablename, ', ' ORDER BY pt.schemaname, pt.tablename) + getPublicationsSQL = `SELECT p.pubname, COALESCE(string_agg(pt.schemaname || '.' || pt.tablename, ', ' ORDER BY pt.schemaname, pt.tablename), '') AS pubtables FROM pg_publication p LEFT JOIN pg_publication_tables pt ON pt.pubname = p.pubname WHERE p.pubowner = 'postgres'::regrole