diff options
Diffstat (limited to 'contrib/pg_upgrade/version_old_8_3.c')
| -rw-r--r-- | contrib/pg_upgrade/version_old_8_3.c | 769 |
1 files changed, 0 insertions, 769 deletions
diff --git a/contrib/pg_upgrade/version_old_8_3.c b/contrib/pg_upgrade/version_old_8_3.c deleted file mode 100644 index 07e79bd609a..00000000000 --- a/contrib/pg_upgrade/version_old_8_3.c +++ /dev/null @@ -1,769 +0,0 @@ -/* - * version.c - * - * Postgres-version-specific routines - * - * Copyright (c) 2010-2014, 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_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_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 " - /* materialized views didn't exist in 8.3, so no need to check 'm' */ - "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_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_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_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_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 " - /* materialized views didn't exist in 8.3, so no need to check 'm' */ - "WHERE c.relkind = 'r' AND " - " c.oid = a.attrelid AND " - " NOT a.attisdropped AND " - /* child attribute changes are processed by the parent */ - " a.attinhcount = 0 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 " \ - /* materialized views didn't exist in 8.3, so no need to check 'm' */ \ - "WHERE c.relkind = 'r' AND " \ - " c.oid = a.attrelid AND " \ - " NOT a.attisdropped AND " \ - /* child attribute changes are processed by the parent */ \ - " a.attinhcount = 0 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_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 and GIN index binary format changed 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_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_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; - - output_path = pg_strdup("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_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; - } -} |