Age         Owner                    Branch data    TLA  Line data    Source code

                                  1                 :                : /*
                                  2                 :                :  *  dump.c
                                  3                 :                :  *
                                  4                 :                :  *  dump functions
                                  5                 :                :  *
                                  6                 :                :  *  Copyright (c) 2010-2025, PostgreSQL Global Development Group
                                  7                 :                :  *  src/bin/pg_upgrade/dump.c
                                  8                 :                :  */
                                  9                 :                : 
                                 10                 :                : #include "postgres_fe.h"
                                 11                 :                : 
                                 12                 :                : #include "fe_utils/string_utils.h"
                                 13                 :                : #include "pg_upgrade.h"
                                 14                 :                : 
                                 15                 :                : void
 5436 bruce@momjian.us           16                 :CBC          10 : generate_old_dump(void)
                                 17                 :                : {
                                 18                 :                :     int         dbnum;
                                 19                 :                : 
 4663                            20                 :             10 :     prep_status("Creating dump of global objects");
                                 21                 :                : 
                                 22                 :                :     /* run new pg_dumpall binary for globals */
 2798                            23                 :             10 :     exec_prog(UTILITY_LOG_FILE, NULL, true, true,
                                 24                 :                :               "\"%s/pg_dumpall\" %s --globals-only --quote-all-identifiers "
                                 25                 :                :               "--binary-upgrade %s --no-sync -f \"%s/%s\"",
                                 26                 :                :               new_cluster.bindir, cluster_conn_opts(&old_cluster),
 4926                            27         [ -  + ]:             10 :               log_opts.verbose ? "--verbose" : "",
                                 28                 :                :               log_opts.dumpdir,
                                 29                 :                :               GLOBALS_DUMP_FILE);
 4663                            30                 :             10 :     check_ok();
                                 31                 :                : 
 1293 andres@anarazel.de         32                 :             10 :     prep_status_progress("Creating dump of database schemas");
                                 33                 :                : 
                                 34                 :                :     /* create per-db dump files */
 4663 bruce@momjian.us           35         [ +  + ]:             44 :     for (dbnum = 0; dbnum < old_cluster.dbarr.ndbs; dbnum++)
                                 36                 :                :     {
                                 37                 :                :         char        sql_file_name[MAXPGPATH],
                                 38                 :                :                     log_file_name[MAXPGPATH];
 4503 tgl@sss.pgh.pa.us          39                 :             34 :         DbInfo     *old_db = &old_cluster.dbarr.dbs[dbnum];
                                 40                 :                :         PQExpBufferData connstr,
                                 41                 :                :                     escaped_connstr;
                                 42                 :                : 
 3316 noah@leadboat.com          43                 :             34 :         initPQExpBuffer(&connstr);
 2256 drowley@postgresql.o       44                 :             34 :         appendPQExpBufferStr(&connstr, "dbname=");
 3316 noah@leadboat.com          45                 :             34 :         appendConnStrVal(&connstr, old_db->db_name);
                                 46                 :             34 :         initPQExpBuffer(&escaped_connstr);
                                 47                 :             34 :         appendShellString(&escaped_connstr, connstr.data);
                                 48                 :             34 :         termPQExpBuffer(&connstr);
                                 49                 :                : 
 4656 bruce@momjian.us           50                 :             34 :         pg_log(PG_STATUS, "%s", old_db->db_name);
 4637                            51                 :             34 :         snprintf(sql_file_name, sizeof(sql_file_name), DB_DUMP_FILE_MASK, old_db->db_oid);
                                 52                 :             34 :         snprintf(log_file_name, sizeof(log_file_name), DB_DUMP_LOG_FILE_MASK, old_db->db_oid);
                                 53                 :                : 
                                 54                 :            102 :         parallel_exec_prog(log_file_name, NULL,
                                 55                 :                :                            "\"%s/pg_dump\" %s --no-data %s %s --quote-all-identifiers "
                                 56                 :                :                            "--binary-upgrade --format=custom %s --no-sync --file=\"%s/%s\" %s",
                                 57                 :                :                            new_cluster.bindir, cluster_conn_opts(&old_cluster),
  165 nathan@postgresql.or       58         [ +  + ]:             34 :                            (user_opts.transfer_mode == TRANSFER_MODE_SWAP) ?
                                 59                 :                :                            "" : "--sequence-data",
 4503 tgl@sss.pgh.pa.us          60         [ -  + ]:             34 :                            log_opts.verbose ? "--verbose" : "",
   35 jdavis@postgresql.or       61         [ +  - ]:             34 :                            user_opts.do_statistics ? "--statistics" : "--no-statistics",
                                 62                 :                :                            log_opts.dumpdir,
                                 63                 :                :                            sql_file_name, escaped_connstr.data);
                                 64                 :                : 
 3316 noah@leadboat.com          65                 :             34 :         termPQExpBuffer(&escaped_connstr);
                                 66                 :                :     }
                                 67                 :                : 
                                 68                 :                :     /* reap all children */
 4637 bruce@momjian.us           69         [ -  + ]:             10 :     while (reap_child(true) == true)
                                 70                 :                :         ;
                                 71                 :                : 
 4663                            72                 :             10 :     end_progress_output();
                                 73                 :             10 :     check_ok();
 5596                            74                 :             10 : }