mirror of
https://git.postgresql.org/git/postgresql.git
synced 2024-12-21 08:29:39 +08:00
791 lines
23 KiB
C
791 lines
23 KiB
C
/*
|
|
* version.c
|
|
*
|
|
* Postgres-version-specific routines
|
|
*/
|
|
|
|
#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(migratorContext *ctx, Cluster whichCluster)
|
|
{
|
|
ClusterInfo *active_cluster = (whichCluster == CLUSTER_OLD) ?
|
|
&ctx->old : &ctx->new;
|
|
int dbnum;
|
|
FILE *script = NULL;
|
|
bool found = false;
|
|
char output_path[MAXPGPATH];
|
|
|
|
prep_status(ctx, "Checking for invalid 'name' user columns");
|
|
|
|
snprintf(output_path, sizeof(output_path), "%s/tables_using_name.txt",
|
|
ctx->cwd);
|
|
|
|
for (dbnum = 0; dbnum < active_cluster->dbarr.ndbs; dbnum++)
|
|
{
|
|
PGresult *res;
|
|
bool db_used = false;
|
|
int ntups;
|
|
int rowno;
|
|
int i_nspname,
|
|
i_relname,
|
|
i_attname;
|
|
DbInfo *active_db = &active_cluster->dbarr.dbs[dbnum];
|
|
PGconn *conn = connectToServer(ctx, active_db->db_name, whichCluster);
|
|
|
|
/*
|
|
* 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(ctx, 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 "
|
|
" n.nspname != 'pg_catalog' 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 (script == NULL && (script = fopen(output_path, "w")) == NULL)
|
|
pg_log(ctx, PG_FATAL, "Could not create necessary file: %s\n", output_path);
|
|
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 (found)
|
|
{
|
|
fclose(script);
|
|
pg_log(ctx, PG_REPORT, "fatal\n");
|
|
pg_log(ctx, PG_FATAL,
|
|
"| Your installation uses the \"name\" data type in\n"
|
|
"| user tables. This data type changed its internal\n"
|
|
"| alignment between your old and new clusters so this\n"
|
|
"| cluster cannot currently be upgraded. You can\n"
|
|
"| remove the problem tables and restart the migration.\n"
|
|
"| A list of the problem columns is in the file:\n"
|
|
"| \t%s\n\n", output_path);
|
|
}
|
|
else
|
|
check_ok(ctx);
|
|
}
|
|
|
|
|
|
/*
|
|
* 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 migration of such fields is impossible.
|
|
*/
|
|
void
|
|
old_8_3_check_for_tsquery_usage(migratorContext *ctx, Cluster whichCluster)
|
|
{
|
|
ClusterInfo *active_cluster = (whichCluster == CLUSTER_OLD) ?
|
|
&ctx->old : &ctx->new;
|
|
int dbnum;
|
|
FILE *script = NULL;
|
|
bool found = false;
|
|
char output_path[MAXPGPATH];
|
|
|
|
prep_status(ctx, "Checking for tsquery user columns");
|
|
|
|
snprintf(output_path, sizeof(output_path), "%s/tables_using_tsquery.txt",
|
|
ctx->cwd);
|
|
|
|
for (dbnum = 0; dbnum < active_cluster->dbarr.ndbs; dbnum++)
|
|
{
|
|
PGresult *res;
|
|
bool db_used = false;
|
|
int ntups;
|
|
int rowno;
|
|
int i_nspname,
|
|
i_relname,
|
|
i_attname;
|
|
DbInfo *active_db = &active_cluster->dbarr.dbs[dbnum];
|
|
PGconn *conn = connectToServer(ctx, active_db->db_name, whichCluster);
|
|
|
|
/* Find any user-defined tsquery columns */
|
|
res = executeQueryOrDie(ctx, 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 "
|
|
" n.nspname != 'pg_catalog' 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 (script == NULL && (script = fopen(output_path, "w")) == NULL)
|
|
pg_log(ctx, PG_FATAL, "Could not create necessary file: %s\n", output_path);
|
|
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 (found)
|
|
{
|
|
fclose(script);
|
|
pg_log(ctx, PG_REPORT, "fatal\n");
|
|
pg_log(ctx, PG_FATAL,
|
|
"| Your installation uses the \"tsquery\" data type.\n"
|
|
"| This data type added a new internal field between\n"
|
|
"| your old and new clusters so this cluster cannot\n"
|
|
"| currently be upgraded. You can remove the problem\n"
|
|
"| columns and restart the migration. A list of the\n"
|
|
"| problem columns is in the file:\n"
|
|
"| \t%s\n\n", output_path);
|
|
}
|
|
else
|
|
check_ok(ctx);
|
|
}
|
|
|
|
|
|
/*
|
|
* old_8_3_check_for_isn_and_int8_passing_mismatch()
|
|
* 8.3 -> 8.4
|
|
* /contrib/isn relies on data type int8, and in 8.4 int8 is now passed
|
|
* by value. The schema dumps the CREATE TYPE PASSEDBYVALUE setting so
|
|
* it must match for the old and new servers.
|
|
*/
|
|
void
|
|
old_8_3_check_for_isn_and_int8_passing_mismatch(migratorContext *ctx, Cluster whichCluster)
|
|
{
|
|
ClusterInfo *active_cluster = (whichCluster == CLUSTER_OLD) ?
|
|
&ctx->old : &ctx->new;
|
|
int dbnum;
|
|
FILE *script = NULL;
|
|
bool found = false;
|
|
char output_path[MAXPGPATH];
|
|
|
|
prep_status(ctx, "Checking for /contrib/isn with bigint-passing mismatch");
|
|
|
|
if (ctx->old.controldata.float8_pass_by_value ==
|
|
ctx->new.controldata.float8_pass_by_value)
|
|
{
|
|
/* no mismatch */
|
|
check_ok(ctx);
|
|
return;
|
|
}
|
|
|
|
snprintf(output_path, sizeof(output_path), "%s/contrib_isn_and_int8_pass_by_value.txt",
|
|
ctx->cwd);
|
|
|
|
for (dbnum = 0; dbnum < active_cluster->dbarr.ndbs; dbnum++)
|
|
{
|
|
PGresult *res;
|
|
bool db_used = false;
|
|
int ntups;
|
|
int rowno;
|
|
int i_nspname,
|
|
i_proname;
|
|
DbInfo *active_db = &active_cluster->dbarr.dbs[dbnum];
|
|
PGconn *conn = connectToServer(ctx, active_db->db_name, whichCluster);
|
|
|
|
/* Find any functions coming from contrib/isn */
|
|
res = executeQueryOrDie(ctx, 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/isn'");
|
|
|
|
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(output_path, "w")) == NULL)
|
|
pg_log(ctx, PG_FATAL, "Could not create necessary file: %s\n", output_path);
|
|
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 (found)
|
|
{
|
|
fclose(script);
|
|
pg_log(ctx, PG_REPORT, "fatal\n");
|
|
pg_log(ctx, PG_FATAL,
|
|
"| Your installation uses \"/contrib/isn\" functions\n"
|
|
"| which rely on the bigint data type. Your old and\n"
|
|
"| new clusters pass bigint values differently so this\n"
|
|
"| cluster cannot currently be upgraded. You can\n"
|
|
"| manually migrate data that use \"/contrib/isn\"\n"
|
|
"| facilities and remove \"/contrib/isn\" from the\n"
|
|
"| old cluster and restart the migration. A list\n"
|
|
"| of the problem functions is in the file:\n"
|
|
"| \t%s\n\n", output_path);
|
|
}
|
|
else
|
|
check_ok(ctx);
|
|
}
|
|
|
|
|
|
/*
|
|
* 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(migratorContext *ctx, bool check_mode,
|
|
Cluster whichCluster)
|
|
{
|
|
ClusterInfo *active_cluster = (whichCluster == CLUSTER_OLD) ?
|
|
&ctx->old : &ctx->new;
|
|
int dbnum;
|
|
FILE *script = NULL;
|
|
bool found = false;
|
|
char output_path[MAXPGPATH];
|
|
|
|
prep_status(ctx, "Checking for tsvector user columns");
|
|
|
|
snprintf(output_path, sizeof(output_path), "%s/rebuild_tsvector_tables.sql",
|
|
ctx->cwd);
|
|
|
|
for (dbnum = 0; dbnum < active_cluster->dbarr.ndbs; dbnum++)
|
|
{
|
|
PGresult *res;
|
|
bool db_used = false;
|
|
char old_nspname[NAMEDATALEN] = "",
|
|
old_relname[NAMEDATALEN] = "";
|
|
int ntups;
|
|
int rowno;
|
|
int i_nspname,
|
|
i_relname,
|
|
i_attname;
|
|
DbInfo *active_db = &active_cluster->dbarr.dbs[dbnum];
|
|
PGconn *conn = connectToServer(ctx, active_db->db_name, whichCluster);
|
|
|
|
/* Find any user-defined tsvector columns */
|
|
res = executeQueryOrDie(ctx, 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 "
|
|
" n.nspname != 'pg_catalog' AND "
|
|
" n.nspname != '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_catalog' 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(output_path, "w")) == NULL)
|
|
pg_log(ctx, PG_FATAL, "Could not create necessary file: %s\n", output_path);
|
|
if (!db_used)
|
|
{
|
|
fprintf(script, "\\connect %s\n\n",
|
|
quote_identifier(ctx, active_db->db_name));
|
|
db_used = true;
|
|
}
|
|
|
|
/* Rebuild all tsvector collumns with one ALTER TABLE command */
|
|
if (strcmp(PQgetvalue(res, rowno, i_nspname), old_nspname) != 0 ||
|
|
strcmp(PQgetvalue(res, rowno, i_relname), old_relname) != 0)
|
|
{
|
|
if (strlen(old_nspname) != 0 || strlen(old_relname) != 0)
|
|
fprintf(script, ";\n\n");
|
|
fprintf(script, "ALTER TABLE %s.%s\n",
|
|
quote_identifier(ctx, PQgetvalue(res, rowno, i_nspname)),
|
|
quote_identifier(ctx, PQgetvalue(res, rowno, i_relname)));
|
|
}
|
|
else
|
|
fprintf(script, ",\n");
|
|
strlcpy(old_nspname, PQgetvalue(res, rowno, i_nspname), sizeof(old_nspname));
|
|
strlcpy(old_relname, PQgetvalue(res, rowno, i_relname), sizeof(old_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(ctx, PQgetvalue(res, rowno, i_attname)),
|
|
quote_identifier(ctx, PQgetvalue(res, rowno, i_attname)));
|
|
}
|
|
}
|
|
if (strlen(old_nspname) != 0 || strlen(old_relname) != 0)
|
|
fprintf(script, ";\n\n");
|
|
|
|
PQclear(res);
|
|
|
|
/* XXX Mark tables as not accessable somehow */
|
|
|
|
PQfinish(conn);
|
|
}
|
|
|
|
if (found)
|
|
{
|
|
if (!check_mode)
|
|
fclose(script);
|
|
report_status(ctx, PG_WARNING, "warning");
|
|
if (check_mode)
|
|
pg_log(ctx, PG_WARNING, "\n"
|
|
"| Your installation contains tsvector columns.\n"
|
|
"| The tsvector internal storage format changed\n"
|
|
"| between your old and new clusters so the tables\n"
|
|
"| must be rebuilt. After migration, you will be\n"
|
|
"| given instructions.\n\n");
|
|
else
|
|
pg_log(ctx, PG_WARNING, "\n"
|
|
"| Your installation contains tsvector columns.\n"
|
|
"| The tsvector internal storage format changed\n"
|
|
"| between your old and new clusters so the tables\n"
|
|
"| must be rebuilt. The file:\n"
|
|
"| \t%s\n"
|
|
"| when executed by psql by the database super-user\n"
|
|
"| will rebuild all tables with tsvector columns.\n\n",
|
|
output_path);
|
|
}
|
|
else
|
|
check_ok(ctx);
|
|
}
|
|
|
|
|
|
/*
|
|
* 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(migratorContext *ctx, bool check_mode,
|
|
Cluster whichCluster)
|
|
{
|
|
ClusterInfo *active_cluster = (whichCluster == CLUSTER_OLD) ?
|
|
&ctx->old : &ctx->new;
|
|
int dbnum;
|
|
FILE *script = NULL;
|
|
bool found = false;
|
|
char output_path[MAXPGPATH];
|
|
|
|
prep_status(ctx, "Checking for hash and gin indexes");
|
|
|
|
snprintf(output_path, sizeof(output_path), "%s/reindex_hash_and_gin.sql",
|
|
ctx->cwd);
|
|
|
|
for (dbnum = 0; dbnum < active_cluster->dbarr.ndbs; dbnum++)
|
|
{
|
|
PGresult *res;
|
|
bool db_used = false;
|
|
int ntups;
|
|
int rowno;
|
|
int i_nspname,
|
|
i_relname;
|
|
DbInfo *active_db = &active_cluster->dbarr.dbs[dbnum];
|
|
PGconn *conn = connectToServer(ctx, active_db->db_name, whichCluster);
|
|
|
|
/* find hash and gin indexes */
|
|
res = executeQueryOrDie(ctx, 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(output_path, "w")) == NULL)
|
|
pg_log(ctx, PG_FATAL, "Could not create necessary file: %s\n", output_path);
|
|
if (!db_used)
|
|
{
|
|
fprintf(script, "\\connect %s\n",
|
|
quote_identifier(ctx, active_db->db_name));
|
|
db_used = true;
|
|
}
|
|
fprintf(script, "REINDEX INDEX %s.%s;\n",
|
|
quote_identifier(ctx, PQgetvalue(res, rowno, i_nspname)),
|
|
quote_identifier(ctx, PQgetvalue(res, rowno, i_relname)));
|
|
}
|
|
}
|
|
|
|
PQclear(res);
|
|
|
|
if (!check_mode && found)
|
|
/* mark hash and gin indexes as invalid */
|
|
PQclear(executeQueryOrDie(ctx, 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 (found)
|
|
{
|
|
if (!check_mode)
|
|
fclose(script);
|
|
report_status(ctx, PG_WARNING, "warning");
|
|
if (check_mode)
|
|
pg_log(ctx, PG_WARNING, "\n"
|
|
"| Your installation contains hash and/or gin\n"
|
|
"| indexes. These indexes have different\n"
|
|
"| internal formats between your old and new\n"
|
|
"| clusters so they must be reindexed with the\n"
|
|
"| REINDEX command. After migration, you will\n"
|
|
"| be given REINDEX instructions.\n\n");
|
|
else
|
|
pg_log(ctx, PG_WARNING, "\n"
|
|
"| Your installation contains hash and/or gin\n"
|
|
"| indexes. These indexes have different internal\n"
|
|
"| formats between your old and new clusters so\n"
|
|
"| they must be reindexed with the REINDEX command.\n"
|
|
"| The file:\n"
|
|
"| \t%s\n"
|
|
"| when executed by psql by the database super-user\n"
|
|
"| will recreate all invalid indexes; until then,\n"
|
|
"| none of these indexes will be used.\n\n",
|
|
output_path);
|
|
}
|
|
else
|
|
check_ok(ctx);
|
|
}
|
|
|
|
|
|
/*
|
|
* 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(migratorContext *ctx, bool check_mode,
|
|
Cluster whichCluster)
|
|
{
|
|
ClusterInfo *active_cluster = (whichCluster == CLUSTER_OLD) ?
|
|
&ctx->old : &ctx->new;
|
|
int dbnum;
|
|
FILE *script = NULL;
|
|
bool found = false;
|
|
char output_path[MAXPGPATH];
|
|
|
|
prep_status(ctx, "Checking for bpchar_pattern_ops indexes");
|
|
|
|
snprintf(output_path, sizeof(output_path), "%s/reindex_bpchar_ops.sql",
|
|
ctx->cwd);
|
|
|
|
for (dbnum = 0; dbnum < active_cluster->dbarr.ndbs; dbnum++)
|
|
{
|
|
PGresult *res;
|
|
bool db_used = false;
|
|
int ntups;
|
|
int rowno;
|
|
int i_nspname,
|
|
i_relname;
|
|
DbInfo *active_db = &active_cluster->dbarr.dbs[dbnum];
|
|
PGconn *conn = connectToServer(ctx, active_db->db_name, whichCluster);
|
|
|
|
/* find bpchar_pattern_ops indexes */
|
|
|
|
/*
|
|
* Do only non-hash, non-gin indexees; we already invalidated them
|
|
* above; no need to reindex twice
|
|
*/
|
|
res = executeQueryOrDie(ctx, 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(output_path, "w")) == NULL)
|
|
pg_log(ctx, PG_FATAL, "Could not create necessary file: %s\n", output_path);
|
|
if (!db_used)
|
|
{
|
|
fprintf(script, "\\connect %s\n",
|
|
quote_identifier(ctx, active_db->db_name));
|
|
db_used = true;
|
|
}
|
|
fprintf(script, "REINDEX INDEX %s.%s;\n",
|
|
quote_identifier(ctx, PQgetvalue(res, rowno, i_nspname)),
|
|
quote_identifier(ctx, PQgetvalue(res, rowno, i_relname)));
|
|
}
|
|
}
|
|
|
|
PQclear(res);
|
|
|
|
if (!check_mode && found)
|
|
/* mark bpchar_pattern_ops indexes as invalid */
|
|
PQclear(executeQueryOrDie(ctx, 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 (found)
|
|
{
|
|
if (!check_mode)
|
|
fclose(script);
|
|
report_status(ctx, PG_WARNING, "warning");
|
|
if (check_mode)
|
|
pg_log(ctx, PG_WARNING, "\n"
|
|
"| Your installation contains indexes using\n"
|
|
"| \"bpchar_pattern_ops\". These indexes have\n"
|
|
"| different internal formats between your old and\n"
|
|
"| new clusters so they must be reindexed with the\n"
|
|
"| REINDEX command. After migration, you will be\n"
|
|
"| given REINDEX instructions.\n\n");
|
|
else
|
|
pg_log(ctx, PG_WARNING, "\n"
|
|
"| Your installation contains indexes using\n"
|
|
"| \"bpchar_pattern_ops\". These indexes have\n"
|
|
"| different internal formats between your old and\n"
|
|
"| new clusters so they must be reindexed with the\n"
|
|
"| REINDEX command. The file:\n"
|
|
"| \t%s\n"
|
|
"| when executed by psql by the database super-user\n"
|
|
"| will recreate all invalid indexes; until then,\n"
|
|
"| none of these indexes will be used.\n\n",
|
|
output_path);
|
|
}
|
|
else
|
|
check_ok(ctx);
|
|
}
|
|
|
|
|
|
/*
|
|
* 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 transfered from the old
|
|
* server, even in link mode.
|
|
*/
|
|
char *
|
|
old_8_3_create_sequence_script(migratorContext *ctx, Cluster whichCluster)
|
|
{
|
|
ClusterInfo *active_cluster = (whichCluster == CLUSTER_OLD) ?
|
|
&ctx->old : &ctx->new;
|
|
int dbnum;
|
|
FILE *script = NULL;
|
|
bool found = false;
|
|
char *output_path = pg_malloc(ctx, MAXPGPATH);
|
|
|
|
snprintf(output_path, MAXPGPATH, "%s/adjust_sequences.sql", ctx->cwd);
|
|
|
|
prep_status(ctx, "Creating script to adjust sequences");
|
|
|
|
for (dbnum = 0; dbnum < active_cluster->dbarr.ndbs; dbnum++)
|
|
{
|
|
PGresult *res;
|
|
bool db_used = false;
|
|
int ntups;
|
|
int rowno;
|
|
int i_nspname,
|
|
i_relname;
|
|
DbInfo *active_db = &active_cluster->dbarr.dbs[dbnum];
|
|
PGconn *conn = connectToServer(ctx, active_db->db_name, whichCluster);
|
|
|
|
/* Find any sequences */
|
|
res = executeQueryOrDie(ctx, 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 "
|
|
" n.nspname != 'pg_catalog' AND "
|
|
" n.nspname != '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(output_path, "w")) == NULL)
|
|
pg_log(ctx, PG_FATAL, "Could not create necessary file: %s\n", output_path);
|
|
if (!db_used)
|
|
{
|
|
fprintf(script, "\\connect %s\n\n",
|
|
quote_identifier(ctx, active_db->db_name));
|
|
db_used = true;
|
|
}
|
|
|
|
/* Find the desired sequence */
|
|
seq_res = executeQueryOrDie(ctx, conn,
|
|
"SELECT s.last_value, s.is_called "
|
|
"FROM %s.%s s",
|
|
quote_identifier(ctx, nspname),
|
|
quote_identifier(ctx, 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(ctx, nspname), quote_identifier(ctx, 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 (found)
|
|
fclose(script);
|
|
|
|
check_ok(ctx);
|
|
|
|
if (found)
|
|
return output_path;
|
|
else
|
|
{
|
|
pg_free(output_path);
|
|
return NULL;
|
|
}
|
|
}
|