pg_dump.h File Reference

#include "pg_backup.h"
#include "catalog/pg_publication_d.h"

Include dependency graph for pg_dump.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	_dumpableObject
struct	_dumpableAcl
struct	_dumpableObjectWithAcl
struct	_namespaceInfo
struct	_extensionInfo
struct	_typeInfo
struct	_shellTypeInfo
struct	_funcInfo
struct	_aggInfo
struct	_oprInfo
struct	_accessMethodInfo
struct	_opclassInfo
struct	_opfamilyInfo
struct	_collInfo
struct	_convInfo
struct	_tableInfo
struct	_tableAttachInfo
struct	_attrDefInfo
struct	_tableDataInfo
struct	_indxInfo
struct	_indexAttachInfo
struct	_relStatsInfo
struct	_statsExtInfo
struct	_ruleInfo
struct	_triggerInfo
struct	_evttriggerInfo
struct	_constraintInfo
struct	_procLangInfo
struct	_castInfo
struct	_transformInfo
struct	_inhInfo
struct	_prsInfo
struct	_dictInfo
struct	_tmplInfo
struct	_cfgInfo
struct	_fdwInfo
struct	_foreignServerInfo
struct	_defaultACLInfo
struct	_loInfo
struct	_policyInfo
struct	_PublicationInfo
struct	_PublicationRelInfo
struct	_PublicationSchemaInfo
struct	_SubscriptionInfo
struct	_SubRelInfo

Macros
#define	oidcmp(x, y)   ( ((x) < (y) ? -1 : ((x) > (y)) ? 1 : 0) )
#define	NUM_DUMPABLE_OBJECT_TYPES   (DO_SUBSCRIPTION_REL + 1)
#define	DUMP_COMPONENT_NONE   (0)
#define	DUMP_COMPONENT_DEFINITION   (1 << 0)
#define	DUMP_COMPONENT_DATA   (1 << 1)
#define	DUMP_COMPONENT_COMMENT   (1 << 2)
#define	DUMP_COMPONENT_SECLABEL   (1 << 3)
#define	DUMP_COMPONENT_ACL   (1 << 4)
#define	DUMP_COMPONENT_POLICY   (1 << 5)
#define	DUMP_COMPONENT_USERMAP   (1 << 6)
#define	DUMP_COMPONENT_STATISTICS   (1 << 7)
#define	DUMP_COMPONENT_ALL   (0xFFFF)
#define	DUMP_COMPONENTS_REQUIRING_LOCK

Typedefs
typedef uint32	DumpComponents
typedef struct _dumpableObject	DumpableObject
typedef struct _dumpableAcl	DumpableAcl
typedef struct _dumpableObjectWithAcl	DumpableObjectWithAcl
typedef struct _namespaceInfo	NamespaceInfo
typedef struct _extensionInfo	ExtensionInfo
typedef struct _typeInfo	TypeInfo
typedef struct _shellTypeInfo	ShellTypeInfo
typedef struct _funcInfo	FuncInfo
typedef struct _aggInfo	AggInfo
typedef struct _oprInfo	OprInfo
typedef struct _accessMethodInfo	AccessMethodInfo
typedef struct _opclassInfo	OpclassInfo
typedef struct _opfamilyInfo	OpfamilyInfo
typedef struct _collInfo	CollInfo
typedef struct _convInfo	ConvInfo
typedef struct _tableInfo	TableInfo
typedef struct _tableAttachInfo	TableAttachInfo
typedef struct _attrDefInfo	AttrDefInfo
typedef struct _tableDataInfo	TableDataInfo
typedef struct _indxInfo	IndxInfo
typedef struct _indexAttachInfo	IndexAttachInfo
typedef struct _relStatsInfo	RelStatsInfo
typedef struct _statsExtInfo	StatsExtInfo
typedef struct _ruleInfo	RuleInfo
typedef struct _triggerInfo	TriggerInfo
typedef struct _evttriggerInfo	EventTriggerInfo
typedef struct _constraintInfo	ConstraintInfo
typedef struct _procLangInfo	ProcLangInfo
typedef struct _castInfo	CastInfo
typedef struct _transformInfo	TransformInfo
typedef struct _inhInfo	InhInfo
typedef struct _prsInfo	TSParserInfo
typedef struct _dictInfo	TSDictInfo
typedef struct _tmplInfo	TSTemplateInfo
typedef struct _cfgInfo	TSConfigInfo
typedef struct _fdwInfo	FdwInfo
typedef struct _foreignServerInfo	ForeignServerInfo
typedef struct _defaultACLInfo	DefaultACLInfo
typedef struct _loInfo	LoInfo
typedef struct _policyInfo	PolicyInfo
typedef struct _PublicationInfo	PublicationInfo
typedef struct _PublicationRelInfo	PublicationRelInfo
typedef struct _PublicationSchemaInfo	PublicationSchemaInfo
typedef struct _SubscriptionInfo	SubscriptionInfo
typedef struct _SubRelInfo	SubRelInfo

Enumerations
enum	DumpableObjectType {   DO_NAMESPACE , DO_EXTENSION , DO_TYPE , DO_SHELL_TYPE ,   DO_FUNC , DO_AGG , DO_OPERATOR , DO_ACCESS_METHOD ,   DO_OPCLASS , DO_OPFAMILY , DO_COLLATION , DO_CONVERSION ,   DO_TABLE , DO_TABLE_ATTACH , DO_ATTRDEF , DO_INDEX ,   DO_INDEX_ATTACH , DO_STATSEXT , DO_RULE , DO_TRIGGER ,   DO_CONSTRAINT , DO_FK_CONSTRAINT , DO_PROCLANG , DO_CAST ,   DO_TABLE_DATA , DO_SEQUENCE_SET , DO_DUMMY_TYPE , DO_TSPARSER ,   DO_TSDICT , DO_TSTEMPLATE , DO_TSCONFIG , DO_FDW ,   DO_FOREIGN_SERVER , DO_DEFAULT_ACL , DO_TRANSFORM , DO_LARGE_OBJECT ,   DO_LARGE_OBJECT_DATA , DO_PRE_DATA_BOUNDARY , DO_POST_DATA_BOUNDARY , DO_EVENT_TRIGGER ,   DO_REFRESH_MATVIEW , DO_POLICY , DO_PUBLICATION , DO_PUBLICATION_REL ,   DO_PUBLICATION_TABLE_IN_SCHEMA , DO_REL_STATS , DO_SUBSCRIPTION , DO_SUBSCRIPTION_REL }

Functions
TableInfo *	getSchemaData (Archive *fout, int *numTablesPtr)
void	AssignDumpId (DumpableObject *dobj)
void	recordAdditionalCatalogID (CatalogId catId, DumpableObject *dobj)
DumpId	createDumpId (void)
DumpId	getMaxDumpId (void)
DumpableObject *	findObjectByDumpId (DumpId dumpId)
DumpableObject *	findObjectByCatalogId (CatalogId catalogId)
void	getDumpableObjects (DumpableObject ***objs, int *numObjs)
void	addObjectDependency (DumpableObject *dobj, DumpId refId)
void	removeObjectDependency (DumpableObject *dobj, DumpId refId)
TableInfo *	findTableByOid (Oid oid)
TypeInfo *	findTypeByOid (Oid oid)
FuncInfo *	findFuncByOid (Oid oid)
OprInfo *	findOprByOid (Oid oid)
AccessMethodInfo *	findAccessMethodByOid (Oid oid)
CollInfo *	findCollationByOid (Oid oid)
NamespaceInfo *	findNamespaceByOid (Oid oid)
ExtensionInfo *	findExtensionByOid (Oid oid)
PublicationInfo *	findPublicationByOid (Oid oid)
SubscriptionInfo *	findSubscriptionByOid (Oid oid)
void	recordExtensionMembership (CatalogId catId, ExtensionInfo *ext)
ExtensionInfo *	findOwningExtension (CatalogId catalogId)
void	parseOidArray (const char *str, Oid *array, int arraysize)
void	sortDumpableObjects (DumpableObject **objs, int numObjs, DumpId preBoundaryId, DumpId postBoundaryId)
void	sortDumpableObjectsByTypeName (DumpableObject **objs, int numObjs)
void	getNamespaces (Archive *fout)
ExtensionInfo *	getExtensions (Archive *fout, int *numExtensions)
void	getTypes (Archive *fout)
void	getFuncs (Archive *fout)
void	getAggregates (Archive *fout)
void	getOperators (Archive *fout)
void	getAccessMethods (Archive *fout)
void	getOpclasses (Archive *fout)
void	getOpfamilies (Archive *fout)
void	getCollations (Archive *fout)
void	getConversions (Archive *fout)
TableInfo *	getTables (Archive *fout, int *numTables)
void	getOwnedSeqs (Archive *fout, TableInfo tblinfo[], int numTables)
InhInfo *	getInherits (Archive *fout, int *numInherits)
void	getPartitioningInfo (Archive *fout)
void	getIndexes (Archive *fout, TableInfo tblinfo[], int numTables)
void	getExtendedStatistics (Archive *fout)
void	getConstraints (Archive *fout, TableInfo tblinfo[], int numTables)
void	getRules (Archive *fout)
void	getTriggers (Archive *fout, TableInfo tblinfo[], int numTables)
void	getProcLangs (Archive *fout)
void	getCasts (Archive *fout)
void	getTransforms (Archive *fout)
void	getTableAttrs (Archive *fout, TableInfo *tblinfo, int numTables)
bool	shouldPrintColumn (const DumpOptions *dopt, const TableInfo *tbinfo, int colno)
void	getTSParsers (Archive *fout)
void	getTSDictionaries (Archive *fout)
void	getTSTemplates (Archive *fout)
void	getTSConfigurations (Archive *fout)
void	getForeignDataWrappers (Archive *fout)
void	getForeignServers (Archive *fout)
void	getDefaultACLs (Archive *fout)
void	getExtensionMembership (Archive *fout, ExtensionInfo extinfo[], int numExtensions)
void	processExtensionTables (Archive *fout, ExtensionInfo extinfo[], int numExtensions)
void	getEventTriggers (Archive *fout)
void	getPolicies (Archive *fout, TableInfo tblinfo[], int numTables)
void	getPublications (Archive *fout)
void	getPublicationNamespaces (Archive *fout)
void	getPublicationTables (Archive *fout, TableInfo tblinfo[], int numTables)
void	getSubscriptions (Archive *fout)
void	getSubscriptionRelations (Archive *fout)

Macro Definition Documentation

DUMP_COMPONENT_ACL

#define DUMP_COMPONENT_ACL   (1 << 4)

Definition at line 113 of file pg_dump.h.

DUMP_COMPONENT_ALL

#define DUMP_COMPONENT_ALL   (0xFFFF)

Definition at line 117 of file pg_dump.h.

DUMP_COMPONENT_COMMENT

#define DUMP_COMPONENT_COMMENT   (1 << 2)

Definition at line 111 of file pg_dump.h.

DUMP_COMPONENT_DATA

#define DUMP_COMPONENT_DATA   (1 << 1)

Definition at line 110 of file pg_dump.h.

DUMP_COMPONENT_DEFINITION

#define DUMP_COMPONENT_DEFINITION   (1 << 0)

Definition at line 109 of file pg_dump.h.

DUMP_COMPONENT_NONE

#define DUMP_COMPONENT_NONE   (0)

Definition at line 108 of file pg_dump.h.

DUMP_COMPONENT_POLICY

#define DUMP_COMPONENT_POLICY   (1 << 5)

Definition at line 114 of file pg_dump.h.

DUMP_COMPONENT_SECLABEL

#define DUMP_COMPONENT_SECLABEL   (1 << 3)

Definition at line 112 of file pg_dump.h.

DUMP_COMPONENT_STATISTICS

#define DUMP_COMPONENT_STATISTICS   (1 << 7)

Definition at line 116 of file pg_dump.h.

DUMP_COMPONENT_USERMAP

#define DUMP_COMPONENT_USERMAP   (1 << 6)

Definition at line 115 of file pg_dump.h.

DUMP_COMPONENTS_REQUIRING_LOCK

#define DUMP_COMPONENTS_REQUIRING_LOCK

Value:

        (\
        DUMP_COMPONENT_DEFINITION |\
        DUMP_COMPONENT_DATA |\
        DUMP_COMPONENT_STATISTICS |\
        DUMP_COMPONENT_POLICY)

Definition at line 141 of file pg_dump.h.

{
    DumpableObjectType objType;
    CatalogId   catId;          /* zero if not a cataloged object */
    DumpId      dumpId;         /* assigned by AssignDumpId() */
    char       *name;           /* object name (should never be NULL) */
    struct _namespaceInfo *namespace;   /* containing namespace, or NULL */
    DumpComponents dump;        /* bitmask of components requested to dump */
    DumpComponents dump_contains;   /* as above, but for contained objects */
    DumpComponents components;  /* bitmask of components available to dump */
    bool        ext_member;     /* true if object is member of extension */
    bool        depends_on_ext; /* true if object depends on an extension */
    DumpId     *dependencies;   /* dumpIds of objects this one depends on */
    int         nDeps;          /* number of valid dependencies */
    int         allocDeps;      /* allocated size of dependencies[] */
} DumpableObject;
 
/*
 * Object types that have ACLs must store them in a DumpableAcl sub-struct,
 * which must immediately follow the DumpableObject base struct.
 */
typedef struct _dumpableAcl
{
    char       *acl;            /* the object's actual ACL string */
    char       *acldefault;     /* default ACL for the object's type & owner */
    /* these fields come from the object's pg_init_privs entry, if any: */
    char        privtype;       /* entry type, 'i' or 'e'; 0 if no entry */
    char       *initprivs;      /* the object's initial ACL string, or NULL */
} DumpableAcl;
 
/* Generic struct that can be used to access any object type having an ACL */
typedef struct _dumpableObjectWithAcl
{
    DumpableObject dobj;
    DumpableAcl dacl;
} DumpableObjectWithAcl;
 
typedef struct _namespaceInfo
{
    DumpableObject dobj;
    DumpableAcl dacl;
    bool        create;         /* CREATE SCHEMA, or just set owner? */
    Oid         nspowner;       /* OID of owner */
    const char *rolname;        /* name of owner */
} NamespaceInfo;
 
typedef struct _extensionInfo
{
    DumpableObject dobj;
    char       *namespace;      /* schema containing extension's objects */
    bool        relocatable;
    char       *extversion;
    char       *extconfig;      /* info about configuration tables */
    char       *extcondition;
} ExtensionInfo;
 
typedef struct _typeInfo
{
    DumpableObject dobj;
    DumpableAcl dacl;
 
    /*
     * Note: dobj.name is the raw pg_type.typname entry.  ftypname is the
     * result of format_type(), which will be quoted if needed, and might be
     * schema-qualified too.
     */
    char       *ftypname;
    const char *rolname;
    Oid         typelem;
    Oid         typrelid;
    Oid         typarray;
    char        typrelkind;     /* 'r', 'v', 'c', etc */
    char        typtype;        /* 'b', 'c', etc */
    bool        isArray;        /* true if auto-generated array type */
    bool        isMultirange;   /* true if auto-generated multirange type */
    bool        isDefined;      /* true if typisdefined */
    /* If needed, we'll create a "shell type" entry for it; link that here: */
    struct _shellTypeInfo *shellType;   /* shell-type entry, or NULL */
    /* If it's a domain, its not-null constraint is here: */
    struct _constraintInfo *notnull;
    /* If it's a domain, we store links to its CHECK constraints here: */
    int         nDomChecks;
    struct _constraintInfo *domChecks;
} TypeInfo;
 
typedef struct _shellTypeInfo
{
    DumpableObject dobj;
 
    TypeInfo   *baseType;       /* back link to associated base type */
} ShellTypeInfo;
 
typedef struct _funcInfo
{
    DumpableObject dobj;
    DumpableAcl dacl;
    const char *rolname;
    Oid         lang;
    int         nargs;
    Oid        *argtypes;
    Oid         prorettype;
    bool        postponed_def;  /* function must be postponed into post-data */
} FuncInfo;
 
/* AggInfo is a superset of FuncInfo */
typedef struct _aggInfo
{
    FuncInfo    aggfn;
    /* we don't require any other fields at the moment */
} AggInfo;
 
typedef struct _oprInfo
{
    DumpableObject dobj;
    const char *rolname;
    char        oprkind;
    Oid         oprleft;
    Oid         oprright;
    Oid         oprcode;
} OprInfo;
 
typedef struct _accessMethodInfo
{
    DumpableObject dobj;
    char        amtype;
    char       *amhandler;
} AccessMethodInfo;
 
typedef struct _opclassInfo
{
    DumpableObject dobj;
    Oid         opcmethod;
    const char *rolname;
} OpclassInfo;
 
typedef struct _opfamilyInfo
{
    DumpableObject dobj;
    Oid         opfmethod;
    const char *rolname;
} OpfamilyInfo;
 
typedef struct _collInfo
{
    DumpableObject dobj;
    const char *rolname;
    int         collencoding;
} CollInfo;
 
typedef struct _convInfo
{
    DumpableObject dobj;
    const char *rolname;
} ConvInfo;
 
typedef struct _tableInfo
{
    /*
     * These fields are collected for every table in the database.
     */
    DumpableObject dobj;
    DumpableAcl dacl;
    const char *rolname;
    char        relkind;
    char        relpersistence; /* relation persistence */
    bool        relispopulated; /* relation is populated */
    char        relreplident;   /* replica identifier */
    char       *reltablespace;  /* relation tablespace */
    char       *reloptions;     /* options specified by WITH (...) */
    char       *checkoption;    /* WITH CHECK OPTION, if any */
    char       *toast_reloptions;   /* WITH options for the TOAST table */
    bool        hasindex;       /* does it have any indexes? */
    bool        hasrules;       /* does it have any rules? */
    bool        hastriggers;    /* does it have any triggers? */
    bool        hascolumnACLs;  /* do any columns have non-default ACLs? */
    bool        rowsec;         /* is row security enabled? */
    bool        forcerowsec;    /* is row security forced? */
    bool        hasoids;        /* does it have OIDs? */
    uint32      frozenxid;      /* table's relfrozenxid */
    uint32      minmxid;        /* table's relminmxid */
    Oid         toast_oid;      /* toast table's OID, or 0 if none */
    uint32      toast_frozenxid;    /* toast table's relfrozenxid, if any */
    uint32      toast_minmxid;  /* toast table's relminmxid */
    int         ncheck;         /* # of CHECK expressions */
    Oid         reltype;        /* OID of table's composite type, if any */
    Oid         reloftype;      /* underlying type for typed table */
    Oid         foreign_server; /* foreign server oid, if applicable */
    /* these two are set only if table is a sequence owned by a column: */
    Oid         owning_tab;     /* OID of table owning sequence */
    int         owning_col;     /* attr # of column owning sequence */
    bool        is_identity_sequence;
    int32       relpages;       /* table's size in pages (from pg_class) */
    int         toastpages;     /* toast table's size in pages, if any */
 
    bool        interesting;    /* true if need to collect more data */
    bool        dummy_view;     /* view's real definition must be postponed */
    bool        postponed_def;  /* matview must be postponed into post-data */
    bool        ispartition;    /* is table a partition? */
    bool        unsafe_partitions;  /* is it an unsafe partitioned table? */
 
    int         numParents;     /* number of (immediate) parent tables */
    struct _tableInfo **parents;    /* TableInfos of immediate parents */
 
    /*
     * These fields are computed only if we decide the table is interesting
     * (it's either a table to dump, or a direct parent of a dumpable table).
     */
    int         numatts;        /* number of attributes */
    char      **attnames;       /* the attribute names */
    char      **atttypnames;    /* attribute type names */
    int        *attstattarget;  /* attribute statistics targets */
    char       *attstorage;     /* attribute storage scheme */
    char       *typstorage;     /* type storage scheme */
    bool       *attisdropped;   /* true if attr is dropped; don't dump it */
    char       *attidentity;
    char       *attgenerated;
    int        *attlen;         /* attribute length, used by binary_upgrade */
    char       *attalign;       /* attribute align, used by binary_upgrade */
    bool       *attislocal;     /* true if attr has local definition */
    char      **attoptions;     /* per-attribute options */
    Oid        *attcollation;   /* per-attribute collation selection */
    char       *attcompression; /* per-attribute compression method */
    char      **attfdwoptions;  /* per-attribute fdw options */
    char      **attmissingval;  /* per attribute missing value */
    char      **notnull_constrs;    /* NOT NULL constraint names. If null,
                                     * there isn't one on this column. If
                                     * empty string, unnamed constraint
                                     * (pre-v17) */
    char      **notnull_comment;    /* comment thereof */
    bool       *notnull_invalid;    /* true for NOT NULL NOT VALID */
    bool       *notnull_noinh;  /* NOT NULL is NO INHERIT */
    bool       *notnull_islocal;    /* true if NOT NULL has local definition */
    struct _attrDefInfo **attrdefs; /* DEFAULT expressions */
    struct _constraintInfo *checkexprs; /* CHECK constraints */
    struct _relStatsInfo *stats;    /* only set for matviews */
    bool        needs_override; /* has GENERATED ALWAYS AS IDENTITY */
    char       *amname;         /* relation access method */
 
    /*
     * Stuff computed only for dumpable tables.
     */
    int         numIndexes;     /* number of indexes */
    struct _indxInfo *indexes;  /* indexes */
    struct _tableDataInfo *dataObj; /* TableDataInfo, if dumping its data */
    int         numTriggers;    /* number of triggers for table */
    struct _triggerInfo *triggers;  /* array of TriggerInfo structs */
} TableInfo;
 
typedef struct _tableAttachInfo
{
    DumpableObject dobj;
    TableInfo  *parentTbl;      /* link to partitioned table */
    TableInfo  *partitionTbl;   /* link to partition */
} TableAttachInfo;
 
typedef struct _attrDefInfo
{
    DumpableObject dobj;        /* note: dobj.name is name of table */
    TableInfo  *adtable;        /* link to table of attribute */
    int         adnum;
    char       *adef_expr;      /* decompiled DEFAULT expression */
    bool        separate;       /* true if must dump as separate item */
} AttrDefInfo;
 
typedef struct _tableDataInfo
{
    DumpableObject dobj;
    TableInfo  *tdtable;        /* link to table to dump */
    char       *filtercond;     /* WHERE condition to limit rows dumped */
} TableDataInfo;
 
typedef struct _indxInfo
{
    DumpableObject dobj;
    TableInfo  *indextable;     /* link to table the index is for */
    char       *indexdef;
    char       *tablespace;     /* tablespace in which index is stored */
    char       *indreloptions;  /* options specified by WITH (...) */
    char       *indstatcols;    /* column numbers with statistics */
    char       *indstatvals;    /* statistic values for columns */
    int         indnkeyattrs;   /* number of index key attributes */
    int         indnattrs;      /* total number of index attributes */
    Oid        *indkeys;        /* In spite of the name 'indkeys' this field
                                 * contains both key and nonkey attributes */
    bool        indisclustered;
    bool        indisreplident;
    bool        indnullsnotdistinct;
    Oid         parentidx;      /* if a partition, parent index OID */
    SimplePtrList partattaches; /* if partitioned, partition attach objects */
 
    /* if there is an associated constraint object, its dumpId: */
    DumpId      indexconstraint;
} IndxInfo;
 
typedef struct _indexAttachInfo
{
    DumpableObject dobj;
    IndxInfo   *parentIdx;      /* link to index on partitioned table */
    IndxInfo   *partitionIdx;   /* link to index on partition */
} IndexAttachInfo;
 
typedef struct _relStatsInfo
{
    DumpableObject dobj;
    Oid         relid;
    int32       relpages;
    char       *reltuples;
    int32       relallvisible;
    int32       relallfrozen;
    char        relkind;        /* 'r', 'm', 'i', etc */
 
    /*
     * indAttNames/nindAttNames are populated only if the relation is an index
     * with at least one expression column; we don't need them otherwise.
     */
    char      **indAttNames;    /* attnames of the index, in order */
    int32       nindAttNames;   /* number of attnames stored (can be 0) */
    teSection   section;        /* stats may appear in data or post-data */
} RelStatsInfo;
 
typedef struct _statsExtInfo
{
    DumpableObject dobj;
    const char *rolname;        /* owner */
    TableInfo  *stattable;      /* link to table the stats are for */
    int         stattarget;     /* statistics target */
} StatsExtInfo;
 
typedef struct _ruleInfo
{
    DumpableObject dobj;
    TableInfo  *ruletable;      /* link to table the rule is for */
    char        ev_type;
    bool        is_instead;
    char        ev_enabled;
    bool        separate;       /* true if must dump as separate item */
    /* separate is always true for non-ON SELECT rules */
} RuleInfo;
 
typedef struct _triggerInfo
{
    DumpableObject dobj;
    TableInfo  *tgtable;        /* link to table the trigger is for */
    char        tgenabled;
    bool        tgispartition;
    char       *tgdef;
} TriggerInfo;
 
typedef struct _evttriggerInfo
{
    DumpableObject dobj;
    char       *evtname;
    char       *evtevent;
    const char *evtowner;
    char       *evttags;
    char       *evtfname;
    char        evtenabled;
} EventTriggerInfo;
 
/*
 * struct ConstraintInfo is used for all constraint types.  However we
 * use a different objType for foreign key constraints, to make it easier
 * to sort them the way we want.
 *
 * Not-null constraints don't need this, unless they are NOT VALID.
 *
 * Note: condeferrable and condeferred are currently only valid for
 * unique/primary-key constraints.  Otherwise that info is in condef.
 */
typedef struct _constraintInfo
{
    DumpableObject dobj;
    TableInfo  *contable;       /* NULL if domain constraint */
    TypeInfo   *condomain;      /* NULL if table constraint */
    char        contype;
    char       *condef;         /* definition, if CHECK or FOREIGN KEY */
    Oid         confrelid;      /* referenced table, if FOREIGN KEY */
    DumpId      conindex;       /* identifies associated index if any */
    bool        condeferrable;  /* true if constraint is DEFERRABLE */
    bool        condeferred;    /* true if constraint is INITIALLY DEFERRED */
    bool        conperiod;      /* true if the constraint is WITHOUT OVERLAPS */
    bool        conislocal;     /* true if constraint has local definition */
    bool        separate;       /* true if must dump as separate item */
} ConstraintInfo;
 
typedef struct _procLangInfo
{
    DumpableObject dobj;
    DumpableAcl dacl;
    bool        lanpltrusted;
    Oid         lanplcallfoid;
    Oid         laninline;
    Oid         lanvalidator;
    const char *lanowner;
} ProcLangInfo;
 
typedef struct _castInfo
{
    DumpableObject dobj;
    Oid         castsource;
    Oid         casttarget;
    Oid         castfunc;
    char        castcontext;
    char        castmethod;
} CastInfo;
 
typedef struct _transformInfo
{
    DumpableObject dobj;
    Oid         trftype;
    Oid         trflang;
    Oid         trffromsql;
    Oid         trftosql;
} TransformInfo;
 
/* InhInfo isn't a DumpableObject, just temporary state */
typedef struct _inhInfo
{
    Oid         inhrelid;       /* OID of a child table */
    Oid         inhparent;      /* OID of its parent */
} InhInfo;
 
typedef struct _prsInfo
{
    DumpableObject dobj;
    Oid         prsstart;
    Oid         prstoken;
    Oid         prsend;
    Oid         prsheadline;
    Oid         prslextype;
} TSParserInfo;
 
typedef struct _dictInfo
{
    DumpableObject dobj;
    const char *rolname;
    Oid         dicttemplate;
    char       *dictinitoption;
} TSDictInfo;
 
typedef struct _tmplInfo
{
    DumpableObject dobj;
    Oid         tmplinit;
    Oid         tmpllexize;
} TSTemplateInfo;
 
typedef struct _cfgInfo
{
    DumpableObject dobj;
    const char *rolname;
    Oid         cfgparser;
} TSConfigInfo;
 
typedef struct _fdwInfo
{
    DumpableObject dobj;
    DumpableAcl dacl;
    const char *rolname;
    char       *fdwhandler;
    char       *fdwvalidator;
    char       *fdwconnection;
    char       *fdwoptions;
} FdwInfo;
 
typedef struct _foreignServerInfo
{
    DumpableObject dobj;
    DumpableAcl dacl;
    const char *rolname;
    Oid         srvfdw;
    char       *srvtype;
    char       *srvversion;
    char       *srvoptions;
} ForeignServerInfo;
 
typedef struct _defaultACLInfo
{
    DumpableObject dobj;
    DumpableAcl dacl;
    const char *defaclrole;
    char        defaclobjtype;
} DefaultACLInfo;
 
/*
 * LoInfo represents a group of large objects (blobs) that share the same
 * owner and ACL setting.  dobj.components has the DUMP_COMPONENT_COMMENT bit
 * set if any blob in the group has a comment; similarly for sec labels.
 * If there are many blobs with the same owner/ACL, we can divide them into
 * multiple LoInfo groups, which will each spawn a BLOB METADATA and a BLOBS
 * (data) TOC entry.  This allows more parallelism during restore.
 */
typedef struct _loInfo
{
    DumpableObject dobj;
    DumpableAcl dacl;
    const char *rolname;
    int         numlos;
    Oid         looids[FLEXIBLE_ARRAY_MEMBER];
} LoInfo;
 
/*
 * The PolicyInfo struct is used to represent policies on a table and
 * to indicate if a table has RLS enabled (ENABLE ROW SECURITY).  If
 * polname is NULL, then the record indicates ENABLE ROW SECURITY, while if
 * it's non-NULL then this is a regular policy definition.
 */
typedef struct _policyInfo
{
    DumpableObject dobj;
    TableInfo  *poltable;
    char       *polname;        /* null indicates RLS is enabled on rel */
    char        polcmd;
    bool        polpermissive;
    char       *polroles;
    char       *polqual;
    char       *polwithcheck;
} PolicyInfo;
 
/*
 * The PublicationInfo struct is used to represent publications.
 */
typedef struct _PublicationInfo
{
    DumpableObject dobj;
    const char *rolname;
    bool        puballtables;
    bool        puballsequences;
    bool        pubinsert;
    bool        pubupdate;
    bool        pubdelete;
    bool        pubtruncate;
    bool        pubviaroot;
    PublishGencolsType pubgencols_type;
    SimplePtrList except_tables;
} PublicationInfo;
 
/*
 * The PublicationRelInfo struct is used to represent publication table
 * mapping.
 */
typedef struct _PublicationRelInfo
{
    DumpableObject dobj;
    PublicationInfo *publication;
    TableInfo  *pubtable;
    char       *pubrelqual;
    char       *pubrattrs;
} PublicationRelInfo;
 
/*
 * The PublicationSchemaInfo struct is used to represent publication schema
 * mapping.
 */
typedef struct _PublicationSchemaInfo
{
    DumpableObject dobj;
    PublicationInfo *publication;
    NamespaceInfo *pubschema;
} PublicationSchemaInfo;
 
/*
 * The SubscriptionInfo struct is used to represent subscription.
 */
typedef struct _SubscriptionInfo
{
    DumpableObject dobj;
    const char *rolname;
    bool        subenabled;
    bool        subbinary;
    char        substream;
    char        subtwophasestate;
    bool        subdisableonerr;
    bool        subpasswordrequired;
    bool        subrunasowner;
    bool        subfailover;
    bool        subretaindeadtuples;
    int         submaxretention;
    char       *subservername;
    char       *subconninfo;
    char       *subslotname;
    char       *subsynccommit;
    char       *subwalrcvtimeout;
    char       *subpublications;
    char       *suborigin;
    char       *suboriginremotelsn;
} SubscriptionInfo;
 
/*
 * The SubRelInfo struct is used to represent a subscription relation.
 *
 * XXX Currently, the subscription tables are added to the subscription after
 * enabling the subscription in binary-upgrade mode. As the apply workers will
 * not be started in binary_upgrade mode the ordering of enable subscription
 * does not matter. The order of adding the subscription tables to the
 * subscription and enabling the subscription should be taken care of if this
 * feature will be supported in a non-binary-upgrade mode in the future.
 */
typedef struct _SubRelInfo
{
    DumpableObject dobj;
    SubscriptionInfo *subinfo;
    TableInfo  *tblinfo;
    char        srsubstate;
    char       *srsublsn;
} SubRelInfo;
 
/*
 *  common utility functions
 */
 
extern TableInfo *getSchemaData(Archive *fout, int *numTablesPtr);
 
extern void AssignDumpId(DumpableObject *dobj);
extern void recordAdditionalCatalogID(CatalogId catId, DumpableObject *dobj);
extern DumpId createDumpId(void);
extern DumpId getMaxDumpId(void);
extern DumpableObject *findObjectByDumpId(DumpId dumpId);
extern DumpableObject *findObjectByCatalogId(CatalogId catalogId);
extern void getDumpableObjects(DumpableObject ***objs, int *numObjs);
 
extern void addObjectDependency(DumpableObject *dobj, DumpId refId);
extern void removeObjectDependency(DumpableObject *dobj, DumpId refId);
 
extern TableInfo *findTableByOid(Oid oid);
extern TypeInfo *findTypeByOid(Oid oid);
extern FuncInfo *findFuncByOid(Oid oid);
extern OprInfo *findOprByOid(Oid oid);
extern AccessMethodInfo *findAccessMethodByOid(Oid oid);
extern CollInfo *findCollationByOid(Oid oid);
extern NamespaceInfo *findNamespaceByOid(Oid oid);
extern ExtensionInfo *findExtensionByOid(Oid oid);
extern PublicationInfo *findPublicationByOid(Oid oid);
extern SubscriptionInfo *findSubscriptionByOid(Oid oid);
 
extern void recordExtensionMembership(CatalogId catId, ExtensionInfo *ext);
extern ExtensionInfo *findOwningExtension(CatalogId catalogId);
 
extern void parseOidArray(const char *str, Oid *array, int arraysize);
 
extern void sortDumpableObjects(DumpableObject **objs, int numObjs,
                                DumpId preBoundaryId, DumpId postBoundaryId);
extern void sortDumpableObjectsByTypeName(DumpableObject **objs, int numObjs);
 
/*
 * version specific routines
 */
extern void getNamespaces(Archive *fout);
extern ExtensionInfo *getExtensions(Archive *fout, int *numExtensions);
extern void getTypes(Archive *fout);
extern void getFuncs(Archive *fout);
extern void getAggregates(Archive *fout);
extern void getOperators(Archive *fout);
extern void getAccessMethods(Archive *fout);
extern void getOpclasses(Archive *fout);
extern void getOpfamilies(Archive *fout);
extern void getCollations(Archive *fout);
extern void getConversions(Archive *fout);
extern TableInfo *getTables(Archive *fout, int *numTables);
extern void getOwnedSeqs(Archive *fout, TableInfo tblinfo[], int numTables);
extern InhInfo *getInherits(Archive *fout, int *numInherits);
extern void getPartitioningInfo(Archive *fout);
extern void getIndexes(Archive *fout, TableInfo tblinfo[], int numTables);
extern void getExtendedStatistics(Archive *fout);
extern void getConstraints(Archive *fout, TableInfo tblinfo[], int numTables);
extern void getRules(Archive *fout);
extern void getTriggers(Archive *fout, TableInfo tblinfo[], int numTables);
extern void getProcLangs(Archive *fout);
extern void getCasts(Archive *fout);
extern void getTransforms(Archive *fout);
extern void getTableAttrs(Archive *fout, TableInfo *tblinfo, int numTables);
extern bool shouldPrintColumn(const DumpOptions *dopt, const TableInfo *tbinfo, int colno);
extern void getTSParsers(Archive *fout);
extern void getTSDictionaries(Archive *fout);
extern void getTSTemplates(Archive *fout);
extern void getTSConfigurations(Archive *fout);
extern void getForeignDataWrappers(Archive *fout);
extern void getForeignServers(Archive *fout);
extern void getDefaultACLs(Archive *fout);
extern void getExtensionMembership(Archive *fout, ExtensionInfo extinfo[],
                                   int numExtensions);
extern void processExtensionTables(Archive *fout, ExtensionInfo extinfo[],
                                   int numExtensions);
extern void getEventTriggers(Archive *fout);
extern void getPolicies(Archive *fout, TableInfo tblinfo[], int numTables);
extern void getPublications(Archive *fout);
extern void getPublicationNamespaces(Archive *fout);
extern void getPublicationTables(Archive *fout, TableInfo tblinfo[],
                                 int numTables);
extern void getSubscriptions(Archive *fout);
extern void getSubscriptionRelations(Archive *fout);
 
#endif                          /* PG_DUMP_H */

NUM_DUMPABLE_OBJECT_TYPES

#define NUM_DUMPABLE_OBJECT_TYPES   (DO_SUBSCRIPTION_REL + 1)

Definition at line 91 of file pg_dump.h.

oidcmp

#define oidcmp	(		x,
			y
	)		( ((x) < (y) ? -1 : ((x) > (y)) ? 1 : 0) )

Definition at line 21 of file pg_dump.h.

Typedef Documentation

AccessMethodInfo

typedef struct _accessMethodInfo AccessMethodInfo

AggInfo

typedef struct _aggInfo AggInfo

AttrDefInfo

typedef struct _attrDefInfo AttrDefInfo

CastInfo

typedef struct _castInfo CastInfo

CollInfo

typedef struct _collInfo CollInfo

ConstraintInfo

typedef struct _constraintInfo ConstraintInfo

ConvInfo

typedef struct _convInfo ConvInfo

DefaultACLInfo

typedef struct _defaultACLInfo DefaultACLInfo

DumpableAcl

typedef struct _dumpableAcl DumpableAcl

DumpableObject

typedef struct _dumpableObject DumpableObject

DumpableObjectWithAcl

typedef struct _dumpableObjectWithAcl DumpableObjectWithAcl

DumpComponents

typedef uint32 DumpComponents

Definition at line 107 of file pg_dump.h.

EventTriggerInfo

typedef struct _evttriggerInfo EventTriggerInfo

ExtensionInfo

typedef struct _extensionInfo ExtensionInfo

FdwInfo

typedef struct _fdwInfo FdwInfo

ForeignServerInfo

typedef struct _foreignServerInfo ForeignServerInfo

FuncInfo

typedef struct _funcInfo FuncInfo

IndexAttachInfo

typedef struct _indexAttachInfo IndexAttachInfo

IndxInfo

typedef struct _indxInfo IndxInfo

InhInfo

typedef struct _inhInfo InhInfo

LoInfo

typedef struct _loInfo LoInfo

NamespaceInfo

typedef struct _namespaceInfo NamespaceInfo

OpclassInfo

typedef struct _opclassInfo OpclassInfo

OpfamilyInfo

typedef struct _opfamilyInfo OpfamilyInfo

OprInfo

typedef struct _oprInfo OprInfo

PolicyInfo

typedef struct _policyInfo PolicyInfo

ProcLangInfo

typedef struct _procLangInfo ProcLangInfo

PublicationInfo

typedef struct _PublicationInfo PublicationInfo

PublicationRelInfo

typedef struct _PublicationRelInfo PublicationRelInfo

PublicationSchemaInfo

typedef struct _PublicationSchemaInfo PublicationSchemaInfo

RelStatsInfo

typedef struct _relStatsInfo RelStatsInfo

RuleInfo

typedef struct _ruleInfo RuleInfo

ShellTypeInfo

typedef struct _shellTypeInfo ShellTypeInfo

StatsExtInfo

typedef struct _statsExtInfo StatsExtInfo

SubRelInfo

typedef struct _SubRelInfo SubRelInfo

SubscriptionInfo

typedef struct _SubscriptionInfo SubscriptionInfo

TableAttachInfo

typedef struct _tableAttachInfo TableAttachInfo

TableDataInfo

typedef struct _tableDataInfo TableDataInfo

TableInfo

typedef struct _tableInfo TableInfo

TransformInfo

typedef struct _transformInfo TransformInfo

TriggerInfo

typedef struct _triggerInfo TriggerInfo

TSConfigInfo

typedef struct _cfgInfo TSConfigInfo

TSDictInfo

typedef struct _dictInfo TSDictInfo

TSParserInfo

typedef struct _prsInfo TSParserInfo

TSTemplateInfo

typedef struct _tmplInfo TSTemplateInfo

TypeInfo

typedef struct _typeInfo TypeInfo

Enumeration Type Documentation

DumpableObjectType

enum DumpableObjectType

Enumerator
DO_NAMESPACE
DO_EXTENSION
DO_TYPE
DO_SHELL_TYPE
DO_FUNC
DO_AGG
DO_OPERATOR
DO_ACCESS_METHOD
DO_OPCLASS
DO_OPFAMILY
DO_COLLATION
DO_CONVERSION
DO_TABLE
DO_TABLE_ATTACH
DO_ATTRDEF
DO_INDEX
DO_INDEX_ATTACH
DO_STATSEXT
DO_RULE
DO_TRIGGER
DO_CONSTRAINT
DO_FK_CONSTRAINT
DO_PROCLANG
DO_CAST
DO_TABLE_DATA
DO_SEQUENCE_SET
DO_DUMMY_TYPE
DO_TSPARSER
DO_TSDICT
DO_TSTEMPLATE
DO_TSCONFIG
DO_FDW
DO_FOREIGN_SERVER
DO_DEFAULT_ACL
DO_TRANSFORM
DO_LARGE_OBJECT
DO_LARGE_OBJECT_DATA
DO_PRE_DATA_BOUNDARY
DO_POST_DATA_BOUNDARY
DO_EVENT_TRIGGER
DO_REFRESH_MATVIEW
DO_POLICY
DO_PUBLICATION
DO_PUBLICATION_REL
DO_PUBLICATION_TABLE_IN_SCHEMA
DO_REL_STATS
DO_SUBSCRIPTION
DO_SUBSCRIPTION_REL

Definition at line 38 of file pg_dump.h.

{
    /* When modifying this enum, update priority tables in pg_dump_sort.c! */
    DO_NAMESPACE,
    DO_EXTENSION,
    DO_TYPE,
    DO_SHELL_TYPE,
    DO_FUNC,
    DO_AGG,
    DO_OPERATOR,
    DO_ACCESS_METHOD,
    DO_OPCLASS,
    DO_OPFAMILY,
    DO_COLLATION,
    DO_CONVERSION,
    DO_TABLE,
    DO_TABLE_ATTACH,
    DO_ATTRDEF,
    DO_INDEX,
    DO_INDEX_ATTACH,
    DO_STATSEXT,
    DO_RULE,
    DO_TRIGGER,
    DO_CONSTRAINT,
    DO_FK_CONSTRAINT,           /* see note for ConstraintInfo */
    DO_PROCLANG,
    DO_CAST,
    DO_TABLE_DATA,
    DO_SEQUENCE_SET,
    DO_DUMMY_TYPE,
    DO_TSPARSER,
    DO_TSDICT,
    DO_TSTEMPLATE,
    DO_TSCONFIG,
    DO_FDW,
    DO_FOREIGN_SERVER,
    DO_DEFAULT_ACL,
    DO_TRANSFORM,
    DO_LARGE_OBJECT,
    DO_LARGE_OBJECT_DATA,
    DO_PRE_DATA_BOUNDARY,
    DO_POST_DATA_BOUNDARY,
    DO_EVENT_TRIGGER,
    DO_REFRESH_MATVIEW,
    DO_POLICY,
    DO_PUBLICATION,
    DO_PUBLICATION_REL,
    DO_PUBLICATION_TABLE_IN_SCHEMA,
    DO_REL_STATS,
    DO_SUBSCRIPTION,
    DO_SUBSCRIPTION_REL,        /* see note for SubRelInfo */
} DumpableObjectType;

Function Documentation

addObjectDependency()

void addObjectDependency ( DumpableObject *  dobj, DumpId  refId  )

extern

Definition at line 819 of file common.c.

{
    if (dobj->nDeps >= dobj->allocDeps)
    {
        if (dobj->allocDeps <= 0)
        {
            dobj->allocDeps = 16;
            dobj->dependencies = pg_malloc_array(DumpId, dobj->allocDeps);
        }
        else
        {
            dobj->allocDeps *= 2;
            dobj->dependencies = pg_realloc_array(dobj->dependencies,
                                                  DumpId, dobj->allocDeps);
        }
    }
    dobj->dependencies[dobj->nDeps++] = refId;
}

References _dumpableObject::allocDeps, _dumpableObject::dependencies, fb(), _dumpableObject::nDeps, pg_malloc_array, and pg_realloc_array.

Referenced by addBoundaryDependencies(), addConstrChildIdxDeps(), buildMatViewRefreshDependencies(), checkExtensionMembership(), flagInhAttrs(), flagInhIndexes(), flagInhTables(), getDependencies(), getDomainConstraints(), getIndexes(), getRules(), getTableAttrs(), getTableDataFKConstraints(), makeTableDataInfo(), processExtensionTables(), repairDomainConstraintMultiLoop(), repairTableAttrDefMultiLoop(), repairTableConstraintMultiLoop(), repairTypeFuncLoop(), and repairViewRuleMultiLoop().

AssignDumpId()

void AssignDumpId ( DumpableObject *  dobj )

extern

Definition at line 658 of file common.c.

{
    dobj->dumpId = ++lastDumpId;
    dobj->name = NULL;          /* must be set later */
    dobj->namespace = NULL;     /* may be set later */
    dobj->dump = DUMP_COMPONENT_ALL;    /* default assumption */
    dobj->dump_contains = DUMP_COMPONENT_ALL;   /* default assumption */
    /* All objects have definitions; we may set more components bits later */
    dobj->components = DUMP_COMPONENT_DEFINITION;
    dobj->ext_member = false;   /* default assumption */
    dobj->depends_on_ext = false;   /* default assumption */
    dobj->dependencies = NULL;
    dobj->nDeps = 0;
    dobj->allocDeps = 0;
 
    /* Add object to dumpIdMap[], enlarging that array if need be */
    while (dobj->dumpId >= allocedDumpIds)
    {
        int         newAlloc;
 
        if (allocedDumpIds <= 0)
        {
            newAlloc = 256;
            dumpIdMap = pg_malloc_array(DumpableObject *, newAlloc);
        }
        else
        {
            newAlloc = allocedDumpIds * 2;
            dumpIdMap = pg_realloc_array(dumpIdMap, DumpableObject *, newAlloc);
        }
        memset(dumpIdMap + allocedDumpIds, 0,
               (newAlloc - allocedDumpIds) * sizeof(DumpableObject *));
        allocedDumpIds = newAlloc;
    }
    dumpIdMap[dobj->dumpId] = dobj;
 
    /* If it has a valid CatalogId, enter it into the hash table */
    if (OidIsValid(dobj->catId.tableoid))
    {
        CatalogIdMapEntry *entry;
        bool        found;
 
        /* Initialize CatalogId hash table if not done yet */
        if (catalogIdHash == NULL)
            catalogIdHash = catalogid_create(CATALOGIDHASH_INITIAL_SIZE, NULL);
 
        entry = catalogid_insert(catalogIdHash, dobj->catId, &found);
        if (!found)
        {
            entry->dobj = NULL;
            entry->ext = NULL;
        }
        Assert(entry->dobj == NULL);
        entry->dobj = dobj;
    }
}

References _dumpableObject::allocDeps, allocedDumpIds, Assert, catalogIdHash, CATALOGIDHASH_INITIAL_SIZE, _dumpableObject::catId, _dumpableObject::components, _dumpableObject::dependencies, _dumpableObject::depends_on_ext, _catalogIdMapEntry::dobj, _dumpableObject::dump, DUMP_COMPONENT_ALL, DUMP_COMPONENT_DEFINITION, _dumpableObject::dump_contains, _dumpableObject::dumpId, dumpIdMap, _catalogIdMapEntry::ext, _dumpableObject::ext_member, fb(), lastDumpId, _dumpableObject::name, _dumpableObject::nDeps, OidIsValid, pg_malloc_array, pg_realloc_array, and CatalogId::tableoid.

Referenced by createBoundaryObjects(), flagInhAttrs(), flagInhIndexes(), flagInhTables(), getAccessMethods(), getAggregates(), getCasts(), getCollations(), getConstraints(), getConversions(), getDefaultACLs(), getDomainConstraints(), getEventTriggers(), getExtendedStatistics(), getExtensions(), getForeignDataWrappers(), getForeignServers(), getFuncs(), getIndexes(), getLOs(), getNamespaces(), getOpclasses(), getOperators(), getOpfamilies(), getPolicies(), getProcLangs(), getPublicationNamespaces(), getPublications(), getPublicationTables(), getRelationStatistics(), getRules(), getSubscriptionRelations(), getSubscriptions(), getTableAttrs(), getTables(), getTransforms(), getTriggers(), getTSConfigurations(), getTSDictionaries(), getTSParsers(), getTSTemplates(), getTypes(), and makeTableDataInfo().

createDumpId()

DumpId createDumpId ( void  )

extern

Definition at line 746 of file common.c.

{
    return ++lastDumpId;
}

References lastDumpId.

Referenced by dumpACL(), dumpCommentExtended(), dumpCompositeTypeColComments(), dumpDatabase(), dumpEncoding(), dumpRelationStats(), dumpSearchPath(), dumpSecLabel(), dumpSequence(), dumpSequenceData(), dumpStatisticsExtStats(), dumpStdStrings(), dumpTableComment(), dumpTableSchema(), dumpTableSecLabel(), and dumpUserMappings().

findAccessMethodByOid()

AccessMethodInfo * findAccessMethodByOid ( Oid  oid )

extern

Definition at line 955 of file common.c.

{
    CatalogId   catId;
    DumpableObject *dobj;
 
    catId.tableoid = AccessMethodRelationId;
    catId.oid = oid;
    dobj = findObjectByCatalogId(catId);
    Assert(dobj == NULL || dobj->objType == DO_ACCESS_METHOD);
    return (AccessMethodInfo *) dobj;
}

References Assert, DO_ACCESS_METHOD, fb(), findObjectByCatalogId(), _dumpableObject::objType, CatalogId::oid, and CatalogId::tableoid.

Referenced by accessMethodNameCompare().

findCollationByOid()

CollInfo * findCollationByOid ( Oid  oid )

extern

Definition at line 973 of file common.c.

{
    CatalogId   catId;
    DumpableObject *dobj;
 
    catId.tableoid = CollationRelationId;
    catId.oid = oid;
    dobj = findObjectByCatalogId(catId);
    Assert(dobj == NULL || dobj->objType == DO_COLLATION);
    return (CollInfo *) dobj;
}

References Assert, DO_COLLATION, fb(), findObjectByCatalogId(), _dumpableObject::objType, CatalogId::oid, and CatalogId::tableoid.

Referenced by createDummyViewAsClause(), dumpCompositeType(), dumpDomain(), dumpRangeType(), and dumpTableSchema().

findExtensionByOid()

ExtensionInfo * findExtensionByOid ( Oid  oid )

extern

Definition at line 1009 of file common.c.

{
    CatalogId   catId;
    DumpableObject *dobj;
 
    catId.tableoid = ExtensionRelationId;
    catId.oid = oid;
    dobj = findObjectByCatalogId(catId);
    Assert(dobj == NULL || dobj->objType == DO_EXTENSION);
    return (ExtensionInfo *) dobj;
}

References Assert, DO_EXTENSION, fb(), findObjectByCatalogId(), _dumpableObject::objType, CatalogId::oid, and CatalogId::tableoid.

Referenced by getExtensionMembership().

findFuncByOid()

FuncInfo * findFuncByOid ( Oid  oid )

extern

Definition at line 919 of file common.c.

{
    CatalogId   catId;
    DumpableObject *dobj;
 
    catId.tableoid = ProcedureRelationId;
    catId.oid = oid;
    dobj = findObjectByCatalogId(catId);
    Assert(dobj == NULL || dobj->objType == DO_FUNC);
    return (FuncInfo *) dobj;
}

References Assert, DO_FUNC, fb(), findObjectByCatalogId(), _dumpableObject::objType, CatalogId::oid, and CatalogId::tableoid.

Referenced by dumpCast(), dumpProcLang(), and dumpTransform().

findNamespaceByOid()

NamespaceInfo * findNamespaceByOid ( Oid  oid )

extern

Definition at line 991 of file common.c.

{
    CatalogId   catId;
    DumpableObject *dobj;
 
    catId.tableoid = NamespaceRelationId;
    catId.oid = oid;
    dobj = findObjectByCatalogId(catId);
    Assert(dobj == NULL || dobj->objType == DO_NAMESPACE);
    return (NamespaceInfo *) dobj;
}

References Assert, DO_NAMESPACE, fb(), findObjectByCatalogId(), _dumpableObject::objType, CatalogId::oid, and CatalogId::tableoid.

Referenced by findNamespace(), and getPublicationNamespaces().

findObjectByCatalogId()

DumpableObject * findObjectByCatalogId ( CatalogId  catalogId )

extern

Definition at line 779 of file common.c.

{
    CatalogIdMapEntry *entry;
 
    if (catalogIdHash == NULL)
        return NULL;            /* no objects exist yet */
 
    entry = catalogid_lookup(catalogIdHash, catalogId);
    if (entry == NULL)
        return NULL;
    return entry->dobj;
}

References catalogIdHash, _catalogIdMapEntry::dobj, and fb().

Referenced by buildMatViewRefreshDependencies(), collectComments(), collectSecLabels(), findAccessMethodByOid(), findCollationByOid(), findExtensionByOid(), findFuncByOid(), findIndexByOid(), findNamespaceByOid(), findOprByOid(), findPublicationByOid(), findSubscriptionByOid(), findTableByOid(), findTypeByOid(), getAdditionalACLs(), and getDependencies().

findObjectByDumpId()

DumpableObject * findObjectByDumpId ( DumpId  dumpId )

extern

Definition at line 766 of file common.c.

{
    if (dumpId <= 0 || dumpId >= allocedDumpIds)
        return NULL;            /* out of range? */
    return dumpIdMap[dumpId];
}

References allocedDumpIds, dumpIdMap, and fb().

Referenced by binary_upgrade_extension_member(), BuildArchiveDependencies(), dumpConstraint(), dumpDumpableObject(), dumpExtension(), findDumpableDependencies(), and findLoop().

findOprByOid()

OprInfo * findOprByOid ( Oid  oid )

extern

Definition at line 937 of file common.c.

{
    CatalogId   catId;
    DumpableObject *dobj;
 
    catId.tableoid = OperatorRelationId;
    catId.oid = oid;
    dobj = findObjectByCatalogId(catId);
    Assert(dobj == NULL || dobj->objType == DO_OPERATOR);
    return (OprInfo *) dobj;
}

References Assert, DO_OPERATOR, fb(), findObjectByCatalogId(), _dumpableObject::objType, CatalogId::oid, and CatalogId::tableoid.

Referenced by getFormattedOperatorName().

findOwningExtension()

ExtensionInfo * findOwningExtension ( CatalogId  catalogId )

extern

Definition at line 1088 of file common.c.

{
    CatalogIdMapEntry *entry;
 
    if (catalogIdHash == NULL)
        return NULL;            /* no objects exist yet */
 
    entry = catalogid_lookup(catalogIdHash, catalogId);
    if (entry == NULL)
        return NULL;
    return entry->ext;
}

References catalogIdHash, _catalogIdMapEntry::ext, and fb().

Referenced by checkExtensionMembership().

findPublicationByOid()

PublicationInfo * findPublicationByOid ( Oid  oid )

extern

Definition at line 1027 of file common.c.

{
    CatalogId   catId;
    DumpableObject *dobj;
 
    catId.tableoid = PublicationRelationId;
    catId.oid = oid;
    dobj = findObjectByCatalogId(catId);
    Assert(dobj == NULL || dobj->objType == DO_PUBLICATION);
    return (PublicationInfo *) dobj;
}

References Assert, DO_PUBLICATION, fb(), findObjectByCatalogId(), _dumpableObject::objType, CatalogId::oid, and CatalogId::tableoid.

Referenced by getPublicationNamespaces(), and getPublicationTables().

findSubscriptionByOid()

SubscriptionInfo * findSubscriptionByOid ( Oid  oid )

extern

Definition at line 1045 of file common.c.

{
    CatalogId   catId;
    DumpableObject *dobj;
 
    catId.tableoid = SubscriptionRelationId;
    catId.oid = oid;
    dobj = findObjectByCatalogId(catId);
    Assert(dobj == NULL || dobj->objType == DO_SUBSCRIPTION);
    return (SubscriptionInfo *) dobj;
}

References Assert, DO_SUBSCRIPTION, fb(), findObjectByCatalogId(), _dumpableObject::objType, CatalogId::oid, and CatalogId::tableoid.

Referenced by getSubscriptionRelations().

findTableByOid()

TableInfo * findTableByOid ( Oid  oid )

extern

Definition at line 864 of file common.c.

{
    CatalogId   catId;
    DumpableObject *dobj;
 
    catId.tableoid = RelationRelationId;
    catId.oid = oid;
    dobj = findObjectByCatalogId(catId);
    Assert(dobj == NULL || dobj->objType == DO_TABLE);
    return (TableInfo *) dobj;
}

References Assert, DO_TABLE, fb(), findObjectByCatalogId(), _dumpableObject::objType, CatalogId::oid, and CatalogId::tableoid.

Referenced by dumpSequence(), flagInhTables(), getAdditionalACLs(), getConstraints(), getExtendedStatistics(), getOwnedSeqs(), getPartitioningInfo(), getPolicies(), getPublications(), getPublicationTables(), getRules(), getSubscriptionRelations(), getTableDataFKConstraints(), main(), processExtensionTables(), and selectDumpableType().

findTypeByOid()

TypeInfo * findTypeByOid ( Oid  oid )

extern

Definition at line 900 of file common.c.

{
    CatalogId   catId;
    DumpableObject *dobj;
 
    catId.tableoid = TypeRelationId;
    catId.oid = oid;
    dobj = findObjectByCatalogId(catId);
    Assert(dobj == NULL ||
           dobj->objType == DO_TYPE || dobj->objType == DO_DUMMY_TYPE);
    return (TypeInfo *) dobj;
}

References Assert, DO_DUMMY_TYPE, DO_TYPE, fb(), findObjectByCatalogId(), _dumpableObject::objType, CatalogId::oid, and CatalogId::tableoid.

Referenced by binary_upgrade_set_type_oids_by_type_oid(), collectComments(), collectSecLabels(), getCasts(), getFormattedTypeName(), getTransforms(), and pgTypeNameCompare().

getAccessMethods()

void getAccessMethods ( Archive *  fout )

extern

Definition at line 6662 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    AccessMethodInfo *aminfo;
    int         i_tableoid;
    int         i_oid;
    int         i_amname;
    int         i_amhandler;
    int         i_amtype;
 
    query = createPQExpBuffer();
 
    /*
     * Select all access methods from pg_am table.  v9.6 introduced CREATE
     * ACCESS METHOD, so earlier versions usually have only built-in access
     * methods.  v9.6 also changed the access method API, replacing dozens of
     * pg_am columns with amhandler.  Even if a user created an access method
     * by "INSERT INTO pg_am", we have no way to translate pre-v9.6 pg_am
     * columns to a v9.6+ CREATE ACCESS METHOD.  Hence, before v9.6, read
     * pg_am just to facilitate findAccessMethodByOid() providing the
     * OID-to-name mapping.
     */
    appendPQExpBufferStr(query, "SELECT tableoid, oid, amname, ");
    if (fout->remoteVersion >= 90600)
        appendPQExpBufferStr(query,
                             "amtype, "
                             "amhandler::pg_catalog.regproc AS amhandler ");
    else
        appendPQExpBufferStr(query,
                             "'i'::pg_catalog.\"char\" AS amtype, "
                             "'-'::pg_catalog.regproc AS amhandler ");
    appendPQExpBufferStr(query, "FROM pg_am");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    aminfo = pg_malloc_array(AccessMethodInfo, ntups);
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_amname = PQfnumber(res, "amname");
    i_amhandler = PQfnumber(res, "amhandler");
    i_amtype = PQfnumber(res, "amtype");
 
    for (i = 0; i < ntups; i++)
    {
        aminfo[i].dobj.objType = DO_ACCESS_METHOD;
        aminfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        aminfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&aminfo[i].dobj);
        aminfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_amname));
        aminfo[i].dobj.namespace = NULL;
        aminfo[i].amhandler = pg_strdup(PQgetvalue(res, i, i_amhandler));
        aminfo[i].amtype = *(PQgetvalue(res, i, i_amtype));
 
        /* Decide whether we want to dump it */
        selectDumpableAccessMethod(&(aminfo[i]), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_ACCESS_METHOD, ExecuteSqlQuery(), fb(), fout, i, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, Archive::remoteVersion, and selectDumpableAccessMethod().

Referenced by getSchemaData().

getAggregates()

void getAggregates ( Archive *  fout )

extern

Definition at line 6864 of file pg_dump.c.

{
    DumpOptions *dopt = fout->dopt;
    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_proowner;
    int         i_aggacl;
    int         i_acldefault;
 
    /*
     * Find all interesting aggregates.  See comment in getFuncs() for the
     * rationale behind the filtering logic.
     */
    if (fout->remoteVersion >= 90600)
    {
        const char *agg_check;
 
        agg_check = (fout->remoteVersion >= 110000 ? "p.prokind = 'a'"
                     : "p.proisagg");
 
        appendPQExpBuffer(query, "SELECT p.tableoid, p.oid, "
                          "p.proname AS aggname, "
                          "p.pronamespace AS aggnamespace, "
                          "p.pronargs, p.proargtypes, "
                          "p.proowner, "
                          "p.proacl AS aggacl, "
                          "acldefault('f', p.proowner) AS acldefault "
                          "FROM pg_proc p "
                          "LEFT JOIN pg_init_privs pip ON "
                          "(p.oid = pip.objoid "
                          "AND pip.classoid = 'pg_proc'::regclass "
                          "AND pip.objsubid = 0) "
                          "WHERE %s AND ("
                          "p.pronamespace != "
                          "(SELECT oid FROM pg_namespace "
                          "WHERE nspname = 'pg_catalog') OR "
                          "p.proacl IS DISTINCT FROM pip.initprivs",
                          agg_check);
        if (dopt->binary_upgrade)
            appendPQExpBufferStr(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')");
        appendPQExpBufferChar(query, ')');
    }
    else
    {
        appendPQExpBufferStr(query, "SELECT tableoid, oid, proname AS aggname, "
                             "pronamespace AS aggnamespace, "
                             "pronargs, proargtypes, "
                             "proowner, "
                             "proacl AS aggacl, "
                             "acldefault('f', proowner) AS acldefault "
                             "FROM pg_proc p "
                             "WHERE proisagg AND ("
                             "pronamespace != "
                             "(SELECT oid FROM pg_namespace "
                             "WHERE nspname = 'pg_catalog')");
        if (dopt->binary_upgrade)
            appendPQExpBufferStr(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')");
        appendPQExpBufferChar(query, ')');
    }
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    agginfo = pg_malloc_array(AggInfo, ntups);
 
    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_proowner = PQfnumber(res, "proowner");
    i_aggacl = PQfnumber(res, "aggacl");
    i_acldefault = PQfnumber(res, "acldefault");
 
    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(atooid(PQgetvalue(res, i, i_aggnamespace)));
        agginfo[i].aggfn.dacl.acl = pg_strdup(PQgetvalue(res, i, i_aggacl));
        agginfo[i].aggfn.dacl.acldefault = pg_strdup(PQgetvalue(res, i, i_acldefault));
        agginfo[i].aggfn.dacl.privtype = 0;
        agginfo[i].aggfn.dacl.initprivs = NULL;
        agginfo[i].aggfn.rolname = getRoleName(PQgetvalue(res, i, i_proowner));
        agginfo[i].aggfn.lang = InvalidOid; /* not currently interesting */
        agginfo[i].aggfn.prorettype = InvalidOid;   /* not saved */
        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 = pg_malloc_array(Oid, agginfo[i].aggfn.nargs);
            parseOidArray(PQgetvalue(res, i, i_proargtypes),
                          agginfo[i].aggfn.argtypes,
                          agginfo[i].aggfn.nargs);
        }
        agginfo[i].aggfn.postponed_def = false; /* might get set during sort */
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(agginfo[i].aggfn.dobj), fout);
 
        /* Mark whether aggregate has an ACL */
        if (!PQgetisnull(res, i, i_aggacl))
            agginfo[i].aggfn.dobj.components |= DUMP_COMPONENT_ACL;
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBuffer(), appendPQExpBufferChar(), appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpOptions::binary_upgrade, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_AGG, Archive::dopt, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), fb(), findNamespace(), fout, getRoleName(), i, InvalidOid, parseOidArray(), pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, Archive::remoteVersion, and selectDumpableObject().

Referenced by getSchemaData().

getCasts()

void getCasts ( Archive *  fout )

extern

Definition at line 9137 of file pg_dump.c.

{
    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;
 
    if (fout->remoteVersion >= 140000)
    {
        appendPQExpBufferStr(query, "SELECT tableoid, oid, "
                             "castsource, casttarget, castfunc, castcontext, "
                             "castmethod "
                             "FROM pg_cast c "
                             "WHERE NOT EXISTS ( "
                             "SELECT 1 FROM pg_range r "
                             "WHERE c.castsource = r.rngtypid "
                             "AND c.casttarget = r.rngmultitypid "
                             ") "
                             "ORDER BY 3,4");
    }
    else
    {
        appendPQExpBufferStr(query, "SELECT tableoid, oid, "
                             "castsource, casttarget, castfunc, castcontext, "
                             "castmethod "
                             "FROM pg_cast ORDER BY 3,4");
    }
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    castinfo = pg_malloc_array(CastInfo, ntups);
 
    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;
 
        /* Decide whether we want to dump it */
        selectDumpableCast(&(castinfo[i]), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBuffer(), appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_CAST, _typeInfo::dobj, ExecuteSqlQuery(), fb(), findTypeByOid(), fout, i, initPQExpBuffer(), _dumpableObject::objType, pg_malloc_array, PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, Archive::remoteVersion, and selectDumpableCast().

Referenced by getSchemaData().

getCollations()

void getCollations ( Archive *  fout )

extern

Definition at line 6534 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    CollInfo   *collinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_collname;
    int         i_collnamespace;
    int         i_collowner;
    int         i_collencoding;
 
    query = createPQExpBuffer();
 
    /*
     * find all collations, including builtin collations; we filter out
     * system-defined collations at dump-out time.
     */
 
    appendPQExpBufferStr(query, "SELECT tableoid, oid, collname, "
                         "collnamespace, "
                         "collowner, "
                         "collencoding "
                         "FROM pg_collation");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    collinfo = pg_malloc_array(CollInfo, ntups);
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_collname = PQfnumber(res, "collname");
    i_collnamespace = PQfnumber(res, "collnamespace");
    i_collowner = PQfnumber(res, "collowner");
    i_collencoding = PQfnumber(res, "collencoding");
 
    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(atooid(PQgetvalue(res, i, i_collnamespace)));
        collinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_collowner));
        collinfo[i].collencoding = atoi(PQgetvalue(res, i, i_collencoding));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(collinfo[i].dobj), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_COLLATION, ExecuteSqlQuery(), fb(), findNamespace(), fout, getRoleName(), i, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, and selectDumpableObject().

Referenced by getSchemaData().

getConstraints()

void getConstraints ( Archive *  fout, TableInfo  tblinfo[], int  numTables  )

extern

Definition at line 8388 of file pg_dump.c.

{
    PQExpBuffer query = createPQExpBuffer();
    PQExpBuffer tbloids = createPQExpBuffer();
    PGresult   *res;
    int         ntups;
    int         curtblindx;
    TableInfo  *tbinfo = NULL;
    ConstraintInfo *constrinfo;
    int         i_contableoid,
                i_conoid,
                i_conrelid,
                i_conname,
                i_confrelid,
                i_conindid,
                i_condef;
 
    /*
     * We want to perform just one query against pg_constraint.  However, we
     * mustn't try to select every row of the catalog and then sort it out on
     * the client side, because some of the server-side functions we need
     * would be unsafe to apply to tables we don't have lock on.  Hence, we
     * build an array of the OIDs of tables we care about (and now have lock
     * on!), and use a WHERE clause to constrain which rows are selected.
     */
    appendPQExpBufferChar(tbloids, '{');
    for (int i = 0; i < numTables; i++)
    {
        TableInfo  *tinfo = &tblinfo[i];
 
        if (!(tinfo->dobj.dump & DUMP_COMPONENT_DEFINITION))
            continue;
 
        /* OK, we need info for this table */
        if (tbloids->len > 1)   /* do we have more than the '{'? */
            appendPQExpBufferChar(tbloids, ',');
        appendPQExpBuffer(tbloids, "%u", tinfo->dobj.catId.oid);
    }
    appendPQExpBufferChar(tbloids, '}');
 
    appendPQExpBufferStr(query,
                         "SELECT c.tableoid, c.oid, "
                         "conrelid, conname, confrelid, ");
    if (fout->remoteVersion >= 110000)
        appendPQExpBufferStr(query, "conindid, ");
    else
        appendPQExpBufferStr(query, "0 AS conindid, ");
    appendPQExpBuffer(query,
                      "pg_catalog.pg_get_constraintdef(c.oid) AS condef\n"
                      "FROM unnest('%s'::pg_catalog.oid[]) AS src(tbloid)\n"
                      "JOIN pg_catalog.pg_constraint c ON (src.tbloid = c.conrelid)\n"
                      "WHERE contype = 'f' ",
                      tbloids->data);
    if (fout->remoteVersion >= 110000)
        appendPQExpBufferStr(query,
                             "AND conparentid = 0 ");
    appendPQExpBufferStr(query,
                         "ORDER BY conrelid, conname");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    i_contableoid = PQfnumber(res, "tableoid");
    i_conoid = PQfnumber(res, "oid");
    i_conrelid = PQfnumber(res, "conrelid");
    i_conname = PQfnumber(res, "conname");
    i_confrelid = PQfnumber(res, "confrelid");
    i_conindid = PQfnumber(res, "conindid");
    i_condef = PQfnumber(res, "condef");
 
    constrinfo = pg_malloc_array(ConstraintInfo, ntups);
 
    curtblindx = -1;
    for (int j = 0; j < ntups; j++)
    {
        Oid         conrelid = atooid(PQgetvalue(res, j, i_conrelid));
        TableInfo  *reftable;
 
        /*
         * Locate the associated TableInfo; we rely on tblinfo[] being in OID
         * order.
         */
        if (tbinfo == NULL || tbinfo->dobj.catId.oid != conrelid)
        {
            while (++curtblindx < numTables)
            {
                tbinfo = &tblinfo[curtblindx];
                if (tbinfo->dobj.catId.oid == conrelid)
                    break;
            }
            if (curtblindx >= numTables)
                pg_fatal("unrecognized table OID %u", conrelid);
        }
 
        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;
 
        /*
         * Restoring an FK that points to a partitioned table requires that
         * all partition indexes have been attached beforehand. Ensure that
         * happens by making the constraint depend on each index partition
         * attach object.
         */
        reftable = findTableByOid(constrinfo[j].confrelid);
        if (reftable && reftable->relkind == RELKIND_PARTITIONED_TABLE)
        {
            Oid         indexOid = atooid(PQgetvalue(res, j, i_conindid));
 
            if (indexOid != InvalidOid)
            {
                for (int k = 0; k < reftable->numIndexes; k++)
                {
                    IndxInfo   *refidx;
 
                    /* not our index? */
                    if (reftable->indexes[k].dobj.catId.oid != indexOid)
                        continue;
 
                    refidx = &reftable->indexes[k];
                    addConstrChildIdxDeps(&constrinfo[j].dobj, refidx);
                    break;
                }
            }
        }
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
    destroyPQExpBuffer(tbloids);
}

References addConstrChildIdxDeps(), appendPQExpBuffer(), appendPQExpBufferChar(), appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_FK_CONSTRAINT, DUMP_COMPONENT_DEFINITION, ExecuteSqlQuery(), fb(), findTableByOid(), fout, i, InvalidOid, j, pg_fatal, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, Archive::remoteVersion, and tinfo.

Referenced by getSchemaData().

getConversions()

void getConversions ( Archive *  fout )

extern

Definition at line 6600 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    ConvInfo   *convinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_conname;
    int         i_connamespace;
    int         i_conowner;
 
    query = createPQExpBuffer();
 
    /*
     * find all conversions, including builtin conversions; we filter out
     * system-defined conversions at dump-out time.
     */
 
    appendPQExpBufferStr(query, "SELECT tableoid, oid, conname, "
                         "connamespace, "
                         "conowner "
                         "FROM pg_conversion");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    convinfo = pg_malloc_array(ConvInfo, ntups);
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_conname = PQfnumber(res, "conname");
    i_connamespace = PQfnumber(res, "connamespace");
    i_conowner = PQfnumber(res, "conowner");
 
    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(atooid(PQgetvalue(res, i, i_connamespace)));
        convinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_conowner));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(convinfo[i].dobj), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_CONVERSION, ExecuteSqlQuery(), fb(), findNamespace(), fout, getRoleName(), i, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, and selectDumpableObject().

Referenced by getSchemaData().

getDefaultACLs()

void getDefaultACLs ( Archive *  fout )

extern

Definition at line 10701 of file pg_dump.c.

{
    DumpOptions *dopt = fout->dopt;
    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_acldefault;
    int         i,
                ntups;
 
    query = createPQExpBuffer();
 
    /*
     * Global entries (with defaclnamespace=0) replace the hard-wired default
     * ACL for their object type.  We should dump them as deltas from the
     * default ACL, since that will be used as a starting point for
     * interpreting the ALTER DEFAULT PRIVILEGES commands.  On the other hand,
     * non-global entries can only add privileges not revoke them.  We must
     * dump those as-is (i.e., as deltas from an empty ACL).
     *
     * We can use defaclobjtype as the object type for acldefault(), except
     * for the case of 'S' (DEFACLOBJ_SEQUENCE) which must be converted to
     * 's'.
     */
    appendPQExpBufferStr(query,
                         "SELECT oid, tableoid, "
                         "defaclrole, "
                         "defaclnamespace, "
                         "defaclobjtype, "
                         "defaclacl, "
                         "CASE WHEN defaclnamespace = 0 THEN "
                         "acldefault(CASE WHEN defaclobjtype = 'S' "
                         "THEN 's'::\"char\" ELSE defaclobjtype END, "
                         "defaclrole) ELSE '{}' END AS acldefault "
                         "FROM pg_default_acl");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    daclinfo = pg_malloc_array(DefaultACLInfo, ntups);
 
    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");
    i_acldefault = PQfnumber(res, "acldefault");
 
    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(nspid);
        else
            daclinfo[i].dobj.namespace = NULL;
 
        daclinfo[i].dacl.acl = pg_strdup(PQgetvalue(res, i, i_defaclacl));
        daclinfo[i].dacl.acldefault = pg_strdup(PQgetvalue(res, i, i_acldefault));
        daclinfo[i].dacl.privtype = 0;
        daclinfo[i].dacl.initprivs = NULL;
        daclinfo[i].defaclrole = getRoleName(PQgetvalue(res, i, i_defaclrole));
        daclinfo[i].defaclobjtype = *(PQgetvalue(res, i, i_defaclobjtype));
 
        /* Default ACLs are ACLs, of course */
        daclinfo[i].dobj.components |= DUMP_COMPONENT_ACL;
 
        /* Decide whether we want to dump it */
        selectDumpableDefaultACL(&(daclinfo[i]), dopt);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_DEFAULT_ACL, Archive::dopt, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), fb(), findNamespace(), fout, getRoleName(), i, InvalidOid, nspid, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, and selectDumpableDefaultACL().

Referenced by getSchemaData().

getDumpableObjects()

void getDumpableObjects ( DumpableObject ***  objs, int *  numObjs  )

extern

Definition at line 798 of file common.c.

{
    int         i,
                j;
 
    *objs = pg_malloc_array(DumpableObject *, allocedDumpIds);
    j = 0;
    for (i = 1; i < allocedDumpIds; i++)
    {
        if (dumpIdMap[i])
            (*objs)[j++] = dumpIdMap[i];
    }
    *numObjs = j;
}

References allocedDumpIds, dumpIdMap, fb(), i, j, and pg_malloc_array.

Referenced by getTableDataFKConstraints(), and main().

getEventTriggers()

void getEventTriggers ( Archive *  fout )

extern

Definition at line 8975 of file pg_dump.c.

{
    int         i;
    PQExpBuffer query;
    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)
        return;
 
    query = createPQExpBuffer();
 
    appendPQExpBufferStr(query,
                         "SELECT e.tableoid, e.oid, evtname, evtenabled, "
                         "evtevent, 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");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    evtinfo = pg_malloc_array(EventTriggerInfo, ntups);
 
    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 = getRoleName(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));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(evtinfo[i].dobj), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_EVENT_TRIGGER, ExecuteSqlQuery(), fb(), fout, getRoleName(), i, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, Archive::remoteVersion, and selectDumpableObject().

Referenced by getSchemaData().

getExtendedStatistics()

void getExtendedStatistics ( Archive *  fout )

extern

Definition at line 8306 of file pg_dump.c.

{
    PQExpBuffer query;
    PGresult   *res;
    StatsExtInfo *statsextinfo;
    int         ntups;
    int         i_tableoid;
    int         i_oid;
    int         i_stxname;
    int         i_stxnamespace;
    int         i_stxowner;
    int         i_stxrelid;
    int         i_stattarget;
    int         i;
 
    /* Extended statistics were new in v10 */
    if (fout->remoteVersion < 100000)
        return;
 
    query = createPQExpBuffer();
 
    if (fout->remoteVersion < 130000)
        appendPQExpBufferStr(query, "SELECT tableoid, oid, stxname, "
                             "stxnamespace, stxowner, stxrelid, NULL AS stxstattarget "
                             "FROM pg_catalog.pg_statistic_ext");
    else
        appendPQExpBufferStr(query, "SELECT tableoid, oid, stxname, "
                             "stxnamespace, stxowner, stxrelid, stxstattarget "
                             "FROM pg_catalog.pg_statistic_ext");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_stxname = PQfnumber(res, "stxname");
    i_stxnamespace = PQfnumber(res, "stxnamespace");
    i_stxowner = PQfnumber(res, "stxowner");
    i_stxrelid = PQfnumber(res, "stxrelid");
    i_stattarget = PQfnumber(res, "stxstattarget");
 
    statsextinfo = pg_malloc_array(StatsExtInfo, ntups);
 
    for (i = 0; i < ntups; i++)
    {
        statsextinfo[i].dobj.objType = DO_STATSEXT;
        statsextinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        statsextinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&statsextinfo[i].dobj);
        statsextinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_stxname));
        statsextinfo[i].dobj.namespace =
            findNamespace(atooid(PQgetvalue(res, i, i_stxnamespace)));
        statsextinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_stxowner));
        statsextinfo[i].stattable =
            findTableByOid(atooid(PQgetvalue(res, i, i_stxrelid)));
        if (PQgetisnull(res, i, i_stattarget))
            statsextinfo[i].stattarget = -1;
        else
            statsextinfo[i].stattarget = atoi(PQgetvalue(res, i, i_stattarget));
 
        /* Decide whether we want to dump it */
        selectDumpableStatisticsObject(&(statsextinfo[i]), fout);
 
        if (fout->dopt->dumpStatistics)
            statsextinfo[i].dobj.components |= DUMP_COMPONENT_STATISTICS;
    }
 
    PQclear(res);
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_STATSEXT, Archive::dopt, DUMP_COMPONENT_STATISTICS, _dumpOptions::dumpStatistics, ExecuteSqlQuery(), fb(), findNamespace(), findTableByOid(), fout, getRoleName(), i, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, Archive::remoteVersion, and selectDumpableStatisticsObject().

Referenced by getSchemaData().

getExtensionMembership()

void getExtensionMembership ( Archive *  fout, ExtensionInfo  extinfo[], int  numExtensions  )

extern

Definition at line 20195 of file pg_dump.c.

{
    PQExpBuffer query;
    PGresult   *res;
    int         ntups,
                i;
    int         i_classid,
                i_objid,
                i_refobjid;
    ExtensionInfo *ext;
 
    /* Nothing to do if no extensions */
    if (numExtensions == 0)
        return;
 
    query = createPQExpBuffer();
 
    /* refclassid constraint is redundant but may speed the search */
    appendPQExpBufferStr(query, "SELECT "
                         "classid, objid, refobjid "
                         "FROM pg_depend "
                         "WHERE refclassid = 'pg_extension'::regclass "
                         "AND deptype = 'e' "
                         "ORDER BY 3");
 
    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");
 
    /*
     * Since we ordered the SELECT by referenced ID, we can expect that
     * multiple entries for the same extension will appear together; this
     * saves on searches.
     */
    ext = NULL;
 
    for (i = 0; i < ntups; i++)
    {
        CatalogId   objId;
        Oid         extId;
 
        objId.tableoid = atooid(PQgetvalue(res, i, i_classid));
        objId.oid = atooid(PQgetvalue(res, i, i_objid));
        extId = atooid(PQgetvalue(res, i, i_refobjid));
 
        if (ext == NULL ||
            ext->dobj.catId.oid != extId)
            ext = findExtensionByOid(extId);
 
        if (ext == NULL)
        {
            /* shouldn't happen */
            pg_log_warning("could not find referenced extension %u", extId);
            continue;
        }
 
        recordExtensionMembership(objId, ext);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), _extensionInfo::dobj, ExecuteSqlQuery(), fb(), findExtensionByOid(), fout, i, CatalogId::oid, pg_log_warning, PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, recordExtensionMembership(), and CatalogId::tableoid.

Referenced by getSchemaData().

getExtensions()

ExtensionInfo * getExtensions ( Archive *  fout, int *  numExtensions  )

extern

Definition at line 6215 of file pg_dump.c.

{
    DumpOptions *dopt = fout->dopt;
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    ExtensionInfo *extinfo = NULL;
    int         i_tableoid;
    int         i_oid;
    int         i_extname;
    int         i_nspname;
    int         i_extrelocatable;
    int         i_extversion;
    int         i_extconfig;
    int         i_extcondition;
 
    query = createPQExpBuffer();
 
    appendPQExpBufferStr(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);
    if (ntups == 0)
        goto cleanup;
 
    extinfo = pg_malloc_array(ExtensionInfo, ntups);
 
    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]), dopt);
    }
 
cleanup:
    PQclear(res);
    destroyPQExpBuffer(query);
 
    *numExtensions = ntups;
 
    return extinfo;
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, cleanup(), createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_EXTENSION, Archive::dopt, ExecuteSqlQuery(), fb(), fout, i, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, and selectDumpableExtension().

Referenced by getSchemaData().

getForeignDataWrappers()

void getForeignDataWrappers ( Archive *  fout )

extern

Definition at line 10519 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    FdwInfo    *fdwinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_fdwname;
    int         i_fdwowner;
    int         i_fdwhandler;
    int         i_fdwvalidator;
    int         i_fdwconnection;
    int         i_fdwacl;
    int         i_acldefault;
    int         i_fdwoptions;
 
    query = createPQExpBuffer();
 
    appendPQExpBufferStr(query, "SELECT tableoid, oid, fdwname, "
                         "fdwowner, "
                         "fdwhandler::pg_catalog.regproc, "
                         "fdwvalidator::pg_catalog.regproc, ");
 
    if (fout->remoteVersion >= 190000)
        appendPQExpBufferStr(query, "fdwconnection::pg_catalog.regproc, ");
    else
        appendPQExpBufferStr(query, "'-' AS fdwconnection, ");
 
    appendPQExpBufferStr(query,
                         "fdwacl, "
                         "acldefault('F', fdwowner) AS acldefault, "
                         "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");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    fdwinfo = pg_malloc_array(FdwInfo, ntups);
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_fdwname = PQfnumber(res, "fdwname");
    i_fdwowner = PQfnumber(res, "fdwowner");
    i_fdwhandler = PQfnumber(res, "fdwhandler");
    i_fdwvalidator = PQfnumber(res, "fdwvalidator");
    i_fdwconnection = PQfnumber(res, "fdwconnection");
    i_fdwacl = PQfnumber(res, "fdwacl");
    i_acldefault = PQfnumber(res, "acldefault");
    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].dacl.acl = pg_strdup(PQgetvalue(res, i, i_fdwacl));
        fdwinfo[i].dacl.acldefault = pg_strdup(PQgetvalue(res, i, i_acldefault));
        fdwinfo[i].dacl.privtype = 0;
        fdwinfo[i].dacl.initprivs = NULL;
        fdwinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_fdwowner));
        fdwinfo[i].fdwhandler = pg_strdup(PQgetvalue(res, i, i_fdwhandler));
        fdwinfo[i].fdwvalidator = pg_strdup(PQgetvalue(res, i, i_fdwvalidator));
        fdwinfo[i].fdwconnection = pg_strdup(PQgetvalue(res, i, i_fdwconnection));
        fdwinfo[i].fdwoptions = pg_strdup(PQgetvalue(res, i, i_fdwoptions));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(fdwinfo[i].dobj), fout);
 
        /* Mark whether FDW has an ACL */
        if (!PQgetisnull(res, i, i_fdwacl))
            fdwinfo[i].dobj.components |= DUMP_COMPONENT_ACL;
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_FDW, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), fb(), fout, getRoleName(), i, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, Archive::remoteVersion, and selectDumpableObject().

Referenced by getSchemaData().

getForeignServers()

void getForeignServers ( Archive *  fout )

extern

Definition at line 10613 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    ForeignServerInfo *srvinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_srvname;
    int         i_srvowner;
    int         i_srvfdw;
    int         i_srvtype;
    int         i_srvversion;
    int         i_srvacl;
    int         i_acldefault;
    int         i_srvoptions;
 
    query = createPQExpBuffer();
 
    appendPQExpBufferStr(query, "SELECT tableoid, oid, srvname, "
                         "srvowner, "
                         "srvfdw, srvtype, srvversion, srvacl, "
                         "acldefault('S', srvowner) AS acldefault, "
                         "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");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    srvinfo = pg_malloc_array(ForeignServerInfo, ntups);
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_srvname = PQfnumber(res, "srvname");
    i_srvowner = PQfnumber(res, "srvowner");
    i_srvfdw = PQfnumber(res, "srvfdw");
    i_srvtype = PQfnumber(res, "srvtype");
    i_srvversion = PQfnumber(res, "srvversion");
    i_srvacl = PQfnumber(res, "srvacl");
    i_acldefault = PQfnumber(res, "acldefault");
    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].dacl.acl = pg_strdup(PQgetvalue(res, i, i_srvacl));
        srvinfo[i].dacl.acldefault = pg_strdup(PQgetvalue(res, i, i_acldefault));
        srvinfo[i].dacl.privtype = 0;
        srvinfo[i].dacl.initprivs = NULL;
        srvinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_srvowner));
        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));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(srvinfo[i].dobj), fout);
 
        /* Servers have user mappings */
        srvinfo[i].dobj.components |= DUMP_COMPONENT_USERMAP;
 
        /* Mark whether server has an ACL */
        if (!PQgetisnull(res, i, i_srvacl))
            srvinfo[i].dobj.components |= DUMP_COMPONENT_ACL;
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_FOREIGN_SERVER, DUMP_COMPONENT_ACL, DUMP_COMPONENT_USERMAP, ExecuteSqlQuery(), fb(), fout, getRoleName(), i, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, and selectDumpableObject().

Referenced by getSchemaData().

getFuncs()

void getFuncs ( Archive *  fout )

extern

Definition at line 7005 of file pg_dump.c.

{
    DumpOptions *dopt = fout->dopt;
    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_proowner;
    int         i_prolang;
    int         i_pronargs;
    int         i_proargtypes;
    int         i_prorettype;
    int         i_proacl;
    int         i_acldefault;
 
    /*
     * Find all interesting functions.  This is a bit complicated:
     *
     * 1. Always exclude aggregates; those are handled elsewhere.
     *
     * 2. Always 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 acts only to suppress constructor
     * functions for range types.  Note 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.
     *
     * 3. Otherwise, we normally exclude functions in pg_catalog.  However, if
     * they're members of extensions and we are in binary-upgrade mode then
     * include them, since we want to dump extension members individually in
     * that mode.  Also, if they are used by casts or transforms then we need
     * to gather the information about them, though they won't be dumped if
     * they are built-in.  Also, in 9.6 and up, include functions in
     * pg_catalog if they have an ACL different from what's shown in
     * pg_init_privs (so we have to join to pg_init_privs; annoying).
     */
    if (fout->remoteVersion >= 90600)
    {
        const char *not_agg_check;
 
        not_agg_check = (fout->remoteVersion >= 110000 ? "p.prokind <> 'a'"
                         : "NOT p.proisagg");
 
        appendPQExpBuffer(query,
                          "SELECT p.tableoid, p.oid, p.proname, p.prolang, "
                          "p.pronargs, p.proargtypes, p.prorettype, "
                          "p.proacl, "
                          "acldefault('f', p.proowner) AS acldefault, "
                          "p.pronamespace, "
                          "p.proowner "
                          "FROM pg_proc p "
                          "LEFT JOIN pg_init_privs pip ON "
                          "(p.oid = pip.objoid "
                          "AND pip.classoid = 'pg_proc'::regclass "
                          "AND pip.objsubid = 0) "
                          "WHERE %s"
                          "\n  AND NOT EXISTS (SELECT 1 FROM pg_depend "
                          "WHERE classid = 'pg_proc'::regclass AND "
                          "objid = p.oid AND deptype = 'i')"
                          "\n  AND ("
                          "\n  pronamespace != "
                          "(SELECT oid FROM pg_namespace "
                          "WHERE nspname = 'pg_catalog')"
                          "\n  OR EXISTS (SELECT 1 FROM pg_cast"
                          "\n  WHERE pg_cast.oid > %u "
                          "\n  AND p.oid = pg_cast.castfunc)"
                          "\n  OR EXISTS (SELECT 1 FROM pg_transform"
                          "\n  WHERE pg_transform.oid > %u AND "
                          "\n  (p.oid = pg_transform.trffromsql"
                          "\n  OR p.oid = pg_transform.trftosql))",
                          not_agg_check,
                          g_last_builtin_oid,
                          g_last_builtin_oid);
        if (dopt->binary_upgrade)
            appendPQExpBufferStr(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')");
        appendPQExpBufferStr(query,
                             "\n  OR p.proacl IS DISTINCT FROM pip.initprivs");
        appendPQExpBufferChar(query, ')');
    }
    else
    {
        appendPQExpBuffer(query,
                          "SELECT tableoid, oid, proname, prolang, "
                          "pronargs, proargtypes, prorettype, proacl, "
                          "acldefault('f', proowner) AS acldefault, "
                          "pronamespace, "
                          "proowner "
                          "FROM pg_proc p "
                          "WHERE NOT proisagg"
                          "\n  AND NOT EXISTS (SELECT 1 FROM pg_depend "
                          "WHERE classid = 'pg_proc'::regclass AND "
                          "objid = p.oid AND deptype = 'i')"
                          "\n  AND ("
                          "\n  pronamespace != "
                          "(SELECT oid FROM pg_namespace "
                          "WHERE nspname = 'pg_catalog')"
                          "\n  OR EXISTS (SELECT 1 FROM pg_cast"
                          "\n  WHERE pg_cast.oid > '%u'::oid"
                          "\n  AND p.oid = pg_cast.castfunc)",
                          g_last_builtin_oid);
 
        if (fout->remoteVersion >= 90500)
            appendPQExpBuffer(query,
                              "\n  OR EXISTS (SELECT 1 FROM pg_transform"
                              "\n  WHERE pg_transform.oid > '%u'::oid"
                              "\n  AND (p.oid = pg_transform.trffromsql"
                              "\n  OR p.oid = pg_transform.trftosql))",
                              g_last_builtin_oid);
 
        if (dopt->binary_upgrade)
            appendPQExpBufferStr(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')");
        appendPQExpBufferChar(query, ')');
    }
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    finfo = pg_malloc0_array(FuncInfo, ntups);
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_proname = PQfnumber(res, "proname");
    i_pronamespace = PQfnumber(res, "pronamespace");
    i_proowner = PQfnumber(res, "proowner");
    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_acldefault = PQfnumber(res, "acldefault");
 
    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(atooid(PQgetvalue(res, i, i_pronamespace)));
        finfo[i].dacl.acl = pg_strdup(PQgetvalue(res, i, i_proacl));
        finfo[i].dacl.acldefault = pg_strdup(PQgetvalue(res, i, i_acldefault));
        finfo[i].dacl.privtype = 0;
        finfo[i].dacl.initprivs = NULL;
        finfo[i].rolname = getRoleName(PQgetvalue(res, i, i_proowner));
        finfo[i].lang = atooid(PQgetvalue(res, i, i_prolang));
        finfo[i].prorettype = atooid(PQgetvalue(res, i, i_prorettype));
        finfo[i].nargs = atoi(PQgetvalue(res, i, i_pronargs));
        if (finfo[i].nargs == 0)
            finfo[i].argtypes = NULL;
        else
        {
            finfo[i].argtypes = pg_malloc_array(Oid, finfo[i].nargs);
            parseOidArray(PQgetvalue(res, i, i_proargtypes),
                          finfo[i].argtypes, finfo[i].nargs);
        }
        finfo[i].postponed_def = false; /* might get set during sort */
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(finfo[i].dobj), fout);
 
        /* Mark whether function has an ACL */
        if (!PQgetisnull(res, i, i_proacl))
            finfo[i].dobj.components |= DUMP_COMPONENT_ACL;
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References _dumpableAcl::acl, _dumpableAcl::acldefault, appendPQExpBuffer(), appendPQExpBufferChar(), appendPQExpBufferStr(), _funcInfo::argtypes, AssignDumpId(), atooid, _dumpOptions::binary_upgrade, _dumpableObject::catId, _dumpableObject::components, createPQExpBuffer(), _funcInfo::dacl, PQExpBufferData::data, destroyPQExpBuffer(), DO_FUNC, _funcInfo::dobj, Archive::dopt, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), fb(), findNamespace(), fout, g_last_builtin_oid, getRoleName(), i, _dumpableAcl::initprivs, _funcInfo::lang, _dumpableObject::name, _funcInfo::nargs, _dumpableObject::objType, CatalogId::oid, parseOidArray(), pg_malloc0_array, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, _funcInfo::postponed_def, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, _dumpableAcl::privtype, _funcInfo::prorettype, Archive::remoteVersion, _funcInfo::rolname, selectDumpableObject(), and CatalogId::tableoid.

Referenced by getSchemaData().

getIndexes()

void getIndexes ( Archive *  fout, TableInfo  tblinfo[], int  numTables  )

extern

Definition at line 7937 of file pg_dump.c.

{
    PQExpBuffer query = createPQExpBuffer();
    PQExpBuffer tbloids = createPQExpBuffer();
    PGresult   *res;
    int         ntups;
    int         curtblindx;
    IndxInfo   *indxinfo;
    int         i_tableoid,
                i_oid,
                i_indrelid,
                i_indexname,
                i_relpages,
                i_reltuples,
                i_relallvisible,
                i_relallfrozen,
                i_parentidx,
                i_indexdef,
                i_indnkeyatts,
                i_indnatts,
                i_indkey,
                i_indisclustered,
                i_indisreplident,
                i_indnullsnotdistinct,
                i_contype,
                i_conname,
                i_condeferrable,
                i_condeferred,
                i_conperiod,
                i_contableoid,
                i_conoid,
                i_condef,
                i_indattnames,
                i_tablespace,
                i_indreloptions,
                i_indstatcols,
                i_indstatvals;
 
    /*
     * We want to perform just one query against pg_index.  However, we
     * mustn't try to select every row of the catalog and then sort it out on
     * the client side, because some of the server-side functions we need
     * would be unsafe to apply to tables we don't have lock on.  Hence, we
     * build an array of the OIDs of tables we care about (and now have lock
     * on!), and use a WHERE clause to constrain which rows are selected.
     */
    appendPQExpBufferChar(tbloids, '{');
    for (int i = 0; i < numTables; i++)
    {
        TableInfo  *tbinfo = &tblinfo[i];
 
        if (!tbinfo->hasindex)
            continue;
 
        /*
         * We can ignore indexes of uninteresting tables.
         */
        if (!tbinfo->interesting)
            continue;
 
        /* OK, we need info for this table */
        if (tbloids->len > 1)   /* do we have more than the '{'? */
            appendPQExpBufferChar(tbloids, ',');
        appendPQExpBuffer(tbloids, "%u", tbinfo->dobj.catId.oid);
    }
    appendPQExpBufferChar(tbloids, '}');
 
    appendPQExpBufferStr(query,
                         "SELECT t.tableoid, t.oid, i.indrelid, "
                         "t.relname AS indexname, "
                         "t.relpages, t.reltuples, t.relallvisible, ");
 
    if (fout->remoteVersion >= 180000)
        appendPQExpBufferStr(query, "t.relallfrozen, ");
    else
        appendPQExpBufferStr(query, "0 AS relallfrozen, ");
 
    appendPQExpBufferStr(query,
                         "pg_catalog.pg_get_indexdef(i.indexrelid) AS indexdef, "
                         "i.indkey, i.indisclustered, "
                         "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, "
                         "CASE WHEN i.indexprs IS NOT NULL THEN "
                         "(SELECT pg_catalog.array_agg(attname ORDER BY attnum)"
                         "  FROM pg_catalog.pg_attribute "
                         "  WHERE attrelid = i.indexrelid) "
                         "ELSE NULL END AS indattnames, "
                         "(SELECT spcname FROM pg_catalog.pg_tablespace s WHERE s.oid = t.reltablespace) AS tablespace, "
                         "t.reloptions AS indreloptions, ");
 
 
    if (fout->remoteVersion >= 90400)
        appendPQExpBufferStr(query,
                             "i.indisreplident, ");
    else
        appendPQExpBufferStr(query,
                             "false AS indisreplident, ");
 
    if (fout->remoteVersion >= 110000)
        appendPQExpBufferStr(query,
                             "inh.inhparent AS parentidx, "
                             "i.indnkeyatts AS indnkeyatts, "
                             "i.indnatts AS indnatts, "
                             "(SELECT pg_catalog.array_agg(attnum ORDER BY attnum) "
                             "  FROM pg_catalog.pg_attribute "
                             "  WHERE attrelid = i.indexrelid AND "
                             "    attstattarget >= 0) AS indstatcols, "
                             "(SELECT pg_catalog.array_agg(attstattarget ORDER BY attnum) "
                             "  FROM pg_catalog.pg_attribute "
                             "  WHERE attrelid = i.indexrelid AND "
                             "    attstattarget >= 0) AS indstatvals, ");
    else
        appendPQExpBufferStr(query,
                             "0 AS parentidx, "
                             "i.indnatts AS indnkeyatts, "
                             "i.indnatts AS indnatts, "
                             "'' AS indstatcols, "
                             "'' AS indstatvals, ");
 
    if (fout->remoteVersion >= 150000)
        appendPQExpBufferStr(query,
                             "i.indnullsnotdistinct, ");
    else
        appendPQExpBufferStr(query,
                             "false AS indnullsnotdistinct, ");
 
    if (fout->remoteVersion >= 180000)
        appendPQExpBufferStr(query,
                             "c.conperiod ");
    else
        appendPQExpBufferStr(query,
                             "NULL AS conperiod ");
 
    /*
     * 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.
     *
     * Note: the check on conrelid is redundant, but useful because that
     * column is indexed while conindid is not.
     */
    if (fout->remoteVersion >= 110000)
    {
        appendPQExpBuffer(query,
                          "FROM unnest('%s'::pg_catalog.oid[]) AS src(tbloid)\n"
                          "JOIN pg_catalog.pg_index i ON (src.tbloid = i.indrelid) "
                          "JOIN pg_catalog.pg_class t ON (t.oid = i.indexrelid) "
                          "JOIN pg_catalog.pg_class t2 ON (t2.oid = i.indrelid) "
                          "LEFT JOIN pg_catalog.pg_constraint c "
                          "ON (i.indrelid = c.conrelid AND "
                          "i.indexrelid = c.conindid AND "
                          "c.contype IN ('p','u','x')) "
                          "LEFT JOIN pg_catalog.pg_inherits inh "
                          "ON (inh.inhrelid = indexrelid) "
                          "WHERE (i.indisvalid OR t2.relkind = 'p') "
                          "AND i.indisready "
                          "ORDER BY i.indrelid, indexname",
                          tbloids->data);
    }
    else
    {
        /*
         * the test on indisready is necessary in 9.2, and harmless in
         * earlier/later versions
         */
        appendPQExpBuffer(query,
                          "FROM unnest('%s'::pg_catalog.oid[]) AS src(tbloid)\n"
                          "JOIN pg_catalog.pg_index i ON (src.tbloid = i.indrelid) "
                          "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.indisvalid AND i.indisready "
                          "ORDER BY i.indrelid, indexname",
                          tbloids->data);
    }
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_indrelid = PQfnumber(res, "indrelid");
    i_indexname = PQfnumber(res, "indexname");
    i_relpages = PQfnumber(res, "relpages");
    i_reltuples = PQfnumber(res, "reltuples");
    i_relallvisible = PQfnumber(res, "relallvisible");
    i_relallfrozen = PQfnumber(res, "relallfrozen");
    i_parentidx = PQfnumber(res, "parentidx");
    i_indexdef = PQfnumber(res, "indexdef");
    i_indnkeyatts = PQfnumber(res, "indnkeyatts");
    i_indnatts = PQfnumber(res, "indnatts");
    i_indkey = PQfnumber(res, "indkey");
    i_indisclustered = PQfnumber(res, "indisclustered");
    i_indisreplident = PQfnumber(res, "indisreplident");
    i_indnullsnotdistinct = PQfnumber(res, "indnullsnotdistinct");
    i_contype = PQfnumber(res, "contype");
    i_conname = PQfnumber(res, "conname");
    i_condeferrable = PQfnumber(res, "condeferrable");
    i_condeferred = PQfnumber(res, "condeferred");
    i_conperiod = PQfnumber(res, "conperiod");
    i_contableoid = PQfnumber(res, "contableoid");
    i_conoid = PQfnumber(res, "conoid");
    i_condef = PQfnumber(res, "condef");
    i_indattnames = PQfnumber(res, "indattnames");
    i_tablespace = PQfnumber(res, "tablespace");
    i_indreloptions = PQfnumber(res, "indreloptions");
    i_indstatcols = PQfnumber(res, "indstatcols");
    i_indstatvals = PQfnumber(res, "indstatvals");
 
    indxinfo = pg_malloc_array(IndxInfo, ntups);
 
    /*
     * Outer loop iterates once per table, not once per row.  Incrementing of
     * j is handled by the inner loop.
     */
    curtblindx = -1;
    for (int j = 0; j < ntups;)
    {
        Oid         indrelid = atooid(PQgetvalue(res, j, i_indrelid));
        TableInfo  *tbinfo = NULL;
        char      **indAttNames = NULL;
        int         nindAttNames = 0;
        int         numinds;
 
        /* Count rows for this table */
        for (numinds = 1; numinds < ntups - j; numinds++)
            if (atooid(PQgetvalue(res, j + numinds, i_indrelid)) != indrelid)
                break;
 
        /*
         * Locate the associated TableInfo; we rely on tblinfo[] being in OID
         * order.
         */
        while (++curtblindx < numTables)
        {
            tbinfo = &tblinfo[curtblindx];
            if (tbinfo->dobj.catId.oid == indrelid)
                break;
        }
        if (curtblindx >= numTables)
            pg_fatal("unrecognized table OID %u", indrelid);
        /* cross-check that we only got requested tables */
        if (!tbinfo->hasindex ||
            !tbinfo->interesting)
            pg_fatal("unexpected index data for table \"%s\"",
                     tbinfo->dobj.name);
 
        /* Save data for this table */
        tbinfo->indexes = indxinfo + j;
        tbinfo->numIndexes = numinds;
 
        for (int c = 0; c < numinds; c++, j++)
        {
            char        contype;
            char        indexkind;
            RelStatsInfo *relstats;
            int32       relpages = atoi(PQgetvalue(res, j, i_relpages));
            int32       relallvisible = atoi(PQgetvalue(res, j, i_relallvisible));
            int32       relallfrozen = atoi(PQgetvalue(res, j, i_relallfrozen));
 
            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.dump = tbinfo->dobj.dump;
            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].indnkeyattrs = atoi(PQgetvalue(res, j, i_indnkeyatts));
            indxinfo[j].indnattrs = atoi(PQgetvalue(res, j, i_indnatts));
            indxinfo[j].tablespace = pg_strdup(PQgetvalue(res, j, i_tablespace));
            indxinfo[j].indreloptions = pg_strdup(PQgetvalue(res, j, i_indreloptions));
            indxinfo[j].indstatcols = pg_strdup(PQgetvalue(res, j, i_indstatcols));
            indxinfo[j].indstatvals = pg_strdup(PQgetvalue(res, j, i_indstatvals));
            indxinfo[j].indkeys = pg_malloc_array(Oid, indxinfo[j].indnattrs);
            parseOidArray(PQgetvalue(res, j, i_indkey),
                          indxinfo[j].indkeys, indxinfo[j].indnattrs);
            indxinfo[j].indisclustered = (PQgetvalue(res, j, i_indisclustered)[0] == 't');
            indxinfo[j].indisreplident = (PQgetvalue(res, j, i_indisreplident)[0] == 't');
            indxinfo[j].indnullsnotdistinct = (PQgetvalue(res, j, i_indnullsnotdistinct)[0] == 't');
            indxinfo[j].parentidx = atooid(PQgetvalue(res, j, i_parentidx));
            indxinfo[j].partattaches = (SimplePtrList)
            {
                NULL, NULL
            };
 
            if (indxinfo[j].parentidx == 0)
                indexkind = RELKIND_INDEX;
            else
                indexkind = RELKIND_PARTITIONED_INDEX;
 
            if (!PQgetisnull(res, j, i_indattnames))
            {
                if (!parsePGArray(PQgetvalue(res, j, i_indattnames),
                                  &indAttNames, &nindAttNames))
                    pg_fatal("could not parse %s array", "indattnames");
            }
 
            relstats = getRelationStatistics(fout, &indxinfo[j].dobj, relpages,
                                             PQgetvalue(res, j, i_reltuples),
                                             relallvisible, relallfrozen, indexkind,
                                             indAttNames, nindAttNames);
 
            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.
                 */
                ConstraintInfo *constrinfo;
 
                constrinfo = pg_malloc_object(ConstraintInfo);
                constrinfo->dobj.objType = DO_CONSTRAINT;
                constrinfo->dobj.catId.tableoid = atooid(PQgetvalue(res, j, i_contableoid));
                constrinfo->dobj.catId.oid = atooid(PQgetvalue(res, j, i_conoid));
                AssignDumpId(&constrinfo->dobj);
                constrinfo->dobj.dump = tbinfo->dobj.dump;
                constrinfo->dobj.name = pg_strdup(PQgetvalue(res, j, i_conname));
                constrinfo->dobj.namespace = tbinfo->dobj.namespace;
                constrinfo->contable = tbinfo;
                constrinfo->condomain = NULL;
                constrinfo->contype = contype;
                if (contype == 'x')
                    constrinfo->condef = pg_strdup(PQgetvalue(res, j, i_condef));
                else
                    constrinfo->condef = NULL;
                constrinfo->confrelid = InvalidOid;
                constrinfo->conindex = indxinfo[j].dobj.dumpId;
                constrinfo->condeferrable = *(PQgetvalue(res, j, i_condeferrable)) == 't';
                constrinfo->condeferred = *(PQgetvalue(res, j, i_condeferred)) == 't';
                constrinfo->conperiod = *(PQgetvalue(res, j, i_conperiod)) == 't';
                constrinfo->conislocal = true;
                constrinfo->separate = true;
 
                indxinfo[j].indexconstraint = constrinfo->dobj.dumpId;
                if (relstats != NULL)
                    addObjectDependency(&relstats->dobj, constrinfo->dobj.dumpId);
            }
            else
            {
                /* Plain secondary index */
                indxinfo[j].indexconstraint = 0;
            }
        }
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
    destroyPQExpBuffer(tbloids);
}

References addObjectDependency(), appendPQExpBuffer(), appendPQExpBufferChar(), appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_CONSTRAINT, DO_INDEX, ExecuteSqlQuery(), fb(), fout, getRelationStatistics(), i, InvalidOid, j, parseOidArray(), parsePGArray(), pg_fatal, pg_malloc_array, pg_malloc_object, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, and Archive::remoteVersion.

Referenced by getSchemaData().

getInherits()

InhInfo * getInherits ( Archive *  fout, int *  numInherits  )

extern

Definition at line 7821 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    InhInfo    *inhinfo;
 
    int         i_inhrelid;
    int         i_inhparent;
 
    /* find all the inheritance information */
    appendPQExpBufferStr(query, "SELECT inhrelid, inhparent FROM pg_inherits");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    *numInherits = ntups;
 
    inhinfo = pg_malloc_array(InhInfo, ntups);
 
    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;
}

References appendPQExpBufferStr(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), ExecuteSqlQuery(), fb(), fout, i, pg_malloc_array, PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, and PQntuples.

Referenced by getSchemaData().

getMaxDumpId()

DumpId getMaxDumpId ( void  )

extern

Definition at line 755 of file common.c.

{
    return lastDumpId;
}

References lastDumpId.

Referenced by findDependencyLoops(), and TopoSort().

getNamespaces()

void getNamespaces ( Archive *  fout )

extern

Definition at line 6083 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    NamespaceInfo *nsinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_nspname;
    int         i_nspowner;
    int         i_nspacl;
    int         i_acldefault;
 
    query = createPQExpBuffer();
 
    /*
     * we fetch all namespaces including system ones, so that every object we
     * read in can be linked to a containing namespace.
     */
    appendPQExpBufferStr(query, "SELECT n.tableoid, n.oid, n.nspname, "
                         "n.nspowner, "
                         "n.nspacl, "
                         "acldefault('n', n.nspowner) AS acldefault "
                         "FROM pg_namespace n");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    nsinfo = pg_malloc_array(NamespaceInfo, ntups);
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_nspname = PQfnumber(res, "nspname");
    i_nspowner = PQfnumber(res, "nspowner");
    i_nspacl = PQfnumber(res, "nspacl");
    i_acldefault = PQfnumber(res, "acldefault");
 
    for (i = 0; i < ntups; i++)
    {
        const char *nspowner;
 
        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].dacl.acl = pg_strdup(PQgetvalue(res, i, i_nspacl));
        nsinfo[i].dacl.acldefault = pg_strdup(PQgetvalue(res, i, i_acldefault));
        nsinfo[i].dacl.privtype = 0;
        nsinfo[i].dacl.initprivs = NULL;
        nspowner = PQgetvalue(res, i, i_nspowner);
        nsinfo[i].nspowner = atooid(nspowner);
        nsinfo[i].rolname = getRoleName(nspowner);
 
        /* Decide whether to dump this namespace */
        selectDumpableNamespace(&nsinfo[i], fout);
 
        /* Mark whether namespace has an ACL */
        if (!PQgetisnull(res, i, i_nspacl))
            nsinfo[i].dobj.components |= DUMP_COMPONENT_ACL;
 
        /*
         * We ignore any pg_init_privs.initprivs entry for the public schema
         * and assume a predetermined default, for several reasons.  First,
         * dropping and recreating the schema removes its pg_init_privs entry,
         * but an empty destination database starts with this ACL nonetheless.
         * Second, we support dump/reload of public schema ownership changes.
         * ALTER SCHEMA OWNER filters nspacl through aclnewowner(), but
         * initprivs continues to reflect the initial owner.  Hence,
         * synthesize the value that nspacl will have after the restore's
         * ALTER SCHEMA OWNER.  Third, this makes the destination database
         * match the source's ACL, even if the latter was an initdb-default
         * ACL, which changed in v15.  An upgrade pulls in changes to most
         * system object ACLs that the DBA had not customized.  We've made the
         * public schema depart from that, because changing its ACL so easily
         * breaks applications.
         */
        if (strcmp(nsinfo[i].dobj.name, "public") == 0)
        {
            PQExpBuffer aclarray = createPQExpBuffer();
            PQExpBuffer aclitem = createPQExpBuffer();
 
            /* Standard ACL as of v15 is {owner=UC/owner,=U/owner} */
            appendPQExpBufferChar(aclarray, '{');
            quoteAclUserName(aclitem, nsinfo[i].rolname);
            appendPQExpBufferStr(aclitem, "=UC/");
            quoteAclUserName(aclitem, nsinfo[i].rolname);
            appendPGArray(aclarray, aclitem->data);
            resetPQExpBuffer(aclitem);
            appendPQExpBufferStr(aclitem, "=U/");
            quoteAclUserName(aclitem, nsinfo[i].rolname);
            appendPGArray(aclarray, aclitem->data);
            appendPQExpBufferChar(aclarray, '}');
 
            nsinfo[i].dacl.privtype = 'i';
            nsinfo[i].dacl.initprivs = pstrdup(aclarray->data);
            nsinfo[i].dobj.components |= DUMP_COMPONENT_ACL;
 
            destroyPQExpBuffer(aclarray);
            destroyPQExpBuffer(aclitem);
        }
    }
 
    PQclear(res);
    destroyPQExpBuffer(query);
}

References appendPGArray(), appendPQExpBufferChar(), appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_NAMESPACE, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), fb(), fout, getRoleName(), i, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, pstrdup(), quoteAclUserName(), resetPQExpBuffer(), rolname, and selectDumpableNamespace().

Referenced by getSchemaData().

getOpclasses()

void getOpclasses ( Archive *  fout )

extern

Definition at line 6736 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    OpclassInfo *opcinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_opcmethod;
    int         i_opcname;
    int         i_opcnamespace;
    int         i_opcowner;
 
    /*
     * find all opclasses, including builtin opclasses; we filter out
     * system-defined opclasses at dump-out time.
     */
 
    appendPQExpBufferStr(query, "SELECT tableoid, oid, opcmethod, opcname, "
                         "opcnamespace, "
                         "opcowner "
                         "FROM pg_opclass");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    opcinfo = pg_malloc_array(OpclassInfo, ntups);
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_opcmethod = PQfnumber(res, "opcmethod");
    i_opcname = PQfnumber(res, "opcname");
    i_opcnamespace = PQfnumber(res, "opcnamespace");
    i_opcowner = PQfnumber(res, "opcowner");
 
    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(atooid(PQgetvalue(res, i, i_opcnamespace)));
        opcinfo[i].opcmethod = atooid(PQgetvalue(res, i, i_opcmethod));
        opcinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_opcowner));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(opcinfo[i].dobj), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_OPCLASS, ExecuteSqlQuery(), fb(), findNamespace(), fout, getRoleName(), i, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, and selectDumpableObject().

Referenced by getSchemaData().

getOperators()

void getOperators ( Archive *  fout )

extern

Definition at line 6458 of file pg_dump.c.

{
    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_oprowner;
    int         i_oprkind;
    int         i_oprleft;
    int         i_oprright;
    int         i_oprcode;
 
    /*
     * find all operators, including builtin operators; we filter out
     * system-defined operators at dump-out time.
     */
 
    appendPQExpBufferStr(query, "SELECT tableoid, oid, oprname, "
                         "oprnamespace, "
                         "oprowner, "
                         "oprkind, "
                         "oprleft, "
                         "oprright, "
                         "oprcode::oid AS oprcode "
                         "FROM pg_operator");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    oprinfo = pg_malloc_array(OprInfo, ntups);
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_oprname = PQfnumber(res, "oprname");
    i_oprnamespace = PQfnumber(res, "oprnamespace");
    i_oprowner = PQfnumber(res, "oprowner");
    i_oprkind = PQfnumber(res, "oprkind");
    i_oprleft = PQfnumber(res, "oprleft");
    i_oprright = PQfnumber(res, "oprright");
    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(atooid(PQgetvalue(res, i, i_oprnamespace)));
        oprinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_oprowner));
        oprinfo[i].oprkind = (PQgetvalue(res, i, i_oprkind))[0];
        oprinfo[i].oprleft = atooid(PQgetvalue(res, i, i_oprleft));
        oprinfo[i].oprright = atooid(PQgetvalue(res, i, i_oprright));
        oprinfo[i].oprcode = atooid(PQgetvalue(res, i, i_oprcode));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(oprinfo[i].dobj), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_OPERATOR, ExecuteSqlQuery(), fb(), findNamespace(), fout, getRoleName(), i, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, and selectDumpableObject().

Referenced by getSchemaData().

getOpfamilies()

void getOpfamilies ( Archive *  fout )

extern

Definition at line 6799 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    OpfamilyInfo *opfinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_opfmethod;
    int         i_opfname;
    int         i_opfnamespace;
    int         i_opfowner;
 
    query = createPQExpBuffer();
 
    /*
     * find all opfamilies, including builtin opfamilies; we filter out
     * system-defined opfamilies at dump-out time.
     */
 
    appendPQExpBufferStr(query, "SELECT tableoid, oid, opfmethod, opfname, "
                         "opfnamespace, "
                         "opfowner "
                         "FROM pg_opfamily");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    opfinfo = pg_malloc_array(OpfamilyInfo, ntups);
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_opfname = PQfnumber(res, "opfname");
    i_opfmethod = PQfnumber(res, "opfmethod");
    i_opfnamespace = PQfnumber(res, "opfnamespace");
    i_opfowner = PQfnumber(res, "opfowner");
 
    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(atooid(PQgetvalue(res, i, i_opfnamespace)));
        opfinfo[i].opfmethod = atooid(PQgetvalue(res, i, i_opfmethod));
        opfinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_opfowner));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(opfinfo[i].dobj), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_OPFAMILY, ExecuteSqlQuery(), fb(), findNamespace(), fout, getRoleName(), i, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, and selectDumpableObject().

Referenced by getSchemaData().

getOwnedSeqs()

void getOwnedSeqs ( Archive *  fout, TableInfo  tblinfo[], int  numTables  )

extern

Definition at line 7756 of file pg_dump.c.

{
    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 */
 
        owning_tab = findTableByOid(seqinfo->owning_tab);
        if (owning_tab == NULL)
            pg_fatal("failed sanity check, parent table with OID %u of sequence with OID %u not found",
                     seqinfo->owning_tab, seqinfo->dobj.catId.oid);
 
        /*
         * For an identity sequence, dump exactly the same components for the
         * sequence as for the owning table.  This is important because we
         * treat the identity sequence as an integral part of the table.  For
         * example, there is not any DDL command that allows creation of such
         * a sequence independently of the table.
         *
         * For other owned sequences such as serial sequences, we need to dump
         * the components that are being dumped for the table and any
         * components that the sequence is explicitly marked with.
         *
         * We can't simply use the set of components which are being dumped
         * for the table as the table might be in an extension (and only the
         * non-extension components, eg: ACLs if changed, security labels, and
         * policies, are being dumped) while the sequence is not (and
         * therefore the definition and other components should also be
         * dumped).
         *
         * If the sequence is part of the extension then it should be properly
         * marked by checkExtensionMembership() and this will be a no-op as
         * the table will be equivalently marked.
         */
        if (seqinfo->is_identity_sequence)
            seqinfo->dobj.dump = owning_tab->dobj.dump;
        else
            seqinfo->dobj.dump |= owning_tab->dobj.dump;
 
        /* Make sure that necessary data is available if we're dumping it */
        if (seqinfo->dobj.dump != DUMP_COMPONENT_NONE)
        {
            seqinfo->interesting = true;
            owning_tab->interesting = true;
        }
    }
}

References _tableInfo::dobj, _dumpableObject::dump, DUMP_COMPONENT_NONE, fb(), findTableByOid(), i, _tableInfo::interesting, OidIsValid, and pg_fatal.

Referenced by getSchemaData().

getPartitioningInfo()

void getPartitioningInfo ( Archive *  fout )

extern

Definition at line 7877 of file pg_dump.c.

{
    PQExpBuffer query;
    PGresult   *res;
    int         ntups;
 
    /* hash partitioning didn't exist before v11 */
    if (fout->remoteVersion < 110000)
        return;
    /* needn't bother if not dumping data */
    if (!fout->dopt->dumpData)
        return;
 
    query = createPQExpBuffer();
 
    /*
     * Unsafe partitioning schemes are exactly those for which hash enum_ops
     * appears among the partition opclasses.  We needn't check partstrat.
     *
     * Note that this query may well retrieve info about tables we aren't
     * going to dump and hence have no lock on.  That's okay since we need not
     * invoke any unsafe server-side functions.
     */
    appendPQExpBufferStr(query,
                         "SELECT partrelid FROM pg_partitioned_table WHERE\n"
                         "(SELECT c.oid FROM pg_opclass c JOIN pg_am a "
                         "ON c.opcmethod = a.oid\n"
                         "WHERE opcname = 'enum_ops' "
                         "AND opcnamespace = 'pg_catalog'::regnamespace "
                         "AND amname = 'hash') = ANY(partclass)");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    for (int i = 0; i < ntups; i++)
    {
        Oid         tabrelid = atooid(PQgetvalue(res, i, 0));
        TableInfo  *tbinfo;
 
        tbinfo = findTableByOid(tabrelid);
        if (tbinfo == NULL)
            pg_fatal("failed sanity check, table OID %u appearing in pg_partitioned_table not found",
                     tabrelid);
        tbinfo->unsafe_partitions = true;
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), Archive::dopt, _dumpOptions::dumpData, ExecuteSqlQuery(), fb(), findTableByOid(), fout, i, pg_fatal, PGRES_TUPLES_OK, PQclear, PQgetvalue, PQntuples, and Archive::remoteVersion.

Referenced by getSchemaData().

getPolicies()

void getPolicies ( Archive *  fout, TableInfo  tblinfo[], int  numTables  )

extern

Definition at line 4226 of file pg_dump.c.

{
    DumpOptions *dopt = fout->dopt;
    PQExpBuffer query;
    PQExpBuffer tbloids;
    PGresult   *res;
    PolicyInfo *polinfo;
    int         i_oid;
    int         i_tableoid;
    int         i_polrelid;
    int         i_polname;
    int         i_polcmd;
    int         i_polpermissive;
    int         i_polroles;
    int         i_polqual;
    int         i_polwithcheck;
    int         i,
                j,
                ntups;
 
    /* No policies before 9.5 */
    if (fout->remoteVersion < 90500)
        return;
 
    /* Skip if --no-policies was specified */
    if (dopt->no_policies)
        return;
 
    query = createPQExpBuffer();
    tbloids = createPQExpBuffer();
 
    /*
     * Identify tables of interest, and check which ones have RLS enabled.
     */
    appendPQExpBufferChar(tbloids, '{');
    for (i = 0; i < numTables; i++)
    {
        TableInfo  *tbinfo = &tblinfo[i];
 
        /* Ignore row security on tables not to be dumped */
        if (!(tbinfo->dobj.dump & DUMP_COMPONENT_POLICY))
            continue;
 
        /* It can't have RLS or policies if it's not a table */
        if (tbinfo->relkind != RELKIND_RELATION &&
            tbinfo->relkind != RELKIND_PARTITIONED_TABLE)
            continue;
 
        /* Add it to the list of table OIDs to be probed below */
        if (tbloids->len > 1)   /* do we have more than the '{'? */
            appendPQExpBufferChar(tbloids, ',');
        appendPQExpBuffer(tbloids, "%u", tbinfo->dobj.catId.oid);
 
        /* Is RLS enabled?  (That's separate from whether it has policies) */
        if (tbinfo->rowsec)
        {
            tbinfo->dobj.components |= DUMP_COMPONENT_POLICY;
 
            /*
             * We represent RLS being enabled on a table by creating a
             * PolicyInfo object with null polname.
             *
             * Note: use tableoid 0 so that this object won't be mistaken for
             * something that pg_depend entries apply to.
             */
            polinfo = pg_malloc_object(PolicyInfo);
            polinfo->dobj.objType = DO_POLICY;
            polinfo->dobj.catId.tableoid = 0;
            polinfo->dobj.catId.oid = tbinfo->dobj.catId.oid;
            AssignDumpId(&polinfo->dobj);
            polinfo->dobj.namespace = tbinfo->dobj.namespace;
            polinfo->dobj.name = pg_strdup(tbinfo->dobj.name);
            polinfo->poltable = tbinfo;
            polinfo->polname = NULL;
            polinfo->polcmd = '\0';
            polinfo->polpermissive = 0;
            polinfo->polroles = NULL;
            polinfo->polqual = NULL;
            polinfo->polwithcheck = NULL;
        }
    }
    appendPQExpBufferChar(tbloids, '}');
 
    /*
     * Now, read all RLS policies belonging to the tables of interest, and
     * create PolicyInfo objects for them.  (Note that we must filter the
     * results server-side not locally, because we dare not apply pg_get_expr
     * to tables we don't have lock on.)
     */
    pg_log_info("reading row-level security policies");
 
    printfPQExpBuffer(query,
                      "SELECT pol.oid, pol.tableoid, pol.polrelid, pol.polname, pol.polcmd, ");
    if (fout->remoteVersion >= 100000)
        appendPQExpBufferStr(query, "pol.polpermissive, ");
    else
        appendPQExpBufferStr(query, "'t' as polpermissive, ");
    appendPQExpBuffer(query,
                      "CASE WHEN pol.polroles = '{0}' THEN NULL ELSE "
                      "   pg_catalog.array_to_string(ARRAY(SELECT pg_catalog.quote_ident(rolname) from pg_catalog.pg_roles WHERE oid = ANY(pol.polroles)), ', ') END AS polroles, "
                      "pg_catalog.pg_get_expr(pol.polqual, pol.polrelid) AS polqual, "
                      "pg_catalog.pg_get_expr(pol.polwithcheck, pol.polrelid) AS polwithcheck "
                      "FROM unnest('%s'::pg_catalog.oid[]) AS src(tbloid)\n"
                      "JOIN pg_catalog.pg_policy pol ON (src.tbloid = pol.polrelid)",
                      tbloids->data);
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
    if (ntups > 0)
    {
        i_oid = PQfnumber(res, "oid");
        i_tableoid = PQfnumber(res, "tableoid");
        i_polrelid = PQfnumber(res, "polrelid");
        i_polname = PQfnumber(res, "polname");
        i_polcmd = PQfnumber(res, "polcmd");
        i_polpermissive = PQfnumber(res, "polpermissive");
        i_polroles = PQfnumber(res, "polroles");
        i_polqual = PQfnumber(res, "polqual");
        i_polwithcheck = PQfnumber(res, "polwithcheck");
 
        polinfo = pg_malloc_array(PolicyInfo, ntups);
 
        for (j = 0; j < ntups; j++)
        {
            Oid         polrelid = atooid(PQgetvalue(res, j, i_polrelid));
            TableInfo  *tbinfo = findTableByOid(polrelid);
 
            tbinfo->dobj.components |= DUMP_COMPONENT_POLICY;
 
            polinfo[j].dobj.objType = DO_POLICY;
            polinfo[j].dobj.catId.tableoid =
                atooid(PQgetvalue(res, j, i_tableoid));
            polinfo[j].dobj.catId.oid = atooid(PQgetvalue(res, j, i_oid));
            AssignDumpId(&polinfo[j].dobj);
            polinfo[j].dobj.namespace = tbinfo->dobj.namespace;
            polinfo[j].poltable = tbinfo;
            polinfo[j].polname = pg_strdup(PQgetvalue(res, j, i_polname));
            polinfo[j].dobj.name = pg_strdup(polinfo[j].polname);
 
            polinfo[j].polcmd = *(PQgetvalue(res, j, i_polcmd));
            polinfo[j].polpermissive = *(PQgetvalue(res, j, i_polpermissive)) == 't';
 
            if (PQgetisnull(res, j, i_polroles))
                polinfo[j].polroles = NULL;
            else
                polinfo[j].polroles = pg_strdup(PQgetvalue(res, j, i_polroles));
 
            if (PQgetisnull(res, j, i_polqual))
                polinfo[j].polqual = NULL;
            else
                polinfo[j].polqual = pg_strdup(PQgetvalue(res, j, i_polqual));
 
            if (PQgetisnull(res, j, i_polwithcheck))
                polinfo[j].polwithcheck = NULL;
            else
                polinfo[j].polwithcheck
                    = pg_strdup(PQgetvalue(res, j, i_polwithcheck));
        }
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
    destroyPQExpBuffer(tbloids);
}

References appendPQExpBuffer(), appendPQExpBufferChar(), appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_POLICY, Archive::dopt, DUMP_COMPONENT_POLICY, ExecuteSqlQuery(), fb(), findTableByOid(), fout, i, j, _dumpOptions::no_policies, pg_log_info, pg_malloc_array, pg_malloc_object, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, printfPQExpBuffer(), and Archive::remoteVersion.

Referenced by getSchemaData().

getProcLangs()

void getProcLangs ( Archive *  fout )

extern

Definition at line 9053 of file pg_dump.c.

{
    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_acldefault;
    int         i_lanowner;
 
    appendPQExpBufferStr(query, "SELECT tableoid, oid, "
                         "lanname, lanpltrusted, lanplcallfoid, "
                         "laninline, lanvalidator, "
                         "lanacl, "
                         "acldefault('l', lanowner) AS acldefault, "
                         "lanowner "
                         "FROM pg_language "
                         "WHERE lanispl "
                         "ORDER BY oid");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    planginfo = pg_malloc_array(ProcLangInfo, ntups);
 
    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");
    i_laninline = PQfnumber(res, "laninline");
    i_lanvalidator = PQfnumber(res, "lanvalidator");
    i_lanacl = PQfnumber(res, "lanacl");
    i_acldefault = PQfnumber(res, "acldefault");
    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].dacl.acl = pg_strdup(PQgetvalue(res, i, i_lanacl));
        planginfo[i].dacl.acldefault = pg_strdup(PQgetvalue(res, i, i_acldefault));
        planginfo[i].dacl.privtype = 0;
        planginfo[i].dacl.initprivs = NULL;
        planginfo[i].lanpltrusted = *(PQgetvalue(res, i, i_lanpltrusted)) == 't';
        planginfo[i].lanplcallfoid = atooid(PQgetvalue(res, i, i_lanplcallfoid));
        planginfo[i].laninline = atooid(PQgetvalue(res, i, i_laninline));
        planginfo[i].lanvalidator = atooid(PQgetvalue(res, i, i_lanvalidator));
        planginfo[i].lanowner = getRoleName(PQgetvalue(res, i, i_lanowner));
 
        /* Decide whether we want to dump it */
        selectDumpableProcLang(&(planginfo[i]), fout);
 
        /* Mark whether language has an ACL */
        if (!PQgetisnull(res, i, i_lanacl))
            planginfo[i].dobj.components |= DUMP_COMPONENT_ACL;
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_PROCLANG, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), fb(), fout, getRoleName(), i, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, and selectDumpableProcLang().

Referenced by getSchemaData().

getPublicationNamespaces()

void getPublicationNamespaces ( Archive *  fout )

extern

Definition at line 4804 of file pg_dump.c.

{
    PQExpBuffer query;
    PGresult   *res;
    PublicationSchemaInfo *pubsinfo;
    DumpOptions *dopt = fout->dopt;
    int         i_tableoid;
    int         i_oid;
    int         i_pnpubid;
    int         i_pnnspid;
    int         i,
                j,
                ntups;
 
    if (dopt->no_publications || fout->remoteVersion < 150000)
        return;
 
    query = createPQExpBuffer();
 
    /* Collect all publication membership info. */
    appendPQExpBufferStr(query,
                         "SELECT tableoid, oid, pnpubid, pnnspid "
                         "FROM pg_catalog.pg_publication_namespace");
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_pnpubid = PQfnumber(res, "pnpubid");
    i_pnnspid = PQfnumber(res, "pnnspid");
 
    /* this allocation may be more than we need */
    pubsinfo = pg_malloc_array(PublicationSchemaInfo, ntups);
    j = 0;
 
    for (i = 0; i < ntups; i++)
    {
        Oid         pnpubid = atooid(PQgetvalue(res, i, i_pnpubid));
        Oid         pnnspid = atooid(PQgetvalue(res, i, i_pnnspid));
        PublicationInfo *pubinfo;
        NamespaceInfo *nspinfo;
 
        /*
         * Ignore any entries for which we aren't interested in either the
         * publication or the rel.
         */
        pubinfo = findPublicationByOid(pnpubid);
        if (pubinfo == NULL)
            continue;
        nspinfo = findNamespaceByOid(pnnspid);
        if (nspinfo == NULL)
            continue;
 
        /* OK, make a DumpableObject for this relationship */
        pubsinfo[j].dobj.objType = DO_PUBLICATION_TABLE_IN_SCHEMA;
        pubsinfo[j].dobj.catId.tableoid =
            atooid(PQgetvalue(res, i, i_tableoid));
        pubsinfo[j].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&pubsinfo[j].dobj);
        pubsinfo[j].dobj.namespace = nspinfo->dobj.namespace;
        pubsinfo[j].dobj.name = nspinfo->dobj.name;
        pubsinfo[j].publication = pubinfo;
        pubsinfo[j].pubschema = nspinfo;
 
        /* Decide whether we want to dump it */
        selectDumpablePublicationObject(&(pubsinfo[j].dobj), fout);
 
        j++;
    }
 
    PQclear(res);
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_PUBLICATION_TABLE_IN_SCHEMA, Archive::dopt, ExecuteSqlQuery(), fb(), findNamespaceByOid(), findPublicationByOid(), fout, i, j, _dumpOptions::no_publications, pg_malloc_array, PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, Archive::remoteVersion, and selectDumpablePublicationObject().

Referenced by getSchemaData().

getPublications()

void getPublications ( Archive *  fout )

extern

Definition at line 4516 of file pg_dump.c.

{
    DumpOptions *dopt = fout->dopt;
    PQExpBuffer query;
    PGresult   *res;
    PublicationInfo *pubinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_pubname;
    int         i_pubowner;
    int         i_puballtables;
    int         i_puballsequences;
    int         i_pubinsert;
    int         i_pubupdate;
    int         i_pubdelete;
    int         i_pubtruncate;
    int         i_pubviaroot;
    int         i_pubgencols;
    int         i,
                ntups;
 
    if (dopt->no_publications || fout->remoteVersion < 100000)
        return;
 
    query = createPQExpBuffer();
 
    /* Get the publications. */
    appendPQExpBufferStr(query, "SELECT p.tableoid, p.oid, p.pubname, "
                         "p.pubowner, p.puballtables, p.pubinsert, "
                         "p.pubupdate, p.pubdelete, ");
 
    if (fout->remoteVersion >= 110000)
        appendPQExpBufferStr(query, "p.pubtruncate, ");
    else
        appendPQExpBufferStr(query, "false AS pubtruncate, ");
 
    if (fout->remoteVersion >= 130000)
        appendPQExpBufferStr(query, "p.pubviaroot, ");
    else
        appendPQExpBufferStr(query, "false AS pubviaroot, ");
 
    if (fout->remoteVersion >= 180000)
        appendPQExpBufferStr(query, "p.pubgencols, ");
    else
        appendPQExpBuffer(query, "'%c' AS pubgencols, ", PUBLISH_GENCOLS_NONE);
 
    if (fout->remoteVersion >= 190000)
        appendPQExpBufferStr(query, "p.puballsequences ");
    else
        appendPQExpBufferStr(query, "false AS puballsequences ");
 
    appendPQExpBufferStr(query, "FROM pg_publication p");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    if (ntups == 0)
        goto cleanup;
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_pubname = PQfnumber(res, "pubname");
    i_pubowner = PQfnumber(res, "pubowner");
    i_puballtables = PQfnumber(res, "puballtables");
    i_puballsequences = PQfnumber(res, "puballsequences");
    i_pubinsert = PQfnumber(res, "pubinsert");
    i_pubupdate = PQfnumber(res, "pubupdate");
    i_pubdelete = PQfnumber(res, "pubdelete");
    i_pubtruncate = PQfnumber(res, "pubtruncate");
    i_pubviaroot = PQfnumber(res, "pubviaroot");
    i_pubgencols = PQfnumber(res, "pubgencols");
 
    pubinfo = pg_malloc_array(PublicationInfo, ntups);
 
    for (i = 0; i < ntups; i++)
    {
        pubinfo[i].dobj.objType = DO_PUBLICATION;
        pubinfo[i].dobj.catId.tableoid =
            atooid(PQgetvalue(res, i, i_tableoid));
        pubinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&pubinfo[i].dobj);
        pubinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_pubname));
        pubinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_pubowner));
        pubinfo[i].puballtables =
            (strcmp(PQgetvalue(res, i, i_puballtables), "t") == 0);
        pubinfo[i].puballsequences =
            (strcmp(PQgetvalue(res, i, i_puballsequences), "t") == 0);
        pubinfo[i].pubinsert =
            (strcmp(PQgetvalue(res, i, i_pubinsert), "t") == 0);
        pubinfo[i].pubupdate =
            (strcmp(PQgetvalue(res, i, i_pubupdate), "t") == 0);
        pubinfo[i].pubdelete =
            (strcmp(PQgetvalue(res, i, i_pubdelete), "t") == 0);
        pubinfo[i].pubtruncate =
            (strcmp(PQgetvalue(res, i, i_pubtruncate), "t") == 0);
        pubinfo[i].pubviaroot =
            (strcmp(PQgetvalue(res, i, i_pubviaroot), "t") == 0);
        pubinfo[i].pubgencols_type =
            *(PQgetvalue(res, i, i_pubgencols));
        pubinfo[i].except_tables = (SimplePtrList)
        {
            NULL, NULL
        };
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(pubinfo[i].dobj), fout);
 
        /*
         * Get the list of tables for publications specified in the EXCEPT
         * TABLE clause.
         *
         * Although individual table entries in EXCEPT list could be stored in
         * PublicationRelInfo, dumpPublicationTable cannot be used to emit
         * them, because there is no ALTER PUBLICATION ... ADD command to add
         * individual table entries to the EXCEPT list.
         *
         * Therefore, the approach is to dump the complete EXCEPT list in a
         * single CREATE PUBLICATION statement. PublicationInfo is used to
         * collect this information, which is then emitted by
         * dumpPublication().
         */
        if (fout->remoteVersion >= 190000)
        {
            int         ntbls;
            PGresult   *res_tbls;
 
            resetPQExpBuffer(query);
            appendPQExpBuffer(query,
                              "SELECT prrelid\n"
                              "FROM pg_catalog.pg_publication_rel\n"
                              "WHERE prpubid = %u AND prexcept",
                              pubinfo[i].dobj.catId.oid);
 
            res_tbls = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
            ntbls = PQntuples(res_tbls);
 
            for (int j = 0; j < ntbls; j++)
            {
                Oid         prrelid;
                TableInfo  *tbinfo;
 
                prrelid = atooid(PQgetvalue(res_tbls, j, 0));
 
                tbinfo = findTableByOid(prrelid);
 
                if (tbinfo != NULL)
                    simple_ptr_list_append(&pubinfo[i].except_tables, tbinfo);
            }
 
            PQclear(res_tbls);
        }
    }
 
cleanup:
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBuffer(), appendPQExpBufferStr(), AssignDumpId(), atooid, cleanup(), createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_PUBLICATION, Archive::dopt, ExecuteSqlQuery(), fb(), findTableByOid(), fout, getRoleName(), i, j, _dumpOptions::no_publications, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, Archive::remoteVersion, resetPQExpBuffer(), selectDumpableObject(), and simple_ptr_list_append().

Referenced by getSchemaData().

getPublicationTables()

void getPublicationTables ( Archive *  fout, TableInfo  tblinfo[], int  numTables  )

extern

Definition at line 4884 of file pg_dump.c.

{
    PQExpBuffer query;
    PGresult   *res;
    PublicationRelInfo *pubrinfo;
    DumpOptions *dopt = fout->dopt;
    int         i_tableoid;
    int         i_oid;
    int         i_prpubid;
    int         i_prrelid;
    int         i_prrelqual;
    int         i_prattrs;
    int         i,
                j,
                ntups;
 
    if (dopt->no_publications || fout->remoteVersion < 100000)
        return;
 
    query = createPQExpBuffer();
 
    /* Collect all publication membership info. */
    if (fout->remoteVersion >= 150000)
    {
        appendPQExpBufferStr(query,
                             "SELECT tableoid, oid, prpubid, prrelid, "
                             "pg_catalog.pg_get_expr(prqual, prrelid) AS prrelqual, "
                             "(CASE\n"
                             "  WHEN pr.prattrs IS NOT NULL THEN\n"
                             "    (SELECT array_agg(attname)\n"
                             "       FROM\n"
                             "         pg_catalog.generate_series(0, pg_catalog.array_upper(pr.prattrs::pg_catalog.int2[], 1)) s,\n"
                             "         pg_catalog.pg_attribute\n"
                             "      WHERE attrelid = pr.prrelid AND attnum = prattrs[s])\n"
                             "  ELSE NULL END) prattrs "
                             "FROM pg_catalog.pg_publication_rel pr");
        if (fout->remoteVersion >= 190000)
            appendPQExpBufferStr(query, " WHERE NOT pr.prexcept");
    }
    else
        appendPQExpBufferStr(query,
                             "SELECT tableoid, oid, prpubid, prrelid, "
                             "NULL AS prrelqual, NULL AS prattrs "
                             "FROM pg_catalog.pg_publication_rel");
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_prpubid = PQfnumber(res, "prpubid");
    i_prrelid = PQfnumber(res, "prrelid");
    i_prrelqual = PQfnumber(res, "prrelqual");
    i_prattrs = PQfnumber(res, "prattrs");
 
    /* this allocation may be more than we need */
    pubrinfo = pg_malloc_array(PublicationRelInfo, ntups);
    j = 0;
 
    for (i = 0; i < ntups; i++)
    {
        Oid         prpubid = atooid(PQgetvalue(res, i, i_prpubid));
        Oid         prrelid = atooid(PQgetvalue(res, i, i_prrelid));
        PublicationInfo *pubinfo;
        TableInfo  *tbinfo;
 
        /*
         * Ignore any entries for which we aren't interested in either the
         * publication or the rel.
         */
        pubinfo = findPublicationByOid(prpubid);
        if (pubinfo == NULL)
            continue;
        tbinfo = findTableByOid(prrelid);
        if (tbinfo == NULL)
            continue;
 
        /* OK, make a DumpableObject for this relationship */
        pubrinfo[j].dobj.objType = DO_PUBLICATION_REL;
        pubrinfo[j].dobj.catId.tableoid =
            atooid(PQgetvalue(res, i, i_tableoid));
        pubrinfo[j].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&pubrinfo[j].dobj);
        pubrinfo[j].dobj.namespace = tbinfo->dobj.namespace;
        pubrinfo[j].dobj.name = tbinfo->dobj.name;
        pubrinfo[j].publication = pubinfo;
        pubrinfo[j].pubtable = tbinfo;
        if (PQgetisnull(res, i, i_prrelqual))
            pubrinfo[j].pubrelqual = NULL;
        else
            pubrinfo[j].pubrelqual = pg_strdup(PQgetvalue(res, i, i_prrelqual));
 
        if (!PQgetisnull(res, i, i_prattrs))
        {
            char      **attnames;
            int         nattnames;
            PQExpBuffer attribs;
 
            if (!parsePGArray(PQgetvalue(res, i, i_prattrs),
                              &attnames, &nattnames))
                pg_fatal("could not parse %s array", "prattrs");
            attribs = createPQExpBuffer();
            for (int k = 0; k < nattnames; k++)
            {
                if (k > 0)
                    appendPQExpBufferStr(attribs, ", ");
 
                appendPQExpBufferStr(attribs, fmtId(attnames[k]));
            }
            pubrinfo[j].pubrattrs = attribs->data;
            free(attribs);      /* but not attribs->data */
            free(attnames);
        }
        else
            pubrinfo[j].pubrattrs = NULL;
 
        /* Decide whether we want to dump it */
        selectDumpablePublicationObject(&(pubrinfo[j].dobj), fout);
 
        j++;
    }
 
    PQclear(res);
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_PUBLICATION_REL, Archive::dopt, ExecuteSqlQuery(), fb(), findPublicationByOid(), findTableByOid(), fmtId(), fout, free, i, j, _dumpOptions::no_publications, parsePGArray(), pg_fatal, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, Archive::remoteVersion, and selectDumpablePublicationObject().

Referenced by getSchemaData().

getRules()

void getRules ( Archive *  fout )

extern

Definition at line 8682 of file pg_dump.c.

{
    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;
 
    appendPQExpBufferStr(query, "SELECT "
                         "tableoid, oid, rulename, "
                         "ev_class AS ruletable, ev_type, is_instead, "
                         "ev_enabled "
                         "FROM pg_rewrite "
                         "ORDER BY oid");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    ruleinfo = pg_malloc_array(RuleInfo, ntups);
 
    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)
            pg_fatal("failed sanity check, parent table with OID %u of pg_rewrite entry with OID %u not found",
                     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;
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References addObjectDependency(), appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_RULE, ExecuteSqlQuery(), fb(), findTableByOid(), fout, i, pg_fatal, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, and PQntuples.

Referenced by getSchemaData().

getSchemaData()

TableInfo * getSchemaData ( Archive *  fout, int *  numTablesPtr  )

extern

Definition at line 98 of file common.c.

{
    TableInfo  *tblinfo;
    ExtensionInfo *extinfo;
    InhInfo    *inhinfo;
    int         numTables;
    int         numExtensions;
    int         numInherits;
 
    /*
     * We must read extensions and extension membership info first, because
     * extension membership needs to be consultable during decisions about
     * whether other objects are to be dumped.
     */
    pg_log_info("reading extensions");
    extinfo = getExtensions(fout, &numExtensions);
 
    pg_log_info("identifying extension members");
    getExtensionMembership(fout, extinfo, numExtensions);
 
    pg_log_info("reading schemas");
    getNamespaces(fout);
 
    /*
     * getTables should be done as soon as possible, so as to minimize the
     * window between starting our transaction and acquiring per-table locks.
     * However, we have to do getNamespaces first because the tables get
     * linked to their containing namespaces during getTables.
     */
    pg_log_info("reading user-defined tables");
    tblinfo = getTables(fout, &numTables);
 
    getOwnedSeqs(fout, tblinfo, numTables);
 
    pg_log_info("reading user-defined functions");
    getFuncs(fout);
 
    /* this must be after getTables and getFuncs */
    pg_log_info("reading user-defined types");
    getTypes(fout);
 
    /* this must be after getFuncs, too */
    pg_log_info("reading procedural languages");
    getProcLangs(fout);
 
    pg_log_info("reading user-defined aggregate functions");
    getAggregates(fout);
 
    pg_log_info("reading user-defined operators");
    getOperators(fout);
 
    pg_log_info("reading user-defined access methods");
    getAccessMethods(fout);
 
    pg_log_info("reading user-defined operator classes");
    getOpclasses(fout);
 
    pg_log_info("reading user-defined operator families");
    getOpfamilies(fout);
 
    pg_log_info("reading user-defined text search parsers");
    getTSParsers(fout);
 
    pg_log_info("reading user-defined text search templates");
    getTSTemplates(fout);
 
    pg_log_info("reading user-defined text search dictionaries");
    getTSDictionaries(fout);
 
    pg_log_info("reading user-defined text search configurations");
    getTSConfigurations(fout);
 
    pg_log_info("reading user-defined foreign-data wrappers");
    getForeignDataWrappers(fout);
 
    pg_log_info("reading user-defined foreign servers");
    getForeignServers(fout);
 
    pg_log_info("reading default privileges");
    getDefaultACLs(fout);
 
    pg_log_info("reading user-defined collations");
    getCollations(fout);
 
    pg_log_info("reading user-defined conversions");
    getConversions(fout);
 
    pg_log_info("reading type casts");
    getCasts(fout);
 
    pg_log_info("reading transforms");
    getTransforms(fout);
 
    pg_log_info("reading table inheritance information");
    inhinfo = getInherits(fout, &numInherits);
 
    pg_log_info("reading event triggers");
    getEventTriggers(fout);
 
    /* Identify extension configuration tables that should be dumped */
    pg_log_info("finding extension tables");
    processExtensionTables(fout, extinfo, numExtensions);
 
    /* Link tables to parents, mark parents of target tables interesting */
    pg_log_info("finding inheritance relationships");
    flagInhTables(fout, tblinfo, numTables, inhinfo, numInherits);
 
    pg_log_info("reading column info for interesting tables");
    getTableAttrs(fout, tblinfo, numTables);
 
    pg_log_info("flagging inherited columns in subtables");
    flagInhAttrs(fout, fout->dopt, tblinfo, numTables);
 
    pg_log_info("reading partitioning data");
    getPartitioningInfo(fout);
 
    pg_log_info("reading indexes");
    getIndexes(fout, tblinfo, numTables);
 
    pg_log_info("flagging indexes in partitioned tables");
    flagInhIndexes(fout, tblinfo, numTables);
 
    pg_log_info("reading extended statistics");
    getExtendedStatistics(fout);
 
    pg_log_info("reading constraints");
    getConstraints(fout, tblinfo, numTables);
 
    pg_log_info("reading triggers");
    getTriggers(fout, tblinfo, numTables);
 
    pg_log_info("reading rewrite rules");
    getRules(fout);
 
    pg_log_info("reading policies");
    getPolicies(fout, tblinfo, numTables);
 
    pg_log_info("reading publications");
    getPublications(fout);
 
    pg_log_info("reading publication membership of tables");
    getPublicationTables(fout, tblinfo, numTables);
 
    pg_log_info("reading publication membership of schemas");
    getPublicationNamespaces(fout);
 
    pg_log_info("reading subscriptions");
    getSubscriptions(fout);
 
    pg_log_info("reading subscription membership of relations");
    getSubscriptionRelations(fout);
 
    free(inhinfo);              /* not needed any longer */
 
    *numTablesPtr = numTables;
    return tblinfo;
}

References Archive::dopt, fb(), flagInhAttrs(), flagInhIndexes(), flagInhTables(), fout, free, getAccessMethods(), getAggregates(), getCasts(), getCollations(), getConstraints(), getConversions(), getDefaultACLs(), getEventTriggers(), getExtendedStatistics(), getExtensionMembership(), getExtensions(), getForeignDataWrappers(), getForeignServers(), getFuncs(), getIndexes(), getInherits(), getNamespaces(), getOpclasses(), getOperators(), getOpfamilies(), getOwnedSeqs(), getPartitioningInfo(), getPolicies(), getProcLangs(), getPublicationNamespaces(), getPublications(), getPublicationTables(), getRules(), getSubscriptionRelations(), getSubscriptions(), getTableAttrs(), getTables(), getTransforms(), getTriggers(), getTSConfigurations(), getTSDictionaries(), getTSParsers(), getTSTemplates(), getTypes(), pg_log_info, and processExtensionTables().

Referenced by main().

getSubscriptionRelations()

void getSubscriptionRelations ( Archive *  fout )

extern

Definition at line 5408 of file pg_dump.c.

{
    DumpOptions *dopt = fout->dopt;
    SubscriptionInfo *subinfo = NULL;
    SubRelInfo *subrinfo;
    PGresult   *res;
    int         i_srsubid;
    int         i_srrelid;
    int         i_srsubstate;
    int         i_srsublsn;
    int         ntups;
    Oid         last_srsubid = InvalidOid;
 
    if (dopt->no_subscriptions || !dopt->binary_upgrade ||
        fout->remoteVersion < 170000)
        return;
 
    res = ExecuteSqlQuery(fout,
                          "SELECT srsubid, srrelid, srsubstate, srsublsn "
                          "FROM pg_catalog.pg_subscription_rel "
                          "ORDER BY srsubid",
                          PGRES_TUPLES_OK);
    ntups = PQntuples(res);
    if (ntups == 0)
        goto cleanup;
 
    /* Get pg_subscription_rel attributes */
    i_srsubid = PQfnumber(res, "srsubid");
    i_srrelid = PQfnumber(res, "srrelid");
    i_srsubstate = PQfnumber(res, "srsubstate");
    i_srsublsn = PQfnumber(res, "srsublsn");
 
    subrinfo = pg_malloc_array(SubRelInfo, ntups);
    for (int i = 0; i < ntups; i++)
    {
        Oid         cur_srsubid = atooid(PQgetvalue(res, i, i_srsubid));
        Oid         relid = atooid(PQgetvalue(res, i, i_srrelid));
        TableInfo  *tblinfo;
 
        /*
         * If we switched to a new subscription, check if the subscription
         * exists.
         */
        if (cur_srsubid != last_srsubid)
        {
            subinfo = findSubscriptionByOid(cur_srsubid);
            if (subinfo == NULL)
                pg_fatal("subscription with OID %u does not exist", cur_srsubid);
 
            last_srsubid = cur_srsubid;
        }
 
        tblinfo = findTableByOid(relid);
        if (tblinfo == NULL)
            pg_fatal("failed sanity check, relation with OID %u not found",
                     relid);
 
        /* OK, make a DumpableObject for this relationship */
        subrinfo[i].dobj.objType = DO_SUBSCRIPTION_REL;
        subrinfo[i].dobj.catId.tableoid = relid;
        subrinfo[i].dobj.catId.oid = cur_srsubid;
        AssignDumpId(&subrinfo[i].dobj);
        subrinfo[i].dobj.namespace = tblinfo->dobj.namespace;
        subrinfo[i].dobj.name = tblinfo->dobj.name;
        subrinfo[i].subinfo = subinfo;
        subrinfo[i].tblinfo = tblinfo;
        subrinfo[i].srsubstate = PQgetvalue(res, i, i_srsubstate)[0];
        if (PQgetisnull(res, i, i_srsublsn))
            subrinfo[i].srsublsn = NULL;
        else
            subrinfo[i].srsublsn = pg_strdup(PQgetvalue(res, i, i_srsublsn));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(subrinfo[i].dobj), fout);
    }
 
cleanup:
    PQclear(res);
}

References AssignDumpId(), atooid, _dumpOptions::binary_upgrade, cleanup(), DO_SUBSCRIPTION_REL, _tableInfo::dobj, Archive::dopt, ExecuteSqlQuery(), fb(), findSubscriptionByOid(), findTableByOid(), fout, i, InvalidOid, _dumpableObject::name, _dumpOptions::no_subscriptions, pg_fatal, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, Archive::remoteVersion, and selectDumpableObject().

Referenced by getSchemaData().

getSubscriptions()

void getSubscriptions ( Archive *  fout )

extern

Definition at line 5159 of file pg_dump.c.

{
    DumpOptions *dopt = fout->dopt;
    PQExpBuffer query;
    PGresult   *res;
    SubscriptionInfo *subinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_subname;
    int         i_subowner;
    int         i_subbinary;
    int         i_substream;
    int         i_subtwophasestate;
    int         i_subdisableonerr;
    int         i_subpasswordrequired;
    int         i_subrunasowner;
    int         i_subservername;
    int         i_subconninfo;
    int         i_subslotname;
    int         i_subsynccommit;
    int         i_subwalrcvtimeout;
    int         i_subpublications;
    int         i_suborigin;
    int         i_suboriginremotelsn;
    int         i_subenabled;
    int         i_subfailover;
    int         i_subretaindeadtuples;
    int         i_submaxretention;
    int         i,
                ntups;
 
    if (dopt->no_subscriptions || fout->remoteVersion < 100000)
        return;
 
    if (!is_superuser(fout))
    {
        int         n;
 
        res = ExecuteSqlQuery(fout,
                              "SELECT count(*) FROM pg_subscription "
                              "WHERE subdbid = (SELECT oid FROM pg_database"
                              "                 WHERE datname = current_database())",
                              PGRES_TUPLES_OK);
        n = atoi(PQgetvalue(res, 0, 0));
        if (n > 0)
            pg_log_warning("subscriptions not dumped because current user is not a superuser");
        PQclear(res);
        return;
    }
 
    query = createPQExpBuffer();
 
    /* Get the subscriptions in current database. */
    appendPQExpBufferStr(query,
                         "SELECT s.tableoid, s.oid, s.subname,\n"
                         " s.subowner,\n"
                         " s.subconninfo, s.subslotname, s.subsynccommit,\n"
                         " s.subpublications,\n");
 
    if (fout->remoteVersion >= 140000)
        appendPQExpBufferStr(query, " s.subbinary,\n");
    else
        appendPQExpBufferStr(query, " false AS subbinary,\n");
 
    if (fout->remoteVersion >= 140000)
        appendPQExpBufferStr(query, " s.substream,\n");
    else
        appendPQExpBufferStr(query, " 'f' AS substream,\n");
 
    if (fout->remoteVersion >= 150000)
        appendPQExpBufferStr(query,
                             " s.subtwophasestate,\n"
                             " s.subdisableonerr,\n");
    else
        appendPQExpBuffer(query,
                          " '%c' AS subtwophasestate,\n"
                          " false AS subdisableonerr,\n",
                          LOGICALREP_TWOPHASE_STATE_DISABLED);
 
    if (fout->remoteVersion >= 160000)
        appendPQExpBufferStr(query,
                             " s.subpasswordrequired,\n"
                             " s.subrunasowner,\n"
                             " s.suborigin,\n");
    else
        appendPQExpBuffer(query,
                          " 't' AS subpasswordrequired,\n"
                          " 't' AS subrunasowner,\n"
                          " '%s' AS suborigin,\n",
                          LOGICALREP_ORIGIN_ANY);
 
    if (dopt->binary_upgrade && fout->remoteVersion >= 170000)
        appendPQExpBufferStr(query, " o.remote_lsn AS suboriginremotelsn,\n"
                             " s.subenabled,\n");
    else
        appendPQExpBufferStr(query, " NULL AS suboriginremotelsn,\n"
                             " false AS subenabled,\n");
 
    if (fout->remoteVersion >= 170000)
        appendPQExpBufferStr(query,
                             " s.subfailover,\n");
    else
        appendPQExpBufferStr(query,
                             " false AS subfailover,\n");
 
    if (fout->remoteVersion >= 190000)
        appendPQExpBufferStr(query,
                             " s.subretaindeadtuples,\n");
    else
        appendPQExpBufferStr(query,
                             " false AS subretaindeadtuples,\n");
 
    if (fout->remoteVersion >= 190000)
        appendPQExpBufferStr(query,
                             " s.submaxretention,\n");
    else
        appendPQExpBufferStr(query, " 0 AS submaxretention,\n");
 
    if (fout->remoteVersion >= 190000)
        appendPQExpBufferStr(query,
                             " s.subwalrcvtimeout,\n");
    else
        appendPQExpBufferStr(query,
                             " '-1' AS subwalrcvtimeout,\n");
 
    if (fout->remoteVersion >= 190000)
        appendPQExpBufferStr(query, " fs.srvname AS subservername\n");
    else
        appendPQExpBufferStr(query, " NULL AS subservername\n");
 
    appendPQExpBufferStr(query,
                         "FROM pg_subscription s\n");
 
    if (fout->remoteVersion >= 190000)
        appendPQExpBufferStr(query,
                             "LEFT JOIN pg_catalog.pg_foreign_server fs \n"
                             "    ON fs.oid = s.subserver \n");
 
    if (dopt->binary_upgrade && fout->remoteVersion >= 170000)
        appendPQExpBufferStr(query,
                             "LEFT JOIN pg_catalog.pg_replication_origin_status o \n"
                             "    ON o.external_id = 'pg_' || s.oid::text \n");
 
    appendPQExpBufferStr(query,
                         "WHERE s.subdbid = (SELECT oid FROM pg_database\n"
                         "                   WHERE datname = current_database())");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    /*
     * Get subscription fields. We don't include subskiplsn in the dump as
     * after restoring the dump this value may no longer be relevant.
     */
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_subname = PQfnumber(res, "subname");
    i_subowner = PQfnumber(res, "subowner");
    i_subenabled = PQfnumber(res, "subenabled");
    i_subbinary = PQfnumber(res, "subbinary");
    i_substream = PQfnumber(res, "substream");
    i_subtwophasestate = PQfnumber(res, "subtwophasestate");
    i_subdisableonerr = PQfnumber(res, "subdisableonerr");
    i_subpasswordrequired = PQfnumber(res, "subpasswordrequired");
    i_subrunasowner = PQfnumber(res, "subrunasowner");
    i_subfailover = PQfnumber(res, "subfailover");
    i_subretaindeadtuples = PQfnumber(res, "subretaindeadtuples");
    i_submaxretention = PQfnumber(res, "submaxretention");
    i_subservername = PQfnumber(res, "subservername");
    i_subconninfo = PQfnumber(res, "subconninfo");
    i_subslotname = PQfnumber(res, "subslotname");
    i_subsynccommit = PQfnumber(res, "subsynccommit");
    i_subwalrcvtimeout = PQfnumber(res, "subwalrcvtimeout");
    i_subpublications = PQfnumber(res, "subpublications");
    i_suborigin = PQfnumber(res, "suborigin");
    i_suboriginremotelsn = PQfnumber(res, "suboriginremotelsn");
 
    subinfo = pg_malloc_array(SubscriptionInfo, ntups);
 
    for (i = 0; i < ntups; i++)
    {
        subinfo[i].dobj.objType = DO_SUBSCRIPTION;
        subinfo[i].dobj.catId.tableoid =
            atooid(PQgetvalue(res, i, i_tableoid));
        subinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&subinfo[i].dobj);
        subinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_subname));
        subinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_subowner));
 
        subinfo[i].subenabled =
            (strcmp(PQgetvalue(res, i, i_subenabled), "t") == 0);
        if (PQgetisnull(res, i, i_subservername))
            subinfo[i].subservername = NULL;
        else
            subinfo[i].subservername = pg_strdup(PQgetvalue(res, i, i_subservername));
        subinfo[i].subbinary =
            (strcmp(PQgetvalue(res, i, i_subbinary), "t") == 0);
        subinfo[i].substream = *(PQgetvalue(res, i, i_substream));
        subinfo[i].subtwophasestate = *(PQgetvalue(res, i, i_subtwophasestate));
        subinfo[i].subdisableonerr =
            (strcmp(PQgetvalue(res, i, i_subdisableonerr), "t") == 0);
        subinfo[i].subpasswordrequired =
            (strcmp(PQgetvalue(res, i, i_subpasswordrequired), "t") == 0);
        subinfo[i].subrunasowner =
            (strcmp(PQgetvalue(res, i, i_subrunasowner), "t") == 0);
        subinfo[i].subfailover =
            (strcmp(PQgetvalue(res, i, i_subfailover), "t") == 0);
        subinfo[i].subretaindeadtuples =
            (strcmp(PQgetvalue(res, i, i_subretaindeadtuples), "t") == 0);
        subinfo[i].submaxretention =
            atoi(PQgetvalue(res, i, i_submaxretention));
        if (PQgetisnull(res, i, i_subconninfo))
            subinfo[i].subconninfo = NULL;
        else
            subinfo[i].subconninfo =
                pg_strdup(PQgetvalue(res, i, i_subconninfo));
        if (PQgetisnull(res, i, i_subslotname))
            subinfo[i].subslotname = NULL;
        else
            subinfo[i].subslotname =
                pg_strdup(PQgetvalue(res, i, i_subslotname));
        subinfo[i].subsynccommit =
            pg_strdup(PQgetvalue(res, i, i_subsynccommit));
        subinfo[i].subwalrcvtimeout =
            pg_strdup(PQgetvalue(res, i, i_subwalrcvtimeout));
        subinfo[i].subpublications =
            pg_strdup(PQgetvalue(res, i, i_subpublications));
        subinfo[i].suborigin = pg_strdup(PQgetvalue(res, i, i_suborigin));
        if (PQgetisnull(res, i, i_suboriginremotelsn))
            subinfo[i].suboriginremotelsn = NULL;
        else
            subinfo[i].suboriginremotelsn =
                pg_strdup(PQgetvalue(res, i, i_suboriginremotelsn));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(subinfo[i].dobj), fout);
    }
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBuffer(), appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpOptions::binary_upgrade, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_SUBSCRIPTION, _SubscriptionInfo::dobj, Archive::dopt, ExecuteSqlQuery(), fb(), fout, getRoleName(), i, is_superuser(), _dumpableObject::name, _dumpOptions::no_subscriptions, _dumpableObject::objType, CatalogId::oid, pg_log_warning, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, Archive::remoteVersion, _SubscriptionInfo::rolname, selectDumpableObject(), _SubscriptionInfo::subbinary, _SubscriptionInfo::subconninfo, _SubscriptionInfo::subdisableonerr, _SubscriptionInfo::subenabled, _SubscriptionInfo::subfailover, _SubscriptionInfo::submaxretention, _SubscriptionInfo::suborigin, _SubscriptionInfo::suboriginremotelsn, _SubscriptionInfo::subpasswordrequired, _SubscriptionInfo::subpublications, _SubscriptionInfo::subretaindeadtuples, _SubscriptionInfo::subrunasowner, _SubscriptionInfo::subservername, _SubscriptionInfo::subslotname, _SubscriptionInfo::substream, _SubscriptionInfo::subsynccommit, _SubscriptionInfo::subtwophasestate, _SubscriptionInfo::subwalrcvtimeout, and CatalogId::tableoid.

Referenced by getSchemaData().

getTableAttrs()

void getTableAttrs ( Archive *  fout, TableInfo *  tblinfo, int  numTables  )

extern

Definition at line 9331 of file pg_dump.c.

{
    DumpOptions *dopt = fout->dopt;
    PQExpBuffer q = createPQExpBuffer();
    PQExpBuffer tbloids = createPQExpBuffer();
    PQExpBuffer checkoids = createPQExpBuffer();
    PQExpBuffer invalidnotnulloids = NULL;
    PGresult   *res;
    int         ntups;
    int         curtblindx;
    int         i_attrelid;
    int         i_attnum;
    int         i_attname;
    int         i_atttypname;
    int         i_attstattarget;
    int         i_attstorage;
    int         i_typstorage;
    int         i_attidentity;
    int         i_attgenerated;
    int         i_attisdropped;
    int         i_attlen;
    int         i_attalign;
    int         i_attislocal;
    int         i_notnull_name;
    int         i_notnull_comment;
    int         i_notnull_noinherit;
    int         i_notnull_islocal;
    int         i_notnull_invalidoid;
    int         i_attoptions;
    int         i_attcollation;
    int         i_attcompression;
    int         i_attfdwoptions;
    int         i_attmissingval;
    int         i_atthasdef;
 
    /*
     * We want to perform just one query against pg_attribute, and then just
     * one against pg_attrdef (for DEFAULTs) and two against pg_constraint
     * (for CHECK constraints and for NOT NULL constraints).  However, we
     * mustn't try to select every row of those catalogs and then sort it out
     * on the client side, because some of the server-side functions we need
     * would be unsafe to apply to tables we don't have lock on.  Hence, we
     * build an array of the OIDs of tables we care about (and now have lock
     * on!), and use a WHERE clause to constrain which rows are selected.
     */
    appendPQExpBufferChar(tbloids, '{');
    appendPQExpBufferChar(checkoids, '{');
    for (int 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.  For binary
         * upgrades, this is bypassed for pg_largeobject_metadata and
         * pg_shdepend so that the columns names are collected for the
         * corresponding COPY commands.  Restoring the data for those catalogs
         * is faster than restoring the equivalent set of large object
         * commands.
         */
        if (!tbinfo->interesting &&
            !(fout->dopt->binary_upgrade &&
              (tbinfo->dobj.catId.oid == LargeObjectMetadataRelationId ||
               tbinfo->dobj.catId.oid == SharedDependRelationId)))
            continue;
 
        /* OK, we need info for this table */
        if (tbloids->len > 1)   /* do we have more than the '{'? */
            appendPQExpBufferChar(tbloids, ',');
        appendPQExpBuffer(tbloids, "%u", tbinfo->dobj.catId.oid);
 
        if (tbinfo->ncheck > 0)
        {
            /* Also make a list of the ones with check constraints */
            if (checkoids->len > 1) /* do we have more than the '{'? */
                appendPQExpBufferChar(checkoids, ',');
            appendPQExpBuffer(checkoids, "%u", tbinfo->dobj.catId.oid);
        }
    }
    appendPQExpBufferChar(tbloids, '}');
    appendPQExpBufferChar(checkoids, '}');
 
    /*
     * Find all the user attributes and their types.
     *
     * 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.
     */
    appendPQExpBufferStr(q,
                         "SELECT\n"
                         "a.attrelid,\n"
                         "a.attnum,\n"
                         "a.attname,\n"
                         "a.attstattarget,\n"
                         "a.attstorage,\n"
                         "t.typstorage,\n"
                         "a.atthasdef,\n"
                         "a.attisdropped,\n"
                         "a.attlen,\n"
                         "a.attalign,\n"
                         "a.attislocal,\n"
                         "pg_catalog.format_type(t.oid, a.atttypmod) AS atttypname,\n"
                         "array_to_string(a.attoptions, ', ') AS attoptions,\n"
                         "CASE WHEN a.attcollation <> t.typcollation "
                         "THEN a.attcollation ELSE 0 END AS attcollation,\n"
                         "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,\n");
 
    /*
     * Find out any NOT NULL markings for each column.  In 18 and up we read
     * pg_constraint to obtain the constraint name, and for valid constraints
     * also pg_description to obtain its comment.  notnull_noinherit is set
     * according to the NO INHERIT property.  For versions prior to 18, we
     * store an empty string as the name when a constraint is marked as
     * attnotnull (this cues dumpTableSchema to print the NOT NULL clause
     * without a name); also, such cases are never NO INHERIT.
     *
     * For invalid constraints, we need to store their OIDs for processing
     * elsewhere, so we bring the pg_constraint.oid value when the constraint
     * is invalid, and NULL otherwise.  Their comments are handled not here
     * but by collectComments, because they're their own dumpable object.
     *
     * We track in notnull_islocal whether the constraint was defined directly
     * in this table or via an ancestor, for binary upgrade.  flagInhAttrs
     * might modify this later.
     */
    if (fout->remoteVersion >= 180000)
        appendPQExpBufferStr(q,
                             "co.conname AS notnull_name,\n"
                             "CASE WHEN co.convalidated THEN pt.description"
                             " ELSE NULL END AS notnull_comment,\n"
                             "CASE WHEN NOT co.convalidated THEN co.oid "
                             "ELSE NULL END AS notnull_invalidoid,\n"
                             "co.connoinherit AS notnull_noinherit,\n"
                             "co.conislocal AS notnull_islocal,\n");
    else
        appendPQExpBufferStr(q,
                             "CASE WHEN a.attnotnull THEN '' ELSE NULL END AS notnull_name,\n"
                             "NULL AS notnull_comment,\n"
                             "NULL AS notnull_invalidoid,\n"
                             "false AS notnull_noinherit,\n"
                             "CASE WHEN a.attislocal THEN true\n"
                             "     WHEN a.attnotnull AND NOT a.attislocal THEN true\n"
                             "     ELSE false\n"
                             "END AS notnull_islocal,\n");
 
    if (fout->remoteVersion >= 140000)
        appendPQExpBufferStr(q,
                             "a.attcompression AS attcompression,\n");
    else
        appendPQExpBufferStr(q,
                             "'' AS attcompression,\n");
 
    if (fout->remoteVersion >= 100000)
        appendPQExpBufferStr(q,
                             "a.attidentity,\n");
    else
        appendPQExpBufferStr(q,
                             "'' AS attidentity,\n");
 
    if (fout->remoteVersion >= 110000)
        appendPQExpBufferStr(q,
                             "CASE WHEN a.atthasmissing AND NOT a.attisdropped "
                             "THEN a.attmissingval ELSE null END AS attmissingval,\n");
    else
        appendPQExpBufferStr(q,
                             "NULL AS attmissingval,\n");
 
    if (fout->remoteVersion >= 120000)
        appendPQExpBufferStr(q,
                             "a.attgenerated\n");
    else
        appendPQExpBufferStr(q,
                             "'' AS attgenerated\n");
 
    /* need left join to pg_type to not fail on dropped columns ... */
    appendPQExpBuffer(q,
                      "FROM unnest('%s'::pg_catalog.oid[]) AS src(tbloid)\n"
                      "JOIN pg_catalog.pg_attribute a ON (src.tbloid = a.attrelid) "
                      "LEFT JOIN pg_catalog.pg_type t "
                      "ON (a.atttypid = t.oid)\n",
                      tbloids->data);
 
    /*
     * In versions 18 and up, we need pg_constraint for explicit NOT NULL
     * entries and pg_description to get their comments.
     */
    if (fout->remoteVersion >= 180000)
        appendPQExpBufferStr(q,
                             " LEFT JOIN pg_catalog.pg_constraint co ON "
                             "(a.attrelid = co.conrelid\n"
                             "   AND co.contype = 'n' AND "
                             "co.conkey = array[a.attnum])\n"
                             " LEFT JOIN pg_catalog.pg_description pt ON "
                             "(pt.classoid = co.tableoid AND pt.objoid = co.oid)\n");
 
    appendPQExpBufferStr(q,
                         "WHERE a.attnum > 0::pg_catalog.int2\n");
 
    /*
     * For binary upgrades from <v12, be sure to pick up
     * pg_largeobject_metadata's oid column.
     */
    if (fout->dopt->binary_upgrade && fout->remoteVersion < 120000)
        appendPQExpBufferStr(q,
                             "OR (a.attnum = -2::pg_catalog.int2 AND src.tbloid = "
                             CppAsString2(LargeObjectMetadataRelationId) ")\n");
 
    appendPQExpBufferStr(q,
                         "ORDER BY a.attrelid, a.attnum");
 
    res = ExecuteSqlQuery(fout, q->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    i_attrelid = PQfnumber(res, "attrelid");
    i_attnum = PQfnumber(res, "attnum");
    i_attname = PQfnumber(res, "attname");
    i_atttypname = PQfnumber(res, "atttypname");
    i_attstattarget = PQfnumber(res, "attstattarget");
    i_attstorage = PQfnumber(res, "attstorage");
    i_typstorage = PQfnumber(res, "typstorage");
    i_attidentity = PQfnumber(res, "attidentity");
    i_attgenerated = PQfnumber(res, "attgenerated");
    i_attisdropped = PQfnumber(res, "attisdropped");
    i_attlen = PQfnumber(res, "attlen");
    i_attalign = PQfnumber(res, "attalign");
    i_attislocal = PQfnumber(res, "attislocal");
    i_notnull_name = PQfnumber(res, "notnull_name");
    i_notnull_comment = PQfnumber(res, "notnull_comment");
    i_notnull_invalidoid = PQfnumber(res, "notnull_invalidoid");
    i_notnull_noinherit = PQfnumber(res, "notnull_noinherit");
    i_notnull_islocal = PQfnumber(res, "notnull_islocal");
    i_attoptions = PQfnumber(res, "attoptions");
    i_attcollation = PQfnumber(res, "attcollation");
    i_attcompression = PQfnumber(res, "attcompression");
    i_attfdwoptions = PQfnumber(res, "attfdwoptions");
    i_attmissingval = PQfnumber(res, "attmissingval");
    i_atthasdef = PQfnumber(res, "atthasdef");
 
    /* Within the next loop, we'll accumulate OIDs of tables with defaults */
    resetPQExpBuffer(tbloids);
    appendPQExpBufferChar(tbloids, '{');
 
    /*
     * Outer loop iterates once per table, not once per row.  Incrementing of
     * r is handled by the inner loop.
     */
    curtblindx = -1;
    for (int r = 0; r < ntups;)
    {
        Oid         attrelid = atooid(PQgetvalue(res, r, i_attrelid));
        TableInfo  *tbinfo = NULL;
        int         numatts;
        bool        hasdefaults;
 
        /* Count rows for this table */
        for (numatts = 1; numatts < ntups - r; numatts++)
            if (atooid(PQgetvalue(res, r + numatts, i_attrelid)) != attrelid)
                break;
 
        /*
         * Locate the associated TableInfo; we rely on tblinfo[] being in OID
         * order.
         */
        while (++curtblindx < numTables)
        {
            tbinfo = &tblinfo[curtblindx];
            if (tbinfo->dobj.catId.oid == attrelid)
                break;
        }
        if (curtblindx >= numTables)
            pg_fatal("unrecognized table OID %u", attrelid);
        /* cross-check that we only got requested tables */
        if (tbinfo->relkind == RELKIND_SEQUENCE ||
            (!tbinfo->interesting &&
             !(fout->dopt->binary_upgrade &&
               (tbinfo->dobj.catId.oid == LargeObjectMetadataRelationId ||
                tbinfo->dobj.catId.oid == SharedDependRelationId))))
            pg_fatal("unexpected column data for table \"%s\"",
                     tbinfo->dobj.name);
 
        /* Save data for this table */
        tbinfo->numatts = numatts;
        tbinfo->attnames = pg_malloc_array(char *, numatts);
        tbinfo->atttypnames = pg_malloc_array(char *, numatts);
        tbinfo->attstattarget = pg_malloc_array(int, numatts);
        tbinfo->attstorage = pg_malloc_array(char, numatts);
        tbinfo->typstorage = pg_malloc_array(char, numatts);
        tbinfo->attidentity = pg_malloc_array(char, numatts);
        tbinfo->attgenerated = pg_malloc_array(char, numatts);
        tbinfo->attisdropped = pg_malloc_array(bool, numatts);
        tbinfo->attlen = pg_malloc_array(int, numatts);
        tbinfo->attalign = pg_malloc_array(char, numatts);
        tbinfo->attislocal = pg_malloc_array(bool, numatts);
        tbinfo->attoptions = pg_malloc_array(char *, numatts);
        tbinfo->attcollation = pg_malloc_array(Oid, numatts);
        tbinfo->attcompression = pg_malloc_array(char, numatts);
        tbinfo->attfdwoptions = pg_malloc_array(char *, numatts);
        tbinfo->attmissingval = pg_malloc_array(char *, numatts);
        tbinfo->notnull_constrs = pg_malloc_array(char *, numatts);
        tbinfo->notnull_comment = pg_malloc_array(char *, numatts);
        tbinfo->notnull_invalid = pg_malloc_array(bool, numatts);
        tbinfo->notnull_noinh = pg_malloc_array(bool, numatts);
        tbinfo->notnull_islocal = pg_malloc_array(bool, numatts);
        tbinfo->attrdefs = pg_malloc_array(AttrDefInfo *, numatts);
        hasdefaults = false;
 
        for (int j = 0; j < numatts; j++, r++)
        {
            if (j + 1 != atoi(PQgetvalue(res, r, i_attnum)) &&
                !(fout->dopt->binary_upgrade && fout->remoteVersion < 120000 &&
                  tbinfo->dobj.catId.oid == LargeObjectMetadataRelationId))
                pg_fatal("invalid column numbering in table \"%s\"",
                         tbinfo->dobj.name);
            tbinfo->attnames[j] = pg_strdup(PQgetvalue(res, r, i_attname));
            tbinfo->atttypnames[j] = pg_strdup(PQgetvalue(res, r, i_atttypname));
            if (PQgetisnull(res, r, i_attstattarget))
                tbinfo->attstattarget[j] = -1;
            else
                tbinfo->attstattarget[j] = atoi(PQgetvalue(res, r, i_attstattarget));
            tbinfo->attstorage[j] = *(PQgetvalue(res, r, i_attstorage));
            tbinfo->typstorage[j] = *(PQgetvalue(res, r, i_typstorage));
            tbinfo->attidentity[j] = *(PQgetvalue(res, r, i_attidentity));
            tbinfo->attgenerated[j] = *(PQgetvalue(res, r, i_attgenerated));
            tbinfo->needs_override = tbinfo->needs_override || (tbinfo->attidentity[j] == ATTRIBUTE_IDENTITY_ALWAYS);
            tbinfo->attisdropped[j] = (PQgetvalue(res, r, i_attisdropped)[0] == 't');
            tbinfo->attlen[j] = atoi(PQgetvalue(res, r, i_attlen));
            tbinfo->attalign[j] = *(PQgetvalue(res, r, i_attalign));
            tbinfo->attislocal[j] = (PQgetvalue(res, r, i_attislocal)[0] == 't');
 
            /* Handle not-null constraint name and flags */
            determineNotNullFlags(fout, res, r,
                                  tbinfo, j,
                                  i_notnull_name,
                                  i_notnull_comment,
                                  i_notnull_invalidoid,
                                  i_notnull_noinherit,
                                  i_notnull_islocal,
                                  &invalidnotnulloids);
 
            tbinfo->notnull_comment[j] = PQgetisnull(res, r, i_notnull_comment) ?
                NULL : pg_strdup(PQgetvalue(res, r, i_notnull_comment));
            tbinfo->attoptions[j] = pg_strdup(PQgetvalue(res, r, i_attoptions));
            tbinfo->attcollation[j] = atooid(PQgetvalue(res, r, i_attcollation));
            tbinfo->attcompression[j] = *(PQgetvalue(res, r, i_attcompression));
            tbinfo->attfdwoptions[j] = pg_strdup(PQgetvalue(res, r, i_attfdwoptions));
            tbinfo->attmissingval[j] = pg_strdup(PQgetvalue(res, r, i_attmissingval));
            tbinfo->attrdefs[j] = NULL; /* fix below */
            if (PQgetvalue(res, r, i_atthasdef)[0] == 't')
                hasdefaults = true;
        }
 
        if (hasdefaults)
        {
            /* Collect OIDs of interesting tables that have defaults */
            if (tbloids->len > 1)   /* do we have more than the '{'? */
                appendPQExpBufferChar(tbloids, ',');
            appendPQExpBuffer(tbloids, "%u", tbinfo->dobj.catId.oid);
        }
    }
 
    /* If invalidnotnulloids has any data, finalize it */
    if (invalidnotnulloids != NULL)
        appendPQExpBufferChar(invalidnotnulloids, '}');
 
    PQclear(res);
 
    /*
     * Now get info about column defaults.  This is skipped for a data-only
     * dump, as it is only needed for table schemas.
     */
    if (dopt->dumpSchema && tbloids->len > 1)
    {
        AttrDefInfo *attrdefs;
        int         numDefaults;
        TableInfo  *tbinfo = NULL;
 
        pg_log_info("finding table default expressions");
 
        appendPQExpBufferChar(tbloids, '}');
 
        printfPQExpBuffer(q, "SELECT a.tableoid, a.oid, adrelid, adnum, "
                          "pg_catalog.pg_get_expr(adbin, adrelid) AS adsrc\n"
                          "FROM unnest('%s'::pg_catalog.oid[]) AS src(tbloid)\n"
                          "JOIN pg_catalog.pg_attrdef a ON (src.tbloid = a.adrelid)\n"
                          "ORDER BY a.adrelid, a.adnum",
                          tbloids->data);
 
        res = ExecuteSqlQuery(fout, q->data, PGRES_TUPLES_OK);
 
        numDefaults = PQntuples(res);
        attrdefs = pg_malloc_array(AttrDefInfo, numDefaults);
 
        curtblindx = -1;
        for (int j = 0; j < numDefaults; j++)
        {
            Oid         adtableoid = atooid(PQgetvalue(res, j, 0));
            Oid         adoid = atooid(PQgetvalue(res, j, 1));
            Oid         adrelid = atooid(PQgetvalue(res, j, 2));
            int         adnum = atoi(PQgetvalue(res, j, 3));
            char       *adsrc = PQgetvalue(res, j, 4);
 
            /*
             * Locate the associated TableInfo; we rely on tblinfo[] being in
             * OID order.
             */
            if (tbinfo == NULL || tbinfo->dobj.catId.oid != adrelid)
            {
                while (++curtblindx < numTables)
                {
                    tbinfo = &tblinfo[curtblindx];
                    if (tbinfo->dobj.catId.oid == adrelid)
                        break;
                }
                if (curtblindx >= numTables)
                    pg_fatal("unrecognized table OID %u", adrelid);
            }
 
            if (adnum <= 0 || adnum > tbinfo->numatts)
                pg_fatal("invalid adnum value %d for table \"%s\"",
                         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 = adtableoid;
            attrdefs[j].dobj.catId.oid = adoid;
            AssignDumpId(&attrdefs[j].dobj);
            attrdefs[j].adtable = tbinfo;
            attrdefs[j].adnum = adnum;
            attrdefs[j].adef_expr = pg_strdup(adsrc);
 
            attrdefs[j].dobj.name = pg_strdup(tbinfo->dobj.name);
            attrdefs[j].dobj.namespace = tbinfo->dobj.namespace;
 
            attrdefs[j].dobj.dump = tbinfo->dobj.dump;
 
            /*
             * Figure out whether the default/generation expression should be
             * dumped as part of the main CREATE TABLE (or similar) command or
             * as a separate ALTER TABLE (or similar) command. The preference
             * is to put it into the CREATE command, but in some cases that's
             * not possible.
             */
            if (tbinfo->attgenerated[adnum - 1])
            {
                /*
                 * Column generation expressions cannot be dumped separately,
                 * because there is no syntax for it.  By setting separate to
                 * false here we prevent the "default" from being processed as
                 * its own dumpable object.  Later, flagInhAttrs() will mark
                 * it as not to be dumped at all, if possible (that is, if it
                 * can be inherited from a parent).
                 */
                attrdefs[j].separate = false;
            }
            else if (tbinfo->relkind == RELKIND_VIEW)
            {
                /*
                 * Defaults on a VIEW must always be dumped as separate ALTER
                 * TABLE commands.
                 */
                attrdefs[j].separate = true;
            }
            else if (!shouldPrintColumn(dopt, tbinfo, adnum - 1))
            {
                /* column will be suppressed, print default separately */
                attrdefs[j].separate = true;
            }
            else
            {
                attrdefs[j].separate = false;
            }
 
            if (!attrdefs[j].separate)
            {
                /*
                 * 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 NOT NULL NOT VALID constraints.  This is skipped for a
     * data-only dump, as it is only needed for table schemas.
     */
    if (dopt->dumpSchema && invalidnotnulloids)
    {
        ConstraintInfo *constrs;
        int         numConstrs;
        int         i_tableoid;
        int         i_oid;
        int         i_conrelid;
        int         i_conname;
        int         i_consrc;
        int         i_conislocal;
 
        pg_log_info("finding invalid not-null constraints");
 
        resetPQExpBuffer(q);
        appendPQExpBuffer(q,
                          "SELECT c.tableoid, c.oid, conrelid, conname, "
                          "pg_catalog.pg_get_constraintdef(c.oid) AS consrc, "
                          "conislocal, convalidated "
                          "FROM unnest('%s'::pg_catalog.oid[]) AS src(conoid)\n"
                          "JOIN pg_catalog.pg_constraint c ON (src.conoid = c.oid)\n"
                          "ORDER BY c.conrelid, c.conname",
                          invalidnotnulloids->data);
 
        res = ExecuteSqlQuery(fout, q->data, PGRES_TUPLES_OK);
 
        numConstrs = PQntuples(res);
        constrs = pg_malloc_array(ConstraintInfo, numConstrs);
 
        i_tableoid = PQfnumber(res, "tableoid");
        i_oid = PQfnumber(res, "oid");
        i_conrelid = PQfnumber(res, "conrelid");
        i_conname = PQfnumber(res, "conname");
        i_consrc = PQfnumber(res, "consrc");
        i_conislocal = PQfnumber(res, "conislocal");
 
        /* As above, this loop iterates once per table, not once per row */
        curtblindx = -1;
        for (int j = 0; j < numConstrs;)
        {
            Oid         conrelid = atooid(PQgetvalue(res, j, i_conrelid));
            TableInfo  *tbinfo = NULL;
            int         numcons;
 
            /* Count rows for this table */
            for (numcons = 1; numcons < numConstrs - j; numcons++)
                if (atooid(PQgetvalue(res, j + numcons, i_conrelid)) != conrelid)
                    break;
 
            /*
             * Locate the associated TableInfo; we rely on tblinfo[] being in
             * OID order.
             */
            while (++curtblindx < numTables)
            {
                tbinfo = &tblinfo[curtblindx];
                if (tbinfo->dobj.catId.oid == conrelid)
                    break;
            }
            if (curtblindx >= numTables)
                pg_fatal("unrecognized table OID %u", conrelid);
 
            for (int c = 0; c < numcons; c++, j++)
            {
                constrs[j].dobj.objType = DO_CONSTRAINT;
                constrs[j].dobj.catId.tableoid = atooid(PQgetvalue(res, j, i_tableoid));
                constrs[j].dobj.catId.oid = atooid(PQgetvalue(res, j, i_oid));
                AssignDumpId(&constrs[j].dobj);
                constrs[j].dobj.name = pg_strdup(PQgetvalue(res, j, i_conname));
                constrs[j].dobj.namespace = tbinfo->dobj.namespace;
                constrs[j].contable = tbinfo;
                constrs[j].condomain = NULL;
                constrs[j].contype = 'n';
                constrs[j].condef = pg_strdup(PQgetvalue(res, j, i_consrc));
                constrs[j].confrelid = InvalidOid;
                constrs[j].conindex = 0;
                constrs[j].condeferrable = false;
                constrs[j].condeferred = false;
                constrs[j].conislocal = (PQgetvalue(res, j, i_conislocal)[0] == 't');
 
                /*
                 * All invalid not-null constraints must be dumped separately,
                 * because CREATE TABLE would not create them as invalid, and
                 * also because they must be created after potentially
                 * violating data has been loaded.
                 */
                constrs[j].separate = true;
 
                constrs[j].dobj.dump = tbinfo->dobj.dump;
            }
        }
        PQclear(res);
    }
 
    /*
     * Get info about table CHECK constraints.  This is skipped for a
     * data-only dump, as it is only needed for table schemas.
     */
    if (dopt->dumpSchema && checkoids->len > 2)
    {
        ConstraintInfo *constrs;
        int         numConstrs;
        int         i_tableoid;
        int         i_oid;
        int         i_conrelid;
        int         i_conname;
        int         i_consrc;
        int         i_conislocal;
        int         i_convalidated;
 
        pg_log_info("finding table check constraints");
 
        resetPQExpBuffer(q);
        appendPQExpBuffer(q,
                          "SELECT c.tableoid, c.oid, conrelid, conname, "
                          "pg_catalog.pg_get_constraintdef(c.oid) AS consrc, "
                          "conislocal, convalidated "
                          "FROM unnest('%s'::pg_catalog.oid[]) AS src(tbloid)\n"
                          "JOIN pg_catalog.pg_constraint c ON (src.tbloid = c.conrelid)\n"
                          "WHERE contype = 'c' "
                          "ORDER BY c.conrelid, c.conname",
                          checkoids->data);
 
        res = ExecuteSqlQuery(fout, q->data, PGRES_TUPLES_OK);
 
        numConstrs = PQntuples(res);
        constrs = pg_malloc_array(ConstraintInfo, numConstrs);
 
        i_tableoid = PQfnumber(res, "tableoid");
        i_oid = PQfnumber(res, "oid");
        i_conrelid = PQfnumber(res, "conrelid");
        i_conname = PQfnumber(res, "conname");
        i_consrc = PQfnumber(res, "consrc");
        i_conislocal = PQfnumber(res, "conislocal");
        i_convalidated = PQfnumber(res, "convalidated");
 
        /* As above, this loop iterates once per table, not once per row */
        curtblindx = -1;
        for (int j = 0; j < numConstrs;)
        {
            Oid         conrelid = atooid(PQgetvalue(res, j, i_conrelid));
            TableInfo  *tbinfo = NULL;
            int         numcons;
 
            /* Count rows for this table */
            for (numcons = 1; numcons < numConstrs - j; numcons++)
                if (atooid(PQgetvalue(res, j + numcons, i_conrelid)) != conrelid)
                    break;
 
            /*
             * Locate the associated TableInfo; we rely on tblinfo[] being in
             * OID order.
             */
            while (++curtblindx < numTables)
            {
                tbinfo = &tblinfo[curtblindx];
                if (tbinfo->dobj.catId.oid == conrelid)
                    break;
            }
            if (curtblindx >= numTables)
                pg_fatal("unrecognized table OID %u", conrelid);
 
            if (numcons != tbinfo->ncheck)
            {
                pg_log_error(ngettext("expected %d check constraint on table \"%s\" but found %d",
                                      "expected %d check constraints on table \"%s\" but found %d",
                                      tbinfo->ncheck),
                             tbinfo->ncheck, tbinfo->dobj.name, numcons);
                pg_log_error_hint("The system catalogs might be corrupted.");
                exit_nicely(1);
            }
 
            tbinfo->checkexprs = constrs + j;
 
            for (int c = 0; c < numcons; c++, j++)
            {
                bool        validated = PQgetvalue(res, j, i_convalidated)[0] == 't';
 
                constrs[j].dobj.objType = DO_CONSTRAINT;
                constrs[j].dobj.catId.tableoid = atooid(PQgetvalue(res, j, i_tableoid));
                constrs[j].dobj.catId.oid = atooid(PQgetvalue(res, j, i_oid));
                AssignDumpId(&constrs[j].dobj);
                constrs[j].dobj.name = pg_strdup(PQgetvalue(res, j, i_conname));
                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, i_consrc));
                constrs[j].confrelid = InvalidOid;
                constrs[j].conindex = 0;
                constrs[j].condeferrable = false;
                constrs[j].condeferred = false;
                constrs[j].conislocal = (PQgetvalue(res, j, i_conislocal)[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);
 
                /*
                 * We will detect later whether the constraint must be split
                 * out from the table definition.
                 */
            }
        }
 
        PQclear(res);
    }
 
    destroyPQExpBuffer(q);
    destroyPQExpBuffer(tbloids);
    destroyPQExpBuffer(checkoids);
}

References addObjectDependency(), _attrDefInfo::adef_expr, _attrDefInfo::adnum, _attrDefInfo::adtable, appendPQExpBuffer(), appendPQExpBufferChar(), appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpOptions::binary_upgrade, _dumpableObject::catId, CppAsString2, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), determineNotNullFlags(), DO_ATTRDEF, DO_CONSTRAINT, _attrDefInfo::dobj, Archive::dopt, _dumpableObject::dump, _dumpableObject::dumpId, _dumpOptions::dumpSchema, ExecuteSqlQuery(), exit_nicely(), fb(), fout, i, InvalidOid, j, _dumpableObject::name, ngettext, _dumpableObject::objType, CatalogId::oid, pg_fatal, pg_log_error, pg_log_error_hint, pg_log_info, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, printfPQExpBuffer(), Archive::remoteVersion, resetPQExpBuffer(), _attrDefInfo::separate, shouldPrintColumn(), and CatalogId::tableoid.

Referenced by getSchemaData().

getTables()

TableInfo * getTables ( Archive *  fout, int *  numTables  )

extern

Definition at line 7278 of file pg_dump.c.

{
    DumpOptions *dopt = fout->dopt;
    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_reltype;
    int         i_relowner;
    int         i_relchecks;
    int         i_relhasindex;
    int         i_relhasrules;
    int         i_relpages;
    int         i_reltuples;
    int         i_relallvisible;
    int         i_relallfrozen;
    int         i_toastpages;
    int         i_owning_tab;
    int         i_owning_col;
    int         i_reltablespace;
    int         i_relhasoids;
    int         i_relhastriggers;
    int         i_relpersistence;
    int         i_relispopulated;
    int         i_relreplident;
    int         i_relrowsec;
    int         i_relforcerowsec;
    int         i_relfrozenxid;
    int         i_toastfrozenxid;
    int         i_toastoid;
    int         i_relminmxid;
    int         i_toastminmxid;
    int         i_reloptions;
    int         i_checkoption;
    int         i_toastreloptions;
    int         i_reloftype;
    int         i_foreignserver;
    int         i_amname;
    int         i_is_identity_sequence;
    int         i_relacl;
    int         i_acldefault;
    int         i_ispartition;
 
    /*
     * Find all the tables and table-like objects.
     *
     * We must fetch all tables in this phase because otherwise we cannot
     * correctly identify inherited columns, owned sequences, etc.
     *
     * We include system catalogs, so that we can work if a user table is
     * defined to inherit from a system catalog (pretty weird, but...)
     *
     * 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.  In particular, since we do not yet have lock on any user
     * table, we MUST NOT invoke any server-side data collection functions
     * (for instance, pg_get_partkeydef()).  Those are likely to fail or give
     * wrong answers if any concurrent DDL is happening.
     */
 
    appendPQExpBufferStr(query,
                         "SELECT c.tableoid, c.oid, c.relname, "
                         "c.relnamespace, c.relkind, c.reltype, "
                         "c.relowner, "
                         "c.relchecks, "
                         "c.relhasindex, c.relhasrules, c.relpages, "
                         "c.reltuples, c.relallvisible, ");
 
    if (fout->remoteVersion >= 180000)
        appendPQExpBufferStr(query, "c.relallfrozen, ");
    else
        appendPQExpBufferStr(query, "0 AS relallfrozen, ");
 
    appendPQExpBufferStr(query,
                         "c.relhastriggers, c.relpersistence, "
                         "c.reloftype, "
                         "c.relacl, "
                         "acldefault(CASE WHEN c.relkind = " CppAsString2(RELKIND_SEQUENCE)
                         " THEN 's'::\"char\" ELSE 'r'::\"char\" END, c.relowner) AS acldefault, "
                         "CASE WHEN c.relkind = " CppAsString2(RELKIND_FOREIGN_TABLE) " THEN "
                         "(SELECT ftserver FROM pg_catalog.pg_foreign_table WHERE ftrelid = c.oid) "
                         "ELSE 0 END AS foreignserver, "
                         "c.relfrozenxid, tc.relfrozenxid AS tfrozenxid, "
                         "tc.oid AS toid, "
                         "tc.relpages AS toastpages, "
                         "tc.reloptions AS toast_reloptions, "
                         "d.refobjid AS owning_tab, "
                         "d.refobjsubid AS owning_col, "
                         "tsp.spcname AS reltablespace, ");
 
    if (fout->remoteVersion >= 120000)
        appendPQExpBufferStr(query,
                             "false AS relhasoids, ");
    else
        appendPQExpBufferStr(query,
                             "c.relhasoids, ");
 
    if (fout->remoteVersion >= 90300)
        appendPQExpBufferStr(query,
                             "c.relispopulated, ");
    else
        appendPQExpBufferStr(query,
                             "'t' as relispopulated, ");
 
    if (fout->remoteVersion >= 90400)
        appendPQExpBufferStr(query,
                             "c.relreplident, ");
    else
        appendPQExpBufferStr(query,
                             "'d' AS relreplident, ");
 
    if (fout->remoteVersion >= 90500)
        appendPQExpBufferStr(query,
                             "c.relrowsecurity, c.relforcerowsecurity, ");
    else
        appendPQExpBufferStr(query,
                             "false AS relrowsecurity, "
                             "false AS relforcerowsecurity, ");
 
    if (fout->remoteVersion >= 90300)
        appendPQExpBufferStr(query,
                             "c.relminmxid, tc.relminmxid AS tminmxid, ");
    else
        appendPQExpBufferStr(query,
                             "0 AS relminmxid, 0 AS tminmxid, ");
 
    if (fout->remoteVersion >= 90300)
        appendPQExpBufferStr(query,
                             "array_remove(array_remove(c.reloptions,'check_option=local'),'check_option=cascaded') AS reloptions, "
                             "CASE WHEN 'check_option=local' = ANY (c.reloptions) THEN 'LOCAL'::text "
                             "WHEN 'check_option=cascaded' = ANY (c.reloptions) THEN 'CASCADED'::text ELSE NULL END AS checkoption, ");
    else
        appendPQExpBufferStr(query,
                             "c.reloptions, NULL AS checkoption, ");
 
    if (fout->remoteVersion >= 90600)
        appendPQExpBufferStr(query,
                             "am.amname, ");
    else
        appendPQExpBufferStr(query,
                             "NULL AS amname, ");
 
    if (fout->remoteVersion >= 90600)
        appendPQExpBufferStr(query,
                             "(d.deptype = 'i') IS TRUE AS is_identity_sequence, ");
    else
        appendPQExpBufferStr(query,
                             "false AS is_identity_sequence, ");
 
    if (fout->remoteVersion >= 100000)
        appendPQExpBufferStr(query,
                             "c.relispartition AS ispartition ");
    else
        appendPQExpBufferStr(query,
                             "false AS ispartition ");
 
    /*
     * Left join to pg_depend to pick up dependency info linking sequences to
     * their owning column, if any (note this dependency is AUTO except for
     * identity sequences, where it's INTERNAL). Also join to pg_tablespace to
     * collect the spcname.
     */
    appendPQExpBufferStr(query,
                         "\nFROM pg_class c\n"
                         "LEFT JOIN pg_depend d ON "
                         "(c.relkind = " CppAsString2(RELKIND_SEQUENCE) " AND "
                         "d.classid = 'pg_class'::regclass AND d.objid = c.oid AND "
                         "d.objsubid = 0 AND "
                         "d.refclassid = 'pg_class'::regclass AND d.deptype IN ('a', 'i'))\n"
                         "LEFT JOIN pg_tablespace tsp ON (tsp.oid = c.reltablespace)\n");
 
    /*
     * In 9.6 and up, left join to pg_am to pick up the amname.
     */
    if (fout->remoteVersion >= 90600)
        appendPQExpBufferStr(query,
                             "LEFT JOIN pg_am am ON (c.relam = am.oid)\n");
 
    /*
     * We purposefully ignore toast OIDs for partitioned tables; the reason is
     * that versions 10 and 11 have them, but later versions do not, so
     * emitting them causes the upgrade to fail.
     */
    appendPQExpBufferStr(query,
                         "LEFT JOIN pg_class tc ON (c.reltoastrelid = tc.oid"
                         " AND tc.relkind = " CppAsString2(RELKIND_TOASTVALUE)
                         " AND c.relkind <> " CppAsString2(RELKIND_PARTITIONED_TABLE) ")\n");
 
    /*
     * Restrict to interesting relkinds (in particular, not indexes).  Not all
     * relkinds are possible in older servers, but it's not worth the trouble
     * to emit a version-dependent list.
     *
     * 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).
     */
    appendPQExpBufferStr(query,
                         "WHERE c.relkind IN ("
                         CppAsString2(RELKIND_RELATION) ", "
                         CppAsString2(RELKIND_SEQUENCE) ", "
                         CppAsString2(RELKIND_VIEW) ", "
                         CppAsString2(RELKIND_COMPOSITE_TYPE) ", "
                         CppAsString2(RELKIND_MATVIEW) ", "
                         CppAsString2(RELKIND_FOREIGN_TABLE) ", "
                         CppAsString2(RELKIND_PARTITIONED_TABLE) ", "
                         CppAsString2(RELKIND_PROPGRAPH) ")\n"
                         "ORDER BY c.oid");
 
    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 = pg_malloc0_array(TableInfo, ntups);
 
    i_reltableoid = PQfnumber(res, "tableoid");
    i_reloid = PQfnumber(res, "oid");
    i_relname = PQfnumber(res, "relname");
    i_relnamespace = PQfnumber(res, "relnamespace");
    i_relkind = PQfnumber(res, "relkind");
    i_reltype = PQfnumber(res, "reltype");
    i_relowner = PQfnumber(res, "relowner");
    i_relchecks = PQfnumber(res, "relchecks");
    i_relhasindex = PQfnumber(res, "relhasindex");
    i_relhasrules = PQfnumber(res, "relhasrules");
    i_relpages = PQfnumber(res, "relpages");
    i_reltuples = PQfnumber(res, "reltuples");
    i_relallvisible = PQfnumber(res, "relallvisible");
    i_relallfrozen = PQfnumber(res, "relallfrozen");
    i_toastpages = PQfnumber(res, "toastpages");
    i_owning_tab = PQfnumber(res, "owning_tab");
    i_owning_col = PQfnumber(res, "owning_col");
    i_reltablespace = PQfnumber(res, "reltablespace");
    i_relhasoids = PQfnumber(res, "relhasoids");
    i_relhastriggers = PQfnumber(res, "relhastriggers");
    i_relpersistence = PQfnumber(res, "relpersistence");
    i_relispopulated = PQfnumber(res, "relispopulated");
    i_relreplident = PQfnumber(res, "relreplident");
    i_relrowsec = PQfnumber(res, "relrowsecurity");
    i_relforcerowsec = PQfnumber(res, "relforcerowsecurity");
    i_relfrozenxid = PQfnumber(res, "relfrozenxid");
    i_toastfrozenxid = PQfnumber(res, "tfrozenxid");
    i_toastoid = PQfnumber(res, "toid");
    i_relminmxid = PQfnumber(res, "relminmxid");
    i_toastminmxid = PQfnumber(res, "tminmxid");
    i_reloptions = PQfnumber(res, "reloptions");
    i_checkoption = PQfnumber(res, "checkoption");
    i_toastreloptions = PQfnumber(res, "toast_reloptions");
    i_reloftype = PQfnumber(res, "reloftype");
    i_foreignserver = PQfnumber(res, "foreignserver");
    i_amname = PQfnumber(res, "amname");
    i_is_identity_sequence = PQfnumber(res, "is_identity_sequence");
    i_relacl = PQfnumber(res, "relacl");
    i_acldefault = PQfnumber(res, "acldefault");
    i_ispartition = PQfnumber(res, "ispartition");
 
    if (dopt->lockWaitTimeout)
    {
        /*
         * 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);
        appendPQExpBufferStr(query, "SET statement_timeout = ");
        appendStringLiteralConn(query, dopt->lockWaitTimeout, GetConnection(fout));
        ExecuteSqlStatement(fout, query->data);
    }
 
    resetPQExpBuffer(query);
 
    for (i = 0; i < ntups; i++)
    {
        int32       relallvisible = atoi(PQgetvalue(res, i, i_relallvisible));
        int32       relallfrozen = atoi(PQgetvalue(res, i, i_relallfrozen));
 
        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(atooid(PQgetvalue(res, i, i_relnamespace)));
        tblinfo[i].dacl.acl = pg_strdup(PQgetvalue(res, i, i_relacl));
        tblinfo[i].dacl.acldefault = pg_strdup(PQgetvalue(res, i, i_acldefault));
        tblinfo[i].dacl.privtype = 0;
        tblinfo[i].dacl.initprivs = NULL;
        tblinfo[i].relkind = *(PQgetvalue(res, i, i_relkind));
        tblinfo[i].reltype = atooid(PQgetvalue(res, i, i_reltype));
        tblinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_relowner));
        tblinfo[i].ncheck = atoi(PQgetvalue(res, i, i_relchecks));
        tblinfo[i].hasindex = (strcmp(PQgetvalue(res, i, i_relhasindex), "t") == 0);
        tblinfo[i].hasrules = (strcmp(PQgetvalue(res, i, i_relhasrules), "t") == 0);
        tblinfo[i].relpages = atoi(PQgetvalue(res, i, i_relpages));
        if (PQgetisnull(res, i, i_toastpages))
            tblinfo[i].toastpages = 0;
        else
            tblinfo[i].toastpages = atoi(PQgetvalue(res, i, i_toastpages));
        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].hasoids = (strcmp(PQgetvalue(res, i, i_relhasoids), "t") == 0);
        tblinfo[i].hastriggers = (strcmp(PQgetvalue(res, i, i_relhastriggers), "t") == 0);
        tblinfo[i].relpersistence = *(PQgetvalue(res, i, i_relpersistence));
        tblinfo[i].relispopulated = (strcmp(PQgetvalue(res, i, i_relispopulated), "t") == 0);
        tblinfo[i].relreplident = *(PQgetvalue(res, i, i_relreplident));
        tblinfo[i].rowsec = (strcmp(PQgetvalue(res, i, i_relrowsec), "t") == 0);
        tblinfo[i].forcerowsec = (strcmp(PQgetvalue(res, i, i_relforcerowsec), "t") == 0);
        tblinfo[i].frozenxid = atooid(PQgetvalue(res, i, i_relfrozenxid));
        tblinfo[i].toast_frozenxid = atooid(PQgetvalue(res, i, i_toastfrozenxid));
        tblinfo[i].toast_oid = atooid(PQgetvalue(res, i, i_toastoid));
        tblinfo[i].minmxid = atooid(PQgetvalue(res, i, i_relminmxid));
        tblinfo[i].toast_minmxid = atooid(PQgetvalue(res, i, i_toastminmxid));
        tblinfo[i].reloptions = pg_strdup(PQgetvalue(res, i, i_reloptions));
        if (PQgetisnull(res, i, i_checkoption))
            tblinfo[i].checkoption = NULL;
        else
            tblinfo[i].checkoption = pg_strdup(PQgetvalue(res, i, i_checkoption));
        tblinfo[i].toast_reloptions = pg_strdup(PQgetvalue(res, i, i_toastreloptions));
        tblinfo[i].reloftype = atooid(PQgetvalue(res, i, i_reloftype));
        tblinfo[i].foreign_server = atooid(PQgetvalue(res, i, i_foreignserver));
        if (PQgetisnull(res, i, i_amname))
            tblinfo[i].amname = NULL;
        else
            tblinfo[i].amname = pg_strdup(PQgetvalue(res, i, i_amname));
        tblinfo[i].is_identity_sequence = (strcmp(PQgetvalue(res, i, i_is_identity_sequence), "t") == 0);
        tblinfo[i].ispartition = (strcmp(PQgetvalue(res, i, i_ispartition), "t") == 0);
 
        /* other fields were zeroed above */
 
        /*
         * Decide whether we want to dump this table.
         */
        if (tblinfo[i].relkind == RELKIND_COMPOSITE_TYPE)
            tblinfo[i].dobj.dump = DUMP_COMPONENT_NONE;
        else
            selectDumpableTable(&tblinfo[i], fout);
 
        /*
         * Now, consider the table "interesting" if we need to dump its
         * definition, data or its statistics.  Later on, we'll skip a lot of
         * data collection for uninteresting tables.
         *
         * Note: the "interesting" flag will also be set by flagInhTables for
         * parents of interesting tables, so that we collect necessary
         * inheritance info even when the parents are not themselves being
         * dumped.  This is the main reason why we need an "interesting" flag
         * that's separate from the components-to-dump bitmask.
         */
        tblinfo[i].interesting = (tblinfo[i].dobj.dump &
                                  (DUMP_COMPONENT_DEFINITION |
                                   DUMP_COMPONENT_DATA |
                                   DUMP_COMPONENT_STATISTICS)) != 0;
 
        tblinfo[i].dummy_view = false;  /* might get set during sort */
        tblinfo[i].postponed_def = false;   /* might get set during sort */
 
        /* Tables have data */
        tblinfo[i].dobj.components |= DUMP_COMPONENT_DATA;
 
        /* Mark whether table has an ACL */
        if (!PQgetisnull(res, i, i_relacl))
            tblinfo[i].dobj.components |= DUMP_COMPONENT_ACL;
        tblinfo[i].hascolumnACLs = false;   /* may get set later */
 
        /* Add statistics */
        if (tblinfo[i].interesting)
        {
            RelStatsInfo *stats;
 
            stats = getRelationStatistics(fout, &tblinfo[i].dobj,
                                          tblinfo[i].relpages,
                                          PQgetvalue(res, i, i_reltuples),
                                          relallvisible, relallfrozen,
                                          tblinfo[i].relkind, NULL, 0);
            if (tblinfo[i].relkind == RELKIND_MATVIEW)
                tblinfo[i].stats = stats;
        }
 
        /*
         * 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 or partitioned tables, but the backend doesn't presently
         * allow that.
         *
         * We only need to lock the table for certain components; see
         * pg_dump.h
         */
        if ((tblinfo[i].dobj.dump & DUMP_COMPONENTS_REQUIRING_LOCK) &&
            (tblinfo[i].relkind == RELKIND_RELATION ||
             tblinfo[i].relkind == RELKIND_PARTITIONED_TABLE))
        {
            /*
             * Tables are locked in batches.  When dumping from a remote
             * server this can save a significant amount of time by reducing
             * the number of round trips.
             */
            if (query->len == 0)
                appendPQExpBuffer(query, "LOCK TABLE %s",
                                  fmtQualifiedDumpable(&tblinfo[i]));
            else
            {
                appendPQExpBuffer(query, ", %s",
                                  fmtQualifiedDumpable(&tblinfo[i]));
 
                /* Arbitrarily end a batch when query length reaches 100K. */
                if (query->len >= 100000)
                {
                    /* Lock another batch of tables. */
                    appendPQExpBufferStr(query, " IN ACCESS SHARE MODE");
                    ExecuteSqlStatement(fout, query->data);
                    resetPQExpBuffer(query);
                }
            }
        }
    }
 
    if (query->len != 0)
    {
        /* Lock the tables in the last batch. */
        appendPQExpBufferStr(query, " IN ACCESS SHARE MODE");
        ExecuteSqlStatement(fout, query->data);
    }
 
    if (dopt->lockWaitTimeout)
    {
        ExecuteSqlStatement(fout, "SET statement_timeout = 0");
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
 
    return tblinfo;
}

References _dumpableAcl::acl, _dumpableAcl::acldefault, _tableInfo::amname, appendPQExpBuffer(), appendPQExpBufferStr(), appendStringLiteralConn(), AssignDumpId(), atooid, _dumpableObject::catId, _tableInfo::checkoption, _dumpableObject::components, CppAsString2, createPQExpBuffer(), _tableInfo::dacl, PQExpBufferData::data, destroyPQExpBuffer(), DO_TABLE, _tableInfo::dobj, Archive::dopt, _tableInfo::dummy_view, _dumpableObject::dump, DUMP_COMPONENT_ACL, DUMP_COMPONENT_DATA, DUMP_COMPONENT_DEFINITION, DUMP_COMPONENT_NONE, DUMP_COMPONENT_STATISTICS, DUMP_COMPONENTS_REQUIRING_LOCK, ExecuteSqlQuery(), ExecuteSqlStatement(), fb(), findNamespace(), fmtQualifiedDumpable, _tableInfo::forcerowsec, _tableInfo::foreign_server, fout, _tableInfo::frozenxid, GetConnection(), getRelationStatistics(), getRoleName(), _tableInfo::hascolumnACLs, _tableInfo::hasindex, _tableInfo::hasoids, _tableInfo::hasrules, _tableInfo::hastriggers, i, _dumpableAcl::initprivs, _tableInfo::interesting, InvalidOid, _tableInfo::is_identity_sequence, _tableInfo::ispartition, PQExpBufferData::len, _dumpOptions::lockWaitTimeout, _tableInfo::minmxid, _dumpableObject::name, _tableInfo::ncheck, _dumpableObject::objType, CatalogId::oid, _tableInfo::owning_col, _tableInfo::owning_tab, pg_malloc0_array, pg_strdup(), PGRES_TUPLES_OK, _tableInfo::postponed_def, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, _dumpableAcl::privtype, _tableInfo::relispopulated, _tableInfo::relkind, _tableInfo::reloftype, _tableInfo::reloptions, _tableInfo::relpages, _tableInfo::relpersistence, _tableInfo::relreplident, _tableInfo::reltablespace, _tableInfo::reltype, Archive::remoteVersion, resetPQExpBuffer(), _tableInfo::rolname, _tableInfo::rowsec, selectDumpableTable(), _tableInfo::stats, CatalogId::tableoid, _tableInfo::toast_frozenxid, _tableInfo::toast_minmxid, _tableInfo::toast_oid, _tableInfo::toast_reloptions, and _tableInfo::toastpages.

Referenced by getSchemaData().

getTransforms()

void getTransforms ( Archive *  fout )

extern

Definition at line 9247 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    TransformInfo *transforminfo;
    int         i_tableoid;
    int         i_oid;
    int         i_trftype;
    int         i_trflang;
    int         i_trffromsql;
    int         i_trftosql;
 
    /* Transforms didn't exist pre-9.5 */
    if (fout->remoteVersion < 90500)
        return;
 
    query = createPQExpBuffer();
 
    appendPQExpBufferStr(query, "SELECT tableoid, oid, "
                         "trftype, trflang, trffromsql::oid, trftosql::oid "
                         "FROM pg_transform "
                         "ORDER BY 3,4");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    transforminfo = pg_malloc_array(TransformInfo, ntups);
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_trftype = PQfnumber(res, "trftype");
    i_trflang = PQfnumber(res, "trflang");
    i_trffromsql = PQfnumber(res, "trffromsql");
    i_trftosql = PQfnumber(res, "trftosql");
 
    for (i = 0; i < ntups; i++)
    {
        PQExpBufferData namebuf;
        TypeInfo   *typeInfo;
        char       *lanname;
 
        transforminfo[i].dobj.objType = DO_TRANSFORM;
        transforminfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        transforminfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&transforminfo[i].dobj);
        transforminfo[i].trftype = atooid(PQgetvalue(res, i, i_trftype));
        transforminfo[i].trflang = atooid(PQgetvalue(res, i, i_trflang));
        transforminfo[i].trffromsql = atooid(PQgetvalue(res, i, i_trffromsql));
        transforminfo[i].trftosql = atooid(PQgetvalue(res, i, i_trftosql));
 
        /*
         * Try to name transform as concatenation of type and language name.
         * This is only used for purposes of sorting.  If we fail to find
         * either, the name will be an empty string.
         */
        initPQExpBuffer(&namebuf);
        typeInfo = findTypeByOid(transforminfo[i].trftype);
        lanname = get_language_name(fout, transforminfo[i].trflang);
        if (typeInfo && lanname)
            appendPQExpBuffer(&namebuf, "%s %s",
                              typeInfo->dobj.name, lanname);
        transforminfo[i].dobj.name = namebuf.data;
        free(lanname);
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(transforminfo[i].dobj), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBuffer(), appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_TRANSFORM, _typeInfo::dobj, ExecuteSqlQuery(), fb(), findTypeByOid(), fout, free, get_language_name(), i, initPQExpBuffer(), _dumpableObject::objType, pg_malloc_array, PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, Archive::remoteVersion, and selectDumpableObject().

Referenced by getSchemaData().

getTriggers()

void getTriggers ( Archive *  fout, TableInfo  tblinfo[], int  numTables  )

extern

Definition at line 8779 of file pg_dump.c.

{
    PQExpBuffer query = createPQExpBuffer();
    PQExpBuffer tbloids = createPQExpBuffer();
    PGresult   *res;
    int         ntups;
    int         curtblindx;
    TriggerInfo *tginfo;
    int         i_tableoid,
                i_oid,
                i_tgrelid,
                i_tgname,
                i_tgenabled,
                i_tgispartition,
                i_tgdef;
 
    /*
     * We want to perform just one query against pg_trigger.  However, we
     * mustn't try to select every row of the catalog and then sort it out on
     * the client side, because some of the server-side functions we need
     * would be unsafe to apply to tables we don't have lock on.  Hence, we
     * build an array of the OIDs of tables we care about (and now have lock
     * on!), and use a WHERE clause to constrain which rows are selected.
     */
    appendPQExpBufferChar(tbloids, '{');
    for (int i = 0; i < numTables; i++)
    {
        TableInfo  *tbinfo = &tblinfo[i];
 
        if (!tbinfo->hastriggers ||
            !(tbinfo->dobj.dump & DUMP_COMPONENT_DEFINITION))
            continue;
 
        /* OK, we need info for this table */
        if (tbloids->len > 1)   /* do we have more than the '{'? */
            appendPQExpBufferChar(tbloids, ',');
        appendPQExpBuffer(tbloids, "%u", tbinfo->dobj.catId.oid);
    }
    appendPQExpBufferChar(tbloids, '}');
 
    if (fout->remoteVersion >= 150000)
    {
        /*
         * 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.
         *
         * NB: We need to see partition triggers in case the tgenabled flag
         * has been changed from the parent.
         */
        appendPQExpBuffer(query,
                          "SELECT t.tgrelid, t.tgname, "
                          "pg_catalog.pg_get_triggerdef(t.oid, false) AS tgdef, "
                          "t.tgenabled, t.tableoid, t.oid, "
                          "t.tgparentid <> 0 AS tgispartition\n"
                          "FROM unnest('%s'::pg_catalog.oid[]) AS src(tbloid)\n"
                          "JOIN pg_catalog.pg_trigger t ON (src.tbloid = t.tgrelid) "
                          "LEFT JOIN pg_catalog.pg_trigger u ON (u.oid = t.tgparentid) "
                          "WHERE ((NOT t.tgisinternal AND t.tgparentid = 0) "
                          "OR t.tgenabled != u.tgenabled) "
                          "ORDER BY t.tgrelid, t.tgname",
                          tbloids->data);
    }
    else if (fout->remoteVersion >= 130000)
    {
        /*
         * 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.
         *
         * NB: We need to see tgisinternal triggers in partitions, in case the
         * tgenabled flag has been changed from the parent.
         */
        appendPQExpBuffer(query,
                          "SELECT t.tgrelid, t.tgname, "
                          "pg_catalog.pg_get_triggerdef(t.oid, false) AS tgdef, "
                          "t.tgenabled, t.tableoid, t.oid, t.tgisinternal as tgispartition\n"
                          "FROM unnest('%s'::pg_catalog.oid[]) AS src(tbloid)\n"
                          "JOIN pg_catalog.pg_trigger t ON (src.tbloid = t.tgrelid) "
                          "LEFT JOIN pg_catalog.pg_trigger u ON (u.oid = t.tgparentid) "
                          "WHERE (NOT t.tgisinternal OR t.tgenabled != u.tgenabled) "
                          "ORDER BY t.tgrelid, t.tgname",
                          tbloids->data);
    }
    else if (fout->remoteVersion >= 110000)
    {
        /*
         * NB: We need to see tgisinternal triggers in partitions, in case the
         * tgenabled flag has been changed from the parent. No tgparentid in
         * version 11-12, so we have to match them via pg_depend.
         *
         * See above about pretty=true in pg_get_triggerdef.
         */
        appendPQExpBuffer(query,
                          "SELECT t.tgrelid, t.tgname, "
                          "pg_catalog.pg_get_triggerdef(t.oid, false) AS tgdef, "
                          "t.tgenabled, t.tableoid, t.oid, t.tgisinternal as tgispartition "
                          "FROM unnest('%s'::pg_catalog.oid[]) AS src(tbloid)\n"
                          "JOIN pg_catalog.pg_trigger t ON (src.tbloid = t.tgrelid) "
                          "LEFT JOIN pg_catalog.pg_depend AS d ON "
                          " d.classid = 'pg_catalog.pg_trigger'::pg_catalog.regclass AND "
                          " d.refclassid = 'pg_catalog.pg_trigger'::pg_catalog.regclass AND "
                          " d.objid = t.oid "
                          "LEFT JOIN pg_catalog.pg_trigger AS pt ON pt.oid = refobjid "
                          "WHERE (NOT t.tgisinternal OR t.tgenabled != pt.tgenabled) "
                          "ORDER BY t.tgrelid, t.tgname",
                          tbloids->data);
    }
    else
    {
        /* See above about pretty=true in pg_get_triggerdef */
        appendPQExpBuffer(query,
                          "SELECT t.tgrelid, t.tgname, "
                          "pg_catalog.pg_get_triggerdef(t.oid, false) AS tgdef, "
                          "t.tgenabled, false as tgispartition, "
                          "t.tableoid, t.oid "
                          "FROM unnest('%s'::pg_catalog.oid[]) AS src(tbloid)\n"
                          "JOIN pg_catalog.pg_trigger t ON (src.tbloid = t.tgrelid) "
                          "WHERE NOT tgisinternal "
                          "ORDER BY t.tgrelid, t.tgname",
                          tbloids->data);
    }
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_tgrelid = PQfnumber(res, "tgrelid");
    i_tgname = PQfnumber(res, "tgname");
    i_tgenabled = PQfnumber(res, "tgenabled");
    i_tgispartition = PQfnumber(res, "tgispartition");
    i_tgdef = PQfnumber(res, "tgdef");
 
    tginfo = pg_malloc_array(TriggerInfo, ntups);
 
    /*
     * Outer loop iterates once per table, not once per row.  Incrementing of
     * j is handled by the inner loop.
     */
    curtblindx = -1;
    for (int j = 0; j < ntups;)
    {
        Oid         tgrelid = atooid(PQgetvalue(res, j, i_tgrelid));
        TableInfo  *tbinfo = NULL;
        int         numtrigs;
 
        /* Count rows for this table */
        for (numtrigs = 1; numtrigs < ntups - j; numtrigs++)
            if (atooid(PQgetvalue(res, j + numtrigs, i_tgrelid)) != tgrelid)
                break;
 
        /*
         * Locate the associated TableInfo; we rely on tblinfo[] being in OID
         * order.
         */
        while (++curtblindx < numTables)
        {
            tbinfo = &tblinfo[curtblindx];
            if (tbinfo->dobj.catId.oid == tgrelid)
                break;
        }
        if (curtblindx >= numTables)
            pg_fatal("unrecognized table OID %u", tgrelid);
 
        /* Save data for this table */
        tbinfo->triggers = tginfo + j;
        tbinfo->numTriggers = numtrigs;
 
        for (int c = 0; c < numtrigs; c++, 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));
            tginfo[j].tgispartition = *(PQgetvalue(res, j, i_tgispartition)) == 't';
            tginfo[j].tgdef = pg_strdup(PQgetvalue(res, j, i_tgdef));
        }
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
    destroyPQExpBuffer(tbloids);
}

References appendPQExpBuffer(), appendPQExpBufferChar(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_TRIGGER, DUMP_COMPONENT_DEFINITION, ExecuteSqlQuery(), fb(), fout, i, j, pg_fatal, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, and Archive::remoteVersion.

Referenced by getSchemaData().

getTSConfigurations()

void getTSConfigurations ( Archive *  fout )

extern

Definition at line 10460 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    TSConfigInfo *cfginfo;
    int         i_tableoid;
    int         i_oid;
    int         i_cfgname;
    int         i_cfgnamespace;
    int         i_cfgowner;
    int         i_cfgparser;
 
    query = createPQExpBuffer();
 
    appendPQExpBufferStr(query, "SELECT tableoid, oid, cfgname, "
                         "cfgnamespace, cfgowner, cfgparser "
                         "FROM pg_ts_config");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    cfginfo = pg_malloc_array(TSConfigInfo, ntups);
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_cfgname = PQfnumber(res, "cfgname");
    i_cfgnamespace = PQfnumber(res, "cfgnamespace");
    i_cfgowner = PQfnumber(res, "cfgowner");
    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(atooid(PQgetvalue(res, i, i_cfgnamespace)));
        cfginfo[i].rolname = getRoleName(PQgetvalue(res, i, i_cfgowner));
        cfginfo[i].cfgparser = atooid(PQgetvalue(res, i, i_cfgparser));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(cfginfo[i].dobj), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_TSCONFIG, ExecuteSqlQuery(), fb(), findNamespace(), fout, getRoleName(), i, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, and selectDumpableObject().

Referenced by getSchemaData().

getTSDictionaries()

void getTSDictionaries ( Archive *  fout )

extern

Definition at line 10335 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    TSDictInfo *dictinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_dictname;
    int         i_dictnamespace;
    int         i_dictowner;
    int         i_dicttemplate;
    int         i_dictinitoption;
 
    query = createPQExpBuffer();
 
    appendPQExpBufferStr(query, "SELECT tableoid, oid, dictname, "
                         "dictnamespace, dictowner, "
                         "dicttemplate, dictinitoption "
                         "FROM pg_ts_dict");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    dictinfo = pg_malloc_array(TSDictInfo, ntups);
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_dictname = PQfnumber(res, "dictname");
    i_dictnamespace = PQfnumber(res, "dictnamespace");
    i_dictowner = PQfnumber(res, "dictowner");
    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(atooid(PQgetvalue(res, i, i_dictnamespace)));
        dictinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_dictowner));
        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), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_TSDICT, ExecuteSqlQuery(), fb(), findNamespace(), fout, getRoleName(), i, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, and selectDumpableObject().

Referenced by getSchemaData().

getTSParsers()

void getTSParsers ( Archive *  fout )

extern

Definition at line 10261 of file pg_dump.c.

{
    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;
 
    query = createPQExpBuffer();
 
    /*
     * find all text search objects, including builtin ones; we filter out
     * system-defined objects at dump-out time.
     */
 
    appendPQExpBufferStr(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);
 
    prsinfo = pg_malloc_array(TSParserInfo, ntups);
 
    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(atooid(PQgetvalue(res, i, i_prsnamespace)));
        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), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_TSPARSER, ExecuteSqlQuery(), fb(), findNamespace(), fout, i, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, and selectDumpableObject().

Referenced by getSchemaData().

getTSTemplates()

void getTSTemplates ( Archive *  fout )

extern

Definition at line 10401 of file pg_dump.c.

{
    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;
 
    query = createPQExpBuffer();
 
    appendPQExpBufferStr(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);
 
    tmplinfo = pg_malloc_array(TSTemplateInfo, ntups);
 
    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(atooid(PQgetvalue(res, i, i_tmplnamespace)));
        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), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_TSTEMPLATE, ExecuteSqlQuery(), fb(), findNamespace(), fout, i, pg_malloc_array, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, and selectDumpableObject().

Referenced by getSchemaData().

getTypes()

void getTypes ( Archive *  fout )

extern

Definition at line 6290 of file pg_dump.c.

{
    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_acldefault;
    int         i_typowner;
    int         i_typelem;
    int         i_typrelid;
    int         i_typrelkind;
    int         i_typtype;
    int         i_typisdefined;
    int         i_isarray;
    int         i_typarray;
 
    /*
     * 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.
     */
    appendPQExpBufferStr(query, "SELECT tableoid, oid, typname, "
                         "typnamespace, typacl, "
                         "acldefault('T', typowner) AS acldefault, "
                         "typowner, "
                         "typelem, typrelid, typarray, "
                         "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");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    tyinfo = pg_malloc_array(TypeInfo, ntups);
 
    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_acldefault = PQfnumber(res, "acldefault");
    i_typowner = PQfnumber(res, "typowner");
    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");
    i_typarray = PQfnumber(res, "typarray");
 
    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(atooid(PQgetvalue(res, i, i_typnamespace)));
        tyinfo[i].dacl.acl = pg_strdup(PQgetvalue(res, i, i_typacl));
        tyinfo[i].dacl.acldefault = pg_strdup(PQgetvalue(res, i, i_acldefault));
        tyinfo[i].dacl.privtype = 0;
        tyinfo[i].dacl.initprivs = NULL;
        tyinfo[i].ftypname = NULL;  /* may get filled later */
        tyinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_typowner));
        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;
 
        tyinfo[i].typarray = atooid(PQgetvalue(res, i, i_typarray));
 
        if (tyinfo[i].typtype == TYPTYPE_MULTIRANGE)
            tyinfo[i].isMultirange = true;
        else
            tyinfo[i].isMultirange = false;
 
        /* Decide whether we want to dump it */
        selectDumpableType(&tyinfo[i], fout);
 
        /* Mark whether type has an ACL */
        if (!PQgetisnull(res, i, i_typacl))
            tyinfo[i].dobj.components |= DUMP_COMPONENT_ACL;
 
        /*
         * If it's a domain, fetch info about its constraints, if any
         */
        tyinfo[i].nDomChecks = 0;
        tyinfo[i].domChecks = NULL;
        tyinfo[i].notnull = NULL;
        if ((tyinfo[i].dobj.dump & DUMP_COMPONENT_DEFINITION) &&
            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 & DUMP_COMPONENT_DEFINITION) &&
            (tyinfo[i].typtype == TYPTYPE_BASE ||
             tyinfo[i].typtype == TYPTYPE_RANGE))
        {
            stinfo = pg_malloc_object(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 = DUMP_COMPONENT_NONE;
        }
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_SHELL_TYPE, DO_TYPE, DUMP_COMPONENT_ACL, DUMP_COMPONENT_DEFINITION, DUMP_COMPONENT_NONE, ExecuteSqlQuery(), fb(), findNamespace(), fout, getDomainConstraints(), getRoleName(), i, nilCatalogId, pg_malloc_array, pg_malloc_object, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, and selectDumpableType().

Referenced by getSchemaData().

parseOidArray()

void parseOidArray ( const char *  str, Oid *  array, int  arraysize  )

extern

Definition at line 1112 of file common.c.

{
    int         j,
                argNum;
    char        temp[100];
    char        s;
 
    argNum = 0;
    j = 0;
    for (;;)
    {
        s = *str++;
        if (s == ' ' || s == '\0')
        {
            if (j > 0)
            {
                if (argNum >= arraysize)
                    pg_fatal("could not parse numeric array \"%s\": too many numbers", str);
                temp[j] = '\0';
                array[argNum++] = atooid(temp);
                j = 0;
            }
            if (s == '\0')
                break;
        }
        else
        {
            if (!(isdigit((unsigned char) s) || s == '-') ||
                j >= sizeof(temp) - 1)
                pg_fatal("could not parse numeric array \"%s\": invalid character in number", str);
            temp[j++] = s;
        }
    }
 
    while (argNum < arraysize)
        array[argNum++] = InvalidOid;
}

References atooid, fb(), InvalidOid, j, pg_fatal, and str.

Referenced by dumpFunc(), getAggregates(), getFuncs(), and getIndexes().

processExtensionTables()

void processExtensionTables ( Archive *  fout, ExtensionInfo  extinfo[], int  numExtensions  )

extern

Definition at line 20288 of file pg_dump.c.

{
    DumpOptions *dopt = fout->dopt;
    PQExpBuffer query;
    PGresult   *res;
    int         ntups,
                i;
    int         i_conrelid,
                i_confrelid;
 
    /* Nothing to do if no extensions */
    if (numExtensions == 0)
        return;
 
    /*
     * Identify extension configuration tables and create TableDataInfo
     * objects for them, ensuring their data will be dumped even though the
     * tables themselves won't be.
     *
     * Note that we create TableDataInfo objects even in schema-only mode, ie,
     * user data in a configuration table is treated like schema data. This
     * seems appropriate since system data in a config table would get
     * reloaded by CREATE EXTENSION.  If the extension is not listed in the
     * list of extensions to be included, none of its data is dumped.
     */
    for (i = 0; i < numExtensions; i++)
    {
        ExtensionInfo *curext = &(extinfo[i]);
        char       *extconfig = curext->extconfig;
        char       *extcondition = curext->extcondition;
        char      **extconfigarray = NULL;
        char      **extconditionarray = NULL;
        int         nconfigitems = 0;
        int         nconditionitems = 0;
 
        /*
         * Check if this extension is listed as to include in the dump.  If
         * not, any table data associated with it is discarded.
         */
        if (extension_include_oids.head != NULL &&
            !simple_oid_list_member(&extension_include_oids,
                                    curext->dobj.catId.oid))
            continue;
 
        /*
         * Check if this extension is listed as to exclude in the dump.  If
         * yes, any table data associated with it is discarded.
         */
        if (extension_exclude_oids.head != NULL &&
            simple_oid_list_member(&extension_exclude_oids,
                                   curext->dobj.catId.oid))
            continue;
 
        if (strlen(extconfig) != 0 || strlen(extcondition) != 0)
        {
            int         j;
 
            if (!parsePGArray(extconfig, &extconfigarray, &nconfigitems))
                pg_fatal("could not parse %s array", "extconfig");
            if (!parsePGArray(extcondition, &extconditionarray, &nconditionitems))
                pg_fatal("could not parse %s array", "extcondition");
            if (nconfigitems != nconditionitems)
                pg_fatal("mismatched number of configurations and conditions for extension");
 
            for (j = 0; j < nconfigitems; j++)
            {
                TableInfo  *configtbl;
                Oid         configtbloid = atooid(extconfigarray[j]);
                bool        dumpobj =
                    curext->dobj.dump & DUMP_COMPONENT_DEFINITION;
 
                configtbl = findTableByOid(configtbloid);
                if (configtbl == NULL)
                    continue;
 
                /*
                 * Tables of not-to-be-dumped extensions shouldn't be dumped
                 * unless the table or its schema is explicitly included
                 */
                if (!(curext->dobj.dump & DUMP_COMPONENT_DEFINITION))
                {
                    /* check table explicitly requested */
                    if (table_include_oids.head != NULL &&
                        simple_oid_list_member(&table_include_oids,
                                               configtbloid))
                        dumpobj = true;
 
                    /* check table's schema explicitly requested */
                    if (configtbl->dobj.namespace->dobj.dump &
                        DUMP_COMPONENT_DATA)
                        dumpobj = true;
                }
 
                /* check table excluded by an exclusion switch */
                if (table_exclude_oids.head != NULL &&
                    simple_oid_list_member(&table_exclude_oids,
                                           configtbloid))
                    dumpobj = false;
 
                /* check schema excluded by an exclusion switch */
                if (simple_oid_list_member(&schema_exclude_oids,
                                           configtbl->dobj.namespace->dobj.catId.oid))
                    dumpobj = false;
 
                if (dumpobj)
                {
                    makeTableDataInfo(dopt, configtbl);
                    if (configtbl->dataObj != NULL)
                    {
                        if (strlen(extconditionarray[j]) > 0)
                            configtbl->dataObj->filtercond = pg_strdup(extconditionarray[j]);
                    }
                }
            }
        }
        if (extconfigarray)
            free(extconfigarray);
        if (extconditionarray)
            free(extconditionarray);
    }
 
    /*
     * Now that all the TableDataInfo objects have been created for all the
     * extensions, check their FK dependencies and register them to try and
     * dump the data out in an order that they can be restored in.
     *
     * Note that this is not a problem for user tables as their FKs are
     * recreated after the data has been loaded.
     */
 
    query = createPQExpBuffer();
 
    printfPQExpBuffer(query,
                      "SELECT conrelid, confrelid "
                      "FROM pg_constraint "
                      "JOIN pg_depend ON (objid = confrelid) "
                      "WHERE contype = 'f' "
                      "AND refclassid = 'pg_extension'::regclass "
                      "AND classid = 'pg_class'::regclass;");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
    ntups = PQntuples(res);
 
    i_conrelid = PQfnumber(res, "conrelid");
    i_confrelid = PQfnumber(res, "confrelid");
 
    /* Now get the dependencies and register them */
    for (i = 0; i < ntups; i++)
    {
        Oid         conrelid,
                    confrelid;
        TableInfo  *reftable,
                   *contable;
 
        conrelid = atooid(PQgetvalue(res, i, i_conrelid));
        confrelid = atooid(PQgetvalue(res, i, i_confrelid));
        contable = findTableByOid(conrelid);
        reftable = findTableByOid(confrelid);
 
        if (reftable == NULL ||
            reftable->dataObj == NULL ||
            contable == NULL ||
            contable->dataObj == NULL)
            continue;
 
        /*
         * Make referencing TABLE_DATA object depend on the referenced table's
         * TABLE_DATA object.
         */
        addObjectDependency(&contable->dataObj->dobj,
                            reftable->dataObj->dobj.dumpId);
    }
    PQclear(res);
    destroyPQExpBuffer(query);
}

References addObjectDependency(), atooid, createPQExpBuffer(), PQExpBufferData::data, _tableInfo::dataObj, destroyPQExpBuffer(), _tableDataInfo::dobj, Archive::dopt, DUMP_COMPONENT_DATA, DUMP_COMPONENT_DEFINITION, _dumpableObject::dumpId, ExecuteSqlQuery(), _extensionInfo::extconfig, extension_exclude_oids, extension_include_oids, fb(), findTableByOid(), fout, free, SimpleOidList::head, i, j, makeTableDataInfo(), parsePGArray(), pg_fatal, pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, printfPQExpBuffer(), schema_exclude_oids, simple_oid_list_member(), table_exclude_oids, and table_include_oids.

Referenced by getSchemaData().

recordAdditionalCatalogID()

void recordAdditionalCatalogID ( CatalogId  catId, DumpableObject *  dobj  )

extern

Definition at line 720 of file common.c.

{
    CatalogIdMapEntry *entry;
    bool        found;
 
    /* CatalogId hash table must exist, if we have a DumpableObject */
    Assert(catalogIdHash != NULL);
 
    /* Add reference to CatalogId hash */
    entry = catalogid_insert(catalogIdHash, catId, &found);
    if (!found)
    {
        entry->dobj = NULL;
        entry->ext = NULL;
    }
    Assert(entry->dobj == NULL);
    entry->dobj = dobj;
}

References Assert, catalogIdHash, _catalogIdMapEntry::dobj, _catalogIdMapEntry::ext, and fb().

Referenced by getLOs().

recordExtensionMembership()

void recordExtensionMembership ( CatalogId  catId, ExtensionInfo *  ext  )

extern

Definition at line 1064 of file common.c.

{
    CatalogIdMapEntry *entry;
    bool        found;
 
    /* CatalogId hash table must exist, if we have an ExtensionInfo */
    Assert(catalogIdHash != NULL);
 
    /* Add reference to CatalogId hash */
    entry = catalogid_insert(catalogIdHash, catId, &found);
    if (!found)
    {
        entry->dobj = NULL;
        entry->ext = NULL;
    }
    Assert(entry->ext == NULL);
    entry->ext = ext;
}

References Assert, catalogIdHash, _catalogIdMapEntry::dobj, _catalogIdMapEntry::ext, and fb().

Referenced by getExtensionMembership().

removeObjectDependency()

void removeObjectDependency ( DumpableObject *  dobj, DumpId  refId  )

extern

Definition at line 844 of file common.c.

{
    int         i;
    int         j = 0;
 
    for (i = 0; i < dobj->nDeps; i++)
    {
        if (dobj->dependencies[i] != refId)
            dobj->dependencies[j++] = dobj->dependencies[i];
    }
    dobj->nDeps = j;
}

References _dumpableObject::dependencies, fb(), i, j, and _dumpableObject::nDeps.

Referenced by repairDependencyLoop(), repairDomainConstraintLoop(), repairDomainConstraintMultiLoop(), repairFunctionBoundaryMultiLoop(), repairIndexLoop(), repairMatViewBoundaryMultiLoop(), repairTableAttrDefLoop(), repairTableAttrDefMultiLoop(), repairTableConstraintLoop(), repairTableConstraintMultiLoop(), repairTypeFuncLoop(), repairViewRuleLoop(), and repairViewRuleMultiLoop().

shouldPrintColumn()

bool shouldPrintColumn ( const DumpOptions *  dopt, const TableInfo *  tbinfo, int  colno  )

extern

Definition at line 10246 of file pg_dump.c.

{
    if (dopt->binary_upgrade)
        return true;
    if (tbinfo->attisdropped[colno])
        return false;
    return (tbinfo->attislocal[colno] || tbinfo->ispartition);
}

References _dumpOptions::binary_upgrade, and fb().

Referenced by dumpTableSchema(), flagInhAttrs(), and getTableAttrs().

sortDumpableObjects()

void sortDumpableObjects ( DumpableObject **  objs, int  numObjs, DumpId  preBoundaryId, DumpId  postBoundaryId  )

extern

Definition at line 559 of file pg_dump_sort.c.

{
    DumpableObject **ordering;
    int         nOrdering;
 
    if (numObjs <= 0)           /* can't happen anymore ... */
        return;
 
    /*
     * Saving the boundary IDs in static variables is a bit grotty, but seems
     * better than adding them to parameter lists of subsidiary functions.
     */
    preDataBoundId = preBoundaryId;
    postDataBoundId = postBoundaryId;
 
    ordering = pg_malloc_array(DumpableObject *, numObjs);
    while (!TopoSort(objs, numObjs, ordering, &nOrdering))
        findDependencyLoops(ordering, nOrdering, numObjs);
 
    memcpy(objs, ordering, numObjs * sizeof(DumpableObject *));
 
    free(ordering);
}

References fb(), findDependencyLoops(), free, memcpy(), pg_malloc_array, postDataBoundId, preDataBoundId, and TopoSort().

Referenced by main().

sortDumpableObjectsByTypeName()

void sortDumpableObjectsByTypeName ( DumpableObject **  objs, int  numObjs  )

extern

Definition at line 192 of file pg_dump_sort.c.

{
    if (numObjs > 1)
        qsort(objs, numObjs, sizeof(DumpableObject *),
              DOTypeNameCompare);
}

References DOTypeNameCompare(), fb(), and qsort.

Referenced by main().