21 #include "catalog/pg_authid_d.h"
33 #define PGDUMP_VERSIONSTR "pg_dump (PostgreSQL) " PG_VERSION "\n"
44 #define SH_PREFIX rolename
45 #define SH_ELEMENT_TYPE RoleNameEntry
46 #define SH_KEY_TYPE char *
47 #define SH_KEY rolename
48 #define SH_HASH_KEY(tb, key) hash_string_pointer(key)
49 #define SH_EQUAL(tb, a, b) (strcmp(a, b) == 0)
51 #define SH_GET_HASH(tb, a) (a)->hashval
52 #define SH_SCOPE static inline
53 #define SH_RAW_ALLOCATOR pg_malloc0
58 static void help(
void);
72 const char *catalog_name,
Oid objectId,
73 const char *objtype,
const char *objname,
77 const char *
pgport,
const char *pguser,
78 trivalue prompt_password,
bool fail_on_error);
115 #define PG_AUTHID "pg_authid"
116 #define PG_ROLES "pg_roles "
124 #define exit_nicely(code) exit(code)
129 static struct option long_options[] = {
188 char *use_role = NULL;
189 const char *dumpencoding = NULL;
191 bool data_only =
false;
192 bool globals_only =
false;
193 bool roles_only =
false;
194 bool tablespaces_only =
false;
197 const char *std_strings;
209 if (strcmp(argv[1],
"--help") == 0 || strcmp(argv[1],
"-?") == 0)
214 if (strcmp(argv[1],
"--version") == 0 || strcmp(argv[1],
"-V") == 0)
216 puts(
"pg_dumpall (PostgreSQL) " PG_VERSION);
230 pg_fatal(
"program \"%s\" is needed by %s but was not found in the same directory as \"%s\"",
233 pg_fatal(
"program \"%s\" was found by \"%s\" but was not the same version as %s",
239 while ((
c =
getopt_long(argc, argv,
"acd:E:f:gh:l:Op:rsS:tU:vwWx", long_options, &optindex)) != -1)
302 tablespaces_only =
true;
373 pg_log_error(
"too many command-line arguments (first is \"%s\")",
380 (globals_only || roles_only || tablespaces_only))
382 pg_log_error(
"option --exclude-database cannot be used together with -g/--globals-only, -r/--roles-only, or -t/--tablespaces-only");
388 if (globals_only && roles_only)
390 pg_log_error(
"options -g/--globals-only and -r/--roles-only cannot be used together");
395 if (globals_only && tablespaces_only)
397 pg_log_error(
"options -g/--globals-only and -t/--tablespaces-only cannot be used together");
403 pg_fatal(
"option --if-exists requires option -c/--clean");
405 if (roles_only && tablespaces_only)
407 pg_log_error(
"options -r/--roles-only and -t/--tablespaces-only cannot be used together");
466 prompt_password,
false);
469 pg_fatal(
"could not connect to database \"%s\"", pgdb);
474 prompt_password,
false);
477 prompt_password,
true);
481 pg_log_error(
"could not connect to databases \"postgres\" or \"template1\"\n"
482 "Please specify an alternative database.");
501 pg_fatal(
"could not open output file \"%s\": %m",
513 pg_fatal(
"invalid client encoding \"%s\" specified",
540 fprintf(
OPF,
"--\n-- PostgreSQL database cluster dump\n--\n\n");
552 fprintf(
OPF,
"SET default_transaction_read_only = off;\n\n");
557 fprintf(
OPF,
"SET standard_conforming_strings = %s;\n", std_strings);
558 if (strcmp(std_strings,
"off") == 0)
559 fprintf(
OPF,
"SET escape_string_warning = off;\n");
572 if (!globals_only && !roles_only && !tablespaces_only)
578 if (!tablespaces_only)
586 if (!tablespaces_only)
604 if (!globals_only && !roles_only && !tablespaces_only)
611 fprintf(
OPF,
"--\n-- PostgreSQL database cluster dump complete\n--\n\n");
629 printf(
_(
"%s extracts a PostgreSQL database cluster into an SQL script file.\n\n"),
progname);
633 printf(
_(
"\nGeneral options:\n"));
634 printf(
_(
" -f, --file=FILENAME output file name\n"));
635 printf(
_(
" -v, --verbose verbose mode\n"));
636 printf(
_(
" -V, --version output version information, then exit\n"));
637 printf(
_(
" --lock-wait-timeout=TIMEOUT fail after waiting TIMEOUT for a table lock\n"));
638 printf(
_(
" -?, --help show this help, then exit\n"));
639 printf(
_(
"\nOptions controlling the output content:\n"));
640 printf(
_(
" -a, --data-only dump only the data, not the schema\n"));
641 printf(
_(
" -c, --clean clean (drop) databases before recreating\n"));
642 printf(
_(
" -E, --encoding=ENCODING dump the data in encoding ENCODING\n"));
643 printf(
_(
" -g, --globals-only dump only global objects, no databases\n"));
644 printf(
_(
" -O, --no-owner skip restoration of object ownership\n"));
645 printf(
_(
" -r, --roles-only dump only roles, no databases or tablespaces\n"));
646 printf(
_(
" -s, --schema-only dump only the schema, no data\n"));
647 printf(
_(
" -S, --superuser=NAME superuser user name to use in the dump\n"));
648 printf(
_(
" -t, --tablespaces-only dump only tablespaces, no databases or roles\n"));
649 printf(
_(
" -x, --no-privileges do not dump privileges (grant/revoke)\n"));
650 printf(
_(
" --binary-upgrade for use by upgrade utilities only\n"));
651 printf(
_(
" --column-inserts dump data as INSERT commands with column names\n"));
652 printf(
_(
" --disable-dollar-quoting disable dollar quoting, use SQL standard quoting\n"));
653 printf(
_(
" --disable-triggers disable triggers during data-only restore\n"));
654 printf(
_(
" --exclude-database=PATTERN exclude databases whose name matches PATTERN\n"));
655 printf(
_(
" --extra-float-digits=NUM override default setting for extra_float_digits\n"));
656 printf(
_(
" --if-exists use IF EXISTS when dropping objects\n"));
657 printf(
_(
" --inserts dump data as INSERT commands, rather than COPY\n"));
658 printf(
_(
" --load-via-partition-root load partitions via the root table\n"));
659 printf(
_(
" --no-comments do not dump comments\n"));
660 printf(
_(
" --no-publications do not dump publications\n"));
661 printf(
_(
" --no-role-passwords do not dump passwords for roles\n"));
662 printf(
_(
" --no-security-labels do not dump security label assignments\n"));
663 printf(
_(
" --no-subscriptions do not dump subscriptions\n"));
664 printf(
_(
" --no-sync do not wait for changes to be written safely to disk\n"));
665 printf(
_(
" --no-table-access-method do not dump table access methods\n"));
666 printf(
_(
" --no-tablespaces do not dump tablespace assignments\n"));
667 printf(
_(
" --no-toast-compression do not dump TOAST compression methods\n"));
668 printf(
_(
" --no-unlogged-table-data do not dump unlogged table data\n"));
669 printf(
_(
" --on-conflict-do-nothing add ON CONFLICT DO NOTHING to INSERT commands\n"));
670 printf(
_(
" --quote-all-identifiers quote all identifiers, even if not key words\n"));
671 printf(
_(
" --rows-per-insert=NROWS number of rows per INSERT; implies --inserts\n"));
672 printf(
_(
" --use-set-session-authorization\n"
673 " use SET SESSION AUTHORIZATION commands instead of\n"
674 " ALTER OWNER commands to set ownership\n"));
676 printf(
_(
"\nConnection options:\n"));
677 printf(
_(
" -d, --dbname=CONNSTR connect using connection string\n"));
678 printf(
_(
" -h, --host=HOSTNAME database server host or socket directory\n"));
679 printf(
_(
" -l, --database=DBNAME alternative default database\n"));
680 printf(
_(
" -p, --port=PORT database server port number\n"));
681 printf(
_(
" -U, --username=NAME connect as specified database user\n"));
682 printf(
_(
" -w, --no-password never prompt for password\n"));
683 printf(
_(
" -W, --password force password prompt (should happen automatically)\n"));
684 printf(
_(
" --role=ROLENAME do SET ROLE before dump\n"));
686 printf(
_(
"\nIf -f/--file is not used, then the SQL script will be written to the standard\n"
688 printf(
_(
"Report bugs to <%s>.\n"), PACKAGE_BUGREPORT);
689 printf(
_(
"%s home page: <%s>\n"), PACKAGE_NAME, PACKAGE_URL);
708 "WHERE rolname !~ '^pg_' "
725 const char *rolename;
767 "SELECT oid, rolname, rolsuper, rolinherit, "
768 "rolcreaterole, rolcreatedb, "
769 "rolcanlogin, rolconnlimit, rolpassword, "
770 "rolvaliduntil, rolreplication, rolbypassrls, "
771 "pg_catalog.shobj_description(oid, '%s') as rolcomment, "
772 "rolname = current_user AS is_current_user "
774 "WHERE rolname !~ '^pg_' "
778 "SELECT oid, rolname, rolsuper, rolinherit, "
779 "rolcreaterole, rolcreatedb, "
780 "rolcanlogin, rolconnlimit, rolpassword, "
781 "rolvaliduntil, rolreplication, rolbypassrls, "
782 "pg_catalog.shobj_description(oid, '%s') as rolcomment, "
783 "rolname = current_user AS is_current_user "
788 "SELECT oid, rolname, rolsuper, rolinherit, "
789 "rolcreaterole, rolcreatedb, "
790 "rolcanlogin, rolconnlimit, rolpassword, "
791 "rolvaliduntil, rolreplication, "
792 "false as rolbypassrls, "
793 "pg_catalog.shobj_description(oid, '%s') as rolcomment, "
794 "rolname = current_user AS is_current_user "
820 const char *rolename;
826 if (strncmp(rolename,
"pg_", 3) == 0)
839 "SELECT pg_catalog.binary_upgrade_set_next_pg_authid_oid('%u'::pg_catalog.oid);\n\n",
929 fprintf(
OPF,
"\n--\n-- User Configurations\n--\n");
958 bool dump_grant_options;
959 int i_inherit_option;
978 "um.rolname AS member, "
979 "ug.oid AS grantorid, "
980 "ug.rolname AS grantor, "
982 if (dump_grant_options)
985 "LEFT JOIN %s ur on ur.oid = a.roleid "
986 "LEFT JOIN %s um on um.oid = a.member "
987 "LEFT JOIN %s ug on ug.oid = a.grantor "
988 "WHERE NOT (ur.rolname ~ '^pg_' AND um.rolname ~ '^pg_')"
995 fprintf(
OPF,
"--\n-- Role memberships\n--\n\n");
1012 while (start < total)
1018 int prev_remaining = 0;
1022 for (end = start; end < total; ++end)
1027 if (strcmp(role, otherrole) != 0)
1050 pg_log_error(
"could not find a legal dump ordering for memberships in role \"%s\"",
1058 for (
i = start;
i < end; ++
i)
1068 if (done[
i - start])
1075 if (dump_grant_options)
1084 if (dump_grantors &&
1085 atooid(grantorid) != BOOTSTRAP_SUPERUSERID &&
1086 rolename_lookup(ht, grantor) == NULL)
1090 done[
i - start] =
true;
1098 rolename_insert(ht, member, &found);
1106 if (dump_grant_options)
1110 if (optbuf->
data[0] !=
'\0')
1119 if (optbuf->
data[0] !=
'\0')
1123 if (optbuf->
data[0] !=
'\0')
1131 rolename_destroy(ht);
1160 "pg_catalog.pg_get_userbyid(" CppAsString2(BOOTSTRAP_SUPERUSERID)
") AS parowner, "
1162 "pg_catalog.acldefault('p', " CppAsString2(BOOTSTRAP_SUPERUSERID)
") AS acldefault "
1163 "FROM pg_catalog.pg_parameter_acl "
1167 fprintf(
OPF,
"--\n-- Role privileges on configuration parameters\n--\n\n");
1185 pg_log_error(
"could not parse ACL list (%s) for parameter \"%s\"",
1216 "FROM pg_catalog.pg_tablespace "
1217 "WHERE spcname !~ '^pg_' "
1221 fprintf(
OPF,
"--\n-- Drop tablespaces\n--\n\n");
1251 "pg_catalog.pg_get_userbyid(spcowner) AS spcowner, "
1252 "pg_catalog.pg_tablespace_location(oid), "
1253 "spcacl, acldefault('t', spcowner) AS acldefault, "
1254 "array_to_string(spcoptions, ', '),"
1255 "pg_catalog.shobj_description(oid, 'pg_tablespace') "
1256 "FROM pg_catalog.pg_tablespace "
1257 "WHERE spcname !~ '^pg_' "
1282 appendPQExpBuffer(
buf,
"SELECT pg_catalog.binary_upgrade_set_next_pg_tablespace_oid('%u'::pg_catalog.oid);\n", spcoid);
1301 if (spcoptions && spcoptions[0] !=
'\0')
1303 fspcname, spcoptions);
1312 pg_log_error(
"could not parse ACL list (%s) for tablespace \"%s\"",
1318 if (!
no_comments && spccomment && spccomment[0] !=
'\0')
1327 "TABLESPACE", spcname,
1356 "FROM pg_database d "
1357 "WHERE datallowconn AND datconnlimit != -2 "
1358 "ORDER BY datname");
1361 fprintf(
OPF,
"--\n-- Drop databases (except postgres and template1)\n--\n\n");
1372 if (strcmp(
dbname,
"template1") != 0 &&
1373 strcmp(
dbname,
"template0") != 0 &&
1374 strcmp(
dbname,
"postgres") != 0)
1398 "WHERE setdatabase = 0 AND setrole = "
1399 "(SELECT oid FROM %s WHERE rolname = ",
1435 if (patterns->
head == NULL)
1451 "SELECT datname FROM pg_catalog.pg_database n\n");
1453 false, NULL,
"datname", NULL, NULL, NULL,
1458 pg_log_error(
"improper qualified name (too many dotted names): %s",
1499 "FROM pg_database d "
1500 "WHERE datallowconn AND datconnlimit != -2 "
1501 "ORDER BY (datname <> 'template1'), datname");
1509 const char *create_opts;
1513 if (strcmp(
dbname,
"template0") == 0)
1535 if (strcmp(
dbname,
"template1") == 0 || strcmp(
dbname,
"postgres") == 0)
1538 create_opts =
"--clean --create";
1547 create_opts =
"--create";
1560 pg_fatal(
"could not re-open the output file \"%s\": %m",
1608 ret = system(cmd.
data);
1629 const char *objtype,
const char *objname,
1655 const char *
pghost,
const char *
pgport,
const char *pguser,
1656 trivalue prompt_password,
bool fail_on_error)
1660 const char *remoteversion_str;
1662 const char **keywords = NULL;
1663 const char **
values = NULL;
1678 char *err_msg = NULL;
1694 if (conn_opts == NULL)
1697 for (conn_opt = conn_opts; conn_opt->
keyword != NULL; conn_opt++)
1699 if (conn_opt->
val != NULL && conn_opt->
val[0] !=
'\0' &&
1700 strcmp(conn_opt->
keyword,
"dbname") != 0)
1704 keywords =
pg_malloc0((argcount + 1) *
sizeof(*keywords));
1707 for (conn_opt = conn_opts; conn_opt->
keyword != NULL; conn_opt++)
1709 if (conn_opt->
val != NULL && conn_opt->
val[0] !=
'\0' &&
1710 strcmp(conn_opt->
keyword,
"dbname") != 0)
1720 keywords =
pg_malloc0((argcount + 1) *
sizeof(*keywords));
1726 keywords[
i] =
"host";
1732 keywords[
i] =
"port";
1738 keywords[
i] =
"user";
1744 keywords[
i] =
"password";
1750 keywords[
i] =
"dbname";
1754 keywords[
i] =
"fallback_application_name";
1767 prompt_password !=
TRI_NO)
1804 if (!remoteversion_str)
1805 pg_fatal(
"could not get server version");
1808 pg_fatal(
"could not parse server version \"%s\"",
1811 my_version = PG_VERSION_NUM;
1821 pg_log_error(
"aborting because of server version mismatch");
1823 remoteversion_str,
progname, PG_VERSION);
1848 bool firstkeyword =
true;
1851 for (
i = 0; keywords[
i] != NULL;
i++)
1853 if (strcmp(keywords[
i],
"dbname") == 0 ||
1854 strcmp(keywords[
i],
"password") == 0 ||
1855 strcmp(keywords[
i],
"fallback_application_name") == 0)
1860 firstkeyword =
false;
1924 time_t
now = time(NULL);
1936 unsigned char *ss = (
unsigned char *) s;
Acl * acldefault(ObjectType objtype, Oid ownerId)
Datum now(PG_FUNCTION_ARGS)
static Datum values[MAXATTR]
#define PG_TEXTDOMAIN(domain)
int find_my_exec(const char *argv0, char *retpath)
void set_pglocale_pgservice(const char *argv0, const char *app)
int find_other_exec(const char *argv0, const char *target, const char *versionstr, char *retpath)
#define ALWAYS_SECURE_SEARCH_PATH_SQL
static void PGresult * res
bool buildACLCommands(const char *name, const char *subname, const char *nspname, const char *type, const char *acls, const char *baseacls, const char *owner, const char *prefix, int remoteVersion, PQExpBuffer sql)
void buildShSecLabelQuery(const char *catalog_name, Oid objectId, PQExpBuffer sql)
void makeAlterConfigCommand(PGconn *conn, const char *configitem, const char *type, const char *name, const char *type2, const char *name2, PQExpBuffer buf)
void emitShSecLabels(PGconn *conn, PGresult *res, PQExpBuffer buffer, const char *objtype, const char *objname)
#define PGDUMP_STRFTIME_FMT
const char * pg_encoding_to_char(int encoding)
void fsync_fname(const char *fname, bool isdir)
const char * PQparameterStatus(const PGconn *conn, const char *paramName)
int PQserverVersion(const PGconn *conn)
PQconninfoOption * PQconninfoParse(const char *conninfo, char **errmsg)
PGconn * PQconnectdbParams(const char *const *keywords, const char *const *values, int expand_dbname)
void PQconninfoFree(PQconninfoOption *connOptions)
int PQconnectionNeedsPassword(const PGconn *conn)
char * PQerrorMessage(const PGconn *conn)
ConnStatusType PQstatus(const PGconn *conn)
int PQclientEncoding(const PGconn *conn)
void PQfinish(PGconn *conn)
int PQsetClientEncoding(PGconn *conn, const char *encoding)
ExecStatusType PQresultStatus(const PGresult *res)
int PQntuples(const PGresult *res)
PGresult * PQexec(PGconn *conn, const char *query)
char * PQgetvalue(const PGresult *res, int tup_num, int field_num)
int PQfnumber(const PGresult *res, const char *field_name)
int PQgetisnull(const PGresult *res, int tup_num, int field_num)
void * pg_malloc0(size_t size)
char * pg_strdup(const char *in)
int getopt_long(int argc, char *const argv[], const char *optstring, const struct option *longopts, int *longindex)
#define required_argument
uint32 hash_bytes(const unsigned char *k, int keylen)
static void const char fflush(stdout)
void pg_logging_increase_verbosity(void)
void pg_logging_init(const char *argv0)
void pg_logging_set_level(enum pg_log_level new_level)
#define pg_log_error(...)
#define pg_log_error_hint(...)
#define pg_log_error_detail(...)
static void dumpTimestamp(const char *msg)
static int on_conflict_do_nothing
int main(int argc, char *argv[])
static void dropTablespaces(PGconn *conn)
static void expand_dbname_patterns(PGconn *conn, SimpleStringList *patterns, SimpleStringList *names)
static int no_role_passwords
static PQExpBuffer pgdumpopts
static int no_table_access_method
static int no_unlogged_table_data
static int binary_upgrade
static int disable_triggers
static void dumpUserConfig(PGconn *conn, const char *username)
static SimpleStringList database_exclude_patterns
static void dumpTablespaces(PGconn *conn)
static void dumpRoleMembership(PGconn *conn)
static PGconn * connectDatabase(const char *dbname, const char *connection_string, const char *pghost, const char *pgport, const char *pguser, trivalue prompt_password, bool fail_on_error)
#define exit_nicely(code)
static char pg_dump_bin[MAXPGPATH]
static SimpleStringList database_exclude_names
static char * constructConnStr(const char **keywords, const char **values)
static int no_publications
static int no_security_labels
static void dumpDatabases(PGconn *conn)
static int disable_dollar_quoting
static void buildShSecLabels(PGconn *conn, const char *catalog_name, Oid objectId, const char *objtype, const char *objname, PQExpBuffer buffer)
static int no_tablespaces
static int no_toast_compression
static void executeCommand(PGconn *conn, const char *query)
static int runPgDump(const char *dbname, const char *create_opts)
static void dumpRoleGUCPrivs(PGconn *conn)
static void dumpRoles(PGconn *conn)
static PGresult * executeQuery(PGconn *conn, const char *query)
static int use_setsessauth
static int load_via_partition_root
static int column_inserts
static void dropRoles(PGconn *conn)
static void dropDBs(PGconn *conn)
static int server_version
static char role_catalog[10]
static const char * progname
static uint32 hash_string_pointer(char *s)
static int no_subscriptions
#define PGDUMP_VERSIONSTR
PGDLLIMPORT char * optarg
#define pg_log_warning(...)
#define is_absolute_path(filename)
const char * get_progname(const char *argv0)
size_t strlcpy(char *dst, const char *src, size_t siz)
void printfPQExpBuffer(PQExpBuffer str, const char *fmt,...)
PQExpBuffer createPQExpBuffer(void)
void initPQExpBuffer(PQExpBuffer str)
void resetPQExpBuffer(PQExpBuffer str)
void appendPQExpBuffer(PQExpBuffer str, const char *fmt,...)
void destroyPQExpBuffer(PQExpBuffer str)
void appendPQExpBufferChar(PQExpBuffer str, char ch)
void appendPQExpBufferStr(PQExpBuffer str, const char *data)
void termPQExpBuffer(PQExpBuffer str)
bool quote_all_identifiers
bool simple_string_list_member(SimpleStringList *list, const char *val)
void simple_string_list_append(SimpleStringList *list, const char *val)
char * simple_prompt(const char *prompt, bool echo)
void appendShellString(PQExpBuffer buf, const char *str)
void appendStringLiteralConn(PQExpBuffer buf, const char *str, PGconn *conn)
bool processSQLNamePattern(PGconn *conn, PQExpBuffer buf, const char *pattern, bool have_where, bool force_escape, const char *schemavar, const char *namevar, const char *altnamevar, const char *visibilityrule, PQExpBuffer dbnamebuf, int *dotcnt)
const char * fmtId(const char *rawid)
void appendConnStrVal(PQExpBuffer buf, const char *str)
struct SimpleStringListCell * next
SimpleStringListCell * head