mirror of
https://git.postgresql.org/git/postgresql.git
synced 2024-12-27 08:39:28 +08:00
8396447cdb
libpgcommon is a new static library to allow sharing code among the various frontend programs and backend; this lets us eliminate duplicate implementations of common routines. We avoid libpgport, because that's intended as a place for porting issues; per discussion, it seems better to keep them separate. The first use case, and the only implemented by this patch, is pg_malloc and friends, which many frontend programs were already using. At the same time, we can use this to provide palloc emulation functions for the frontend; this way, some palloc-using files in the backend can also be used by the frontend cleanly. To do this, we change palloc() in the backend to be a function instead of a macro on top of MemoryContextAlloc(). This was previously believed to cause loss of performance, but this implementation has been tweaked by Tom and Andres so that on modern compilers it provides a slight improvement over the previous one. This lets us clean up some places that were already with localized hacks. Most of the pg_malloc/palloc changes in this patch were authored by Andres Freund. Zoltán Böszörményi also independently provided a form of that. libpgcommon infrastructure was authored by Álvaro.
766 lines
22 KiB
C
766 lines
22 KiB
C
/*
|
|
* version.c
|
|
*
|
|
* Postgres-version-specific routines
|
|
*
|
|
* Copyright (c) 2010-2013, PostgreSQL Global Development Group
|
|
* contrib/pg_upgrade/version_old_8_3.c
|
|
*/
|
|
|
|
#include "postgres_fe.h"
|
|
|
|
#include "pg_upgrade.h"
|
|
|
|
#include "access/transam.h"
|
|
|
|
|
|
/*
|
|
* old_8_3_check_for_name_data_type_usage()
|
|
* 8.3 -> 8.4
|
|
* Alignment for the 'name' data type changed to 'char' in 8.4;
|
|
* checks tables and indexes.
|
|
*/
|
|
void
|
|
old_8_3_check_for_name_data_type_usage(ClusterInfo *cluster)
|
|
{
|
|
int dbnum;
|
|
FILE *script = NULL;
|
|
bool found = false;
|
|
char output_path[MAXPGPATH];
|
|
|
|
prep_status("Checking for invalid \"name\" user columns");
|
|
|
|
snprintf(output_path, sizeof(output_path), "tables_using_name.txt");
|
|
|
|
for (dbnum = 0; dbnum < cluster->dbarr.ndbs; dbnum++)
|
|
{
|
|
PGresult *res;
|
|
bool db_used = false;
|
|
int ntups;
|
|
int rowno;
|
|
int i_nspname,
|
|
i_relname,
|
|
i_attname;
|
|
DbInfo *active_db = &cluster->dbarr.dbs[dbnum];
|
|
PGconn *conn = connectToServer(cluster, active_db->db_name);
|
|
|
|
/*
|
|
* With a smaller alignment in 8.4, 'name' cannot be used in a
|
|
* non-pg_catalog table, except as the first column. (We could tighten
|
|
* that condition with enough analysis, but it seems not worth the
|
|
* trouble.)
|
|
*/
|
|
res = executeQueryOrDie(conn,
|
|
"SELECT n.nspname, c.relname, a.attname "
|
|
"FROM pg_catalog.pg_class c, "
|
|
" pg_catalog.pg_namespace n, "
|
|
" pg_catalog.pg_attribute a "
|
|
"WHERE c.oid = a.attrelid AND "
|
|
" a.attnum > 1 AND "
|
|
" NOT a.attisdropped AND "
|
|
" a.atttypid = 'pg_catalog.name'::pg_catalog.regtype AND "
|
|
" c.relnamespace = n.oid AND "
|
|
/* exclude possible orphaned temp tables */
|
|
" n.nspname !~ '^pg_temp_' AND "
|
|
" n.nspname !~ '^pg_toast_temp_' AND "
|
|
" n.nspname NOT IN ('pg_catalog', 'information_schema')");
|
|
|
|
ntups = PQntuples(res);
|
|
i_nspname = PQfnumber(res, "nspname");
|
|
i_relname = PQfnumber(res, "relname");
|
|
i_attname = PQfnumber(res, "attname");
|
|
for (rowno = 0; rowno < ntups; rowno++)
|
|
{
|
|
found = true;
|
|
if (script == NULL && (script = fopen_priv(output_path, "w")) == NULL)
|
|
pg_log(PG_FATAL, "could not open file \"%s\": %s\n", output_path, getErrorText(errno));
|
|
if (!db_used)
|
|
{
|
|
fprintf(script, "Database: %s\n", active_db->db_name);
|
|
db_used = true;
|
|
}
|
|
fprintf(script, " %s.%s.%s\n",
|
|
PQgetvalue(res, rowno, i_nspname),
|
|
PQgetvalue(res, rowno, i_relname),
|
|
PQgetvalue(res, rowno, i_attname));
|
|
}
|
|
|
|
PQclear(res);
|
|
|
|
PQfinish(conn);
|
|
}
|
|
|
|
if (script)
|
|
fclose(script);
|
|
|
|
if (found)
|
|
{
|
|
pg_log(PG_REPORT, "fatal\n");
|
|
pg_log(PG_FATAL,
|
|
"Your installation contains the \"name\" data type in user tables. This\n"
|
|
"data type changed its internal alignment between your old and new\n"
|
|
"clusters so this cluster cannot currently be upgraded. You can remove\n"
|
|
"the problem tables and restart the upgrade. A list of the problem\n"
|
|
"columns is in the file:\n"
|
|
" %s\n\n", output_path);
|
|
}
|
|
else
|
|
check_ok();
|
|
}
|
|
|
|
|
|
/*
|
|
* old_8_3_check_for_tsquery_usage()
|
|
* 8.3 -> 8.4
|
|
* A new 'prefix' field was added to the 'tsquery' data type in 8.4
|
|
* so upgrading of such fields is impossible.
|
|
*/
|
|
void
|
|
old_8_3_check_for_tsquery_usage(ClusterInfo *cluster)
|
|
{
|
|
int dbnum;
|
|
FILE *script = NULL;
|
|
bool found = false;
|
|
char output_path[MAXPGPATH];
|
|
|
|
prep_status("Checking for tsquery user columns");
|
|
|
|
snprintf(output_path, sizeof(output_path), "tables_using_tsquery.txt");
|
|
|
|
for (dbnum = 0; dbnum < cluster->dbarr.ndbs; dbnum++)
|
|
{
|
|
PGresult *res;
|
|
bool db_used = false;
|
|
int ntups;
|
|
int rowno;
|
|
int i_nspname,
|
|
i_relname,
|
|
i_attname;
|
|
DbInfo *active_db = &cluster->dbarr.dbs[dbnum];
|
|
PGconn *conn = connectToServer(cluster, active_db->db_name);
|
|
|
|
/* Find any user-defined tsquery columns */
|
|
res = executeQueryOrDie(conn,
|
|
"SELECT n.nspname, c.relname, a.attname "
|
|
"FROM pg_catalog.pg_class c, "
|
|
" pg_catalog.pg_namespace n, "
|
|
" pg_catalog.pg_attribute a "
|
|
"WHERE c.relkind = 'r' AND "
|
|
" c.oid = a.attrelid AND "
|
|
" NOT a.attisdropped AND "
|
|
" a.atttypid = 'pg_catalog.tsquery'::pg_catalog.regtype AND "
|
|
" c.relnamespace = n.oid AND "
|
|
/* exclude possible orphaned temp tables */
|
|
" n.nspname !~ '^pg_temp_' AND "
|
|
" n.nspname !~ '^pg_toast_temp_' AND "
|
|
" n.nspname NOT IN ('pg_catalog', 'information_schema')");
|
|
|
|
ntups = PQntuples(res);
|
|
i_nspname = PQfnumber(res, "nspname");
|
|
i_relname = PQfnumber(res, "relname");
|
|
i_attname = PQfnumber(res, "attname");
|
|
for (rowno = 0; rowno < ntups; rowno++)
|
|
{
|
|
found = true;
|
|
if (script == NULL && (script = fopen_priv(output_path, "w")) == NULL)
|
|
pg_log(PG_FATAL, "could not open file \"%s\": %s\n", output_path, getErrorText(errno));
|
|
if (!db_used)
|
|
{
|
|
fprintf(script, "Database: %s\n", active_db->db_name);
|
|
db_used = true;
|
|
}
|
|
fprintf(script, " %s.%s.%s\n",
|
|
PQgetvalue(res, rowno, i_nspname),
|
|
PQgetvalue(res, rowno, i_relname),
|
|
PQgetvalue(res, rowno, i_attname));
|
|
}
|
|
|
|
PQclear(res);
|
|
|
|
PQfinish(conn);
|
|
}
|
|
|
|
if (script)
|
|
fclose(script);
|
|
|
|
if (found)
|
|
{
|
|
pg_log(PG_REPORT, "fatal\n");
|
|
pg_log(PG_FATAL,
|
|
"Your installation contains the \"tsquery\" data type. This data type\n"
|
|
"added a new internal field between your old and new clusters so this\n"
|
|
"cluster cannot currently be upgraded. You can remove the problem\n"
|
|
"columns and restart the upgrade. A list of the problem columns is in the\n"
|
|
"file:\n"
|
|
" %s\n\n", output_path);
|
|
}
|
|
else
|
|
check_ok();
|
|
}
|
|
|
|
|
|
/*
|
|
* old_8_3_check_ltree_usage()
|
|
* 8.3 -> 8.4
|
|
* The internal ltree structure was changed in 8.4 so upgrading is impossible.
|
|
*/
|
|
void
|
|
old_8_3_check_ltree_usage(ClusterInfo *cluster)
|
|
{
|
|
int dbnum;
|
|
FILE *script = NULL;
|
|
bool found = false;
|
|
char output_path[MAXPGPATH];
|
|
|
|
prep_status("Checking for contrib/ltree");
|
|
|
|
snprintf(output_path, sizeof(output_path), "contrib_ltree.txt");
|
|
|
|
for (dbnum = 0; dbnum < cluster->dbarr.ndbs; dbnum++)
|
|
{
|
|
PGresult *res;
|
|
bool db_used = false;
|
|
int ntups;
|
|
int rowno;
|
|
int i_nspname,
|
|
i_proname;
|
|
DbInfo *active_db = &cluster->dbarr.dbs[dbnum];
|
|
PGconn *conn = connectToServer(cluster, active_db->db_name);
|
|
|
|
/* Find any functions coming from contrib/ltree */
|
|
res = executeQueryOrDie(conn,
|
|
"SELECT n.nspname, p.proname "
|
|
"FROM pg_catalog.pg_proc p, "
|
|
" pg_catalog.pg_namespace n "
|
|
"WHERE p.pronamespace = n.oid AND "
|
|
" p.probin = '$libdir/ltree'");
|
|
|
|
ntups = PQntuples(res);
|
|
i_nspname = PQfnumber(res, "nspname");
|
|
i_proname = PQfnumber(res, "proname");
|
|
for (rowno = 0; rowno < ntups; rowno++)
|
|
{
|
|
found = true;
|
|
if (script == NULL && (script = fopen_priv(output_path, "w")) == NULL)
|
|
pg_log(PG_FATAL, "Could not open file \"%s\": %s\n",
|
|
output_path, getErrorText(errno));
|
|
if (!db_used)
|
|
{
|
|
fprintf(script, "Database: %s\n", active_db->db_name);
|
|
db_used = true;
|
|
}
|
|
fprintf(script, " %s.%s\n",
|
|
PQgetvalue(res, rowno, i_nspname),
|
|
PQgetvalue(res, rowno, i_proname));
|
|
}
|
|
|
|
PQclear(res);
|
|
|
|
PQfinish(conn);
|
|
}
|
|
|
|
if (script)
|
|
fclose(script);
|
|
|
|
if (found)
|
|
{
|
|
pg_log(PG_REPORT, "fatal\n");
|
|
pg_log(PG_FATAL,
|
|
"Your installation contains the \"ltree\" data type. This data type\n"
|
|
"changed its internal storage format between your old and new clusters so this\n"
|
|
"cluster cannot currently be upgraded. You can manually upgrade databases\n"
|
|
"that use \"contrib/ltree\" facilities and remove \"contrib/ltree\" from the old\n"
|
|
"cluster and restart the upgrade. A list of the problem functions is in the\n"
|
|
"file:\n"
|
|
" %s\n\n", output_path);
|
|
}
|
|
else
|
|
check_ok();
|
|
}
|
|
|
|
|
|
/*
|
|
* old_8_3_rebuild_tsvector_tables()
|
|
* 8.3 -> 8.4
|
|
* 8.3 sorts lexemes by its length and if lengths are the same then it uses
|
|
* alphabetic order; 8.4 sorts lexemes in lexicographical order, e.g.
|
|
*
|
|
* => SELECT 'c bb aaa'::tsvector;
|
|
* tsvector
|
|
* ----------------
|
|
* 'aaa' 'bb' 'c' -- 8.4
|
|
* 'c' 'bb' 'aaa' -- 8.3
|
|
*/
|
|
void
|
|
old_8_3_rebuild_tsvector_tables(ClusterInfo *cluster, bool check_mode)
|
|
{
|
|
int dbnum;
|
|
FILE *script = NULL;
|
|
bool found = false;
|
|
char output_path[MAXPGPATH];
|
|
|
|
prep_status("Checking for tsvector user columns");
|
|
|
|
snprintf(output_path, sizeof(output_path), "rebuild_tsvector_tables.sql");
|
|
|
|
for (dbnum = 0; dbnum < cluster->dbarr.ndbs; dbnum++)
|
|
{
|
|
PGresult *res;
|
|
bool db_used = false;
|
|
char nspname[NAMEDATALEN] = "",
|
|
relname[NAMEDATALEN] = "";
|
|
int ntups;
|
|
int rowno;
|
|
int i_nspname,
|
|
i_relname,
|
|
i_attname;
|
|
DbInfo *active_db = &cluster->dbarr.dbs[dbnum];
|
|
PGconn *conn = connectToServer(cluster, active_db->db_name);
|
|
|
|
/* Find any user-defined tsvector columns */
|
|
res = executeQueryOrDie(conn,
|
|
"SELECT n.nspname, c.relname, a.attname "
|
|
"FROM pg_catalog.pg_class c, "
|
|
" pg_catalog.pg_namespace n, "
|
|
" pg_catalog.pg_attribute a "
|
|
"WHERE c.relkind = 'r' AND "
|
|
" c.oid = a.attrelid AND "
|
|
" NOT a.attisdropped AND "
|
|
" a.atttypid = 'pg_catalog.tsvector'::pg_catalog.regtype AND "
|
|
" c.relnamespace = n.oid AND "
|
|
/* exclude possible orphaned temp tables */
|
|
" n.nspname !~ '^pg_temp_' AND "
|
|
" n.nspname !~ '^pg_toast_temp_' AND "
|
|
" n.nspname NOT IN ('pg_catalog', 'information_schema')");
|
|
|
|
/*
|
|
* This macro is used below to avoid reindexing indexes already rebuilt
|
|
* because of tsvector columns.
|
|
*/
|
|
#define SKIP_TSVECTOR_TABLES \
|
|
"i.indrelid NOT IN ( " \
|
|
"SELECT DISTINCT c.oid " \
|
|
"FROM pg_catalog.pg_class c, " \
|
|
" pg_catalog.pg_namespace n, " \
|
|
" pg_catalog.pg_attribute a " \
|
|
"WHERE c.relkind = 'r' AND " \
|
|
" c.oid = a.attrelid AND " \
|
|
" NOT a.attisdropped AND " \
|
|
" a.atttypid = 'pg_catalog.tsvector'::pg_catalog.regtype AND " \
|
|
" c.relnamespace = n.oid AND " \
|
|
" n.nspname !~ '^pg_' AND " \
|
|
" n.nspname != 'information_schema') "
|
|
|
|
ntups = PQntuples(res);
|
|
i_nspname = PQfnumber(res, "nspname");
|
|
i_relname = PQfnumber(res, "relname");
|
|
i_attname = PQfnumber(res, "attname");
|
|
for (rowno = 0; rowno < ntups; rowno++)
|
|
{
|
|
found = true;
|
|
if (!check_mode)
|
|
{
|
|
if (script == NULL && (script = fopen_priv(output_path, "w")) == NULL)
|
|
pg_log(PG_FATAL, "could not open file \"%s\": %s\n", output_path, getErrorText(errno));
|
|
if (!db_used)
|
|
{
|
|
fprintf(script, "\\connect %s\n\n",
|
|
quote_identifier(active_db->db_name));
|
|
db_used = true;
|
|
}
|
|
|
|
/* Rebuild all tsvector collumns with one ALTER TABLE command */
|
|
if (strcmp(PQgetvalue(res, rowno, i_nspname), nspname) != 0 ||
|
|
strcmp(PQgetvalue(res, rowno, i_relname), relname) != 0)
|
|
{
|
|
if (strlen(nspname) != 0 || strlen(relname) != 0)
|
|
fprintf(script, ";\n\n");
|
|
fprintf(script, "ALTER TABLE %s.%s\n",
|
|
quote_identifier(PQgetvalue(res, rowno, i_nspname)),
|
|
quote_identifier(PQgetvalue(res, rowno, i_relname)));
|
|
}
|
|
else
|
|
fprintf(script, ",\n");
|
|
strlcpy(nspname, PQgetvalue(res, rowno, i_nspname), sizeof(nspname));
|
|
strlcpy(relname, PQgetvalue(res, rowno, i_relname), sizeof(relname));
|
|
|
|
fprintf(script, "ALTER COLUMN %s "
|
|
/* This could have been a custom conversion function call. */
|
|
"TYPE pg_catalog.tsvector USING %s::pg_catalog.text::pg_catalog.tsvector",
|
|
quote_identifier(PQgetvalue(res, rowno, i_attname)),
|
|
quote_identifier(PQgetvalue(res, rowno, i_attname)));
|
|
}
|
|
}
|
|
if (strlen(nspname) != 0 || strlen(relname) != 0)
|
|
fprintf(script, ";\n\n");
|
|
|
|
PQclear(res);
|
|
|
|
/* XXX Mark tables as not accessible somehow */
|
|
|
|
PQfinish(conn);
|
|
}
|
|
|
|
if (script)
|
|
fclose(script);
|
|
|
|
if (found)
|
|
{
|
|
report_status(PG_WARNING, "warning");
|
|
if (check_mode)
|
|
pg_log(PG_WARNING, "\n"
|
|
"Your installation contains tsvector columns. The tsvector internal\n"
|
|
"storage format changed between your old and new clusters so the tables\n"
|
|
"must be rebuilt. After upgrading, you will be given instructions.\n\n");
|
|
else
|
|
pg_log(PG_WARNING, "\n"
|
|
"Your installation contains tsvector columns. The tsvector internal\n"
|
|
"storage format changed between your old and new clusters so the tables\n"
|
|
"must be rebuilt. The file:\n"
|
|
" %s\n"
|
|
"when executed by psql by the database superuser will rebuild all tables\n"
|
|
"with tsvector columns.\n\n",
|
|
output_path);
|
|
}
|
|
else
|
|
check_ok();
|
|
}
|
|
|
|
|
|
/*
|
|
* old_8_3_invalidate_hash_gin_indexes()
|
|
* 8.3 -> 8.4
|
|
* Hash, Gin, and GiST index binary format has changes from 8.3->8.4
|
|
*/
|
|
void
|
|
old_8_3_invalidate_hash_gin_indexes(ClusterInfo *cluster, bool check_mode)
|
|
{
|
|
int dbnum;
|
|
FILE *script = NULL;
|
|
bool found = false;
|
|
char output_path[MAXPGPATH];
|
|
|
|
prep_status("Checking for hash and GIN indexes");
|
|
|
|
snprintf(output_path, sizeof(output_path), "reindex_hash_and_gin.sql");
|
|
|
|
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 and gin 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 IN ('hash', 'gin') AND "
|
|
SKIP_TSVECTOR_TABLES);
|
|
|
|
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_log(PG_FATAL, "could not open file \"%s\": %s\n", output_path, getErrorText(errno));
|
|
if (!db_used)
|
|
{
|
|
fprintf(script, "\\connect %s\n",
|
|
quote_identifier(active_db->db_name));
|
|
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 && found)
|
|
/* mark hash and gin 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 IN ('hash', 'gin')"));
|
|
|
|
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 and/or GIN indexes. These indexes have\n"
|
|
"different internal formats between your old and new clusters, so they\n"
|
|
"must be reindexed with the REINDEX command. After upgrading, you will\n"
|
|
"be given REINDEX instructions.\n\n");
|
|
else
|
|
pg_log(PG_WARNING, "\n"
|
|
"Your installation contains hash and/or GIN indexes. These indexes have\n"
|
|
"different internal formats between your old and new clusters, so they\n"
|
|
"must be 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.\n\n",
|
|
output_path);
|
|
}
|
|
else
|
|
check_ok();
|
|
}
|
|
|
|
|
|
/*
|
|
* old_8_3_invalidate_bpchar_pattern_ops_indexes()
|
|
* 8.3 -> 8.4
|
|
* 8.4 bpchar_pattern_ops no longer sorts based on trailing spaces
|
|
*/
|
|
void
|
|
old_8_3_invalidate_bpchar_pattern_ops_indexes(ClusterInfo *cluster,
|
|
bool check_mode)
|
|
{
|
|
int dbnum;
|
|
FILE *script = NULL;
|
|
bool found = false;
|
|
char output_path[MAXPGPATH];
|
|
|
|
prep_status("Checking for bpchar_pattern_ops indexes");
|
|
|
|
snprintf(output_path, sizeof(output_path), "reindex_bpchar_ops.sql");
|
|
|
|
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 bpchar_pattern_ops indexes */
|
|
|
|
/*
|
|
* Do only non-hash, non-gin indexees; we already invalidated them
|
|
* above; no need to reindex twice
|
|
*/
|
|
res = executeQueryOrDie(conn,
|
|
"SELECT n.nspname, c.relname "
|
|
"FROM pg_catalog.pg_index i, "
|
|
" pg_catalog.pg_class c, "
|
|
" pg_catalog.pg_namespace n "
|
|
"WHERE indexrelid = c.oid AND "
|
|
" c.relnamespace = n.oid AND "
|
|
" ( "
|
|
" SELECT o.oid "
|
|
" FROM pg_catalog.pg_opclass o, "
|
|
" pg_catalog.pg_am a"
|
|
" WHERE a.amname NOT IN ('hash', 'gin') AND "
|
|
" a.oid = o.opcmethod AND "
|
|
" o.opcname = 'bpchar_pattern_ops') "
|
|
" = ANY (i.indclass) AND "
|
|
SKIP_TSVECTOR_TABLES);
|
|
|
|
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_log(PG_FATAL, "could not open file \"%s\": %s\n", output_path, getErrorText(errno));
|
|
if (!db_used)
|
|
{
|
|
fprintf(script, "\\connect %s\n",
|
|
quote_identifier(active_db->db_name));
|
|
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 && found)
|
|
/* mark bpchar_pattern_ops indexes as invalid */
|
|
PQclear(executeQueryOrDie(conn,
|
|
"UPDATE pg_catalog.pg_index i "
|
|
"SET indisvalid = false "
|
|
"FROM pg_catalog.pg_class c, "
|
|
" pg_catalog.pg_namespace n "
|
|
"WHERE indexrelid = c.oid AND "
|
|
" c.relnamespace = n.oid AND "
|
|
" ( "
|
|
" SELECT o.oid "
|
|
" FROM pg_catalog.pg_opclass o, "
|
|
" pg_catalog.pg_am a"
|
|
" WHERE a.amname NOT IN ('hash', 'gin') AND "
|
|
" a.oid = o.opcmethod AND "
|
|
" o.opcname = 'bpchar_pattern_ops') "
|
|
" = ANY (i.indclass)"));
|
|
|
|
PQfinish(conn);
|
|
}
|
|
|
|
if (script)
|
|
fclose(script);
|
|
|
|
if (found)
|
|
{
|
|
report_status(PG_WARNING, "warning");
|
|
if (check_mode)
|
|
pg_log(PG_WARNING, "\n"
|
|
"Your installation contains indexes using \"bpchar_pattern_ops\". These\n"
|
|
"indexes have different internal formats between your old and new clusters\n"
|
|
"so they must be reindexed with the REINDEX command. After upgrading, you\n"
|
|
"will be given REINDEX instructions.\n\n");
|
|
else
|
|
pg_log(PG_WARNING, "\n"
|
|
"Your installation contains indexes using \"bpchar_pattern_ops\". These\n"
|
|
"indexes have different internal formats between your old and new clusters\n"
|
|
"so they must be 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.\n\n",
|
|
output_path);
|
|
}
|
|
else
|
|
check_ok();
|
|
}
|
|
|
|
|
|
/*
|
|
* old_8_3_create_sequence_script()
|
|
* 8.3 -> 8.4
|
|
* 8.4 added the column "start_value" to all sequences. For this reason,
|
|
* we don't transfer sequence files but instead use the CREATE SEQUENCE
|
|
* command from the schema dump, and use setval() to restore the sequence
|
|
* value and 'is_called' from the old database. This is safe to run
|
|
* by pg_upgrade because sequence files are not transferred from the old
|
|
* server, even in link mode.
|
|
*/
|
|
char *
|
|
old_8_3_create_sequence_script(ClusterInfo *cluster)
|
|
{
|
|
int dbnum;
|
|
FILE *script = NULL;
|
|
bool found = false;
|
|
char *output_path = pg_malloc(MAXPGPATH);
|
|
|
|
snprintf(output_path, MAXPGPATH, "adjust_sequences.sql");
|
|
|
|
prep_status("Creating script to adjust sequences");
|
|
|
|
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 any sequences */
|
|
res = executeQueryOrDie(conn,
|
|
"SELECT n.nspname, c.relname "
|
|
"FROM pg_catalog.pg_class c, "
|
|
" pg_catalog.pg_namespace n "
|
|
"WHERE c.relkind = 'S' AND "
|
|
" c.relnamespace = n.oid AND "
|
|
/* exclude possible orphaned temp tables */
|
|
" n.nspname !~ '^pg_temp_' AND "
|
|
" n.nspname !~ '^pg_toast_temp_' AND "
|
|
" n.nspname NOT IN ('pg_catalog', 'information_schema')");
|
|
|
|
ntups = PQntuples(res);
|
|
i_nspname = PQfnumber(res, "nspname");
|
|
i_relname = PQfnumber(res, "relname");
|
|
for (rowno = 0; rowno < ntups; rowno++)
|
|
{
|
|
PGresult *seq_res;
|
|
int i_last_value,
|
|
i_is_called;
|
|
const char *nspname = PQgetvalue(res, rowno, i_nspname);
|
|
const char *relname = PQgetvalue(res, rowno, i_relname);
|
|
|
|
found = true;
|
|
|
|
if (script == NULL && (script = fopen_priv(output_path, "w")) == NULL)
|
|
pg_log(PG_FATAL, "could not open file \"%s\": %s\n", output_path, getErrorText(errno));
|
|
if (!db_used)
|
|
{
|
|
fprintf(script, "\\connect %s\n\n",
|
|
quote_identifier(active_db->db_name));
|
|
db_used = true;
|
|
}
|
|
|
|
/* Find the desired sequence */
|
|
seq_res = executeQueryOrDie(conn,
|
|
"SELECT s.last_value, s.is_called "
|
|
"FROM %s.%s s",
|
|
quote_identifier(nspname),
|
|
quote_identifier(relname));
|
|
|
|
assert(PQntuples(seq_res) == 1);
|
|
i_last_value = PQfnumber(seq_res, "last_value");
|
|
i_is_called = PQfnumber(seq_res, "is_called");
|
|
|
|
fprintf(script, "SELECT setval('%s.%s', %s, '%s');\n",
|
|
quote_identifier(nspname), quote_identifier(relname),
|
|
PQgetvalue(seq_res, 0, i_last_value), PQgetvalue(seq_res, 0, i_is_called));
|
|
PQclear(seq_res);
|
|
}
|
|
if (db_used)
|
|
fprintf(script, "\n");
|
|
|
|
PQclear(res);
|
|
|
|
PQfinish(conn);
|
|
}
|
|
|
|
if (script)
|
|
fclose(script);
|
|
|
|
check_ok();
|
|
|
|
if (found)
|
|
return output_path;
|
|
else
|
|
{
|
|
pg_free(output_path);
|
|
return NULL;
|
|
}
|
|
}
|