Line data    Source code

       1              : /*
       2              :  *      dump.c
       3              :  *
       4              :  *      dump functions
       5              :  *
       6              :  *      Copyright (c) 2010-2026, 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
      16            0 : generate_old_dump(void)
      17              : {
      18            0 :         int                     dbnum;
      19              : 
      20            0 :         prep_status("Creating dump of global objects");
      21              : 
      22              :         /* run new pg_dumpall binary for globals */
      23            0 :         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            0 :                           new_cluster.bindir, cluster_conn_opts(&old_cluster),
      27            0 :                           log_opts.verbose ? "--verbose" : "",
      28            0 :                           log_opts.dumpdir,
      29              :                           GLOBALS_DUMP_FILE);
      30            0 :         check_ok();
      31              : 
      32            0 :         prep_status_progress("Creating dump of database schemas");
      33              : 
      34              :         /* create per-db dump files */
      35            0 :         for (dbnum = 0; dbnum < old_cluster.dbarr.ndbs; dbnum++)
      36              :         {
      37            0 :                 char            sql_file_name[MAXPGPATH],
      38              :                                         log_file_name[MAXPGPATH];
      39            0 :                 DbInfo     *old_db = &old_cluster.dbarr.dbs[dbnum];
      40            0 :                 PQExpBufferData connstr,
      41              :                                         escaped_connstr;
      42              : 
      43            0 :                 initPQExpBuffer(&connstr);
      44            0 :                 appendPQExpBufferStr(&connstr, "dbname=");
      45            0 :                 appendConnStrVal(&connstr, old_db->db_name);
      46            0 :                 initPQExpBuffer(&escaped_connstr);
      47            0 :                 appendShellString(&escaped_connstr, connstr.data);
      48            0 :                 termPQExpBuffer(&connstr);
      49              : 
      50            0 :                 pg_log(PG_STATUS, "%s", old_db->db_name);
      51            0 :                 snprintf(sql_file_name, sizeof(sql_file_name), DB_DUMP_FILE_MASK, old_db->db_oid);
      52            0 :                 snprintf(log_file_name, sizeof(log_file_name), DB_DUMP_LOG_FILE_MASK, old_db->db_oid);
      53              : 
      54            0 :                 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            0 :                                                    new_cluster.bindir, cluster_conn_opts(&old_cluster),
      58            0 :                                                    (user_opts.transfer_mode == TRANSFER_MODE_SWAP) ?
      59              :                                                    "" : "--sequence-data",
      60            0 :                                                    log_opts.verbose ? "--verbose" : "",
      61            0 :                                                    user_opts.do_statistics ? "--statistics" : "--no-statistics",
      62            0 :                                                    log_opts.dumpdir,
      63            0 :                                                    sql_file_name, escaped_connstr.data);
      64              : 
      65            0 :                 termPQExpBuffer(&escaped_connstr);
      66            0 :         }
      67              : 
      68              :         /* reap all children */
      69            0 :         while (reap_child(true) == true)
      70              :                 ;
      71              : 
      72            0 :         end_progress_output();
      73            0 :         check_ok();
      74            0 : }