#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	_statsExtInfo

struct	_ruleInfo

struct	_triggerInfo

struct	_evttriggerInfo

struct	_constraintInfo

struct	_procLangInfo

struct	_castInfo

struct	_transformInfo

struct	_inhInfo

struct	_prsInfo

struct	_dictInfo

struct	_tmplInfo

struct	_cfgInfo

struct	_fdwInfo

struct	_foreignServerInfo

struct	_defaultACLInfo

struct	_blobInfo

struct	_policyInfo

struct	_PublicationInfo

struct	_PublicationRelInfo

struct	_SubscriptionInfo

struct	_extensionMemberId

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

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

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

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

#define	oidzero(x) ( (x) == 0 )

#define	DUMP_COMPONENT_NONE (0)

#define	DUMP_COMPONENT_DEFINITION (1 << 0)

#define	DUMP_COMPONENT_DATA (1 << 1)

#define	DUMP_COMPONENT_COMMENT (1 << 2)

#define	DUMP_COMPONENT_SECLABEL (1 << 3)

#define	DUMP_COMPONENT_ACL (1 << 4)

#define	DUMP_COMPONENT_POLICY (1 << 5)

#define	DUMP_COMPONENT_USERMAP (1 << 6)

#define	DUMP_COMPONENT_ALL (0xFFFF)

#define	DUMP_COMPONENTS_REQUIRING_LOCK

Typedefs
typedef uint32	DumpComponents

typedef struct _dumpableObject	DumpableObject

typedef struct _namespaceInfo	NamespaceInfo

typedef struct _extensionInfo	ExtensionInfo

typedef struct _typeInfo	TypeInfo

typedef struct _shellTypeInfo	ShellTypeInfo

typedef struct _funcInfo	FuncInfo

typedef struct _aggInfo	AggInfo

typedef struct _oprInfo	OprInfo

typedef struct _accessMethodInfo	AccessMethodInfo

typedef struct _opclassInfo	OpclassInfo

typedef struct _opfamilyInfo	OpfamilyInfo

typedef struct _collInfo	CollInfo

typedef struct _convInfo	ConvInfo

typedef struct _tableInfo	TableInfo

typedef struct _attrDefInfo	AttrDefInfo

typedef struct _tableDataInfo	TableDataInfo

typedef struct _indxInfo	IndxInfo

typedef struct _statsExtInfo	StatsExtInfo

typedef struct _ruleInfo	RuleInfo

typedef struct _triggerInfo	TriggerInfo

typedef struct _evttriggerInfo	EventTriggerInfo

typedef struct _constraintInfo	ConstraintInfo

typedef struct _procLangInfo	ProcLangInfo

typedef struct _castInfo	CastInfo

typedef struct _transformInfo	TransformInfo

typedef struct _inhInfo	InhInfo

typedef struct _prsInfo	TSParserInfo

typedef struct _dictInfo	TSDictInfo

typedef struct _tmplInfo	TSTemplateInfo

typedef struct _cfgInfo	TSConfigInfo

typedef struct _fdwInfo	FdwInfo

typedef struct _foreignServerInfo	ForeignServerInfo

typedef struct _defaultACLInfo	DefaultACLInfo

typedef struct _blobInfo	BlobInfo

typedef struct _policyInfo	PolicyInfo

typedef struct _PublicationInfo	PublicationInfo

typedef struct _PublicationRelInfo	PublicationRelInfo

typedef struct _SubscriptionInfo	SubscriptionInfo

typedef struct _extensionMemberId	ExtensionMemberId

Functions
TableInfo *	getSchemaData (Archive fout, int numTablesPtr)

void	AssignDumpId (DumpableObject *dobj)

DumpId	createDumpId (void)

DumpId	getMaxDumpId (void)

DumpableObject *	findObjectByDumpId (DumpId dumpId)

DumpableObject *	findObjectByCatalogId (CatalogId catalogId)

void	getDumpableObjects (DumpableObject **objs, int numObjs)

void	addObjectDependency (DumpableObject *dobj, DumpId refId)

void	removeObjectDependency (DumpableObject *dobj, DumpId refId)

TableInfo *	findTableByOid (Oid oid)

TypeInfo *	findTypeByOid (Oid oid)

FuncInfo *	findFuncByOid (Oid oid)

OprInfo *	findOprByOid (Oid oid)

CollInfo *	findCollationByOid (Oid oid)

NamespaceInfo *	findNamespaceByOid (Oid oid)

ExtensionInfo *	findExtensionByOid (Oid oid)

void	setExtensionMembership (ExtensionMemberId *extmems, int nextmems)

ExtensionInfo *	findOwningExtension (CatalogId catalogId)

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

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

void	sortDumpableObjectsByTypeName (DumpableObject **objs, int numObjs)

void	sortDataAndIndexObjectsBySize (DumpableObject **objs, int numObjs)

NamespaceInfo *	getNamespaces (Archive fout, int numNamespaces)

ExtensionInfo *	getExtensions (Archive fout, int numExtensions)

TypeInfo *	getTypes (Archive fout, int numTypes)

FuncInfo *	getFuncs (Archive fout, int numFuncs)

AggInfo *	getAggregates (Archive fout, int numAggregates)

OprInfo *	getOperators (Archive fout, int numOperators)

AccessMethodInfo *	getAccessMethods (Archive fout, int numAccessMethods)

OpclassInfo *	getOpclasses (Archive fout, int numOpclasses)

OpfamilyInfo *	getOpfamilies (Archive fout, int numOpfamilies)

CollInfo *	getCollations (Archive fout, int numCollations)

ConvInfo *	getConversions (Archive fout, int numConversions)

TableInfo *	getTables (Archive fout, int numTables)

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

InhInfo *	getInherits (Archive fout, int numInherits)

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

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

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

RuleInfo *	getRules (Archive fout, int numRules)

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

ProcLangInfo *	getProcLangs (Archive fout, int numProcLangs)

CastInfo *	getCasts (Archive fout, int numCasts)

TransformInfo *	getTransforms (Archive fout, int numTransforms)

void	getTableAttrs (Archive fout, TableInfo tbinfo, int numTables)

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

TSParserInfo *	getTSParsers (Archive fout, int numTSParsers)

TSDictInfo *	getTSDictionaries (Archive fout, int numTSDicts)

TSTemplateInfo *	getTSTemplates (Archive fout, int numTSTemplates)

TSConfigInfo *	getTSConfigurations (Archive fout, int numTSConfigs)

FdwInfo *	getForeignDataWrappers (Archive fout, int numForeignDataWrappers)

ForeignServerInfo *	getForeignServers (Archive fout, int numForeignServers)

DefaultACLInfo *	getDefaultACLs (Archive fout, int numDefaultACLs)

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

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

EventTriggerInfo *	getEventTriggers (Archive fout, int numEventTriggers)

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

void	getPublications (Archive *fout)

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

void	getSubscriptions (Archive *fout)

Variables
bool	force_quotes

bool	g_verbose

char	g_comment_start [10]

char	g_comment_end [10]

char	g_opaque_type [10]

Macro Definition Documentation

#define DUMP_COMPONENT_ACL (1 << 4)

#define DUMP_COMPONENT_ALL (0xFFFF)

Definition at line 99 of file pg_dump.h.

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

#define DUMP_COMPONENT_COMMENT (1 << 2)

#define DUMP_COMPONENT_DATA (1 << 1)

Definition at line 93 of file pg_dump.h.

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

#define DUMP_COMPONENT_DEFINITION (1 << 0)

Definition at line 92 of file pg_dump.h.

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

#define DUMP_COMPONENT_NONE (0)

Definition at line 91 of file pg_dump.h.

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

#define DUMP_COMPONENT_POLICY (1 << 5)

Definition at line 97 of file pg_dump.h.

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

#define DUMP_COMPONENT_SECLABEL (1 << 3)

Definition at line 95 of file pg_dump.h.

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

#define DUMP_COMPONENT_USERMAP (1 << 6)

Definition at line 98 of file pg_dump.h.

Referenced by dumpForeignServer().

#define DUMP_COMPONENTS_REQUIRING_LOCK

Value:

(\
		DUMP_COMPONENT_DEFINITION |\
		DUMP_COMPONENT_DATA |\
		DUMP_COMPONENT_POLICY)

Definition at line 123 of file pg_dump.h.

Referenced by getTables().

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

Definition at line 20 of file pg_dump.h.

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

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

Definition at line 21 of file pg_dump.h.

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

Definition at line 23 of file pg_dump.h.

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

Definition at line 22 of file pg_dump.h.

#define oidzero ( x ) ( (x) == 0 )

Definition at line 24 of file pg_dump.h.

Typedef Documentation

typedef struct _accessMethodInfo AccessMethodInfo

typedef struct _aggInfo AggInfo

typedef struct _attrDefInfo AttrDefInfo

typedef struct _blobInfo BlobInfo

typedef struct _castInfo CastInfo

typedef struct _collInfo CollInfo

typedef struct _constraintInfo ConstraintInfo

typedef struct _convInfo ConvInfo

typedef struct _defaultACLInfo DefaultACLInfo

typedef struct _dumpableObject DumpableObject

typedef uint32 DumpComponents

Definition at line 90 of file pg_dump.h.

typedef struct _evttriggerInfo EventTriggerInfo

typedef struct _extensionInfo ExtensionInfo

typedef struct _extensionMemberId ExtensionMemberId

typedef struct _fdwInfo FdwInfo

typedef struct _foreignServerInfo ForeignServerInfo

typedef struct _funcInfo FuncInfo

typedef struct _indxInfo IndxInfo

typedef struct _inhInfo InhInfo

typedef struct _namespaceInfo NamespaceInfo

typedef struct _opclassInfo OpclassInfo

typedef struct _opfamilyInfo OpfamilyInfo

typedef struct _oprInfo OprInfo

typedef struct _policyInfo PolicyInfo

typedef struct _procLangInfo ProcLangInfo

typedef struct _PublicationInfo PublicationInfo

typedef struct _PublicationRelInfo PublicationRelInfo

typedef struct _ruleInfo RuleInfo

typedef struct _shellTypeInfo ShellTypeInfo

typedef struct _statsExtInfo StatsExtInfo

typedef struct _SubscriptionInfo SubscriptionInfo

typedef struct _tableDataInfo TableDataInfo

typedef struct _tableInfo TableInfo

typedef struct _transformInfo TransformInfo

typedef struct _triggerInfo TriggerInfo

typedef struct _cfgInfo TSConfigInfo

typedef struct _dictInfo TSDictInfo

typedef struct _prsInfo TSParserInfo

typedef struct _tmplInfo TSTemplateInfo

typedef struct _typeInfo TypeInfo

Enumeration Type Documentation

enum DumpableObjectType

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

Definition at line 41 of file pg_dump.h.

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

Function Documentation

void addObjectDependency	(	DumpableObject *	dobj,
		DumpId	refId
	)

Definition at line 712 of file common.c.

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

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

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

void AssignDumpId ( DumpableObject * dobj )

Definition at line 476 of file common.c.

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

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

 {
     dobj->dumpId = ++lastDumpId;
     dobj->name = NULL;          /* must be set later */
     dobj->namespace = NULL;     /* may be set later */
     dobj->dump = DUMP_COMPONENT_ALL;    /* default assumption */
     dobj->ext_member = false;   /* default assumption */
     dobj->dependencies = NULL;
     dobj->nDeps = 0;
     dobj->allocDeps = 0;
 
     while (dobj->dumpId >= allocedDumpIds)
     {
         int         newAlloc;
 
         if (allocedDumpIds <= 0)
         {
             newAlloc = 256;
             dumpIdMap = (DumpableObject **)
                 pg_malloc(newAlloc * sizeof(DumpableObject *));
         }
         else
         {
             newAlloc = allocedDumpIds * 2;
             dumpIdMap = (DumpableObject **)
                 pg_realloc(dumpIdMap, newAlloc * sizeof(DumpableObject *));
         }
         memset(dumpIdMap + allocedDumpIds, 0,
                (newAlloc - allocedDumpIds) * sizeof(DumpableObject *));
         allocedDumpIds = newAlloc;
     }
     dumpIdMap[dobj->dumpId] = dobj;
 
     /* mark catalogIdMap invalid, but don't rebuild it yet */
     catalogIdMapValid = false;
 }

DumpId createDumpId ( void )

Definition at line 520 of file common.c.

References lastDumpId.

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

 {
     return ++lastDumpId;
 }

CollInfo* findCollationByOid ( Oid oid )

Definition at line 803 of file common.c.

References findObjectByOid(), and numCollations.

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

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

ExtensionInfo* findExtensionByOid ( Oid oid )

Definition at line 825 of file common.c.

References findObjectByOid(), and numExtensions.

Referenced by getExtensionMembership().

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

FuncInfo* findFuncByOid ( Oid oid )

Definition at line 781 of file common.c.

References findObjectByOid(), and numFuncs.

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

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

NamespaceInfo* findNamespaceByOid ( Oid oid )

Definition at line 814 of file common.c.

References findObjectByOid(), and numNamespaces.

Referenced by findNamespace().

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

DumpableObject* findObjectByCatalogId ( CatalogId catalogId )

Definition at line 558 of file common.c.

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

Referenced by buildMatViewRefreshDependencies(), and getDependencies().

 {
     DumpableObject **low;
     DumpableObject **high;
 
     if (!catalogIdMapValid)
     {
         if (catalogIdMap)
             free(catalogIdMap);
         getDumpableObjects(&catalogIdMap, &numCatalogIds);
         if (numCatalogIds > 1)
             qsort((void *) catalogIdMap, numCatalogIds,
                   sizeof(DumpableObject *), DOCatalogIdCompare);
         catalogIdMapValid = true;
     }
 
     /*
      * We could use bsearch() here, but the notational cruft of calling
      * bsearch is nearly as bad as doing it ourselves; and the generalized
      * bsearch function is noticeably slower as well.
      */
     if (numCatalogIds <= 0)
         return NULL;
     low = catalogIdMap;
     high = catalogIdMap + (numCatalogIds - 1);
     while (low <= high)
     {
         DumpableObject **middle;
         int         difference;
 
         middle = low + (high - low) / 2;
         /* comparison must match DOCatalogIdCompare, below */
         difference = oidcmp((*middle)->catId.oid, catalogId.oid);
         if (difference == 0)
             difference = oidcmp((*middle)->catId.tableoid, catalogId.tableoid);
         if (difference == 0)
             return *middle;
         else if (difference < 0)
             low = middle + 1;
         else
             high = middle - 1;
     }
     return NULL;
 }

DumpableObject* findObjectByDumpId ( DumpId dumpId )

Definition at line 540 of file common.c.

References allocedDumpIds, and NULL.

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

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

OprInfo* findOprByOid ( Oid oid )

Definition at line 792 of file common.c.

References findObjectByOid(), and numOperators.

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

ExtensionInfo* findOwningExtension ( CatalogId catalogId )

Definition at line 852 of file common.c.

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

Referenced by checkExtensionMembership().

 {
     ExtensionMemberId *low;
     ExtensionMemberId *high;
 
     /*
      * We could use bsearch() here, but the notational cruft of calling
      * bsearch is nearly as bad as doing it ourselves; and the generalized
      * bsearch function is noticeably slower as well.
      */
     if (numextmembers <= 0)
         return NULL;
     low = extmembers;
     high = extmembers + (numextmembers - 1);
     while (low <= high)
     {
         ExtensionMemberId *middle;
         int         difference;
 
         middle = low + (high - low) / 2;
         /* comparison must match ExtensionMemberIdCompare, below */
         difference = oidcmp(middle->catId.oid, catalogId.oid);
         if (difference == 0)
             difference = oidcmp(middle->catId.tableoid, catalogId.tableoid);
         if (difference == 0)
             return middle->ext;
         else if (difference < 0)
             low = middle + 1;
         else
             high = middle - 1;
     }
     return NULL;
 }

TableInfo* findTableByOid ( Oid oid )

Definition at line 759 of file common.c.

References findObjectByOid(), and numTables.

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

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

TypeInfo* findTypeByOid ( Oid oid )

Definition at line 770 of file common.c.

References findObjectByOid(), and numTypes.

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

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

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

Definition at line 4899 of file pg_dump.c.

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

Referenced by getSchemaData().

 {
     PGresult   *res;
     int         ntups;
     int         i;
     PQExpBuffer query;
     AccessMethodInfo *aminfo;
     int         i_tableoid;
     int         i_oid;
     int         i_amname;
     int         i_amhandler;
     int         i_amtype;
 
     /* Before 9.6, there are no user-defined access methods */
     if (fout->remoteVersion < 90600)
     {
         *numAccessMethods = 0;
         return NULL;
     }
 
     query = createPQExpBuffer();
 
     /* Make sure we are in proper schema */
     selectSourceSchema(fout, "pg_catalog");
 
     /* Select all access methods from pg_am table */
     appendPQExpBuffer(query, "SELECT tableoid, oid, amname, amtype, "
                       "amhandler::pg_catalog.regproc AS amhandler "
                       "FROM pg_am");
 
     res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
     ntups = PQntuples(res);
     *numAccessMethods = ntups;
 
     aminfo = (AccessMethodInfo *) pg_malloc(ntups * sizeof(AccessMethodInfo));
 
     i_tableoid = PQfnumber(res, "tableoid");
     i_oid = PQfnumber(res, "oid");
     i_amname = PQfnumber(res, "amname");
     i_amhandler = PQfnumber(res, "amhandler");
     i_amtype = PQfnumber(res, "amtype");
 
     for (i = 0; i < ntups; i++)
     {
         aminfo[i].dobj.objType = DO_ACCESS_METHOD;
         aminfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
         aminfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
         AssignDumpId(&aminfo[i].dobj);
         aminfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_amname));
         aminfo[i].dobj.namespace = NULL;
         aminfo[i].amhandler = pg_strdup(PQgetvalue(res, i, i_amhandler));
         aminfo[i].amtype = *(PQgetvalue(res, i, i_amtype));
 
         /* Decide whether we want to dump it */
         selectDumpableAccessMethod(&(aminfo[i]), fout);
 
         /* Access methods do not currently have ACLs. */
         aminfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;
     }
 
     PQclear(res);
 
     destroyPQExpBuffer(query);
 
     return aminfo;
 }

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

Definition at line 5141 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, NULL, _dumpableObject::objType, CatalogId::oid, parseOidArray(), pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetisnull(), PQgetvalue(), PQntuples(), _funcInfo::proacl, _funcInfo::prorettype, Archive::remoteVersion, _funcInfo::rolname, _funcInfo::rproacl, selectDumpableObject(), selectSourceSchema(), CatalogId::tableoid, username_subquery, and write_msg().

Referenced by getSchemaData().

 {
     DumpOptions *dopt = fout->dopt;
     PGresult   *res;
     int         ntups;
     int         i;
     PQExpBuffer query = createPQExpBuffer();
     AggInfo    *agginfo;
     int         i_tableoid;
     int         i_oid;
     int         i_aggname;
     int         i_aggnamespace;
     int         i_pronargs;
     int         i_proargtypes;
     int         i_rolname;
     int         i_aggacl;
     int         i_raggacl;
     int         i_initaggacl;
     int         i_initraggacl;
 
     /* Make sure we are in proper schema */
     selectSourceSchema(fout, "pg_catalog");
 
     /*
      * Find all interesting aggregates.  See comment in getFuncs() for the
      * rationale behind the filtering logic.
      */
     if (fout->remoteVersion >= 90600)
     {
         PQExpBuffer acl_subquery = createPQExpBuffer();
         PQExpBuffer racl_subquery = createPQExpBuffer();
         PQExpBuffer initacl_subquery = createPQExpBuffer();
         PQExpBuffer initracl_subquery = createPQExpBuffer();
 
         buildACLQueries(acl_subquery, racl_subquery, initacl_subquery,
                         initracl_subquery, "p.proacl", "p.proowner", "'f'",
                         dopt->binary_upgrade);
 
         appendPQExpBuffer(query, "SELECT p.tableoid, p.oid, "
                           "p.proname AS aggname, "
                           "p.pronamespace AS aggnamespace, "
                           "p.pronargs, p.proargtypes, "
                           "(%s p.proowner) AS rolname, "
                           "%s AS aggacl, "
                           "%s AS raggacl, "
                           "%s AS initaggacl, "
                           "%s AS initraggacl "
                           "FROM pg_proc p "
                           "LEFT JOIN pg_init_privs pip ON "
                           "(p.oid = pip.objoid "
                           "AND pip.classoid = 'pg_proc'::regclass "
                           "AND pip.objsubid = 0) "
                           "WHERE p.proisagg AND ("
                           "p.pronamespace != "
                           "(SELECT oid FROM pg_namespace "
                           "WHERE nspname = 'pg_catalog') OR "
                           "p.proacl IS DISTINCT FROM pip.initprivs",
                           username_subquery,
                           acl_subquery->data,
                           racl_subquery->data,
                           initacl_subquery->data,
                           initracl_subquery->data);
         if (dopt->binary_upgrade)
             appendPQExpBufferStr(query,
                                  " OR EXISTS(SELECT 1 FROM pg_depend WHERE "
                                  "classid = 'pg_proc'::regclass AND "
                                  "objid = p.oid AND "
                                  "refclassid = 'pg_extension'::regclass AND "
                                  "deptype = 'e')");
         appendPQExpBufferChar(query, ')');
 
         destroyPQExpBuffer(acl_subquery);
         destroyPQExpBuffer(racl_subquery);
         destroyPQExpBuffer(initacl_subquery);
         destroyPQExpBuffer(initracl_subquery);
     }
     else if (fout->remoteVersion >= 80200)
     {
         appendPQExpBuffer(query, "SELECT tableoid, oid, proname AS aggname, "
                           "pronamespace AS aggnamespace, "
                           "pronargs, proargtypes, "
                           "(%s proowner) AS rolname, "
                           "proacl AS aggacl, "
                           "NULL AS raggacl, "
                           "NULL AS initaggacl, NULL AS initraggacl "
                           "FROM pg_proc p "
                           "WHERE proisagg AND ("
                           "pronamespace != "
                           "(SELECT oid FROM pg_namespace "
                           "WHERE nspname = 'pg_catalog')",
                           username_subquery);
         if (dopt->binary_upgrade && fout->remoteVersion >= 90100)
             appendPQExpBufferStr(query,
                                  " OR EXISTS(SELECT 1 FROM pg_depend WHERE "
                                  "classid = 'pg_proc'::regclass AND "
                                  "objid = p.oid AND "
                                  "refclassid = 'pg_extension'::regclass AND "
                                  "deptype = 'e')");
         appendPQExpBufferChar(query, ')');
     }
     else
     {
         appendPQExpBuffer(query, "SELECT tableoid, oid, proname AS aggname, "
                           "pronamespace AS aggnamespace, "
                           "CASE WHEN proargtypes[0] = 'pg_catalog.\"any\"'::pg_catalog.regtype THEN 0 ELSE 1 END AS pronargs, "
                           "proargtypes, "
                           "(%s proowner) AS rolname, "
                           "proacl AS aggacl, "
                           "NULL AS raggacl, "
                           "NULL AS initaggacl, NULL AS initraggacl "
                           "FROM pg_proc "
                           "WHERE proisagg "
                           "AND pronamespace != "
                           "(SELECT oid FROM pg_namespace WHERE nspname = 'pg_catalog')",
                           username_subquery);
     }
 
     res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
     ntups = PQntuples(res);
     *numAggs = ntups;
 
     agginfo = (AggInfo *) pg_malloc(ntups * sizeof(AggInfo));
 
     i_tableoid = PQfnumber(res, "tableoid");
     i_oid = PQfnumber(res, "oid");
     i_aggname = PQfnumber(res, "aggname");
     i_aggnamespace = PQfnumber(res, "aggnamespace");
     i_pronargs = PQfnumber(res, "pronargs");
     i_proargtypes = PQfnumber(res, "proargtypes");
     i_rolname = PQfnumber(res, "rolname");
     i_aggacl = PQfnumber(res, "aggacl");
     i_raggacl = PQfnumber(res, "raggacl");
     i_initaggacl = PQfnumber(res, "initaggacl");
     i_initraggacl = PQfnumber(res, "initraggacl");
 
     for (i = 0; i < ntups; i++)
     {
         agginfo[i].aggfn.dobj.objType = DO_AGG;
         agginfo[i].aggfn.dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
         agginfo[i].aggfn.dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
         AssignDumpId(&agginfo[i].aggfn.dobj);
         agginfo[i].aggfn.dobj.name = pg_strdup(PQgetvalue(res, i, i_aggname));
         agginfo[i].aggfn.dobj.namespace =
             findNamespace(fout,
                           atooid(PQgetvalue(res, i, i_aggnamespace)));
         agginfo[i].aggfn.rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
         if (strlen(agginfo[i].aggfn.rolname) == 0)
             write_msg(NULL, "WARNING: owner of aggregate function \"%s\" appears to be invalid\n",
                       agginfo[i].aggfn.dobj.name);
         agginfo[i].aggfn.lang = InvalidOid; /* not currently interesting */
         agginfo[i].aggfn.prorettype = InvalidOid;   /* not saved */
         agginfo[i].aggfn.proacl = pg_strdup(PQgetvalue(res, i, i_aggacl));
         agginfo[i].aggfn.rproacl = pg_strdup(PQgetvalue(res, i, i_raggacl));
         agginfo[i].aggfn.initproacl = pg_strdup(PQgetvalue(res, i, i_initaggacl));
         agginfo[i].aggfn.initrproacl = pg_strdup(PQgetvalue(res, i, i_initraggacl));
         agginfo[i].aggfn.nargs = atoi(PQgetvalue(res, i, i_pronargs));
         if (agginfo[i].aggfn.nargs == 0)
             agginfo[i].aggfn.argtypes = NULL;
         else
         {
             agginfo[i].aggfn.argtypes = (Oid *) pg_malloc(agginfo[i].aggfn.nargs * sizeof(Oid));
             parseOidArray(PQgetvalue(res, i, i_proargtypes),
                           agginfo[i].aggfn.argtypes,
                           agginfo[i].aggfn.nargs);
         }
 
         /* Decide whether we want to dump it */
         selectDumpableObject(&(agginfo[i].aggfn.dobj), fout);
 
         /* Do not try to dump ACL if no ACL exists. */
         if (PQgetisnull(res, i, i_aggacl) && PQgetisnull(res, i, i_raggacl) &&
             PQgetisnull(res, i, i_initaggacl) &&
             PQgetisnull(res, i, i_initraggacl))
             agginfo[i].aggfn.dobj.dump &= ~DUMP_COMPONENT_ACL;
     }
 
     PQclear(res);
 
     destroyPQExpBuffer(query);
 
     return agginfo;
 }

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

Definition at line 7617 of file pg_dump.c.

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

Referenced by getSchemaData().

 {
     PGresult   *res;
     int         ntups;
     int         i;
     PQExpBuffer query = createPQExpBuffer();
     CastInfo   *castinfo;
     int         i_tableoid;
     int         i_oid;
     int         i_castsource;
     int         i_casttarget;
     int         i_castfunc;
     int         i_castcontext;
     int         i_castmethod;
 
     /* Make sure we are in proper schema */
     selectSourceSchema(fout, "pg_catalog");
 
     if (fout->remoteVersion >= 80400)
     {
         appendPQExpBufferStr(query, "SELECT tableoid, oid, "
                              "castsource, casttarget, castfunc, castcontext, "
                              "castmethod "
                              "FROM pg_cast ORDER BY 3,4");
     }
     else
     {
         appendPQExpBufferStr(query, "SELECT tableoid, oid, "
                              "castsource, casttarget, castfunc, castcontext, "
                              "CASE WHEN castfunc = 0 THEN 'b' ELSE 'f' END AS castmethod "
                              "FROM pg_cast ORDER BY 3,4");
     }
 
     res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
     ntups = PQntuples(res);
 
     *numCasts = ntups;
 
     castinfo = (CastInfo *) pg_malloc(ntups * sizeof(CastInfo));
 
     i_tableoid = PQfnumber(res, "tableoid");
     i_oid = PQfnumber(res, "oid");
     i_castsource = PQfnumber(res, "castsource");
     i_casttarget = PQfnumber(res, "casttarget");
     i_castfunc = PQfnumber(res, "castfunc");
     i_castcontext = PQfnumber(res, "castcontext");
     i_castmethod = PQfnumber(res, "castmethod");
 
     for (i = 0; i < ntups; i++)
     {
         PQExpBufferData namebuf;
         TypeInfo   *sTypeInfo;
         TypeInfo   *tTypeInfo;
 
         castinfo[i].dobj.objType = DO_CAST;
         castinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
         castinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
         AssignDumpId(&castinfo[i].dobj);
         castinfo[i].castsource = atooid(PQgetvalue(res, i, i_castsource));
         castinfo[i].casttarget = atooid(PQgetvalue(res, i, i_casttarget));
         castinfo[i].castfunc = atooid(PQgetvalue(res, i, i_castfunc));
         castinfo[i].castcontext = *(PQgetvalue(res, i, i_castcontext));
         castinfo[i].castmethod = *(PQgetvalue(res, i, i_castmethod));
 
         /*
          * Try to name cast as concatenation of typnames.  This is only used
          * for purposes of sorting.  If we fail to find either type, the name
          * will be an empty string.
          */
         initPQExpBuffer(&namebuf);
         sTypeInfo = findTypeByOid(castinfo[i].castsource);
         tTypeInfo = findTypeByOid(castinfo[i].casttarget);
         if (sTypeInfo && tTypeInfo)
             appendPQExpBuffer(&namebuf, "%s %s",
                               sTypeInfo->dobj.name, tTypeInfo->dobj.name);
         castinfo[i].dobj.name = namebuf.data;
 
         /* Decide whether we want to dump it */
         selectDumpableCast(&(castinfo[i]), fout);
 
         /* Casts do not currently have ACLs. */
         castinfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;
     }
 
     PQclear(res);
 
     destroyPQExpBuffer(query);
 
     return castinfo;
 }

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

Definition at line 4740 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, NULL, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), Archive::remoteVersion, _collInfo::rolname, selectDumpableObject(), selectSourceSchema(), CatalogId::tableoid, and username_subquery.

Referenced by getSchemaData().

 {
     PGresult   *res;
     int         ntups;
     int         i;
     PQExpBuffer query;
     CollInfo   *collinfo;
     int         i_tableoid;
     int         i_oid;
     int         i_collname;
     int         i_collnamespace;
     int         i_rolname;
 
     /* Collations didn't exist pre-9.1 */
     if (fout->remoteVersion < 90100)
     {
         *numCollations = 0;
         return NULL;
     }
 
     query = createPQExpBuffer();
 
     /*
      * find all collations, including builtin collations; we filter out
      * system-defined collations at dump-out time.
      */
 
     /* Make sure we are in proper schema */
     selectSourceSchema(fout, "pg_catalog");
 
     appendPQExpBuffer(query, "SELECT tableoid, oid, collname, "
                       "collnamespace, "
                       "(%s collowner) AS rolname "
                       "FROM pg_collation",
                       username_subquery);
 
     res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
     ntups = PQntuples(res);
     *numCollations = ntups;
 
     collinfo = (CollInfo *) pg_malloc(ntups * sizeof(CollInfo));
 
     i_tableoid = PQfnumber(res, "tableoid");
     i_oid = PQfnumber(res, "oid");
     i_collname = PQfnumber(res, "collname");
     i_collnamespace = PQfnumber(res, "collnamespace");
     i_rolname = PQfnumber(res, "rolname");
 
     for (i = 0; i < ntups; i++)
     {
         collinfo[i].dobj.objType = DO_COLLATION;
         collinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
         collinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
         AssignDumpId(&collinfo[i].dobj);
         collinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_collname));
         collinfo[i].dobj.namespace =
             findNamespace(fout,
                           atooid(PQgetvalue(res, i, i_collnamespace)));
         collinfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
 
         /* Decide whether we want to dump it */
         selectDumpableObject(&(collinfo[i].dobj), fout);
 
         /* Collations do not currently have ACLs. */
         collinfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;
     }
 
     PQclear(res);
 
     destroyPQExpBuffer(query);
 
     return collinfo;
 }

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

Definition at line 6842 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_condef;
     int         ntups;
 
     query = createPQExpBuffer();
 
     for (i = 0; i < numTables; i++)
     {
         TableInfo  *tbinfo = &tblinfo[i];
 
         if (!tbinfo->hastriggers ||
             !(tbinfo->dobj.dump & DUMP_COMPONENT_DEFINITION))
             continue;
 
         if (g_verbose)
             write_msg(NULL, "reading foreign key constraints for table \"%s.%s\"\n",
                       tbinfo->dobj.namespace->dobj.name,
                       tbinfo->dobj.name);
 
         /*
          * select table schema to ensure constraint expr is qualified if
          * needed
          */
         selectSourceSchema(fout, tbinfo->dobj.namespace->dobj.name);
 
         resetPQExpBuffer(query);
         appendPQExpBuffer(query,
                           "SELECT tableoid, oid, conname, confrelid, "
                           "pg_catalog.pg_get_constraintdef(oid) AS condef "
                           "FROM pg_catalog.pg_constraint "
                           "WHERE conrelid = '%u'::pg_catalog.oid "
                           "AND contype = 'f'",
                           tbinfo->dobj.catId.oid);
         res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
         ntups = PQntuples(res);
 
         i_contableoid = PQfnumber(res, "tableoid");
         i_conoid = PQfnumber(res, "oid");
         i_conname = PQfnumber(res, "conname");
         i_confrelid = PQfnumber(res, "confrelid");
         i_condef = PQfnumber(res, "condef");
 
         constrinfo = (ConstraintInfo *) pg_malloc(ntups * sizeof(ConstraintInfo));
 
         for (j = 0; j < ntups; j++)
         {
             constrinfo[j].dobj.objType = DO_FK_CONSTRAINT;
             constrinfo[j].dobj.catId.tableoid = atooid(PQgetvalue(res, j, i_contableoid));
             constrinfo[j].dobj.catId.oid = atooid(PQgetvalue(res, j, i_conoid));
             AssignDumpId(&constrinfo[j].dobj);
             constrinfo[j].dobj.name = pg_strdup(PQgetvalue(res, j, i_conname));
             constrinfo[j].dobj.namespace = tbinfo->dobj.namespace;
             constrinfo[j].contable = tbinfo;
             constrinfo[j].condomain = NULL;
             constrinfo[j].contype = 'f';
             constrinfo[j].condef = pg_strdup(PQgetvalue(res, j, i_condef));
             constrinfo[j].confrelid = atooid(PQgetvalue(res, j, i_confrelid));
             constrinfo[j].conindex = 0;
             constrinfo[j].condeferrable = false;
             constrinfo[j].condeferred = false;
             constrinfo[j].conislocal = true;
             constrinfo[j].separate = true;
         }
 
         PQclear(res);
     }
 
     destroyPQExpBuffer(query);
 }

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

Definition at line 4823 of file pg_dump.c.

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

Referenced by getSchemaData().

 {
     PGresult   *res;
     int         ntups;
     int         i;
     PQExpBuffer query;
     ConvInfo   *convinfo;
     int         i_tableoid;
     int         i_oid;
     int         i_conname;
     int         i_connamespace;
     int         i_rolname;
 
     query = createPQExpBuffer();
 
     /*
      * find all conversions, including builtin conversions; we filter out
      * system-defined conversions at dump-out time.
      */
 
     /* Make sure we are in proper schema */
     selectSourceSchema(fout, "pg_catalog");
 
     appendPQExpBuffer(query, "SELECT tableoid, oid, conname, "
                       "connamespace, "
                       "(%s conowner) AS rolname "
                       "FROM pg_conversion",
                       username_subquery);
 
     res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
     ntups = PQntuples(res);
     *numConversions = ntups;
 
     convinfo = (ConvInfo *) pg_malloc(ntups * sizeof(ConvInfo));
 
     i_tableoid = PQfnumber(res, "tableoid");
     i_oid = PQfnumber(res, "oid");
     i_conname = PQfnumber(res, "conname");
     i_connamespace = PQfnumber(res, "connamespace");
     i_rolname = PQfnumber(res, "rolname");
 
     for (i = 0; i < ntups; i++)
     {
         convinfo[i].dobj.objType = DO_CONVERSION;
         convinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
         convinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
         AssignDumpId(&convinfo[i].dobj);
         convinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_conname));
         convinfo[i].dobj.namespace =
             findNamespace(fout,
                           atooid(PQgetvalue(res, i, i_connamespace)));
         convinfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
 
         /* Decide whether we want to dump it */
         selectDumpableObject(&(convinfo[i].dobj), fout);
 
         /* Conversions do not currently have ACLs. */
         convinfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;
     }
 
     PQclear(res);
 
     destroyPQExpBuffer(query);
 
     return convinfo;
 }

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

Definition at line 8983 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, NULL, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), _defaultACLInfo::rdefaclacl, Archive::remoteVersion, selectDumpableDefaultACL(), selectSourceSchema(), CatalogId::tableoid, and username_subquery.

Referenced by getSchemaData().

 {
     DumpOptions *dopt = fout->dopt;
     DefaultACLInfo *daclinfo;
     PQExpBuffer query;
     PGresult   *res;
     int         i_oid;
     int         i_tableoid;
     int         i_defaclrole;
     int         i_defaclnamespace;
     int         i_defaclobjtype;
     int         i_defaclacl;
     int         i_rdefaclacl;
     int         i_initdefaclacl;
     int         i_initrdefaclacl;
     int         i,
                 ntups;
 
     if (fout->remoteVersion < 90000)
     {
         *numDefaultACLs = 0;
         return NULL;
     }
 
     query = createPQExpBuffer();
 
     /* Make sure we are in proper schema */
     selectSourceSchema(fout, "pg_catalog");
 
     if (fout->remoteVersion >= 90600)
     {
         PQExpBuffer acl_subquery = createPQExpBuffer();
         PQExpBuffer racl_subquery = createPQExpBuffer();
         PQExpBuffer initacl_subquery = createPQExpBuffer();
         PQExpBuffer initracl_subquery = createPQExpBuffer();
 
         buildACLQueries(acl_subquery, racl_subquery, initacl_subquery,
                         initracl_subquery, "defaclacl", "defaclrole",
                         "CASE WHEN defaclobjtype = 'S' THEN 's' ELSE defaclobjtype END::\"char\"",
                         dopt->binary_upgrade);
 
         appendPQExpBuffer(query, "SELECT d.oid, d.tableoid, "
                           "(%s d.defaclrole) AS defaclrole, "
                           "d.defaclnamespace, "
                           "d.defaclobjtype, "
                           "%s AS defaclacl, "
                           "%s AS rdefaclacl, "
                           "%s AS initdefaclacl, "
                           "%s AS initrdefaclacl "
                           "FROM pg_default_acl d "
                           "LEFT JOIN pg_init_privs pip ON "
                           "(d.oid = pip.objoid "
                           "AND pip.classoid = 'pg_default_acl'::regclass "
                           "AND pip.objsubid = 0) ",
                           username_subquery,
                           acl_subquery->data,
                           racl_subquery->data,
                           initacl_subquery->data,
                           initracl_subquery->data);
     }
     else
     {
         appendPQExpBuffer(query, "SELECT oid, tableoid, "
                           "(%s defaclrole) AS defaclrole, "
                           "defaclnamespace, "
                           "defaclobjtype, "
                           "defaclacl, "
                           "NULL AS rdefaclacl, "
                           "NULL AS initdefaclacl, "
                           "NULL AS initrdefaclacl "
                           "FROM pg_default_acl",
                           username_subquery);
     }
 
     res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
     ntups = PQntuples(res);
     *numDefaultACLs = ntups;
 
     daclinfo = (DefaultACLInfo *) pg_malloc(ntups * sizeof(DefaultACLInfo));
 
     i_oid = PQfnumber(res, "oid");
     i_tableoid = PQfnumber(res, "tableoid");
     i_defaclrole = PQfnumber(res, "defaclrole");
     i_defaclnamespace = PQfnumber(res, "defaclnamespace");
     i_defaclobjtype = PQfnumber(res, "defaclobjtype");
     i_defaclacl = PQfnumber(res, "defaclacl");
     i_rdefaclacl = PQfnumber(res, "rdefaclacl");
     i_initdefaclacl = PQfnumber(res, "initdefaclacl");
     i_initrdefaclacl = PQfnumber(res, "initrdefaclacl");
 
     for (i = 0; i < ntups; i++)
     {
         Oid         nspid = atooid(PQgetvalue(res, i, i_defaclnamespace));
 
         daclinfo[i].dobj.objType = DO_DEFAULT_ACL;
         daclinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
         daclinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
         AssignDumpId(&daclinfo[i].dobj);
         /* cheesy ... is it worth coming up with a better object name? */
         daclinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_defaclobjtype));
 
         if (nspid != InvalidOid)
             daclinfo[i].dobj.namespace = findNamespace(fout, nspid);
         else
             daclinfo[i].dobj.namespace = NULL;
 
         daclinfo[i].defaclrole = pg_strdup(PQgetvalue(res, i, i_defaclrole));
         daclinfo[i].defaclobjtype = *(PQgetvalue(res, i, i_defaclobjtype));
         daclinfo[i].defaclacl = pg_strdup(PQgetvalue(res, i, i_defaclacl));
         daclinfo[i].rdefaclacl = pg_strdup(PQgetvalue(res, i, i_rdefaclacl));
         daclinfo[i].initdefaclacl = pg_strdup(PQgetvalue(res, i, i_initdefaclacl));
         daclinfo[i].initrdefaclacl = pg_strdup(PQgetvalue(res, i, i_initrdefaclacl));
 
         /* Decide whether we want to dump it */
         selectDumpableDefaultACL(&(daclinfo[i]), dopt);
     }
 
     PQclear(res);
 
     destroyPQExpBuffer(query);
 
     return daclinfo;
 }

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

Definition at line 690 of file common.c.

References allocedDumpIds, i, and pg_malloc().

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

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

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

Definition at line 7342 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, NULL, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), Archive::remoteVersion, selectDumpableObject(), selectSourceSchema(), CatalogId::tableoid, and username_subquery.

Referenced by getSchemaData().

 {
     int         i;
     PQExpBuffer query;
     PGresult   *res;
     EventTriggerInfo *evtinfo;
     int         i_tableoid,
                 i_oid,
                 i_evtname,
                 i_evtevent,
                 i_evtowner,
                 i_evttags,
                 i_evtfname,
                 i_evtenabled;
     int         ntups;
 
     /* Before 9.3, there are no event triggers */
     if (fout->remoteVersion < 90300)
     {
         *numEventTriggers = 0;
         return NULL;
     }
 
     query = createPQExpBuffer();
 
     /* Make sure we are in proper schema */
     selectSourceSchema(fout, "pg_catalog");
 
     appendPQExpBuffer(query,
                       "SELECT e.tableoid, e.oid, evtname, evtenabled, "
                       "evtevent, (%s evtowner) AS evtowner, "
                       "array_to_string(array("
                       "select quote_literal(x) "
                       " from unnest(evttags) as t(x)), ', ') as evttags, "
                       "e.evtfoid::regproc as evtfname "
                       "FROM pg_event_trigger e "
                       "ORDER BY e.oid",
                       username_subquery);
 
     res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
     ntups = PQntuples(res);
 
     *numEventTriggers = ntups;
 
     evtinfo = (EventTriggerInfo *) pg_malloc(ntups * sizeof(EventTriggerInfo));
 
     i_tableoid = PQfnumber(res, "tableoid");
     i_oid = PQfnumber(res, "oid");
     i_evtname = PQfnumber(res, "evtname");
     i_evtevent = PQfnumber(res, "evtevent");
     i_evtowner = PQfnumber(res, "evtowner");
     i_evttags = PQfnumber(res, "evttags");
     i_evtfname = PQfnumber(res, "evtfname");
     i_evtenabled = PQfnumber(res, "evtenabled");
 
     for (i = 0; i < ntups; i++)
     {
         evtinfo[i].dobj.objType = DO_EVENT_TRIGGER;
         evtinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
         evtinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
         AssignDumpId(&evtinfo[i].dobj);
         evtinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_evtname));
         evtinfo[i].evtname = pg_strdup(PQgetvalue(res, i, i_evtname));
         evtinfo[i].evtevent = pg_strdup(PQgetvalue(res, i, i_evtevent));
         evtinfo[i].evtowner = pg_strdup(PQgetvalue(res, i, i_evtowner));
         evtinfo[i].evttags = pg_strdup(PQgetvalue(res, i, i_evttags));
         evtinfo[i].evtfname = pg_strdup(PQgetvalue(res, i, i_evtfname));
         evtinfo[i].evtenabled = *(PQgetvalue(res, i, i_evtenabled));
 
         /* Decide whether we want to dump it */
         selectDumpableObject(&(evtinfo[i].dobj), fout);
 
         /* Event Triggers do not currently have ACLs. */
         evtinfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;
     }
 
     PQclear(res);
 
     destroyPQExpBuffer(query);
 
     return evtinfo;
 }

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

Definition at line 6743 of file pg_dump.c.

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

Referenced by getSchemaData().

 {
     int         i,
                 j;
     PQExpBuffer query;
     PGresult   *res;
     StatsExtInfo *statsextinfo;
     int         ntups;
     int         i_tableoid;
     int         i_oid;
     int         i_stxname;
     int         i_stxdef;
 
     /* Extended statistics were new in v10 */
     if (fout->remoteVersion < 100000)
         return;
 
     query = createPQExpBuffer();
 
     for (i = 0; i < numTables; i++)
     {
         TableInfo  *tbinfo = &tblinfo[i];
 
         /*
          * Only plain tables, materialized views, foreign tables and
          * partitioned tables can have extended statistics.
          */
         if (tbinfo->relkind != RELKIND_RELATION &&
             tbinfo->relkind != RELKIND_MATVIEW &&
             tbinfo->relkind != RELKIND_FOREIGN_TABLE &&
             tbinfo->relkind != RELKIND_PARTITIONED_TABLE)
             continue;
 
         /*
          * Ignore extended statistics of tables whose definitions are not to
          * be dumped.
          */
         if (!(tbinfo->dobj.dump & DUMP_COMPONENT_DEFINITION))
             continue;
 
         if (g_verbose)
             write_msg(NULL, "reading extended statistics for table \"%s.%s\"\n",
                       tbinfo->dobj.namespace->dobj.name,
                       tbinfo->dobj.name);
 
         /* Make sure we are in proper schema so stadef is right */
         selectSourceSchema(fout, tbinfo->dobj.namespace->dobj.name);
 
         resetPQExpBuffer(query);
 
         appendPQExpBuffer(query,
                           "SELECT "
                           "tableoid, "
                           "oid, "
                           "stxname, "
                           "pg_catalog.pg_get_statisticsobjdef(oid) AS stxdef "
                           "FROM pg_statistic_ext "
                           "WHERE stxrelid = '%u' "
                           "ORDER BY stxname", tbinfo->dobj.catId.oid);
 
         res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
         ntups = PQntuples(res);
 
         i_tableoid = PQfnumber(res, "tableoid");
         i_oid = PQfnumber(res, "oid");
         i_stxname = PQfnumber(res, "stxname");
         i_stxdef = PQfnumber(res, "stxdef");
 
         statsextinfo = (StatsExtInfo *) pg_malloc(ntups * sizeof(StatsExtInfo));
 
         for (j = 0; j < ntups; j++)
         {
             statsextinfo[j].dobj.objType = DO_STATSEXT;
             statsextinfo[j].dobj.catId.tableoid = atooid(PQgetvalue(res, j, i_tableoid));
             statsextinfo[j].dobj.catId.oid = atooid(PQgetvalue(res, j, i_oid));
             AssignDumpId(&statsextinfo[j].dobj);
             statsextinfo[j].dobj.name = pg_strdup(PQgetvalue(res, j, i_stxname));
             statsextinfo[j].dobj.namespace = tbinfo->dobj.namespace;
             statsextinfo[j].statsexttable = tbinfo;
             statsextinfo[j].statsextdef = pg_strdup(PQgetvalue(res, j, i_stxdef));
         }
 
         PQclear(res);
     }
 
     destroyPQExpBuffer(query);
 }

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

Definition at line 17188 of file pg_dump.c.

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

Referenced by getSchemaData().

 {
     PQExpBuffer query;
     PGresult   *res;
     int         ntups,
                 nextmembers,
                 i;
     int         i_classid,
                 i_objid,
                 i_refobjid;
     ExtensionMemberId *extmembers;
     ExtensionInfo *ext;
 
     /* Nothing to do if no extensions */
     if (numExtensions == 0)
         return;
 
     /* Make sure we are in proper schema */
     selectSourceSchema(fout, "pg_catalog");
 
     query = createPQExpBuffer();
 
     /* refclassid constraint is redundant but may speed the search */
     appendPQExpBufferStr(query, "SELECT "
                          "classid, objid, refobjid "
                          "FROM pg_depend "
                          "WHERE refclassid = 'pg_extension'::regclass "
                          "AND deptype = 'e' "
                          "ORDER BY 3");
 
     res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
     ntups = PQntuples(res);
 
     i_classid = PQfnumber(res, "classid");
     i_objid = PQfnumber(res, "objid");
     i_refobjid = PQfnumber(res, "refobjid");
 
     extmembers = (ExtensionMemberId *) pg_malloc(ntups * sizeof(ExtensionMemberId));
     nextmembers = 0;
 
     /*
      * Accumulate data into extmembers[].
      *
      * Since we ordered the SELECT by referenced ID, we can expect that
      * multiple entries for the same extension will appear together; this
      * saves on searches.
      */
     ext = NULL;
 
     for (i = 0; i < ntups; i++)
     {
         CatalogId   objId;
         Oid         extId;
 
         objId.tableoid = atooid(PQgetvalue(res, i, i_classid));
         objId.oid = atooid(PQgetvalue(res, i, i_objid));
         extId = atooid(PQgetvalue(res, i, i_refobjid));
 
         if (ext == NULL ||
             ext->dobj.catId.oid != extId)
             ext = findExtensionByOid(extId);
 
         if (ext == NULL)
         {
             /* shouldn't happen */
             fprintf(stderr, "could not find referenced extension %u\n", extId);
             continue;
         }
 
         extmembers[nextmembers].catId = objId;
         extmembers[nextmembers].ext = ext;
         nextmembers++;
     }
 
     PQclear(res);
 
     /* Remember the data for use later */
     setExtensionMembership(extmembers, nextmembers);
 
     destroyPQExpBuffer(query);
 }

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

Definition at line 4314 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, NULL, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), _extensionInfo::relocatable, Archive::remoteVersion, selectDumpableExtension(), selectSourceSchema(), and CatalogId::tableoid.

Referenced by getSchemaData().

 {
     DumpOptions *dopt = fout->dopt;
     PGresult   *res;
     int         ntups;
     int         i;
     PQExpBuffer query;
     ExtensionInfo *extinfo;
     int         i_tableoid;
     int         i_oid;
     int         i_extname;
     int         i_nspname;
     int         i_extrelocatable;
     int         i_extversion;
     int         i_extconfig;
     int         i_extcondition;
 
     /*
      * Before 9.1, there are no extensions.
      */
     if (fout->remoteVersion < 90100)
     {
         *numExtensions = 0;
         return NULL;
     }
 
     query = createPQExpBuffer();
 
     /* Make sure we are in proper schema */
     selectSourceSchema(fout, "pg_catalog");
 
     appendPQExpBufferStr(query, "SELECT x.tableoid, x.oid, "
                          "x.extname, n.nspname, x.extrelocatable, x.extversion, x.extconfig, x.extcondition "
                          "FROM pg_extension x "
                          "JOIN pg_namespace n ON n.oid = x.extnamespace");
 
     res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
     ntups = PQntuples(res);
 
     extinfo = (ExtensionInfo *) pg_malloc(ntups * sizeof(ExtensionInfo));
 
     i_tableoid = PQfnumber(res, "tableoid");
     i_oid = PQfnumber(res, "oid");
     i_extname = PQfnumber(res, "extname");
     i_nspname = PQfnumber(res, "nspname");
     i_extrelocatable = PQfnumber(res, "extrelocatable");
     i_extversion = PQfnumber(res, "extversion");
     i_extconfig = PQfnumber(res, "extconfig");
     i_extcondition = PQfnumber(res, "extcondition");
 
     for (i = 0; i < ntups; i++)
     {
         extinfo[i].dobj.objType = DO_EXTENSION;
         extinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
         extinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
         AssignDumpId(&extinfo[i].dobj);
         extinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_extname));
         extinfo[i].namespace = pg_strdup(PQgetvalue(res, i, i_nspname));
         extinfo[i].relocatable = *(PQgetvalue(res, i, i_extrelocatable)) == 't';
         extinfo[i].extversion = pg_strdup(PQgetvalue(res, i, i_extversion));
         extinfo[i].extconfig = pg_strdup(PQgetvalue(res, i, i_extconfig));
         extinfo[i].extcondition = pg_strdup(PQgetvalue(res, i, i_extcondition));
 
         /* Decide whether we want to dump it */
         selectDumpableExtension(&(extinfo[i]), dopt);
     }
 
     PQclear(res);
     destroyPQExpBuffer(query);
 
     *numExtensions = ntups;
 
     return extinfo;
 }

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

Definition at line 8661 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, NULL, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetisnull(), PQgetvalue(), PQntuples(), Archive::remoteVersion, _fdwInfo::rfdwacl, _fdwInfo::rolname, selectDumpableObject(), selectSourceSchema(), CatalogId::tableoid, and username_subquery.

Referenced by getSchemaData().

 {
     DumpOptions *dopt = fout->dopt;
     PGresult   *res;
     int         ntups;
     int         i;
     PQExpBuffer query;
     FdwInfo    *fdwinfo;
     int         i_tableoid;
     int         i_oid;
     int         i_fdwname;
     int         i_rolname;
     int         i_fdwhandler;
     int         i_fdwvalidator;
     int         i_fdwacl;
     int         i_rfdwacl;
     int         i_initfdwacl;
     int         i_initrfdwacl;
     int         i_fdwoptions;
 
     /* Before 8.4, there are no foreign-data wrappers */
     if (fout->remoteVersion < 80400)
     {
         *numForeignDataWrappers = 0;
         return NULL;
     }
 
     query = createPQExpBuffer();
 
     /* Make sure we are in proper schema */
     selectSourceSchema(fout, "pg_catalog");
 
     if (fout->remoteVersion >= 90600)
     {
         PQExpBuffer acl_subquery = createPQExpBuffer();
         PQExpBuffer racl_subquery = createPQExpBuffer();
         PQExpBuffer initacl_subquery = createPQExpBuffer();
         PQExpBuffer initracl_subquery = createPQExpBuffer();
 
         buildACLQueries(acl_subquery, racl_subquery, initacl_subquery,
                         initracl_subquery, "f.fdwacl", "f.fdwowner", "'F'",
                         dopt->binary_upgrade);
 
         appendPQExpBuffer(query, "SELECT f.tableoid, f.oid, f.fdwname, "
                           "(%s f.fdwowner) AS rolname, "
                           "f.fdwhandler::pg_catalog.regproc, "
                           "f.fdwvalidator::pg_catalog.regproc, "
                           "%s AS fdwacl, "
                           "%s AS rfdwacl, "
                           "%s AS initfdwacl, "
                           "%s AS initrfdwacl, "
                           "array_to_string(ARRAY("
                           "SELECT quote_ident(option_name) || ' ' || "
                           "quote_literal(option_value) "
                           "FROM pg_options_to_table(f.fdwoptions) "
                           "ORDER BY option_name"
                           "), E',\n    ') AS fdwoptions "
                           "FROM pg_foreign_data_wrapper f "
                           "LEFT JOIN pg_init_privs pip ON "
                           "(f.oid = pip.objoid "
                           "AND pip.classoid = 'pg_foreign_data_wrapper'::regclass "
                           "AND pip.objsubid = 0) ",
                           username_subquery,
                           acl_subquery->data,
                           racl_subquery->data,
                           initacl_subquery->data,
                           initracl_subquery->data);
 
         destroyPQExpBuffer(acl_subquery);
         destroyPQExpBuffer(racl_subquery);
         destroyPQExpBuffer(initacl_subquery);
         destroyPQExpBuffer(initracl_subquery);
     }
     else if (fout->remoteVersion >= 90100)
     {
         appendPQExpBuffer(query, "SELECT tableoid, oid, fdwname, "
                           "(%s fdwowner) AS rolname, "
                           "fdwhandler::pg_catalog.regproc, "
                           "fdwvalidator::pg_catalog.regproc, fdwacl, "
                           "NULL as rfdwacl, "
                           "NULL as initfdwacl, NULL AS initrfdwacl, "
                           "array_to_string(ARRAY("
                           "SELECT quote_ident(option_name) || ' ' || "
                           "quote_literal(option_value) "
                           "FROM pg_options_to_table(fdwoptions) "
                           "ORDER BY option_name"
                           "), E',\n    ') AS fdwoptions "
                           "FROM pg_foreign_data_wrapper",
                           username_subquery);
     }
     else
     {
         appendPQExpBuffer(query, "SELECT tableoid, oid, fdwname, "
                           "(%s fdwowner) AS rolname, "
                           "'-' AS fdwhandler, "
                           "fdwvalidator::pg_catalog.regproc, fdwacl, "
                           "NULL as rfdwacl, "
                           "NULL as initfdwacl, NULL AS initrfdwacl, "
                           "array_to_string(ARRAY("
                           "SELECT quote_ident(option_name) || ' ' || "
                           "quote_literal(option_value) "
                           "FROM pg_options_to_table(fdwoptions) "
                           "ORDER BY option_name"
                           "), E',\n    ') AS fdwoptions "
                           "FROM pg_foreign_data_wrapper",
                           username_subquery);
     }
 
     res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
     ntups = PQntuples(res);
     *numForeignDataWrappers = ntups;
 
     fdwinfo = (FdwInfo *) pg_malloc(ntups * sizeof(FdwInfo));
 
     i_tableoid = PQfnumber(res, "tableoid");
     i_oid = PQfnumber(res, "oid");
     i_fdwname = PQfnumber(res, "fdwname");
     i_rolname = PQfnumber(res, "rolname");
     i_fdwhandler = PQfnumber(res, "fdwhandler");
     i_fdwvalidator = PQfnumber(res, "fdwvalidator");
     i_fdwacl = PQfnumber(res, "fdwacl");
     i_rfdwacl = PQfnumber(res, "rfdwacl");
     i_initfdwacl = PQfnumber(res, "initfdwacl");
     i_initrfdwacl = PQfnumber(res, "initrfdwacl");
     i_fdwoptions = PQfnumber(res, "fdwoptions");
 
     for (i = 0; i < ntups; i++)
     {
         fdwinfo[i].dobj.objType = DO_FDW;
         fdwinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
         fdwinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
         AssignDumpId(&fdwinfo[i].dobj);
         fdwinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_fdwname));
         fdwinfo[i].dobj.namespace = NULL;
         fdwinfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
         fdwinfo[i].fdwhandler = pg_strdup(PQgetvalue(res, i, i_fdwhandler));
         fdwinfo[i].fdwvalidator = pg_strdup(PQgetvalue(res, i, i_fdwvalidator));
         fdwinfo[i].fdwoptions = pg_strdup(PQgetvalue(res, i, i_fdwoptions));
         fdwinfo[i].fdwacl = pg_strdup(PQgetvalue(res, i, i_fdwacl));
         fdwinfo[i].rfdwacl = pg_strdup(PQgetvalue(res, i, i_rfdwacl));
         fdwinfo[i].initfdwacl = pg_strdup(PQgetvalue(res, i, i_initfdwacl));
         fdwinfo[i].initrfdwacl = pg_strdup(PQgetvalue(res, i, i_initrfdwacl));
 
         /* Decide whether we want to dump it */
         selectDumpableObject(&(fdwinfo[i].dobj), fout);
 
         /* Do not try to dump ACL if no ACL exists. */
         if (PQgetisnull(res, i, i_fdwacl) && PQgetisnull(res, i, i_rfdwacl) &&
             PQgetisnull(res, i, i_initfdwacl) &&
             PQgetisnull(res, i, i_initrfdwacl))
             fdwinfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;
     }
 
     PQclear(res);
 
     destroyPQExpBuffer(query);
 
     return fdwinfo;
 }

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

Definition at line 8830 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();
 
     /* Make sure we are in proper schema */
     selectSourceSchema(fout, "pg_catalog");
 
     if (fout->remoteVersion >= 90600)
     {
         PQExpBuffer acl_subquery = createPQExpBuffer();
         PQExpBuffer racl_subquery = createPQExpBuffer();
         PQExpBuffer initacl_subquery = createPQExpBuffer();
         PQExpBuffer initracl_subquery = createPQExpBuffer();
 
         buildACLQueries(acl_subquery, racl_subquery, initacl_subquery,
                         initracl_subquery, "f.srvacl", "f.srvowner", "'S'",
                         dopt->binary_upgrade);
 
         appendPQExpBuffer(query, "SELECT f.tableoid, f.oid, f.srvname, "
                           "(%s f.srvowner) AS rolname, "
                           "f.srvfdw, f.srvtype, f.srvversion, "
                           "%s AS srvacl, "
                           "%s AS rsrvacl, "
                           "%s AS initsrvacl, "
                           "%s AS initrsrvacl, "
                           "array_to_string(ARRAY("
                           "SELECT quote_ident(option_name) || ' ' || "
                           "quote_literal(option_value) "
                           "FROM pg_options_to_table(f.srvoptions) "
                           "ORDER BY option_name"
                           "), E',\n    ') AS srvoptions "
                           "FROM pg_foreign_server f "
                           "LEFT JOIN pg_init_privs pip "
                           "ON (f.oid = pip.objoid "
                           "AND pip.classoid = 'pg_foreign_server'::regclass "
                           "AND pip.objsubid = 0) ",
                           username_subquery,
                           acl_subquery->data,
                           racl_subquery->data,
                           initacl_subquery->data,
                           initracl_subquery->data);
 
         destroyPQExpBuffer(acl_subquery);
         destroyPQExpBuffer(racl_subquery);
         destroyPQExpBuffer(initacl_subquery);
         destroyPQExpBuffer(initracl_subquery);
     }
     else
     {
         appendPQExpBuffer(query, "SELECT tableoid, oid, srvname, "
                           "(%s srvowner) AS rolname, "
                           "srvfdw, srvtype, srvversion, srvacl, "
                           "NULL AS rsrvacl, "
                           "NULL AS initsrvacl, NULL AS initrsrvacl, "
                           "array_to_string(ARRAY("
                           "SELECT quote_ident(option_name) || ' ' || "
                           "quote_literal(option_value) "
                           "FROM pg_options_to_table(srvoptions) "
                           "ORDER BY option_name"
                           "), E',\n    ') AS srvoptions "
                           "FROM pg_foreign_server",
                           username_subquery);
     }
 
     res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
     ntups = PQntuples(res);
     *numForeignServers = ntups;
 
     srvinfo = (ForeignServerInfo *) pg_malloc(ntups * sizeof(ForeignServerInfo));
 
     i_tableoid = PQfnumber(res, "tableoid");
     i_oid = PQfnumber(res, "oid");
     i_srvname = PQfnumber(res, "srvname");
     i_rolname = PQfnumber(res, "rolname");
     i_srvfdw = PQfnumber(res, "srvfdw");
     i_srvtype = PQfnumber(res, "srvtype");
     i_srvversion = PQfnumber(res, "srvversion");
     i_srvacl = PQfnumber(res, "srvacl");
     i_rsrvacl = PQfnumber(res, "rsrvacl");
     i_initsrvacl = PQfnumber(res, "initsrvacl");
     i_initrsrvacl = PQfnumber(res, "initrsrvacl");
     i_srvoptions = PQfnumber(res, "srvoptions");
 
     for (i = 0; i < ntups; i++)
     {
         srvinfo[i].dobj.objType = DO_FOREIGN_SERVER;
         srvinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
         srvinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
         AssignDumpId(&srvinfo[i].dobj);
         srvinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_srvname));
         srvinfo[i].dobj.namespace = NULL;
         srvinfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
         srvinfo[i].srvfdw = atooid(PQgetvalue(res, i, i_srvfdw));
         srvinfo[i].srvtype = pg_strdup(PQgetvalue(res, i, i_srvtype));
         srvinfo[i].srvversion = pg_strdup(PQgetvalue(res, i, i_srvversion));
         srvinfo[i].srvoptions = pg_strdup(PQgetvalue(res, i, i_srvoptions));
         srvinfo[i].srvacl = pg_strdup(PQgetvalue(res, i, i_srvacl));
         srvinfo[i].rsrvacl = pg_strdup(PQgetvalue(res, i, i_rsrvacl));
         srvinfo[i].initsrvacl = pg_strdup(PQgetvalue(res, i, i_initsrvacl));
         srvinfo[i].initrsrvacl = pg_strdup(PQgetvalue(res, i, i_initrsrvacl));
 
         /* Decide whether we want to dump it */
         selectDumpableObject(&(srvinfo[i].dobj), fout);
 
         /* Do not try to dump ACL if no ACL exists. */
         if (PQgetisnull(res, i, i_srvacl) && PQgetisnull(res, i, i_rsrvacl) &&
             PQgetisnull(res, i, i_initsrvacl) &&
             PQgetisnull(res, i, i_initrsrvacl))
             srvinfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;
     }
 
     PQclear(res);
 
     destroyPQExpBuffer(query);
 
     return srvinfo;
 }

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

Definition at line 5333 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, NULL, _dumpableObject::objType, CatalogId::oid, parseOidArray(), pg_malloc(), pg_malloc0(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetisnull(), PQgetvalue(), PQntuples(), _funcInfo::proacl, _funcInfo::prorettype, Archive::remoteVersion, _funcInfo::rolname, _funcInfo::rproacl, selectDumpableObject(), selectSourceSchema(), CatalogId::tableoid, username_subquery, and write_msg().

Referenced by getSchemaData().

 {
     DumpOptions *dopt = fout->dopt;
     PGresult   *res;
     int         ntups;
     int         i;
     PQExpBuffer query = createPQExpBuffer();
     FuncInfo   *finfo;
     int         i_tableoid;
     int         i_oid;
     int         i_proname;
     int         i_pronamespace;
     int         i_rolname;
     int         i_prolang;
     int         i_pronargs;
     int         i_proargtypes;
     int         i_prorettype;
     int         i_proacl;
     int         i_rproacl;
     int         i_initproacl;
     int         i_initrproacl;
 
     /* Make sure we are in proper schema */
     selectSourceSchema(fout, "pg_catalog");
 
     /*
      * Find all interesting functions.  This is a bit complicated:
      *
      * 1. Always exclude aggregates; those are handled elsewhere.
      *
      * 2. Always exclude functions that are internally dependent on something
      * else, since presumably those will be created as a result of creating
      * the something else.  This currently acts only to suppress constructor
      * functions for range types (so we only need it in 9.2 and up).  Note
      * this is OK only because the constructors don't have any dependencies
      * the range type doesn't have; otherwise we might not get creation
      * ordering correct.
      *
      * 3. Otherwise, we normally exclude functions in pg_catalog.  However, if
      * they're members of extensions and we are in binary-upgrade mode then
      * include them, since we want to dump extension members individually in
      * that mode.  Also, if they are used by casts or transforms then we need
      * to gather the information about them, though they won't be dumped if
      * they are built-in.  Also, in 9.6 and up, include functions in
      * pg_catalog if they have an ACL different from what's shown in
      * pg_init_privs.
      */
     if (fout->remoteVersion >= 90600)
     {
         PQExpBuffer acl_subquery = createPQExpBuffer();
         PQExpBuffer racl_subquery = createPQExpBuffer();
         PQExpBuffer initacl_subquery = createPQExpBuffer();
         PQExpBuffer initracl_subquery = createPQExpBuffer();
 
         buildACLQueries(acl_subquery, racl_subquery, initacl_subquery,
                         initracl_subquery, "p.proacl", "p.proowner", "'f'",
                         dopt->binary_upgrade);
 
         appendPQExpBuffer(query,
                           "SELECT p.tableoid, p.oid, p.proname, p.prolang, "
                           "p.pronargs, p.proargtypes, p.prorettype, "
                           "%s AS proacl, "
                           "%s AS rproacl, "
                           "%s AS initproacl, "
                           "%s AS initrproacl, "
                           "p.pronamespace, "
                           "(%s p.proowner) AS rolname "
                           "FROM pg_proc p "
                           "LEFT JOIN pg_init_privs pip ON "
                           "(p.oid = pip.objoid "
                           "AND pip.classoid = 'pg_proc'::regclass "
                           "AND pip.objsubid = 0) "
                           "WHERE NOT proisagg"
                           "\n  AND NOT EXISTS (SELECT 1 FROM pg_depend "
                           "WHERE classid = 'pg_proc'::regclass AND "
                           "objid = p.oid AND deptype = 'i')"
                           "\n  AND ("
                           "\n  pronamespace != "
                           "(SELECT oid FROM pg_namespace "
                           "WHERE nspname = 'pg_catalog')"
                           "\n  OR EXISTS (SELECT 1 FROM pg_cast"
                           "\n  WHERE pg_cast.oid > %u "
                           "\n  AND p.oid = pg_cast.castfunc)"
                           "\n  OR EXISTS (SELECT 1 FROM pg_transform"
                           "\n  WHERE pg_transform.oid > %u AND "
                           "\n  (p.oid = pg_transform.trffromsql"
                           "\n  OR p.oid = pg_transform.trftosql))",
                           acl_subquery->data,
                           racl_subquery->data,
                           initacl_subquery->data,
                           initracl_subquery->data,
                           username_subquery,
                           g_last_builtin_oid,
                           g_last_builtin_oid);
         if (dopt->binary_upgrade)
             appendPQExpBufferStr(query,
                                  "\n  OR EXISTS(SELECT 1 FROM pg_depend WHERE "
                                  "classid = 'pg_proc'::regclass AND "
                                  "objid = p.oid AND "
                                  "refclassid = 'pg_extension'::regclass AND "
                                  "deptype = 'e')");
         appendPQExpBufferStr(query,
                              "\n  OR p.proacl IS DISTINCT FROM pip.initprivs");
         appendPQExpBufferChar(query, ')');
 
         destroyPQExpBuffer(acl_subquery);
         destroyPQExpBuffer(racl_subquery);
         destroyPQExpBuffer(initacl_subquery);
         destroyPQExpBuffer(initracl_subquery);
     }
     else
     {
         appendPQExpBuffer(query,
                           "SELECT tableoid, oid, proname, prolang, "
                           "pronargs, proargtypes, prorettype, proacl, "
                           "NULL as rproacl, "
                           "NULL as initproacl, NULL AS initrproacl, "
                           "pronamespace, "
                           "(%s proowner) AS rolname "
                           "FROM pg_proc p "
                           "WHERE NOT proisagg",
                           username_subquery);
         if (fout->remoteVersion >= 90200)
             appendPQExpBufferStr(query,
                                  "\n  AND NOT EXISTS (SELECT 1 FROM pg_depend "
                                  "WHERE classid = 'pg_proc'::regclass AND "
                                  "objid = p.oid AND deptype = 'i')");
         appendPQExpBuffer(query,
                           "\n  AND ("
                           "\n  pronamespace != "
                           "(SELECT oid FROM pg_namespace "
                           "WHERE nspname = 'pg_catalog')"
                           "\n  OR EXISTS (SELECT 1 FROM pg_cast"
                           "\n  WHERE pg_cast.oid > '%u'::oid"
                           "\n  AND p.oid = pg_cast.castfunc)",
                           g_last_builtin_oid);
 
         if (fout->remoteVersion >= 90500)
             appendPQExpBuffer(query,
                               "\n  OR EXISTS (SELECT 1 FROM pg_transform"
                               "\n  WHERE pg_transform.oid > '%u'::oid"
                               "\n  AND (p.oid = pg_transform.trffromsql"
                               "\n  OR p.oid = pg_transform.trftosql))",
                               g_last_builtin_oid);
 
         if (dopt->binary_upgrade && fout->remoteVersion >= 90100)
             appendPQExpBufferStr(query,
                                  "\n  OR EXISTS(SELECT 1 FROM pg_depend WHERE "
                                  "classid = 'pg_proc'::regclass AND "
                                  "objid = p.oid AND "
                                  "refclassid = 'pg_extension'::regclass AND "
                                  "deptype = 'e')");
         appendPQExpBufferChar(query, ')');
     }
 
     res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
     ntups = PQntuples(res);
 
     *numFuncs = ntups;
 
     finfo = (FuncInfo *) pg_malloc0(ntups * sizeof(FuncInfo));
 
     i_tableoid = PQfnumber(res, "tableoid");
     i_oid = PQfnumber(res, "oid");
     i_proname = PQfnumber(res, "proname");
     i_pronamespace = PQfnumber(res, "pronamespace");
     i_rolname = PQfnumber(res, "rolname");
     i_prolang = PQfnumber(res, "prolang");
     i_pronargs = PQfnumber(res, "pronargs");
     i_proargtypes = PQfnumber(res, "proargtypes");
     i_prorettype = PQfnumber(res, "prorettype");
     i_proacl = PQfnumber(res, "proacl");
     i_rproacl = PQfnumber(res, "rproacl");
     i_initproacl = PQfnumber(res, "initproacl");
     i_initrproacl = PQfnumber(res, "initrproacl");
 
     for (i = 0; i < ntups; i++)
     {
         finfo[i].dobj.objType = DO_FUNC;
         finfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
         finfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
         AssignDumpId(&finfo[i].dobj);
         finfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_proname));
         finfo[i].dobj.namespace =
             findNamespace(fout,
                           atooid(PQgetvalue(res, i, i_pronamespace)));
         finfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
         finfo[i].lang = atooid(PQgetvalue(res, i, i_prolang));
         finfo[i].prorettype = atooid(PQgetvalue(res, i, i_prorettype));
         finfo[i].proacl = pg_strdup(PQgetvalue(res, i, i_proacl));
         finfo[i].rproacl = pg_strdup(PQgetvalue(res, i, i_rproacl));
         finfo[i].initproacl = pg_strdup(PQgetvalue(res, i, i_initproacl));
         finfo[i].initrproacl = pg_strdup(PQgetvalue(res, i, i_initrproacl));
         finfo[i].nargs = atoi(PQgetvalue(res, i, i_pronargs));
         if (finfo[i].nargs == 0)
             finfo[i].argtypes = NULL;
         else
         {
             finfo[i].argtypes = (Oid *) pg_malloc(finfo[i].nargs * sizeof(Oid));
             parseOidArray(PQgetvalue(res, i, i_proargtypes),
                           finfo[i].argtypes, finfo[i].nargs);
         }
 
         /* Decide whether we want to dump it */
         selectDumpableObject(&(finfo[i].dobj), fout);
 
         /* Do not try to dump ACL if no ACL exists. */
         if (PQgetisnull(res, i, i_proacl) && PQgetisnull(res, i, i_rproacl) &&
             PQgetisnull(res, i, i_initproacl) &&
             PQgetisnull(res, i, i_initrproacl))
             finfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;
 
         if (strlen(finfo[i].rolname) == 0)
             write_msg(NULL,
                       "WARNING: owner of function \"%s\" appears to be invalid\n",
                       finfo[i].dobj.name);
     }
 
     PQclear(res);
 
     destroyPQExpBuffer(query);
 
     return finfo;
 }

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

Definition at line 6459 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_indexdef,
                 i_indnkeys,
                 i_indkey,
                 i_indisclustered,
                 i_indisreplident,
                 i_contype,
                 i_conname,
                 i_condeferrable,
                 i_condeferred,
                 i_contableoid,
                 i_conoid,
                 i_condef,
                 i_tablespace,
                 i_indreloptions,
                 i_relpages;
     int         ntups;
 
     for (i = 0; i < numTables; i++)
     {
         TableInfo  *tbinfo = &tblinfo[i];
 
         /* Only plain tables and materialized views have indexes. */
         if (tbinfo->relkind != RELKIND_RELATION &&
             tbinfo->relkind != RELKIND_MATVIEW)
             continue;
         if (!tbinfo->hasindex)
             continue;
 
         /* Ignore indexes of tables whose definitions are not to be dumped */
         if (!(tbinfo->dobj.dump & DUMP_COMPONENT_DEFINITION))
             continue;
 
         if (g_verbose)
             write_msg(NULL, "reading indexes for table \"%s.%s\"\n",
                       tbinfo->dobj.namespace->dobj.name,
                       tbinfo->dobj.name);
 
         /* Make sure we are in proper schema so indexdef is right */
         selectSourceSchema(fout, tbinfo->dobj.namespace->dobj.name);
 
         /*
          * The point of the messy-looking outer join is to find a constraint
          * that is related by an internal dependency link to the index. If we
          * find one, create a CONSTRAINT entry linked to the INDEX entry.  We
          * assume an index won't have more than one internal dependency.
          *
          * As of 9.0 we don't need to look at pg_depend but can check for a
          * match to pg_constraint.conindid.  The check on conrelid is
          * redundant but useful because that column is indexed while conindid
          * is not.
          */
         resetPQExpBuffer(query);
         if (fout->remoteVersion >= 90400)
         {
             /*
              * the test on indisready is necessary in 9.2, and harmless in
              * earlier/later versions
              */
             appendPQExpBuffer(query,
                               "SELECT t.tableoid, t.oid, "
                               "t.relname AS indexname, "
                               "pg_catalog.pg_get_indexdef(i.indexrelid) AS indexdef, "
                               "t.relnatts AS indnkeys, "
                               "i.indkey, i.indisclustered, "
                               "i.indisreplident, t.relpages, "
                               "c.contype, c.conname, "
                               "c.condeferrable, c.condeferred, "
                               "c.tableoid AS contableoid, "
                               "c.oid AS conoid, "
                               "pg_catalog.pg_get_constraintdef(c.oid, false) AS condef, "
                               "(SELECT spcname FROM pg_catalog.pg_tablespace s WHERE s.oid = t.reltablespace) AS tablespace, "
                               "t.reloptions AS indreloptions "
                               "FROM pg_catalog.pg_index i "
                               "JOIN pg_catalog.pg_class t ON (t.oid = i.indexrelid) "
                               "LEFT JOIN pg_catalog.pg_constraint c "
                               "ON (i.indrelid = c.conrelid AND "
                               "i.indexrelid = c.conindid AND "
                               "c.contype IN ('p','u','x')) "
                               "WHERE i.indrelid = '%u'::pg_catalog.oid "
                               "AND i.indisvalid AND i.indisready "
                               "ORDER BY indexname",
                               tbinfo->dobj.catId.oid);
         }
         else if (fout->remoteVersion >= 90000)
         {
             /*
              * the test on indisready is necessary in 9.2, and harmless in
              * earlier/later versions
              */
             appendPQExpBuffer(query,
                               "SELECT t.tableoid, t.oid, "
                               "t.relname AS indexname, "
                               "pg_catalog.pg_get_indexdef(i.indexrelid) AS indexdef, "
                               "t.relnatts AS indnkeys, "
                               "i.indkey, i.indisclustered, "
                               "false AS indisreplident, t.relpages, "
                               "c.contype, c.conname, "
                               "c.condeferrable, c.condeferred, "
                               "c.tableoid AS contableoid, "
                               "c.oid AS conoid, "
                               "pg_catalog.pg_get_constraintdef(c.oid, false) AS condef, "
                               "(SELECT spcname FROM pg_catalog.pg_tablespace s WHERE s.oid = t.reltablespace) AS tablespace, "
                               "t.reloptions AS indreloptions "
                               "FROM pg_catalog.pg_index i "
                               "JOIN pg_catalog.pg_class t ON (t.oid = i.indexrelid) "
                               "LEFT JOIN pg_catalog.pg_constraint c "
                               "ON (i.indrelid = c.conrelid AND "
                               "i.indexrelid = c.conindid AND "
                               "c.contype IN ('p','u','x')) "
                               "WHERE i.indrelid = '%u'::pg_catalog.oid "
                               "AND i.indisvalid AND i.indisready "
                               "ORDER BY indexname",
                               tbinfo->dobj.catId.oid);
         }
         else if (fout->remoteVersion >= 80200)
         {
             appendPQExpBuffer(query,
                               "SELECT t.tableoid, t.oid, "
                               "t.relname AS indexname, "
                               "pg_catalog.pg_get_indexdef(i.indexrelid) AS indexdef, "
                               "t.relnatts AS indnkeys, "
                               "i.indkey, i.indisclustered, "
                               "false AS indisreplident, t.relpages, "
                               "c.contype, c.conname, "
                               "c.condeferrable, c.condeferred, "
                               "c.tableoid AS contableoid, "
                               "c.oid AS conoid, "
                               "null AS condef, "
                               "(SELECT spcname FROM pg_catalog.pg_tablespace s WHERE s.oid = t.reltablespace) AS tablespace, "
                               "t.reloptions AS indreloptions "
                               "FROM pg_catalog.pg_index i "
                               "JOIN pg_catalog.pg_class t ON (t.oid = i.indexrelid) "
                               "LEFT JOIN pg_catalog.pg_depend d "
                               "ON (d.classid = t.tableoid "
                               "AND d.objid = t.oid "
                               "AND d.deptype = 'i') "
                               "LEFT JOIN pg_catalog.pg_constraint c "
                               "ON (d.refclassid = c.tableoid "
                               "AND d.refobjid = c.oid) "
                               "WHERE i.indrelid = '%u'::pg_catalog.oid "
                               "AND i.indisvalid "
                               "ORDER BY indexname",
                               tbinfo->dobj.catId.oid);
         }
         else
         {
             appendPQExpBuffer(query,
                               "SELECT t.tableoid, t.oid, "
                               "t.relname AS indexname, "
                               "pg_catalog.pg_get_indexdef(i.indexrelid) AS indexdef, "
                               "t.relnatts AS indnkeys, "
                               "i.indkey, i.indisclustered, "
                               "false AS indisreplident, t.relpages, "
                               "c.contype, c.conname, "
                               "c.condeferrable, c.condeferred, "
                               "c.tableoid AS contableoid, "
                               "c.oid AS conoid, "
                               "null AS condef, "
                               "(SELECT spcname FROM pg_catalog.pg_tablespace s WHERE s.oid = t.reltablespace) AS tablespace, "
                               "null AS indreloptions "
                               "FROM pg_catalog.pg_index i "
                               "JOIN pg_catalog.pg_class t ON (t.oid = i.indexrelid) "
                               "LEFT JOIN pg_catalog.pg_depend d "
                               "ON (d.classid = t.tableoid "
                               "AND d.objid = t.oid "
                               "AND d.deptype = 'i') "
                               "LEFT JOIN pg_catalog.pg_constraint c "
                               "ON (d.refclassid = c.tableoid "
                               "AND d.refobjid = c.oid) "
                               "WHERE i.indrelid = '%u'::pg_catalog.oid "
                               "ORDER BY indexname",
                               tbinfo->dobj.catId.oid);
         }
 
         res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
         ntups = PQntuples(res);
 
         i_tableoid = PQfnumber(res, "tableoid");
         i_oid = PQfnumber(res, "oid");
         i_indexname = PQfnumber(res, "indexname");
         i_indexdef = PQfnumber(res, "indexdef");
         i_indnkeys = PQfnumber(res, "indnkeys");
         i_indkey = PQfnumber(res, "indkey");
         i_indisclustered = PQfnumber(res, "indisclustered");
         i_indisreplident = PQfnumber(res, "indisreplident");
         i_relpages = PQfnumber(res, "relpages");
         i_contype = PQfnumber(res, "contype");
         i_conname = PQfnumber(res, "conname");
         i_condeferrable = PQfnumber(res, "condeferrable");
         i_condeferred = PQfnumber(res, "condeferred");
         i_contableoid = PQfnumber(res, "contableoid");
         i_conoid = PQfnumber(res, "conoid");
         i_condef = PQfnumber(res, "condef");
         i_tablespace = PQfnumber(res, "tablespace");
         i_indreloptions = PQfnumber(res, "indreloptions");
 
         indxinfo = (IndxInfo *) pg_malloc(ntups * sizeof(IndxInfo));
         constrinfo = (ConstraintInfo *) pg_malloc(ntups * sizeof(ConstraintInfo));
 
         for (j = 0; j < ntups; j++)
         {
             char        contype;
 
             indxinfo[j].dobj.objType = DO_INDEX;
             indxinfo[j].dobj.catId.tableoid = atooid(PQgetvalue(res, j, i_tableoid));
             indxinfo[j].dobj.catId.oid = atooid(PQgetvalue(res, j, i_oid));
             AssignDumpId(&indxinfo[j].dobj);
             indxinfo[j].dobj.name = pg_strdup(PQgetvalue(res, j, i_indexname));
             indxinfo[j].dobj.namespace = tbinfo->dobj.namespace;
             indxinfo[j].indextable = tbinfo;
             indxinfo[j].indexdef = pg_strdup(PQgetvalue(res, j, i_indexdef));
             indxinfo[j].indnkeys = atoi(PQgetvalue(res, j, i_indnkeys));
             indxinfo[j].tablespace = pg_strdup(PQgetvalue(res, j, i_tablespace));
             indxinfo[j].indreloptions = pg_strdup(PQgetvalue(res, j, i_indreloptions));
             indxinfo[j].indkeys = (Oid *) pg_malloc(indxinfo[j].indnkeys * sizeof(Oid));
             parseOidArray(PQgetvalue(res, j, i_indkey),
                           indxinfo[j].indkeys, indxinfo[j].indnkeys);
             indxinfo[j].indisclustered = (PQgetvalue(res, j, i_indisclustered)[0] == 't');
             indxinfo[j].indisreplident = (PQgetvalue(res, j, i_indisreplident)[0] == 't');
             indxinfo[j].relpages = atoi(PQgetvalue(res, j, i_relpages));
             contype = *(PQgetvalue(res, j, i_contype));
 
             if (contype == 'p' || contype == 'u' || contype == 'x')
             {
                 /*
                  * If we found a constraint matching the index, create an
                  * entry for it.
                  */
                 constrinfo[j].dobj.objType = DO_CONSTRAINT;
                 constrinfo[j].dobj.catId.tableoid = atooid(PQgetvalue(res, j, i_contableoid));
                 constrinfo[j].dobj.catId.oid = atooid(PQgetvalue(res, j, i_conoid));
                 AssignDumpId(&constrinfo[j].dobj);
                 constrinfo[j].dobj.name = pg_strdup(PQgetvalue(res, j, i_conname));
                 constrinfo[j].dobj.namespace = tbinfo->dobj.namespace;
                 constrinfo[j].contable = tbinfo;
                 constrinfo[j].condomain = NULL;
                 constrinfo[j].contype = contype;
                 if (contype == 'x')
                     constrinfo[j].condef = pg_strdup(PQgetvalue(res, j, i_condef));
                 else
                     constrinfo[j].condef = NULL;
                 constrinfo[j].confrelid = InvalidOid;
                 constrinfo[j].conindex = indxinfo[j].dobj.dumpId;
                 constrinfo[j].condeferrable = *(PQgetvalue(res, j, i_condeferrable)) == 't';
                 constrinfo[j].condeferred = *(PQgetvalue(res, j, i_condeferred)) == 't';
                 constrinfo[j].conislocal = true;
                 constrinfo[j].separate = true;
 
                 indxinfo[j].indexconstraint = constrinfo[j].dobj.dumpId;
             }
             else
             {
                 /* Plain secondary index */
                 indxinfo[j].indexconstraint = 0;
             }
         }
 
         PQclear(res);
     }
 
     destroyPQExpBuffer(query);
 }

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

Definition at line 6405 of file pg_dump.c.

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

Referenced by getSchemaData().

 {
     PGresult   *res;
     int         ntups;
     int         i;
     PQExpBuffer query = createPQExpBuffer();
     InhInfo    *inhinfo;
 
     int         i_inhrelid;
     int         i_inhparent;
 
     /* Make sure we are in proper schema */
     selectSourceSchema(fout, "pg_catalog");
 
     /*
      * Find all the inheritance information, excluding implicit inheritance
      * via partitioning.  We handle that case using getPartitions(), because
      * we want more information about partitions than just the parent-child
      * relationship.
      */
     appendPQExpBufferStr(query, "SELECT inhrelid, inhparent FROM pg_inherits");
 
     res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
     ntups = PQntuples(res);
 
     *numInherits = ntups;
 
     inhinfo = (InhInfo *) pg_malloc(ntups * sizeof(InhInfo));
 
     i_inhrelid = PQfnumber(res, "inhrelid");
     i_inhparent = PQfnumber(res, "inhparent");
 
     for (i = 0; i < ntups; i++)
     {
         inhinfo[i].inhrelid = atooid(PQgetvalue(res, i, i_inhrelid));
         inhinfo[i].inhparent = atooid(PQgetvalue(res, i, i_inhparent));
     }
 
     PQclear(res);
 
     destroyPQExpBuffer(query);
 
     return inhinfo;
 }

DumpId getMaxDumpId ( void )

Definition at line 529 of file common.c.

References lastDumpId.

Referenced by findDependencyLoops(), and TopoSort().

 {
     return lastDumpId;
 }

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

Definition at line 4142 of file pg_dump.c.

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

Referenced by getSchemaData().

 {
     DumpOptions *dopt = fout->dopt;
     PGresult   *res;
     int         ntups;
     int         i;
     PQExpBuffer query;
     NamespaceInfo *nsinfo;
     int         i_tableoid;
     int         i_oid;
     int         i_nspname;
     int         i_rolname;
     int         i_nspacl;
     int         i_rnspacl;
     int         i_initnspacl;
     int         i_initrnspacl;
 
     query = createPQExpBuffer();
 
     /* Make sure we are in proper schema */
     selectSourceSchema(fout, "pg_catalog");
 
     /*
      * we fetch all namespaces including system ones, so that every object we
      * read in can be linked to a containing namespace.
      */
     if (fout->remoteVersion >= 90600)
     {
         PQExpBuffer acl_subquery = createPQExpBuffer();
         PQExpBuffer racl_subquery = createPQExpBuffer();
         PQExpBuffer init_acl_subquery = createPQExpBuffer();
         PQExpBuffer init_racl_subquery = createPQExpBuffer();
 
         buildACLQueries(acl_subquery, racl_subquery, init_acl_subquery,
                         init_racl_subquery, "n.nspacl", "n.nspowner", "'n'",
                         dopt->binary_upgrade);
 
         appendPQExpBuffer(query, "SELECT n.tableoid, n.oid, n.nspname, "
                           "(%s nspowner) AS rolname, "
                           "%s as nspacl, "
                           "%s as rnspacl, "
                           "%s as initnspacl, "
                           "%s as initrnspacl "
                           "FROM pg_namespace n "
                           "LEFT JOIN pg_init_privs pip "
                           "ON (n.oid = pip.objoid "
                           "AND pip.classoid = 'pg_namespace'::regclass "
                           "AND pip.objsubid = 0",
                           username_subquery,
                           acl_subquery->data,
                           racl_subquery->data,
                           init_acl_subquery->data,
                           init_racl_subquery->data);
 
         /*
          * When we are doing a 'clean' run, we will be dropping and recreating
          * the 'public' schema (the only object which has that kind of
          * treatment in the backend and which has an entry in pg_init_privs)
          * and therefore we should not consider any initial privileges in
          * pg_init_privs in that case.
          *
          * See pg_backup_archiver.c:_printTocEntry() for the details on why
          * the public schema is special in this regard.
          *
          * Note that if the public schema is dropped and re-created, this is
          * essentially a no-op because the new public schema won't have an
          * entry in pg_init_privs anyway, as the entry will be removed when
          * the public schema is dropped.
          *
          * Further, we have to handle the case where the public schema does
          * not exist at all.
          */
         if (dopt->outputClean)
             appendPQExpBuffer(query, " AND pip.objoid <> "
                               "coalesce((select oid from pg_namespace "
                               "where nspname = 'public'),0)");
 
         appendPQExpBuffer(query, ") ");
 
         destroyPQExpBuffer(acl_subquery);
         destroyPQExpBuffer(racl_subquery);
         destroyPQExpBuffer(init_acl_subquery);
         destroyPQExpBuffer(init_racl_subquery);
     }
     else
         appendPQExpBuffer(query, "SELECT tableoid, oid, nspname, "
                           "(%s nspowner) AS rolname, "
                           "nspacl, NULL as rnspacl, "
                           "NULL AS initnspacl, NULL as initrnspacl "
                           "FROM pg_namespace",
                           username_subquery);
 
     res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
     ntups = PQntuples(res);
 
     nsinfo = (NamespaceInfo *) pg_malloc(ntups * sizeof(NamespaceInfo));
 
     i_tableoid = PQfnumber(res, "tableoid");
     i_oid = PQfnumber(res, "oid");
     i_nspname = PQfnumber(res, "nspname");
     i_rolname = PQfnumber(res, "rolname");
     i_nspacl = PQfnumber(res, "nspacl");
     i_rnspacl = PQfnumber(res, "rnspacl");
     i_initnspacl = PQfnumber(res, "initnspacl");
     i_initrnspacl = PQfnumber(res, "initrnspacl");
 
     for (i = 0; i < ntups; i++)
     {
         nsinfo[i].dobj.objType = DO_NAMESPACE;
         nsinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
         nsinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
         AssignDumpId(&nsinfo[i].dobj);
         nsinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_nspname));
         nsinfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
         nsinfo[i].nspacl = pg_strdup(PQgetvalue(res, i, i_nspacl));
         nsinfo[i].rnspacl = pg_strdup(PQgetvalue(res, i, i_rnspacl));
         nsinfo[i].initnspacl = pg_strdup(PQgetvalue(res, i, i_initnspacl));
         nsinfo[i].initrnspacl = pg_strdup(PQgetvalue(res, i, i_initrnspacl));
 
         /* Decide whether to dump this namespace */
         selectDumpableNamespace(&nsinfo[i], fout);
 
         /*
          * Do not try to dump ACL if the ACL is empty or the default.
          *
          * This is useful because, for some schemas/objects, the only
          * component we are going to try and dump is the ACL and if we can
          * remove that then 'dump' goes to zero/false and we don't consider
          * this object for dumping at all later on.
          */
         if (PQgetisnull(res, i, i_nspacl) && PQgetisnull(res, i, i_rnspacl) &&
             PQgetisnull(res, i, i_initnspacl) &&
             PQgetisnull(res, i, i_initrnspacl))
             nsinfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;
 
         if (strlen(nsinfo[i].rolname) == 0)
             write_msg(NULL, "WARNING: owner of schema \"%s\" appears to be invalid\n",
                       nsinfo[i].dobj.name);
     }
 
     PQclear(res);
     destroyPQExpBuffer(query);
 
     *numNamespaces = ntups;
 
     return nsinfo;
 }

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

Definition at line 4976 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, NULL, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), _opclassInfo::rolname, selectDumpableObject(), selectSourceSchema(), CatalogId::tableoid, username_subquery, and write_msg().

Referenced by getSchemaData().

 {
     PGresult   *res;
     int         ntups;
     int         i;
     PQExpBuffer query = createPQExpBuffer();
     OpclassInfo *opcinfo;
     int         i_tableoid;
     int         i_oid;
     int         i_opcname;
     int         i_opcnamespace;
     int         i_rolname;
 
     /*
      * find all opclasses, including builtin opclasses; we filter out
      * system-defined opclasses at dump-out time.
      */
 
     /* Make sure we are in proper schema */
     selectSourceSchema(fout, "pg_catalog");
 
     appendPQExpBuffer(query, "SELECT tableoid, oid, opcname, "
                       "opcnamespace, "
                       "(%s opcowner) AS rolname "
                       "FROM pg_opclass",
                       username_subquery);
 
     res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
     ntups = PQntuples(res);
     *numOpclasses = ntups;
 
     opcinfo = (OpclassInfo *) pg_malloc(ntups * sizeof(OpclassInfo));
 
     i_tableoid = PQfnumber(res, "tableoid");
     i_oid = PQfnumber(res, "oid");
     i_opcname = PQfnumber(res, "opcname");
     i_opcnamespace = PQfnumber(res, "opcnamespace");
     i_rolname = PQfnumber(res, "rolname");
 
     for (i = 0; i < ntups; i++)
     {
         opcinfo[i].dobj.objType = DO_OPCLASS;
         opcinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
         opcinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
         AssignDumpId(&opcinfo[i].dobj);
         opcinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_opcname));
         opcinfo[i].dobj.namespace =
             findNamespace(fout,
                           atooid(PQgetvalue(res, i, i_opcnamespace)));
         opcinfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
 
         /* Decide whether we want to dump it */
         selectDumpableObject(&(opcinfo[i].dobj), fout);
 
         /* Op Classes do not currently have ACLs. */
         opcinfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;
 
         if (strlen(opcinfo[i].rolname) == 0)
             write_msg(NULL, "WARNING: owner of operator class \"%s\" appears to be invalid\n",
                       opcinfo[i].dobj.name);
     }
 
     PQclear(res);
 
     destroyPQExpBuffer(query);
 
     return opcinfo;
 }

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

Definition at line 4654 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, NULL, _dumpableObject::objType, CatalogId::oid, _oprInfo::oprcode, _oprInfo::oprkind, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), _oprInfo::rolname, selectDumpableObject(), selectSourceSchema(), CatalogId::tableoid, username_subquery, and write_msg().

Referenced by getSchemaData().

 {
     PGresult   *res;
     int         ntups;
     int         i;
     PQExpBuffer query = createPQExpBuffer();
     OprInfo    *oprinfo;
     int         i_tableoid;
     int         i_oid;
     int         i_oprname;
     int         i_oprnamespace;
     int         i_rolname;
     int         i_oprkind;
     int         i_oprcode;
 
     /*
      * find all operators, including builtin operators; we filter out
      * system-defined operators at dump-out time.
      */
 
     /* Make sure we are in proper schema */
     selectSourceSchema(fout, "pg_catalog");
 
     appendPQExpBuffer(query, "SELECT tableoid, oid, oprname, "
                       "oprnamespace, "
                       "(%s oprowner) AS rolname, "
                       "oprkind, "
                       "oprcode::oid AS oprcode "
                       "FROM pg_operator",
                       username_subquery);
 
     res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
     ntups = PQntuples(res);
     *numOprs = ntups;
 
     oprinfo = (OprInfo *) pg_malloc(ntups * sizeof(OprInfo));
 
     i_tableoid = PQfnumber(res, "tableoid");
     i_oid = PQfnumber(res, "oid");
     i_oprname = PQfnumber(res, "oprname");
     i_oprnamespace = PQfnumber(res, "oprnamespace");
     i_rolname = PQfnumber(res, "rolname");
     i_oprkind = PQfnumber(res, "oprkind");
     i_oprcode = PQfnumber(res, "oprcode");
 
     for (i = 0; i < ntups; i++)
     {
         oprinfo[i].dobj.objType = DO_OPERATOR;
         oprinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
         oprinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
         AssignDumpId(&oprinfo[i].dobj);
         oprinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_oprname));
         oprinfo[i].dobj.namespace =
             findNamespace(fout,
                           atooid(PQgetvalue(res, i, i_oprnamespace)));
         oprinfo[i].rolname = pg_strdup(PQgetvalue(res, i, i_rolname));
         oprinfo[i].oprkind = (PQgetvalue(res, i, i_oprkind))[0];
         oprinfo[i].oprcode = atooid(PQgetvalue(res, i, i_oprcode));
 
         /* Decide whether we want to dump it */
         selectDumpableObject(&(oprinfo[i].dobj), fout);
 
         /* Operators do not currently have ACLs. */
         oprinfo[i].dobj.dump &= ~DUMP_COMPONENT_ACL;
 
         if (strlen(oprinfo[i].rolname) == 0)
             write_msg(NULL, "WARNING: owner of operator \"%s\" appears to be invalid\n",
                       oprinfo[i].dobj.name);
     }
 
     PQclear(res);
 
     destroyPQExpBuffer(query);
 
     return oprinfo;
 }

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

Definition at line 5054 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, NULL, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear(), PQfnumber(), PQgetvalue(), PQntuples(), Archive::remoteVersion, _opfamilyInfo::rolname, selectDumpableObject(), selectSourceSchema(), CatalogId::tableoid, username_subquery, and write_msg().

Referenced by getSchemaData().

 {
     PGresult   *res;
     int         ntups;
     int         i;
     PQExpBuffer query;
     OpfamilyInfo *opfinfo;
     int         i_tableoid;
     int         i_oid;
     int         i_opfname;
     int         i_opfnamespace;
     int         i_rolname;
 
     /* Before 8.3, there is no separate concept of opfamilies */
     if (fout->remoteVersion < 80300)
     {
         *numOpfamilies = 0;
         return NULL;
     }
 
     query = createPQExpBuffer();
 
     /*
      

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

Data Structures

Macros

Typedefs

Enumerations

Functions

Variables

Macro Definition Documentation

Typedef Documentation

Enumeration Type Documentation

Function Documentation