mirror/postgresql
2
0
Fork 0
mirror of https://git.postgresql.org/git/postgresql.git synced 2024-12-27 08:39:28 +08:00
Code Issues Packages Projects Releases Wiki Activity

pg_dump: Refactor dumpDatabase()

Browse Source 
Rearrange the version-dependent pieces in the new more modular style.
This commit is contained in:
Peter Eisentraut 2022-01-04 16:19:48 +01:00
parent dfe67c0e85
commit 56a3e848c7
1 changed files with 13 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
src/bin/pg_dump/pg_dump.c
View File

@ -2779,34 +2779,21 @@ dumpDatabase(Archive *fout)
/* /*
* Fetch the database-level properties for this database. * Fetch the database-level properties for this database.
*/ */
appendPQExpBuffer(dbQry, "SELECT tableoid, oid, datname, "
"datdba, "
"pg_encoding_to_char(encoding) AS encoding, "
"datcollate, datctype, datfrozenxid, "
"datacl, acldefault('d', datdba) AS acldefault, "
"datistemplate, datconnlimit, ");
if (fout->remoteVersion >= 90300) if (fout->remoteVersion >= 90300)
{ appendPQExpBuffer(dbQry, "datminmxid, ");
appendPQExpBuffer(dbQry, "SELECT tableoid, oid, datname, "
"datdba, "
"pg_encoding_to_char(encoding) AS encoding, "
"datcollate, datctype, datfrozenxid, datminmxid, "
"datacl, acldefault('d', datdba) AS acldefault, "
"datistemplate, datconnlimit, "
"(SELECT spcname FROM pg_tablespace t WHERE t.oid = dattablespace) AS tablespace, "
"shobj_description(oid, 'pg_database') AS description "
"FROM pg_database "
"WHERE datname = current_database()");
}
else else
{ appendPQExpBuffer(dbQry, "0 AS datminmxid, ");
appendPQExpBuffer(dbQry, "SELECT tableoid, oid, datname, " appendPQExpBuffer(dbQry,
"datdba, " "(SELECT spcname FROM pg_tablespace t WHERE t.oid = dattablespace) AS tablespace, "
"pg_encoding_to_char(encoding) AS encoding, " "shobj_description(oid, 'pg_database') AS description "
"datcollate, datctype, datfrozenxid, 0 AS datminmxid, " "FROM pg_database "
"datacl, acldefault('d', datdba) AS acldefault, " "WHERE datname = current_database()");
"datistemplate, datconnlimit, "
"(SELECT spcname FROM pg_tablespace t WHERE t.oid = dattablespace) AS tablespace, "
"shobj_description(oid, 'pg_database') AS description "
"FROM pg_database "
"WHERE datname = current_database()");
}
res = ExecuteSqlQueryForSingleRow(fout, dbQry->data); res = ExecuteSqlQueryForSingleRow(fout, dbQry->data);