version.c File Reference

#include "postgres_fe.h"
#include "fe_utils/string_utils.h"
#include "pg_upgrade.h"

Include dependency graph for version.c:

Go to the source code of this file.

Functions
bool	jsonb_9_4_check_applicable (ClusterInfo *cluster)
bool	protocol_negotiation_supported (const ClusterInfo *cluster)
void	old_9_6_invalidate_hash_indexes (ClusterInfo *cluster, bool check_mode)
static void	process_extension_updates (DbInfo *dbinfo, PGresult *res, void *arg)
void	report_extension_updates (ClusterInfo *cluster)

Function Documentation

jsonb_9_4_check_applicable()

bool jsonb_9_4_check_applicable

(

ClusterInfo *

cluster

)

Definition at line 21 of file version.c.

{
    /* JSONB changed its storage format during 9.4 beta */
    if (GET_MAJOR_VERSION(cluster->major_version) == 904 &&
        cluster->controldata.cat_ver < JSONB_FORMAT_CHANGE_CAT_VER)
        return true;
 
    return false;
}

References cluster(), GET_MAJOR_VERSION, and JSONB_FORMAT_CHANGE_CAT_VER.

old_9_6_invalidate_hash_indexes()

void old_9_6_invalidate_hash_indexes	(	ClusterInfo *	cluster,
		bool	check_mode
	)

Definition at line 55 of file version.c.

{
    int         dbnum;
    FILE       *script = NULL;
    bool        found = false;
    char       *output_path = "reindex_hash.sql";
 
    prep_status("Checking for hash indexes");
 
    for (dbnum = 0; dbnum < cluster->dbarr.ndbs; dbnum++)
    {
        PGresult   *res;
        bool        db_used = false;
        int         ntups;
        int         rowno;
        int         i_nspname,
                    i_relname;
        DbInfo     *active_db = &cluster->dbarr.dbs[dbnum];
        PGconn     *conn = connectToServer(cluster, active_db->db_name);
 
        /* find hash indexes */
        res = executeQueryOrDie(conn,
                                "SELECT n.nspname, c.relname "
                                "FROM   pg_catalog.pg_class c, "
                                "       pg_catalog.pg_index i, "
                                "       pg_catalog.pg_am a, "
                                "       pg_catalog.pg_namespace n "
                                "WHERE  i.indexrelid = c.oid AND "
                                "       c.relam = a.oid AND "
                                "       c.relnamespace = n.oid AND "
                                "       a.amname = 'hash'"
            );
 
        ntups = PQntuples(res);
        i_nspname = PQfnumber(res, "nspname");
        i_relname = PQfnumber(res, "relname");
        for (rowno = 0; rowno < ntups; rowno++)
        {
            found = true;
            if (!check_mode)
            {
                if (script == NULL && (script = fopen_priv(output_path, "w")) == NULL)
                    pg_fatal("could not open file \"%s\": %m", output_path);
                if (!db_used)
                {
                    PQExpBufferData connectbuf;
 
                    initPQExpBuffer(&connectbuf);
                    appendPsqlMetaConnect(&connectbuf, active_db->db_name);
                    fputs(connectbuf.data, script);
                    termPQExpBuffer(&connectbuf);
                    db_used = true;
                }
                fprintf(script, "REINDEX INDEX %s.%s;\n",
                        quote_identifier(PQgetvalue(res, rowno, i_nspname)),
                        quote_identifier(PQgetvalue(res, rowno, i_relname)));
            }
        }
 
        PQclear(res);
 
        if (!check_mode && db_used)
        {
            /* mark hash indexes as invalid */
            PQclear(executeQueryOrDie(conn,
                                      "UPDATE pg_catalog.pg_index i "
                                      "SET  indisvalid = false "
                                      "FROM pg_catalog.pg_class c, "
                                      "     pg_catalog.pg_am a, "
                                      "     pg_catalog.pg_namespace n "
                                      "WHERE    i.indexrelid = c.oid AND "
                                      "     c.relam = a.oid AND "
                                      "     c.relnamespace = n.oid AND "
                                      "     a.amname = 'hash'"));
        }
 
        PQfinish(conn);
    }
 
    if (script)
        fclose(script);
 
    if (found)
    {
        report_status(PG_WARNING, "warning");
        if (check_mode)
            pg_log(PG_WARNING, "\n"
                   "Your installation contains hash indexes.  These indexes have different\n"
                   "internal formats between your old and new clusters, so they must be\n"
                   "reindexed with the REINDEX command.  After upgrading, you will be given\n"
                   "REINDEX instructions.");
        else
            pg_log(PG_WARNING, "\n"
                   "Your installation contains hash indexes.  These indexes have different\n"
                   "internal formats between your old and new clusters, so they must be\n"
                   "reindexed with the REINDEX command.  The file\n"
                   "    %s\n"
                   "when executed by psql by the database superuser will recreate all invalid\n"
                   "indexes; until then, none of these indexes will be used.",
                   output_path);
    }
    else
        check_ok();
}

References appendPsqlMetaConnect(), check_ok(), cluster(), conn, connectToServer(), executeQueryOrDie(), fb(), fopen_priv, fprintf, initPQExpBuffer(), pg_fatal, pg_log(), PG_WARNING, PQclear, PQfinish(), PQfnumber(), PQgetvalue, PQntuples, prep_status(), quote_identifier(), report_status(), and termPQExpBuffer().

Referenced by check_and_dump_old_cluster(), and issue_warnings_and_set_wal_level().

process_extension_updates()

static void process_extension_updates ( DbInfo *  dbinfo, PGresult *  res, void *  arg  )

static

Definition at line 166 of file version.c.

{
    int         ntups = PQntuples(res);
    int         i_name = PQfnumber(res, "name");
    UpgradeTaskReport *report = (UpgradeTaskReport *) arg;
    PQExpBufferData connectbuf;
 
    if (ntups == 0)
        return;
 
    if (report->file == NULL &&
        (report->file = fopen_priv(report->path, "w")) == NULL)
        pg_fatal("could not open file \"%s\": %m", report->path);
 
    initPQExpBuffer(&connectbuf);
    appendPsqlMetaConnect(&connectbuf, dbinfo->db_name);
    fputs(connectbuf.data, report->file);
    termPQExpBuffer(&connectbuf);
 
    for (int rowno = 0; rowno < ntups; rowno++)
        fprintf(report->file, "ALTER EXTENSION %s UPDATE;\n",
                quote_identifier(PQgetvalue(res, rowno, i_name)));
}

References appendPsqlMetaConnect(), arg, DbInfo::db_name, fb(), UpgradeTaskReport::file, fopen_priv, fprintf, initPQExpBuffer(), UpgradeTaskReport::path, pg_fatal, PQfnumber(), PQgetvalue, PQntuples, quote_identifier(), and termPQExpBuffer().

Referenced by report_extension_updates().

protocol_negotiation_supported()

bool protocol_negotiation_supported

(

const ClusterInfo *

cluster

)

Definition at line 36 of file version.c.

{
    /*
     * The February 2018 patch release (9.3.21, 9.4.16, 9.5.11, 9.6.7, and
     * 10.2) added support for NegotiateProtocolVersion. But ClusterInfo only
     * has information about the major version number. To ensure we can still
     * upgrade older unpatched servers, just assume anything prior to PG11
     * can't negotiate. It's not possible for those servers to make use of
     * newer protocols anyway, so nothing is lost.
     */
    return (GET_MAJOR_VERSION(cluster->major_version) >= 1100);
}

References cluster(), and GET_MAJOR_VERSION.

Referenced by generate_old_dump(), get_db_conn(), and start_conn().

report_extension_updates()

void report_extension_updates

(

ClusterInfo *

cluster

)

Definition at line 195 of file version.c.

{
    UpgradeTaskReport report;
    UpgradeTask *task = upgrade_task_create();
    const char *query = "SELECT name "
        "FROM pg_available_extensions "
        "WHERE installed_version != default_version";
 
    prep_status("Checking for extension updates");
 
    report.file = NULL;
    strcpy(report.path, "update_extensions.sql");
 
    upgrade_task_add_step(task, query, process_extension_updates,
                          true, &report);
 
    upgrade_task_run(task, cluster);
    upgrade_task_free(task);
 
    if (report.file)
    {
        fclose(report.file);
        report_status(PG_REPORT, "notice");
        pg_log(PG_REPORT, "\n"
               "Your installation contains extensions that should be updated\n"
               "with the ALTER EXTENSION command.  The file\n"
               "    %s\n"
               "when executed by psql by the database superuser will update\n"
               "these extensions.",
               report.path);
    }
    else
        check_ok();
}

References check_ok(), cluster(), fb(), UpgradeTaskReport::file, UpgradeTaskReport::path, pg_log(), PG_REPORT, prep_status(), process_extension_updates(), report_status(), upgrade_task_add_step(), upgrade_task_create(), upgrade_task_free(), and upgrade_task_run().

Referenced by issue_warnings_and_set_wal_level().