diff options
| author | Noah Misch <noah@leadboat.com> | 2017-11-01 19:16:14 -0700 |
|---|---|---|
| committer | Noah Misch <noah@leadboat.com> | 2017-11-01 19:16:14 -0700 |
| commit | 51f4d3ed7ea40998f66e15830aa84009c0e36e11 (patch) | |
| tree | 1da71c591f139a79ddbda15a442466123c2a5413 /src | |
| parent | c0e2062d3214f6230a0e1eee9236b202bda9221f (diff) | |
| download | postgresql-51f4d3ed7ea40998f66e15830aa84009c0e36e11.tar.gz postgresql-51f4d3ed7ea40998f66e15830aa84009c0e36e11.zip | |
In client support of v10 features, use standard schema handling.
Back-patch to v10. This continues the work of commit
080351466c5a669bf35a323bdec9e296330a5dbb.
Discussion: https://postgr.es/m/CAKOSWN=ds66zLw2SqkLTM8wbXFgDbc_OdkmT3dJfPT2mE5kipA@mail.gmail.com
Diffstat (limited to 'src')
| -rw-r--r-- | src/bin/pg_dump/pg_dump.c | 22 | ||||
| -rw-r--r-- | src/bin/psql/describe.c | 2 |
2 files changed, 16 insertions, 8 deletions
diff --git a/src/bin/pg_dump/pg_dump.c b/src/bin/pg_dump/pg_dump.c index b807df58a85..6d4c28852ce 100644 --- a/src/bin/pg_dump/pg_dump.c +++ b/src/bin/pg_dump/pg_dump.c @@ -3475,12 +3475,15 @@ getPublications(Archive *fout) resetPQExpBuffer(query); + /* Make sure we are in proper schema */ + selectSourceSchema(fout, "pg_catalog"); + /* Get the publications. */ appendPQExpBuffer(query, "SELECT p.tableoid, p.oid, p.pubname, " "(%s p.pubowner) AS rolname, " "p.puballtables, p.pubinsert, p.pubupdate, p.pubdelete " - "FROM pg_catalog.pg_publication p", + "FROM pg_publication p", username_subquery); res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK); @@ -3631,6 +3634,9 @@ getPublicationTables(Archive *fout, TableInfo tblinfo[], int numTables) query = createPQExpBuffer(); + /* Make sure we are in proper schema */ + selectSourceSchema(fout, "pg_catalog"); + for (i = 0; i < numTables; i++) { TableInfo *tbinfo = &tblinfo[i]; @@ -3656,8 +3662,7 @@ getPublicationTables(Archive *fout, TableInfo tblinfo[], int numTables) /* Get the publication membership for the table. */ appendPQExpBuffer(query, "SELECT pr.tableoid, pr.oid, p.pubname " - "FROM pg_catalog.pg_publication_rel pr," - " pg_catalog.pg_publication p " + "FROM pg_publication_rel pr, pg_publication p " "WHERE pr.prrelid = '%u'" " AND p.oid = pr.prpubid", tbinfo->dobj.catId.oid); @@ -3783,13 +3788,16 @@ getSubscriptions(Archive *fout) if (dopt->no_subscriptions || fout->remoteVersion < 100000) return; + /* Make sure we are in proper schema */ + selectSourceSchema(fout, "pg_catalog"); + if (!is_superuser(fout)) { int n; res = ExecuteSqlQuery(fout, "SELECT count(*) FROM pg_subscription " - "WHERE subdbid = (SELECT oid FROM pg_catalog.pg_database" + "WHERE subdbid = (SELECT oid FROM pg_database" " WHERE datname = current_database())", PGRES_TUPLES_OK); n = atoi(PQgetvalue(res, 0, 0)); @@ -3809,8 +3817,8 @@ getSubscriptions(Archive *fout) "(%s s.subowner) AS rolname, " " s.subconninfo, s.subslotname, s.subsynccommit, " " s.subpublications " - "FROM pg_catalog.pg_subscription s " - "WHERE s.subdbid = (SELECT oid FROM pg_catalog.pg_database" + "FROM pg_subscription s " + "WHERE s.subdbid = (SELECT oid FROM pg_database" " WHERE datname = current_database())", username_subquery); res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK); @@ -6830,7 +6838,7 @@ getExtendedStatistics(Archive *fout, TableInfo tblinfo[], int numTables) "oid, " "stxname, " "pg_catalog.pg_get_statisticsobjdef(oid) AS stxdef " - "FROM pg_statistic_ext " + "FROM pg_catalog.pg_statistic_ext " "WHERE stxrelid = '%u' " "ORDER BY stxname", tbinfo->dobj.catId.oid); diff --git a/src/bin/psql/describe.c b/src/bin/psql/describe.c index 986172616ee..b7b978a3614 100644 --- a/src/bin/psql/describe.c +++ b/src/bin/psql/describe.c @@ -5363,7 +5363,7 @@ describeSubscriptions(const char *pattern, bool verbose) "FROM pg_catalog.pg_subscription\n" "WHERE subdbid = (SELECT oid\n" " FROM pg_catalog.pg_database\n" - " WHERE datname = current_database())"); + " WHERE datname = pg_catalog.current_database())"); processSQLNamePattern(pset.db, &buf, pattern, true, false, NULL, "subname", NULL, |