#include "pg_backup.h"

Include dependency graph for pg_dump.h:

This graph shows which files directly or indirectly include 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	_indexAttachInfo

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	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 _indexAttachInfo	IndexAttachInfo

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

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)

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)

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
char	g_comment_start [10]

char	g_comment_end [10]

char	g_opaque_type [10]

Macro Definition Documentation

◆ DUMP_COMPONENT_ACL

#define DUMP_COMPONENT_ACL (1 << 4)

◆ DUMP_COMPONENT_ALL

#define DUMP_COMPONENT_ALL (0xFFFF)

Definition at line 96 of file pg_dump.h.

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

◆ DUMP_COMPONENT_COMMENT

#define DUMP_COMPONENT_COMMENT (1 << 2)

◆ DUMP_COMPONENT_DATA

#define DUMP_COMPONENT_DATA (1 << 1)

Definition at line 90 of file pg_dump.h.

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

◆ DUMP_COMPONENT_DEFINITION

#define DUMP_COMPONENT_DEFINITION (1 << 0)

Definition at line 89 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(), dumpIndexAttach(), dumpNamespace(), dumpOpclass(), dumpOpfamily(), dumpOpr(), dumpProcLang(), dumpPublication(), dumpPublicationTable(), dumpRangeType(), dumpRule(), dumpSequence(), dumpShellType(), dumpStatisticsExt(), dumpSubscription(), dumpTableSchema(), dumpTransform(), dumpTrigger(), dumpTSConfig(), dumpTSDictionary(), dumpTSParser(), dumpTSTemplate(), dumpUndefinedType(), getConstraints(), getIndexes(), getPublicationTables(), getTriggers(), getTypes(), guessConstraintInheritance(), processExtensionTables(), and repairTypeFuncLoop().

◆ DUMP_COMPONENT_NONE

#define DUMP_COMPONENT_NONE (0)

Definition at line 88 of file pg_dump.h.

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

◆ DUMP_COMPONENT_POLICY

#define DUMP_COMPONENT_POLICY (1 << 5)

Definition at line 94 of file pg_dump.h.

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

◆ DUMP_COMPONENT_SECLABEL

#define DUMP_COMPONENT_SECLABEL (1 << 3)

Definition at line 92 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().

◆ DUMP_COMPONENT_USERMAP

#define DUMP_COMPONENT_USERMAP (1 << 6)

Definition at line 95 of file pg_dump.h.

Referenced by dumpForeignServer().

◆ DUMP_COMPONENTS_REQUIRING_LOCK

#define DUMP_COMPONENTS_REQUIRING_LOCK

Value:

(\
        DUMP_COMPONENT_DEFINITION |\
        DUMP_COMPONENT_DATA |\
        DUMP_COMPONENT_POLICY)

Definition at line 120 of file pg_dump.h.

Referenced by getTables().

◆ oidcmp

#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().

Typedef Documentation

◆ AccessMethodInfo

typedef struct _accessMethodInfo AccessMethodInfo

◆ AggInfo

typedef struct _aggInfo AggInfo

◆ AttrDefInfo

typedef struct _attrDefInfo AttrDefInfo

◆ BlobInfo

typedef struct _blobInfo BlobInfo

◆ CastInfo

typedef struct _castInfo CastInfo

◆ CollInfo

typedef struct _collInfo CollInfo

◆ ConstraintInfo

typedef struct _constraintInfo ConstraintInfo

◆ ConvInfo

typedef struct _convInfo ConvInfo

◆ DefaultACLInfo

typedef struct _defaultACLInfo DefaultACLInfo

◆ DumpableObject

typedef struct _dumpableObject DumpableObject

◆ DumpComponents

typedef uint32 DumpComponents

Definition at line 87 of file pg_dump.h.

◆ EventTriggerInfo

typedef struct _evttriggerInfo EventTriggerInfo

◆ ExtensionInfo

typedef struct _extensionInfo ExtensionInfo

◆ ExtensionMemberId

typedef struct _extensionMemberId ExtensionMemberId

◆ FdwInfo

typedef struct _fdwInfo FdwInfo

◆ ForeignServerInfo

typedef struct _foreignServerInfo ForeignServerInfo

◆ FuncInfo

typedef struct _funcInfo FuncInfo

◆ IndexAttachInfo

typedef struct _indexAttachInfo IndexAttachInfo

◆ IndxInfo

typedef struct _indxInfo IndxInfo

◆ InhInfo

typedef struct _inhInfo InhInfo

◆ NamespaceInfo

typedef struct _namespaceInfo NamespaceInfo

◆ OpclassInfo

typedef struct _opclassInfo OpclassInfo

◆ OpfamilyInfo

typedef struct _opfamilyInfo OpfamilyInfo

◆ OprInfo

typedef struct _oprInfo OprInfo

◆ PolicyInfo

typedef struct _policyInfo PolicyInfo

◆ ProcLangInfo

typedef struct _procLangInfo ProcLangInfo

◆ PublicationInfo

typedef struct _PublicationInfo PublicationInfo

◆ PublicationRelInfo

typedef struct _PublicationRelInfo PublicationRelInfo

◆ RuleInfo

typedef struct _ruleInfo RuleInfo

◆ ShellTypeInfo

typedef struct _shellTypeInfo ShellTypeInfo

◆ StatsExtInfo

typedef struct _statsExtInfo StatsExtInfo

◆ SubscriptionInfo

typedef struct _SubscriptionInfo SubscriptionInfo

◆ TableDataInfo

typedef struct _tableDataInfo TableDataInfo

◆ TableInfo

typedef struct _tableInfo TableInfo

◆ TransformInfo

typedef struct _transformInfo TransformInfo

◆ TriggerInfo

typedef struct _triggerInfo TriggerInfo

◆ TSConfigInfo

typedef struct _cfgInfo TSConfigInfo

◆ TSDictInfo

typedef struct _dictInfo TSDictInfo

◆ TSParserInfo

typedef struct _prsInfo TSParserInfo

◆ TSTemplateInfo

typedef struct _tmplInfo TSTemplateInfo

◆ TypeInfo

typedef struct _typeInfo TypeInfo

Enumeration Type Documentation

◆ DumpableObjectType

enum DumpableObjectType

Enumerator
DO_NAMESPACE
DO_EXTENSION
DO_TYPE
DO_SHELL_TYPE
DO_FUNC
DO_AGG
DO_OPERATOR
DO_ACCESS_METHOD
DO_OPCLASS
DO_OPFAMILY
DO_COLLATION
DO_CONVERSION
DO_TABLE
DO_ATTRDEF
DO_INDEX
DO_INDEX_ATTACH
DO_STATSEXT
DO_RULE
DO_TRIGGER
DO_CONSTRAINT
DO_FK_CONSTRAINT
DO_PROCLANG
DO_CAST
DO_TABLE_DATA
DO_SEQUENCE_SET
DO_DUMMY_TYPE
DO_TSPARSER
DO_TSDICT
DO_TSTEMPLATE
DO_TSCONFIG
DO_FDW
DO_FOREIGN_SERVER
DO_DEFAULT_ACL
DO_TRANSFORM
DO_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 37 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_INDEX_ATTACH,
     DO_STATSEXT,
     DO_RULE,
     DO_TRIGGER,
     DO_CONSTRAINT,
     DO_FK_CONSTRAINT,           /* see note for ConstraintInfo */
     DO_PROCLANG,
     DO_CAST,
     DO_TABLE_DATA,
     DO_SEQUENCE_SET,
     DO_DUMMY_TYPE,
     DO_TSPARSER,
     DO_TSDICT,
     DO_TSTEMPLATE,
     DO_TSCONFIG,
     DO_FDW,
     DO_FOREIGN_SERVER,
     DO_DEFAULT_ACL,
     DO_TRANSFORM,
     DO_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

◆ addObjectDependency()

void addObjectDependency	(	DumpableObject *	dobj,
		DumpId	refId
	)

Definition at line 781 of file common.c.

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

Referenced by addBoundaryDependencies(), buildMatViewRefreshDependencies(), checkExtensionMembership(), flagInhAttrs(), flagInhIndexes(), getConstraints(), 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;
 }

◆ AssignDumpId()

void AssignDumpId ( DumpableObject * dobj )

Definition at line 545 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(), flagInhIndexes(), 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;
 }

◆ createDumpId()

DumpId createDumpId ( void )

Definition at line 589 of file common.c.

References lastDumpId.

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

 {
     return ++lastDumpId;
 }

◆ findCollationByOid()

CollInfo* findCollationByOid ( Oid oid )

Definition at line 872 of file common.c.

References findObjectByOid(), and numCollations.

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

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

◆ findExtensionByOid()

ExtensionInfo* findExtensionByOid ( Oid oid )

Definition at line 894 of file common.c.

References findObjectByOid(), and numExtensions.

Referenced by getExtensionMembership().

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

◆ findFuncByOid()

FuncInfo* findFuncByOid ( Oid oid )

Definition at line 850 of file common.c.

References findObjectByOid(), and numFuncs.

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

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

◆ findNamespaceByOid()

NamespaceInfo* findNamespaceByOid ( Oid oid )

Definition at line 883 of file common.c.

References findObjectByOid(), and numNamespaces.

Referenced by findNamespace().

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

◆ findObjectByCatalogId()

DumpableObject* findObjectByCatalogId ( CatalogId catalogId )

Definition at line 627 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;
 }

◆ findObjectByDumpId()

DumpableObject* findObjectByDumpId ( DumpId dumpId )

Definition at line 609 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];
 }

◆ findOprByOid()

OprInfo* findOprByOid ( Oid oid )

Definition at line 861 of file common.c.

References findObjectByOid(), and numOperators.

Referenced by getFormattedOperatorName().

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

◆ findOwningExtension()

ExtensionInfo* findOwningExtension ( CatalogId catalogId )

Definition at line 933 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;
 }

◆ findTableByOid()

TableInfo* findTableByOid ( Oid oid )

Definition at line 828 of file common.c.

References findObjectByOid(), and numTables.

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

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

◆ findTypeByOid()

TypeInfo* findTypeByOid ( Oid oid )

Definition at line 839 of file common.c.

References findObjectByOid(), and numTypes.

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

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

◆ getAccessMethods()

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

Definition at line 5233 of file pg_dump.c.

References _accessMethodInfo::amhandler, _accessMethodInfo::amtype, appendPQExpBufferStr(), 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(), 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();
 
     /* Select all access methods from pg_am table */
     appendPQExpBufferStr(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;
 }

◆ getAggregates()

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

Definition at line 5466 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_log_warning, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetisnull(), PQgetvalue(), PQntuples(), _funcInfo::proacl, _funcInfo::prorettype, Archive::remoteVersion, _funcInfo::rolname, _funcInfo::rproacl, selectDumpableObject(), CatalogId::tableoid, and username_subquery.

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;
 
     /*
      * 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();
         const char *agg_check;
 
         buildACLQueries(acl_subquery, racl_subquery, initacl_subquery,
                         initracl_subquery, "p.proacl", "p.proowner", "'f'",
                         dopt->binary_upgrade);
 
         agg_check = (fout->remoteVersion >= 110000 ? "p.prokind = 'a'"
                      : "p.proisagg");
 
         appendPQExpBuffer(query, "SELECT p.tableoid, p.oid, "
                           "p.proname AS aggname, "
                           "p.pronamespace AS aggnamespace, "
                           "p.pronargs, p.proargtypes, "
                           "(%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 %s 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,
                           agg_check);
         if (dopt->binary_upgrade)
             appendPQExpBufferStr(query,
                                  " OR EXISTS(SELECT 1 FROM pg_depend WHERE "
                                  "classid = 'pg_proc'::regclass AND "
                                  "objid = p.oid AND "
                                  "refclassid = 'pg_extension'::regclass AND "
                                  "deptype = 'e')");
         appendPQExpBufferChar(query, ')');
 
         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)
             pg_log_warning("owner of aggregate function \"%s\" appears to be invalid",
                            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;
 }

◆ getCasts()

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

Definition at line 8045 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(), 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;
 
     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;
 }

◆ getCollations()

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

Definition at line 5080 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(), 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.
      */
 
     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;
 }

◆ getConstraints()

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

Definition at line 7246 of file pg_dump.c.

Referenced by getSchemaData().

 {
     int         i,
                 j;
     ConstraintInfo *constrinfo;
     PQExpBuffer query;
     PGresult   *res;
     int         i_contableoid,
                 i_conoid,
                 i_conname,
                 i_confrelid,
                 i_conindid,
                 i_condef;
     int         ntups;
 
     query = createPQExpBuffer();
 
     for (i = 0; i < numTables; i++)
     {
         TableInfo  *tbinfo = &tblinfo[i];
 
         /*
          * For partitioned tables, foreign keys have no triggers so they must
          * be included anyway in case some foreign keys are defined.
          */
         if ((!tbinfo->hastriggers &&
              tbinfo->relkind != RELKIND_PARTITIONED_TABLE) ||
             !(tbinfo->dobj.dump & DUMP_COMPONENT_DEFINITION))
             continue;
 
         pg_log_info("reading foreign key constraints for table \"%s.%s\"",
                     tbinfo->dobj.namespace->dobj.name,
                     tbinfo->dobj.name);
 
         resetPQExpBuffer(query);
         if (fout->remoteVersion >= 110000)
             appendPQExpBuffer(query,
                               "SELECT tableoid, oid, conname, confrelid, conindid, "
                               "pg_catalog.pg_get_constraintdef(oid) AS condef "
                               "FROM pg_catalog.pg_constraint "
                               "WHERE conrelid = '%u'::pg_catalog.oid "
                               "AND conparentid = 0 "
                               "AND contype = 'f'",
                               tbinfo->dobj.catId.oid);
         else
             appendPQExpBuffer(query,
                               "SELECT tableoid, oid, conname, confrelid, 0 as conindid, "
                               "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_conindid = PQfnumber(res, "conindid");
         i_condef = PQfnumber(res, "condef");
 
         constrinfo = (ConstraintInfo *) pg_malloc(ntups * sizeof(ConstraintInfo));
 
         for (j = 0; j < ntups; j++)
         {
             TableInfo *reftable;
 
             constrinfo[j].dobj.objType = DO_FK_CONSTRAINT;
             constrinfo[j].dobj.catId.tableoid = atooid(PQgetvalue(res, j, i_contableoid));
             constrinfo[j].dobj.catId.oid = atooid(PQgetvalue(res, j, i_conoid));
             AssignDumpId(&constrinfo[j].dobj);
             constrinfo[j].dobj.name = pg_strdup(PQgetvalue(res, j, i_conname));
             constrinfo[j].dobj.namespace = tbinfo->dobj.namespace;
             constrinfo[j].contable = tbinfo;
             constrinfo[j].condomain = NULL;
             constrinfo[j].contype = 'f';
             constrinfo[j].condef = pg_strdup(PQgetvalue(res, j, i_condef));
             constrinfo[j].confrelid = atooid(PQgetvalue(res, j, i_confrelid));
             constrinfo[j].conindex = 0;
             constrinfo[j].condeferrable = false;
             constrinfo[j].condeferred = false;
             constrinfo[j].conislocal = true;
             constrinfo[j].separate = true;
 
             /*
              * Restoring an FK that points to a partitioned table requires
              * that all partition indexes have been attached beforehand.
              * Ensure that happens by making the constraint depend on each
              * index partition attach object.
              */
             reftable = findTableByOid(constrinfo[j].confrelid);
             if (reftable && reftable->relkind == RELKIND_PARTITIONED_TABLE)
             {
                 IndxInfo   *refidx;
                 Oid         indexOid = atooid(PQgetvalue(res, j, i_conindid));
 
                 if (indexOid != InvalidOid)
                 {
                     for (int k = 0; k < reftable->numIndexes; k++)
                     {
                         SimplePtrListCell *cell;
 
                         /* not our index? */
                         if (reftable->indexes[k].dobj.catId.oid != indexOid)
                             continue;
 
                         refidx = &reftable->indexes[k];
                         for (cell = refidx->partattaches.head; cell;
                              cell = cell->next)
                             addObjectDependency(&constrinfo[j].dobj,
                                                 ((DumpableObject *)
                                                  cell->ptr)->dumpId);
                         break;
                     }
                 }
             }
         }
 
         PQclear(res);
     }
 
     destroyPQExpBuffer(query);
 }

◆ getConversions()

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

Definition at line 5160 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(), 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.
      */
 
     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;
 }

◆ getDefaultACLs()

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

Definition at line 9357 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(), 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();
 
     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;
 }

◆ getDumpableObjects()

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

Definition at line 759 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;
 }

◆ getEventTriggers()

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

Definition at line 7776 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(), 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();
 
     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;
 }

◆ getExtendedStatistics()

void getExtendedStatistics ( Archive * fout )

Definition at line 7168 of file pg_dump.c.

References appendPQExpBuffer(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_STATSEXT, _statsExtInfo::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, _statsExtInfo::rolname, selectDumpableObject(), _statsExtInfo::stattarget, CatalogId::tableoid, and username_subquery.

Referenced by getSchemaData().

 {
     PQExpBuffer query;
     PGresult   *res;
     StatsExtInfo *statsextinfo;
     int         ntups;
     int         i_tableoid;
     int         i_oid;
     int         i_stxname;
     int         i_stxnamespace;
     int         i_rolname;
     int         i_stattarget;
     int         i;
 
     /* Extended statistics were new in v10 */
     if (fout->remoteVersion < 100000)
         return;
 
     query = createPQExpBuffer();
 
     if (fout->remoteVersion < 130000)
         appendPQExpBuffer(query, "SELECT tableoid, oid, stxname, "
                           "stxnamespace, (%s stxowner) AS rolname, (-1) AS stxstattarget "
                           "FROM pg_catalog.pg_statistic_ext",
                           username_subquery);
     else
         appendPQExpBuffer(query, "SELECT tableoid, oid, stxname, "
                           "stxnamespace, (%s stxowner) AS rolname, stxstattarget "
                           "FROM pg_catalog.pg_statistic_ext",
                           username_subquery);
 
     res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
     ntups = PQntuples(res);
 
     i_tableoid = PQfnumber(res, "tableoid");
     i_oid = PQfnumber(res, "oid");
     i_stxname = PQfnumber(res, "stxname");
     i_stxnamespace = PQfnumber(res, "stxnamespace");
     i_rolname = PQfnumber(res, "rolname");
     i_stattarget = PQfnumber(res, "stxstattarget");
 
     statsextinfo = (StatsExtInfo *) pg_malloc(ntups * sizeof(StatsExtInfo));
 
     for (i = 0; i < ntups; i++)
     {
         statsextinfo[i].dobj.objType = DO_STATSEXT;
         statsextinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
         statsextinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
         AssignDumpId(&statsextinfo[i].dobj);
         statsextinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_stxname));
         statsextinfo[i].dobj.namespace =
             findNamespace(fout,
                           atooid(PQgetvalue(res, i, i_stxnamespace)));
         statsextinfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
         statsextinfo[i].stattarget = atoi(PQgetvalue(res, i, i_stattarget));
 
         /* Decide whether we want to dump it */
         selectDumpableObject(&(statsextinfo[i].dobj), fout);
 
         /* Stats objects do not currently have ACLs. */
         statsextinfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;
     }
 
     PQclear(res);
     destroyPQExpBuffer(query);
 }

◆ getExtensionMembership()

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

Definition at line 17688 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_log_warning, pg_malloc(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), 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;
 
     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 */
             pg_log_warning("could not find referenced extension %u", extId);
             continue;
         }
 
         extmembers[nextmembers].catId = objId;
         extmembers[nextmembers].ext = ext;
         nextmembers++;
     }
 
     PQclear(res);
 
     /* Remember the data for use later */
     setExtensionMembership(extmembers, nextmembers);
 
     destroyPQExpBuffer(query);
 }

◆ getExtensions()

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

Definition at line 4663 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(), 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();
 
     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;
 }

◆ getForeignDataWrappers()

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

Definition at line 9041 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(), 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();
 
     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;
 }

◆ getForeignServers()

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

Definition at line 9207 of file pg_dump.c.

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

◆ getFuncs()

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

Definition at line 5660 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_log_warning, pg_malloc(), pg_malloc0(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetisnull(), PQgetvalue(), PQntuples(), _funcInfo::proacl, _funcInfo::prorettype, Archive::remoteVersion, rolname, _funcInfo::rolname, _funcInfo::rproacl, selectDumpableObject(), CatalogId::tableoid, and username_subquery.

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;
 
     /*
      * 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();
         const char *not_agg_check;
 
         buildACLQueries(acl_subquery, racl_subquery, initacl_subquery,
                         initracl_subquery, "p.proacl", "p.proowner", "'f'",
                         dopt->binary_upgrade);
 
         not_agg_check = (fout->remoteVersion >= 110000 ? "p.prokind <> 'a'"
                          : "NOT p.proisagg");
 
         appendPQExpBuffer(query,
                           "SELECT p.tableoid, p.oid, p.proname, p.prolang, "
                           "p.pronargs, p.proargtypes, p.prorettype, "
                           "%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 %s"
                           "\n  AND NOT EXISTS (SELECT 1 FROM pg_depend "
                           "WHERE classid = 'pg_proc'::regclass AND "
                           "objid = p.oid AND deptype = 'i')"
                           "\n  AND ("
                           "\n  pronamespace != "
                           "(SELECT oid FROM pg_namespace "
                           "WHERE nspname = 'pg_catalog')"
                           "\n  OR EXISTS (SELECT 1 FROM pg_cast"
                           "\n  WHERE pg_cast.oid > %u "
                           "\n  AND p.oid = pg_cast.castfunc)"
                           "\n  OR EXISTS (SELECT 1 FROM pg_transform"
                           "\n  WHERE pg_transform.oid > %u AND "
                           "\n  (p.oid = pg_transform.trffromsql"
                           "\n  OR p.oid = pg_transform.trftosql))",
                           acl_subquery->data,
                           racl_subquery->data,
                           initacl_subquery->data,
                           initracl_subquery->data,
                           username_subquery,
                           not_agg_check,
                           g_last_builtin_oid,
                           g_last_builtin_oid);
         if (dopt->binary_upgrade)
             appendPQExpBufferStr(query,
                                  "\n  OR EXISTS(SELECT 1 FROM pg_depend WHERE "
                                  "classid = 'pg_proc'::regclass AND "
                                  "objid = p.oid AND "
                                  "refclassid = 'pg_extension'::regclass AND "
                                  "deptype = 'e')");
         appendPQExpBufferStr(query,
                              "\n  OR p.proacl IS DISTINCT FROM pip.initprivs");
         appendPQExpBufferChar(query, ')');
 
         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)
             pg_log_warning("owner of function \"%s\" appears to be invalid",
                            finfo[i].dobj.name);
     }
 
     PQclear(res);
 
     destroyPQExpBuffer(query);
 
     return finfo;
 }

◆ getIndexes()

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

Definition at line 6816 of file pg_dump.c.

Referenced by getSchemaData().

 {
     int         i,
                 j;
     PQExpBuffer query = createPQExpBuffer();
     PGresult   *res;
     IndxInfo   *indxinfo;
     ConstraintInfo *constrinfo;
     int         i_tableoid,
                 i_oid,
                 i_indexname,
                 i_parentidx,
                 i_indexdef,
                 i_indnkeyatts,
                 i_indnatts,
                 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_indstatcols,
                 i_indstatvals;
     int         ntups;
 
     for (i = 0; i < numTables; i++)
     {
         TableInfo  *tbinfo = &tblinfo[i];
 
         if (!tbinfo->hasindex)
             continue;
 
         /*
          * Ignore indexes of tables whose definitions are not to be dumped.
          *
          * We also need indexes on partitioned tables which have partitions to
          * be dumped, in order to dump the indexes on the partitions.
          */
         if (!(tbinfo->dobj.dump & DUMP_COMPONENT_DEFINITION) &&
             !tbinfo->interesting)
             continue;
 
         pg_log_info("reading indexes for table \"%s.%s\"",
                     tbinfo->dobj.namespace->dobj.name,
                     tbinfo->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 >= 110000)
         {
             appendPQExpBuffer(query,
                               "SELECT t.tableoid, t.oid, "
                               "t.relname AS indexname, "
                               "inh.inhparent AS parentidx, "
                               "pg_catalog.pg_get_indexdef(i.indexrelid) AS indexdef, "
                               "i.indnkeyatts AS indnkeyatts, "
                               "i.indnatts AS indnatts, "
                               "i.indkey, i.indisclustered, "
                               "i.indisreplident, "
                               "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, "
                               "(SELECT pg_catalog.array_agg(attnum ORDER BY attnum) "
                               "  FROM pg_catalog.pg_attribute "
                               "  WHERE attrelid = i.indexrelid AND "
                               "    attstattarget >= 0) AS indstatcols,"
                               "(SELECT pg_catalog.array_agg(attstattarget ORDER BY attnum) "
                               "  FROM pg_catalog.pg_attribute "
                               "  WHERE attrelid = i.indexrelid AND "
                               "    attstattarget >= 0) AS indstatvals "
                               "FROM pg_catalog.pg_index i "
                               "JOIN pg_catalog.pg_class t ON (t.oid = i.indexrelid) "
                               "JOIN pg_catalog.pg_class t2 ON (t2.oid = i.indrelid) "
                               "LEFT JOIN pg_catalog.pg_constraint c "
                               "ON (i.indrelid = c.conrelid AND "
                               "i.indexrelid = c.conindid AND "
                               "c.contype IN ('p','u','x')) "
                               "LEFT JOIN pg_catalog.pg_inherits inh "
                               "ON (inh.inhrelid = indexrelid) "
                               "WHERE i.indrelid = '%u'::pg_catalog.oid "
                               "AND (i.indisvalid OR t2.relkind = 'p') "
                               "AND i.indisready "
                               "ORDER BY indexname",
                               tbinfo->dobj.catId.oid);
         }
         else 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, "
                               "0 AS parentidx, "
                               "pg_catalog.pg_get_indexdef(i.indexrelid) AS indexdef, "
                               "i.indnatts AS indnkeyatts, "
                               "i.indnatts AS indnatts, "
                               "i.indkey, i.indisclustered, "
                               "i.indisreplident, "
                               "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, "
                               "'' AS indstatcols, "
                               "'' AS indstatvals "
                               "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, "
                               "0 AS parentidx, "
                               "pg_catalog.pg_get_indexdef(i.indexrelid) AS indexdef, "
                               "i.indnatts AS indnkeyatts, "
                               "i.indnatts AS indnatts, "
                               "i.indkey, i.indisclustered, "
                               "false AS indisreplident, "
                               "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, "
                               "'' AS indstatcols, "
                               "'' AS indstatvals "
                               "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, "
                               "0 AS parentidx, "
                               "pg_catalog.pg_get_indexdef(i.indexrelid) AS indexdef, "
                               "i.indnatts AS indnkeyatts, "
                               "i.indnatts AS indnatts, "
                               "i.indkey, i.indisclustered, "
                               "false AS indisreplident, "
                               "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, "
                               "'' AS indstatcols, "
                               "'' AS indstatvals "
                               "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, "
                               "0 AS parentidx, "
                               "pg_catalog.pg_get_indexdef(i.indexrelid) AS indexdef, "
                               "t.relnatts AS indnkeyatts, "
                               "t.relnatts AS indnatts, "
                               "i.indkey, i.indisclustered, "
                               "false AS indisreplident, "
                               "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, "
                               "'' AS indstatcols, "
                               "'' AS indstatvals "
                               "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_parentidx = PQfnumber(res, "parentidx");
         i_indexdef = PQfnumber(res, "indexdef");
         i_indnkeyatts = PQfnumber(res, "indnkeyatts");
         i_indnatts = PQfnumber(res, "indnatts");
         i_indkey = PQfnumber(res, "indkey");
         i_indisclustered = PQfnumber(res, "indisclustered");
         i_indisreplident = PQfnumber(res, "indisreplident");
         i_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");
         i_indstatcols = PQfnumber(res, "indstatcols");
         i_indstatvals = PQfnumber(res, "indstatvals");
 
         tbinfo->indexes = indxinfo =
             (IndxInfo *) pg_malloc(ntups * sizeof(IndxInfo));
         constrinfo = (ConstraintInfo *) pg_malloc(ntups * sizeof(ConstraintInfo));
         tbinfo->numIndexes = ntups;
 
         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.dump = tbinfo->dobj.dump;
             indxinfo[j].dobj.name = pg_strdup(PQgetvalue(res, j, i_indexname));
             indxinfo[j].dobj.namespace = tbinfo->dobj.namespace;
             indxinfo[j].indextable = tbinfo;
             indxinfo[j].indexdef = pg_strdup(PQgetvalue(res, j, i_indexdef));
             indxinfo[j].indnkeyattrs = atoi(PQgetvalue(res, j, i_indnkeyatts));
             indxinfo[j].indnattrs = atoi(PQgetvalue(res, j, i_indnatts));
             indxinfo[j].tablespace = pg_strdup(PQgetvalue(res, j, i_tablespace));
             indxinfo[j].indreloptions = pg_strdup(PQgetvalue(res, j, i_indreloptions));
             indxinfo[j].indstatcols = pg_strdup(PQgetvalue(res, j, i_indstatcols));
             indxinfo[j].indstatvals = pg_strdup(PQgetvalue(res, j, i_indstatvals));
             indxinfo[j].indkeys = (Oid *) pg_malloc(indxinfo[j].indnattrs * sizeof(Oid));
             parseOidArray(PQgetvalue(res, j, i_indkey),
                           indxinfo[j].indkeys, indxinfo[j].indnattrs);
             indxinfo[j].indisclustered = (PQgetvalue(res, j, i_indisclustered)[0] == 't');
             indxinfo[j].indisreplident = (PQgetvalue(res, j, i_indisreplident)[0] == 't');
             indxinfo[j].parentidx = atooid(PQgetvalue(res, j, i_parentidx));
             indxinfo[j].partattaches = (SimplePtrList) { NULL, NULL };
             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.dump = tbinfo->dobj.dump;
                 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);
 }

◆ getInherits()

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

Definition at line 6767 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(), and PQntuples().

Referenced by getSchemaData().

 {
     PGresult   *res;
     int         ntups;
     int         i;
     PQExpBuffer query = createPQExpBuffer();
     InhInfo    *inhinfo;
 
     int         i_inhrelid;
     int         i_inhparent;
 
     /*
      * Find all the inheritance information, excluding implicit inheritance
      * via partitioning.
      */
     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;
 }

◆ getMaxDumpId()

DumpId getMaxDumpId ( void )

Definition at line 598 of file common.c.

References lastDumpId.

Referenced by findDependencyLoops(), flagInhIndexes(), and TopoSort().

 {
     return lastDumpId;
 }

◆ getNamespaces()

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

Definition at line 4517 of file pg_dump.c.

References appendPQExpBuffer(), appendPQExpBufferStr(), 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, pg_log_warning, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetisnull(), PQgetvalue(), PQntuples(), Archive::remoteVersion, _namespaceInfo::rnspacl, rolname, _namespaceInfo::rolname, selectDumpableNamespace(), CatalogId::tableoid, and username_subquery.

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();
 
     /*
      * 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);
 
         appendPQExpBufferStr(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)
             pg_log_warning("owner of schema \"%s\" appears to be invalid",
                            nsinfo[i].dobj.name);
     }
 
     PQclear(res);
     destroyPQExpBuffer(query);
 
     *numNamespaces = ntups;
 
     return nsinfo;
 }

◆ getOpclasses()

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

Definition at line 5307 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_log_warning, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), rolname, _opclassInfo::rolname, selectDumpableObject(), CatalogId::tableoid, and username_subquery.

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.
      */
 
     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)
             pg_log_warning("owner of operator class \"%s\" appears to be invalid",
                            opcinfo[i].dobj.name);
     }
 
     PQclear(res);
 
     destroyPQExpBuffer(query);
 
     return opcinfo;
 }

◆ getOperators()

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

Definition at line 4997 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_log_warning, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), rolname, _oprInfo::rolname, selectDumpableObject(), CatalogId::tableoid, and username_subquery.

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.
      */
 
     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)
             pg_log_warning("owner of operator \"%s\" appears to be invalid",
                            oprinfo[i].dobj.name);
     }
 
     PQclear(res);
 
     destroyPQExpBuffer(query);
 
     return oprinfo;
 }

◆ getOpfamilies()

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

Definition at line 5382 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_log_warning, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), Archive::remoteVersion, rolname, _opfamilyInfo::rolname, selectDumpableObject(), CatalogId::tableoid, and username_subquery.

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.
      */
 
     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].

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_INDEX_ATTACH, DO_STATSEXT, DO_RULE, DO_TRIGGER, DO_CONSTRAINT, DO_FK_CONSTRAINT, DO_PROCLANG, DO_CAST, DO_TABLE_DATA, DO_SEQUENCE_SET, DO_DUMMY_TYPE, DO_TSPARSER, DO_TSDICT, DO_TSTEMPLATE, DO_TSCONFIG, DO_FDW, DO_FOREIGN_SERVER, DO_DEFAULT_ACL, DO_TRANSFORM, DO_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 }

Data Structures

Macros

Typedefs

Enumerations

Functions

Variables

Macro Definition Documentation

◆ DUMP_COMPONENT_ACL

◆ DUMP_COMPONENT_ALL

◆ DUMP_COMPONENT_COMMENT

◆ DUMP_COMPONENT_DATA

◆ DUMP_COMPONENT_DEFINITION

◆ DUMP_COMPONENT_NONE

◆ DUMP_COMPONENT_POLICY

◆ DUMP_COMPONENT_SECLABEL

◆ DUMP_COMPONENT_USERMAP

◆ DUMP_COMPONENTS_REQUIRING_LOCK

◆ oidcmp

Typedef Documentation

◆ AccessMethodInfo

◆ AggInfo

◆ AttrDefInfo

◆ BlobInfo

◆ CastInfo

◆ CollInfo

◆ ConstraintInfo

◆ ConvInfo

◆ DefaultACLInfo

◆ DumpableObject

◆ DumpComponents

◆ EventTriggerInfo

◆ ExtensionInfo

◆ ExtensionMemberId

◆ FdwInfo

◆ ForeignServerInfo

◆ FuncInfo

◆ IndexAttachInfo

◆ IndxInfo

◆ InhInfo

◆ NamespaceInfo

◆ OpclassInfo

◆ OpfamilyInfo

◆ OprInfo

◆ PolicyInfo

◆ ProcLangInfo

◆ PublicationInfo

◆ PublicationRelInfo

◆ RuleInfo

◆ ShellTypeInfo

◆ StatsExtInfo

◆ SubscriptionInfo

◆ TableDataInfo

◆ TableInfo

◆ TransformInfo

◆ TriggerInfo

◆ TSConfigInfo

◆ TSDictInfo

◆ TSParserInfo

◆ TSTemplateInfo

◆ TypeInfo

Enumeration Type Documentation

◆ DumpableObjectType

Function Documentation

◆ addObjectDependency()

◆ AssignDumpId()

◆ createDumpId()

◆ findCollationByOid()

◆ findExtensionByOid()

◆ findFuncByOid()

◆ findNamespaceByOid()

◆ findObjectByCatalogId()

◆ findObjectByDumpId()

◆ findOprByOid()

◆ findOwningExtension()

◆ findTableByOid()

◆ findTypeByOid()

◆ getAccessMethods()

◆ getAggregates()

◆ getCasts()

◆ getCollations()