pg_dump.c

Go to the documentation of this file.

/*-------------------------------------------------------------------------
 *
 * pg_dump.c
 *    pg_dump is a utility for dumping out a postgres database
 *    into a script file.
 *
 * Portions Copyright (c) 1996-2013, PostgreSQL Global Development Group
 * Portions Copyright (c) 1994, Regents of the University of California
 *
 *  pg_dump will read the system catalogs in a database and dump out a
 *  script that reproduces the schema in terms of SQL that is understood
 *  by PostgreSQL
 *
 *  Note that pg_dump runs in a transaction-snapshot mode transaction,
 *  so it sees a consistent snapshot of the database including system
 *  catalogs. However, it relies in part on various specialized backend
 *  functions like pg_get_indexdef(), and those things tend to run on
 *  SnapshotNow time, ie they look at the currently committed state.  So
 *  it is possible to get 'cache lookup failed' error if someone
 *  performs DDL changes while a dump is happening. The window for this
 *  sort of thing is from the acquisition of the transaction snapshot to
 *  getSchemaData() (when pg_dump acquires AccessShareLock on every
 *  table it intends to dump). It isn't very large, but it can happen.
 *
 *  http://archives.postgresql.org/pgsql-bugs/2010-02/msg00187.php
 *
 * IDENTIFICATION
 *    src/bin/pg_dump/pg_dump.c
 *
 *-------------------------------------------------------------------------
 */

#include "postgres_fe.h"

#include <unistd.h>
#include <ctype.h>
#ifdef ENABLE_NLS
#include <locale.h>
#endif
#ifdef HAVE_TERMIOS_H
#include <termios.h>
#endif

#include "getopt_long.h"

#include "access/attnum.h"
#include "access/sysattr.h"
#include "access/transam.h"
#include "catalog/pg_cast.h"
#include "catalog/pg_class.h"
#include "catalog/pg_default_acl.h"
#include "catalog/pg_event_trigger.h"
#include "catalog/pg_largeobject.h"
#include "catalog/pg_largeobject_metadata.h"
#include "catalog/pg_proc.h"
#include "catalog/pg_trigger.h"
#include "catalog/pg_type.h"
#include "libpq/libpq-fs.h"

#include "pg_backup_archiver.h"
#include "pg_backup_db.h"
#include "pg_backup_utils.h"
#include "dumputils.h"
#include "parallel.h"

extern char *optarg;
extern int  optind,
            opterr;


typedef struct
{
    const char *descr;          /* comment for an object */
    Oid         classoid;       /* object class (catalog OID) */
    Oid         objoid;         /* object OID */
    int         objsubid;       /* subobject (table column #) */
} CommentItem;

typedef struct
{
    const char *provider;       /* label provider of this security label */
    const char *label;          /* security label for an object */
    Oid         classoid;       /* object class (catalog OID) */
    Oid         objoid;         /* object OID */
    int         objsubid;       /* subobject (table column #) */
} SecLabelItem;

/* global decls */
bool        g_verbose;          /* User wants verbose narration of our
                                 * activities. */

/* various user-settable parameters */
bool        schemaOnly;
bool        dataOnly;
int         dumpSections;       /* bitmask of chosen sections */
bool        aclsSkip;
const char *lockWaitTimeout;

/* subquery used to convert user ID (eg, datdba) to user name */
static const char *username_subquery;

/* obsolete as of 7.3: */
static Oid  g_last_builtin_oid; /* value of the last builtin oid */

/*
 * Object inclusion/exclusion lists
 *
 * The string lists record the patterns given by command-line switches,
 * which we then convert to lists of OIDs of matching objects.
 */
static SimpleStringList schema_include_patterns = {NULL, NULL};
static SimpleOidList schema_include_oids = {NULL, NULL};
static SimpleStringList schema_exclude_patterns = {NULL, NULL};
static SimpleOidList schema_exclude_oids = {NULL, NULL};

static SimpleStringList table_include_patterns = {NULL, NULL};
static SimpleOidList table_include_oids = {NULL, NULL};
static SimpleStringList table_exclude_patterns = {NULL, NULL};
static SimpleOidList table_exclude_oids = {NULL, NULL};
static SimpleStringList tabledata_exclude_patterns = {NULL, NULL};
static SimpleOidList tabledata_exclude_oids = {NULL, NULL};

/* default, if no "inclusion" switches appear, is to dump everything */
static bool include_everything = true;

char        g_opaque_type[10];  /* name for the opaque type */

/* placeholders for the delimiters for comments */
char        g_comment_start[10];
char        g_comment_end[10];

static const CatalogId nilCatalogId = {0, 0};

/* flags for various command-line long options */
static int  binary_upgrade = 0;
static int  disable_dollar_quoting = 0;
static int  dump_inserts = 0;
static int  column_inserts = 0;
static int  no_security_labels = 0;
static int  no_synchronized_snapshots = 0;
static int  no_unlogged_table_data = 0;
static int  serializable_deferrable = 0;


static void help(const char *progname);
static void setup_connection(Archive *AH, const char *dumpencoding,
                 char *use_role);
static ArchiveFormat parseArchiveFormat(const char *format, ArchiveMode *mode);
static void expand_schema_name_patterns(Archive *fout,
                            SimpleStringList *patterns,
                            SimpleOidList *oids);
static void expand_table_name_patterns(Archive *fout,
                           SimpleStringList *patterns,
                           SimpleOidList *oids);
static NamespaceInfo *findNamespace(Archive *fout, Oid nsoid, Oid objoid);
static void dumpTableData(Archive *fout, TableDataInfo *tdinfo);
static void refreshMatViewData(Archive *fout, TableDataInfo *tdinfo);
static void guessConstraintInheritance(TableInfo *tblinfo, int numTables);
static void dumpComment(Archive *fout, const char *target,
            const char *namespace, const char *owner,
            CatalogId catalogId, int subid, DumpId dumpId);
static int findComments(Archive *fout, Oid classoid, Oid objoid,
             CommentItem **items);
static int  collectComments(Archive *fout, CommentItem **items);
static void dumpSecLabel(Archive *fout, const char *target,
             const char *namespace, const char *owner,
             CatalogId catalogId, int subid, DumpId dumpId);
static int findSecLabels(Archive *fout, Oid classoid, Oid objoid,
              SecLabelItem **items);
static int  collectSecLabels(Archive *fout, SecLabelItem **items);
static void dumpDumpableObject(Archive *fout, DumpableObject *dobj);
static void dumpNamespace(Archive *fout, NamespaceInfo *nspinfo);
static void dumpExtension(Archive *fout, ExtensionInfo *extinfo);
static void dumpType(Archive *fout, TypeInfo *tyinfo);
static void dumpBaseType(Archive *fout, TypeInfo *tyinfo);
static void dumpEnumType(Archive *fout, TypeInfo *tyinfo);
static void dumpRangeType(Archive *fout, TypeInfo *tyinfo);
static void dumpDomain(Archive *fout, TypeInfo *tyinfo);
static void dumpCompositeType(Archive *fout, TypeInfo *tyinfo);
static void dumpCompositeTypeColComments(Archive *fout, TypeInfo *tyinfo);
static void dumpShellType(Archive *fout, ShellTypeInfo *stinfo);
static void dumpProcLang(Archive *fout, ProcLangInfo *plang);
static void dumpFunc(Archive *fout, FuncInfo *finfo);
static void dumpCast(Archive *fout, CastInfo *cast);
static void dumpOpr(Archive *fout, OprInfo *oprinfo);
static void dumpOpclass(Archive *fout, OpclassInfo *opcinfo);
static void dumpOpfamily(Archive *fout, OpfamilyInfo *opfinfo);
static void dumpCollation(Archive *fout, CollInfo *convinfo);
static void dumpConversion(Archive *fout, ConvInfo *convinfo);
static void dumpRule(Archive *fout, RuleInfo *rinfo);
static void dumpAgg(Archive *fout, AggInfo *agginfo);
static void dumpTrigger(Archive *fout, TriggerInfo *tginfo);
static void dumpEventTrigger(Archive *fout, EventTriggerInfo *evtinfo);
static void dumpTable(Archive *fout, TableInfo *tbinfo);
static void dumpTableSchema(Archive *fout, TableInfo *tbinfo);
static void dumpAttrDef(Archive *fout, AttrDefInfo *adinfo);
static void dumpSequence(Archive *fout, TableInfo *tbinfo);
static void dumpSequenceData(Archive *fout, TableDataInfo *tdinfo);
static void dumpIndex(Archive *fout, IndxInfo *indxinfo);
static void dumpConstraint(Archive *fout, ConstraintInfo *coninfo);
static void dumpTableConstraintComment(Archive *fout, ConstraintInfo *coninfo);
static void dumpTSParser(Archive *fout, TSParserInfo *prsinfo);
static void dumpTSDictionary(Archive *fout, TSDictInfo *dictinfo);
static void dumpTSTemplate(Archive *fout, TSTemplateInfo *tmplinfo);
static void dumpTSConfig(Archive *fout, TSConfigInfo *cfginfo);
static void dumpForeignDataWrapper(Archive *fout, FdwInfo *fdwinfo);
static void dumpForeignServer(Archive *fout, ForeignServerInfo *srvinfo);
static void dumpUserMappings(Archive *fout,
                 const char *servername, const char *namespace,
                 const char *owner, CatalogId catalogId, DumpId dumpId);
static void dumpDefaultACL(Archive *fout, DefaultACLInfo *daclinfo);

static void dumpACL(Archive *fout, CatalogId objCatId, DumpId objDumpId,
        const char *type, const char *name, const char *subname,
        const char *tag, const char *nspname, const char *owner,
        const char *acls);

static void getDependencies(Archive *fout);
static void BuildArchiveDependencies(Archive *fout);
static void findDumpableDependencies(ArchiveHandle *AH, DumpableObject *dobj,
                         DumpId **dependencies, int *nDeps, int *allocDeps);

static DumpableObject *createBoundaryObjects(void);
static void addBoundaryDependencies(DumpableObject **dobjs, int numObjs,
                        DumpableObject *boundaryObjs);

static void getDomainConstraints(Archive *fout, TypeInfo *tyinfo);
static void getTableData(TableInfo *tblinfo, int numTables, bool oids);
static void makeTableDataInfo(TableInfo *tbinfo, bool oids);
static void buildMatViewRefreshDependencies(Archive *fout);
static void getTableDataFKConstraints(void);
static char *format_function_arguments(FuncInfo *finfo, char *funcargs);
static char *format_function_arguments_old(Archive *fout,
                              FuncInfo *finfo, int nallargs,
                              char **allargtypes,
                              char **argmodes,
                              char **argnames);
static char *format_function_signature(Archive *fout,
                          FuncInfo *finfo, bool honor_quotes);
static const char *convertRegProcReference(Archive *fout,
                        const char *proc);
static const char *convertOperatorReference(Archive *fout, const char *opr);
static const char *convertTSFunction(Archive *fout, Oid funcOid);
static Oid  findLastBuiltinOid_V71(Archive *fout, const char *);
static Oid  findLastBuiltinOid_V70(Archive *fout);
static void selectSourceSchema(Archive *fout, const char *schemaName);
static char *getFormattedTypeName(Archive *fout, Oid oid, OidOptions opts);
static char *myFormatType(const char *typname, int32 typmod);
static void getBlobs(Archive *fout);
static void dumpBlob(Archive *fout, BlobInfo *binfo);
static int  dumpBlobs(Archive *fout, void *arg);
static void dumpDatabase(Archive *AH);
static void dumpEncoding(Archive *AH);
static void dumpStdStrings(Archive *AH);
static void binary_upgrade_set_type_oids_by_type_oid(Archive *fout,
                                PQExpBuffer upgrade_buffer, Oid pg_type_oid);
static bool binary_upgrade_set_type_oids_by_rel_oid(Archive *fout,
                                 PQExpBuffer upgrade_buffer, Oid pg_rel_oid);
static void binary_upgrade_set_pg_class_oids(Archive *fout,
                                 PQExpBuffer upgrade_buffer,
                                 Oid pg_class_oid, bool is_index);
static void binary_upgrade_extension_member(PQExpBuffer upgrade_buffer,
                                DumpableObject *dobj,
                                const char *objlabel);
static const char *getAttrName(int attrnum, TableInfo *tblInfo);
static const char *fmtCopyColumnList(const TableInfo *ti, PQExpBuffer buffer);
static char *get_synchronized_snapshot(Archive *fout);
static PGresult *ExecuteSqlQueryForSingleRow(Archive *fout, char *query);
static void setupDumpWorker(Archive *AHX, RestoreOptions *ropt);


int
main(int argc, char **argv)
{
    int         c;
    const char *filename = NULL;
    const char *format = "p";
    const char *dbname = NULL;
    const char *pghost = NULL;
    const char *pgport = NULL;
    const char *username = NULL;
    const char *dumpencoding = NULL;
    bool        oids = false;
    TableInfo  *tblinfo;
    int         numTables;
    DumpableObject **dobjs;
    int         numObjs;
    DumpableObject *boundaryObjs;
    int         i;
    int         numWorkers = 1;
    enum trivalue prompt_password = TRI_DEFAULT;
    int         compressLevel = -1;
    int         plainText = 0;
    int         outputClean = 0;
    int         outputCreateDB = 0;
    bool        outputBlobs = false;
    int         outputNoOwner = 0;
    char       *outputSuperuser = NULL;
    char       *use_role = NULL;
    int         optindex;
    RestoreOptions *ropt;
    ArchiveFormat archiveFormat = archUnknown;
    ArchiveMode archiveMode;
    Archive    *fout;           /* the script file */

    static int  disable_triggers = 0;
    static int  outputNoTablespaces = 0;
    static int  use_setsessauth = 0;

    static struct option long_options[] = {
        {"data-only", no_argument, NULL, 'a'},
        {"blobs", no_argument, NULL, 'b'},
        {"clean", no_argument, NULL, 'c'},
        {"create", no_argument, NULL, 'C'},
        {"dbname", required_argument, NULL, 'd'},
        {"file", required_argument, NULL, 'f'},
        {"format", required_argument, NULL, 'F'},
        {"host", required_argument, NULL, 'h'},
        {"ignore-version", no_argument, NULL, 'i'},
        {"jobs", 1, NULL, 'j'},
        {"no-reconnect", no_argument, NULL, 'R'},
        {"oids", no_argument, NULL, 'o'},
        {"no-owner", no_argument, NULL, 'O'},
        {"port", required_argument, NULL, 'p'},
        {"schema", required_argument, NULL, 'n'},
        {"exclude-schema", required_argument, NULL, 'N'},
        {"schema-only", no_argument, NULL, 's'},
        {"superuser", required_argument, NULL, 'S'},
        {"table", required_argument, NULL, 't'},
        {"exclude-table", required_argument, NULL, 'T'},
        {"no-password", no_argument, NULL, 'w'},
        {"password", no_argument, NULL, 'W'},
        {"username", required_argument, NULL, 'U'},
        {"verbose", no_argument, NULL, 'v'},
        {"no-privileges", no_argument, NULL, 'x'},
        {"no-acl", no_argument, NULL, 'x'},
        {"compress", required_argument, NULL, 'Z'},
        {"encoding", required_argument, NULL, 'E'},
        {"help", no_argument, NULL, '?'},
        {"version", no_argument, NULL, 'V'},

        /*
         * the following options don't have an equivalent short option letter
         */
        {"attribute-inserts", no_argument, &column_inserts, 1},
        {"binary-upgrade", no_argument, &binary_upgrade, 1},
        {"column-inserts", no_argument, &column_inserts, 1},
        {"disable-dollar-quoting", no_argument, &disable_dollar_quoting, 1},
        {"disable-triggers", no_argument, &disable_triggers, 1},
        {"exclude-table-data", required_argument, NULL, 4},
        {"inserts", no_argument, &dump_inserts, 1},
        {"lock-wait-timeout", required_argument, NULL, 2},
        {"no-tablespaces", no_argument, &outputNoTablespaces, 1},
        {"quote-all-identifiers", no_argument, &quote_all_identifiers, 1},
        {"role", required_argument, NULL, 3},
        {"section", required_argument, NULL, 5},
        {"serializable-deferrable", no_argument, &serializable_deferrable, 1},
        {"use-set-session-authorization", no_argument, &use_setsessauth, 1},
        {"no-security-labels", no_argument, &no_security_labels, 1},
        {"no-synchronized-snapshots", no_argument, &no_synchronized_snapshots, 1},
        {"no-unlogged-table-data", no_argument, &no_unlogged_table_data, 1},

        {NULL, 0, NULL, 0}
    };

    set_pglocale_pgservice(argv[0], PG_TEXTDOMAIN("pg_dump"));

    /*
     * Initialize what we need for parallel execution, especially for thread
     * support on Windows.
     */
    init_parallel_dump_utils();

    g_verbose = false;

    strcpy(g_comment_start, "-- ");
    g_comment_end[0] = '\0';
    strcpy(g_opaque_type, "opaque");

    dataOnly = schemaOnly = false;
    dumpSections = DUMP_UNSECTIONED;
    lockWaitTimeout = NULL;

    progname = get_progname(argv[0]);

    /* Set default options based on progname */
    if (strcmp(progname, "pg_backup") == 0)
        format = "c";

    if (argc > 1)
    {
        if (strcmp(argv[1], "--help") == 0 || strcmp(argv[1], "-?") == 0)
        {
            help(progname);
            exit_nicely(0);
        }
        if (strcmp(argv[1], "--version") == 0 || strcmp(argv[1], "-V") == 0)
        {
            puts("pg_dump (PostgreSQL) " PG_VERSION);
            exit_nicely(0);
        }
    }

    while ((c = getopt_long(argc, argv, "abcCd:E:f:F:h:ij:K:n:N:oOp:RsS:t:T:U:vwWxZ:",
                            long_options, &optindex)) != -1)
    {
        switch (c)
        {
            case 'a':           /* Dump data only */
                dataOnly = true;
                break;

            case 'b':           /* Dump blobs */
                outputBlobs = true;
                break;

            case 'c':           /* clean (i.e., drop) schema prior to create */
                outputClean = 1;
                break;

            case 'C':           /* Create DB */
                outputCreateDB = 1;
                break;

            case 'd':           /* database name */
                dbname = pg_strdup(optarg);
                break;

            case 'E':           /* Dump encoding */
                dumpencoding = pg_strdup(optarg);
                break;

            case 'f':
                filename = pg_strdup(optarg);
                break;

            case 'F':
                format = pg_strdup(optarg);
                break;

            case 'h':           /* server host */
                pghost = pg_strdup(optarg);
                break;

            case 'i':
                /* ignored, deprecated option */
                break;

            case 'j':           /* number of dump jobs */
                numWorkers = atoi(optarg);
                break;

            case 'n':           /* include schema(s) */
                simple_string_list_append(&schema_include_patterns, optarg);
                include_everything = false;
                break;

            case 'N':           /* exclude schema(s) */
                simple_string_list_append(&schema_exclude_patterns, optarg);
                break;

            case 'o':           /* Dump oids */
                oids = true;
                break;

            case 'O':           /* Don't reconnect to match owner */
                outputNoOwner = 1;
                break;

            case 'p':           /* server port */
                pgport = pg_strdup(optarg);
                break;

            case 'R':
                /* no-op, still accepted for backwards compatibility */
                break;

            case 's':           /* dump schema only */
                schemaOnly = true;
                break;

            case 'S':           /* Username for superuser in plain text output */
                outputSuperuser = pg_strdup(optarg);
                break;

            case 't':           /* include table(s) */
                simple_string_list_append(&table_include_patterns, optarg);
                include_everything = false;
                break;

            case 'T':           /* exclude table(s) */
                simple_string_list_append(&table_exclude_patterns, optarg);
                break;

            case 'U':
                username = pg_strdup(optarg);
                break;

            case 'v':           /* verbose */
                g_verbose = true;
                break;

            case 'w':
                prompt_password = TRI_NO;
                break;

            case 'W':
                prompt_password = TRI_YES;
                break;

            case 'x':           /* skip ACL dump */
                aclsSkip = true;
                break;

            case 'Z':           /* Compression Level */
                compressLevel = atoi(optarg);
                break;

            case 0:
                /* This covers the long options. */
                break;

            case 2:             /* lock-wait-timeout */
                lockWaitTimeout = pg_strdup(optarg);
                break;

            case 3:             /* SET ROLE */
                use_role = pg_strdup(optarg);
                break;

            case 4:             /* exclude table(s) data */
                simple_string_list_append(&tabledata_exclude_patterns, optarg);
                break;

            case 5:             /* section */
                set_dump_section(optarg, &dumpSections);
                break;

            default:
                fprintf(stderr, _("Try \"%s --help\" for more information.\n"), progname);
                exit_nicely(1);
        }
    }

    /*
     * Non-option argument specifies database name as long as it wasn't
     * already specified with -d / --dbname
     */
    if (optind < argc && dbname == NULL)
        dbname = argv[optind++];

    /* Complain if any arguments remain */
    if (optind < argc)
    {
        fprintf(stderr, _("%s: too many command-line arguments (first is \"%s\")\n"),
                progname, argv[optind]);
        fprintf(stderr, _("Try \"%s --help\" for more information.\n"),
                progname);
        exit_nicely(1);
    }

    /* --column-inserts implies --inserts */
    if (column_inserts)
        dump_inserts = 1;

    if (dataOnly && schemaOnly)
        exit_horribly(NULL, "options -s/--schema-only and -a/--data-only cannot be used together\n");

    if (dataOnly && outputClean)
        exit_horribly(NULL, "options -c/--clean and -a/--data-only cannot be used together\n");

    if (dump_inserts && oids)
    {
        write_msg(NULL, "options --inserts/--column-inserts and -o/--oids cannot be used together\n");
        write_msg(NULL, "(The INSERT command cannot set OIDs.)\n");
        exit_nicely(1);
    }

    /* Identify archive format to emit */
    archiveFormat = parseArchiveFormat(format, &archiveMode);

    /* archiveFormat specific setup */
    if (archiveFormat == archNull)
        plainText = 1;

    /* Custom and directory formats are compressed by default, others not */
    if (compressLevel == -1)
    {
        if (archiveFormat == archCustom || archiveFormat == archDirectory)
            compressLevel = Z_DEFAULT_COMPRESSION;
        else
            compressLevel = 0;
    }

    /*
     * On Windows we can only have at most MAXIMUM_WAIT_OBJECTS (= 64 usually)
     * parallel jobs because that's the maximum limit for the
     * WaitForMultipleObjects() call.
     */
    if (numWorkers <= 0
#ifdef WIN32
        || numWorkers > MAXIMUM_WAIT_OBJECTS
#endif
        )
        exit_horribly(NULL, "%s: invalid number of parallel jobs\n", progname);

    /* Parallel backup only in the directory archive format so far */
    if (archiveFormat != archDirectory && numWorkers > 1)
        exit_horribly(NULL, "parallel backup only supported by the directory format\n");

    /* Open the output file */
    fout = CreateArchive(filename, archiveFormat, compressLevel, archiveMode,
                         setupDumpWorker);

    /* Register the cleanup hook */
    on_exit_close_archive(fout);

    if (fout == NULL)
        exit_horribly(NULL, "could not open output file \"%s\" for writing\n", filename);

    /* Let the archiver know how noisy to be */
    fout->verbose = g_verbose;

    /*
     * We allow the server to be back to 7.0, and up to any minor release of
     * our own major version.  (See also version check in pg_dumpall.c.)
     */
    fout->minRemoteVersion = 70000;
    fout->maxRemoteVersion = (PG_VERSION_NUM / 100) * 100 + 99;

    fout->numWorkers = numWorkers;

    /*
     * Open the database using the Archiver, so it knows about it. Errors mean
     * death.
     */
    ConnectDatabase(fout, dbname, pghost, pgport, username, prompt_password);
    setup_connection(fout, dumpencoding, use_role);

    /*
     * Disable security label support if server version < v9.1.x (prevents
     * access to nonexistent pg_seclabel catalog)
     */
    if (fout->remoteVersion < 90100)
        no_security_labels = 1;

    /*
     * When running against 9.0 or later, check if we are in recovery mode,
     * which means we are on a hot standby.
     */
    if (fout->remoteVersion >= 90000)
    {
        PGresult   *res = ExecuteSqlQueryForSingleRow(fout, "SELECT pg_catalog.pg_is_in_recovery()");

        if (strcmp(PQgetvalue(res, 0, 0), "t") == 0)
        {
            /*
             * On hot standby slaves, never try to dump unlogged table data,
             * since it will just throw an error.
             */
            no_unlogged_table_data = true;
        }
        PQclear(res);
    }

    /* Select the appropriate subquery to convert user IDs to names */
    if (fout->remoteVersion >= 80100)
        username_subquery = "SELECT rolname FROM pg_catalog.pg_roles WHERE oid =";
    else if (fout->remoteVersion >= 70300)
        username_subquery = "SELECT usename FROM pg_catalog.pg_user WHERE usesysid =";
    else
        username_subquery = "SELECT usename FROM pg_user WHERE usesysid =";

    /* check the version for the synchronized snapshots feature */
    if (numWorkers > 1 && fout->remoteVersion < 90200
        && !no_synchronized_snapshots)
        exit_horribly(NULL,
                      "Synchronized snapshots are not supported by this server version.\n"
                      "Run with --no-synchronized-snapshots instead if you do not need\n"
                      "synchronized snapshots.\n");

    /* Find the last built-in OID, if needed */
    if (fout->remoteVersion < 70300)
    {
        if (fout->remoteVersion >= 70100)
            g_last_builtin_oid = findLastBuiltinOid_V71(fout,
                                                  PQdb(GetConnection(fout)));
        else
            g_last_builtin_oid = findLastBuiltinOid_V70(fout);
        if (g_verbose)
            write_msg(NULL, "last built-in OID is %u\n", g_last_builtin_oid);
    }

    /* Expand schema selection patterns into OID lists */
    if (schema_include_patterns.head != NULL)
    {
        expand_schema_name_patterns(fout, &schema_include_patterns,
                                    &schema_include_oids);
        if (schema_include_oids.head == NULL)
            exit_horribly(NULL, "No matching schemas were found\n");
    }
    expand_schema_name_patterns(fout, &schema_exclude_patterns,
                                &schema_exclude_oids);
    /* non-matching exclusion patterns aren't an error */

    /* Expand table selection patterns into OID lists */
    if (table_include_patterns.head != NULL)
    {
        expand_table_name_patterns(fout, &table_include_patterns,
                                   &table_include_oids);
        if (table_include_oids.head == NULL)
            exit_horribly(NULL, "No matching tables were found\n");
    }
    expand_table_name_patterns(fout, &table_exclude_patterns,
                               &table_exclude_oids);

    expand_table_name_patterns(fout, &tabledata_exclude_patterns,
                               &tabledata_exclude_oids);

    /* non-matching exclusion patterns aren't an error */

    /*
     * Dumping blobs is now default unless we saw an inclusion switch or -s
     * ... but even if we did see one of these, -b turns it back on.
     */
    if (include_everything && !schemaOnly)
        outputBlobs = true;

    /*
     * Now scan the database and create DumpableObject structs for all the
     * objects we intend to dump.
     */
    tblinfo = getSchemaData(fout, &numTables);

    if (fout->remoteVersion < 80400)
        guessConstraintInheritance(tblinfo, numTables);

    if (!schemaOnly)
    {
        getTableData(tblinfo, numTables, oids);
        buildMatViewRefreshDependencies(fout);
        if (dataOnly)
            getTableDataFKConstraints();
    }

    if (outputBlobs)
        getBlobs(fout);

    /*
     * Collect dependency data to assist in ordering the objects.
     */
    getDependencies(fout);

    /* Lastly, create dummy objects to represent the section boundaries */
    boundaryObjs = createBoundaryObjects();

    /* Get pointers to all the known DumpableObjects */
    getDumpableObjects(&dobjs, &numObjs);

    /*
     * Add dummy dependencies to enforce the dump section ordering.
     */
    addBoundaryDependencies(dobjs, numObjs, boundaryObjs);

    /*
     * Sort the objects into a safe dump order (no forward references).
     *
     * In 7.3 or later, we can rely on dependency information to help us
     * determine a safe order, so the initial sort is mostly for cosmetic
     * purposes: we sort by name to ensure that logically identical schemas
     * will dump identically.  Before 7.3 we don't have dependencies and we
     * use OID ordering as an (unreliable) guide to creation order.
     */
    if (fout->remoteVersion >= 70300)
        sortDumpableObjectsByTypeName(dobjs, numObjs);
    else
        sortDumpableObjectsByTypeOid(dobjs, numObjs);

    /* If we do a parallel dump, we want the largest tables to go first */
    if (archiveFormat == archDirectory && numWorkers > 1)
        sortDataAndIndexObjectsBySize(dobjs, numObjs);

    sortDumpableObjects(dobjs, numObjs,
                        boundaryObjs[0].dumpId, boundaryObjs[1].dumpId);

    /*
     * Create archive TOC entries for all the objects to be dumped, in a safe
     * order.
     */

    /* First the special ENCODING and STDSTRINGS entries. */
    dumpEncoding(fout);
    dumpStdStrings(fout);

    /* The database item is always next, unless we don't want it at all */
    if (include_everything && !dataOnly)
        dumpDatabase(fout);

    /* Now the rearrangeable objects. */
    for (i = 0; i < numObjs; i++)
        dumpDumpableObject(fout, dobjs[i]);

    /*
     * Set up options info to ensure we dump what we want.
     */
    ropt = NewRestoreOptions();
    ropt->filename = filename;
    ropt->dropSchema = outputClean;
    ropt->dataOnly = dataOnly;
    ropt->schemaOnly = schemaOnly;
    ropt->dumpSections = dumpSections;
    ropt->aclsSkip = aclsSkip;
    ropt->superuser = outputSuperuser;
    ropt->createDB = outputCreateDB;
    ropt->noOwner = outputNoOwner;
    ropt->noTablespace = outputNoTablespaces;
    ropt->disable_triggers = disable_triggers;
    ropt->use_setsessauth = use_setsessauth;

    if (compressLevel == -1)
        ropt->compression = 0;
    else
        ropt->compression = compressLevel;

    ropt->suppressDumpWarnings = true;  /* We've already shown them */

    SetArchiveRestoreOptions(fout, ropt);

    /*
     * The archive's TOC entries are now marked as to which ones will actually
     * be output, so we can set up their dependency lists properly. This isn't
     * necessary for plain-text output, though.
     */
    if (!plainText)
        BuildArchiveDependencies(fout);

    /*
     * And finally we can do the actual output.
     *
     * Note: for non-plain-text output formats, the output file is written
     * inside CloseArchive().  This is, um, bizarre; but not worth changing
     * right now.
     */
    if (plainText)
        RestoreArchive(fout);

    CloseArchive(fout);

    exit_nicely(0);
}


static void
help(const char *progname)
{
    printf(_("%s dumps a database as a text file or to other formats.\n\n"), progname);
    printf(_("Usage:\n"));
    printf(_("  %s [OPTION]... [DBNAME]\n"), progname);

    printf(_("\nGeneral options:\n"));
    printf(_("  -f, --file=FILENAME          output file or directory name\n"));
    printf(_("  -F, --format=c|d|t|p         output file format (custom, directory, tar,\n"
             "                               plain text (default))\n"));
    printf(_("  -j, --jobs=NUM               use this many parallel jobs to dump\n"));
    printf(_("  -v, --verbose                verbose mode\n"));
    printf(_("  -V, --version                output version information, then exit\n"));
    printf(_("  -Z, --compress=0-9           compression level for compressed formats\n"));
    printf(_("  --lock-wait-timeout=TIMEOUT  fail after waiting TIMEOUT for a table lock\n"));
    printf(_("  -?, --help                   show this help, then exit\n"));

    printf(_("\nOptions controlling the output content:\n"));
    printf(_("  -a, --data-only              dump only the data, not the schema\n"));
    printf(_("  -b, --blobs                  include large objects in dump\n"));
    printf(_("  -c, --clean                  clean (drop) database objects before recreating\n"));
    printf(_("  -C, --create                 include commands to create database in dump\n"));
    printf(_("  -E, --encoding=ENCODING      dump the data in encoding ENCODING\n"));
    printf(_("  -n, --schema=SCHEMA          dump the named schema(s) only\n"));
    printf(_("  -N, --exclude-schema=SCHEMA  do NOT dump the named schema(s)\n"));
    printf(_("  -o, --oids                   include OIDs in dump\n"));
    printf(_("  -O, --no-owner               skip restoration of object ownership in\n"
             "                               plain-text format\n"));
    printf(_("  -s, --schema-only            dump only the schema, no data\n"));
    printf(_("  -S, --superuser=NAME         superuser user name to use in plain-text format\n"));
    printf(_("  -t, --table=TABLE            dump the named table(s) only\n"));
    printf(_("  -T, --exclude-table=TABLE    do NOT dump the named table(s)\n"));
    printf(_("  -x, --no-privileges          do not dump privileges (grant/revoke)\n"));
    printf(_("  --binary-upgrade             for use by upgrade utilities only\n"));
    printf(_("  --column-inserts             dump data as INSERT commands with column names\n"));
    printf(_("  --disable-dollar-quoting     disable dollar quoting, use SQL standard quoting\n"));
    printf(_("  --disable-triggers           disable triggers during data-only restore\n"));
    printf(_("  --exclude-table-data=TABLE   do NOT dump data for the named table(s)\n"));
    printf(_("  --inserts                    dump data as INSERT commands, rather than COPY\n"));
    printf(_("  --no-security-labels         do not dump security label assignments\n"));
    printf(_("  --no-synchronized-snapshots  do not use synchronized snapshots in parallel jobs\n"));
    printf(_("  --no-tablespaces             do not dump tablespace assignments\n"));
    printf(_("  --no-unlogged-table-data     do not dump unlogged table data\n"));
    printf(_("  --quote-all-identifiers      quote all identifiers, even if not key words\n"));
    printf(_("  --section=SECTION            dump named section (pre-data, data, or post-data)\n"));
    printf(_("  --serializable-deferrable    wait until the dump can run without anomalies\n"));
    printf(_("  --use-set-session-authorization\n"
             "                               use SET SESSION AUTHORIZATION commands instead of\n"
             "                               ALTER OWNER commands to set ownership\n"));

    printf(_("\nConnection options:\n"));
    printf(_("  -d, --dbname=DBNAME      database to dump\n"));
    printf(_("  -h, --host=HOSTNAME      database server host or socket directory\n"));
    printf(_("  -p, --port=PORT          database server port number\n"));
    printf(_("  -U, --username=NAME      connect as specified database user\n"));
    printf(_("  -w, --no-password        never prompt for password\n"));
    printf(_("  -W, --password           force password prompt (should happen automatically)\n"));
    printf(_("  --role=ROLENAME          do SET ROLE before dump\n"));

    printf(_("\nIf no database name is supplied, then the PGDATABASE environment\n"
             "variable value is used.\n\n"));
    printf(_("Report bugs to <[email protected]>.\n"));
}

static void
setup_connection(Archive *AH, const char *dumpencoding, char *use_role)
{
    PGconn     *conn = GetConnection(AH);
    const char *std_strings;

    /*
     * Set the client encoding if requested. If dumpencoding == NULL then
     * either it hasn't been requested or we're a cloned connection and then
     * this has already been set in CloneArchive according to the original
     * connection encoding.
     */
    if (dumpencoding)
    {
        if (PQsetClientEncoding(conn, dumpencoding) < 0)
            exit_horribly(NULL, "invalid client encoding \"%s\" specified\n",
                          dumpencoding);
    }

    /*
     * Get the active encoding and the standard_conforming_strings setting, so
     * we know how to escape strings.
     */
    AH->encoding = PQclientEncoding(conn);

    std_strings = PQparameterStatus(conn, "standard_conforming_strings");
    AH->std_strings = (std_strings && strcmp(std_strings, "on") == 0);

    /* Set the role if requested */
    if (!use_role && AH->use_role)
        use_role = AH->use_role;

    /* Set the role if requested */
    if (use_role && AH->remoteVersion >= 80100)
    {
        PQExpBuffer query = createPQExpBuffer();

        appendPQExpBuffer(query, "SET ROLE %s", fmtId(use_role));
        ExecuteSqlStatement(AH, query->data);
        destroyPQExpBuffer(query);

        /* save this for later use on parallel connections */
        if (!AH->use_role)
            AH->use_role = strdup(use_role);
    }

    /* Set the datestyle to ISO to ensure the dump's portability */
    ExecuteSqlStatement(AH, "SET DATESTYLE = ISO");

    /* Likewise, avoid using sql_standard intervalstyle */
    if (AH->remoteVersion >= 80400)
        ExecuteSqlStatement(AH, "SET INTERVALSTYLE = POSTGRES");

    /*
     * If supported, set extra_float_digits so that we can dump float data
     * exactly (given correctly implemented float I/O code, anyway)
     */
    if (AH->remoteVersion >= 90000)
        ExecuteSqlStatement(AH, "SET extra_float_digits TO 3");
    else if (AH->remoteVersion >= 70400)
        ExecuteSqlStatement(AH, "SET extra_float_digits TO 2");

    /*
     * If synchronized scanning is supported, disable it, to prevent
     * unpredictable changes in row ordering across a dump and reload.
     */
    if (AH->remoteVersion >= 80300)
        ExecuteSqlStatement(AH, "SET synchronize_seqscans TO off");

    /*
     * Disable timeouts if supported.
     */
    if (AH->remoteVersion >= 70300)
        ExecuteSqlStatement(AH, "SET statement_timeout = 0");
    if (AH->remoteVersion >= 90300)
        ExecuteSqlStatement(AH, "SET lock_timeout = 0");

    /*
     * Quote all identifiers, if requested.
     */
    if (quote_all_identifiers && AH->remoteVersion >= 90100)
        ExecuteSqlStatement(AH, "SET quote_all_identifiers = true");

    /*
     * Start transaction-snapshot mode transaction to dump consistent data.
     */
    ExecuteSqlStatement(AH, "BEGIN");
    if (AH->remoteVersion >= 90100)
    {
        if (serializable_deferrable)
            ExecuteSqlStatement(AH,
                                "SET TRANSACTION ISOLATION LEVEL "
                                "SERIALIZABLE, READ ONLY, DEFERRABLE");
        else
            ExecuteSqlStatement(AH,
                                "SET TRANSACTION ISOLATION LEVEL "
                                "REPEATABLE READ, READ ONLY");
    }
    else if (AH->remoteVersion >= 70400)
    {
        /* note: comma was not accepted in SET TRANSACTION before 8.0 */
        ExecuteSqlStatement(AH,
                            "SET TRANSACTION ISOLATION LEVEL "
                            "SERIALIZABLE READ ONLY");
    }
    else
        ExecuteSqlStatement(AH,
                            "SET TRANSACTION ISOLATION LEVEL SERIALIZABLE");



    if (AH->numWorkers > 1 && AH->remoteVersion >= 90200 && !no_synchronized_snapshots)
    {
        if (AH->sync_snapshot_id)
        {
            PQExpBuffer query = createPQExpBuffer();

            appendPQExpBuffer(query, "SET TRANSACTION SNAPSHOT ");
            appendStringLiteralConn(query, AH->sync_snapshot_id, conn);
            destroyPQExpBuffer(query);
        }
        else
            AH->sync_snapshot_id = get_synchronized_snapshot(AH);
    }
}

static void
setupDumpWorker(Archive *AHX, RestoreOptions *ropt)
{
    setup_connection(AHX, NULL, NULL);
}

static char *
get_synchronized_snapshot(Archive *fout)
{
    char       *query = "SELECT pg_export_snapshot()";
    char       *result;
    PGresult   *res;

    res = ExecuteSqlQueryForSingleRow(fout, query);
    result = strdup(PQgetvalue(res, 0, 0));
    PQclear(res);

    return result;
}

static ArchiveFormat
parseArchiveFormat(const char *format, ArchiveMode *mode)
{
    ArchiveFormat archiveFormat;

    *mode = archModeWrite;

    if (pg_strcasecmp(format, "a") == 0 || pg_strcasecmp(format, "append") == 0)
    {
        /* This is used by pg_dumpall, and is not documented */
        archiveFormat = archNull;
        *mode = archModeAppend;
    }
    else if (pg_strcasecmp(format, "c") == 0)
        archiveFormat = archCustom;
    else if (pg_strcasecmp(format, "custom") == 0)
        archiveFormat = archCustom;
    else if (pg_strcasecmp(format, "d") == 0)
        archiveFormat = archDirectory;
    else if (pg_strcasecmp(format, "directory") == 0)
        archiveFormat = archDirectory;
    else if (pg_strcasecmp(format, "p") == 0)
        archiveFormat = archNull;
    else if (pg_strcasecmp(format, "plain") == 0)
        archiveFormat = archNull;
    else if (pg_strcasecmp(format, "t") == 0)
        archiveFormat = archTar;
    else if (pg_strcasecmp(format, "tar") == 0)
        archiveFormat = archTar;
    else
        exit_horribly(NULL, "invalid output format \"%s\" specified\n", format);
    return archiveFormat;
}

/*
 * Find the OIDs of all schemas matching the given list of patterns,
 * and append them to the given OID list.
 */
static void
expand_schema_name_patterns(Archive *fout,
                            SimpleStringList *patterns,
                            SimpleOidList *oids)
{
    PQExpBuffer query;
    PGresult   *res;
    SimpleStringListCell *cell;
    int         i;

    if (patterns->head == NULL)
        return;                 /* nothing to do */

    if (fout->remoteVersion < 70300)
        exit_horribly(NULL, "server version must be at least 7.3 to use schema selection switches\n");

    query = createPQExpBuffer();

    /*
     * We use UNION ALL rather than UNION; this might sometimes result in
     * duplicate entries in the OID list, but we don't care.
     */

    for (cell = patterns->head; cell; cell = cell->next)
    {
        if (cell != patterns->head)
            appendPQExpBuffer(query, "UNION ALL\n");
        appendPQExpBuffer(query,
                          "SELECT oid FROM pg_catalog.pg_namespace n\n");
        processSQLNamePattern(GetConnection(fout), query, cell->val, false,
                              false, NULL, "n.nspname", NULL, NULL);
    }

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    for (i = 0; i < PQntuples(res); i++)
    {
        simple_oid_list_append(oids, atooid(PQgetvalue(res, i, 0)));
    }

    PQclear(res);
    destroyPQExpBuffer(query);
}

/*
 * Find the OIDs of all tables matching the given list of patterns,
 * and append them to the given OID list.
 */
static void
expand_table_name_patterns(Archive *fout,
                           SimpleStringList *patterns, SimpleOidList *oids)
{
    PQExpBuffer query;
    PGresult   *res;
    SimpleStringListCell *cell;
    int         i;

    if (patterns->head == NULL)
        return;                 /* nothing to do */

    query = createPQExpBuffer();

    /*
     * We use UNION ALL rather than UNION; this might sometimes result in
     * duplicate entries in the OID list, but we don't care.
     */

    for (cell = patterns->head; cell; cell = cell->next)
    {
        if (cell != patterns->head)
            appendPQExpBuffer(query, "UNION ALL\n");
        appendPQExpBuffer(query,
                          "SELECT c.oid"
                          "\nFROM pg_catalog.pg_class c"
        "\n     LEFT JOIN pg_catalog.pg_namespace n ON n.oid = c.relnamespace"
                     "\nWHERE c.relkind in ('%c', '%c', '%c', '%c', '%c')\n",
                          RELKIND_RELATION, RELKIND_SEQUENCE, RELKIND_VIEW,
                          RELKIND_MATVIEW, RELKIND_FOREIGN_TABLE);
        processSQLNamePattern(GetConnection(fout), query, cell->val, true,
                              false, "n.nspname", "c.relname", NULL,
                              "pg_catalog.pg_table_is_visible(c.oid)");
    }

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    for (i = 0; i < PQntuples(res); i++)
    {
        simple_oid_list_append(oids, atooid(PQgetvalue(res, i, 0)));
    }

    PQclear(res);
    destroyPQExpBuffer(query);
}

/*
 * selectDumpableNamespace: policy-setting subroutine
 *      Mark a namespace as to be dumped or not
 */
static void
selectDumpableNamespace(NamespaceInfo *nsinfo)
{
    /*
     * If specific tables are being dumped, do not dump any complete
     * namespaces. If specific namespaces are being dumped, dump just those
     * namespaces. Otherwise, dump all non-system namespaces.
     */
    if (table_include_oids.head != NULL)
        nsinfo->dobj.dump = false;
    else if (schema_include_oids.head != NULL)
        nsinfo->dobj.dump = simple_oid_list_member(&schema_include_oids,
                                                   nsinfo->dobj.catId.oid);
    else if (strncmp(nsinfo->dobj.name, "pg_", 3) == 0 ||
             strcmp(nsinfo->dobj.name, "information_schema") == 0)
        nsinfo->dobj.dump = false;
    else
        nsinfo->dobj.dump = true;

    /*
     * In any case, a namespace can be excluded by an exclusion switch
     */
    if (nsinfo->dobj.dump &&
        simple_oid_list_member(&schema_exclude_oids,
                               nsinfo->dobj.catId.oid))
        nsinfo->dobj.dump = false;
}

/*
 * selectDumpableTable: policy-setting subroutine
 *      Mark a table as to be dumped or not
 */
static void
selectDumpableTable(TableInfo *tbinfo)
{
    /*
     * If specific tables are being dumped, dump just those tables; else, dump
     * according to the parent namespace's dump flag.
     */
    if (table_include_oids.head != NULL)
        tbinfo->dobj.dump = simple_oid_list_member(&table_include_oids,
                                                   tbinfo->dobj.catId.oid);
    else
        tbinfo->dobj.dump = tbinfo->dobj.namespace->dobj.dump;

    /*
     * In any case, a table can be excluded by an exclusion switch
     */
    if (tbinfo->dobj.dump &&
        simple_oid_list_member(&table_exclude_oids,
                               tbinfo->dobj.catId.oid))
        tbinfo->dobj.dump = false;
}

/*
 * selectDumpableType: policy-setting subroutine
 *      Mark a type as to be dumped or not
 *
 * If it's a table's rowtype or an autogenerated array type, we also apply a
 * special type code to facilitate sorting into the desired order.  (We don't
 * want to consider those to be ordinary types because that would bring tables
 * up into the datatype part of the dump order.)  We still set the object's
 * dump flag; that's not going to cause the dummy type to be dumped, but we
 * need it so that casts involving such types will be dumped correctly -- see
 * dumpCast.  This means the flag should be set the same as for the underlying
 * object (the table or base type).
 */
static void
selectDumpableType(TypeInfo *tyinfo)
{
    /* skip complex types, except for standalone composite types */
    if (OidIsValid(tyinfo->typrelid) &&
        tyinfo->typrelkind != RELKIND_COMPOSITE_TYPE)
    {
        TableInfo  *tytable = findTableByOid(tyinfo->typrelid);

        tyinfo->dobj.objType = DO_DUMMY_TYPE;
        if (tytable != NULL)
            tyinfo->dobj.dump = tytable->dobj.dump;
        else
            tyinfo->dobj.dump = false;
        return;
    }

    /* skip auto-generated array types */
    if (tyinfo->isArray)
    {
        tyinfo->dobj.objType = DO_DUMMY_TYPE;

        /*
         * Fall through to set the dump flag; we assume that the subsequent
         * rules will do the same thing as they would for the array's base
         * type.  (We cannot reliably look up the base type here, since
         * getTypes may not have processed it yet.)
         */
    }

    /* dump only types in dumpable namespaces */
    if (!tyinfo->dobj.namespace->dobj.dump)
        tyinfo->dobj.dump = false;

    /* skip undefined placeholder types */
    else if (!tyinfo->isDefined)
        tyinfo->dobj.dump = false;

    else
        tyinfo->dobj.dump = true;
}

/*
 * selectDumpableDefaultACL: policy-setting subroutine
 *      Mark a default ACL as to be dumped or not
 *
 * For per-schema default ACLs, dump if the schema is to be dumped.
 * Otherwise dump if we are dumping "everything".  Note that dataOnly
 * and aclsSkip are checked separately.
 */
static void
selectDumpableDefaultACL(DefaultACLInfo *dinfo)
{
    if (dinfo->dobj.namespace)
        dinfo->dobj.dump = dinfo->dobj.namespace->dobj.dump;
    else
        dinfo->dobj.dump = include_everything;
}

/*
 * selectDumpableExtension: policy-setting subroutine
 *      Mark an extension as to be dumped or not
 *
 * Normally, we dump all extensions, or none of them if include_everything
 * is false (i.e., a --schema or --table switch was given).  However, in
 * binary-upgrade mode it's necessary to skip built-in extensions, since we
 * assume those will already be installed in the target database.  We identify
 * such extensions by their having OIDs in the range reserved for initdb.
 */
static void
selectDumpableExtension(ExtensionInfo *extinfo)
{
    if (binary_upgrade && extinfo->dobj.catId.oid < (Oid) FirstNormalObjectId)
        extinfo->dobj.dump = false;
    else
        extinfo->dobj.dump = include_everything;
}

/*
 * selectDumpableObject: policy-setting subroutine
 *      Mark a generic dumpable object as to be dumped or not
 *
 * Use this only for object types without a special-case routine above.
 */
static void
selectDumpableObject(DumpableObject *dobj)
{
    /*
     * Default policy is to dump if parent namespace is dumpable, or always
     * for non-namespace-associated items.
     */
    if (dobj->namespace)
        dobj->dump = dobj->namespace->dobj.dump;
    else
        dobj->dump = true;
}

/*
 *  Dump a table's contents for loading using the COPY command
 *  - this routine is called by the Archiver when it wants the table
 *    to be dumped.
 */

static int
dumpTableData_copy(Archive *fout, void *dcontext)
{
    TableDataInfo *tdinfo = (TableDataInfo *) dcontext;
    TableInfo  *tbinfo = tdinfo->tdtable;
    const char *classname = tbinfo->dobj.name;
    const bool  hasoids = tbinfo->hasoids;
    const bool  oids = tdinfo->oids;
    PQExpBuffer q = createPQExpBuffer();

    /*
     * Note: can't use getThreadLocalPQExpBuffer() here, we're calling fmtId
     * which uses it already.
     */
    PQExpBuffer clistBuf = createPQExpBuffer();
    PGconn     *conn = GetConnection(fout);
    PGresult   *res;
    int         ret;
    char       *copybuf;
    const char *column_list;

    if (g_verbose)
        write_msg(NULL, "dumping contents of table %s\n", classname);

    /*
     * Make sure we are in proper schema.  We will qualify the table name
     * below anyway (in case its name conflicts with a pg_catalog table); but
     * this ensures reproducible results in case the table contains regproc,
     * regclass, etc columns.
     */
    selectSourceSchema(fout, tbinfo->dobj.namespace->dobj.name);

    /*
     * If possible, specify the column list explicitly so that we have no
     * possibility of retrieving data in the wrong column order.  (The default
     * column ordering of COPY will not be what we want in certain corner
     * cases involving ADD COLUMN and inheritance.)
     */
    if (fout->remoteVersion >= 70300)
        column_list = fmtCopyColumnList(tbinfo, clistBuf);
    else
        column_list = "";       /* can't select columns in COPY */

    if (oids && hasoids)
    {
        appendPQExpBuffer(q, "COPY %s %s WITH OIDS TO stdout;",
                          fmtQualifiedId(fout->remoteVersion,
                                         tbinfo->dobj.namespace->dobj.name,
                                         classname),
                          column_list);
    }
    else if (tdinfo->filtercond)
    {
        /* Note: this syntax is only supported in 8.2 and up */
        appendPQExpBufferStr(q, "COPY (SELECT ");
        /* klugery to get rid of parens in column list */
        if (strlen(column_list) > 2)
        {
            appendPQExpBufferStr(q, column_list + 1);
            q->data[q->len - 1] = ' ';
        }
        else
            appendPQExpBufferStr(q, "* ");
        appendPQExpBuffer(q, "FROM %s %s) TO stdout;",
                          fmtQualifiedId(fout->remoteVersion,
                                         tbinfo->dobj.namespace->dobj.name,
                                         classname),
                          tdinfo->filtercond);
    }
    else
    {
        appendPQExpBuffer(q, "COPY %s %s TO stdout;",
                          fmtQualifiedId(fout->remoteVersion,
                                         tbinfo->dobj.namespace->dobj.name,
                                         classname),
                          column_list);
    }
    res = ExecuteSqlQuery(fout, q->data, PGRES_COPY_OUT);
    PQclear(res);
    destroyPQExpBuffer(clistBuf);

    for (;;)
    {
        ret = PQgetCopyData(conn, &copybuf, 0);

        if (ret < 0)
            break;              /* done or error */

        if (copybuf)
        {
            WriteData(fout, copybuf, ret);
            PQfreemem(copybuf);
        }

        /* ----------
         * THROTTLE:
         *
         * There was considerable discussion in late July, 2000 regarding
         * slowing down pg_dump when backing up large tables. Users with both
         * slow & fast (multi-processor) machines experienced performance
         * degradation when doing a backup.
         *
         * Initial attempts based on sleeping for a number of ms for each ms
         * of work were deemed too complex, then a simple 'sleep in each loop'
         * implementation was suggested. The latter failed because the loop
         * was too tight. Finally, the following was implemented:
         *
         * If throttle is non-zero, then
         *      See how long since the last sleep.
         *      Work out how long to sleep (based on ratio).
         *      If sleep is more than 100ms, then
         *          sleep
         *          reset timer
         *      EndIf
         * EndIf
         *
         * where the throttle value was the number of ms to sleep per ms of
         * work. The calculation was done in each loop.
         *
         * Most of the hard work is done in the backend, and this solution
         * still did not work particularly well: on slow machines, the ratio
         * was 50:1, and on medium paced machines, 1:1, and on fast
         * multi-processor machines, it had little or no effect, for reasons
         * that were unclear.
         *
         * Further discussion ensued, and the proposal was dropped.
         *
         * For those people who want this feature, it can be implemented using
         * gettimeofday in each loop, calculating the time since last sleep,
         * multiplying that by the sleep ratio, then if the result is more
         * than a preset 'minimum sleep time' (say 100ms), call the 'select'
         * function to sleep for a subsecond period ie.
         *
         * select(0, NULL, NULL, NULL, &tvi);
         *
         * This will return after the interval specified in the structure tvi.
         * Finally, call gettimeofday again to save the 'last sleep time'.
         * ----------
         */
    }
    archprintf(fout, "\\.\n\n\n");

    if (ret == -2)
    {
        /* copy data transfer failed */
        write_msg(NULL, "Dumping the contents of table \"%s\" failed: PQgetCopyData() failed.\n", classname);
        write_msg(NULL, "Error message from server: %s", PQerrorMessage(conn));
        write_msg(NULL, "The command was: %s\n", q->data);
        exit_nicely(1);
    }

    /* Check command status and return to normal libpq state */
    res = PQgetResult(conn);
    if (PQresultStatus(res) != PGRES_COMMAND_OK)
    {
        write_msg(NULL, "Dumping the contents of table \"%s\" failed: PQgetResult() failed.\n", classname);
        write_msg(NULL, "Error message from server: %s", PQerrorMessage(conn));
        write_msg(NULL, "The command was: %s\n", q->data);
        exit_nicely(1);
    }
    PQclear(res);

    destroyPQExpBuffer(q);
    return 1;
}

/*
 * Dump table data using INSERT commands.
 *
 * Caution: when we restore from an archive file direct to database, the
 * INSERT commands emitted by this function have to be parsed by
 * pg_backup_db.c's ExecuteInsertCommands(), which will not handle comments,
 * E'' strings, or dollar-quoted strings.  So don't emit anything like that.
 */
static int
dumpTableData_insert(Archive *fout, void *dcontext)
{
    TableDataInfo *tdinfo = (TableDataInfo *) dcontext;
    TableInfo  *tbinfo = tdinfo->tdtable;
    const char *classname = tbinfo->dobj.name;
    PQExpBuffer q = createPQExpBuffer();
    PGresult   *res;
    int         tuple;
    int         nfields;
    int         field;

    /*
     * Make sure we are in proper schema.  We will qualify the table name
     * below anyway (in case its name conflicts with a pg_catalog table); but
     * this ensures reproducible results in case the table contains regproc,
     * regclass, etc columns.
     */
    selectSourceSchema(fout, tbinfo->dobj.namespace->dobj.name);

    if (fout->remoteVersion >= 70100)
    {
        appendPQExpBuffer(q, "DECLARE _pg_dump_cursor CURSOR FOR "
                          "SELECT * FROM ONLY %s",
                          fmtQualifiedId(fout->remoteVersion,
                                         tbinfo->dobj.namespace->dobj.name,
                                         classname));
    }
    else
    {
        appendPQExpBuffer(q, "DECLARE _pg_dump_cursor CURSOR FOR "
                          "SELECT * FROM %s",
                          fmtQualifiedId(fout->remoteVersion,
                                         tbinfo->dobj.namespace->dobj.name,
                                         classname));
    }
    if (tdinfo->filtercond)
        appendPQExpBuffer(q, " %s", tdinfo->filtercond);

    ExecuteSqlStatement(fout, q->data);

    while (1)
    {
        res = ExecuteSqlQuery(fout, "FETCH 100 FROM _pg_dump_cursor",
                              PGRES_TUPLES_OK);
        nfields = PQnfields(res);
        for (tuple = 0; tuple < PQntuples(res); tuple++)
        {
            archprintf(fout, "INSERT INTO %s ", fmtId(classname));
            if (nfields == 0)
            {
                /* corner case for zero-column table */
                archprintf(fout, "DEFAULT VALUES;\n");
                continue;
            }
            if (column_inserts)
            {
                resetPQExpBuffer(q);
                appendPQExpBuffer(q, "(");
                for (field = 0; field < nfields; field++)
                {
                    if (field > 0)
                        appendPQExpBuffer(q, ", ");
                    appendPQExpBufferStr(q, fmtId(PQfname(res, field)));
                }
                appendPQExpBuffer(q, ") ");
                archputs(q->data, fout);
            }
            archprintf(fout, "VALUES (");
            for (field = 0; field < nfields; field++)
            {
                if (field > 0)
                    archprintf(fout, ", ");
                if (PQgetisnull(res, tuple, field))
                {
                    archprintf(fout, "NULL");
                    continue;
                }

                /* XXX This code is partially duplicated in ruleutils.c */
                switch (PQftype(res, field))
                {
                    case INT2OID:
                    case INT4OID:
                    case INT8OID:
                    case OIDOID:
                    case FLOAT4OID:
                    case FLOAT8OID:
                    case NUMERICOID:
                        {
                            /*
                             * These types are printed without quotes unless
                             * they contain values that aren't accepted by the
                             * scanner unquoted (e.g., 'NaN').  Note that
                             * strtod() and friends might accept NaN, so we
                             * can't use that to test.
                             *
                             * In reality we only need to defend against
                             * infinity and NaN, so we need not get too crazy
                             * about pattern matching here.
                             */
                            const char *s = PQgetvalue(res, tuple, field);

                            if (strspn(s, "0123456789 +-eE.") == strlen(s))
                                archprintf(fout, "%s", s);
                            else
                                archprintf(fout, "'%s'", s);
                        }
                        break;

                    case BITOID:
                    case VARBITOID:
                        archprintf(fout, "B'%s'",
                                   PQgetvalue(res, tuple, field));
                        break;

                    case BOOLOID:
                        if (strcmp(PQgetvalue(res, tuple, field), "t") == 0)
                            archprintf(fout, "true");
                        else
                            archprintf(fout, "false");
                        break;

                    default:
                        /* All other types are printed as string literals. */
                        resetPQExpBuffer(q);
                        appendStringLiteralAH(q,
                                              PQgetvalue(res, tuple, field),
                                              fout);
                        archputs(q->data, fout);
                        break;
                }
            }
            archprintf(fout, ");\n");
        }

        if (PQntuples(res) <= 0)
        {
            PQclear(res);
            break;
        }
        PQclear(res);
    }

    archprintf(fout, "\n\n");

    ExecuteSqlStatement(fout, "CLOSE _pg_dump_cursor");

    destroyPQExpBuffer(q);
    return 1;
}


/*
 * dumpTableData -
 *    dump the contents of a single table
 *
 * Actually, this just makes an ArchiveEntry for the table contents.
 */
static void
dumpTableData(Archive *fout, TableDataInfo *tdinfo)
{
    TableInfo  *tbinfo = tdinfo->tdtable;
    PQExpBuffer copyBuf = createPQExpBuffer();
    PQExpBuffer clistBuf = createPQExpBuffer();
    DataDumperPtr dumpFn;
    char       *copyStmt;

    if (!dump_inserts)
    {
        /* Dump/restore using COPY */
        dumpFn = dumpTableData_copy;
        /* must use 2 steps here 'cause fmtId is nonreentrant */
        appendPQExpBuffer(copyBuf, "COPY %s ",
                          fmtId(tbinfo->dobj.name));
        appendPQExpBuffer(copyBuf, "%s %sFROM stdin;\n",
                          fmtCopyColumnList(tbinfo, clistBuf),
                      (tdinfo->oids && tbinfo->hasoids) ? "WITH OIDS " : "");
        copyStmt = copyBuf->data;
    }
    else
    {
        /* Restore using INSERT */
        dumpFn = dumpTableData_insert;
        copyStmt = NULL;
    }

    /*
     * Note: although the TableDataInfo is a full DumpableObject, we treat its
     * dependency on its table as "special" and pass it to ArchiveEntry now.
     * See comments for BuildArchiveDependencies.
     */
    ArchiveEntry(fout, tdinfo->dobj.catId, tdinfo->dobj.dumpId,
                 tbinfo->dobj.name, tbinfo->dobj.namespace->dobj.name,
                 NULL, tbinfo->rolname,
                 false, "TABLE DATA", SECTION_DATA,
                 "", "", copyStmt,
                 &(tbinfo->dobj.dumpId), 1,
                 dumpFn, tdinfo);

    destroyPQExpBuffer(copyBuf);
    destroyPQExpBuffer(clistBuf);
}

/*
 * refreshMatViewData -
 *    load or refresh the contents of a single materialized view
 *
 * Actually, this just makes an ArchiveEntry for the REFRESH MATERIALIZED VIEW
 * statement.
 */
static void
refreshMatViewData(Archive *fout, TableDataInfo *tdinfo)
{
    TableInfo  *tbinfo = tdinfo->tdtable;
    PQExpBuffer q;

    /* If the materialized view is not flagged as scannable, skip this. */
    if (!tbinfo->isscannable)
        return;

    q = createPQExpBuffer();

    appendPQExpBuffer(q, "REFRESH MATERIALIZED VIEW %s;\n",
                      fmtId(tbinfo->dobj.name));

    ArchiveEntry(fout,
                 tdinfo->dobj.catId,    /* catalog ID */
                 tdinfo->dobj.dumpId,   /* dump ID */
                 tbinfo->dobj.name,     /* Name */
                 tbinfo->dobj.namespace->dobj.name,     /* Namespace */
                 NULL,          /* Tablespace */
                 tbinfo->rolname,       /* Owner */
                 false,         /* with oids */
                 "MATERIALIZED VIEW DATA",      /* Desc */
                 SECTION_POST_DATA,     /* Section */
                 q->data,       /* Create */
                 "",            /* Del */
                 NULL,          /* Copy */
                 tdinfo->dobj.dependencies,     /* Deps */
                 tdinfo->dobj.nDeps,    /* # Deps */
                 NULL,          /* Dumper */
                 NULL);         /* Dumper Arg */

    destroyPQExpBuffer(q);
}

/*
 * getTableData -
 *    set up dumpable objects representing the contents of tables
 */
static void
getTableData(TableInfo *tblinfo, int numTables, bool oids)
{
    int         i;

    for (i = 0; i < numTables; i++)
    {
        if (tblinfo[i].dobj.dump)
            makeTableDataInfo(&(tblinfo[i]), oids);
    }
}

/*
 * Make a dumpable object for the data of this specific table
 *
 * Note: we make a TableDataInfo if and only if we are going to dump the
 * table data; the "dump" flag in such objects isn't used.
 */
static void
makeTableDataInfo(TableInfo *tbinfo, bool oids)
{
    TableDataInfo *tdinfo;

    /*
     * Nothing to do if we already decided to dump the table.  This will
     * happen for "config" tables.
     */
    if (tbinfo->dataObj != NULL)
        return;

    /* Skip VIEWs (no data to dump) */
    if (tbinfo->relkind == RELKIND_VIEW)
        return;
    /* Skip FOREIGN TABLEs (no data to dump) */
    if (tbinfo->relkind == RELKIND_FOREIGN_TABLE)
        return;

    /* Don't dump data in unlogged tables, if so requested */
    if (tbinfo->relpersistence == RELPERSISTENCE_UNLOGGED &&
        no_unlogged_table_data)
        return;

    /* Check that the data is not explicitly excluded */
    if (simple_oid_list_member(&tabledata_exclude_oids,
                               tbinfo->dobj.catId.oid))
        return;

    /* OK, let's dump it */
    tdinfo = (TableDataInfo *) pg_malloc(sizeof(TableDataInfo));

    if (tbinfo->relkind == RELKIND_MATVIEW)
        tdinfo->dobj.objType = DO_REFRESH_MATVIEW;
    else
        tdinfo->dobj.objType = DO_TABLE_DATA;

    /*
     * Note: use tableoid 0 so that this object won't be mistaken for
     * something that pg_depend entries apply to.
     */
    tdinfo->dobj.catId.tableoid = 0;
    tdinfo->dobj.catId.oid = tbinfo->dobj.catId.oid;
    AssignDumpId(&tdinfo->dobj);
    tdinfo->dobj.name = tbinfo->dobj.name;
    tdinfo->dobj.namespace = tbinfo->dobj.namespace;
    tdinfo->tdtable = tbinfo;
    tdinfo->oids = oids;
    tdinfo->filtercond = NULL;  /* might get set later */
    addObjectDependency(&tdinfo->dobj, tbinfo->dobj.dumpId);

    tbinfo->dataObj = tdinfo;
}

/*
 * The refresh for a materialized view must be dependent on the refresh for
 * any materialized view that this one is dependent on.
 *
 * This must be called after all the objects are created, but before they are
 * sorted.
 */
static void
buildMatViewRefreshDependencies(Archive *fout)
{
    PQExpBuffer query;
    PGresult   *res;
    int         ntups,
                i;
    int         i_classid,
                i_objid,
                i_refobjid;

    /* No Mat Views before 9.3. */
    if (fout->remoteVersion < 90300)
        return;

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    query = createPQExpBuffer();

    appendPQExpBuffer(query, "with recursive w as "
                      "( "
                    "select d1.objid, d2.refobjid, c2.relkind as refrelkind "
                      "from pg_depend d1 "
                      "join pg_class c1 on c1.oid = d1.objid "
                      "and c1.relkind = 'm' "
                      "join pg_rewrite r1 on r1.ev_class = d1.objid "
                  "join pg_depend d2 on d2.classid = 'pg_rewrite'::regclass "
                      "and d2.objid = r1.oid "
                      "and d2.refobjid <> d1.objid "
                      "join pg_class c2 on c2.oid = d2.refobjid "
                      "and c2.relkind in ('m','v') "
                      "where d1.classid = 'pg_class'::regclass "
                      "union "
                      "select w.objid, d3.refobjid, c3.relkind "
                      "from w "
                      "join pg_rewrite r3 on r3.ev_class = w.refobjid "
                  "join pg_depend d3 on d3.classid = 'pg_rewrite'::regclass "
                      "and d3.objid = r3.oid "
                      "and d3.refobjid <> w.refobjid "
                      "join pg_class c3 on c3.oid = d3.refobjid "
                      "and c3.relkind in ('m','v') "
                      ") "
              "select 'pg_class'::regclass::oid as classid, objid, refobjid "
                      "from w "
                      "where refrelkind = 'm'");

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);

    i_classid = PQfnumber(res, "classid");
    i_objid = PQfnumber(res, "objid");
    i_refobjid = PQfnumber(res, "refobjid");

    for (i = 0; i < ntups; i++)
    {
        CatalogId   objId;
        CatalogId   refobjId;
        DumpableObject *dobj;
        DumpableObject *refdobj;
        TableInfo  *tbinfo;
        TableInfo  *reftbinfo;

        objId.tableoid = atooid(PQgetvalue(res, i, i_classid));
        objId.oid = atooid(PQgetvalue(res, i, i_objid));
        refobjId.tableoid = objId.tableoid;
        refobjId.oid = atooid(PQgetvalue(res, i, i_refobjid));

        dobj = findObjectByCatalogId(objId);
        if (dobj == NULL)
            continue;

        Assert(dobj->objType == DO_TABLE);
        tbinfo = (TableInfo *) dobj;
        Assert(tbinfo->relkind == RELKIND_MATVIEW);
        dobj = (DumpableObject *) tbinfo->dataObj;
        if (dobj == NULL)
            continue;
        Assert(dobj->objType == DO_REFRESH_MATVIEW);

        refdobj = findObjectByCatalogId(refobjId);
        if (refdobj == NULL)
            continue;

        Assert(refdobj->objType == DO_TABLE);
        reftbinfo = (TableInfo *) refdobj;
        Assert(reftbinfo->relkind == RELKIND_MATVIEW);
        refdobj = (DumpableObject *) reftbinfo->dataObj;
        if (refdobj == NULL)
            continue;
        Assert(refdobj->objType == DO_REFRESH_MATVIEW);

        addObjectDependency(dobj, refdobj->dumpId);

        if (!reftbinfo->isscannable)
            tbinfo->isscannable = false;
    }

    PQclear(res);

    destroyPQExpBuffer(query);
}

/*
 * getTableDataFKConstraints -
 *    add dump-order dependencies reflecting foreign key constraints
 *
 * This code is executed only in a data-only dump --- in schema+data dumps
 * we handle foreign key issues by not creating the FK constraints until
 * after the data is loaded.  In a data-only dump, however, we want to
 * order the table data objects in such a way that a table's referenced
 * tables are restored first.  (In the presence of circular references or
 * self-references this may be impossible; we'll detect and complain about
 * that during the dependency sorting step.)
 */
static void
getTableDataFKConstraints(void)
{
    DumpableObject **dobjs;
    int         numObjs;
    int         i;

    /* Search through all the dumpable objects for FK constraints */
    getDumpableObjects(&dobjs, &numObjs);
    for (i = 0; i < numObjs; i++)
    {
        if (dobjs[i]->objType == DO_FK_CONSTRAINT)
        {
            ConstraintInfo *cinfo = (ConstraintInfo *) dobjs[i];
            TableInfo  *ftable;

            /* Not interesting unless both tables are to be dumped */
            if (cinfo->contable == NULL ||
                cinfo->contable->dataObj == NULL)
                continue;
            ftable = findTableByOid(cinfo->confrelid);
            if (ftable == NULL ||
                ftable->dataObj == NULL)
                continue;

            /*
             * Okay, make referencing table's TABLE_DATA object depend on the
             * referenced table's TABLE_DATA object.
             */
            addObjectDependency(&cinfo->contable->dataObj->dobj,
                                ftable->dataObj->dobj.dumpId);
        }
    }
    free(dobjs);
}


/*
 * guessConstraintInheritance:
 *  In pre-8.4 databases, we can't tell for certain which constraints
 *  are inherited.  We assume a CHECK constraint is inherited if its name
 *  matches the name of any constraint in the parent.  Originally this code
 *  tried to compare the expression texts, but that can fail for various
 *  reasons --- for example, if the parent and child tables are in different
 *  schemas, reverse-listing of function calls may produce different text
 *  (schema-qualified or not) depending on search path.
 *
 *  In 8.4 and up we can rely on the conislocal field to decide which
 *  constraints must be dumped; much safer.
 *
 *  This function assumes all conislocal flags were initialized to TRUE.
 *  It clears the flag on anything that seems to be inherited.
 */
static void
guessConstraintInheritance(TableInfo *tblinfo, int numTables)
{
    int         i,
                j,
                k;

    for (i = 0; i < numTables; i++)
    {
        TableInfo  *tbinfo = &(tblinfo[i]);
        int         numParents;
        TableInfo **parents;
        TableInfo  *parent;

        /* Sequences and views never have parents */
        if (tbinfo->relkind == RELKIND_SEQUENCE ||
            tbinfo->relkind == RELKIND_VIEW)
            continue;

        /* Don't bother computing anything for non-target tables, either */
        if (!tbinfo->dobj.dump)
            continue;

        numParents = tbinfo->numParents;
        parents = tbinfo->parents;

        if (numParents == 0)
            continue;           /* nothing to see here, move along */

        /* scan for inherited CHECK constraints */
        for (j = 0; j < tbinfo->ncheck; j++)
        {
            ConstraintInfo *constr;

            constr = &(tbinfo->checkexprs[j]);

            for (k = 0; k < numParents; k++)
            {
                int         l;

                parent = parents[k];
                for (l = 0; l < parent->ncheck; l++)
                {
                    ConstraintInfo *pconstr = &(parent->checkexprs[l]);

                    if (strcmp(pconstr->dobj.name, constr->dobj.name) == 0)
                    {
                        constr->conislocal = false;
                        break;
                    }
                }
                if (!constr->conislocal)
                    break;
            }
        }
    }
}


/*
 * dumpDatabase:
 *  dump the database definition
 */
static void
dumpDatabase(Archive *fout)
{
    PQExpBuffer dbQry = createPQExpBuffer();
    PQExpBuffer delQry = createPQExpBuffer();
    PQExpBuffer creaQry = createPQExpBuffer();
    PGconn     *conn = GetConnection(fout);
    PGresult   *res;
    int         i_tableoid,
                i_oid,
                i_dba,
                i_encoding,
                i_collate,
                i_ctype,
                i_frozenxid,
                i_tablespace;
    CatalogId   dbCatId;
    DumpId      dbDumpId;
    const char *datname,
               *dba,
               *encoding,
               *collate,
               *ctype,
               *tablespace;
    uint32      frozenxid;

    datname = PQdb(conn);

    if (g_verbose)
        write_msg(NULL, "saving database definition\n");

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    /* Get the database owner and parameters from pg_database */
    if (fout->remoteVersion >= 80400)
    {
        appendPQExpBuffer(dbQry, "SELECT tableoid, oid, "
                          "(%s datdba) AS dba, "
                          "pg_encoding_to_char(encoding) AS encoding, "
                          "datcollate, datctype, datfrozenxid, "
                          "(SELECT spcname FROM pg_tablespace t WHERE t.oid = dattablespace) AS tablespace, "
                      "shobj_description(oid, 'pg_database') AS description "

                          "FROM pg_database "
                          "WHERE datname = ",
                          username_subquery);
        appendStringLiteralAH(dbQry, datname, fout);
    }
    else if (fout->remoteVersion >= 80200)
    {
        appendPQExpBuffer(dbQry, "SELECT tableoid, oid, "
                          "(%s datdba) AS dba, "
                          "pg_encoding_to_char(encoding) AS encoding, "
                       "NULL AS datcollate, NULL AS datctype, datfrozenxid, "
                          "(SELECT spcname FROM pg_tablespace t WHERE t.oid = dattablespace) AS tablespace, "
                      "shobj_description(oid, 'pg_database') AS description "

                          "FROM pg_database "
                          "WHERE datname = ",
                          username_subquery);
        appendStringLiteralAH(dbQry, datname, fout);
    }
    else if (fout->remoteVersion >= 80000)
    {
        appendPQExpBuffer(dbQry, "SELECT tableoid, oid, "
                          "(%s datdba) AS dba, "
                          "pg_encoding_to_char(encoding) AS encoding, "
                       "NULL AS datcollate, NULL AS datctype, datfrozenxid, "
                          "(SELECT spcname FROM pg_tablespace t WHERE t.oid = dattablespace) AS tablespace "
                          "FROM pg_database "
                          "WHERE datname = ",
                          username_subquery);
        appendStringLiteralAH(dbQry, datname, fout);
    }
    else if (fout->remoteVersion >= 70100)
    {
        appendPQExpBuffer(dbQry, "SELECT tableoid, oid, "
                          "(%s datdba) AS dba, "
                          "pg_encoding_to_char(encoding) AS encoding, "
                          "NULL AS datcollate, NULL AS datctype, "
                          "0 AS datfrozenxid, "
                          "NULL AS tablespace "
                          "FROM pg_database "
                          "WHERE datname = ",
                          username_subquery);
        appendStringLiteralAH(dbQry, datname, fout);
    }
    else
    {
        appendPQExpBuffer(dbQry, "SELECT "
                          "(SELECT oid FROM pg_class WHERE relname = 'pg_database') AS tableoid, "
                          "oid, "
                          "(%s datdba) AS dba, "
                          "pg_encoding_to_char(encoding) AS encoding, "
                          "NULL AS datcollate, NULL AS datctype, "
                          "0 AS datfrozenxid, "
                          "NULL AS tablespace "
                          "FROM pg_database "
                          "WHERE datname = ",
                          username_subquery);
        appendStringLiteralAH(dbQry, datname, fout);
    }

    res = ExecuteSqlQueryForSingleRow(fout, dbQry->data);

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_dba = PQfnumber(res, "dba");
    i_encoding = PQfnumber(res, "encoding");
    i_collate = PQfnumber(res, "datcollate");
    i_ctype = PQfnumber(res, "datctype");
    i_frozenxid = PQfnumber(res, "datfrozenxid");
    i_tablespace = PQfnumber(res, "tablespace");

    dbCatId.tableoid = atooid(PQgetvalue(res, 0, i_tableoid));
    dbCatId.oid = atooid(PQgetvalue(res, 0, i_oid));
    dba = PQgetvalue(res, 0, i_dba);
    encoding = PQgetvalue(res, 0, i_encoding);
    collate = PQgetvalue(res, 0, i_collate);
    ctype = PQgetvalue(res, 0, i_ctype);
    frozenxid = atooid(PQgetvalue(res, 0, i_frozenxid));
    tablespace = PQgetvalue(res, 0, i_tablespace);

    appendPQExpBuffer(creaQry, "CREATE DATABASE %s WITH TEMPLATE = template0",
                      fmtId(datname));
    if (strlen(encoding) > 0)
    {
        appendPQExpBuffer(creaQry, " ENCODING = ");
        appendStringLiteralAH(creaQry, encoding, fout);
    }
    if (strlen(collate) > 0)
    {
        appendPQExpBuffer(creaQry, " LC_COLLATE = ");
        appendStringLiteralAH(creaQry, collate, fout);
    }
    if (strlen(ctype) > 0)
    {
        appendPQExpBuffer(creaQry, " LC_CTYPE = ");
        appendStringLiteralAH(creaQry, ctype, fout);
    }
    if (strlen(tablespace) > 0 && strcmp(tablespace, "pg_default") != 0)
        appendPQExpBuffer(creaQry, " TABLESPACE = %s",
                          fmtId(tablespace));
    appendPQExpBuffer(creaQry, ";\n");

    if (binary_upgrade)
    {
        appendPQExpBuffer(creaQry, "\n-- For binary upgrade, set datfrozenxid.\n");
        appendPQExpBuffer(creaQry, "UPDATE pg_catalog.pg_database\n"
                          "SET datfrozenxid = '%u'\n"
                          "WHERE    datname = ",
                          frozenxid);
        appendStringLiteralAH(creaQry, datname, fout);
        appendPQExpBuffer(creaQry, ";\n");

    }

    appendPQExpBuffer(delQry, "DROP DATABASE %s;\n",
                      fmtId(datname));

    dbDumpId = createDumpId();

    ArchiveEntry(fout,
                 dbCatId,       /* catalog ID */
                 dbDumpId,      /* dump ID */
                 datname,       /* Name */
                 NULL,          /* Namespace */
                 NULL,          /* Tablespace */
                 dba,           /* Owner */
                 false,         /* with oids */
                 "DATABASE",    /* Desc */
                 SECTION_PRE_DATA,      /* Section */
                 creaQry->data, /* Create */
                 delQry->data,  /* Del */
                 NULL,          /* Copy */
                 NULL,          /* Deps */
                 0,             /* # Deps */
                 NULL,          /* Dumper */
                 NULL);         /* Dumper Arg */

    /*
     * pg_largeobject and pg_largeobject_metadata come from the old system
     * intact, so set their relfrozenxids.
     */
    if (binary_upgrade)
    {
        PGresult   *lo_res;
        PQExpBuffer loFrozenQry = createPQExpBuffer();
        PQExpBuffer loOutQry = createPQExpBuffer();
        int         i_relfrozenxid;

        /*
         * pg_largeobject
         */
        appendPQExpBuffer(loFrozenQry, "SELECT relfrozenxid\n"
                          "FROM pg_catalog.pg_class\n"
                          "WHERE oid = %u;\n",
                          LargeObjectRelationId);

        lo_res = ExecuteSqlQueryForSingleRow(fout, loFrozenQry->data);

        i_relfrozenxid = PQfnumber(lo_res, "relfrozenxid");

        appendPQExpBuffer(loOutQry, "\n-- For binary upgrade, set pg_largeobject.relfrozenxid\n");
        appendPQExpBuffer(loOutQry, "UPDATE pg_catalog.pg_class\n"
                          "SET relfrozenxid = '%u'\n"
                          "WHERE oid = %u;\n",
                          atoi(PQgetvalue(lo_res, 0, i_relfrozenxid)),
                          LargeObjectRelationId);
        ArchiveEntry(fout, nilCatalogId, createDumpId(),
                     "pg_largeobject", NULL, NULL, "",
                     false, "pg_largeobject", SECTION_PRE_DATA,
                     loOutQry->data, "", NULL,
                     NULL, 0,
                     NULL, NULL);

        PQclear(lo_res);

        /*
         * pg_largeobject_metadata
         */
        if (fout->remoteVersion >= 90000)
        {
            resetPQExpBuffer(loFrozenQry);
            resetPQExpBuffer(loOutQry);

            appendPQExpBuffer(loFrozenQry, "SELECT relfrozenxid\n"
                              "FROM pg_catalog.pg_class\n"
                              "WHERE oid = %u;\n",
                              LargeObjectMetadataRelationId);

            lo_res = ExecuteSqlQueryForSingleRow(fout, loFrozenQry->data);

            i_relfrozenxid = PQfnumber(lo_res, "relfrozenxid");

            appendPQExpBuffer(loOutQry, "\n-- For binary upgrade, set pg_largeobject_metadata.relfrozenxid\n");
            appendPQExpBuffer(loOutQry, "UPDATE pg_catalog.pg_class\n"
                              "SET relfrozenxid = '%u'\n"
                              "WHERE oid = %u;\n",
                              atoi(PQgetvalue(lo_res, 0, i_relfrozenxid)),
                              LargeObjectMetadataRelationId);
            ArchiveEntry(fout, nilCatalogId, createDumpId(),
                         "pg_largeobject_metadata", NULL, NULL, "",
                         false, "pg_largeobject_metadata", SECTION_PRE_DATA,
                         loOutQry->data, "", NULL,
                         NULL, 0,
                         NULL, NULL);

            PQclear(lo_res);
        }

        destroyPQExpBuffer(loFrozenQry);
        destroyPQExpBuffer(loOutQry);
    }

    /* Dump DB comment if any */
    if (fout->remoteVersion >= 80200)
    {
        /*
         * 8.2 keeps comments on shared objects in a shared table, so we
         * cannot use the dumpComment used for other database objects.
         */
        char       *comment = PQgetvalue(res, 0, PQfnumber(res, "description"));

        if (comment && strlen(comment))
        {
            resetPQExpBuffer(dbQry);

            /*
             * Generates warning when loaded into a differently-named
             * database.
             */
            appendPQExpBuffer(dbQry, "COMMENT ON DATABASE %s IS ", fmtId(datname));
            appendStringLiteralAH(dbQry, comment, fout);
            appendPQExpBuffer(dbQry, ";\n");

            ArchiveEntry(fout, dbCatId, createDumpId(), datname, NULL, NULL,
                         dba, false, "COMMENT", SECTION_NONE,
                         dbQry->data, "", NULL,
                         &dbDumpId, 1, NULL, NULL);
        }
    }
    else
    {
        resetPQExpBuffer(dbQry);
        appendPQExpBuffer(dbQry, "DATABASE %s", fmtId(datname));
        dumpComment(fout, dbQry->data, NULL, "",
                    dbCatId, 0, dbDumpId);
    }

    PQclear(res);

    /* Dump shared security label. */
    if (!no_security_labels && fout->remoteVersion >= 90200)
    {
        PQExpBuffer seclabelQry = createPQExpBuffer();

        buildShSecLabelQuery(conn, "pg_database", dbCatId.oid, seclabelQry);
        res = ExecuteSqlQuery(fout, seclabelQry->data, PGRES_TUPLES_OK);
        resetPQExpBuffer(seclabelQry);
        emitShSecLabels(conn, res, seclabelQry, "DATABASE", datname);
        if (strlen(seclabelQry->data))
            ArchiveEntry(fout, dbCatId, createDumpId(), datname, NULL, NULL,
                         dba, false, "SECURITY LABEL", SECTION_NONE,
                         seclabelQry->data, "", NULL,
                         &dbDumpId, 1, NULL, NULL);
        destroyPQExpBuffer(seclabelQry);
    }

    destroyPQExpBuffer(dbQry);
    destroyPQExpBuffer(delQry);
    destroyPQExpBuffer(creaQry);
}


/*
 * dumpEncoding: put the correct encoding into the archive
 */
static void
dumpEncoding(Archive *AH)
{
    const char *encname = pg_encoding_to_char(AH->encoding);
    PQExpBuffer qry = createPQExpBuffer();

    if (g_verbose)
        write_msg(NULL, "saving encoding = %s\n", encname);

    appendPQExpBuffer(qry, "SET client_encoding = ");
    appendStringLiteralAH(qry, encname, AH);
    appendPQExpBuffer(qry, ";\n");

    ArchiveEntry(AH, nilCatalogId, createDumpId(),
                 "ENCODING", NULL, NULL, "",
                 false, "ENCODING", SECTION_PRE_DATA,
                 qry->data, "", NULL,
                 NULL, 0,
                 NULL, NULL);

    destroyPQExpBuffer(qry);
}


/*
 * dumpStdStrings: put the correct escape string behavior into the archive
 */
static void
dumpStdStrings(Archive *AH)
{
    const char *stdstrings = AH->std_strings ? "on" : "off";
    PQExpBuffer qry = createPQExpBuffer();

    if (g_verbose)
        write_msg(NULL, "saving standard_conforming_strings = %s\n",
                  stdstrings);

    appendPQExpBuffer(qry, "SET standard_conforming_strings = '%s';\n",
                      stdstrings);

    ArchiveEntry(AH, nilCatalogId, createDumpId(),
                 "STDSTRINGS", NULL, NULL, "",
                 false, "STDSTRINGS", SECTION_PRE_DATA,
                 qry->data, "", NULL,
                 NULL, 0,
                 NULL, NULL);

    destroyPQExpBuffer(qry);
}


/*
 * getBlobs:
 *  Collect schema-level data about large objects
 */
static void
getBlobs(Archive *fout)
{
    PQExpBuffer blobQry = createPQExpBuffer();
    BlobInfo   *binfo;
    DumpableObject *bdata;
    PGresult   *res;
    int         ntups;
    int         i;

    /* Verbose message */
    if (g_verbose)
        write_msg(NULL, "reading large objects\n");

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    /* Fetch BLOB OIDs, and owner/ACL data if >= 9.0 */
    if (fout->remoteVersion >= 90000)
        appendPQExpBuffer(blobQry,
                          "SELECT oid, (%s lomowner) AS rolname, lomacl"
                          " FROM pg_largeobject_metadata",
                          username_subquery);
    else if (fout->remoteVersion >= 70100)
        appendPQExpBuffer(blobQry,
                          "SELECT DISTINCT loid, NULL::oid, NULL::oid"
                          " FROM pg_largeobject");
    else
        appendPQExpBuffer(blobQry,
                          "SELECT oid, NULL::oid, NULL::oid"
                          " FROM pg_class WHERE relkind = 'l'");

    res = ExecuteSqlQuery(fout, blobQry->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);
    if (ntups > 0)
    {
        /*
         * Each large object has its own BLOB archive entry.
         */
        binfo = (BlobInfo *) pg_malloc(ntups * sizeof(BlobInfo));

        for (i = 0; i < ntups; i++)
        {
            binfo[i].dobj.objType = DO_BLOB;
            binfo[i].dobj.catId.tableoid = LargeObjectRelationId;
            binfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, 0));
            AssignDumpId(&binfo[i].dobj);

            binfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, 0));
            if (!PQgetisnull(res, i, 1))
                binfo[i].rolname = pg_strdup(PQgetvalue(res, i, 1));
            else
                binfo[i].rolname = "";
            if (!PQgetisnull(res, i, 2))
                binfo[i].blobacl = pg_strdup(PQgetvalue(res, i, 2));
            else
                binfo[i].blobacl = NULL;
        }

        /*
         * If we have any large objects, a "BLOBS" archive entry is needed.
         * This is just a placeholder for sorting; it carries no data now.
         */
        bdata = (DumpableObject *) pg_malloc(sizeof(DumpableObject));
        bdata->objType = DO_BLOB_DATA;
        bdata->catId = nilCatalogId;
        AssignDumpId(bdata);
        bdata->name = pg_strdup("BLOBS");
    }

    PQclear(res);
    destroyPQExpBuffer(blobQry);
}

/*
 * dumpBlob
 *
 * dump the definition (metadata) of the given large object
 */
static void
dumpBlob(Archive *fout, BlobInfo *binfo)
{
    PQExpBuffer cquery = createPQExpBuffer();
    PQExpBuffer dquery = createPQExpBuffer();

    appendPQExpBuffer(cquery,
                      "SELECT pg_catalog.lo_create('%s');\n",
                      binfo->dobj.name);

    appendPQExpBuffer(dquery,
                      "SELECT pg_catalog.lo_unlink('%s');\n",
                      binfo->dobj.name);

    ArchiveEntry(fout, binfo->dobj.catId, binfo->dobj.dumpId,
                 binfo->dobj.name,
                 NULL, NULL,
                 binfo->rolname, false,
                 "BLOB", SECTION_PRE_DATA,
                 cquery->data, dquery->data, NULL,
                 NULL, 0,
                 NULL, NULL);

    /* set up tag for comment and/or ACL */
    resetPQExpBuffer(cquery);
    appendPQExpBuffer(cquery, "LARGE OBJECT %s", binfo->dobj.name);

    /* Dump comment if any */
    dumpComment(fout, cquery->data,
                NULL, binfo->rolname,
                binfo->dobj.catId, 0, binfo->dobj.dumpId);

    /* Dump security label if any */
    dumpSecLabel(fout, cquery->data,
                 NULL, binfo->rolname,
                 binfo->dobj.catId, 0, binfo->dobj.dumpId);

    /* Dump ACL if any */
    if (binfo->blobacl)
        dumpACL(fout, binfo->dobj.catId, binfo->dobj.dumpId, "LARGE OBJECT",
                binfo->dobj.name, NULL, cquery->data,
                NULL, binfo->rolname, binfo->blobacl);

    destroyPQExpBuffer(cquery);
    destroyPQExpBuffer(dquery);
}

/*
 * dumpBlobs:
 *  dump the data contents of all large objects
 */
static int
dumpBlobs(Archive *fout, void *arg)
{
    const char *blobQry;
    const char *blobFetchQry;
    PGconn     *conn = GetConnection(fout);
    PGresult   *res;
    char        buf[LOBBUFSIZE];
    int         ntups;
    int         i;
    int         cnt;

    if (g_verbose)
        write_msg(NULL, "saving large objects\n");

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    /*
     * Currently, we re-fetch all BLOB OIDs using a cursor.  Consider scanning
     * the already-in-memory dumpable objects instead...
     */
    if (fout->remoteVersion >= 90000)
        blobQry = "DECLARE bloboid CURSOR FOR SELECT oid FROM pg_largeobject_metadata";
    else if (fout->remoteVersion >= 70100)
        blobQry = "DECLARE bloboid CURSOR FOR SELECT DISTINCT loid FROM pg_largeobject";
    else
        blobQry = "DECLARE bloboid CURSOR FOR SELECT oid FROM pg_class WHERE relkind = 'l'";

    ExecuteSqlStatement(fout, blobQry);

    /* Command to fetch from cursor */
    blobFetchQry = "FETCH 1000 IN bloboid";

    do
    {
        /* Do a fetch */
        res = ExecuteSqlQuery(fout, blobFetchQry, PGRES_TUPLES_OK);

        /* Process the tuples, if any */
        ntups = PQntuples(res);
        for (i = 0; i < ntups; i++)
        {
            Oid         blobOid;
            int         loFd;

            blobOid = atooid(PQgetvalue(res, i, 0));
            /* Open the BLOB */
            loFd = lo_open(conn, blobOid, INV_READ);
            if (loFd == -1)
                exit_horribly(NULL, "could not open large object %u: %s",
                              blobOid, PQerrorMessage(conn));

            StartBlob(fout, blobOid);

            /* Now read it in chunks, sending data to archive */
            do
            {
                cnt = lo_read(conn, loFd, buf, LOBBUFSIZE);
                if (cnt < 0)
                    exit_horribly(NULL, "error reading large object %u: %s",
                                  blobOid, PQerrorMessage(conn));

                WriteData(fout, buf, cnt);
            } while (cnt > 0);

            lo_close(conn, loFd);

            EndBlob(fout, blobOid);
        }

        PQclear(res);
    } while (ntups > 0);

    return 1;
}

static void
binary_upgrade_set_type_oids_by_type_oid(Archive *fout,
                                         PQExpBuffer upgrade_buffer,
                                         Oid pg_type_oid)
{
    PQExpBuffer upgrade_query = createPQExpBuffer();
    PGresult   *upgrade_res;
    Oid         pg_type_array_oid;

    appendPQExpBuffer(upgrade_buffer, "\n-- For binary upgrade, must preserve pg_type oid\n");
    appendPQExpBuffer(upgrade_buffer,
     "SELECT binary_upgrade.set_next_pg_type_oid('%u'::pg_catalog.oid);\n\n",
                      pg_type_oid);

    /* we only support old >= 8.3 for binary upgrades */
    appendPQExpBuffer(upgrade_query,
                      "SELECT typarray "
                      "FROM pg_catalog.pg_type "
                      "WHERE pg_type.oid = '%u'::pg_catalog.oid;",
                      pg_type_oid);

    upgrade_res = ExecuteSqlQueryForSingleRow(fout, upgrade_query->data);

    pg_type_array_oid = atooid(PQgetvalue(upgrade_res, 0, PQfnumber(upgrade_res, "typarray")));

    if (OidIsValid(pg_type_array_oid))
    {
        appendPQExpBuffer(upgrade_buffer,
               "\n-- For binary upgrade, must preserve pg_type array oid\n");
        appendPQExpBuffer(upgrade_buffer,
                          "SELECT binary_upgrade.set_next_array_pg_type_oid('%u'::pg_catalog.oid);\n\n",
                          pg_type_array_oid);
    }

    PQclear(upgrade_res);
    destroyPQExpBuffer(upgrade_query);
}

static bool
binary_upgrade_set_type_oids_by_rel_oid(Archive *fout,
                                        PQExpBuffer upgrade_buffer,
                                        Oid pg_rel_oid)
{
    PQExpBuffer upgrade_query = createPQExpBuffer();
    PGresult   *upgrade_res;
    Oid         pg_type_oid;
    bool        toast_set = false;

    /* we only support old >= 8.3 for binary upgrades */
    appendPQExpBuffer(upgrade_query,
                      "SELECT c.reltype AS crel, t.reltype AS trel "
                      "FROM pg_catalog.pg_class c "
                      "LEFT JOIN pg_catalog.pg_class t ON "
                      "  (c.reltoastrelid = t.oid) "
                      "WHERE c.oid = '%u'::pg_catalog.oid;",
                      pg_rel_oid);

    upgrade_res = ExecuteSqlQueryForSingleRow(fout, upgrade_query->data);

    pg_type_oid = atooid(PQgetvalue(upgrade_res, 0, PQfnumber(upgrade_res, "crel")));

    binary_upgrade_set_type_oids_by_type_oid(fout, upgrade_buffer,
                                             pg_type_oid);

    if (!PQgetisnull(upgrade_res, 0, PQfnumber(upgrade_res, "trel")))
    {
        /* Toast tables do not have pg_type array rows */
        Oid         pg_type_toast_oid = atooid(PQgetvalue(upgrade_res, 0,
                                            PQfnumber(upgrade_res, "trel")));

        appendPQExpBuffer(upgrade_buffer, "\n-- For binary upgrade, must preserve pg_type toast oid\n");
        appendPQExpBuffer(upgrade_buffer,
                          "SELECT binary_upgrade.set_next_toast_pg_type_oid('%u'::pg_catalog.oid);\n\n",
                          pg_type_toast_oid);

        toast_set = true;
    }

    PQclear(upgrade_res);
    destroyPQExpBuffer(upgrade_query);

    return toast_set;
}

static void
binary_upgrade_set_pg_class_oids(Archive *fout,
                                 PQExpBuffer upgrade_buffer, Oid pg_class_oid,
                                 bool is_index)
{
    PQExpBuffer upgrade_query = createPQExpBuffer();
    PGresult   *upgrade_res;
    Oid         pg_class_reltoastrelid;
    Oid         pg_class_reltoastidxid;

    appendPQExpBuffer(upgrade_query,
                      "SELECT c.reltoastrelid, t.reltoastidxid "
                      "FROM pg_catalog.pg_class c LEFT JOIN "
                      "pg_catalog.pg_class t ON (c.reltoastrelid = t.oid) "
                      "WHERE c.oid = '%u'::pg_catalog.oid;",
                      pg_class_oid);

    upgrade_res = ExecuteSqlQueryForSingleRow(fout, upgrade_query->data);

    pg_class_reltoastrelid = atooid(PQgetvalue(upgrade_res, 0, PQfnumber(upgrade_res, "reltoastrelid")));
    pg_class_reltoastidxid = atooid(PQgetvalue(upgrade_res, 0, PQfnumber(upgrade_res, "reltoastidxid")));

    appendPQExpBuffer(upgrade_buffer,
                   "\n-- For binary upgrade, must preserve pg_class oids\n");

    if (!is_index)
    {
        appendPQExpBuffer(upgrade_buffer,
                          "SELECT binary_upgrade.set_next_heap_pg_class_oid('%u'::pg_catalog.oid);\n",
                          pg_class_oid);
        /* only tables have toast tables, not indexes */
        if (OidIsValid(pg_class_reltoastrelid))
        {
            /*
             * One complexity is that the table definition might not require
             * the creation of a TOAST table, and the TOAST table might have
             * been created long after table creation, when the table was
             * loaded with wide data.  By setting the TOAST oid we force
             * creation of the TOAST heap and TOAST index by the backend so we
             * can cleanly copy the files during binary upgrade.
             */

            appendPQExpBuffer(upgrade_buffer,
                              "SELECT binary_upgrade.set_next_toast_pg_class_oid('%u'::pg_catalog.oid);\n",
                              pg_class_reltoastrelid);

            /* every toast table has an index */
            appendPQExpBuffer(upgrade_buffer,
                              "SELECT binary_upgrade.set_next_index_pg_class_oid('%u'::pg_catalog.oid);\n",
                              pg_class_reltoastidxid);
        }
    }
    else
        appendPQExpBuffer(upgrade_buffer,
                          "SELECT binary_upgrade.set_next_index_pg_class_oid('%u'::pg_catalog.oid);\n",
                          pg_class_oid);

    appendPQExpBuffer(upgrade_buffer, "\n");

    PQclear(upgrade_res);
    destroyPQExpBuffer(upgrade_query);
}

/*
 * If the DumpableObject is a member of an extension, add a suitable
 * ALTER EXTENSION ADD command to the creation commands in upgrade_buffer.
 */
static void
binary_upgrade_extension_member(PQExpBuffer upgrade_buffer,
                                DumpableObject *dobj,
                                const char *objlabel)
{
    DumpableObject *extobj = NULL;
    int         i;

    if (!dobj->ext_member)
        return;

    /*
     * Find the parent extension.  We could avoid this search if we wanted to
     * add a link field to DumpableObject, but the space costs of that would
     * be considerable.  We assume that member objects could only have a
     * direct dependency on their own extension, not any others.
     */
    for (i = 0; i < dobj->nDeps; i++)
    {
        extobj = findObjectByDumpId(dobj->dependencies[i]);
        if (extobj && extobj->objType == DO_EXTENSION)
            break;
        extobj = NULL;
    }
    if (extobj == NULL)
        exit_horribly(NULL, "could not find parent extension for %s\n", objlabel);

    appendPQExpBuffer(upgrade_buffer,
      "\n-- For binary upgrade, handle extension membership the hard way\n");
    appendPQExpBuffer(upgrade_buffer, "ALTER EXTENSION %s ADD %s;\n",
                      fmtId(extobj->name),
                      objlabel);
}

/*
 * getNamespaces:
 *    read all namespaces in the system catalogs and return them in the
 * NamespaceInfo* structure
 *
 *  numNamespaces is set to the number of namespaces read in
 */
NamespaceInfo *
getNamespaces(Archive *fout, int *numNamespaces)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    NamespaceInfo *nsinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_nspname;
    int         i_rolname;
    int         i_nspacl;

    /*
     * Before 7.3, there are no real namespaces; create two dummy entries, one
     * for user stuff and one for system stuff.
     */
    if (fout->remoteVersion < 70300)
    {
        nsinfo = (NamespaceInfo *) pg_malloc(2 * sizeof(NamespaceInfo));

        nsinfo[0].dobj.objType = DO_NAMESPACE;
        nsinfo[0].dobj.catId.tableoid = 0;
        nsinfo[0].dobj.catId.oid = 0;
        AssignDumpId(&nsinfo[0].dobj);
        nsinfo[0].dobj.name = pg_strdup("public");
        nsinfo[0].rolname = pg_strdup("");
        nsinfo[0].nspacl = pg_strdup("");

        selectDumpableNamespace(&nsinfo[0]);

        nsinfo[1].dobj.objType = DO_NAMESPACE;
        nsinfo[1].dobj.catId.tableoid = 0;
        nsinfo[1].dobj.catId.oid = 1;
        AssignDumpId(&nsinfo[1].dobj);
        nsinfo[1].dobj.name = pg_strdup("pg_catalog");
        nsinfo[1].rolname = pg_strdup("");
        nsinfo[1].nspacl = pg_strdup("");

        selectDumpableNamespace(&nsinfo[1]);

        *numNamespaces = 2;

        return nsinfo;
    }

    query = createPQExpBuffer();

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    /*
     * we fetch all namespaces including system ones, so that every object we
     * read in can be linked to a containing namespace.
     */
    appendPQExpBuffer(query, "SELECT tableoid, oid, nspname, "
                      "(%s nspowner) AS rolname, "
                      "nspacl FROM pg_namespace",
                      username_subquery);

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);

    nsinfo = (NamespaceInfo *) pg_malloc(ntups * sizeof(NamespaceInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_nspname = PQfnumber(res, "nspname");
    i_rolname = PQfnumber(res, "rolname");
    i_nspacl = PQfnumber(res, "nspacl");

    for (i = 0; i < ntups; i++)
    {
        nsinfo[i].dobj.objType = DO_NAMESPACE;
        nsinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        nsinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&nsinfo[i].dobj);
        nsinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_nspname));
        nsinfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
        nsinfo[i].nspacl = pg_strdup(PQgetvalue(res, i, i_nspacl));

        /* Decide whether to dump this namespace */
        selectDumpableNamespace(&nsinfo[i]);

        if (strlen(nsinfo[i].rolname) == 0)
            write_msg(NULL, "WARNING: owner of schema \"%s\" appears to be invalid\n",
                      nsinfo[i].dobj.name);
    }

    PQclear(res);
    destroyPQExpBuffer(query);

    *numNamespaces = ntups;

    return nsinfo;
}

/*
 * findNamespace:
 *      given a namespace OID and an object OID, look up the info read by
 *      getNamespaces
 *
 * NB: for pre-7.3 source database, we use object OID to guess whether it's
 * a system object or not.  In 7.3 and later there is no guessing, and we
 * don't use objoid at all.
 */
static NamespaceInfo *
findNamespace(Archive *fout, Oid nsoid, Oid objoid)
{
    NamespaceInfo *nsinfo;

    if (fout->remoteVersion >= 70300)
    {
        nsinfo = findNamespaceByOid(nsoid);
    }
    else
    {
        /* This code depends on the dummy objects set up by getNamespaces. */
        Oid         i;

        if (objoid > g_last_builtin_oid)
            i = 0;              /* user object */
        else
            i = 1;              /* system object */
        nsinfo = findNamespaceByOid(i);
    }

    if (nsinfo == NULL)
        exit_horribly(NULL, "schema with OID %u does not exist\n", nsoid);

    return nsinfo;
}

/*
 * getExtensions:
 *    read all extensions in the system catalogs and return them in the
 * ExtensionInfo* structure
 *
 *  numExtensions is set to the number of extensions read in
 */
ExtensionInfo *
getExtensions(Archive *fout, int *numExtensions)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    ExtensionInfo *extinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_extname;
    int         i_nspname;
    int         i_extrelocatable;
    int         i_extversion;
    int         i_extconfig;
    int         i_extcondition;

    /*
     * Before 9.1, there are no extensions.
     */
    if (fout->remoteVersion < 90100)
    {
        *numExtensions = 0;
        return NULL;
    }

    query = createPQExpBuffer();

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    appendPQExpBuffer(query, "SELECT x.tableoid, x.oid, "
                      "x.extname, n.nspname, x.extrelocatable, x.extversion, x.extconfig, x.extcondition "
                      "FROM pg_extension x "
                      "JOIN pg_namespace n ON n.oid = x.extnamespace");

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);

    extinfo = (ExtensionInfo *) pg_malloc(ntups * sizeof(ExtensionInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_extname = PQfnumber(res, "extname");
    i_nspname = PQfnumber(res, "nspname");
    i_extrelocatable = PQfnumber(res, "extrelocatable");
    i_extversion = PQfnumber(res, "extversion");
    i_extconfig = PQfnumber(res, "extconfig");
    i_extcondition = PQfnumber(res, "extcondition");

    for (i = 0; i < ntups; i++)
    {
        extinfo[i].dobj.objType = DO_EXTENSION;
        extinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        extinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&extinfo[i].dobj);
        extinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_extname));
        extinfo[i].namespace = pg_strdup(PQgetvalue(res, i, i_nspname));
        extinfo[i].relocatable = *(PQgetvalue(res, i, i_extrelocatable)) == 't';
        extinfo[i].extversion = pg_strdup(PQgetvalue(res, i, i_extversion));
        extinfo[i].extconfig = pg_strdup(PQgetvalue(res, i, i_extconfig));
        extinfo[i].extcondition = pg_strdup(PQgetvalue(res, i, i_extcondition));

        /* Decide whether we want to dump it */
        selectDumpableExtension(&(extinfo[i]));
    }

    PQclear(res);
    destroyPQExpBuffer(query);

    *numExtensions = ntups;

    return extinfo;
}

/*
 * getTypes:
 *    read all types in the system catalogs and return them in the
 * TypeInfo* structure
 *
 *  numTypes is set to the number of types read in
 *
 * NB: this must run after getFuncs() because we assume we can do
 * findFuncByOid().
 */
TypeInfo *
getTypes(Archive *fout, int *numTypes)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    TypeInfo   *tyinfo;
    ShellTypeInfo *stinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_typname;
    int         i_typnamespace;
    int         i_typacl;
    int         i_rolname;
    int         i_typinput;
    int         i_typoutput;
    int         i_typelem;
    int         i_typrelid;
    int         i_typrelkind;
    int         i_typtype;
    int         i_typisdefined;
    int         i_isarray;

    /*
     * we include even the built-in types because those may be used as array
     * elements by user-defined types
     *
     * we filter out the built-in types when we dump out the types
     *
     * same approach for undefined (shell) types and array types
     *
     * Note: as of 8.3 we can reliably detect whether a type is an
     * auto-generated array type by checking the element type's typarray.
     * (Before that the test is capable of generating false positives.) We
     * still check for name beginning with '_', though, so as to avoid the
     * cost of the subselect probe for all standard types.  This would have to
     * be revisited if the backend ever allows renaming of array types.
     */

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    if (fout->remoteVersion >= 90200)
    {
        appendPQExpBuffer(query, "SELECT tableoid, oid, typname, "
                          "typnamespace, typacl, "
                          "(%s typowner) AS rolname, "
                          "typinput::oid AS typinput, "
                          "typoutput::oid AS typoutput, typelem, typrelid, "
                          "CASE WHEN typrelid = 0 THEN ' '::\"char\" "
                          "ELSE (SELECT relkind FROM pg_class WHERE oid = typrelid) END AS typrelkind, "
                          "typtype, typisdefined, "
                          "typname[0] = '_' AND typelem != 0 AND "
                          "(SELECT typarray FROM pg_type te WHERE oid = pg_type.typelem) = oid AS isarray "
                          "FROM pg_type",
                          username_subquery);
    }
    else if (fout->remoteVersion >= 80300)
    {
        appendPQExpBuffer(query, "SELECT tableoid, oid, typname, "
                          "typnamespace, '{=U}' AS typacl, "
                          "(%s typowner) AS rolname, "
                          "typinput::oid AS typinput, "
                          "typoutput::oid AS typoutput, typelem, typrelid, "
                          "CASE WHEN typrelid = 0 THEN ' '::\"char\" "
                          "ELSE (SELECT relkind FROM pg_class WHERE oid = typrelid) END AS typrelkind, "
                          "typtype, typisdefined, "
                          "typname[0] = '_' AND typelem != 0 AND "
                          "(SELECT typarray FROM pg_type te WHERE oid = pg_type.typelem) = oid AS isarray "
                          "FROM pg_type",
                          username_subquery);
    }
    else if (fout->remoteVersion >= 70300)
    {
        appendPQExpBuffer(query, "SELECT tableoid, oid, typname, "
                          "typnamespace, '{=U}' AS typacl, "
                          "(%s typowner) AS rolname, "
                          "typinput::oid AS typinput, "
                          "typoutput::oid AS typoutput, typelem, typrelid, "
                          "CASE WHEN typrelid = 0 THEN ' '::\"char\" "
                          "ELSE (SELECT relkind FROM pg_class WHERE oid = typrelid) END AS typrelkind, "
                          "typtype, typisdefined, "
                          "typname[0] = '_' AND typelem != 0 AS isarray "
                          "FROM pg_type",
                          username_subquery);
    }
    else if (fout->remoteVersion >= 70100)
    {
        appendPQExpBuffer(query, "SELECT tableoid, oid, typname, "
                          "0::oid AS typnamespace, '{=U}' AS typacl, "
                          "(%s typowner) AS rolname, "
                          "typinput::oid AS typinput, "
                          "typoutput::oid AS typoutput, typelem, typrelid, "
                          "CASE WHEN typrelid = 0 THEN ' '::\"char\" "
                          "ELSE (SELECT relkind FROM pg_class WHERE oid = typrelid) END AS typrelkind, "
                          "typtype, typisdefined, "
                          "typname[0] = '_' AND typelem != 0 AS isarray "
                          "FROM pg_type",
                          username_subquery);
    }
    else
    {
        appendPQExpBuffer(query, "SELECT "
         "(SELECT oid FROM pg_class WHERE relname = 'pg_type') AS tableoid, "
                          "oid, typname, "
                          "0::oid AS typnamespace, '{=U}' AS typacl, "
                          "(%s typowner) AS rolname, "
                          "typinput::oid AS typinput, "
                          "typoutput::oid AS typoutput, typelem, typrelid, "
                          "CASE WHEN typrelid = 0 THEN ' '::\"char\" "
                          "ELSE (SELECT relkind FROM pg_class WHERE oid = typrelid) END AS typrelkind, "
                          "typtype, typisdefined, "
                          "typname[0] = '_' AND typelem != 0 AS isarray "
                          "FROM pg_type",
                          username_subquery);
    }

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);

    tyinfo = (TypeInfo *) pg_malloc(ntups * sizeof(TypeInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_typname = PQfnumber(res, "typname");
    i_typnamespace = PQfnumber(res, "typnamespace");
    i_typacl = PQfnumber(res, "typacl");
    i_rolname = PQfnumber(res, "rolname");
    i_typinput = PQfnumber(res, "typinput");
    i_typoutput = PQfnumber(res, "typoutput");
    i_typelem = PQfnumber(res, "typelem");
    i_typrelid = PQfnumber(res, "typrelid");
    i_typrelkind = PQfnumber(res, "typrelkind");
    i_typtype = PQfnumber(res, "typtype");
    i_typisdefined = PQfnumber(res, "typisdefined");
    i_isarray = PQfnumber(res, "isarray");

    for (i = 0; i < ntups; i++)
    {
        tyinfo[i].dobj.objType = DO_TYPE;
        tyinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        tyinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&tyinfo[i].dobj);
        tyinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_typname));
        tyinfo[i].dobj.namespace =
            findNamespace(fout,
                          atooid(PQgetvalue(res, i, i_typnamespace)),
                          tyinfo[i].dobj.catId.oid);
        tyinfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
        tyinfo[i].typacl = pg_strdup(PQgetvalue(res, i, i_typacl));
        tyinfo[i].typelem = atooid(PQgetvalue(res, i, i_typelem));
        tyinfo[i].typrelid = atooid(PQgetvalue(res, i, i_typrelid));
        tyinfo[i].typrelkind = *PQgetvalue(res, i, i_typrelkind);
        tyinfo[i].typtype = *PQgetvalue(res, i, i_typtype);
        tyinfo[i].shellType = NULL;

        if (strcmp(PQgetvalue(res, i, i_typisdefined), "t") == 0)
            tyinfo[i].isDefined = true;
        else
            tyinfo[i].isDefined = false;

        if (strcmp(PQgetvalue(res, i, i_isarray), "t") == 0)
            tyinfo[i].isArray = true;
        else
            tyinfo[i].isArray = false;

        /* Decide whether we want to dump it */
        selectDumpableType(&tyinfo[i]);

        /*
         * If it's a domain, fetch info about its constraints, if any
         */
        tyinfo[i].nDomChecks = 0;
        tyinfo[i].domChecks = NULL;
        if (tyinfo[i].dobj.dump && tyinfo[i].typtype == TYPTYPE_DOMAIN)
            getDomainConstraints(fout, &(tyinfo[i]));

        /*
         * If it's a base type, make a DumpableObject representing a shell
         * definition of the type.  We will need to dump that ahead of the I/O
         * functions for the type.  Similarly, range types need a shell
         * definition in case they have a canonicalize function.
         *
         * Note: the shell type doesn't have a catId.  You might think it
         * should copy the base type's catId, but then it might capture the
         * pg_depend entries for the type, which we don't want.
         */
        if (tyinfo[i].dobj.dump && (tyinfo[i].typtype == TYPTYPE_BASE ||
                                    tyinfo[i].typtype == TYPTYPE_RANGE))
        {
            stinfo = (ShellTypeInfo *) pg_malloc(sizeof(ShellTypeInfo));
            stinfo->dobj.objType = DO_SHELL_TYPE;
            stinfo->dobj.catId = nilCatalogId;
            AssignDumpId(&stinfo->dobj);
            stinfo->dobj.name = pg_strdup(tyinfo[i].dobj.name);
            stinfo->dobj.namespace = tyinfo[i].dobj.namespace;
            stinfo->baseType = &(tyinfo[i]);
            tyinfo[i].shellType = stinfo;

            /*
             * Initially mark the shell type as not to be dumped.  We'll only
             * dump it if the I/O or canonicalize functions need to be dumped;
             * this is taken care of while sorting dependencies.
             */
            stinfo->dobj.dump = false;

            /*
             * However, if dumping from pre-7.3, there will be no dependency
             * info so we have to fake it here.  We only need to worry about
             * typinput and typoutput since the other functions only exist
             * post-7.3.
             */
            if (fout->remoteVersion < 70300)
            {
                Oid         typinput;
                Oid         typoutput;
                FuncInfo   *funcInfo;

                typinput = atooid(PQgetvalue(res, i, i_typinput));
                typoutput = atooid(PQgetvalue(res, i, i_typoutput));

                funcInfo = findFuncByOid(typinput);
                if (funcInfo && funcInfo->dobj.dump)
                {
                    /* base type depends on function */
                    addObjectDependency(&tyinfo[i].dobj,
                                        funcInfo->dobj.dumpId);
                    /* function depends on shell type */
                    addObjectDependency(&funcInfo->dobj,
                                        stinfo->dobj.dumpId);
                    /* mark shell type as to be dumped */
                    stinfo->dobj.dump = true;
                }

                funcInfo = findFuncByOid(typoutput);
                if (funcInfo && funcInfo->dobj.dump)
                {
                    /* base type depends on function */
                    addObjectDependency(&tyinfo[i].dobj,
                                        funcInfo->dobj.dumpId);
                    /* function depends on shell type */
                    addObjectDependency(&funcInfo->dobj,
                                        stinfo->dobj.dumpId);
                    /* mark shell type as to be dumped */
                    stinfo->dobj.dump = true;
                }
            }
        }

        if (strlen(tyinfo[i].rolname) == 0 && tyinfo[i].isDefined)
            write_msg(NULL, "WARNING: owner of data type \"%s\" appears to be invalid\n",
                      tyinfo[i].dobj.name);
    }

    *numTypes = ntups;

    PQclear(res);

    destroyPQExpBuffer(query);

    return tyinfo;
}

/*
 * getOperators:
 *    read all operators in the system catalogs and return them in the
 * OprInfo* structure
 *
 *  numOprs is set to the number of operators read in
 */
OprInfo *
getOperators(Archive *fout, int *numOprs)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    OprInfo    *oprinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_oprname;
    int         i_oprnamespace;
    int         i_rolname;
    int         i_oprkind;
    int         i_oprcode;

    /*
     * find all operators, including builtin operators; we filter out
     * system-defined operators at dump-out time.
     */

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    if (fout->remoteVersion >= 70300)
    {
        appendPQExpBuffer(query, "SELECT tableoid, oid, oprname, "
                          "oprnamespace, "
                          "(%s oprowner) AS rolname, "
                          "oprkind, "
                          "oprcode::oid AS oprcode "
                          "FROM pg_operator",
                          username_subquery);
    }
    else if (fout->remoteVersion >= 70100)
    {
        appendPQExpBuffer(query, "SELECT tableoid, oid, oprname, "
                          "0::oid AS oprnamespace, "
                          "(%s oprowner) AS rolname, "
                          "oprkind, "
                          "oprcode::oid AS oprcode "
                          "FROM pg_operator",
                          username_subquery);
    }
    else
    {
        appendPQExpBuffer(query, "SELECT "
                          "(SELECT oid FROM pg_class WHERE relname = 'pg_operator') AS tableoid, "
                          "oid, oprname, "
                          "0::oid AS oprnamespace, "
                          "(%s oprowner) AS rolname, "
                          "oprkind, "
                          "oprcode::oid AS oprcode "
                          "FROM pg_operator",
                          username_subquery);
    }

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);
    *numOprs = ntups;

    oprinfo = (OprInfo *) pg_malloc(ntups * sizeof(OprInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_oprname = PQfnumber(res, "oprname");
    i_oprnamespace = PQfnumber(res, "oprnamespace");
    i_rolname = PQfnumber(res, "rolname");
    i_oprkind = PQfnumber(res, "oprkind");
    i_oprcode = PQfnumber(res, "oprcode");

    for (i = 0; i < ntups; i++)
    {
        oprinfo[i].dobj.objType = DO_OPERATOR;
        oprinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        oprinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&oprinfo[i].dobj);
        oprinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_oprname));
        oprinfo[i].dobj.namespace =
            findNamespace(fout,
                          atooid(PQgetvalue(res, i, i_oprnamespace)),
                          oprinfo[i].dobj.catId.oid);
        oprinfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
        oprinfo[i].oprkind = (PQgetvalue(res, i, i_oprkind))[0];
        oprinfo[i].oprcode = atooid(PQgetvalue(res, i, i_oprcode));

        /* Decide whether we want to dump it */
        selectDumpableObject(&(oprinfo[i].dobj));

        if (strlen(oprinfo[i].rolname) == 0)
            write_msg(NULL, "WARNING: owner of operator \"%s\" appears to be invalid\n",
                      oprinfo[i].dobj.name);
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return oprinfo;
}

/*
 * getCollations:
 *    read all collations in the system catalogs and return them in the
 * CollInfo* structure
 *
 *  numCollations is set to the number of collations read in
 */
CollInfo *
getCollations(Archive *fout, int *numCollations)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    CollInfo   *collinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_collname;
    int         i_collnamespace;
    int         i_rolname;

    /* Collations didn't exist pre-9.1 */
    if (fout->remoteVersion < 90100)
    {
        *numCollations = 0;
        return NULL;
    }

    query = createPQExpBuffer();

    /*
     * find all collations, including builtin collations; we filter out
     * system-defined collations at dump-out time.
     */

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    appendPQExpBuffer(query, "SELECT tableoid, oid, collname, "
                      "collnamespace, "
                      "(%s collowner) AS rolname "
                      "FROM pg_collation",
                      username_subquery);

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);
    *numCollations = ntups;

    collinfo = (CollInfo *) pg_malloc(ntups * sizeof(CollInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_collname = PQfnumber(res, "collname");
    i_collnamespace = PQfnumber(res, "collnamespace");
    i_rolname = PQfnumber(res, "rolname");

    for (i = 0; i < ntups; i++)
    {
        collinfo[i].dobj.objType = DO_COLLATION;
        collinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        collinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&collinfo[i].dobj);
        collinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_collname));
        collinfo[i].dobj.namespace =
            findNamespace(fout,
                          atooid(PQgetvalue(res, i, i_collnamespace)),
                          collinfo[i].dobj.catId.oid);
        collinfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));

        /* Decide whether we want to dump it */
        selectDumpableObject(&(collinfo[i].dobj));
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return collinfo;
}

/*
 * getConversions:
 *    read all conversions in the system catalogs and return them in the
 * ConvInfo* structure
 *
 *  numConversions is set to the number of conversions read in
 */
ConvInfo *
getConversions(Archive *fout, int *numConversions)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    ConvInfo   *convinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_conname;
    int         i_connamespace;
    int         i_rolname;

    /* Conversions didn't exist pre-7.3 */
    if (fout->remoteVersion < 70300)
    {
        *numConversions = 0;
        return NULL;
    }

    /*
     * find all conversions, including builtin conversions; we filter out
     * system-defined conversions at dump-out time.
     */

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    appendPQExpBuffer(query, "SELECT tableoid, oid, conname, "
                      "connamespace, "
                      "(%s conowner) AS rolname "
                      "FROM pg_conversion",
                      username_subquery);

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);
    *numConversions = ntups;

    convinfo = (ConvInfo *) pg_malloc(ntups * sizeof(ConvInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_conname = PQfnumber(res, "conname");
    i_connamespace = PQfnumber(res, "connamespace");
    i_rolname = PQfnumber(res, "rolname");

    for (i = 0; i < ntups; i++)
    {
        convinfo[i].dobj.objType = DO_CONVERSION;
        convinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        convinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&convinfo[i].dobj);
        convinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_conname));
        convinfo[i].dobj.namespace =
            findNamespace(fout,
                          atooid(PQgetvalue(res, i, i_connamespace)),
                          convinfo[i].dobj.catId.oid);
        convinfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));

        /* Decide whether we want to dump it */
        selectDumpableObject(&(convinfo[i].dobj));
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return convinfo;
}

/*
 * getOpclasses:
 *    read all opclasses in the system catalogs and return them in the
 * OpclassInfo* structure
 *
 *  numOpclasses is set to the number of opclasses read in
 */
OpclassInfo *
getOpclasses(Archive *fout, int *numOpclasses)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    OpclassInfo *opcinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_opcname;
    int         i_opcnamespace;
    int         i_rolname;

    /*
     * find all opclasses, including builtin opclasses; we filter out
     * system-defined opclasses at dump-out time.
     */

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    if (fout->remoteVersion >= 70300)
    {
        appendPQExpBuffer(query, "SELECT tableoid, oid, opcname, "
                          "opcnamespace, "
                          "(%s opcowner) AS rolname "
                          "FROM pg_opclass",
                          username_subquery);
    }
    else if (fout->remoteVersion >= 70100)
    {
        appendPQExpBuffer(query, "SELECT tableoid, oid, opcname, "
                          "0::oid AS opcnamespace, "
                          "''::name AS rolname "
                          "FROM pg_opclass");
    }
    else
    {
        appendPQExpBuffer(query, "SELECT "
                          "(SELECT oid FROM pg_class WHERE relname = 'pg_opclass') AS tableoid, "
                          "oid, opcname, "
                          "0::oid AS opcnamespace, "
                          "''::name AS rolname "
                          "FROM pg_opclass");
    }

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);
    *numOpclasses = ntups;

    opcinfo = (OpclassInfo *) pg_malloc(ntups * sizeof(OpclassInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_opcname = PQfnumber(res, "opcname");
    i_opcnamespace = PQfnumber(res, "opcnamespace");
    i_rolname = PQfnumber(res, "rolname");

    for (i = 0; i < ntups; i++)
    {
        opcinfo[i].dobj.objType = DO_OPCLASS;
        opcinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        opcinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&opcinfo[i].dobj);
        opcinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_opcname));
        opcinfo[i].dobj.namespace =
            findNamespace(fout,
                          atooid(PQgetvalue(res, i, i_opcnamespace)),
                          opcinfo[i].dobj.catId.oid);
        opcinfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));

        /* Decide whether we want to dump it */
        selectDumpableObject(&(opcinfo[i].dobj));

        if (fout->remoteVersion >= 70300)
        {
            if (strlen(opcinfo[i].rolname) == 0)
                write_msg(NULL, "WARNING: owner of operator class \"%s\" appears to be invalid\n",
                          opcinfo[i].dobj.name);
        }
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return opcinfo;
}

/*
 * getOpfamilies:
 *    read all opfamilies in the system catalogs and return them in the
 * OpfamilyInfo* structure
 *
 *  numOpfamilies is set to the number of opfamilies read in
 */
OpfamilyInfo *
getOpfamilies(Archive *fout, int *numOpfamilies)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    OpfamilyInfo *opfinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_opfname;
    int         i_opfnamespace;
    int         i_rolname;

    /* Before 8.3, there is no separate concept of opfamilies */
    if (fout->remoteVersion < 80300)
    {
        *numOpfamilies = 0;
        return NULL;
    }

    query = createPQExpBuffer();

    /*
     * find all opfamilies, including builtin opfamilies; we filter out
     * system-defined opfamilies at dump-out time.
     */

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    appendPQExpBuffer(query, "SELECT tableoid, oid, opfname, "
                      "opfnamespace, "
                      "(%s opfowner) AS rolname "
                      "FROM pg_opfamily",
                      username_subquery);

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);
    *numOpfamilies = ntups;

    opfinfo = (OpfamilyInfo *) pg_malloc(ntups * sizeof(OpfamilyInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_opfname = PQfnumber(res, "opfname");
    i_opfnamespace = PQfnumber(res, "opfnamespace");
    i_rolname = PQfnumber(res, "rolname");

    for (i = 0; i < ntups; i++)
    {
        opfinfo[i].dobj.objType = DO_OPFAMILY;
        opfinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        opfinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&opfinfo[i].dobj);
        opfinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_opfname));
        opfinfo[i].dobj.namespace =
            findNamespace(fout,
                          atooid(PQgetvalue(res, i, i_opfnamespace)),
                          opfinfo[i].dobj.catId.oid);
        opfinfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));

        /* Decide whether we want to dump it */
        selectDumpableObject(&(opfinfo[i].dobj));

        if (fout->remoteVersion >= 70300)
        {
            if (strlen(opfinfo[i].rolname) == 0)
                write_msg(NULL, "WARNING: owner of operator family \"%s\" appears to be invalid\n",
                          opfinfo[i].dobj.name);
        }
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return opfinfo;
}

/*
 * getAggregates:
 *    read all the user-defined aggregates in the system catalogs and
 * return them in the AggInfo* structure
 *
 * numAggs is set to the number of aggregates read in
 */
AggInfo *
getAggregates(Archive *fout, int *numAggs)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    AggInfo    *agginfo;
    int         i_tableoid;
    int         i_oid;
    int         i_aggname;
    int         i_aggnamespace;
    int         i_pronargs;
    int         i_proargtypes;
    int         i_rolname;
    int         i_aggacl;
    int         i_proiargs;

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    /*
     * Find all user-defined aggregates.  See comment in getFuncs() for the
     * rationale behind the filtering logic.
     */

    if (fout->remoteVersion >= 80400)
    {
        appendPQExpBuffer(query, "SELECT tableoid, oid, proname AS aggname, "
                          "pronamespace AS aggnamespace, "
                          "pronargs, proargtypes, "
            "pg_catalog.pg_get_function_identity_arguments(oid) AS proiargs,"
                          "(%s proowner) AS rolname, "
                          "proacl AS aggacl "
                          "FROM pg_proc p "
                          "WHERE proisagg AND ("
                          "pronamespace != "
                          "(SELECT oid FROM pg_namespace "
                          "WHERE nspname = 'pg_catalog')",
                          username_subquery);
        if (binary_upgrade && fout->remoteVersion >= 90100)
            appendPQExpBuffer(query,
                              " OR EXISTS(SELECT 1 FROM pg_depend WHERE "
                              "classid = 'pg_proc'::regclass AND "
                              "objid = p.oid AND "
                              "refclassid = 'pg_extension'::regclass AND "
                              "deptype = 'e')");
        appendPQExpBuffer(query, ")");
    }
    else if (fout->remoteVersion >= 80200)
    {
        appendPQExpBuffer(query, "SELECT tableoid, oid, proname AS aggname, "
                          "pronamespace AS aggnamespace, "
                          "pronargs, proargtypes, "
                          "NULL::text AS proiargs,"
                          "(%s proowner) AS rolname, "
                          "proacl AS aggacl "
                          "FROM pg_proc p "
                          "WHERE proisagg AND ("
                          "pronamespace != "
                          "(SELECT oid FROM pg_namespace "
                          "WHERE nspname = 'pg_catalog'))",
                          username_subquery);
    }
    else if (fout->remoteVersion >= 70300)
    {
        appendPQExpBuffer(query, "SELECT tableoid, oid, proname AS aggname, "
                          "pronamespace AS aggnamespace, "
                          "CASE WHEN proargtypes[0] = 'pg_catalog.\"any\"'::pg_catalog.regtype THEN 0 ELSE 1 END AS pronargs, "
                          "proargtypes, "
                          "NULL::text AS proiargs, "
                          "(%s proowner) AS rolname, "
                          "proacl AS aggacl "
                          "FROM pg_proc "
                          "WHERE proisagg "
                          "AND pronamespace != "
               "(SELECT oid FROM pg_namespace WHERE nspname = 'pg_catalog')",
                          username_subquery);
    }
    else if (fout->remoteVersion >= 70100)
    {
        appendPQExpBuffer(query, "SELECT tableoid, oid, aggname, "
                          "0::oid AS aggnamespace, "
                  "CASE WHEN aggbasetype = 0 THEN 0 ELSE 1 END AS pronargs, "
                          "aggbasetype AS proargtypes, "
                          "NULL::text AS proiargs, "
                          "(%s aggowner) AS rolname, "
                          "'{=X}' AS aggacl "
                          "FROM pg_aggregate "
                          "where oid > '%u'::oid",
                          username_subquery,
                          g_last_builtin_oid);
    }
    else
    {
        appendPQExpBuffer(query, "SELECT "
                          "(SELECT oid FROM pg_class WHERE relname = 'pg_aggregate') AS tableoid, "
                          "oid, aggname, "
                          "0::oid AS aggnamespace, "
                  "CASE WHEN aggbasetype = 0 THEN 0 ELSE 1 END AS pronargs, "
                          "aggbasetype AS proargtypes, "
                          "NULL::text AS proiargs, "
                          "(%s aggowner) AS rolname, "
                          "'{=X}' AS aggacl "
                          "FROM pg_aggregate "
                          "where oid > '%u'::oid",
                          username_subquery,
                          g_last_builtin_oid);
    }

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);
    *numAggs = ntups;

    agginfo = (AggInfo *) pg_malloc(ntups * sizeof(AggInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_aggname = PQfnumber(res, "aggname");
    i_aggnamespace = PQfnumber(res, "aggnamespace");
    i_pronargs = PQfnumber(res, "pronargs");
    i_proargtypes = PQfnumber(res, "proargtypes");
    i_rolname = PQfnumber(res, "rolname");
    i_aggacl = PQfnumber(res, "aggacl");
    i_proiargs = PQfnumber(res, "proiargs");

    for (i = 0; i < ntups; i++)
    {
        agginfo[i].aggfn.dobj.objType = DO_AGG;
        agginfo[i].aggfn.dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        agginfo[i].aggfn.dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&agginfo[i].aggfn.dobj);
        agginfo[i].aggfn.dobj.name = pg_strdup(PQgetvalue(res, i, i_aggname));
        agginfo[i].aggfn.dobj.namespace =
            findNamespace(fout,
                          atooid(PQgetvalue(res, i, i_aggnamespace)),
                          agginfo[i].aggfn.dobj.catId.oid);
        agginfo[i].aggfn.rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
        if (strlen(agginfo[i].aggfn.rolname) == 0)
            write_msg(NULL, "WARNING: owner of aggregate function \"%s\" appears to be invalid\n",
                      agginfo[i].aggfn.dobj.name);
        agginfo[i].aggfn.lang = InvalidOid;     /* not currently interesting */
        agginfo[i].aggfn.prorettype = InvalidOid;       /* not saved */
        agginfo[i].aggfn.proacl = pg_strdup(PQgetvalue(res, i, i_aggacl));
        agginfo[i].aggfn.proiargs = pg_strdup(PQgetvalue(res, i, i_proiargs));
        agginfo[i].aggfn.nargs = atoi(PQgetvalue(res, i, i_pronargs));
        if (agginfo[i].aggfn.nargs == 0)
            agginfo[i].aggfn.argtypes = NULL;
        else
        {
            agginfo[i].aggfn.argtypes = (Oid *) pg_malloc(agginfo[i].aggfn.nargs * sizeof(Oid));
            if (fout->remoteVersion >= 70300)
                parseOidArray(PQgetvalue(res, i, i_proargtypes),
                              agginfo[i].aggfn.argtypes,
                              agginfo[i].aggfn.nargs);
            else
                /* it's just aggbasetype */
                agginfo[i].aggfn.argtypes[0] = atooid(PQgetvalue(res, i, i_proargtypes));
        }

        /* Decide whether we want to dump it */
        selectDumpableObject(&(agginfo[i].aggfn.dobj));
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return agginfo;
}

/*
 * getFuncs:
 *    read all the user-defined functions in the system catalogs and
 * return them in the FuncInfo* structure
 *
 * numFuncs is set to the number of functions read in
 */
FuncInfo *
getFuncs(Archive *fout, int *numFuncs)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    FuncInfo   *finfo;
    int         i_tableoid;
    int         i_oid;
    int         i_proname;
    int         i_pronamespace;
    int         i_rolname;
    int         i_prolang;
    int         i_pronargs;
    int         i_proargtypes;
    int         i_prorettype;
    int         i_proacl;
    int         i_proiargs;

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    /*
     * Find all user-defined functions.  Normally we can exclude functions in
     * pg_catalog, which is worth doing since there are several thousand of
     * 'em.  However, there are some extensions that create functions in
     * pg_catalog.  In normal dumps we can still ignore those --- but in
     * binary-upgrade mode, we must dump the member objects of the extension,
     * so be sure to fetch any such functions.
     *
     * Also, in 9.2 and up, exclude functions that are internally dependent on
     * something else, since presumably those will be created as a result of
     * creating the something else.  This currently only acts to suppress
     * constructor functions for range types.  Note that this is OK only
     * because the constructors don't have any dependencies the range type
     * doesn't have; otherwise we might not get creation ordering correct.
     */

    if (fout->remoteVersion >= 80400)
    {
        appendPQExpBuffer(query,
                          "SELECT tableoid, oid, proname, prolang, "
                          "pronargs, proargtypes, prorettype, proacl, "
                          "pronamespace, "
            "pg_catalog.pg_get_function_identity_arguments(oid) AS proiargs,"
                          "(%s proowner) AS rolname "
                          "FROM pg_proc p "
                          "WHERE NOT proisagg AND ("
                          "pronamespace != "
                          "(SELECT oid FROM pg_namespace "
                          "WHERE nspname = 'pg_catalog')",
                          username_subquery);
        if (fout->remoteVersion >= 90200)
            appendPQExpBuffer(query,
                              "\n  AND NOT EXISTS (SELECT 1 FROM pg_depend "
                              "WHERE classid = 'pg_proc'::regclass AND "
                              "objid = p.oid AND deptype = 'i')");
        if (binary_upgrade && fout->remoteVersion >= 90100)
            appendPQExpBuffer(query,
                              "\n  OR EXISTS(SELECT 1 FROM pg_depend WHERE "
                              "classid = 'pg_proc'::regclass AND "
                              "objid = p.oid AND "
                              "refclassid = 'pg_extension'::regclass AND "
                              "deptype = 'e')");
        appendPQExpBuffer(query, ")");
    }
    else if (fout->remoteVersion >= 70300)
    {
        appendPQExpBuffer(query,
                          "SELECT tableoid, oid, proname, prolang, "
                          "pronargs, proargtypes, prorettype, proacl, "
                          "pronamespace, "
                          "NULL::text AS proiargs,"
                          "(%s proowner) AS rolname "
                          "FROM pg_proc p "
                          "WHERE NOT proisagg AND ("
                          "pronamespace != "
                          "(SELECT oid FROM pg_namespace "
                          "WHERE nspname = 'pg_catalog'))",
                          username_subquery);
    }
    else if (fout->remoteVersion >= 70100)
    {
        appendPQExpBuffer(query,
                          "SELECT tableoid, oid, proname, prolang, "
                          "pronargs, proargtypes, prorettype, "
                          "'{=X}' AS proacl, "
                          "0::oid AS pronamespace, "
                          "NULL::text AS proiargs,"
                          "(%s proowner) AS rolname "
                          "FROM pg_proc "
                          "WHERE pg_proc.oid > '%u'::oid",
                          username_subquery,
                          g_last_builtin_oid);
    }
    else
    {
        appendPQExpBuffer(query,
                          "SELECT "
                          "(SELECT oid FROM pg_class "
                          " WHERE relname = 'pg_proc') AS tableoid, "
                          "oid, proname, prolang, "
                          "pronargs, proargtypes, prorettype, "
                          "'{=X}' AS proacl, "
                          "0::oid AS pronamespace, "
                          "NULL::text AS proiargs,"
                          "(%s proowner) AS rolname "
                          "FROM pg_proc "
                          "where pg_proc.oid > '%u'::oid",
                          username_subquery,
                          g_last_builtin_oid);
    }

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);

    *numFuncs = ntups;

    finfo = (FuncInfo *) pg_malloc0(ntups * sizeof(FuncInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_proname = PQfnumber(res, "proname");
    i_pronamespace = PQfnumber(res, "pronamespace");
    i_rolname = PQfnumber(res, "rolname");
    i_prolang = PQfnumber(res, "prolang");
    i_pronargs = PQfnumber(res, "pronargs");
    i_proargtypes = PQfnumber(res, "proargtypes");
    i_prorettype = PQfnumber(res, "prorettype");
    i_proacl = PQfnumber(res, "proacl");
    i_proiargs = PQfnumber(res, "proiargs");

    for (i = 0; i < ntups; i++)
    {
        finfo[i].dobj.objType = DO_FUNC;
        finfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        finfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&finfo[i].dobj);
        finfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_proname));
        finfo[i].dobj.namespace =
            findNamespace(fout,
                          atooid(PQgetvalue(res, i, i_pronamespace)),
                          finfo[i].dobj.catId.oid);
        finfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
        finfo[i].lang = atooid(PQgetvalue(res, i, i_prolang));
        finfo[i].prorettype = atooid(PQgetvalue(res, i, i_prorettype));
        finfo[i].proiargs = pg_strdup(PQgetvalue(res, i, i_proiargs));
        finfo[i].proacl = pg_strdup(PQgetvalue(res, i, i_proacl));
        finfo[i].nargs = atoi(PQgetvalue(res, i, i_pronargs));
        if (finfo[i].nargs == 0)
            finfo[i].argtypes = NULL;
        else
        {
            finfo[i].argtypes = (Oid *) pg_malloc(finfo[i].nargs * sizeof(Oid));
            parseOidArray(PQgetvalue(res, i, i_proargtypes),
                          finfo[i].argtypes, finfo[i].nargs);
        }

        /* Decide whether we want to dump it */
        selectDumpableObject(&(finfo[i].dobj));

        if (strlen(finfo[i].rolname) == 0)
            write_msg(NULL,
                 "WARNING: owner of function \"%s\" appears to be invalid\n",
                      finfo[i].dobj.name);
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return finfo;
}

/*
 * getTables
 *    read all the user-defined tables (no indexes, no catalogs)
 * in the system catalogs return them in the TableInfo* structure
 *
 * numTables is set to the number of tables read in
 */
TableInfo *
getTables(Archive *fout, int *numTables)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    TableInfo  *tblinfo;
    int         i_reltableoid;
    int         i_reloid;
    int         i_relname;
    int         i_relnamespace;
    int         i_relkind;
    int         i_relacl;
    int         i_rolname;
    int         i_relchecks;
    int         i_relhastriggers;
    int         i_relhasindex;
    int         i_relhasrules;
    int         i_relhasoids;
    int         i_relfrozenxid;
    int         i_toastoid;
    int         i_toastfrozenxid;
    int         i_relpersistence;
    int         i_isscannable;
    int         i_owning_tab;
    int         i_owning_col;
    int         i_reltablespace;
    int         i_reloptions;
    int         i_toastreloptions;
    int         i_reloftype;
    int         i_relpages;

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    /*
     * Find all the tables and table-like objects.
     *
     * We include system catalogs, so that we can work if a user table is
     * defined to inherit from a system catalog (pretty weird, but...)
     *
     * We ignore relations that are not ordinary tables, sequences, views,
     * materialized views, composite types, or foreign tables.
     *
     * Composite-type table entries won't be dumped as such, but we have to
     * make a DumpableObject for them so that we can track dependencies of the
     * composite type (pg_depend entries for columns of the composite type
     * link to the pg_class entry not the pg_type entry).
     *
     * Note: in this phase we should collect only a minimal amount of
     * information about each table, basically just enough to decide if it is
     * interesting. We must fetch all tables in this phase because otherwise
     * we cannot correctly identify inherited columns, owned sequences, etc.
     */

    if (fout->remoteVersion >= 90300)
    {
        /*
         * Left join to pick up dependency info linking sequences to their
         * owning column, if any (note this dependency is AUTO as of 8.2)
         */
        appendPQExpBuffer(query,
                          "SELECT c.tableoid, c.oid, c.relname, "
                          "c.relacl, c.relkind, c.relnamespace, "
                          "(%s c.relowner) AS rolname, "
                          "c.relchecks, c.relhastriggers, "
                          "c.relhasindex, c.relhasrules, c.relhasoids, "
                          "c.relfrozenxid, tc.oid AS toid, "
                          "tc.relfrozenxid AS tfrozenxid, "
                          "c.relpersistence, "
                          "CASE WHEN c.relkind = '%c' THEN pg_relation_is_scannable(c.oid) ELSE 't'::bool END as isscannable, "
                          "c.relpages, "
                          "CASE WHEN c.reloftype <> 0 THEN c.reloftype::pg_catalog.regtype ELSE NULL END AS reloftype, "
                          "d.refobjid AS owning_tab, "
                          "d.refobjsubid AS owning_col, "
                          "(SELECT spcname FROM pg_tablespace t WHERE t.oid = c.reltablespace) AS reltablespace, "
                        "array_to_string(c.reloptions, ', ') AS reloptions, "
                          "array_to_string(array(SELECT 'toast.' || x FROM unnest(tc.reloptions) x), ', ') AS toast_reloptions "
                          "FROM pg_class c "
                          "LEFT JOIN pg_depend d ON "
                          "(c.relkind = '%c' AND "
                          "d.classid = c.tableoid AND d.objid = c.oid AND "
                          "d.objsubid = 0 AND "
                          "d.refclassid = c.tableoid AND d.deptype = 'a') "
                       "LEFT JOIN pg_class tc ON (c.reltoastrelid = tc.oid) "
                   "WHERE c.relkind in ('%c', '%c', '%c', '%c', '%c', '%c') "
                          "ORDER BY c.oid",
                          username_subquery,
                          RELKIND_MATVIEW,
                          RELKIND_SEQUENCE,
                          RELKIND_RELATION, RELKIND_SEQUENCE,
                          RELKIND_VIEW, RELKIND_COMPOSITE_TYPE,
                          RELKIND_MATVIEW, RELKIND_FOREIGN_TABLE);
    }
    else if (fout->remoteVersion >= 90100)
    {
        /*
         * Left join to pick up dependency info linking sequences to their
         * owning column, if any (note this dependency is AUTO as of 8.2)
         */
        appendPQExpBuffer(query,
                          "SELECT c.tableoid, c.oid, c.relname, "
                          "c.relacl, c.relkind, c.relnamespace, "
                          "(%s c.relowner) AS rolname, "
                          "c.relchecks, c.relhastriggers, "
                          "c.relhasindex, c.relhasrules, c.relhasoids, "
                          "c.relfrozenxid, tc.oid AS toid, "
                          "tc.relfrozenxid AS tfrozenxid, "
                          "c.relpersistence, 't'::bool as isscannable, "
                          "c.relpages, "
                          "CASE WHEN c.reloftype <> 0 THEN c.reloftype::pg_catalog.regtype ELSE NULL END AS reloftype, "
                          "d.refobjid AS owning_tab, "
                          "d.refobjsubid AS owning_col, "
                          "(SELECT spcname FROM pg_tablespace t WHERE t.oid = c.reltablespace) AS reltablespace, "
                        "array_to_string(c.reloptions, ', ') AS reloptions, "
                          "array_to_string(array(SELECT 'toast.' || x FROM unnest(tc.reloptions) x), ', ') AS toast_reloptions "
                          "FROM pg_class c "
                          "LEFT JOIN pg_depend d ON "
                          "(c.relkind = '%c' AND "
                          "d.classid = c.tableoid AND d.objid = c.oid AND "
                          "d.objsubid = 0 AND "
                          "d.refclassid = c.tableoid AND d.deptype = 'a') "
                       "LEFT JOIN pg_class tc ON (c.reltoastrelid = tc.oid) "
                   "WHERE c.relkind in ('%c', '%c', '%c', '%c', '%c', '%c') "
                          "ORDER BY c.oid",
                          username_subquery,
                          RELKIND_SEQUENCE,
                          RELKIND_RELATION, RELKIND_SEQUENCE,
                          RELKIND_VIEW, RELKIND_COMPOSITE_TYPE,
                          RELKIND_MATVIEW, RELKIND_FOREIGN_TABLE);
    }
    else if (fout->remoteVersion >= 90000)
    {
        /*
         * Left join to pick up dependency info linking sequences to their
         * owning column, if any (note this dependency is AUTO as of 8.2)
         */
        appendPQExpBuffer(query,
                          "SELECT c.tableoid, c.oid, c.relname, "
                          "c.relacl, c.relkind, c.relnamespace, "
                          "(%s c.relowner) AS rolname, "
                          "c.relchecks, c.relhastriggers, "
                          "c.relhasindex, c.relhasrules, c.relhasoids, "
                          "c.relfrozenxid, tc.oid AS toid, "
                          "tc.relfrozenxid AS tfrozenxid, "
                          "'p' AS relpersistence, 't'::bool as isscannable, "
                          "c.relpages, "
                          "CASE WHEN c.reloftype <> 0 THEN c.reloftype::pg_catalog.regtype ELSE NULL END AS reloftype, "
                          "d.refobjid AS owning_tab, "
                          "d.refobjsubid AS owning_col, "
                          "(SELECT spcname FROM pg_tablespace t WHERE t.oid = c.reltablespace) AS reltablespace, "
                        "array_to_string(c.reloptions, ', ') AS reloptions, "
                          "array_to_string(array(SELECT 'toast.' || x FROM unnest(tc.reloptions) x), ', ') AS toast_reloptions "
                          "FROM pg_class c "
                          "LEFT JOIN pg_depend d ON "
                          "(c.relkind = '%c' AND "
                          "d.classid = c.tableoid AND d.objid = c.oid AND "
                          "d.objsubid = 0 AND "
                          "d.refclassid = c.tableoid AND d.deptype = 'a') "
                       "LEFT JOIN pg_class tc ON (c.reltoastrelid = tc.oid) "
                          "WHERE c.relkind in ('%c', '%c', '%c', '%c') "
                          "ORDER BY c.oid",
                          username_subquery,
                          RELKIND_SEQUENCE,
                          RELKIND_RELATION, RELKIND_SEQUENCE,
                          RELKIND_VIEW, RELKIND_COMPOSITE_TYPE);
    }
    else if (fout->remoteVersion >= 80400)
    {
        /*
         * Left join to pick up dependency info linking sequences to their
         * owning column, if any (note this dependency is AUTO as of 8.2)
         */
        appendPQExpBuffer(query,
                          "SELECT c.tableoid, c.oid, c.relname, "
                          "c.relacl, c.relkind, c.relnamespace, "
                          "(%s c.relowner) AS rolname, "
                          "c.relchecks, c.relhastriggers, "
                          "c.relhasindex, c.relhasrules, c.relhasoids, "
                          "c.relfrozenxid, tc.oid AS toid, "
                          "tc.relfrozenxid AS tfrozenxid, "
                          "'p' AS relpersistence, 't'::bool as isscannable, "
                          "c.relpages, "
                          "NULL AS reloftype, "
                          "d.refobjid AS owning_tab, "
                          "d.refobjsubid AS owning_col, "
                          "(SELECT spcname FROM pg_tablespace t WHERE t.oid = c.reltablespace) AS reltablespace, "
                        "array_to_string(c.reloptions, ', ') AS reloptions, "
                          "array_to_string(array(SELECT 'toast.' || x FROM unnest(tc.reloptions) x), ', ') AS toast_reloptions "
                          "FROM pg_class c "
                          "LEFT JOIN pg_depend d ON "
                          "(c.relkind = '%c' AND "
                          "d.classid = c.tableoid AND d.objid = c.oid AND "
                          "d.objsubid = 0 AND "
                          "d.refclassid = c.tableoid AND d.deptype = 'a') "
                       "LEFT JOIN pg_class tc ON (c.reltoastrelid = tc.oid) "
                          "WHERE c.relkind in ('%c', '%c', '%c', '%c') "
                          "ORDER BY c.oid",
                          username_subquery,
                          RELKIND_SEQUENCE,
                          RELKIND_RELATION, RELKIND_SEQUENCE,
                          RELKIND_VIEW, RELKIND_COMPOSITE_TYPE);
    }
    else if (fout->remoteVersion >= 80200)
    {
        /*
         * Left join to pick up dependency info linking sequences to their
         * owning column, if any (note this dependency is AUTO as of 8.2)
         */
        appendPQExpBuffer(query,
                          "SELECT c.tableoid, c.oid, c.relname, "
                          "c.relacl, c.relkind, c.relnamespace, "
                          "(%s c.relowner) AS rolname, "
                      "c.relchecks, (c.reltriggers <> 0) AS relhastriggers, "
                          "c.relhasindex, c.relhasrules, c.relhasoids, "
                          "c.relfrozenxid, tc.oid AS toid, "
                          "tc.relfrozenxid AS tfrozenxid, "
                          "'p' AS relpersistence, 't'::bool as isscannable, "
                          "c.relpages, "
                          "NULL AS reloftype, "
                          "d.refobjid AS owning_tab, "
                          "d.refobjsubid AS owning_col, "
                          "(SELECT spcname FROM pg_tablespace t WHERE t.oid = c.reltablespace) AS reltablespace, "
                        "array_to_string(c.reloptions, ', ') AS reloptions, "
                          "NULL AS toast_reloptions "
                          "FROM pg_class c "
                          "LEFT JOIN pg_depend d ON "
                          "(c.relkind = '%c' AND "
                          "d.classid = c.tableoid AND d.objid = c.oid AND "
                          "d.objsubid = 0 AND "
                          "d.refclassid = c.tableoid AND d.deptype = 'a') "
                       "LEFT JOIN pg_class tc ON (c.reltoastrelid = tc.oid) "
                          "WHERE c.relkind in ('%c', '%c', '%c', '%c') "
                          "ORDER BY c.oid",
                          username_subquery,
                          RELKIND_SEQUENCE,
                          RELKIND_RELATION, RELKIND_SEQUENCE,
                          RELKIND_VIEW, RELKIND_COMPOSITE_TYPE);
    }
    else if (fout->remoteVersion >= 80000)
    {
        /*
         * Left join to pick up dependency info linking sequences to their
         * owning column, if any
         */
        appendPQExpBuffer(query,
                          "SELECT c.tableoid, c.oid, relname, "
                          "relacl, relkind, relnamespace, "
                          "(%s relowner) AS rolname, "
                          "relchecks, (reltriggers <> 0) AS relhastriggers, "
                          "relhasindex, relhasrules, relhasoids, "
                          "0 AS relfrozenxid, "
                          "0 AS toid, "
                          "0 AS tfrozenxid, "
                          "'p' AS relpersistence, 't'::bool as isscannable, "
                          "relpages, "
                          "NULL AS reloftype, "
                          "d.refobjid AS owning_tab, "
                          "d.refobjsubid AS owning_col, "
                          "(SELECT spcname FROM pg_tablespace t WHERE t.oid = c.reltablespace) AS reltablespace, "
                          "NULL AS reloptions, "
                          "NULL AS toast_reloptions "
                          "FROM pg_class c "
                          "LEFT JOIN pg_depend d ON "
                          "(c.relkind = '%c' AND "
                          "d.classid = c.tableoid AND d.objid = c.oid AND "
                          "d.objsubid = 0 AND "
                          "d.refclassid = c.tableoid AND d.deptype = 'i') "
                          "WHERE relkind in ('%c', '%c', '%c', '%c') "
                          "ORDER BY c.oid",
                          username_subquery,
                          RELKIND_SEQUENCE,
                          RELKIND_RELATION, RELKIND_SEQUENCE,
                          RELKIND_VIEW, RELKIND_COMPOSITE_TYPE);
    }
    else if (fout->remoteVersion >= 70300)
    {
        /*
         * Left join to pick up dependency info linking sequences to their
         * owning column, if any
         */
        appendPQExpBuffer(query,
                          "SELECT c.tableoid, c.oid, relname, "
                          "relacl, relkind, relnamespace, "
                          "(%s relowner) AS rolname, "
                          "relchecks, (reltriggers <> 0) AS relhastriggers, "
                          "relhasindex, relhasrules, relhasoids, "
                          "0 AS relfrozenxid, "
                          "0 AS toid, "
                          "0 AS tfrozenxid, "
                          "'p' AS relpersistence, 't'::bool as isscannable, "
                          "relpages, "
                          "NULL AS reloftype, "
                          "d.refobjid AS owning_tab, "
                          "d.refobjsubid AS owning_col, "
                          "NULL AS reltablespace, "
                          "NULL AS reloptions, "
                          "NULL AS toast_reloptions "
                          "FROM pg_class c "
                          "LEFT JOIN pg_depend d ON "
                          "(c.relkind = '%c' AND "
                          "d.classid = c.tableoid AND d.objid = c.oid AND "
                          "d.objsubid = 0 AND "
                          "d.refclassid = c.tableoid AND d.deptype = 'i') "
                          "WHERE relkind IN ('%c', '%c', '%c', '%c') "
                          "ORDER BY c.oid",
                          username_subquery,
                          RELKIND_SEQUENCE,
                          RELKIND_RELATION, RELKIND_SEQUENCE,
                          RELKIND_VIEW, RELKIND_COMPOSITE_TYPE);
    }
    else if (fout->remoteVersion >= 70200)
    {
        appendPQExpBuffer(query,
                          "SELECT tableoid, oid, relname, relacl, relkind, "
                          "0::oid AS relnamespace, "
                          "(%s relowner) AS rolname, "
                          "relchecks, (reltriggers <> 0) AS relhastriggers, "
                          "relhasindex, relhasrules, relhasoids, "
                          "0 AS relfrozenxid, "
                          "0 AS toid, "
                          "0 AS tfrozenxid, "
                          "'p' AS relpersistence, 't'::bool as isscannable, "
                          "relpages, "
                          "NULL AS reloftype, "
                          "NULL::oid AS owning_tab, "
                          "NULL::int4 AS owning_col, "
                          "NULL AS reltablespace, "
                          "NULL AS reloptions, "
                          "NULL AS toast_reloptions "
                          "FROM pg_class "
                          "WHERE relkind IN ('%c', '%c', '%c') "
                          "ORDER BY oid",
                          username_subquery,
                          RELKIND_RELATION, RELKIND_SEQUENCE, RELKIND_VIEW);
    }
    else if (fout->remoteVersion >= 70100)
    {
        /* all tables have oids in 7.1 */
        appendPQExpBuffer(query,
                          "SELECT tableoid, oid, relname, relacl, relkind, "
                          "0::oid AS relnamespace, "
                          "(%s relowner) AS rolname, "
                          "relchecks, (reltriggers <> 0) AS relhastriggers, "
                          "relhasindex, relhasrules, "
                          "'t'::bool AS relhasoids, "
                          "0 AS relfrozenxid, "
                          "0 AS toid, "
                          "0 AS tfrozenxid, "
                          "'p' AS relpersistence, 't'::bool as isscannable, "
                          "relpages, "
                          "NULL AS reloftype, "
                          "NULL::oid AS owning_tab, "
                          "NULL::int4 AS owning_col, "
                          "NULL AS reltablespace, "
                          "NULL AS reloptions, "
                          "NULL AS toast_reloptions "
                          "FROM pg_class "
                          "WHERE relkind IN ('%c', '%c', '%c') "
                          "ORDER BY oid",
                          username_subquery,
                          RELKIND_RELATION, RELKIND_SEQUENCE, RELKIND_VIEW);
    }
    else
    {
        /*
         * Before 7.1, view relkind was not set to 'v', so we must check if we
         * have a view by looking for a rule in pg_rewrite.
         */
        appendPQExpBuffer(query,
                          "SELECT "
        "(SELECT oid FROM pg_class WHERE relname = 'pg_class') AS tableoid, "
                          "oid, relname, relacl, "
                          "CASE WHEN relhasrules and relkind = 'r' "
                      "  and EXISTS(SELECT rulename FROM pg_rewrite r WHERE "
                      "             r.ev_class = c.oid AND r.ev_type = '1') "
                          "THEN '%c'::\"char\" "
                          "ELSE relkind END AS relkind,"
                          "0::oid AS relnamespace, "
                          "(%s relowner) AS rolname, "
                          "relchecks, (reltriggers <> 0) AS relhastriggers, "
                          "relhasindex, relhasrules, "
                          "'t'::bool AS relhasoids, "
                          "0 as relfrozenxid, "
                          "0 AS toid, "
                          "0 AS tfrozenxid, "
                          "'p' AS relpersistence, 't'::bool as isscannable, "
                          "0 AS relpages, "
                          "NULL AS reloftype, "
                          "NULL::oid AS owning_tab, "
                          "NULL::int4 AS owning_col, "
                          "NULL AS reltablespace, "
                          "NULL AS reloptions, "
                          "NULL AS toast_reloptions "
                          "FROM pg_class c "
                          "WHERE relkind IN ('%c', '%c') "
                          "ORDER BY oid",
                          RELKIND_VIEW,
                          username_subquery,
                          RELKIND_RELATION, RELKIND_SEQUENCE);
    }

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);

    *numTables = ntups;

    /*
     * Extract data from result and lock dumpable tables.  We do the locking
     * before anything else, to minimize the window wherein a table could
     * disappear under us.
     *
     * Note that we have to save info about all tables here, even when dumping
     * only one, because we don't yet know which tables might be inheritance
     * ancestors of the target table.
     */
    tblinfo = (TableInfo *) pg_malloc0(ntups * sizeof(TableInfo));

    i_reltableoid = PQfnumber(res, "tableoid");
    i_reloid = PQfnumber(res, "oid");
    i_relname = PQfnumber(res, "relname");
    i_relnamespace = PQfnumber(res, "relnamespace");
    i_relacl = PQfnumber(res, "relacl");
    i_relkind = PQfnumber(res, "relkind");
    i_rolname = PQfnumber(res, "rolname");
    i_relchecks = PQfnumber(res, "relchecks");
    i_relhastriggers = PQfnumber(res, "relhastriggers");
    i_relhasindex = PQfnumber(res, "relhasindex");
    i_relhasrules = PQfnumber(res, "relhasrules");
    i_relhasoids = PQfnumber(res, "relhasoids");
    i_relfrozenxid = PQfnumber(res, "relfrozenxid");
    i_toastoid = PQfnumber(res, "toid");
    i_toastfrozenxid = PQfnumber(res, "tfrozenxid");
    i_relpersistence = PQfnumber(res, "relpersistence");
    i_isscannable = PQfnumber(res, "isscannable");
    i_relpages = PQfnumber(res, "relpages");
    i_owning_tab = PQfnumber(res, "owning_tab");
    i_owning_col = PQfnumber(res, "owning_col");
    i_reltablespace = PQfnumber(res, "reltablespace");
    i_reloptions = PQfnumber(res, "reloptions");
    i_toastreloptions = PQfnumber(res, "toast_reloptions");
    i_reloftype = PQfnumber(res, "reloftype");

    if (lockWaitTimeout && fout->remoteVersion >= 70300)
    {
        /*
         * Arrange to fail instead of waiting forever for a table lock.
         *
         * NB: this coding assumes that the only queries issued within the
         * following loop are LOCK TABLEs; else the timeout may be undesirably
         * applied to other things too.
         */
        resetPQExpBuffer(query);
        appendPQExpBuffer(query, "SET statement_timeout = ");
        appendStringLiteralConn(query, lockWaitTimeout, GetConnection(fout));
        ExecuteSqlStatement(fout, query->data);
    }

    for (i = 0; i < ntups; i++)
    {
        tblinfo[i].dobj.objType = DO_TABLE;
        tblinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_reltableoid));
        tblinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_reloid));
        AssignDumpId(&tblinfo[i].dobj);
        tblinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_relname));
        tblinfo[i].dobj.namespace =
            findNamespace(fout,
                          atooid(PQgetvalue(res, i, i_relnamespace)),
                          tblinfo[i].dobj.catId.oid);
        tblinfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
        tblinfo[i].relacl = pg_strdup(PQgetvalue(res, i, i_relacl));
        tblinfo[i].relkind = *(PQgetvalue(res, i, i_relkind));
        tblinfo[i].relpersistence = *(PQgetvalue(res, i, i_relpersistence));
        tblinfo[i].hasindex = (strcmp(PQgetvalue(res, i, i_relhasindex), "t") == 0);
        tblinfo[i].hasrules = (strcmp(PQgetvalue(res, i, i_relhasrules), "t") == 0);
        tblinfo[i].hastriggers = (strcmp(PQgetvalue(res, i, i_relhastriggers), "t") == 0);
        tblinfo[i].hasoids = (strcmp(PQgetvalue(res, i, i_relhasoids), "t") == 0);
        tblinfo[i].isscannable = (strcmp(PQgetvalue(res, i, i_isscannable), "t") == 0);
        tblinfo[i].relpages = atoi(PQgetvalue(res, i, i_relpages));
        tblinfo[i].frozenxid = atooid(PQgetvalue(res, i, i_relfrozenxid));
        tblinfo[i].toast_oid = atooid(PQgetvalue(res, i, i_toastoid));
        tblinfo[i].toast_frozenxid = atooid(PQgetvalue(res, i, i_toastfrozenxid));
        if (PQgetisnull(res, i, i_reloftype))
            tblinfo[i].reloftype = NULL;
        else
            tblinfo[i].reloftype = pg_strdup(PQgetvalue(res, i, i_reloftype));
        tblinfo[i].ncheck = atoi(PQgetvalue(res, i, i_relchecks));
        if (PQgetisnull(res, i, i_owning_tab))
        {
            tblinfo[i].owning_tab = InvalidOid;
            tblinfo[i].owning_col = 0;
        }
        else
        {
            tblinfo[i].owning_tab = atooid(PQgetvalue(res, i, i_owning_tab));
            tblinfo[i].owning_col = atoi(PQgetvalue(res, i, i_owning_col));
        }
        tblinfo[i].reltablespace = pg_strdup(PQgetvalue(res, i, i_reltablespace));
        tblinfo[i].reloptions = pg_strdup(PQgetvalue(res, i, i_reloptions));
        tblinfo[i].toast_reloptions = pg_strdup(PQgetvalue(res, i, i_toastreloptions));

        /* other fields were zeroed above */

        /*
         * Decide whether we want to dump this table.
         */
        if (tblinfo[i].relkind == RELKIND_COMPOSITE_TYPE)
            tblinfo[i].dobj.dump = false;
        else
            selectDumpableTable(&tblinfo[i]);
        tblinfo[i].interesting = tblinfo[i].dobj.dump;

        /*
         * Read-lock target tables to make sure they aren't DROPPED or altered
         * in schema before we get around to dumping them.
         *
         * Note that we don't explicitly lock parents of the target tables; we
         * assume our lock on the child is enough to prevent schema
         * alterations to parent tables.
         *
         * NOTE: it'd be kinda nice to lock other relations too, not only
         * plain tables, but the backend doesn't presently allow that.
         */
        if (tblinfo[i].dobj.dump && tblinfo[i].relkind == RELKIND_RELATION)
        {
            resetPQExpBuffer(query);
            appendPQExpBuffer(query,
                              "LOCK TABLE %s IN ACCESS SHARE MODE",
                              fmtQualifiedId(fout->remoteVersion,
                                        tblinfo[i].dobj.namespace->dobj.name,
                                             tblinfo[i].dobj.name));
            ExecuteSqlStatement(fout, query->data);
        }

        /* Emit notice if join for owner failed */
        if (strlen(tblinfo[i].rolname) == 0)
            write_msg(NULL, "WARNING: owner of table \"%s\" appears to be invalid\n",
                      tblinfo[i].dobj.name);
    }

    if (lockWaitTimeout && fout->remoteVersion >= 70300)
    {
        ExecuteSqlStatement(fout, "SET statement_timeout = 0");
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return tblinfo;
}

/*
 * getOwnedSeqs
 *    identify owned sequences and mark them as dumpable if owning table is
 *
 * We used to do this in getTables(), but it's better to do it after the
 * index used by findTableByOid() has been set up.
 */
void
getOwnedSeqs(Archive *fout, TableInfo tblinfo[], int numTables)
{
    int         i;

    /*
     * Force sequences that are "owned" by table columns to be dumped whenever
     * their owning table is being dumped.
     */
    for (i = 0; i < numTables; i++)
    {
        TableInfo  *seqinfo = &tblinfo[i];
        TableInfo  *owning_tab;

        if (!OidIsValid(seqinfo->owning_tab))
            continue;           /* not an owned sequence */
        if (seqinfo->dobj.dump)
            continue;           /* no need to search */
        owning_tab = findTableByOid(seqinfo->owning_tab);
        if (owning_tab && owning_tab->dobj.dump)
        {
            seqinfo->interesting = true;
            seqinfo->dobj.dump = true;
        }
    }
}

/*
 * getInherits
 *    read all the inheritance information
 * from the system catalogs return them in the InhInfo* structure
 *
 * numInherits is set to the number of pairs read in
 */
InhInfo *
getInherits(Archive *fout, int *numInherits)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    InhInfo    *inhinfo;

    int         i_inhrelid;
    int         i_inhparent;

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    /* find all the inheritance information */

    appendPQExpBuffer(query, "SELECT inhrelid, inhparent FROM pg_inherits");

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);

    *numInherits = ntups;

    inhinfo = (InhInfo *) pg_malloc(ntups * sizeof(InhInfo));

    i_inhrelid = PQfnumber(res, "inhrelid");
    i_inhparent = PQfnumber(res, "inhparent");

    for (i = 0; i < ntups; i++)
    {
        inhinfo[i].inhrelid = atooid(PQgetvalue(res, i, i_inhrelid));
        inhinfo[i].inhparent = atooid(PQgetvalue(res, i, i_inhparent));
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return inhinfo;
}

/*
 * getIndexes
 *    get information about every index on a dumpable table
 *
 * Note: index data is not returned directly to the caller, but it
 * does get entered into the DumpableObject tables.
 */
void
getIndexes(Archive *fout, TableInfo tblinfo[], int numTables)
{
    int         i,
                j;
    PQExpBuffer query = createPQExpBuffer();
    PGresult   *res;
    IndxInfo   *indxinfo;
    ConstraintInfo *constrinfo;
    int         i_tableoid,
                i_oid,
                i_indexname,
                i_indexdef,
                i_indnkeys,
                i_indkey,
                i_indisclustered,
                i_contype,
                i_conname,
                i_condeferrable,
                i_condeferred,
                i_contableoid,
                i_conoid,
                i_condef,
                i_tablespace,
                i_options,
                i_relpages;
    int         ntups;

    for (i = 0; i < numTables; i++)
    {
        TableInfo  *tbinfo = &tblinfo[i];

        /* Only plain tables and materialized views have indexes. */
        if (tbinfo->relkind != RELKIND_RELATION &&
            tbinfo->relkind != RELKIND_MATVIEW)
            continue;
        if (!tbinfo->hasindex)
            continue;

        /* Ignore indexes of tables not to be dumped */
        if (!tbinfo->dobj.dump)
            continue;

        if (g_verbose)
            write_msg(NULL, "reading indexes for table \"%s\"\n",
                      tbinfo->dobj.name);

        /* Make sure we are in proper schema so indexdef is right */
        selectSourceSchema(fout, tbinfo->dobj.namespace->dobj.name);

        /*
         * The point of the messy-looking outer join is to find a constraint
         * that is related by an internal dependency link to the index. If we
         * find one, create a CONSTRAINT entry linked to the INDEX entry.  We
         * assume an index won't have more than one internal dependency.
         *
         * As of 9.0 we don't need to look at pg_depend but can check for a
         * match to pg_constraint.conindid.  The check on conrelid is
         * redundant but useful because that column is indexed while conindid
         * is not.
         */
        resetPQExpBuffer(query);
        if (fout->remoteVersion >= 90000)
        {
            /*
             * the test on indisready is necessary in 9.2, and harmless in
             * earlier/later versions
             */
            appendPQExpBuffer(query,
                              "SELECT t.tableoid, t.oid, "
                              "t.relname AS indexname, "
                     "pg_catalog.pg_get_indexdef(i.indexrelid) AS indexdef, "
                              "t.relnatts AS indnkeys, "
                              "i.indkey, i.indisclustered, "
                              "t.relpages, "
                              "c.contype, c.conname, "
                              "c.condeferrable, c.condeferred, "
                              "c.tableoid AS contableoid, "
                              "c.oid AS conoid, "
                  "pg_catalog.pg_get_constraintdef(c.oid, false) AS condef, "
                              "(SELECT spcname FROM pg_catalog.pg_tablespace s WHERE s.oid = t.reltablespace) AS tablespace, "
                            "array_to_string(t.reloptions, ', ') AS options "
                              "FROM pg_catalog.pg_index i "
                      "JOIN pg_catalog.pg_class t ON (t.oid = i.indexrelid) "
                              "LEFT JOIN pg_catalog.pg_constraint c "
                              "ON (i.indrelid = c.conrelid AND "
                              "i.indexrelid = c.conindid AND "
                              "c.contype IN ('p','u','x')) "
                              "WHERE i.indrelid = '%u'::pg_catalog.oid "
                              "AND i.indisvalid AND i.indisready "
                              "ORDER BY indexname",
                              tbinfo->dobj.catId.oid);
        }
        else if (fout->remoteVersion >= 80200)
        {
            appendPQExpBuffer(query,
                              "SELECT t.tableoid, t.oid, "
                              "t.relname AS indexname, "
                     "pg_catalog.pg_get_indexdef(i.indexrelid) AS indexdef, "
                              "t.relnatts AS indnkeys, "
                              "i.indkey, i.indisclustered, "
                              "t.relpages, "
                              "c.contype, c.conname, "
                              "c.condeferrable, c.condeferred, "
                              "c.tableoid AS contableoid, "
                              "c.oid AS conoid, "
                              "null AS condef, "
                              "(SELECT spcname FROM pg_catalog.pg_tablespace s WHERE s.oid = t.reltablespace) AS tablespace, "
                            "array_to_string(t.reloptions, ', ') AS options "
                              "FROM pg_catalog.pg_index i "
                      "JOIN pg_catalog.pg_class t ON (t.oid = i.indexrelid) "
                              "LEFT JOIN pg_catalog.pg_depend d "
                              "ON (d.classid = t.tableoid "
                              "AND d.objid = t.oid "
                              "AND d.deptype = 'i') "
                              "LEFT JOIN pg_catalog.pg_constraint c "
                              "ON (d.refclassid = c.tableoid "
                              "AND d.refobjid = c.oid) "
                              "WHERE i.indrelid = '%u'::pg_catalog.oid "
                              "AND i.indisvalid "
                              "ORDER BY indexname",
                              tbinfo->dobj.catId.oid);
        }
        else if (fout->remoteVersion >= 80000)
        {
            appendPQExpBuffer(query,
                              "SELECT t.tableoid, t.oid, "
                              "t.relname AS indexname, "
                     "pg_catalog.pg_get_indexdef(i.indexrelid) AS indexdef, "
                              "t.relnatts AS indnkeys, "
                              "i.indkey, i.indisclustered, "
                              "t.relpages, "
                              "c.contype, c.conname, "
                              "c.condeferrable, c.condeferred, "
                              "c.tableoid AS contableoid, "
                              "c.oid AS conoid, "
                              "null AS condef, "
                              "(SELECT spcname FROM pg_catalog.pg_tablespace s WHERE s.oid = t.reltablespace) AS tablespace, "
                              "null AS options "
                              "FROM pg_catalog.pg_index i "
                      "JOIN pg_catalog.pg_class t ON (t.oid = i.indexrelid) "
                              "LEFT JOIN pg_catalog.pg_depend d "
                              "ON (d.classid = t.tableoid "
                              "AND d.objid = t.oid "
                              "AND d.deptype = 'i') "
                              "LEFT JOIN pg_catalog.pg_constraint c "
                              "ON (d.refclassid = c.tableoid "
                              "AND d.refobjid = c.oid) "
                              "WHERE i.indrelid = '%u'::pg_catalog.oid "
                              "ORDER BY indexname",
                              tbinfo->dobj.catId.oid);
        }
        else if (fout->remoteVersion >= 70300)
        {
            appendPQExpBuffer(query,
                              "SELECT t.tableoid, t.oid, "
                              "t.relname AS indexname, "
                     "pg_catalog.pg_get_indexdef(i.indexrelid) AS indexdef, "
                              "t.relnatts AS indnkeys, "
                              "i.indkey, i.indisclustered, "
                              "t.relpages, "
                              "c.contype, c.conname, "
                              "c.condeferrable, c.condeferred, "
                              "c.tableoid AS contableoid, "
                              "c.oid AS conoid, "
                              "null AS condef, "
                              "NULL AS tablespace, "
                              "null AS options "
                              "FROM pg_catalog.pg_index i "
                      "JOIN pg_catalog.pg_class t ON (t.oid = i.indexrelid) "
                              "LEFT JOIN pg_catalog.pg_depend d "
                              "ON (d.classid = t.tableoid "
                              "AND d.objid = t.oid "
                              "AND d.deptype = 'i') "
                              "LEFT JOIN pg_catalog.pg_constraint c "
                              "ON (d.refclassid = c.tableoid "
                              "AND d.refobjid = c.oid) "
                              "WHERE i.indrelid = '%u'::pg_catalog.oid "
                              "ORDER BY indexname",
                              tbinfo->dobj.catId.oid);
        }
        else if (fout->remoteVersion >= 70100)
        {
            appendPQExpBuffer(query,
                              "SELECT t.tableoid, t.oid, "
                              "t.relname AS indexname, "
                              "pg_get_indexdef(i.indexrelid) AS indexdef, "
                              "t.relnatts AS indnkeys, "
                              "i.indkey, false AS indisclustered, "
                              "t.relpages, "
                              "CASE WHEN i.indisprimary THEN 'p'::char "
                              "ELSE '0'::char END AS contype, "
                              "t.relname AS conname, "
                              "false AS condeferrable, "
                              "false AS condeferred, "
                              "0::oid AS contableoid, "
                              "t.oid AS conoid, "
                              "null AS condef, "
                              "NULL AS tablespace, "
                              "null AS options "
                              "FROM pg_index i, pg_class t "
                              "WHERE t.oid = i.indexrelid "
                              "AND i.indrelid = '%u'::oid "
                              "ORDER BY indexname",
                              tbinfo->dobj.catId.oid);
        }
        else
        {
            appendPQExpBuffer(query,
                              "SELECT "
                              "(SELECT oid FROM pg_class WHERE relname = 'pg_class') AS tableoid, "
                              "t.oid, "
                              "t.relname AS indexname, "
                              "pg_get_indexdef(i.indexrelid) AS indexdef, "
                              "t.relnatts AS indnkeys, "
                              "i.indkey, false AS indisclustered, "
                              "t.relpages, "
                              "CASE WHEN i.indisprimary THEN 'p'::char "
                              "ELSE '0'::char END AS contype, "
                              "t.relname AS conname, "
                              "false AS condeferrable, "
                              "false AS condeferred, "
                              "0::oid AS contableoid, "
                              "t.oid AS conoid, "
                              "null AS condef, "
                              "NULL AS tablespace, "
                              "null AS options "
                              "FROM pg_index i, pg_class t "
                              "WHERE t.oid = i.indexrelid "
                              "AND i.indrelid = '%u'::oid "
                              "ORDER BY indexname",
                              tbinfo->dobj.catId.oid);
        }

        res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

        ntups = PQntuples(res);

        i_tableoid = PQfnumber(res, "tableoid");
        i_oid = PQfnumber(res, "oid");
        i_indexname = PQfnumber(res, "indexname");
        i_indexdef = PQfnumber(res, "indexdef");
        i_indnkeys = PQfnumber(res, "indnkeys");
        i_indkey = PQfnumber(res, "indkey");
        i_indisclustered = PQfnumber(res, "indisclustered");
        i_relpages = PQfnumber(res, "relpages");
        i_contype = PQfnumber(res, "contype");
        i_conname = PQfnumber(res, "conname");
        i_condeferrable = PQfnumber(res, "condeferrable");
        i_condeferred = PQfnumber(res, "condeferred");
        i_contableoid = PQfnumber(res, "contableoid");
        i_conoid = PQfnumber(res, "conoid");
        i_condef = PQfnumber(res, "condef");
        i_tablespace = PQfnumber(res, "tablespace");
        i_options = PQfnumber(res, "options");

        indxinfo = (IndxInfo *) pg_malloc(ntups * sizeof(IndxInfo));
        constrinfo = (ConstraintInfo *) pg_malloc(ntups * sizeof(ConstraintInfo));

        for (j = 0; j < ntups; j++)
        {
            char        contype;

            indxinfo[j].dobj.objType = DO_INDEX;
            indxinfo[j].dobj.catId.tableoid = atooid(PQgetvalue(res, j, i_tableoid));
            indxinfo[j].dobj.catId.oid = atooid(PQgetvalue(res, j, i_oid));
            AssignDumpId(&indxinfo[j].dobj);
            indxinfo[j].dobj.name = pg_strdup(PQgetvalue(res, j, i_indexname));
            indxinfo[j].dobj.namespace = tbinfo->dobj.namespace;
            indxinfo[j].indextable = tbinfo;
            indxinfo[j].indexdef = pg_strdup(PQgetvalue(res, j, i_indexdef));
            indxinfo[j].indnkeys = atoi(PQgetvalue(res, j, i_indnkeys));
            indxinfo[j].tablespace = pg_strdup(PQgetvalue(res, j, i_tablespace));
            indxinfo[j].options = pg_strdup(PQgetvalue(res, j, i_options));

            /*
             * In pre-7.4 releases, indkeys may contain more entries than
             * indnkeys says (since indnkeys will be 1 for a functional
             * index).  We don't actually care about this case since we don't
             * examine indkeys except for indexes associated with PRIMARY and
             * UNIQUE constraints, which are never functional indexes. But we
             * have to allocate enough space to keep parseOidArray from
             * complaining.
             */
            indxinfo[j].indkeys = (Oid *) pg_malloc(INDEX_MAX_KEYS * sizeof(Oid));
            parseOidArray(PQgetvalue(res, j, i_indkey),
                          indxinfo[j].indkeys, INDEX_MAX_KEYS);
            indxinfo[j].indisclustered = (PQgetvalue(res, j, i_indisclustered)[0] == 't');
            indxinfo[j].relpages = atoi(PQgetvalue(res, j, i_relpages));
            contype = *(PQgetvalue(res, j, i_contype));

            if (contype == 'p' || contype == 'u' || contype == 'x')
            {
                /*
                 * If we found a constraint matching the index, create an
                 * entry for it.
                 *
                 * In a pre-7.3 database, we take this path iff the index was
                 * marked indisprimary.
                 */
                constrinfo[j].dobj.objType = DO_CONSTRAINT;
                constrinfo[j].dobj.catId.tableoid = atooid(PQgetvalue(res, j, i_contableoid));
                constrinfo[j].dobj.catId.oid = atooid(PQgetvalue(res, j, i_conoid));
                AssignDumpId(&constrinfo[j].dobj);
                constrinfo[j].dobj.name = pg_strdup(PQgetvalue(res, j, i_conname));
                constrinfo[j].dobj.namespace = tbinfo->dobj.namespace;
                constrinfo[j].contable = tbinfo;
                constrinfo[j].condomain = NULL;
                constrinfo[j].contype = contype;
                if (contype == 'x')
                    constrinfo[j].condef = pg_strdup(PQgetvalue(res, j, i_condef));
                else
                    constrinfo[j].condef = NULL;
                constrinfo[j].confrelid = InvalidOid;
                constrinfo[j].conindex = indxinfo[j].dobj.dumpId;
                constrinfo[j].condeferrable = *(PQgetvalue(res, j, i_condeferrable)) == 't';
                constrinfo[j].condeferred = *(PQgetvalue(res, j, i_condeferred)) == 't';
                constrinfo[j].conislocal = true;
                constrinfo[j].separate = true;

                indxinfo[j].indexconstraint = constrinfo[j].dobj.dumpId;

                /* If pre-7.3 DB, better make sure table comes first */
                addObjectDependency(&constrinfo[j].dobj,
                                    tbinfo->dobj.dumpId);
            }
            else
            {
                /* Plain secondary index */
                indxinfo[j].indexconstraint = 0;
            }
        }

        PQclear(res);
    }

    destroyPQExpBuffer(query);
}

/*
 * getConstraints
 *
 * Get info about constraints on dumpable tables.
 *
 * Currently handles foreign keys only.
 * Unique and primary key constraints are handled with indexes,
 * while check constraints are processed in getTableAttrs().
 */
void
getConstraints(Archive *fout, TableInfo tblinfo[], int numTables)
{
    int         i,
                j;
    ConstraintInfo *constrinfo;
    PQExpBuffer query;
    PGresult   *res;
    int         i_contableoid,
                i_conoid,
                i_conname,
                i_confrelid,
                i_condef;
    int         ntups;

    /* pg_constraint was created in 7.3, so nothing to do if older */
    if (fout->remoteVersion < 70300)
        return;

    query = createPQExpBuffer();

    for (i = 0; i < numTables; i++)
    {
        TableInfo  *tbinfo = &tblinfo[i];

        if (!tbinfo->hastriggers || !tbinfo->dobj.dump)
            continue;

        if (g_verbose)
            write_msg(NULL, "reading foreign key constraints for table \"%s\"\n",
                      tbinfo->dobj.name);

        /*
         * select table schema to ensure constraint expr is qualified if
         * needed
         */
        selectSourceSchema(fout, tbinfo->dobj.namespace->dobj.name);

        resetPQExpBuffer(query);
        appendPQExpBuffer(query,
                          "SELECT tableoid, oid, conname, confrelid, "
                          "pg_catalog.pg_get_constraintdef(oid) AS condef "
                          "FROM pg_catalog.pg_constraint "
                          "WHERE conrelid = '%u'::pg_catalog.oid "
                          "AND contype = 'f'",
                          tbinfo->dobj.catId.oid);
        res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

        ntups = PQntuples(res);

        i_contableoid = PQfnumber(res, "tableoid");
        i_conoid = PQfnumber(res, "oid");
        i_conname = PQfnumber(res, "conname");
        i_confrelid = PQfnumber(res, "confrelid");
        i_condef = PQfnumber(res, "condef");

        constrinfo = (ConstraintInfo *) pg_malloc(ntups * sizeof(ConstraintInfo));

        for (j = 0; j < ntups; j++)
        {
            constrinfo[j].dobj.objType = DO_FK_CONSTRAINT;
            constrinfo[j].dobj.catId.tableoid = atooid(PQgetvalue(res, j, i_contableoid));
            constrinfo[j].dobj.catId.oid = atooid(PQgetvalue(res, j, i_conoid));
            AssignDumpId(&constrinfo[j].dobj);
            constrinfo[j].dobj.name = pg_strdup(PQgetvalue(res, j, i_conname));
            constrinfo[j].dobj.namespace = tbinfo->dobj.namespace;
            constrinfo[j].contable = tbinfo;
            constrinfo[j].condomain = NULL;
            constrinfo[j].contype = 'f';
            constrinfo[j].condef = pg_strdup(PQgetvalue(res, j, i_condef));
            constrinfo[j].confrelid = atooid(PQgetvalue(res, j, i_confrelid));
            constrinfo[j].conindex = 0;
            constrinfo[j].condeferrable = false;
            constrinfo[j].condeferred = false;
            constrinfo[j].conislocal = true;
            constrinfo[j].separate = true;
        }

        PQclear(res);
    }

    destroyPQExpBuffer(query);
}

/*
 * getDomainConstraints
 *
 * Get info about constraints on a domain.
 */
static void
getDomainConstraints(Archive *fout, TypeInfo *tyinfo)
{
    int         i;
    ConstraintInfo *constrinfo;
    PQExpBuffer query;
    PGresult   *res;
    int         i_tableoid,
                i_oid,
                i_conname,
                i_consrc;
    int         ntups;

    /* pg_constraint was created in 7.3, so nothing to do if older */
    if (fout->remoteVersion < 70300)
        return;

    /*
     * select appropriate schema to ensure names in constraint are properly
     * qualified
     */
    selectSourceSchema(fout, tyinfo->dobj.namespace->dobj.name);

    query = createPQExpBuffer();

    if (fout->remoteVersion >= 90100)
        appendPQExpBuffer(query, "SELECT tableoid, oid, conname, "
                          "pg_catalog.pg_get_constraintdef(oid) AS consrc, "
                          "convalidated "
                          "FROM pg_catalog.pg_constraint "
                          "WHERE contypid = '%u'::pg_catalog.oid "
                          "ORDER BY conname",
                          tyinfo->dobj.catId.oid);

    else if (fout->remoteVersion >= 70400)
        appendPQExpBuffer(query, "SELECT tableoid, oid, conname, "
                          "pg_catalog.pg_get_constraintdef(oid) AS consrc, "
                          "true as convalidated "
                          "FROM pg_catalog.pg_constraint "
                          "WHERE contypid = '%u'::pg_catalog.oid "
                          "ORDER BY conname",
                          tyinfo->dobj.catId.oid);
    else
        appendPQExpBuffer(query, "SELECT tableoid, oid, conname, "
                          "'CHECK (' || consrc || ')' AS consrc, "
                          "true as convalidated "
                          "FROM pg_catalog.pg_constraint "
                          "WHERE contypid = '%u'::pg_catalog.oid "
                          "ORDER BY conname",
                          tyinfo->dobj.catId.oid);

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_conname = PQfnumber(res, "conname");
    i_consrc = PQfnumber(res, "consrc");

    constrinfo = (ConstraintInfo *) pg_malloc(ntups * sizeof(ConstraintInfo));

    tyinfo->nDomChecks = ntups;
    tyinfo->domChecks = constrinfo;

    for (i = 0; i < ntups; i++)
    {
        bool        validated = PQgetvalue(res, i, 4)[0] == 't';

        constrinfo[i].dobj.objType = DO_CONSTRAINT;
        constrinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        constrinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&constrinfo[i].dobj);
        constrinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_conname));
        constrinfo[i].dobj.namespace = tyinfo->dobj.namespace;
        constrinfo[i].contable = NULL;
        constrinfo[i].condomain = tyinfo;
        constrinfo[i].contype = 'c';
        constrinfo[i].condef = pg_strdup(PQgetvalue(res, i, i_consrc));
        constrinfo[i].confrelid = InvalidOid;
        constrinfo[i].conindex = 0;
        constrinfo[i].condeferrable = false;
        constrinfo[i].condeferred = false;
        constrinfo[i].conislocal = true;

        constrinfo[i].separate = !validated;

        /*
         * Make the domain depend on the constraint, ensuring it won't be
         * output till any constraint dependencies are OK.  If the constraint
         * has not been validated, it's going to be dumped after the domain
         * anyway, so this doesn't matter.
         */
        if (validated)
            addObjectDependency(&tyinfo->dobj,
                                constrinfo[i].dobj.dumpId);
    }

    PQclear(res);

    destroyPQExpBuffer(query);
}

/*
 * getRules
 *    get basic information about every rule in the system
 *
 * numRules is set to the number of rules read in
 */
RuleInfo *
getRules(Archive *fout, int *numRules)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    RuleInfo   *ruleinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_rulename;
    int         i_ruletable;
    int         i_ev_type;
    int         i_is_instead;
    int         i_ev_enabled;

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    if (fout->remoteVersion >= 80300)
    {
        appendPQExpBuffer(query, "SELECT "
                          "tableoid, oid, rulename, "
                          "ev_class AS ruletable, ev_type, is_instead, "
                          "ev_enabled "
                          "FROM pg_rewrite "
                          "ORDER BY oid");
    }
    else if (fout->remoteVersion >= 70100)
    {
        appendPQExpBuffer(query, "SELECT "
                          "tableoid, oid, rulename, "
                          "ev_class AS ruletable, ev_type, is_instead, "
                          "'O'::char AS ev_enabled "
                          "FROM pg_rewrite "
                          "ORDER BY oid");
    }
    else
    {
        appendPQExpBuffer(query, "SELECT "
                          "(SELECT oid FROM pg_class WHERE relname = 'pg_rewrite') AS tableoid, "
                          "oid, rulename, "
                          "ev_class AS ruletable, ev_type, is_instead, "
                          "'O'::char AS ev_enabled "
                          "FROM pg_rewrite "
                          "ORDER BY oid");
    }

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);

    *numRules = ntups;

    ruleinfo = (RuleInfo *) pg_malloc(ntups * sizeof(RuleInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_rulename = PQfnumber(res, "rulename");
    i_ruletable = PQfnumber(res, "ruletable");
    i_ev_type = PQfnumber(res, "ev_type");
    i_is_instead = PQfnumber(res, "is_instead");
    i_ev_enabled = PQfnumber(res, "ev_enabled");

    for (i = 0; i < ntups; i++)
    {
        Oid         ruletableoid;

        ruleinfo[i].dobj.objType = DO_RULE;
        ruleinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        ruleinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&ruleinfo[i].dobj);
        ruleinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_rulename));
        ruletableoid = atooid(PQgetvalue(res, i, i_ruletable));
        ruleinfo[i].ruletable = findTableByOid(ruletableoid);
        if (ruleinfo[i].ruletable == NULL)
            exit_horribly(NULL, "failed sanity check, parent table OID %u of pg_rewrite entry OID %u not found\n",
                          ruletableoid, ruleinfo[i].dobj.catId.oid);
        ruleinfo[i].dobj.namespace = ruleinfo[i].ruletable->dobj.namespace;
        ruleinfo[i].dobj.dump = ruleinfo[i].ruletable->dobj.dump;
        ruleinfo[i].ev_type = *(PQgetvalue(res, i, i_ev_type));
        ruleinfo[i].is_instead = *(PQgetvalue(res, i, i_is_instead)) == 't';
        ruleinfo[i].ev_enabled = *(PQgetvalue(res, i, i_ev_enabled));
        if (ruleinfo[i].ruletable)
        {
            /*
             * If the table is a view or materialized view, force its ON
             * SELECT rule to be sorted before the view itself --- this
             * ensures that any dependencies for the rule affect the table's
             * positioning. Other rules are forced to appear after their
             * table.
             */
            if ((ruleinfo[i].ruletable->relkind == RELKIND_VIEW ||
                 ruleinfo[i].ruletable->relkind == RELKIND_MATVIEW) &&
                ruleinfo[i].ev_type == '1' && ruleinfo[i].is_instead)
            {
                addObjectDependency(&ruleinfo[i].ruletable->dobj,
                                    ruleinfo[i].dobj.dumpId);
                /* We'll merge the rule into CREATE VIEW, if possible */
                ruleinfo[i].separate = false;
            }
            else
            {
                addObjectDependency(&ruleinfo[i].dobj,
                                    ruleinfo[i].ruletable->dobj.dumpId);
                ruleinfo[i].separate = true;
            }
        }
        else
            ruleinfo[i].separate = true;

        /*
         * If we're forced to break a dependency loop by dumping a view as a
         * table and separate _RETURN rule, we'll move the view's reloptions
         * to the rule.  (This is necessary because tables and views have
         * different valid reloptions, so we can't apply the options until the
         * backend knows it's a view.)  Otherwise the rule's reloptions stay
         * NULL.
         */
        ruleinfo[i].reloptions = NULL;
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return ruleinfo;
}

/*
 * getTriggers
 *    get information about every trigger on a dumpable table
 *
 * Note: trigger data is not returned directly to the caller, but it
 * does get entered into the DumpableObject tables.
 */
void
getTriggers(Archive *fout, TableInfo tblinfo[], int numTables)
{
    int         i,
                j;
    PQExpBuffer query = createPQExpBuffer();
    PGresult   *res;
    TriggerInfo *tginfo;
    int         i_tableoid,
                i_oid,
                i_tgname,
                i_tgfname,
                i_tgtype,
                i_tgnargs,
                i_tgargs,
                i_tgisconstraint,
                i_tgconstrname,
                i_tgconstrrelid,
                i_tgconstrrelname,
                i_tgenabled,
                i_tgdeferrable,
                i_tginitdeferred,
                i_tgdef;
    int         ntups;

    for (i = 0; i < numTables; i++)
    {
        TableInfo  *tbinfo = &tblinfo[i];

        if (!tbinfo->hastriggers || !tbinfo->dobj.dump)
            continue;

        if (g_verbose)
            write_msg(NULL, "reading triggers for table \"%s\"\n",
                      tbinfo->dobj.name);

        /*
         * select table schema to ensure regproc name is qualified if needed
         */
        selectSourceSchema(fout, tbinfo->dobj.namespace->dobj.name);

        resetPQExpBuffer(query);
        if (fout->remoteVersion >= 90000)
        {
            /*
             * NB: think not to use pretty=true in pg_get_triggerdef.  It
             * could result in non-forward-compatible dumps of WHEN clauses
             * due to under-parenthesization.
             */
            appendPQExpBuffer(query,
                              "SELECT tgname, "
                              "tgfoid::pg_catalog.regproc AS tgfname, "
                        "pg_catalog.pg_get_triggerdef(oid, false) AS tgdef, "
                              "tgenabled, tableoid, oid "
                              "FROM pg_catalog.pg_trigger t "
                              "WHERE tgrelid = '%u'::pg_catalog.oid "
                              "AND NOT tgisinternal",
                              tbinfo->dobj.catId.oid);
        }
        else if (fout->remoteVersion >= 80300)
        {
            /*
             * We ignore triggers that are tied to a foreign-key constraint
             */
            appendPQExpBuffer(query,
                              "SELECT tgname, "
                              "tgfoid::pg_catalog.regproc AS tgfname, "
                              "tgtype, tgnargs, tgargs, tgenabled, "
                              "tgisconstraint, tgconstrname, tgdeferrable, "
                              "tgconstrrelid, tginitdeferred, tableoid, oid, "
                     "tgconstrrelid::pg_catalog.regclass AS tgconstrrelname "
                              "FROM pg_catalog.pg_trigger t "
                              "WHERE tgrelid = '%u'::pg_catalog.oid "
                              "AND tgconstraint = 0",
                              tbinfo->dobj.catId.oid);
        }
        else if (fout->remoteVersion >= 70300)
        {
            /*
             * We ignore triggers that are tied to a foreign-key constraint,
             * but in these versions we have to grovel through pg_constraint
             * to find out
             */
            appendPQExpBuffer(query,
                              "SELECT tgname, "
                              "tgfoid::pg_catalog.regproc AS tgfname, "
                              "tgtype, tgnargs, tgargs, tgenabled, "
                              "tgisconstraint, tgconstrname, tgdeferrable, "
                              "tgconstrrelid, tginitdeferred, tableoid, oid, "
                     "tgconstrrelid::pg_catalog.regclass AS tgconstrrelname "
                              "FROM pg_catalog.pg_trigger t "
                              "WHERE tgrelid = '%u'::pg_catalog.oid "
                              "AND (NOT tgisconstraint "
                              " OR NOT EXISTS"
                              "  (SELECT 1 FROM pg_catalog.pg_depend d "
                              "   JOIN pg_catalog.pg_constraint c ON (d.refclassid = c.tableoid AND d.refobjid = c.oid) "
                              "   WHERE d.classid = t.tableoid AND d.objid = t.oid AND d.deptype = 'i' AND c.contype = 'f'))",
                              tbinfo->dobj.catId.oid);
        }
        else if (fout->remoteVersion >= 70100)
        {
            appendPQExpBuffer(query,
                              "SELECT tgname, tgfoid::regproc AS tgfname, "
                              "tgtype, tgnargs, tgargs, tgenabled, "
                              "tgisconstraint, tgconstrname, tgdeferrable, "
                              "tgconstrrelid, tginitdeferred, tableoid, oid, "
                  "(SELECT relname FROM pg_class WHERE oid = tgconstrrelid) "
                              "     AS tgconstrrelname "
                              "FROM pg_trigger "
                              "WHERE tgrelid = '%u'::oid",
                              tbinfo->dobj.catId.oid);
        }
        else
        {
            appendPQExpBuffer(query,
                              "SELECT tgname, tgfoid::regproc AS tgfname, "
                              "tgtype, tgnargs, tgargs, tgenabled, "
                              "tgisconstraint, tgconstrname, tgdeferrable, "
                              "tgconstrrelid, tginitdeferred, "
                              "(SELECT oid FROM pg_class WHERE relname = 'pg_trigger') AS tableoid, "
                              "oid, "
                  "(SELECT relname FROM pg_class WHERE oid = tgconstrrelid) "
                              "     AS tgconstrrelname "
                              "FROM pg_trigger "
                              "WHERE tgrelid = '%u'::oid",
                              tbinfo->dobj.catId.oid);
        }
        res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

        ntups = PQntuples(res);

        i_tableoid = PQfnumber(res, "tableoid");
        i_oid = PQfnumber(res, "oid");
        i_tgname = PQfnumber(res, "tgname");
        i_tgfname = PQfnumber(res, "tgfname");
        i_tgtype = PQfnumber(res, "tgtype");
        i_tgnargs = PQfnumber(res, "tgnargs");
        i_tgargs = PQfnumber(res, "tgargs");
        i_tgisconstraint = PQfnumber(res, "tgisconstraint");
        i_tgconstrname = PQfnumber(res, "tgconstrname");
        i_tgconstrrelid = PQfnumber(res, "tgconstrrelid");
        i_tgconstrrelname = PQfnumber(res, "tgconstrrelname");
        i_tgenabled = PQfnumber(res, "tgenabled");
        i_tgdeferrable = PQfnumber(res, "tgdeferrable");
        i_tginitdeferred = PQfnumber(res, "tginitdeferred");
        i_tgdef = PQfnumber(res, "tgdef");

        tginfo = (TriggerInfo *) pg_malloc(ntups * sizeof(TriggerInfo));

        for (j = 0; j < ntups; j++)
        {
            tginfo[j].dobj.objType = DO_TRIGGER;
            tginfo[j].dobj.catId.tableoid = atooid(PQgetvalue(res, j, i_tableoid));
            tginfo[j].dobj.catId.oid = atooid(PQgetvalue(res, j, i_oid));
            AssignDumpId(&tginfo[j].dobj);
            tginfo[j].dobj.name = pg_strdup(PQgetvalue(res, j, i_tgname));
            tginfo[j].dobj.namespace = tbinfo->dobj.namespace;
            tginfo[j].tgtable = tbinfo;
            tginfo[j].tgenabled = *(PQgetvalue(res, j, i_tgenabled));
            if (i_tgdef >= 0)
            {
                tginfo[j].tgdef = pg_strdup(PQgetvalue(res, j, i_tgdef));

                /* remaining fields are not valid if we have tgdef */
                tginfo[j].tgfname = NULL;
                tginfo[j].tgtype = 0;
                tginfo[j].tgnargs = 0;
                tginfo[j].tgargs = NULL;
                tginfo[j].tgisconstraint = false;
                tginfo[j].tgdeferrable = false;
                tginfo[j].tginitdeferred = false;
                tginfo[j].tgconstrname = NULL;
                tginfo[j].tgconstrrelid = InvalidOid;
                tginfo[j].tgconstrrelname = NULL;
            }
            else
            {
                tginfo[j].tgdef = NULL;

                tginfo[j].tgfname = pg_strdup(PQgetvalue(res, j, i_tgfname));
                tginfo[j].tgtype = atoi(PQgetvalue(res, j, i_tgtype));
                tginfo[j].tgnargs = atoi(PQgetvalue(res, j, i_tgnargs));
                tginfo[j].tgargs = pg_strdup(PQgetvalue(res, j, i_tgargs));
                tginfo[j].tgisconstraint = *(PQgetvalue(res, j, i_tgisconstraint)) == 't';
                tginfo[j].tgdeferrable = *(PQgetvalue(res, j, i_tgdeferrable)) == 't';
                tginfo[j].tginitdeferred = *(PQgetvalue(res, j, i_tginitdeferred)) == 't';

                if (tginfo[j].tgisconstraint)
                {
                    tginfo[j].tgconstrname = pg_strdup(PQgetvalue(res, j, i_tgconstrname));
                    tginfo[j].tgconstrrelid = atooid(PQgetvalue(res, j, i_tgconstrrelid));
                    if (OidIsValid(tginfo[j].tgconstrrelid))
                    {
                        if (PQgetisnull(res, j, i_tgconstrrelname))
                            exit_horribly(NULL, "query produced null referenced table name for foreign key trigger \"%s\" on table \"%s\" (OID of table: %u)\n",
                                          tginfo[j].dobj.name,
                                          tbinfo->dobj.name,
                                          tginfo[j].tgconstrrelid);
                        tginfo[j].tgconstrrelname = pg_strdup(PQgetvalue(res, j, i_tgconstrrelname));
                    }
                    else
                        tginfo[j].tgconstrrelname = NULL;
                }
                else
                {
                    tginfo[j].tgconstrname = NULL;
                    tginfo[j].tgconstrrelid = InvalidOid;
                    tginfo[j].tgconstrrelname = NULL;
                }
            }
        }

        PQclear(res);
    }

    destroyPQExpBuffer(query);
}

/*
 * getEventTriggers
 *    get information about event triggers
 */
EventTriggerInfo *
getEventTriggers(Archive *fout, int *numEventTriggers)
{
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    PGresult   *res;
    EventTriggerInfo *evtinfo;
    int         i_tableoid,
                i_oid,
                i_evtname,
                i_evtevent,
                i_evtowner,
                i_evttags,
                i_evtfname,
                i_evtenabled;
    int         ntups;

    /* Before 9.3, there are no event triggers */
    if (fout->remoteVersion < 90300)
    {
        *numEventTriggers = 0;
        return NULL;
    }

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    appendPQExpBuffer(query,
                      "SELECT e.tableoid, e.oid, evtname, evtenabled, "
                      "evtevent, (%s evtowner) AS evtowner, "
                      "array_to_string(array("
                      "select quote_literal(x) "
                      " from unnest(evttags) as t(x)), ', ') as evttags, "
                      "e.evtfoid::regproc as evtfname "
                      "FROM pg_event_trigger e "
                      "ORDER BY e.oid",
                      username_subquery);

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);

    *numEventTriggers = ntups;

    evtinfo = (EventTriggerInfo *) pg_malloc(ntups * sizeof(EventTriggerInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_evtname = PQfnumber(res, "evtname");
    i_evtevent = PQfnumber(res, "evtevent");
    i_evtowner = PQfnumber(res, "evtowner");
    i_evttags = PQfnumber(res, "evttags");
    i_evtfname = PQfnumber(res, "evtfname");
    i_evtenabled = PQfnumber(res, "evtenabled");

    for (i = 0; i < ntups; i++)
    {
        evtinfo[i].dobj.objType = DO_EVENT_TRIGGER;
        evtinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        evtinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&evtinfo[i].dobj);
        evtinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_evtname));
        evtinfo[i].evtname = pg_strdup(PQgetvalue(res, i, i_evtname));
        evtinfo[i].evtevent = pg_strdup(PQgetvalue(res, i, i_evtevent));
        evtinfo[i].evtowner = pg_strdup(PQgetvalue(res, i, i_evtowner));
        evtinfo[i].evttags = pg_strdup(PQgetvalue(res, i, i_evttags));
        evtinfo[i].evtfname = pg_strdup(PQgetvalue(res, i, i_evtfname));
        evtinfo[i].evtenabled = *(PQgetvalue(res, i, i_evtenabled));
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return evtinfo;
}

/*
 * getProcLangs
 *    get basic information about every procedural language in the system
 *
 * numProcLangs is set to the number of langs read in
 *
 * NB: this must run after getFuncs() because we assume we can do
 * findFuncByOid().
 */
ProcLangInfo *
getProcLangs(Archive *fout, int *numProcLangs)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    ProcLangInfo *planginfo;
    int         i_tableoid;
    int         i_oid;
    int         i_lanname;
    int         i_lanpltrusted;
    int         i_lanplcallfoid;
    int         i_laninline;
    int         i_lanvalidator;
    int         i_lanacl;
    int         i_lanowner;

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    if (fout->remoteVersion >= 90000)
    {
        /* pg_language has a laninline column */
        appendPQExpBuffer(query, "SELECT tableoid, oid, "
                          "lanname, lanpltrusted, lanplcallfoid, "
                          "laninline, lanvalidator,  lanacl, "
                          "(%s lanowner) AS lanowner "
                          "FROM pg_language "
                          "WHERE lanispl "
                          "ORDER BY oid",
                          username_subquery);
    }
    else if (fout->remoteVersion >= 80300)
    {
        /* pg_language has a lanowner column */
        appendPQExpBuffer(query, "SELECT tableoid, oid, "
                          "lanname, lanpltrusted, lanplcallfoid, "
                          "lanvalidator,  lanacl, "
                          "(%s lanowner) AS lanowner "
                          "FROM pg_language "
                          "WHERE lanispl "
                          "ORDER BY oid",
                          username_subquery);
    }
    else if (fout->remoteVersion >= 80100)
    {
        /* Languages are owned by the bootstrap superuser, OID 10 */
        appendPQExpBuffer(query, "SELECT tableoid, oid, *, "
                          "(%s '10') AS lanowner "
                          "FROM pg_language "
                          "WHERE lanispl "
                          "ORDER BY oid",
                          username_subquery);
    }
    else if (fout->remoteVersion >= 70400)
    {
        /* Languages are owned by the bootstrap superuser, sysid 1 */
        appendPQExpBuffer(query, "SELECT tableoid, oid, *, "
                          "(%s '1') AS lanowner "
                          "FROM pg_language "
                          "WHERE lanispl "
                          "ORDER BY oid",
                          username_subquery);
    }
    else if (fout->remoteVersion >= 70100)
    {
        /* No clear notion of an owner at all before 7.4 ... */
        appendPQExpBuffer(query, "SELECT tableoid, oid, * FROM pg_language "
                          "WHERE lanispl "
                          "ORDER BY oid");
    }
    else
    {
        appendPQExpBuffer(query, "SELECT "
                          "(SELECT oid FROM pg_class WHERE relname = 'pg_language') AS tableoid, "
                          "oid, * FROM pg_language "
                          "WHERE lanispl "
                          "ORDER BY oid");
    }

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);

    *numProcLangs = ntups;

    planginfo = (ProcLangInfo *) pg_malloc(ntups * sizeof(ProcLangInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_lanname = PQfnumber(res, "lanname");
    i_lanpltrusted = PQfnumber(res, "lanpltrusted");
    i_lanplcallfoid = PQfnumber(res, "lanplcallfoid");
    /* these may fail and return -1: */
    i_laninline = PQfnumber(res, "laninline");
    i_lanvalidator = PQfnumber(res, "lanvalidator");
    i_lanacl = PQfnumber(res, "lanacl");
    i_lanowner = PQfnumber(res, "lanowner");

    for (i = 0; i < ntups; i++)
    {
        planginfo[i].dobj.objType = DO_PROCLANG;
        planginfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        planginfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&planginfo[i].dobj);

        planginfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_lanname));
        planginfo[i].lanpltrusted = *(PQgetvalue(res, i, i_lanpltrusted)) == 't';
        planginfo[i].lanplcallfoid = atooid(PQgetvalue(res, i, i_lanplcallfoid));
        if (i_laninline >= 0)
            planginfo[i].laninline = atooid(PQgetvalue(res, i, i_laninline));
        else
            planginfo[i].laninline = InvalidOid;
        if (i_lanvalidator >= 0)
            planginfo[i].lanvalidator = atooid(PQgetvalue(res, i, i_lanvalidator));
        else
            planginfo[i].lanvalidator = InvalidOid;
        if (i_lanacl >= 0)
            planginfo[i].lanacl = pg_strdup(PQgetvalue(res, i, i_lanacl));
        else
            planginfo[i].lanacl = pg_strdup("{=U}");
        if (i_lanowner >= 0)
            planginfo[i].lanowner = pg_strdup(PQgetvalue(res, i, i_lanowner));
        else
            planginfo[i].lanowner = pg_strdup("");

        if (fout->remoteVersion < 70300)
        {
            /*
             * We need to make a dependency to ensure the function will be
             * dumped first.  (In 7.3 and later the regular dependency
             * mechanism will handle this for us.)
             */
            FuncInfo   *funcInfo = findFuncByOid(planginfo[i].lanplcallfoid);

            if (funcInfo)
                addObjectDependency(&planginfo[i].dobj,
                                    funcInfo->dobj.dumpId);
        }
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return planginfo;
}

/*
 * getCasts
 *    get basic information about every cast in the system
 *
 * numCasts is set to the number of casts read in
 */
CastInfo *
getCasts(Archive *fout, int *numCasts)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    CastInfo   *castinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_castsource;
    int         i_casttarget;
    int         i_castfunc;
    int         i_castcontext;
    int         i_castmethod;

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    if (fout->remoteVersion >= 80400)
    {
        appendPQExpBuffer(query, "SELECT tableoid, oid, "
                          "castsource, casttarget, castfunc, castcontext, "
                          "castmethod "
                          "FROM pg_cast ORDER BY 3,4");
    }
    else if (fout->remoteVersion >= 70300)
    {
        appendPQExpBuffer(query, "SELECT tableoid, oid, "
                          "castsource, casttarget, castfunc, castcontext, "
                "CASE WHEN castfunc = 0 THEN 'b' ELSE 'f' END AS castmethod "
                          "FROM pg_cast ORDER BY 3,4");
    }
    else
    {
        appendPQExpBuffer(query, "SELECT 0 AS tableoid, p.oid, "
                          "t1.oid AS castsource, t2.oid AS casttarget, "
                          "p.oid AS castfunc, 'e' AS castcontext, "
                          "'f' AS castmethod "
                          "FROM pg_type t1, pg_type t2, pg_proc p "
                          "WHERE p.pronargs = 1 AND "
                          "p.proargtypes[0] = t1.oid AND "
                          "p.prorettype = t2.oid AND p.proname = t2.typname "
                          "ORDER BY 3,4");
    }

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);

    *numCasts = ntups;

    castinfo = (CastInfo *) pg_malloc(ntups * sizeof(CastInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_castsource = PQfnumber(res, "castsource");
    i_casttarget = PQfnumber(res, "casttarget");
    i_castfunc = PQfnumber(res, "castfunc");
    i_castcontext = PQfnumber(res, "castcontext");
    i_castmethod = PQfnumber(res, "castmethod");

    for (i = 0; i < ntups; i++)
    {
        PQExpBufferData namebuf;
        TypeInfo   *sTypeInfo;
        TypeInfo   *tTypeInfo;

        castinfo[i].dobj.objType = DO_CAST;
        castinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        castinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&castinfo[i].dobj);
        castinfo[i].castsource = atooid(PQgetvalue(res, i, i_castsource));
        castinfo[i].casttarget = atooid(PQgetvalue(res, i, i_casttarget));
        castinfo[i].castfunc = atooid(PQgetvalue(res, i, i_castfunc));
        castinfo[i].castcontext = *(PQgetvalue(res, i, i_castcontext));
        castinfo[i].castmethod = *(PQgetvalue(res, i, i_castmethod));

        /*
         * Try to name cast as concatenation of typnames.  This is only used
         * for purposes of sorting.  If we fail to find either type, the name
         * will be an empty string.
         */
        initPQExpBuffer(&namebuf);
        sTypeInfo = findTypeByOid(castinfo[i].castsource);
        tTypeInfo = findTypeByOid(castinfo[i].casttarget);
        if (sTypeInfo && tTypeInfo)
            appendPQExpBuffer(&namebuf, "%s %s",
                              sTypeInfo->dobj.name, tTypeInfo->dobj.name);
        castinfo[i].dobj.name = namebuf.data;

        if (OidIsValid(castinfo[i].castfunc))
        {
            /*
             * We need to make a dependency to ensure the function will be
             * dumped first.  (In 7.3 and later the regular dependency
             * mechanism will handle this for us.)
             */
            FuncInfo   *funcInfo;

            funcInfo = findFuncByOid(castinfo[i].castfunc);
            if (funcInfo)
                addObjectDependency(&castinfo[i].dobj,
                                    funcInfo->dobj.dumpId);
        }
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return castinfo;
}

/*
 * getTableAttrs -
 *    for each interesting table, read info about its attributes
 *    (names, types, default values, CHECK constraints, etc)
 *
 * This is implemented in a very inefficient way right now, looping
 * through the tblinfo and doing a join per table to find the attrs and their
 * types.  However, because we want type names and so forth to be named
 * relative to the schema of each table, we couldn't do it in just one
 * query.  (Maybe one query per schema?)
 *
 *  modifies tblinfo
 */
void
getTableAttrs(Archive *fout, TableInfo *tblinfo, int numTables)
{
    int         i,
                j;
    PQExpBuffer q = createPQExpBuffer();
    int         i_attnum;
    int         i_attname;
    int         i_atttypname;
    int         i_atttypmod;
    int         i_attstattarget;
    int         i_attstorage;
    int         i_typstorage;
    int         i_attnotnull;
    int         i_atthasdef;
    int         i_attisdropped;
    int         i_attlen;
    int         i_attalign;
    int         i_attislocal;
    int         i_attoptions;
    int         i_attcollation;
    int         i_attfdwoptions;
    PGresult   *res;
    int         ntups;
    bool        hasdefaults;

    for (i = 0; i < numTables; i++)
    {
        TableInfo  *tbinfo = &tblinfo[i];

        /* Don't bother to collect info for sequences */
        if (tbinfo->relkind == RELKIND_SEQUENCE)
            continue;

        /* Don't bother with uninteresting tables, either */
        if (!tbinfo->interesting)
            continue;

        /*
         * Make sure we are in proper schema for this table; this allows
         * correct retrieval of formatted type names and default exprs
         */
        selectSourceSchema(fout, tbinfo->dobj.namespace->dobj.name);

        /* find all the user attributes and their types */

        /*
         * we must read the attribute names in attribute number order! because
         * we will use the attnum to index into the attnames array later.  We
         * actually ask to order by "attrelid, attnum" because (at least up to
         * 7.3) the planner is not smart enough to realize it needn't re-sort
         * the output of an indexscan on pg_attribute_relid_attnum_index.
         */
        if (g_verbose)
            write_msg(NULL, "finding the columns and types of table \"%s\"\n",
                      tbinfo->dobj.name);

        resetPQExpBuffer(q);

        if (fout->remoteVersion >= 90200)
        {
            /*
             * attfdwoptions is new in 9.2.
             */
            appendPQExpBuffer(q, "SELECT a.attnum, a.attname, a.atttypmod, "
                              "a.attstattarget, a.attstorage, t.typstorage, "
                              "a.attnotnull, a.atthasdef, a.attisdropped, "
                              "a.attlen, a.attalign, a.attislocal, "
                  "pg_catalog.format_type(t.oid,a.atttypmod) AS atttypname, "
                        "array_to_string(a.attoptions, ', ') AS attoptions, "
                              "CASE WHEN a.attcollation <> t.typcollation "
                           "THEN a.attcollation ELSE 0 END AS attcollation, "
                              "pg_catalog.array_to_string(ARRAY("
                              "SELECT pg_catalog.quote_ident(option_name) || "
                              "' ' || pg_catalog.quote_literal(option_value) "
                        "FROM pg_catalog.pg_options_to_table(attfdwoptions) "
                              "ORDER BY option_name"
                              "), E',\n    ') AS attfdwoptions "
             "FROM pg_catalog.pg_attribute a LEFT JOIN pg_catalog.pg_type t "
                              "ON a.atttypid = t.oid "
                              "WHERE a.attrelid = '%u'::pg_catalog.oid "
                              "AND a.attnum > 0::pg_catalog.int2 "
                              "ORDER BY a.attrelid, a.attnum",
                              tbinfo->dobj.catId.oid);
        }
        else if (fout->remoteVersion >= 90100)
        {
            /*
             * attcollation is new in 9.1.  Since we only want to dump COLLATE
             * clauses for attributes whose collation is different from their
             * type's default, we use a CASE here to suppress uninteresting
             * attcollations cheaply.
             */
            appendPQExpBuffer(q, "SELECT a.attnum, a.attname, a.atttypmod, "
                              "a.attstattarget, a.attstorage, t.typstorage, "
                              "a.attnotnull, a.atthasdef, a.attisdropped, "
                              "a.attlen, a.attalign, a.attislocal, "
                  "pg_catalog.format_type(t.oid,a.atttypmod) AS atttypname, "
                        "array_to_string(a.attoptions, ', ') AS attoptions, "
                              "CASE WHEN a.attcollation <> t.typcollation "
                           "THEN a.attcollation ELSE 0 END AS attcollation, "
                              "NULL AS attfdwoptions "
             "FROM pg_catalog.pg_attribute a LEFT JOIN pg_catalog.pg_type t "
                              "ON a.atttypid = t.oid "
                              "WHERE a.attrelid = '%u'::pg_catalog.oid "
                              "AND a.attnum > 0::pg_catalog.int2 "
                              "ORDER BY a.attrelid, a.attnum",
                              tbinfo->dobj.catId.oid);
        }
        else if (fout->remoteVersion >= 90000)
        {
            /* attoptions is new in 9.0 */
            appendPQExpBuffer(q, "SELECT a.attnum, a.attname, a.atttypmod, "
                              "a.attstattarget, a.attstorage, t.typstorage, "
                              "a.attnotnull, a.atthasdef, a.attisdropped, "
                              "a.attlen, a.attalign, a.attislocal, "
                  "pg_catalog.format_type(t.oid,a.atttypmod) AS atttypname, "
                        "array_to_string(a.attoptions, ', ') AS attoptions, "
                              "0 AS attcollation, "
                              "NULL AS attfdwoptions "
             "FROM pg_catalog.pg_attribute a LEFT JOIN pg_catalog.pg_type t "
                              "ON a.atttypid = t.oid "
                              "WHERE a.attrelid = '%u'::pg_catalog.oid "
                              "AND a.attnum > 0::pg_catalog.int2 "
                              "ORDER BY a.attrelid, a.attnum",
                              tbinfo->dobj.catId.oid);
        }
        else if (fout->remoteVersion >= 70300)
        {
            /* need left join here to not fail on dropped columns ... */
            appendPQExpBuffer(q, "SELECT a.attnum, a.attname, a.atttypmod, "
                              "a.attstattarget, a.attstorage, t.typstorage, "
                              "a.attnotnull, a.atthasdef, a.attisdropped, "
                              "a.attlen, a.attalign, a.attislocal, "
                  "pg_catalog.format_type(t.oid,a.atttypmod) AS atttypname, "
                              "'' AS attoptions, 0 AS attcollation, "
                              "NULL AS attfdwoptions "
             "FROM pg_catalog.pg_attribute a LEFT JOIN pg_catalog.pg_type t "
                              "ON a.atttypid = t.oid "
                              "WHERE a.attrelid = '%u'::pg_catalog.oid "
                              "AND a.attnum > 0::pg_catalog.int2 "
                              "ORDER BY a.attrelid, a.attnum",
                              tbinfo->dobj.catId.oid);
        }
        else if (fout->remoteVersion >= 70100)
        {
            /*
             * attstattarget doesn't exist in 7.1.  It does exist in 7.2, but
             * we don't dump it because we can't tell whether it's been
             * explicitly set or was just a default.
             *
             * attislocal doesn't exist before 7.3, either; in older databases
             * we assume it's TRUE, else we'd fail to dump non-inherited atts.
             */
            appendPQExpBuffer(q, "SELECT a.attnum, a.attname, a.atttypmod, "
                              "-1 AS attstattarget, a.attstorage, "
                              "t.typstorage, a.attnotnull, a.atthasdef, "
                              "false AS attisdropped, a.attlen, "
                              "a.attalign, true AS attislocal, "
                              "format_type(t.oid,a.atttypmod) AS atttypname, "
                              "'' AS attoptions, 0 AS attcollation, "
                              "NULL AS attfdwoptions "
                              "FROM pg_attribute a LEFT JOIN pg_type t "
                              "ON a.atttypid = t.oid "
                              "WHERE a.attrelid = '%u'::oid "
                              "AND a.attnum > 0::int2 "
                              "ORDER BY a.attrelid, a.attnum",
                              tbinfo->dobj.catId.oid);
        }
        else
        {
            /* format_type not available before 7.1 */
            appendPQExpBuffer(q, "SELECT attnum, attname, atttypmod, "
                              "-1 AS attstattarget, "
                              "attstorage, attstorage AS typstorage, "
                              "attnotnull, atthasdef, false AS attisdropped, "
                              "attlen, attalign, "
                              "true AS attislocal, "
                              "(SELECT typname FROM pg_type WHERE oid = atttypid) AS atttypname, "
                              "'' AS attoptions, 0 AS attcollation, "
                              "NULL AS attfdwoptions "
                              "FROM pg_attribute a "
                              "WHERE attrelid = '%u'::oid "
                              "AND attnum > 0::int2 "
                              "ORDER BY attrelid, attnum",
                              tbinfo->dobj.catId.oid);
        }

        res = ExecuteSqlQuery(fout, q->data, PGRES_TUPLES_OK);

        ntups = PQntuples(res);

        i_attnum = PQfnumber(res, "attnum");
        i_attname = PQfnumber(res, "attname");
        i_atttypname = PQfnumber(res, "atttypname");
        i_atttypmod = PQfnumber(res, "atttypmod");
        i_attstattarget = PQfnumber(res, "attstattarget");
        i_attstorage = PQfnumber(res, "attstorage");
        i_typstorage = PQfnumber(res, "typstorage");
        i_attnotnull = PQfnumber(res, "attnotnull");
        i_atthasdef = PQfnumber(res, "atthasdef");
        i_attisdropped = PQfnumber(res, "attisdropped");
        i_attlen = PQfnumber(res, "attlen");
        i_attalign = PQfnumber(res, "attalign");
        i_attislocal = PQfnumber(res, "attislocal");
        i_attoptions = PQfnumber(res, "attoptions");
        i_attcollation = PQfnumber(res, "attcollation");
        i_attfdwoptions = PQfnumber(res, "attfdwoptions");

        tbinfo->numatts = ntups;
        tbinfo->attnames = (char **) pg_malloc(ntups * sizeof(char *));
        tbinfo->atttypnames = (char **) pg_malloc(ntups * sizeof(char *));
        tbinfo->atttypmod = (int *) pg_malloc(ntups * sizeof(int));
        tbinfo->attstattarget = (int *) pg_malloc(ntups * sizeof(int));
        tbinfo->attstorage = (char *) pg_malloc(ntups * sizeof(char));
        tbinfo->typstorage = (char *) pg_malloc(ntups * sizeof(char));
        tbinfo->attisdropped = (bool *) pg_malloc(ntups * sizeof(bool));
        tbinfo->attlen = (int *) pg_malloc(ntups * sizeof(int));
        tbinfo->attalign = (char *) pg_malloc(ntups * sizeof(char));
        tbinfo->attislocal = (bool *) pg_malloc(ntups * sizeof(bool));
        tbinfo->attoptions = (char **) pg_malloc(ntups * sizeof(char *));
        tbinfo->attcollation = (Oid *) pg_malloc(ntups * sizeof(Oid));
        tbinfo->attfdwoptions = (char **) pg_malloc(ntups * sizeof(char *));
        tbinfo->notnull = (bool *) pg_malloc(ntups * sizeof(bool));
        tbinfo->inhNotNull = (bool *) pg_malloc(ntups * sizeof(bool));
        tbinfo->attrdefs = (AttrDefInfo **) pg_malloc(ntups * sizeof(AttrDefInfo *));
        hasdefaults = false;

        for (j = 0; j < ntups; j++)
        {
            if (j + 1 != atoi(PQgetvalue(res, j, i_attnum)))
                exit_horribly(NULL,
                              "invalid column numbering in table \"%s\"\n",
                              tbinfo->dobj.name);
            tbinfo->attnames[j] = pg_strdup(PQgetvalue(res, j, i_attname));
            tbinfo->atttypnames[j] = pg_strdup(PQgetvalue(res, j, i_atttypname));
            tbinfo->atttypmod[j] = atoi(PQgetvalue(res, j, i_atttypmod));
            tbinfo->attstattarget[j] = atoi(PQgetvalue(res, j, i_attstattarget));
            tbinfo->attstorage[j] = *(PQgetvalue(res, j, i_attstorage));
            tbinfo->typstorage[j] = *(PQgetvalue(res, j, i_typstorage));
            tbinfo->attisdropped[j] = (PQgetvalue(res, j, i_attisdropped)[0] == 't');
            tbinfo->attlen[j] = atoi(PQgetvalue(res, j, i_attlen));
            tbinfo->attalign[j] = *(PQgetvalue(res, j, i_attalign));
            tbinfo->attislocal[j] = (PQgetvalue(res, j, i_attislocal)[0] == 't');
            tbinfo->notnull[j] = (PQgetvalue(res, j, i_attnotnull)[0] == 't');
            tbinfo->attoptions[j] = pg_strdup(PQgetvalue(res, j, i_attoptions));
            tbinfo->attcollation[j] = atooid(PQgetvalue(res, j, i_attcollation));
            tbinfo->attfdwoptions[j] = pg_strdup(PQgetvalue(res, j, i_attfdwoptions));
            tbinfo->attrdefs[j] = NULL; /* fix below */
            if (PQgetvalue(res, j, i_atthasdef)[0] == 't')
                hasdefaults = true;
            /* these flags will be set in flagInhAttrs() */
            tbinfo->inhNotNull[j] = false;
        }

        PQclear(res);

        /*
         * Get info about column defaults
         */
        if (hasdefaults)
        {
            AttrDefInfo *attrdefs;
            int         numDefaults;

            if (g_verbose)
                write_msg(NULL, "finding default expressions of table \"%s\"\n",
                          tbinfo->dobj.name);

            resetPQExpBuffer(q);
            if (fout->remoteVersion >= 70300)
            {
                appendPQExpBuffer(q, "SELECT tableoid, oid, adnum, "
                           "pg_catalog.pg_get_expr(adbin, adrelid) AS adsrc "
                                  "FROM pg_catalog.pg_attrdef "
                                  "WHERE adrelid = '%u'::pg_catalog.oid",
                                  tbinfo->dobj.catId.oid);
            }
            else if (fout->remoteVersion >= 70200)
            {
                /* 7.2 did not have OIDs in pg_attrdef */
                appendPQExpBuffer(q, "SELECT tableoid, 0 AS oid, adnum, "
                                  "pg_get_expr(adbin, adrelid) AS adsrc "
                                  "FROM pg_attrdef "
                                  "WHERE adrelid = '%u'::oid",
                                  tbinfo->dobj.catId.oid);
            }
            else if (fout->remoteVersion >= 70100)
            {
                /* no pg_get_expr, so must rely on adsrc */
                appendPQExpBuffer(q, "SELECT tableoid, oid, adnum, adsrc "
                                  "FROM pg_attrdef "
                                  "WHERE adrelid = '%u'::oid",
                                  tbinfo->dobj.catId.oid);
            }
            else
            {
                /* no pg_get_expr, no tableoid either */
                appendPQExpBuffer(q, "SELECT "
                                  "(SELECT oid FROM pg_class WHERE relname = 'pg_attrdef') AS tableoid, "
                                  "oid, adnum, adsrc "
                                  "FROM pg_attrdef "
                                  "WHERE adrelid = '%u'::oid",
                                  tbinfo->dobj.catId.oid);
            }
            res = ExecuteSqlQuery(fout, q->data, PGRES_TUPLES_OK);

            numDefaults = PQntuples(res);
            attrdefs = (AttrDefInfo *) pg_malloc(numDefaults * sizeof(AttrDefInfo));

            for (j = 0; j < numDefaults; j++)
            {
                int         adnum;

                adnum = atoi(PQgetvalue(res, j, 2));

                if (adnum <= 0 || adnum > ntups)
                    exit_horribly(NULL,
                                  "invalid adnum value %d for table \"%s\"\n",
                                  adnum, tbinfo->dobj.name);

                /*
                 * dropped columns shouldn't have defaults, but just in case,
                 * ignore 'em
                 */
                if (tbinfo->attisdropped[adnum - 1])
                    continue;

                attrdefs[j].dobj.objType = DO_ATTRDEF;
                attrdefs[j].dobj.catId.tableoid = atooid(PQgetvalue(res, j, 0));
                attrdefs[j].dobj.catId.oid = atooid(PQgetvalue(res, j, 1));
                AssignDumpId(&attrdefs[j].dobj);
                attrdefs[j].adtable = tbinfo;
                attrdefs[j].adnum = adnum;
                attrdefs[j].adef_expr = pg_strdup(PQgetvalue(res, j, 3));

                attrdefs[j].dobj.name = pg_strdup(tbinfo->dobj.name);
                attrdefs[j].dobj.namespace = tbinfo->dobj.namespace;

                attrdefs[j].dobj.dump = tbinfo->dobj.dump;

                /*
                 * Defaults on a VIEW must always be dumped as separate ALTER
                 * TABLE commands.  Defaults on regular tables are dumped as
                 * part of the CREATE TABLE if possible, which it won't be if
                 * the column is not going to be emitted explicitly.
                 */
                if (tbinfo->relkind == RELKIND_VIEW)
                {
                    attrdefs[j].separate = true;
                    /* needed in case pre-7.3 DB: */
                    addObjectDependency(&attrdefs[j].dobj,
                                        tbinfo->dobj.dumpId);
                }
                else if (!shouldPrintColumn(tbinfo, adnum - 1))
                {
                    /* column will be suppressed, print default separately */
                    attrdefs[j].separate = true;
                    /* needed in case pre-7.3 DB: */
                    addObjectDependency(&attrdefs[j].dobj,
                                        tbinfo->dobj.dumpId);
                }
                else
                {
                    attrdefs[j].separate = false;

                    /*
                     * Mark the default as needing to appear before the table,
                     * so that any dependencies it has must be emitted before
                     * the CREATE TABLE.  If this is not possible, we'll
                     * change to "separate" mode while sorting dependencies.
                     */
                    addObjectDependency(&tbinfo->dobj,
                                        attrdefs[j].dobj.dumpId);
                }

                tbinfo->attrdefs[adnum - 1] = &attrdefs[j];
            }
            PQclear(res);
        }

        /*
         * Get info about table CHECK constraints
         */
        if (tbinfo->ncheck > 0)
        {
            ConstraintInfo *constrs;
            int         numConstrs;

            if (g_verbose)
                write_msg(NULL, "finding check constraints for table \"%s\"\n",
                          tbinfo->dobj.name);

            resetPQExpBuffer(q);
            if (fout->remoteVersion >= 90200)
            {
                /*
                 * convalidated is new in 9.2 (actually, it is there in 9.1,
                 * but it wasn't ever false for check constraints until 9.2).
                 */
                appendPQExpBuffer(q, "SELECT tableoid, oid, conname, "
                           "pg_catalog.pg_get_constraintdef(oid) AS consrc, "
                                  "conislocal, convalidated "
                                  "FROM pg_catalog.pg_constraint "
                                  "WHERE conrelid = '%u'::pg_catalog.oid "
                                  "   AND contype = 'c' "
                                  "ORDER BY conname",
                                  tbinfo->dobj.catId.oid);
            }
            else if (fout->remoteVersion >= 80400)
            {
                /* conislocal is new in 8.4 */
                appendPQExpBuffer(q, "SELECT tableoid, oid, conname, "
                           "pg_catalog.pg_get_constraintdef(oid) AS consrc, "
                                  "conislocal, true AS convalidated "
                                  "FROM pg_catalog.pg_constraint "
                                  "WHERE conrelid = '%u'::pg_catalog.oid "
                                  "   AND contype = 'c' "
                                  "ORDER BY conname",
                                  tbinfo->dobj.catId.oid);
            }
            else if (fout->remoteVersion >= 70400)
            {
                appendPQExpBuffer(q, "SELECT tableoid, oid, conname, "
                           "pg_catalog.pg_get_constraintdef(oid) AS consrc, "
                                  "true AS conislocal, true AS convalidated "
                                  "FROM pg_catalog.pg_constraint "
                                  "WHERE conrelid = '%u'::pg_catalog.oid "
                                  "   AND contype = 'c' "
                                  "ORDER BY conname",
                                  tbinfo->dobj.catId.oid);
            }
            else if (fout->remoteVersion >= 70300)
            {
                /* no pg_get_constraintdef, must use consrc */
                appendPQExpBuffer(q, "SELECT tableoid, oid, conname, "
                                  "'CHECK (' || consrc || ')' AS consrc, "
                                  "true AS conislocal, true AS convalidated "
                                  "FROM pg_catalog.pg_constraint "
                                  "WHERE conrelid = '%u'::pg_catalog.oid "
                                  "   AND contype = 'c' "
                                  "ORDER BY conname",
                                  tbinfo->dobj.catId.oid);
            }
            else if (fout->remoteVersion >= 70200)
            {
                /* 7.2 did not have OIDs in pg_relcheck */
                appendPQExpBuffer(q, "SELECT tableoid, 0 AS oid, "
                                  "rcname AS conname, "
                                  "'CHECK (' || rcsrc || ')' AS consrc, "
                                  "true AS conislocal, true AS convalidated "
                                  "FROM pg_relcheck "
                                  "WHERE rcrelid = '%u'::oid "
                                  "ORDER BY rcname",
                                  tbinfo->dobj.catId.oid);
            }
            else if (fout->remoteVersion >= 70100)
            {
                appendPQExpBuffer(q, "SELECT tableoid, oid, "
                                  "rcname AS conname, "
                                  "'CHECK (' || rcsrc || ')' AS consrc, "
                                  "true AS conislocal, true AS convalidated "
                                  "FROM pg_relcheck "
                                  "WHERE rcrelid = '%u'::oid "
                                  "ORDER BY rcname",
                                  tbinfo->dobj.catId.oid);
            }
            else
            {
                /* no tableoid in 7.0 */
                appendPQExpBuffer(q, "SELECT "
                                  "(SELECT oid FROM pg_class WHERE relname = 'pg_relcheck') AS tableoid, "
                                  "oid, rcname AS conname, "
                                  "'CHECK (' || rcsrc || ')' AS consrc, "
                                  "true AS conislocal, true AS convalidated "
                                  "FROM pg_relcheck "
                                  "WHERE rcrelid = '%u'::oid "
                                  "ORDER BY rcname",
                                  tbinfo->dobj.catId.oid);
            }
            res = ExecuteSqlQuery(fout, q->data, PGRES_TUPLES_OK);

            numConstrs = PQntuples(res);
            if (numConstrs != tbinfo->ncheck)
            {
                write_msg(NULL, ngettext("expected %d check constraint on table \"%s\" but found %d\n",
                                         "expected %d check constraints on table \"%s\" but found %d\n",
                                         tbinfo->ncheck),
                          tbinfo->ncheck, tbinfo->dobj.name, numConstrs);
                write_msg(NULL, "(The system catalogs might be corrupted.)\n");
                exit_nicely(1);
            }

            constrs = (ConstraintInfo *) pg_malloc(numConstrs * sizeof(ConstraintInfo));
            tbinfo->checkexprs = constrs;

            for (j = 0; j < numConstrs; j++)
            {
                bool        validated = PQgetvalue(res, j, 5)[0] == 't';

                constrs[j].dobj.objType = DO_CONSTRAINT;
                constrs[j].dobj.catId.tableoid = atooid(PQgetvalue(res, j, 0));
                constrs[j].dobj.catId.oid = atooid(PQgetvalue(res, j, 1));
                AssignDumpId(&constrs[j].dobj);
                constrs[j].dobj.name = pg_strdup(PQgetvalue(res, j, 2));
                constrs[j].dobj.namespace = tbinfo->dobj.namespace;
                constrs[j].contable = tbinfo;
                constrs[j].condomain = NULL;
                constrs[j].contype = 'c';
                constrs[j].condef = pg_strdup(PQgetvalue(res, j, 3));
                constrs[j].confrelid = InvalidOid;
                constrs[j].conindex = 0;
                constrs[j].condeferrable = false;
                constrs[j].condeferred = false;
                constrs[j].conislocal = (PQgetvalue(res, j, 4)[0] == 't');

                /*
                 * An unvalidated constraint needs to be dumped separately, so
                 * that potentially-violating existing data is loaded before
                 * the constraint.
                 */
                constrs[j].separate = !validated;

                constrs[j].dobj.dump = tbinfo->dobj.dump;

                /*
                 * Mark the constraint as needing to appear before the table
                 * --- this is so that any other dependencies of the
                 * constraint will be emitted before we try to create the
                 * table.  If the constraint is to be dumped separately, it
                 * will be dumped after data is loaded anyway, so don't do it.
                 * (There's an automatic dependency in the opposite direction
                 * anyway, so don't need to add one manually here.)
                 */
                if (!constrs[j].separate)
                    addObjectDependency(&tbinfo->dobj,
                                        constrs[j].dobj.dumpId);

                /*
                 * If the constraint is inherited, this will be detected later
                 * (in pre-8.4 databases).  We also detect later if the
                 * constraint must be split out from the table definition.
                 */
            }
            PQclear(res);
        }
    }

    destroyPQExpBuffer(q);
}

/*
 * Test whether a column should be printed as part of table's CREATE TABLE.
 * Column number is zero-based.
 *
 * Normally this is always true, but it's false for dropped columns, as well
 * as those that were inherited without any local definition.  (If we print
 * such a column it will mistakenly get pg_attribute.attislocal set to true.)
 * However, in binary_upgrade mode, we must print all such columns anyway and
 * fix the attislocal/attisdropped state later, so as to keep control of the
 * physical column order.
 *
 * This function exists because there are scattered nonobvious places that
 * must be kept in sync with this decision.
 */
bool
shouldPrintColumn(TableInfo *tbinfo, int colno)
{
    if (binary_upgrade)
        return true;
    return (tbinfo->attislocal[colno] && !tbinfo->attisdropped[colno]);
}


/*
 * getTSParsers:
 *    read all text search parsers in the system catalogs and return them
 *    in the TSParserInfo* structure
 *
 *  numTSParsers is set to the number of parsers read in
 */
TSParserInfo *
getTSParsers(Archive *fout, int *numTSParsers)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    TSParserInfo *prsinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_prsname;
    int         i_prsnamespace;
    int         i_prsstart;
    int         i_prstoken;
    int         i_prsend;
    int         i_prsheadline;
    int         i_prslextype;

    /* Before 8.3, there is no built-in text search support */
    if (fout->remoteVersion < 80300)
    {
        *numTSParsers = 0;
        return NULL;
    }

    query = createPQExpBuffer();

    /*
     * find all text search objects, including builtin ones; we filter out
     * system-defined objects at dump-out time.
     */

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    appendPQExpBuffer(query, "SELECT tableoid, oid, prsname, prsnamespace, "
                      "prsstart::oid, prstoken::oid, "
                      "prsend::oid, prsheadline::oid, prslextype::oid "
                      "FROM pg_ts_parser");

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);
    *numTSParsers = ntups;

    prsinfo = (TSParserInfo *) pg_malloc(ntups * sizeof(TSParserInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_prsname = PQfnumber(res, "prsname");
    i_prsnamespace = PQfnumber(res, "prsnamespace");
    i_prsstart = PQfnumber(res, "prsstart");
    i_prstoken = PQfnumber(res, "prstoken");
    i_prsend = PQfnumber(res, "prsend");
    i_prsheadline = PQfnumber(res, "prsheadline");
    i_prslextype = PQfnumber(res, "prslextype");

    for (i = 0; i < ntups; i++)
    {
        prsinfo[i].dobj.objType = DO_TSPARSER;
        prsinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        prsinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&prsinfo[i].dobj);
        prsinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_prsname));
        prsinfo[i].dobj.namespace =
            findNamespace(fout,
                          atooid(PQgetvalue(res, i, i_prsnamespace)),
                          prsinfo[i].dobj.catId.oid);
        prsinfo[i].prsstart = atooid(PQgetvalue(res, i, i_prsstart));
        prsinfo[i].prstoken = atooid(PQgetvalue(res, i, i_prstoken));
        prsinfo[i].prsend = atooid(PQgetvalue(res, i, i_prsend));
        prsinfo[i].prsheadline = atooid(PQgetvalue(res, i, i_prsheadline));
        prsinfo[i].prslextype = atooid(PQgetvalue(res, i, i_prslextype));

        /* Decide whether we want to dump it */
        selectDumpableObject(&(prsinfo[i].dobj));
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return prsinfo;
}

/*
 * getTSDictionaries:
 *    read all text search dictionaries in the system catalogs and return them
 *    in the TSDictInfo* structure
 *
 *  numTSDicts is set to the number of dictionaries read in
 */
TSDictInfo *
getTSDictionaries(Archive *fout, int *numTSDicts)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    TSDictInfo *dictinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_dictname;
    int         i_dictnamespace;
    int         i_rolname;
    int         i_dicttemplate;
    int         i_dictinitoption;

    /* Before 8.3, there is no built-in text search support */
    if (fout->remoteVersion < 80300)
    {
        *numTSDicts = 0;
        return NULL;
    }

    query = createPQExpBuffer();

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    appendPQExpBuffer(query, "SELECT tableoid, oid, dictname, "
                      "dictnamespace, (%s dictowner) AS rolname, "
                      "dicttemplate, dictinitoption "
                      "FROM pg_ts_dict",
                      username_subquery);

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);
    *numTSDicts = ntups;

    dictinfo = (TSDictInfo *) pg_malloc(ntups * sizeof(TSDictInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_dictname = PQfnumber(res, "dictname");
    i_dictnamespace = PQfnumber(res, "dictnamespace");
    i_rolname = PQfnumber(res, "rolname");
    i_dictinitoption = PQfnumber(res, "dictinitoption");
    i_dicttemplate = PQfnumber(res, "dicttemplate");

    for (i = 0; i < ntups; i++)
    {
        dictinfo[i].dobj.objType = DO_TSDICT;
        dictinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        dictinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&dictinfo[i].dobj);
        dictinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_dictname));
        dictinfo[i].dobj.namespace =
            findNamespace(fout,
                          atooid(PQgetvalue(res, i, i_dictnamespace)),
                          dictinfo[i].dobj.catId.oid);
        dictinfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
        dictinfo[i].dicttemplate = atooid(PQgetvalue(res, i, i_dicttemplate));
        if (PQgetisnull(res, i, i_dictinitoption))
            dictinfo[i].dictinitoption = NULL;
        else
            dictinfo[i].dictinitoption = pg_strdup(PQgetvalue(res, i, i_dictinitoption));

        /* Decide whether we want to dump it */
        selectDumpableObject(&(dictinfo[i].dobj));
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return dictinfo;
}

/*
 * getTSTemplates:
 *    read all text search templates in the system catalogs and return them
 *    in the TSTemplateInfo* structure
 *
 *  numTSTemplates is set to the number of templates read in
 */
TSTemplateInfo *
getTSTemplates(Archive *fout, int *numTSTemplates)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    TSTemplateInfo *tmplinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_tmplname;
    int         i_tmplnamespace;
    int         i_tmplinit;
    int         i_tmpllexize;

    /* Before 8.3, there is no built-in text search support */
    if (fout->remoteVersion < 80300)
    {
        *numTSTemplates = 0;
        return NULL;
    }

    query = createPQExpBuffer();

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    appendPQExpBuffer(query, "SELECT tableoid, oid, tmplname, "
                      "tmplnamespace, tmplinit::oid, tmpllexize::oid "
                      "FROM pg_ts_template");

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);
    *numTSTemplates = ntups;

    tmplinfo = (TSTemplateInfo *) pg_malloc(ntups * sizeof(TSTemplateInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_tmplname = PQfnumber(res, "tmplname");
    i_tmplnamespace = PQfnumber(res, "tmplnamespace");
    i_tmplinit = PQfnumber(res, "tmplinit");
    i_tmpllexize = PQfnumber(res, "tmpllexize");

    for (i = 0; i < ntups; i++)
    {
        tmplinfo[i].dobj.objType = DO_TSTEMPLATE;
        tmplinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        tmplinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&tmplinfo[i].dobj);
        tmplinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_tmplname));
        tmplinfo[i].dobj.namespace =
            findNamespace(fout,
                          atooid(PQgetvalue(res, i, i_tmplnamespace)),
                          tmplinfo[i].dobj.catId.oid);
        tmplinfo[i].tmplinit = atooid(PQgetvalue(res, i, i_tmplinit));
        tmplinfo[i].tmpllexize = atooid(PQgetvalue(res, i, i_tmpllexize));

        /* Decide whether we want to dump it */
        selectDumpableObject(&(tmplinfo[i].dobj));
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return tmplinfo;
}

/*
 * getTSConfigurations:
 *    read all text search configurations in the system catalogs and return
 *    them in the TSConfigInfo* structure
 *
 *  numTSConfigs is set to the number of configurations read in
 */
TSConfigInfo *
getTSConfigurations(Archive *fout, int *numTSConfigs)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    TSConfigInfo *cfginfo;
    int         i_tableoid;
    int         i_oid;
    int         i_cfgname;
    int         i_cfgnamespace;
    int         i_rolname;
    int         i_cfgparser;

    /* Before 8.3, there is no built-in text search support */
    if (fout->remoteVersion < 80300)
    {
        *numTSConfigs = 0;
        return NULL;
    }

    query = createPQExpBuffer();

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    appendPQExpBuffer(query, "SELECT tableoid, oid, cfgname, "
                      "cfgnamespace, (%s cfgowner) AS rolname, cfgparser "
                      "FROM pg_ts_config",
                      username_subquery);

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);
    *numTSConfigs = ntups;

    cfginfo = (TSConfigInfo *) pg_malloc(ntups * sizeof(TSConfigInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_cfgname = PQfnumber(res, "cfgname");
    i_cfgnamespace = PQfnumber(res, "cfgnamespace");
    i_rolname = PQfnumber(res, "rolname");
    i_cfgparser = PQfnumber(res, "cfgparser");

    for (i = 0; i < ntups; i++)
    {
        cfginfo[i].dobj.objType = DO_TSCONFIG;
        cfginfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        cfginfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&cfginfo[i].dobj);
        cfginfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_cfgname));
        cfginfo[i].dobj.namespace =
            findNamespace(fout,
                          atooid(PQgetvalue(res, i, i_cfgnamespace)),
                          cfginfo[i].dobj.catId.oid);
        cfginfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
        cfginfo[i].cfgparser = atooid(PQgetvalue(res, i, i_cfgparser));

        /* Decide whether we want to dump it */
        selectDumpableObject(&(cfginfo[i].dobj));
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return cfginfo;
}

/*
 * getForeignDataWrappers:
 *    read all foreign-data wrappers in the system catalogs and return
 *    them in the FdwInfo* structure
 *
 *  numForeignDataWrappers is set to the number of fdws read in
 */
FdwInfo *
getForeignDataWrappers(Archive *fout, int *numForeignDataWrappers)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    FdwInfo    *fdwinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_fdwname;
    int         i_rolname;
    int         i_fdwhandler;
    int         i_fdwvalidator;
    int         i_fdwacl;
    int         i_fdwoptions;

    /* Before 8.4, there are no foreign-data wrappers */
    if (fout->remoteVersion < 80400)
    {
        *numForeignDataWrappers = 0;
        return NULL;
    }

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    if (fout->remoteVersion >= 90100)
    {
        appendPQExpBuffer(query, "SELECT tableoid, oid, fdwname, "
                          "(%s fdwowner) AS rolname, "
                          "fdwhandler::pg_catalog.regproc, "
                          "fdwvalidator::pg_catalog.regproc, fdwacl, "
                          "array_to_string(ARRAY("
                          "SELECT quote_ident(option_name) || ' ' || "
                          "quote_literal(option_value) "
                          "FROM pg_options_to_table(fdwoptions) "
                          "ORDER BY option_name"
                          "), E',\n    ') AS fdwoptions "
                          "FROM pg_foreign_data_wrapper",
                          username_subquery);
    }
    else
    {
        appendPQExpBuffer(query, "SELECT tableoid, oid, fdwname, "
                          "(%s fdwowner) AS rolname, "
                          "'-' AS fdwhandler, "
                          "fdwvalidator::pg_catalog.regproc, fdwacl, "
                          "array_to_string(ARRAY("
                          "SELECT quote_ident(option_name) || ' ' || "
                          "quote_literal(option_value) "
                          "FROM pg_options_to_table(fdwoptions) "
                          "ORDER BY option_name"
                          "), E',\n    ') AS fdwoptions "
                          "FROM pg_foreign_data_wrapper",
                          username_subquery);
    }

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);
    *numForeignDataWrappers = ntups;

    fdwinfo = (FdwInfo *) pg_malloc(ntups * sizeof(FdwInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_fdwname = PQfnumber(res, "fdwname");
    i_rolname = PQfnumber(res, "rolname");
    i_fdwhandler = PQfnumber(res, "fdwhandler");
    i_fdwvalidator = PQfnumber(res, "fdwvalidator");
    i_fdwacl = PQfnumber(res, "fdwacl");
    i_fdwoptions = PQfnumber(res, "fdwoptions");

    for (i = 0; i < ntups; i++)
    {
        fdwinfo[i].dobj.objType = DO_FDW;
        fdwinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        fdwinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&fdwinfo[i].dobj);
        fdwinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_fdwname));
        fdwinfo[i].dobj.namespace = NULL;
        fdwinfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
        fdwinfo[i].fdwhandler = pg_strdup(PQgetvalue(res, i, i_fdwhandler));
        fdwinfo[i].fdwvalidator = pg_strdup(PQgetvalue(res, i, i_fdwvalidator));
        fdwinfo[i].fdwoptions = pg_strdup(PQgetvalue(res, i, i_fdwoptions));
        fdwinfo[i].fdwacl = pg_strdup(PQgetvalue(res, i, i_fdwacl));

        /* Decide whether we want to dump it */
        selectDumpableObject(&(fdwinfo[i].dobj));
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return fdwinfo;
}

/*
 * getForeignServers:
 *    read all foreign servers in the system catalogs and return
 *    them in the ForeignServerInfo * structure
 *
 *  numForeignServers is set to the number of servers read in
 */
ForeignServerInfo *
getForeignServers(Archive *fout, int *numForeignServers)
{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    ForeignServerInfo *srvinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_srvname;
    int         i_rolname;
    int         i_srvfdw;
    int         i_srvtype;
    int         i_srvversion;
    int         i_srvacl;
    int         i_srvoptions;

    /* Before 8.4, there are no foreign servers */
    if (fout->remoteVersion < 80400)
    {
        *numForeignServers = 0;
        return NULL;
    }

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    appendPQExpBuffer(query, "SELECT tableoid, oid, srvname, "
                      "(%s srvowner) AS rolname, "
                      "srvfdw, srvtype, srvversion, srvacl,"
                      "array_to_string(ARRAY("
                      "SELECT quote_ident(option_name) || ' ' || "
                      "quote_literal(option_value) "
                      "FROM pg_options_to_table(srvoptions) "
                      "ORDER BY option_name"
                      "), E',\n    ') AS srvoptions "
                      "FROM pg_foreign_server",
                      username_subquery);

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);
    *numForeignServers = ntups;

    srvinfo = (ForeignServerInfo *) pg_malloc(ntups * sizeof(ForeignServerInfo));

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_srvname = PQfnumber(res, "srvname");
    i_rolname = PQfnumber(res, "rolname");
    i_srvfdw = PQfnumber(res, "srvfdw");
    i_srvtype = PQfnumber(res, "srvtype");
    i_srvversion = PQfnumber(res, "srvversion");
    i_srvacl = PQfnumber(res, "srvacl");
    i_srvoptions = PQfnumber(res, "srvoptions");

    for (i = 0; i < ntups; i++)
    {
        srvinfo[i].dobj.objType = DO_FOREIGN_SERVER;
        srvinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        srvinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&srvinfo[i].dobj);
        srvinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_srvname));
        srvinfo[i].dobj.namespace = NULL;
        srvinfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
        srvinfo[i].srvfdw = atooid(PQgetvalue(res, i, i_srvfdw));
        srvinfo[i].srvtype = pg_strdup(PQgetvalue(res, i, i_srvtype));
        srvinfo[i].srvversion = pg_strdup(PQgetvalue(res, i, i_srvversion));
        srvinfo[i].srvoptions = pg_strdup(PQgetvalue(res, i, i_srvoptions));
        srvinfo[i].srvacl = pg_strdup(PQgetvalue(res, i, i_srvacl));

        /* Decide whether we want to dump it */
        selectDumpableObject(&(srvinfo[i].dobj));
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return srvinfo;
}

/*
 * getDefaultACLs:
 *    read all default ACL information in the system catalogs and return
 *    them in the DefaultACLInfo structure
 *
 *  numDefaultACLs is set to the number of ACLs read in
 */
DefaultACLInfo *
getDefaultACLs(Archive *fout, int *numDefaultACLs)
{
    DefaultACLInfo *daclinfo;
    PQExpBuffer query;
    PGresult   *res;
    int         i_oid;
    int         i_tableoid;
    int         i_defaclrole;
    int         i_defaclnamespace;
    int         i_defaclobjtype;
    int         i_defaclacl;
    int         i,
                ntups;

    if (fout->remoteVersion < 90000)
    {
        *numDefaultACLs = 0;
        return NULL;
    }

    query = createPQExpBuffer();

    /* Make sure we are in proper schema */
    selectSourceSchema(fout, "pg_catalog");

    appendPQExpBuffer(query, "SELECT oid, tableoid, "
                      "(%s defaclrole) AS defaclrole, "
                      "defaclnamespace, "
                      "defaclobjtype, "
                      "defaclacl "
                      "FROM pg_default_acl",
                      username_subquery);

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    ntups = PQntuples(res);
    *numDefaultACLs = ntups;

    daclinfo = (DefaultACLInfo *) pg_malloc(ntups * sizeof(DefaultACLInfo));

    i_oid = PQfnumber(res, "oid");
    i_tableoid = PQfnumber(res, "tableoid");
    i_defaclrole = PQfnumber(res, "defaclrole");
    i_defaclnamespace = PQfnumber(res, "defaclnamespace");
    i_defaclobjtype = PQfnumber(res, "defaclobjtype");
    i_defaclacl = PQfnumber(res, "defaclacl");

    for (i = 0; i < ntups; i++)
    {
        Oid         nspid = atooid(PQgetvalue(res, i, i_defaclnamespace));

        daclinfo[i].dobj.objType = DO_DEFAULT_ACL;
        daclinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        daclinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&daclinfo[i].dobj);
        /* cheesy ... is it worth coming up with a better object name? */
        daclinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_defaclobjtype));

        if (nspid != InvalidOid)
            daclinfo[i].dobj.namespace = findNamespace(fout, nspid,
                                                 daclinfo[i].dobj.catId.oid);
        else
            daclinfo[i].dobj.namespace = NULL;

        daclinfo[i].defaclrole = pg_strdup(PQgetvalue(res, i, i_defaclrole));
        daclinfo[i].defaclobjtype = *(PQgetvalue(res, i, i_defaclobjtype));
        daclinfo[i].defaclacl = pg_strdup(PQgetvalue(res, i, i_defaclacl));

        /* Decide whether we want to dump it */
        selectDumpableDefaultACL(&(daclinfo[i]));
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return daclinfo;
}

/*
 * dumpComment --
 *
 * This routine is used to dump any comments associated with the
 * object handed to this routine. The routine takes a constant character
 * string for the target part of the comment-creation command, plus
 * the namespace and owner of the object (for labeling the ArchiveEntry),
 * plus catalog ID and subid which are the lookup key for pg_description,
 * plus the dump ID for the object (for setting a dependency).
 * If a matching pg_description entry is found, it is dumped.
 *
 * Note: although this routine takes a dumpId for dependency purposes,
 * that purpose is just to mark the dependency in the emitted dump file
 * for possible future use by pg_restore.  We do NOT use it for determining
 * ordering of the comment in the dump file, because this routine is called
 * after dependency sorting occurs.  This routine should be called just after
 * calling ArchiveEntry() for the specified object.
 */
static void
dumpComment(Archive *fout, const char *target,
            const char *namespace, const char *owner,
            CatalogId catalogId, int subid, DumpId dumpId)
{
    CommentItem *comments;
    int         ncomments;

    /* Comments are schema not data ... except blob comments are data */
    if (strncmp(target, "LARGE OBJECT ", 13) != 0)
    {
        if (dataOnly)
            return;
    }
    else
    {
        if (schemaOnly)
            return;
    }

    /* Search for comments associated with catalogId, using table */
    ncomments = findComments(fout, catalogId.tableoid, catalogId.oid,
                             &comments);

    /* Is there one matching the subid? */
    while (ncomments > 0)
    {
        if (comments->objsubid == subid)
            break;
        comments++;
        ncomments--;
    }

    /* If a comment exists, build COMMENT ON statement */
    if (ncomments > 0)
    {
        PQExpBuffer query = createPQExpBuffer();

        appendPQExpBuffer(query, "COMMENT ON %s IS ", target);
        appendStringLiteralAH(query, comments->descr, fout);
        appendPQExpBuffer(query, ";\n");

        /*
         * We mark comments as SECTION_NONE because they really belong in the
         * same section as their parent, whether that is pre-data or
         * post-data.
         */
        ArchiveEntry(fout, nilCatalogId, createDumpId(),
                     target, namespace, NULL, owner,
                     false, "COMMENT", SECTION_NONE,
                     query->data, "", NULL,
                     &(dumpId), 1,
                     NULL, NULL);

        destroyPQExpBuffer(query);
    }
}

/*
 * dumpTableComment --
 *
 * As above, but dump comments for both the specified table (or view)
 * and its columns.
 */
static void
dumpTableComment(Archive *fout, TableInfo *tbinfo,
                 const char *reltypename)
{
    CommentItem *comments;
    int         ncomments;
    PQExpBuffer query;
    PQExpBuffer target;

    /* Comments are SCHEMA not data */
    if (dataOnly)
        return;

    /* Search for comments associated with relation, using table */
    ncomments = findComments(fout,
                             tbinfo->dobj.catId.tableoid,
                             tbinfo->dobj.catId.oid,
                             &comments);

    /* If comments exist, build COMMENT ON statements */
    if (ncomments <= 0)
        return;

    query = createPQExpBuffer();
    target = createPQExpBuffer();

    while (ncomments > 0)
    {
        const char *descr = comments->descr;
        int         objsubid = comments->objsubid;

        if (objsubid == 0)
        {
            resetPQExpBuffer(target);
            appendPQExpBuffer(target, "%s %s", reltypename,
                              fmtId(tbinfo->dobj.name));

            resetPQExpBuffer(query);
            appendPQExpBuffer(query, "COMMENT ON %s IS ", target->data);
            appendStringLiteralAH(query, descr, fout);
            appendPQExpBuffer(query, ";\n");

            ArchiveEntry(fout, nilCatalogId, createDumpId(),
                         target->data,
                         tbinfo->dobj.namespace->dobj.name,
                         NULL, tbinfo->rolname,
                         false, "COMMENT", SECTION_NONE,
                         query->data, "", NULL,
                         &(tbinfo->dobj.dumpId), 1,
                         NULL, NULL);
        }
        else if (objsubid > 0 && objsubid <= tbinfo->numatts)
        {
            resetPQExpBuffer(target);
            appendPQExpBuffer(target, "COLUMN %s.",
                              fmtId(tbinfo->dobj.name));
            appendPQExpBuffer(target, "%s",
                              fmtId(tbinfo->attnames[objsubid - 1]));

            resetPQExpBuffer(query);
            appendPQExpBuffer(query, "COMMENT ON %s IS ", target->data);
            appendStringLiteralAH(query, descr, fout);
            appendPQExpBuffer(query, ";\n");

            ArchiveEntry(fout, nilCatalogId, createDumpId(),
                         target->data,
                         tbinfo->dobj.namespace->dobj.name,
                         NULL, tbinfo->rolname,
                         false, "COMMENT", SECTION_NONE,
                         query->data, "", NULL,
                         &(tbinfo->dobj.dumpId), 1,
                         NULL, NULL);
        }

        comments++;
        ncomments--;
    }

    destroyPQExpBuffer(query);
    destroyPQExpBuffer(target);
}

/*
 * findComments --
 *
 * Find the comment(s), if any, associated with the given object.  All the
 * objsubid values associated with the given classoid/objoid are found with
 * one search.
 */
static int
findComments(Archive *fout, Oid classoid, Oid objoid,
             CommentItem **items)
{
    /* static storage for table of comments */
    static CommentItem *comments = NULL;
    static int  ncomments = -1;

    CommentItem *middle = NULL;
    CommentItem *low;
    CommentItem *high;
    int         nmatch;

    /* Get comments if we didn't already */
    if (ncomments < 0)
        ncomments = collectComments(fout, &comments);

    /*
     * Pre-7.2, pg_description does not contain classoid, so collectComments
     * just stores a zero.  If there's a collision on object OID, well, you
     * get duplicate comments.
     */
    if (fout->remoteVersion < 70200)
        classoid = 0;

    /*
     * Do binary search to find some item matching the object.
     */
    low = &comments[0];
    high = &comments[ncomments - 1];
    while (low <= high)
    {
        middle = low + (high - low) / 2;

        if (classoid < middle->classoid)
            high = middle - 1;
        else if (classoid > middle->classoid)
            low = middle + 1;
        else if (objoid < middle->objoid)
            high = middle - 1;
        else if (objoid > middle->objoid)
            low = middle + 1;
        else
            break;              /* found a match */
    }

    if (low > high)             /* no matches */
    {
        *items = NULL;
        return 0;
    }

    /*
     * Now determine how many items match the object.  The search loop
     * invariant still holds: only items between low and high inclusive could
     * match.
     */
    nmatch = 1;
    while (middle > low)
    {
        if (classoid != middle[-1].classoid ||
            objoid != middle[-1].objoid)
            break;
        middle--;
        nmatch++;
    }

    *items = middle;

    middle += nmatch;
    while (middle <= high)
    {
        if (classoid != middle->classoid ||
            objoid != middle->objoid)
            break;
        middle++;
        nmatch++;
    }

    return nmatch;
}

/*
 * collectComments --
 *
 * Construct a table of all comments available for database objects.
 * We used to do per-object queries for the comments, but it's much faster
 * to pull them all over at once, and on most databases the memory cost
 * isn't high.
 *
 * The table is sorted by classoid/objid/objsubid for speed in lookup.
 */
static int
collectComments(Archive *fout, CommentItem **items)
{
    PGresult   *res;
    PQExpBuffer query;
    int         i_description;
    int         i_classoid;
    int         i_objoid;
    int         i_objsubid;
    int         ntups;
    int         i;
    CommentItem *comments;

    /*
     * Note we do NOT change source schema here; preserve the caller's
     * setting, instead.
     */

    query = createPQExpBuffer();

    if (fout->remoteVersion >= 70300)
    {
        appendPQExpBuffer(query, "SELECT description, classoid, objoid, objsubid "
                          "FROM pg_catalog.pg_description "
                          "ORDER BY classoid, objoid, objsubid");
    }
    else if (fout->remoteVersion >= 70200)
    {
        appendPQExpBuffer(query, "SELECT description, classoid, objoid, objsubid "
                          "FROM pg_description "
                          "ORDER BY classoid, objoid, objsubid");
    }
    else
    {
        /* Note: this will fail to find attribute comments in pre-7.2... */
        appendPQExpBuffer(query, "SELECT description, 0 AS classoid, objoid, 0 AS objsubid "
                          "FROM pg_description "
                          "ORDER BY objoid");
    }

    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);

    /* Construct lookup table containing OIDs in numeric form */

    i_description = PQfnumber(res, "description");
    i_classoid = PQfnumber(res, "classoid");
    i_objoid = PQfnumber(res, "objoid");
    i_objsubid = PQfnumber(res, "objsubid");

    ntups = PQntuples(res);

    comments = (CommentItem *) pg_malloc(ntups * sizeof(CommentItem));

    for (i = 0; i < ntups; i++)
    {
        comments[i].descr = PQgetvalue(res, i, i_description);
        comments[i].classoid = atooid(PQgetvalue(res, i, i_classoid));
        comments[i].objoid = atooid(PQgetvalue(res, i, i_objoid));
        comments[i].objsubid = atoi(PQgetvalue(res, i, i_objsubid));
    }

    /* Do NOT free the PGresult since we are keeping pointers into it */
    destroyPQExpBuffer(query);

    *items = comments;
    return ntups;
}

/*
 * dumpDumpableObject
 *
 * This routine and its subsidiaries are responsible for creating
 * ArchiveEntries (TOC objects) for each object to be dumped.
 */
static void
dumpDumpableObject(Archive *fout, DumpableObject *dobj)
{
    switch (dobj->objType)
    {
        case DO_NAMESPACE:
            dumpNamespace(fout, (NamespaceInfo *) dobj);
            break;
        case DO_EXTENSION:
            dumpExtension(fout, (ExtensionInfo *) dobj);
            break;
        case DO_TYPE:
            dumpType(fout, (TypeInfo *) dobj);
            break;
        case DO_SHELL_TYPE:
            dumpShellType(fout, (ShellTypeInfo *) dobj);
            break;
        case DO_FUNC:
            dumpFunc(fout, (FuncInfo *) dobj);
            break;
        case DO_AGG:
            dumpAgg(fout, (AggInfo *) dobj);
            break;
        case DO_OPERATOR:
            dumpOpr(fout, (OprInfo *) dobj);
            break;
        case DO_OPCLASS:
            dumpOpclass(fout, (OpclassInfo *) dobj);
            break