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)
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 37 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 148 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().

report_extension_updates()

void report_extension_updates

(

ClusterInfo *

cluster

)

Definition at line 177 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().