43 #ifdef HAVE_LANGINFO_H
47 #include "catalog/pg_class_d.h"
59 #define RESTORE_TRANSACTION_SIZE 1000
88 main(
int argc,
char **argv)
90 char *deletion_script_file_name = NULL;
114 pg_fatal(
"could not read permissions of directory \"%s\": %m",
147 "Performing Upgrade\n"
148 "------------------");
193 "\"%s/pg_resetwal\" -o %u \"%s\"",
217 "\"%s/initdb\" --sync-only \"%s\" --sync-method %s",
235 pg_free(deletion_script_file_name);
252 time_t run_time = time(NULL);
262 pg_fatal(
"directory path for new cluster is too long");
266 tt = (time_t) time.tv_sec;
267 strftime(timebuf,
sizeof(timebuf),
"%Y%m%dT%H%M%S", localtime(&tt));
269 snprintf(timebuf + strlen(timebuf),
sizeof(timebuf) - strlen(timebuf),
270 ".%03d", (
int) (time.tv_usec / 1000));
275 pg_fatal(
"directory path for new cluster is too long");
282 pg_fatal(
"directory path for new cluster is too long");
289 pg_fatal(
"directory path for new cluster is too long");
304 len =
snprintf(filename_path,
sizeof(filename_path),
"%s/%s",
306 if (
len >=
sizeof(filename_path))
307 pg_fatal(
"directory path for new cluster is too long");
310 pg_fatal(
"could not open log file \"%s\": %m", filename_path);
315 len =
snprintf(filename_path,
sizeof(filename_path),
"%s/%s",
317 if (
len >=
sizeof(filename_path))
318 pg_fatal(
"directory path for new cluster is too long");
319 if ((fp =
fopen_priv(filename_path,
"a")) == NULL)
320 pg_fatal(
"could not write to log file \"%s\": %m", filename_path);
323 "-----------------------------------------------------------------\n"
324 " pg_upgrade run on %s"
325 "-----------------------------------------------------------------\n\n",
351 pg_fatal(
"%s: could not find own program executable",
argv0);
377 pg_fatal(
"There seems to be a postmaster servicing the old cluster.\n"
378 "Please shutdown that postmaster and try again.");
390 pg_fatal(
"There seems to be a postmaster servicing the new cluster.\n"
391 "Please shutdown that postmaster and try again.");
406 PGconn *conn_new_template1;
407 char *datcollate_literal;
408 char *datctype_literal;
409 char *datlocale_literal = NULL;
412 prep_status(
"Setting locale and encoding for new cluster");
419 strlen(
locale->db_collate));
422 strlen(
locale->db_ctype));
426 strlen(
locale->db_locale));
433 "UPDATE pg_catalog.pg_database "
434 " SET encoding = %d, "
435 " datlocprovider = '%c', "
439 " WHERE datname = 'template0' ",
447 "UPDATE pg_catalog.pg_database "
448 " SET encoding = %d, "
449 " datlocprovider = '%c', "
452 " daticulocale = %s "
453 " WHERE datname = 'template0' ",
461 "UPDATE pg_catalog.pg_database "
462 " SET encoding = %d, "
465 " WHERE datname = 'template0' ",
488 prep_status(
"Analyzing all rows in the new cluster");
490 "\"%s/vacuumdb\" %s --all --analyze %s",
501 prep_status(
"Freezing all rows in the new cluster");
503 "\"%s/vacuumdb\" %s --all --freeze %s",
521 prep_status(
"Restoring global objects in the new cluster");
536 PGconn *conn_new_template1;
561 const char *create_opts;
564 if (strcmp(old_db->
db_name,
"template1") != 0)
576 create_opts =
"--clean --create";
582 "\"%s/pg_restore\" %s %s --exit-on-error --verbose "
583 "--transaction-size=%d "
584 "--dbname postgres \"%s/%s\"",
600 const char *create_opts;
604 if (strcmp(old_db->
db_name,
"template1") == 0)
616 if (strcmp(old_db->
db_name,
"postgres") == 0)
617 create_opts =
"--clean --create";
619 create_opts =
"--create";
631 txn_size =
Max(txn_size, 10);
636 "\"%s/pg_restore\" %s %s --exit-on-error --verbose "
637 "--transaction-size=%d "
638 "--dbname template1 \"%s/%s\"",
676 if (!
rmtree(new_path, rmtopdir))
677 pg_fatal(
"could not delete directory \"%s\"", new_path);
696 prep_status(
"Copying old %s to new server", old_subdir);
700 "cp -Rf \"%s\" \"%s\"",
703 "xcopy /e /y /q /r \"%s\" \"%s\\\"",
718 "pg_clog" :
"pg_xact",
720 "pg_clog" :
"pg_xact");
724 "\"%s/pg_resetwal\" -f -u %u \"%s\"",
730 prep_status(
"Setting next transaction ID and epoch for new cluster");
732 "\"%s/pg_resetwal\" -f -x %u \"%s\"",
736 "\"%s/pg_resetwal\" -f -e %u \"%s\"",
741 "\"%s/pg_resetwal\" -f -c %u,%u \"%s\"",
760 prep_status(
"Setting next multixact ID and offset for new cluster");
767 "\"%s/pg_resetwal\" -O %u -m %u,%u \"%s\"",
784 prep_status(
"Setting oldest multixact ID in new cluster");
795 "\"%s/pg_resetwal\" -m %u,%u \"%s\"",
847 prep_status(
"Setting frozenxid and minmxid counters in new cluster");
849 prep_status(
"Setting minmxid counter in new cluster");
856 "UPDATE pg_catalog.pg_database "
857 "SET datfrozenxid = '%u'",
862 "UPDATE pg_catalog.pg_database "
863 "SET datminmxid = '%u'",
868 "SELECT datname, datallowconn "
869 "FROM pg_catalog.pg_database");
872 i_datallowconn =
PQfnumber(dbres,
"datallowconn");
875 for (dbnum = 0; dbnum < ntups; dbnum++)
889 "ALTER DATABASE %s ALLOW_CONNECTIONS = true",
897 "UPDATE pg_catalog.pg_class "
898 "SET relfrozenxid = '%u' "
908 "UPDATE pg_catalog.pg_class "
909 "SET relminmxid = '%u' "
921 "ALTER DATABASE %s ALLOW_CONNECTIONS = false",
950 if (slot_arr->
nslots == 0)
958 for (
int slotnum = 0; slotnum < slot_arr->
nslots; slotnum++)
965 "pg_catalog.pg_create_logical_replication_slot(");
972 slot_info->
failover ?
"true" :
"false");
bool exec_prog(const char *log_filename, const char *opt_log_file, bool report_error, bool exit_on_error, const char *fmt,...)
bool pid_lock_file_exists(const char *datadir)
void verify_directories(void)
bool reap_child(bool wait_for_child)
void parallel_exec_prog(const char *log_file, const char *opt_log_file, const char *fmt,...)
#define PG_TEXTDOMAIN(domain)
void check_cluster_versions(void)
void issue_warnings_and_set_wal_level(void)
void check_cluster_compatibility(void)
void check_new_cluster(void)
void report_clusters_compatible(void)
void create_script_for_old_cluster_deletion(char **deletion_script_file_name)
void check_and_dump_old_cluster(void)
void output_completion_banner(char *deletion_script_file_name)
void output_check_banner(void)
int find_my_exec(const char *argv0, char *retpath)
void set_pglocale_pgservice(const char *argv0, const char *app)
void disable_old_cluster(void)
void PQfinish(PGconn *conn)
void PQfreemem(void *ptr)
int PQntuples(const PGresult *res)
char * PQescapeLiteral(PGconn *conn, const char *str, size_t len)
char * PQgetvalue(const PGresult *res, int tup_num, int field_num)
int PQfnumber(const PGresult *res, const char *field_name)
void * pg_malloc0(size_t size)
char * pg_strdup(const char *in)
bool GetDataDirectoryCreatePerm(const char *dataDir)
#define PG_MODE_MASK_OWNER
int count_old_cluster_logical_slots(void)
void get_db_rel_and_slot_infos(ClusterInfo *cluster)
static void check_ok(void)
void pg_logging_init(const char *argv0)
static void adjust_data_dir(void)
static pid_t start_postmaster(void)
static void create_logical_replication_slots(void)
static void set_frozenxids(bool minmxid_only)
static void make_outputdirs(char *pgdata)
static void prepare_new_cluster(void)
int main(int argc, char **argv)
static void copy_subdir_files(const char *old_subdir, const char *new_subdir)
static void create_new_objects(void)
static void remove_new_subdir(const char *subdir, bool rmtopdir)
static void copy_xact_xlog_xid(void)
static void set_locale_and_encoding(void)
static void setup(char *argv0)
#define RESTORE_TRANSACTION_SIZE
static void prepare_new_globals(void)
void transfer_all_new_tablespaces(DbInfoArr *old_db_arr, DbInfoArr *new_db_arr, char *old_pgdata, char *new_pgdata)
#define SERVER_START_LOG_FILE
void check_pghost_envvar(void)
#define MULTIXACT_FORMATCHANGE_CAT_VER
#define GLOBALS_DUMP_FILE
#define DB_DUMP_LOG_FILE_MASK
void cleanup_output_dirs(void)
void void pg_log(eLogType type, const char *fmt,...) pg_attribute_printf(2
void void prep_status_progress(const char *fmt,...) pg_attribute_printf(1
#define fopen_priv(path, mode)
PGconn * connectToServer(ClusterInfo *cluster, const char *db_name)
#define GET_MAJOR_VERSION(v)
void stop_postmaster(bool in_atexit)
void prep_status(const char *fmt,...) pg_attribute_printf(1
#define INTERNAL_LOG_FILE
void end_progress_output(void)
PGresult char * cluster_conn_opts(ClusterInfo *cluster)
PGresult * executeQueryOrDie(PGconn *conn, const char *fmt,...) pg_attribute_printf(2
#define DB_DUMP_FILE_MASK
char * last_dir_separator(const char *filename)
void canonicalize_path(char *path)
PQExpBuffer createPQExpBuffer(void)
void resetPQExpBuffer(PQExpBuffer str)
void appendPQExpBuffer(PQExpBuffer str, const char *fmt,...)
void destroyPQExpBuffer(PQExpBuffer str)
void get_restricted_token(void)
bool rmtree(const char *path, bool rmtopdir)
const char * quote_identifier(const char *ident)
void parseCommandLine(int argc, char *argv[])
void get_sock_dir(ClusterInfo *cluster)
void appendStringLiteralConn(PQExpBuffer buf, const char *str, PGconn *conn)
LogicalSlotInfoArr slot_arr
transferMode transfer_mode
int gettimeofday(struct timeval *tp, void *tzp)