pg_dump.h File Reference

#include "pg_backup.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	_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	_attrDefInfo
struct	_tableDataInfo
struct	_indxInfo
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	_blobInfo
struct	_policyInfo
struct	_PublicationInfo
struct	_PublicationRelInfo
struct	_SubscriptionInfo
struct	_extensionMemberId

Macros
#define	oidcmp(x, y)   ( ((x) < (y) ? -1 : ((x) > (y)) ? 1 : 0) )
#define	oideq(x, y)   ( (x) == (y) )
#define	oidle(x, y)   ( (x) <= (y) )
#define	oidge(x, y)   ( (x) >= (y) )
#define	oidzero(x)   ( (x) == 0 )
#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_ALL   (0xFFFF)
#define	DUMP_COMPONENTS_REQUIRING_LOCK

Typedefs
typedef uint32	DumpComponents
typedef struct _dumpableObject	DumpableObject
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 _attrDefInfo	AttrDefInfo
typedef struct _tableDataInfo	TableDataInfo
typedef struct _indxInfo	IndxInfo
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 _blobInfo	BlobInfo
typedef struct _policyInfo	PolicyInfo
typedef struct _PublicationInfo	PublicationInfo
typedef struct _PublicationRelInfo	PublicationRelInfo
typedef struct _SubscriptionInfo	SubscriptionInfo
typedef struct _extensionMemberId	ExtensionMemberId

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_ATTRDEF, DO_INDEX, 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_BLOB, DO_BLOB_DATA, DO_PRE_DATA_BOUNDARY,   DO_POST_DATA_BOUNDARY, DO_EVENT_TRIGGER, DO_REFRESH_MATVIEW, DO_POLICY,   DO_PUBLICATION, DO_PUBLICATION_REL, DO_SUBSCRIPTION }

Functions
TableInfo *	getSchemaData (Archive *fout, int *numTablesPtr)
void	AssignDumpId (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)
CollInfo *	findCollationByOid (Oid oid)
NamespaceInfo *	findNamespaceByOid (Oid oid)
ExtensionInfo *	findExtensionByOid (Oid oid)
void	setExtensionMembership (ExtensionMemberId *extmems, int nextmems)
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	sortDataAndIndexObjectsBySize (DumpableObject **objs, int numObjs)
NamespaceInfo *	getNamespaces (Archive *fout, int *numNamespaces)
ExtensionInfo *	getExtensions (Archive *fout, int *numExtensions)
TypeInfo *	getTypes (Archive *fout, int *numTypes)
FuncInfo *	getFuncs (Archive *fout, int *numFuncs)
AggInfo *	getAggregates (Archive *fout, int *numAggregates)
OprInfo *	getOperators (Archive *fout, int *numOperators)
AccessMethodInfo *	getAccessMethods (Archive *fout, int *numAccessMethods)
OpclassInfo *	getOpclasses (Archive *fout, int *numOpclasses)
OpfamilyInfo *	getOpfamilies (Archive *fout, int *numOpfamilies)
CollInfo *	getCollations (Archive *fout, int *numCollations)
ConvInfo *	getConversions (Archive *fout, int *numConversions)
TableInfo *	getTables (Archive *fout, int *numTables)
void	getOwnedSeqs (Archive *fout, TableInfo tblinfo[], int numTables)
InhInfo *	getInherits (Archive *fout, int *numInherits)
void	getIndexes (Archive *fout, TableInfo tblinfo[], int numTables)
void	getExtendedStatistics (Archive *fout, TableInfo tblinfo[], int numTables)
void	getConstraints (Archive *fout, TableInfo tblinfo[], int numTables)
RuleInfo *	getRules (Archive *fout, int *numRules)
void	getTriggers (Archive *fout, TableInfo tblinfo[], int numTables)
ProcLangInfo *	getProcLangs (Archive *fout, int *numProcLangs)
CastInfo *	getCasts (Archive *fout, int *numCasts)
TransformInfo *	getTransforms (Archive *fout, int *numTransforms)
void	getTableAttrs (Archive *fout, TableInfo *tbinfo, int numTables)
bool	shouldPrintColumn (DumpOptions *dopt, TableInfo *tbinfo, int colno)
TSParserInfo *	getTSParsers (Archive *fout, int *numTSParsers)
TSDictInfo *	getTSDictionaries (Archive *fout, int *numTSDicts)
TSTemplateInfo *	getTSTemplates (Archive *fout, int *numTSTemplates)
TSConfigInfo *	getTSConfigurations (Archive *fout, int *numTSConfigs)
FdwInfo *	getForeignDataWrappers (Archive *fout, int *numForeignDataWrappers)
ForeignServerInfo *	getForeignServers (Archive *fout, int *numForeignServers)
DefaultACLInfo *	getDefaultACLs (Archive *fout, int *numDefaultACLs)
void	getExtensionMembership (Archive *fout, ExtensionInfo extinfo[], int numExtensions)
void	processExtensionTables (Archive *fout, ExtensionInfo extinfo[], int numExtensions)
EventTriggerInfo *	getEventTriggers (Archive *fout, int *numEventTriggers)
void	getPolicies (Archive *fout, TableInfo tblinfo[], int numTables)
void	getPublications (Archive *fout)
void	getPublicationTables (Archive *fout, TableInfo tblinfo[], int numTables)
void	getSubscriptions (Archive *fout)

Variables
bool	force_quotes
bool	g_verbose
char	g_comment_start [10]
char	g_comment_end [10]
char	g_opaque_type [10]

Macro Definition Documentation

#define DUMP_COMPONENT_ACL   (1 << 4)

Definition at line 96 of file pg_dump.h.

Referenced by checkExtensionMembership(), dumpAgg(), dumpBaseType(), dumpBlob(), dumpCompositeType(), dumpDefaultACL(), dumpDomain(), dumpEnumType(), dumpForeignDataWrapper(), dumpForeignServer(), dumpFunc(), dumpNamespace(), dumpProcLang(), dumpRangeType(), dumpTable(), dumpUndefinedType(), getAccessMethods(), getAggregates(), getBlobs(), getCasts(), getCollations(), getConversions(), getEventTriggers(), getForeignDataWrappers(), getForeignServers(), getFuncs(), getNamespaces(), getOpclasses(), getOperators(), getOpfamilies(), getProcLangs(), getTables(), getTSConfigurations(), getTSDictionaries(), getTSParsers(), getTSTemplates(), getTypes(), selectDumpableExtension(), selectDumpableNamespace(), and selectDumpableProcLang().

#define DUMP_COMPONENT_ALL   (0xFFFF)

Definition at line 99 of file pg_dump.h.

Referenced by AssignDumpId(), selectDumpableAccessMethod(), selectDumpableCast(), selectDumpableDefaultACL(), selectDumpableExtension(), selectDumpableNamespace(), selectDumpableObject(), selectDumpableProcLang(), selectDumpablePublicationTable(), and selectDumpableTable().

#define DUMP_COMPONENT_COMMENT   (1 << 2)

Definition at line 94 of file pg_dump.h.

Referenced by dumpAccessMethod(), dumpAgg(), dumpBaseType(), dumpBlob(), dumpCast(), dumpCollation(), dumpCompositeType(), dumpConstraint(), dumpConversion(), dumpDomain(), dumpEnumType(), dumpEventTrigger(), dumpExtension(), dumpForeignDataWrapper(), dumpForeignServer(), dumpFunc(), dumpIndex(), dumpNamespace(), dumpOpclass(), dumpOpfamily(), dumpOpr(), dumpProcLang(), dumpPublication(), dumpRangeType(), dumpRule(), dumpSequence(), dumpStatisticsExt(), dumpSubscription(), dumpTableConstraintComment(), dumpTableSchema(), dumpTransform(), dumpTrigger(), dumpTSConfig(), dumpTSDictionary(), dumpTSParser(), dumpTSTemplate(), and dumpUndefinedType().

#define DUMP_COMPONENT_DATA   (1 << 1)

Definition at line 93 of file pg_dump.h.

Referenced by dumpDumpableObject(), dumpSequenceData(), dumpTableData(), getBlobs(), getTableData(), processExtensionTables(), and refreshMatViewData().

#define DUMP_COMPONENT_DEFINITION   (1 << 0)

Definition at line 92 of file pg_dump.h.

Referenced by dumpAccessMethod(), dumpAgg(), dumpAttrDef(), dumpBaseType(), dumpBlob(), dumpCast(), dumpCollation(), dumpCompositeType(), dumpConstraint(), dumpConversion(), dumpDomain(), dumpEnumType(), dumpEventTrigger(), dumpExtension(), dumpForeignDataWrapper(), dumpForeignServer(), dumpFunc(), dumpIndex(), dumpNamespace(), dumpOpclass(), dumpOpfamily(), dumpOpr(), dumpProcLang(), dumpPublication(), dumpPublicationTable(), dumpRangeType(), dumpRule(), dumpSequence(), dumpShellType(), dumpStatisticsExt(), dumpSubscription(), dumpTableSchema(), dumpTransform(), dumpTrigger(), dumpTSConfig(), dumpTSDictionary(), dumpTSParser(), dumpTSTemplate(), dumpUndefinedType(), getConstraints(), getExtendedStatistics(), getIndexes(), getPublicationTables(), getTriggers(), getTypes(), guessConstraintInheritance(), processExtensionTables(), and repairTypeFuncLoop().

#define DUMP_COMPONENT_NONE   (0)

Definition at line 91 of file pg_dump.h.

Referenced by checkExtensionMembership(), getOwnedSeqs(), getTables(), getTypes(), selectDumpableAccessMethod(), selectDumpableCast(), selectDumpableDefaultACL(), selectDumpableExtension(), selectDumpableNamespace(), selectDumpableObject(), selectDumpableProcLang(), selectDumpablePublicationTable(), selectDumpableTable(), and selectDumpableType().

#define DUMP_COMPONENT_POLICY   (1 << 5)

Definition at line 97 of file pg_dump.h.

Referenced by checkExtensionMembership(), dumpPolicy(), and getPolicies().

#define DUMP_COMPONENT_SECLABEL   (1 << 3)

Definition at line 95 of file pg_dump.h.

Referenced by checkExtensionMembership(), dumpAgg(), dumpBaseType(), dumpBlob(), dumpCompositeType(), dumpDomain(), dumpEnumType(), dumpExtension(), dumpFunc(), dumpNamespace(), dumpProcLang(), dumpPublication(), dumpRangeType(), dumpSequence(), dumpSubscription(), dumpTableSchema(), and dumpUndefinedType().

#define DUMP_COMPONENT_USERMAP   (1 << 6)

Definition at line 98 of file pg_dump.h.

Referenced by dumpForeignServer().

#define DUMP_COMPONENTS_REQUIRING_LOCK

Value:

(\
		DUMP_COMPONENT_DEFINITION |\
		DUMP_COMPONENT_DATA |\
		DUMP_COMPONENT_POLICY)

Definition at line 123 of file pg_dump.h.

Referenced by getTables().

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

Definition at line 20 of file pg_dump.h.

Referenced by DOCatalogIdCompare(), DOTypeNameCompare(), ExtensionMemberIdCompare(), findObjectByCatalogId(), findObjectByOid(), and findOwningExtension().

#define oideq	(		x,
			y
	)		( (x) == (y) )

Definition at line 21 of file pg_dump.h.

#define oidge	(		x,
			y
	)		( (x) >= (y) )

Definition at line 23 of file pg_dump.h.

#define oidle	(		x,
			y
	)		( (x) <= (y) )

Definition at line 22 of file pg_dump.h.

#define oidzero

(

x

)

( (x) == 0 )

Definition at line 24 of file pg_dump.h.

Typedef Documentation

typedef struct _accessMethodInfo AccessMethodInfo

typedef struct _aggInfo AggInfo

typedef struct _attrDefInfo AttrDefInfo

typedef struct _blobInfo BlobInfo

typedef struct _castInfo CastInfo

typedef struct _collInfo CollInfo

typedef struct _constraintInfo ConstraintInfo

typedef struct _convInfo ConvInfo

typedef struct _defaultACLInfo DefaultACLInfo

typedef struct _dumpableObject DumpableObject

typedef uint32 DumpComponents

Definition at line 90 of file pg_dump.h.

typedef struct _evttriggerInfo EventTriggerInfo

typedef struct _extensionInfo ExtensionInfo

typedef struct _extensionMemberId ExtensionMemberId

typedef struct _fdwInfo FdwInfo

typedef struct _foreignServerInfo ForeignServerInfo

typedef struct _funcInfo FuncInfo

typedef struct _indxInfo IndxInfo

typedef struct _inhInfo InhInfo

typedef struct _namespaceInfo NamespaceInfo

typedef struct _opclassInfo OpclassInfo

typedef struct _opfamilyInfo OpfamilyInfo

typedef struct _oprInfo OprInfo

typedef struct _policyInfo PolicyInfo

typedef struct _procLangInfo ProcLangInfo

typedef struct _PublicationInfo PublicationInfo

typedef struct _PublicationRelInfo PublicationRelInfo

typedef struct _ruleInfo RuleInfo

typedef struct _shellTypeInfo ShellTypeInfo

typedef struct _statsExtInfo StatsExtInfo

typedef struct _SubscriptionInfo SubscriptionInfo

typedef struct _tableDataInfo TableDataInfo

typedef struct _tableInfo TableInfo

typedef struct _transformInfo TransformInfo

typedef struct _triggerInfo TriggerInfo

typedef struct _cfgInfo TSConfigInfo

typedef struct _dictInfo TSDictInfo

typedef struct _prsInfo TSParserInfo

typedef struct _tmplInfo TSTemplateInfo

typedef struct _typeInfo TypeInfo

Enumeration Type Documentation

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_ATTRDEF
DO_INDEX
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_BLOB
DO_BLOB_DATA
DO_PRE_DATA_BOUNDARY
DO_POST_DATA_BOUNDARY
DO_EVENT_TRIGGER
DO_REFRESH_MATVIEW
DO_POLICY
DO_PUBLICATION
DO_PUBLICATION_REL
DO_SUBSCRIPTION

Definition at line 41 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_ATTRDEF,
    DO_INDEX,
    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_BLOB,
    DO_BLOB_DATA,
    DO_PRE_DATA_BOUNDARY,
    DO_POST_DATA_BOUNDARY,
    DO_EVENT_TRIGGER,
    DO_REFRESH_MATVIEW,
    DO_POLICY,
    DO_PUBLICATION,
    DO_PUBLICATION_REL,
    DO_SUBSCRIPTION
} DumpableObjectType;

Function Documentation

void addObjectDependency	(	DumpableObject *	dobj,
		DumpId	refId
	)

Definition at line 712 of file common.c.

References _dumpableObject::allocDeps, _dumpableObject::dependencies, _dumpableObject::nDeps, pg_malloc(), and pg_realloc().

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

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

void AssignDumpId

(

DumpableObject *

dobj

)

Definition at line 476 of file common.c.

References _dumpableObject::allocDeps, allocedDumpIds, catalogIdMapValid, _dumpableObject::dependencies, _dumpableObject::dump, DUMP_COMPONENT_ALL, _dumpableObject::dumpId, _dumpableObject::ext_member, lastDumpId, _dumpableObject::name, _dumpableObject::nDeps, pg_malloc(), and pg_realloc().

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

{
    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->ext_member = false;   /* default assumption */
    dobj->dependencies = NULL;
    dobj->nDeps = 0;
    dobj->allocDeps = 0;

    while (dobj->dumpId >= allocedDumpIds)
    {
        int         newAlloc;

        if (allocedDumpIds <= 0)
        {
            newAlloc = 256;
            dumpIdMap = (DumpableObject **)
                pg_malloc(newAlloc * sizeof(DumpableObject *));
        }
        else
        {
            newAlloc = allocedDumpIds * 2;
            dumpIdMap = (DumpableObject **)
                pg_realloc(dumpIdMap, newAlloc * sizeof(DumpableObject *));
        }
        memset(dumpIdMap + allocedDumpIds, 0,
               (newAlloc - allocedDumpIds) * sizeof(DumpableObject *));
        allocedDumpIds = newAlloc;
    }
    dumpIdMap[dobj->dumpId] = dobj;

    /* mark catalogIdMap invalid, but don't rebuild it yet */
    catalogIdMapValid = false;
}

DumpId createDumpId

(

void

)

Definition at line 520 of file common.c.

References lastDumpId.

Referenced by dumpACL(), dumpComment(), dumpCompositeTypeColComments(), dumpDatabase(), dumpEncoding(), dumpSecLabel(), dumpSequence(), dumpSequenceData(), dumpStdStrings(), dumpTableComment(), dumpTableSecLabel(), and dumpUserMappings().

{
    return ++lastDumpId;
}

CollInfo* findCollationByOid

(

Oid

oid

)

Definition at line 803 of file common.c.

References findObjectByOid(), and numCollations.

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

{
    return (CollInfo *) findObjectByOid(oid, collinfoindex, numCollations);
}

ExtensionInfo* findExtensionByOid

(

Oid

oid

)

Definition at line 825 of file common.c.

References findObjectByOid(), and numExtensions.

Referenced by getExtensionMembership().

{
    return (ExtensionInfo *) findObjectByOid(oid, extinfoindex, numExtensions);
}

FuncInfo* findFuncByOid

(

Oid

oid

)

Definition at line 781 of file common.c.

References findObjectByOid(), and numFuncs.

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

{
    return (FuncInfo *) findObjectByOid(oid, funinfoindex, numFuncs);
}

NamespaceInfo* findNamespaceByOid

(

Oid

oid

)

Definition at line 814 of file common.c.

References findObjectByOid(), and numNamespaces.

Referenced by findNamespace().

{
    return (NamespaceInfo *) findObjectByOid(oid, nspinfoindex, numNamespaces);
}

DumpableObject* findObjectByCatalogId

(

CatalogId

catalogId

)

Definition at line 558 of file common.c.

References catalogIdMap, catalogIdMapValid, difference(), DOCatalogIdCompare(), free, getDumpableObjects(), numCatalogIds, CatalogId::oid, oidcmp, qsort, and CatalogId::tableoid.

Referenced by buildMatViewRefreshDependencies(), and getDependencies().

{
    DumpableObject **low;
    DumpableObject **high;

    if (!catalogIdMapValid)
    {
        if (catalogIdMap)
            free(catalogIdMap);
        getDumpableObjects(&catalogIdMap, &numCatalogIds);
        if (numCatalogIds > 1)
            qsort((void *) catalogIdMap, numCatalogIds,
                  sizeof(DumpableObject *), DOCatalogIdCompare);
        catalogIdMapValid = true;
    }

    /*
     * We could use bsearch() here, but the notational cruft of calling
     * bsearch is nearly as bad as doing it ourselves; and the generalized
     * bsearch function is noticeably slower as well.
     */
    if (numCatalogIds <= 0)
        return NULL;
    low = catalogIdMap;
    high = catalogIdMap + (numCatalogIds - 1);
    while (low <= high)
    {
        DumpableObject **middle;
        int         difference;

        middle = low + (high - low) / 2;
        /* comparison must match DOCatalogIdCompare, below */
        difference = oidcmp((*middle)->catId.oid, catalogId.oid);
        if (difference == 0)
            difference = oidcmp((*middle)->catId.tableoid, catalogId.tableoid);
        if (difference == 0)
            return *middle;
        else if (difference < 0)
            low = middle + 1;
        else
            high = middle - 1;
    }
    return NULL;
}

DumpableObject* findObjectByDumpId

(

DumpId

dumpId

)

Definition at line 540 of file common.c.

References allocedDumpIds.

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

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

OprInfo* findOprByOid

(

Oid

oid

)

Definition at line 792 of file common.c.

References findObjectByOid(), and numOperators.

{
    return (OprInfo *) findObjectByOid(oid, oprinfoindex, numOperators);
}

ExtensionInfo* findOwningExtension

(

CatalogId

catalogId

)

Definition at line 852 of file common.c.

References _extensionMemberId::catId, difference(), _extensionMemberId::ext, extmembers, numextmembers, CatalogId::oid, oidcmp, and CatalogId::tableoid.

Referenced by checkExtensionMembership().

{
    ExtensionMemberId *low;
    ExtensionMemberId *high;

    /*
     * We could use bsearch() here, but the notational cruft of calling
     * bsearch is nearly as bad as doing it ourselves; and the generalized
     * bsearch function is noticeably slower as well.
     */
    if (numextmembers <= 0)
        return NULL;
    low = extmembers;
    high = extmembers + (numextmembers - 1);
    while (low <= high)
    {
        ExtensionMemberId *middle;
        int         difference;

        middle = low + (high - low) / 2;
        /* comparison must match ExtensionMemberIdCompare, below */
        difference = oidcmp(middle->catId.oid, catalogId.oid);
        if (difference == 0)
            difference = oidcmp(middle->catId.tableoid, catalogId.tableoid);
        if (difference == 0)
            return middle->ext;
        else if (difference < 0)
            low = middle + 1;
        else
            high = middle - 1;
    }
    return NULL;
}

TableInfo* findTableByOid

(

Oid

oid

)

Definition at line 759 of file common.c.

References findObjectByOid(), and numTables.

Referenced by dumpSequence(), findParentsByOid(), getOwnedSeqs(), getRules(), getTableDataFKConstraints(), processExtensionTables(), and selectDumpableType().

{
    return (TableInfo *) findObjectByOid(oid, tblinfoindex, numTables);
}

TypeInfo* findTypeByOid

(

Oid

oid

)

Definition at line 770 of file common.c.

References findObjectByOid(), and numTypes.

Referenced by DOTypeNameCompare(), getCasts(), and getTransforms().

{
    return (TypeInfo *) findObjectByOid(oid, typinfoindex, numTypes);
}

AccessMethodInfo* getAccessMethods	(	Archive *	fout,
		int *	numAccessMethods
	)

Definition at line 4933 of file pg_dump.c.

References _accessMethodInfo::amhandler, _accessMethodInfo::amtype, appendPQExpBuffer(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_ACCESS_METHOD, _accessMethodInfo::dobj, _dumpableObject::dump, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), i, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), Archive::remoteVersion, selectDumpableAccessMethod(), selectSourceSchema(), and CatalogId::tableoid.

Referenced by getSchemaData().

{
    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;

    /* Before 9.6, there are no user-defined access methods */
    if (fout->remoteVersion < 90600)
    {
        *numAccessMethods = 0;
        return NULL;
    }

    query = createPQExpBuffer();

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

    /* Select all access methods from pg_am table */
    appendPQExpBuffer(query, "SELECT tableoid, oid, amname, amtype, "
                      "amhandler::pg_catalog.regproc AS amhandler "
                      "FROM pg_am");

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

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

    aminfo = (AccessMethodInfo *) pg_malloc(ntups * sizeof(AccessMethodInfo));

    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);

        /* Access methods do not currently have ACLs. */
        aminfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return aminfo;
}

AggInfo* getAggregates	(	Archive *	fout,
		int *	numAggregates
	)

Definition at line 5175 of file pg_dump.c.

References _aggInfo::aggfn, appendPQExpBuffer(), appendPQExpBufferChar(), appendPQExpBufferStr(), _funcInfo::argtypes, AssignDumpId(), atooid, _dumpOptions::binary_upgrade, buildACLQueries(), _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_AGG, _funcInfo::dobj, Archive::dopt, _dumpableObject::dump, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), findNamespace(), i, _funcInfo::initproacl, _funcInfo::initrproacl, InvalidOid, _funcInfo::lang, _dumpableObject::name, _funcInfo::nargs, _dumpableObject::objType, CatalogId::oid, parseOidArray(), pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetisnull(), PQgetvalue(), PQntuples(), _funcInfo::proacl, _funcInfo::prorettype, Archive::remoteVersion, _funcInfo::rolname, _funcInfo::rproacl, selectDumpableObject(), selectSourceSchema(), CatalogId::tableoid, username_subquery, and write_msg().

Referenced by getSchemaData().

{
    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_rolname;
    int         i_aggacl;
    int         i_raggacl;
    int         i_initaggacl;
    int         i_initraggacl;

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

    /*
     * Find all interesting aggregates.  See comment in getFuncs() for the
     * rationale behind the filtering logic.
     */
    if (fout->remoteVersion >= 90600)
    {
        PQExpBuffer acl_subquery = createPQExpBuffer();
        PQExpBuffer racl_subquery = createPQExpBuffer();
        PQExpBuffer initacl_subquery = createPQExpBuffer();
        PQExpBuffer initracl_subquery = createPQExpBuffer();

        buildACLQueries(acl_subquery, racl_subquery, initacl_subquery,
                        initracl_subquery, "p.proacl", "p.proowner", "'f'",
                        dopt->binary_upgrade);

        appendPQExpBuffer(query, "SELECT p.tableoid, p.oid, "
                          "p.proname AS aggname, "
                          "p.pronamespace AS aggnamespace, "
                          "p.pronargs, p.proargtypes, "
                          "(%s p.proowner) AS rolname, "
                          "%s AS aggacl, "
                          "%s AS raggacl, "
                          "%s AS initaggacl, "
                          "%s AS initraggacl "
                          "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 p.proisagg AND ("
                          "p.pronamespace != "
                          "(SELECT oid FROM pg_namespace "
                          "WHERE nspname = 'pg_catalog') OR "
                          "p.proacl IS DISTINCT FROM pip.initprivs",
                          username_subquery,
                          acl_subquery->data,
                          racl_subquery->data,
                          initacl_subquery->data,
                          initracl_subquery->data);
        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, ')');

        destroyPQExpBuffer(acl_subquery);
        destroyPQExpBuffer(racl_subquery);
        destroyPQExpBuffer(initacl_subquery);
        destroyPQExpBuffer(initracl_subquery);
    }
    else if (fout->remoteVersion >= 80200)
    {
        appendPQExpBuffer(query, "SELECT tableoid, oid, proname AS aggname, "
                          "pronamespace AS aggnamespace, "
                          "pronargs, proargtypes, "
                          "(%s proowner) AS rolname, "
                          "proacl AS aggacl, "
                          "NULL AS raggacl, "
                          "NULL AS initaggacl, NULL AS initraggacl "
                          "FROM pg_proc p "
                          "WHERE proisagg AND ("
                          "pronamespace != "
                          "(SELECT oid FROM pg_namespace "
                          "WHERE nspname = 'pg_catalog')",
                          username_subquery);
        if (dopt->binary_upgrade && fout->remoteVersion >= 90100)
            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
    {
        appendPQExpBuffer(query, "SELECT tableoid, oid, proname AS aggname, "
                          "pronamespace AS aggnamespace, "
                          "CASE WHEN proargtypes[0] = 'pg_catalog.\"any\"'::pg_catalog.regtype THEN 0 ELSE 1 END AS pronargs, "
                          "proargtypes, "
                          "(%s proowner) AS rolname, "
                          "proacl AS aggacl, "
                          "NULL AS raggacl, "
                          "NULL AS initaggacl, NULL AS initraggacl "
                          "FROM pg_proc "
                          "WHERE proisagg "
                          "AND pronamespace != "
                          "(SELECT oid FROM pg_namespace WHERE nspname = 'pg_catalog')",
                          username_subquery);
    }

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

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

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

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_aggname = PQfnumber(res, "aggname");
    i_aggnamespace = PQfnumber(res, "aggnamespace");
    i_pronargs = PQfnumber(res, "pronargs");
    i_proargtypes = PQfnumber(res, "proargtypes");
    i_rolname = PQfnumber(res, "rolname");
    i_aggacl = PQfnumber(res, "aggacl");
    i_raggacl = PQfnumber(res, "raggacl");
    i_initaggacl = PQfnumber(res, "initaggacl");
    i_initraggacl = PQfnumber(res, "initraggacl");

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

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

        /* Do not try to dump ACL if no ACL exists. */
        if (PQgetisnull(res, i, i_aggacl) && PQgetisnull(res, i, i_raggacl) &&
            PQgetisnull(res, i, i_initaggacl) &&
            PQgetisnull(res, i, i_initraggacl))
            agginfo[i].aggfn.dobj.dump &= ~DUMP_COMPONENT_ACL;
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return agginfo;
}

CastInfo* getCasts	(	Archive *	fout,
		int *	numCasts
	)

Definition at line 7651 of file pg_dump.c.

References appendPQExpBuffer(), appendPQExpBufferStr(), AssignDumpId(), atooid, _castInfo::castcontext, _castInfo::castfunc, _castInfo::castmethod, _castInfo::castsource, _castInfo::casttarget, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_CAST, _typeInfo::dobj, _castInfo::dobj, _dumpableObject::dump, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), findTypeByOid(), i, initPQExpBuffer(), _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), Archive::remoteVersion, selectDumpableCast(), selectSourceSchema(), and CatalogId::tableoid.

Referenced by getSchemaData().

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    CastInfo   *castinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_castsource;
    int         i_casttarget;
    int         i_castfunc;
    int         i_castcontext;
    int         i_castmethod;

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

    if (fout->remoteVersion >= 80400)
    {
        appendPQExpBufferStr(query, "SELECT tableoid, oid, "
                             "castsource, casttarget, castfunc, castcontext, "
                             "castmethod "
                             "FROM pg_cast ORDER BY 3,4");
    }
    else
    {
        appendPQExpBufferStr(query, "SELECT tableoid, oid, "
                             "castsource, casttarget, castfunc, castcontext, "
                             "CASE WHEN castfunc = 0 THEN 'b' ELSE 'f' END AS castmethod "
                             "FROM pg_cast ORDER BY 3,4");
    }

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

    ntups = PQntuples(res);

    *numCasts = ntups;

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

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

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

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

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

        /* Decide whether we want to dump it */
        selectDumpableCast(&(castinfo[i]), fout);

        /* Casts do not currently have ACLs. */
        castinfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return castinfo;
}

CollInfo* getCollations	(	Archive *	fout,
		int *	numCollations
	)

Definition at line 4774 of file pg_dump.c.

References appendPQExpBuffer(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_COLLATION, _collInfo::dobj, _dumpableObject::dump, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), findNamespace(), i, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), Archive::remoteVersion, _collInfo::rolname, selectDumpableObject(), selectSourceSchema(), CatalogId::tableoid, and username_subquery.

Referenced by getSchemaData().

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    CollInfo   *collinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_collname;
    int         i_collnamespace;
    int         i_rolname;

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

    query = createPQExpBuffer();

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

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

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

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

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

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

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

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

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

        /* Collations do not currently have ACLs. */
        collinfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return collinfo;
}

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

Definition at line 6876 of file pg_dump.c.

References appendPQExpBuffer(), AssignDumpId(), atooid, _dumpableObject::catId, _constraintInfo::condef, _constraintInfo::condeferrable, _constraintInfo::condeferred, _constraintInfo::condomain, _constraintInfo::confrelid, _constraintInfo::conindex, _constraintInfo::conislocal, _constraintInfo::contable, _constraintInfo::contype, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_FK_CONSTRAINT, _tableInfo::dobj, _constraintInfo::dobj, _dumpableObject::dump, DUMP_COMPONENT_DEFINITION, ExecuteSqlQuery(), g_verbose, _tableInfo::hastriggers, i, _dumpableObject::name, numTables, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), resetPQExpBuffer(), selectSourceSchema(), _constraintInfo::separate, CatalogId::tableoid, and write_msg().

Referenced by getSchemaData().

{
    int         i,
                j;
    ConstraintInfo *constrinfo;
    PQExpBuffer query;
    PGresult   *res;
    int         i_contableoid,
                i_conoid,
                i_conname,
                i_confrelid,
                i_condef;
    int         ntups;

    query = createPQExpBuffer();

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

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

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

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

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

        ntups = PQntuples(res);

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

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

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

        PQclear(res);
    }

    destroyPQExpBuffer(query);
}

ConvInfo* getConversions	(	Archive *	fout,
		int *	numConversions
	)

Definition at line 4857 of file pg_dump.c.

References appendPQExpBuffer(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_CONVERSION, _convInfo::dobj, _dumpableObject::dump, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), findNamespace(), i, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), _convInfo::rolname, selectDumpableObject(), selectSourceSchema(), CatalogId::tableoid, and username_subquery.

Referenced by getSchemaData().

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    ConvInfo   *convinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_conname;
    int         i_connamespace;
    int         i_rolname;

    query = createPQExpBuffer();

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

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

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

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

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

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

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

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

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

        /* Conversions do not currently have ACLs. */
        convinfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return convinfo;
}

DefaultACLInfo* getDefaultACLs	(	Archive *	fout,
		int *	numDefaultACLs
	)

Definition at line 9017 of file pg_dump.c.

References appendPQExpBuffer(), AssignDumpId(), atooid, _dumpOptions::binary_upgrade, buildACLQueries(), _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, _defaultACLInfo::defaclacl, _defaultACLInfo::defaclobjtype, _defaultACLInfo::defaclrole, destroyPQExpBuffer(), DO_DEFAULT_ACL, _defaultACLInfo::dobj, Archive::dopt, ExecuteSqlQuery(), findNamespace(), i, _defaultACLInfo::initdefaclacl, _defaultACLInfo::initrdefaclacl, InvalidOid, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), _defaultACLInfo::rdefaclacl, Archive::remoteVersion, selectDumpableDefaultACL(), selectSourceSchema(), CatalogId::tableoid, and username_subquery.

Referenced by getSchemaData().

{
    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_rdefaclacl;
    int         i_initdefaclacl;
    int         i_initrdefaclacl;
    int         i,
                ntups;

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

    query = createPQExpBuffer();

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

    if (fout->remoteVersion >= 90600)
    {
        PQExpBuffer acl_subquery = createPQExpBuffer();
        PQExpBuffer racl_subquery = createPQExpBuffer();
        PQExpBuffer initacl_subquery = createPQExpBuffer();
        PQExpBuffer initracl_subquery = createPQExpBuffer();

        buildACLQueries(acl_subquery, racl_subquery, initacl_subquery,
                        initracl_subquery, "defaclacl", "defaclrole",
                        "CASE WHEN defaclobjtype = 'S' THEN 's' ELSE defaclobjtype END::\"char\"",
                        dopt->binary_upgrade);

        appendPQExpBuffer(query, "SELECT d.oid, d.tableoid, "
                          "(%s d.defaclrole) AS defaclrole, "
                          "d.defaclnamespace, "
                          "d.defaclobjtype, "
                          "%s AS defaclacl, "
                          "%s AS rdefaclacl, "
                          "%s AS initdefaclacl, "
                          "%s AS initrdefaclacl "
                          "FROM pg_default_acl d "
                          "LEFT JOIN pg_init_privs pip ON "
                          "(d.oid = pip.objoid "
                          "AND pip.classoid = 'pg_default_acl'::regclass "
                          "AND pip.objsubid = 0) ",
                          username_subquery,
                          acl_subquery->data,
                          racl_subquery->data,
                          initacl_subquery->data,
                          initracl_subquery->data);
    }
    else
    {
        appendPQExpBuffer(query, "SELECT oid, tableoid, "
                          "(%s defaclrole) AS defaclrole, "
                          "defaclnamespace, "
                          "defaclobjtype, "
                          "defaclacl, "
                          "NULL AS rdefaclacl, "
                          "NULL AS initdefaclacl, "
                          "NULL AS initrdefaclacl "
                          "FROM pg_default_acl",
                          username_subquery);
    }

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

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

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

    i_oid = PQfnumber(res, "oid");
    i_tableoid = PQfnumber(res, "tableoid");
    i_defaclrole = PQfnumber(res, "defaclrole");
    i_defaclnamespace = PQfnumber(res, "defaclnamespace");
    i_defaclobjtype = PQfnumber(res, "defaclobjtype");
    i_defaclacl = PQfnumber(res, "defaclacl");
    i_rdefaclacl = PQfnumber(res, "rdefaclacl");
    i_initdefaclacl = PQfnumber(res, "initdefaclacl");
    i_initrdefaclacl = PQfnumber(res, "initrdefaclacl");

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

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

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

        daclinfo[i].defaclrole = pg_strdup(PQgetvalue(res, i, i_defaclrole));
        daclinfo[i].defaclobjtype = *(PQgetvalue(res, i, i_defaclobjtype));
        daclinfo[i].defaclacl = pg_strdup(PQgetvalue(res, i, i_defaclacl));
        daclinfo[i].rdefaclacl = pg_strdup(PQgetvalue(res, i, i_rdefaclacl));
        daclinfo[i].initdefaclacl = pg_strdup(PQgetvalue(res, i, i_initdefaclacl));
        daclinfo[i].initrdefaclacl = pg_strdup(PQgetvalue(res, i, i_initrdefaclacl));

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

    PQclear(res);

    destroyPQExpBuffer(query);

    return daclinfo;
}

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

Definition at line 690 of file common.c.

References allocedDumpIds, i, and pg_malloc().

Referenced by findObjectByCatalogId(), getTableDataFKConstraints(), and main().

{
    int         i,
                j;

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

EventTriggerInfo* getEventTriggers	(	Archive *	fout,
		int *	numEventTriggers
	)

Definition at line 7376 of file pg_dump.c.

References appendPQExpBuffer(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_EVENT_TRIGGER, _evttriggerInfo::dobj, _dumpableObject::dump, DUMP_COMPONENT_ACL, _evttriggerInfo::evtenabled, _evttriggerInfo::evtevent, _evttriggerInfo::evtfname, _evttriggerInfo::evtname, _evttriggerInfo::evtowner, _evttriggerInfo::evttags, ExecuteSqlQuery(), i, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), Archive::remoteVersion, selectDumpableObject(), selectSourceSchema(), CatalogId::tableoid, and username_subquery.

Referenced by getSchemaData().

{
    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)
    {
        *numEventTriggers = 0;
        return NULL;
    }

    query = createPQExpBuffer();

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

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

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

    ntups = PQntuples(res);

    *numEventTriggers = ntups;

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

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

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

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

        /* Event Triggers do not currently have ACLs. */
        evtinfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return evtinfo;
}

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

Definition at line 6777 of file pg_dump.c.

References appendPQExpBuffer(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_STATSEXT, _tableInfo::dobj, _statsExtInfo::dobj, _dumpableObject::dump, DUMP_COMPONENT_DEFINITION, ExecuteSqlQuery(), g_verbose, i, _dumpableObject::name, numTables, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), _tableInfo::relkind, RELKIND_FOREIGN_TABLE, RELKIND_MATVIEW, RELKIND_PARTITIONED_TABLE, RELKIND_RELATION, Archive::remoteVersion, resetPQExpBuffer(), selectSourceSchema(), _statsExtInfo::statsextdef, _statsExtInfo::statsexttable, CatalogId::tableoid, and write_msg().

Referenced by getSchemaData().

{
    int         i,
                j;
    PQExpBuffer query;
    PGresult   *res;
    StatsExtInfo *statsextinfo;
    int         ntups;
    int         i_tableoid;
    int         i_oid;
    int         i_stxname;
    int         i_stxdef;

    /* Extended statistics were new in v10 */
    if (fout->remoteVersion < 100000)
        return;

    query = createPQExpBuffer();

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

        /*
         * Only plain tables, materialized views, foreign tables and
         * partitioned tables can have extended statistics.
         */
        if (tbinfo->relkind != RELKIND_RELATION &&
            tbinfo->relkind != RELKIND_MATVIEW &&
            tbinfo->relkind != RELKIND_FOREIGN_TABLE &&
            tbinfo->relkind != RELKIND_PARTITIONED_TABLE)
            continue;

        /*
         * Ignore extended statistics of tables whose definitions are not to
         * be dumped.
         */
        if (!(tbinfo->dobj.dump & DUMP_COMPONENT_DEFINITION))
            continue;

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

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

        resetPQExpBuffer(query);

        appendPQExpBuffer(query,
                          "SELECT "
                          "tableoid, "
                          "oid, "
                          "stxname, "
                          "pg_catalog.pg_get_statisticsobjdef(oid) AS stxdef "
                          "FROM pg_statistic_ext "
                          "WHERE stxrelid = '%u' "
                          "ORDER BY stxname", tbinfo->dobj.catId.oid);

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

        ntups = PQntuples(res);

        i_tableoid = PQfnumber(res, "tableoid");
        i_oid = PQfnumber(res, "oid");
        i_stxname = PQfnumber(res, "stxname");
        i_stxdef = PQfnumber(res, "stxdef");

        statsextinfo = (StatsExtInfo *) pg_malloc(ntups * sizeof(StatsExtInfo));

        for (j = 0; j < ntups; j++)
        {
            statsextinfo[j].dobj.objType = DO_STATSEXT;
            statsextinfo[j].dobj.catId.tableoid = atooid(PQgetvalue(res, j, i_tableoid));
            statsextinfo[j].dobj.catId.oid = atooid(PQgetvalue(res, j, i_oid));
            AssignDumpId(&statsextinfo[j].dobj);
            statsextinfo[j].dobj.name = pg_strdup(PQgetvalue(res, j, i_stxname));
            statsextinfo[j].dobj.namespace = tbinfo->dobj.namespace;
            statsextinfo[j].statsexttable = tbinfo;
            statsextinfo[j].statsextdef = pg_strdup(PQgetvalue(res, j, i_stxdef));
        }

        PQclear(res);
    }

    destroyPQExpBuffer(query);
}

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

Definition at line 17314 of file pg_dump.c.

References appendPQExpBufferStr(), atooid, _dumpableObject::catId, _extensionMemberId::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), _extensionInfo::dobj, ExecuteSqlQuery(), _extensionMemberId::ext, extmembers, findExtensionByOid(), i, CatalogId::oid, pg_malloc(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), selectSourceSchema(), setExtensionMembership(), and CatalogId::tableoid.

Referenced by getSchemaData().

{
    PQExpBuffer query;
    PGresult   *res;
    int         ntups,
                nextmembers,
                i;
    int         i_classid,
                i_objid,
                i_refobjid;
    ExtensionMemberId *extmembers;
    ExtensionInfo *ext;

    /* Nothing to do if no extensions */
    if (numExtensions == 0)
        return;

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

    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");

    extmembers = (ExtensionMemberId *) pg_malloc(ntups * sizeof(ExtensionMemberId));
    nextmembers = 0;

    /*
     * Accumulate data into extmembers[].
     *
     * 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 */
            fprintf(stderr, "could not find referenced extension %u\n", extId);
            continue;
        }

        extmembers[nextmembers].catId = objId;
        extmembers[nextmembers].ext = ext;
        nextmembers++;
    }

    PQclear(res);

    /* Remember the data for use later */
    setExtensionMembership(extmembers, nextmembers);

    destroyPQExpBuffer(query);
}

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

Definition at line 4348 of file pg_dump.c.

References appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_EXTENSION, _extensionInfo::dobj, Archive::dopt, ExecuteSqlQuery(), _extensionInfo::extcondition, _extensionInfo::extconfig, _extensionInfo::extversion, i, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), _extensionInfo::relocatable, Archive::remoteVersion, selectDumpableExtension(), selectSourceSchema(), and CatalogId::tableoid.

Referenced by getSchemaData().

{
    DumpOptions *dopt = fout->dopt;
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    ExtensionInfo *extinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_extname;
    int         i_nspname;
    int         i_extrelocatable;
    int         i_extversion;
    int         i_extconfig;
    int         i_extcondition;

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

    query = createPQExpBuffer();

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

    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);

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

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

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

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

    PQclear(res);
    destroyPQExpBuffer(query);

    *numExtensions = ntups;

    return extinfo;
}

FdwInfo* getForeignDataWrappers	(	Archive *	fout,
		int *	numForeignDataWrappers
	)

Definition at line 8695 of file pg_dump.c.

References appendPQExpBuffer(), AssignDumpId(), atooid, _dumpOptions::binary_upgrade, buildACLQueries(), _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_FDW, _fdwInfo::dobj, Archive::dopt, _dumpableObject::dump, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), _fdwInfo::fdwacl, _fdwInfo::fdwhandler, _fdwInfo::fdwoptions, _fdwInfo::fdwvalidator, i, _fdwInfo::initfdwacl, _fdwInfo::initrfdwacl, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetisnull(), PQgetvalue(), PQntuples(), Archive::remoteVersion, _fdwInfo::rfdwacl, _fdwInfo::rolname, selectDumpableObject(), selectSourceSchema(), CatalogId::tableoid, and username_subquery.

Referenced by getSchemaData().

{
    DumpOptions *dopt = fout->dopt;
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    FdwInfo    *fdwinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_fdwname;
    int         i_rolname;
    int         i_fdwhandler;
    int         i_fdwvalidator;
    int         i_fdwacl;
    int         i_rfdwacl;
    int         i_initfdwacl;
    int         i_initrfdwacl;
    int         i_fdwoptions;

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

    query = createPQExpBuffer();

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

    if (fout->remoteVersion >= 90600)
    {
        PQExpBuffer acl_subquery = createPQExpBuffer();
        PQExpBuffer racl_subquery = createPQExpBuffer();
        PQExpBuffer initacl_subquery = createPQExpBuffer();
        PQExpBuffer initracl_subquery = createPQExpBuffer();

        buildACLQueries(acl_subquery, racl_subquery, initacl_subquery,
                        initracl_subquery, "f.fdwacl", "f.fdwowner", "'F'",
                        dopt->binary_upgrade);

        appendPQExpBuffer(query, "SELECT f.tableoid, f.oid, f.fdwname, "
                          "(%s f.fdwowner) AS rolname, "
                          "f.fdwhandler::pg_catalog.regproc, "
                          "f.fdwvalidator::pg_catalog.regproc, "
                          "%s AS fdwacl, "
                          "%s AS rfdwacl, "
                          "%s AS initfdwacl, "
                          "%s AS initrfdwacl, "
                          "array_to_string(ARRAY("
                          "SELECT quote_ident(option_name) || ' ' || "
                          "quote_literal(option_value) "
                          "FROM pg_options_to_table(f.fdwoptions) "
                          "ORDER BY option_name"
                          "), E',\n    ') AS fdwoptions "
                          "FROM pg_foreign_data_wrapper f "
                          "LEFT JOIN pg_init_privs pip ON "
                          "(f.oid = pip.objoid "
                          "AND pip.classoid = 'pg_foreign_data_wrapper'::regclass "
                          "AND pip.objsubid = 0) ",
                          username_subquery,
                          acl_subquery->data,
                          racl_subquery->data,
                          initacl_subquery->data,
                          initracl_subquery->data);

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

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

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

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

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

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

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

        /* Do not try to dump ACL if no ACL exists. */
        if (PQgetisnull(res, i, i_fdwacl) && PQgetisnull(res, i, i_rfdwacl) &&
            PQgetisnull(res, i, i_initfdwacl) &&
            PQgetisnull(res, i, i_initrfdwacl))
            fdwinfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return fdwinfo;
}

ForeignServerInfo* getForeignServers	(	Archive *	fout,
		int *	numForeignServers
	)

Definition at line 8864 of file pg_dump.c.

References appendPQExpBuffer(), AssignDumpId(), atooid, _dumpOptions::binary_upgrade, buildACLQueries(), _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_FOREIGN_SERVER, _foreignServerInfo::dobj, Archive::dopt, _dumpableObject::dump, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), i, _foreignServerInfo::initrsrvacl, _foreignServerInfo::initsrvacl, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetisnull(), PQgetvalue(), PQntuples(), Archive::remoteVersion, _foreignServerInfo::rolname, _foreignServerInfo::rsrvacl, selectDumpableObject(), selectSourceSchema(), _foreignServerInfo::srvacl, _foreignServerInfo::srvfdw, _foreignServerInfo::srvoptions, _foreignServerInfo::srvtype, _foreignServerInfo::srvversion, CatalogId::tableoid, and username_subquery.

Referenced by getSchemaData().

{
    DumpOptions *dopt = fout->dopt;
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    ForeignServerInfo *srvinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_srvname;
    int         i_rolname;
    int         i_srvfdw;
    int         i_srvtype;
    int         i_srvversion;
    int         i_srvacl;
    int         i_rsrvacl;
    int         i_initsrvacl;
    int         i_initrsrvacl;
    int         i_srvoptions;

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

    query = createPQExpBuffer();

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

    if (fout->remoteVersion >= 90600)
    {
        PQExpBuffer acl_subquery = createPQExpBuffer();
        PQExpBuffer racl_subquery = createPQExpBuffer();
        PQExpBuffer initacl_subquery = createPQExpBuffer();
        PQExpBuffer initracl_subquery = createPQExpBuffer();

        buildACLQueries(acl_subquery, racl_subquery, initacl_subquery,
                        initracl_subquery, "f.srvacl", "f.srvowner", "'S'",
                        dopt->binary_upgrade);

        appendPQExpBuffer(query, "SELECT f.tableoid, f.oid, f.srvname, "
                          "(%s f.srvowner) AS rolname, "
                          "f.srvfdw, f.srvtype, f.srvversion, "
                          "%s AS srvacl, "
                          "%s AS rsrvacl, "
                          "%s AS initsrvacl, "
                          "%s AS initrsrvacl, "
                          "array_to_string(ARRAY("
                          "SELECT quote_ident(option_name) || ' ' || "
                          "quote_literal(option_value) "
                          "FROM pg_options_to_table(f.srvoptions) "
                          "ORDER BY option_name"
                          "), E',\n    ') AS srvoptions "
                          "FROM pg_foreign_server f "
                          "LEFT JOIN pg_init_privs pip "
                          "ON (f.oid = pip.objoid "
                          "AND pip.classoid = 'pg_foreign_server'::regclass "
                          "AND pip.objsubid = 0) ",
                          username_subquery,
                          acl_subquery->data,
                          racl_subquery->data,
                          initacl_subquery->data,
                          initracl_subquery->data);

        destroyPQExpBuffer(acl_subquery);
        destroyPQExpBuffer(racl_subquery);
        destroyPQExpBuffer(initacl_subquery);
        destroyPQExpBuffer(initracl_subquery);
    }
    else
    {
        appendPQExpBuffer(query, "SELECT tableoid, oid, srvname, "
                          "(%s srvowner) AS rolname, "
                          "srvfdw, srvtype, srvversion, srvacl, "
                          "NULL AS rsrvacl, "
                          "NULL AS initsrvacl, NULL AS initrsrvacl, "
                          "array_to_string(ARRAY("
                          "SELECT quote_ident(option_name) || ' ' || "
                          "quote_literal(option_value) "
                          "FROM pg_options_to_table(srvoptions) "
                          "ORDER BY option_name"
                          "), E',\n    ') AS srvoptions "
                          "FROM pg_foreign_server",
                          username_subquery);
    }

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

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

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

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

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

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

        /* Do not try to dump ACL if no ACL exists. */
        if (PQgetisnull(res, i, i_srvacl) && PQgetisnull(res, i, i_rsrvacl) &&
            PQgetisnull(res, i, i_initsrvacl) &&
            PQgetisnull(res, i, i_initrsrvacl))
            srvinfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;
    }

    PQclear(res);

    destroyPQExpBuffer(query);

    return srvinfo;
}

FuncInfo* getFuncs	(	Archive *	fout,
		int *	numFuncs
	)

Definition at line 5367 of file pg_dump.c.

References appendPQExpBuffer(), appendPQExpBufferChar(), appendPQExpBufferStr(), _funcInfo::argtypes, AssignDumpId(), atooid, _dumpOptions::binary_upgrade, buildACLQueries(), _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_FUNC, _funcInfo::dobj, Archive::dopt, _dumpableObject::dump, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), findNamespace(), g_last_builtin_oid, i, _funcInfo::initproacl, _funcInfo::initrproacl, _funcInfo::lang, _dumpableObject::name, _funcInfo::nargs, _dumpableObject::objType, CatalogId::oid, parseOidArray(), pg_malloc(), pg_malloc0(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetisnull(), PQgetvalue(), PQntuples(), _funcInfo::proacl, _funcInfo::prorettype, Archive::remoteVersion, _funcInfo::rolname, _funcInfo::rproacl, selectDumpableObject(), selectSourceSchema(), CatalogId::tableoid, username_subquery, and write_msg().

Referenced by getSchemaData().

{
    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_rolname;
    int         i_prolang;
    int         i_pronargs;
    int         i_proargtypes;
    int         i_prorettype;
    int         i_proacl;
    int         i_rproacl;
    int         i_initproacl;
    int         i_initrproacl;

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

    /*
     * 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 (so we only need it in 9.2 and up).  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.
     */
    if (fout->remoteVersion >= 90600)
    {
        PQExpBuffer acl_subquery = createPQExpBuffer();
        PQExpBuffer racl_subquery = createPQExpBuffer();
        PQExpBuffer initacl_subquery = createPQExpBuffer();
        PQExpBuffer initracl_subquery = createPQExpBuffer();

        buildACLQueries(acl_subquery, racl_subquery, initacl_subquery,
                        initracl_subquery, "p.proacl", "p.proowner", "'f'",
                        dopt->binary_upgrade);

        appendPQExpBuffer(query,
                          "SELECT p.tableoid, p.oid, p.proname, p.prolang, "
                          "p.pronargs, p.proargtypes, p.prorettype, "
                          "%s AS proacl, "
                          "%s AS rproacl, "
                          "%s AS initproacl, "
                          "%s AS initrproacl, "
                          "p.pronamespace, "
                          "(%s p.proowner) AS rolname "
                          "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 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 "
                          "\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))",
                          acl_subquery->data,
                          racl_subquery->data,
                          initacl_subquery->data,
                          initracl_subquery->data,
                          username_subquery,
                          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, ')');

        destroyPQExpBuffer(acl_subquery);
        destroyPQExpBuffer(racl_subquery);
        destroyPQExpBuffer(initacl_subquery);
        destroyPQExpBuffer(initracl_subquery);
    }
    else
    {
        appendPQExpBuffer(query,
                          "SELECT tableoid, oid, proname, prolang, "
                          "pronargs, proargtypes, prorettype, proacl, "
                          "NULL as rproacl, "
                          "NULL as initproacl, NULL AS initrproacl, "
                          "pronamespace, "
                          "(%s proowner) AS rolname "
                          "FROM pg_proc p "
                          "WHERE NOT proisagg",
                          username_subquery);
        if (fout->remoteVersion >= 90200)
            appendPQExpBufferStr(query,
                                 "\n  AND NOT EXISTS (SELECT 1 FROM pg_depend "
                                 "WHERE classid = 'pg_proc'::regclass AND "
                                 "objid = p.oid AND deptype = 'i')");
        appendPQExpBuffer(query,
                          "\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 && fout->remoteVersion >= 90100)
            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);

    *numFuncs = ntups;

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

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_proname = PQfnumber(res, "proname");
    i_pronamespace = PQfnumber(res, "pronamespace");
    i_rolname = PQfnumber(res, "rolname");
    i_prolang = PQfnumber(res, "prolang");
    i_pronargs = PQfnumber(res, "pronargs");
    i_proargtypes = PQfnumber(res, "proargtypes");
    i_prorettype = PQfnumber(res, "prorettype");
    i_proacl = PQfnumber(res, "proacl");
    i_rproacl = PQfnumber(res, "rproacl");
    i_initproacl = PQfnumber(res, "initproacl");
    i_initrproacl = PQfnumber(res, "initrproacl");

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

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

        /* Do not try to dump ACL if no ACL exists. */
        if (PQgetisnull(res, i, i_proacl) && PQgetisnull(res, i, i_rproacl) &&
            PQgetisnull(res, i, i_initproacl) &&
            PQgetisnull(res, i, i_initrproacl))
            finfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;

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

    PQclear(res);

    destroyPQExpBuffer(query);

    return finfo;
}

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

Definition at line 6493 of file pg_dump.c.

References appendPQExpBuffer(), AssignDumpId(), atooid, _dumpableObject::catId, _constraintInfo::condef, _constraintInfo::condeferrable, _constraintInfo::condeferred, _constraintInfo::condomain, _constraintInfo::confrelid, _constraintInfo::conindex, _constraintInfo::conislocal, _constraintInfo::contable, _constraintInfo::contype, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_CONSTRAINT, DO_INDEX, _tableInfo::dobj, _indxInfo::dobj, _constraintInfo::dobj, _dumpableObject::dump, DUMP_COMPONENT_DEFINITION, _dumpableObject::dumpId, ExecuteSqlQuery(), g_verbose, _tableInfo::hasindex, i, _indxInfo::indexconstraint, _indxInfo::indexdef, _indxInfo::indextable, _indxInfo::indisclustered, _indxInfo::indisreplident, _indxInfo::indkeys, _indxInfo::indnkeys, _indxInfo::indreloptions, InvalidOid, _dumpableObject::name, numTables, _dumpableObject::objType, CatalogId::oid, parseOidArray(), pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), _tableInfo::relkind, RELKIND_MATVIEW, RELKIND_RELATION, _indxInfo::relpages, Archive::remoteVersion, resetPQExpBuffer(), selectSourceSchema(), _constraintInfo::separate, CatalogId::tableoid, _indxInfo::tablespace, and write_msg().

Referenced by getSchemaData().

{
    int         i,
                j;
    PQExpBuffer query = createPQExpBuffer();
    PGresult   *res;
    IndxInfo   *indxinfo;
    ConstraintInfo *constrinfo;
    int         i_tableoid,
                i_oid,
                i_indexname,
                i_indexdef,
                i_indnkeys,
                i_indkey,
                i_indisclustered,
                i_indisreplident,
                i_contype,
                i_conname,
                i_condeferrable,
                i_condeferred,
                i_contableoid,
                i_conoid,
                i_condef,
                i_tablespace,
                i_indreloptions,
                i_relpages;
    int         ntups;

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

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

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

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

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

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

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

        ntups = PQntuples(res);

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

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

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

            indxinfo[j].dobj.objType = DO_INDEX;
            indxinfo[j].dobj.catId.tableoid = atooid(PQgetvalue(res, j, i_tableoid));
            indxinfo[j].dobj.catId.oid = atooid(PQgetvalue(res, j, i_oid));
            AssignDumpId(&indxinfo[j].dobj);
            indxinfo[j].dobj.name = pg_strdup(PQgetvalue(res, j, i_indexname));
            indxinfo[j].dobj.namespace = tbinfo->dobj.namespace;
            indxinfo[j].indextable = tbinfo;
            indxinfo[j].indexdef = pg_strdup(PQgetvalue(res, j, i_indexdef));
            indxinfo[j].indnkeys = atoi(PQgetvalue(res, j, i_indnkeys));
            indxinfo[j].tablespace = pg_strdup(PQgetvalue(res, j, i_tablespace));
            indxinfo[j].indreloptions = pg_strdup(PQgetvalue(res, j, i_indreloptions));
            indxinfo[j].indkeys = (Oid *) pg_malloc(indxinfo[j].indnkeys * sizeof(Oid));
            parseOidArray(PQgetvalue(res, j, i_indkey),
                          indxinfo[j].indkeys, indxinfo[j].indnkeys);
            indxinfo[j].indisclustered = (PQgetvalue(res, j, i_indisclustered)[0] == 't');
            indxinfo[j].indisreplident = (PQgetvalue(res, j, i_indisreplident)[0] == 't');
            indxinfo[j].relpages = atoi(PQgetvalue(res, j, i_relpages));
            contype = *(PQgetvalue(res, j, i_contype));

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

                indxinfo[j].indexconstraint = constrinfo[j].dobj.dumpId;
            }
            else
            {
                /* Plain secondary index */
                indxinfo[j].indexconstraint = 0;
            }
        }

        PQclear(res);
    }

    destroyPQExpBuffer(query);
}

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

Definition at line 6439 of file pg_dump.c.

References appendPQExpBufferStr(), atooid, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), ExecuteSqlQuery(), i, _inhInfo::inhparent, _inhInfo::inhrelid, pg_malloc(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), and selectSourceSchema().

Referenced by getSchemaData().

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    InhInfo    *inhinfo;

    int         i_inhrelid;
    int         i_inhparent;

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

    /*
     * Find all the inheritance information, excluding implicit inheritance
     * via partitioning.  We handle that case using getPartitions(), because
     * we want more information about partitions than just the parent-child
     * relationship.
     */
    appendPQExpBufferStr(query, "SELECT inhrelid, inhparent FROM pg_inherits");

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

    ntups = PQntuples(res);

    *numInherits = ntups;

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

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

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

    PQclear(res);

    destroyPQExpBuffer(query);

    return inhinfo;
}

DumpId getMaxDumpId

(

void

)

Definition at line 529 of file common.c.

References lastDumpId.

Referenced by findDependencyLoops(), and TopoSort().

{
    return lastDumpId;
}

NamespaceInfo* getNamespaces	(	Archive *	fout,
		int *	numNamespaces
	)

Definition at line 4176 of file pg_dump.c.

References appendPQExpBuffer(), AssignDumpId(), atooid, _dumpOptions::binary_upgrade, buildACLQueries(), _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_NAMESPACE, _namespaceInfo::dobj, Archive::dopt, _dumpableObject::dump, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), i, _namespaceInfo::initnspacl, _namespaceInfo::initrnspacl, _dumpableObject::name, _namespaceInfo::nspacl, _dumpableObject::objType, CatalogId::oid, _dumpOptions::outputClean, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetisnull(), PQgetvalue(), PQntuples(), Archive::remoteVersion, _namespaceInfo::rnspacl, _namespaceInfo::rolname, selectDumpableNamespace(), selectSourceSchema(), CatalogId::tableoid, username_subquery, and write_msg().

Referenced by getSchemaData().

{
    DumpOptions *dopt = fout->dopt;
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    NamespaceInfo *nsinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_nspname;
    int         i_rolname;
    int         i_nspacl;
    int         i_rnspacl;
    int         i_initnspacl;
    int         i_initrnspacl;

    query = createPQExpBuffer();

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

    /*
     * we fetch all namespaces including system ones, so that every object we
     * read in can be linked to a containing namespace.
     */
    if (fout->remoteVersion >= 90600)
    {
        PQExpBuffer acl_subquery = createPQExpBuffer();
        PQExpBuffer racl_subquery = createPQExpBuffer();
        PQExpBuffer init_acl_subquery = createPQExpBuffer();
        PQExpBuffer init_racl_subquery = createPQExpBuffer();

        buildACLQueries(acl_subquery, racl_subquery, init_acl_subquery,
                        init_racl_subquery, "n.nspacl", "n.nspowner", "'n'",
                        dopt->binary_upgrade);

        appendPQExpBuffer(query, "SELECT n.tableoid, n.oid, n.nspname, "
                          "(%s nspowner) AS rolname, "
                          "%s as nspacl, "
                          "%s as rnspacl, "
                          "%s as initnspacl, "
                          "%s as initrnspacl "
                          "FROM pg_namespace n "
                          "LEFT JOIN pg_init_privs pip "
                          "ON (n.oid = pip.objoid "
                          "AND pip.classoid = 'pg_namespace'::regclass "
                          "AND pip.objsubid = 0",
                          username_subquery,
                          acl_subquery->data,
                          racl_subquery->data,
                          init_acl_subquery->data,
                          init_racl_subquery->data);

        /*
         * When we are doing a 'clean' run, we will be dropping and recreating
         * the 'public' schema (the only object which has that kind of
         * treatment in the backend and which has an entry in pg_init_privs)
         * and therefore we should not consider any initial privileges in
         * pg_init_privs in that case.
         *
         * See pg_backup_archiver.c:_printTocEntry() for the details on why
         * the public schema is special in this regard.
         *
         * Note that if the public schema is dropped and re-created, this is
         * essentially a no-op because the new public schema won't have an
         * entry in pg_init_privs anyway, as the entry will be removed when
         * the public schema is dropped.
         *
         * Further, we have to handle the case where the public schema does
         * not exist at all.
         */
        if (dopt->outputClean)
            appendPQExpBuffer(query, " AND pip.objoid <> "
                              "coalesce((select oid from pg_namespace "
                              "where nspname = 'public'),0)");

        appendPQExpBuffer(query, ") ");

        destroyPQExpBuffer(acl_subquery);
        destroyPQExpBuffer(racl_subquery);
        destroyPQExpBuffer(init_acl_subquery);
        destroyPQExpBuffer(init_racl_subquery);
    }
    else
        appendPQExpBuffer(query, "SELECT tableoid, oid, nspname, "
                          "(%s nspowner) AS rolname, "
                          "nspacl, NULL as rnspacl, "
                          "NULL AS initnspacl, NULL as initrnspacl "
                          "FROM pg_namespace",
                          username_subquery);

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

    ntups = PQntuples(res);

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

    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_nspname = PQfnumber(res, "nspname");
    i_rolname = PQfnumber(res, "rolname");
    i_nspacl = PQfnumber(res, "nspacl");
    i_rnspacl = PQfnumber(res, "rnspacl");
    i_initnspacl = PQfnumber(res, "initnspacl");
    i_initrnspacl = PQfnumber(res, "initrnspacl");

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

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

        /*
         * Do not try to dump ACL if the ACL is empty or the default.
         *
         * This is useful because, for some schemas/objects, the only
         * component we are going to try and dump is the ACL and if we can
         * remove that then 'dump' goes to zero/false and we don't consider
         * this object for dumping at all later on.
         */
        if (PQgetisnull(res, i, i_nspacl) && PQgetisnull(res, i, i_rnspacl) &&
            PQgetisnull(res, i, i_initnspacl) &&
            PQgetisnull(res, i, i_initrnspacl))
            nsinfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;

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

    PQclear(res);
    destroyPQExpBuffer(query);

    *numNamespaces = ntups;

    return nsinfo;
}

OpclassInfo* getOpclasses	(	Archive *	fout,
		int *	numOpclasses
	)

Definition at line 5010 of file pg_dump.c.

References appendPQExpBuffer(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_OPCLASS, _opclassInfo::dobj, _dumpableObject::dump, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), findNamespace(), i, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), _opclassInfo::rolname, selectDumpableObject(), selectSourceSchema(), CatalogId::tableoid, username_subquery, and write_msg().

Referenced by getSchemaData().

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    OpclassInfo *opcinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_opcname;
    int         i_opcnamespace;
    int         i_rolname;

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

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

    appendPQExpBuffer(query, "SELECT tableoid, oid, opcname, "
                      "opcnamespace, "
                      "(%s opcowner) AS rolname "
                      "FROM pg_opclass",
                      username_subquery);

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

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

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

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

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

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

        /* Op Classes do not currently have ACLs. */
        opcinfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;

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

    PQclear(res);

    destroyPQExpBuffer(query);

    return opcinfo;
}

OprInfo* getOperators	(	Archive *	fout,
		int *	numOperators
	)

Definition at line 4688 of file pg_dump.c.

References appendPQExpBuffer(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_OPERATOR, _oprInfo::dobj, _dumpableObject::dump, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), findNamespace(), i, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, _oprInfo::oprcode, _oprInfo::oprkind, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), _oprInfo::rolname, selectDumpableObject(), selectSourceSchema(), CatalogId::tableoid, username_subquery, and write_msg().

Referenced by getSchemaData().

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    OprInfo    *oprinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_oprname;
    int         i_oprnamespace;
    int         i_rolname;
    int         i_oprkind;
    int         i_oprcode;

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

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

    appendPQExpBuffer(query, "SELECT tableoid, oid, oprname, "
                      "oprnamespace, "
                      "(%s oprowner) AS rolname, "
                      "oprkind, "
                      "oprcode::oid AS oprcode "
                      "FROM pg_operator",
                      username_subquery);

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

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

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

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

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

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

        /* Operators do not currently have ACLs. */
        oprinfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;

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

    PQclear(res);

    destroyPQExpBuffer(query);

    return oprinfo;
}

OpfamilyInfo* getOpfamilies	(	Archive *	fout,
		int *	numOpfamilies
	)

Definition at line 5088 of file pg_dump.c.

References appendPQExpBuffer(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_OPFAMILY, _opfamilyInfo::dobj, _dumpableObject::dump, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), findNamespace(), i, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), Archive::remoteVersion, _opfamilyInfo::rolname, selectDumpableObject(), selectSourceSchema(), CatalogId::tableoid, username_subquery, and write_msg().

Referenced by getSchemaData().

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    OpfamilyInfo *opfinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_opfname;
    int         i_opfnamespace;
    int         i_rolname;

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

    query = createPQExpBuffer();

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

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

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

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

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

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

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

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

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