pg_dump.h File Reference

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

Include dependency graph for pg_dump.h:

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

Go to the source code of this file.

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

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

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

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

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

Macro Definition Documentation

DUMP_COMPONENT_ACL

#define DUMP_COMPONENT_ACL   (1 << 4)

Definition at line 113 of file pg_dump.h.

DUMP_COMPONENT_ALL

#define DUMP_COMPONENT_ALL   (0xFFFF)

Definition at line 117 of file pg_dump.h.

DUMP_COMPONENT_COMMENT

#define DUMP_COMPONENT_COMMENT   (1 << 2)

Definition at line 111 of file pg_dump.h.

DUMP_COMPONENT_DATA

#define DUMP_COMPONENT_DATA   (1 << 1)

Definition at line 110 of file pg_dump.h.

DUMP_COMPONENT_DEFINITION

#define DUMP_COMPONENT_DEFINITION   (1 << 0)

Definition at line 109 of file pg_dump.h.

DUMP_COMPONENT_NONE

#define DUMP_COMPONENT_NONE   (0)

Definition at line 108 of file pg_dump.h.

DUMP_COMPONENT_POLICY

#define DUMP_COMPONENT_POLICY   (1 << 5)

Definition at line 114 of file pg_dump.h.

DUMP_COMPONENT_SECLABEL

#define DUMP_COMPONENT_SECLABEL   (1 << 3)

Definition at line 112 of file pg_dump.h.

DUMP_COMPONENT_STATISTICS

#define DUMP_COMPONENT_STATISTICS   (1 << 7)

Definition at line 116 of file pg_dump.h.

DUMP_COMPONENT_USERMAP

#define DUMP_COMPONENT_USERMAP   (1 << 6)

Definition at line 115 of file pg_dump.h.

DUMP_COMPONENTS_REQUIRING_LOCK

#define DUMP_COMPONENTS_REQUIRING_LOCK

Value:

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

Definition at line 141 of file pg_dump.h.

NUM_DUMPABLE_OBJECT_TYPES

#define NUM_DUMPABLE_OBJECT_TYPES   (DO_SUBSCRIPTION_REL + 1)

Definition at line 91 of file pg_dump.h.

oidcmp

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

Definition at line 21 of file pg_dump.h.

Typedef Documentation

AccessMethodInfo

typedef struct _accessMethodInfo AccessMethodInfo

AggInfo

typedef struct _aggInfo AggInfo

AttrDefInfo

typedef struct _attrDefInfo AttrDefInfo

CastInfo

typedef struct _castInfo CastInfo

CollInfo

typedef struct _collInfo CollInfo

ConstraintInfo

typedef struct _constraintInfo ConstraintInfo

ConvInfo

typedef struct _convInfo ConvInfo

DefaultACLInfo

typedef struct _defaultACLInfo DefaultACLInfo

DumpableAcl

typedef struct _dumpableAcl DumpableAcl

DumpableObject

typedef struct _dumpableObject DumpableObject

DumpableObjectWithAcl

typedef struct _dumpableObjectWithAcl DumpableObjectWithAcl

DumpComponents

typedef uint32 DumpComponents

Definition at line 107 of file pg_dump.h.

EventTriggerInfo

typedef struct _evttriggerInfo EventTriggerInfo

ExtensionInfo

typedef struct _extensionInfo ExtensionInfo

FdwInfo

typedef struct _fdwInfo FdwInfo

ForeignServerInfo

typedef struct _foreignServerInfo ForeignServerInfo

FuncInfo

typedef struct _funcInfo FuncInfo

IndexAttachInfo

typedef struct _indexAttachInfo IndexAttachInfo

IndxInfo

typedef struct _indxInfo IndxInfo

InhInfo

typedef struct _inhInfo InhInfo

LoInfo

typedef struct _loInfo LoInfo

NamespaceInfo

typedef struct _namespaceInfo NamespaceInfo

OpclassInfo

typedef struct _opclassInfo OpclassInfo

OpfamilyInfo

typedef struct _opfamilyInfo OpfamilyInfo

OprInfo

typedef struct _oprInfo OprInfo

PolicyInfo

typedef struct _policyInfo PolicyInfo

ProcLangInfo

typedef struct _procLangInfo ProcLangInfo

PublicationInfo

typedef struct _PublicationInfo PublicationInfo

PublicationRelInfo

typedef struct _PublicationRelInfo PublicationRelInfo

PublicationSchemaInfo

typedef struct _PublicationSchemaInfo PublicationSchemaInfo

RelStatsInfo

typedef struct _relStatsInfo RelStatsInfo

RuleInfo

typedef struct _ruleInfo RuleInfo

ShellTypeInfo

typedef struct _shellTypeInfo ShellTypeInfo

StatsExtInfo

typedef struct _statsExtInfo StatsExtInfo

SubRelInfo

typedef struct _SubRelInfo SubRelInfo

SubscriptionInfo

typedef struct _SubscriptionInfo SubscriptionInfo

TableAttachInfo

typedef struct _tableAttachInfo TableAttachInfo

TableDataInfo

typedef struct _tableDataInfo TableDataInfo

TableInfo

typedef struct _tableInfo TableInfo

TransformInfo

typedef struct _transformInfo TransformInfo

TriggerInfo

typedef struct _triggerInfo TriggerInfo

TSConfigInfo

typedef struct _cfgInfo TSConfigInfo

TSDictInfo

typedef struct _dictInfo TSDictInfo

TSParserInfo

typedef struct _prsInfo TSParserInfo

TSTemplateInfo

typedef struct _tmplInfo TSTemplateInfo

TypeInfo

typedef struct _typeInfo TypeInfo

Enumeration Type Documentation

DumpableObjectType

enum DumpableObjectType

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

Definition at line 38 of file pg_dump.h.

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

Function Documentation

addObjectDependency()

void addObjectDependency	(	DumpableObject *	dobj,
		DumpId	refId
	)

Definition at line 818 of file common.c.

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

References _dumpableObject::allocDeps, _dumpableObject::dependencies, _dumpableObject::nDeps, pg_malloc_array, and pg_realloc_array.

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

AssignDumpId()

void AssignDumpId

(

DumpableObject *

dobj

)

Definition at line 657 of file common.c.

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

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

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

createDumpId()

DumpId createDumpId

(

void

)

Definition at line 745 of file common.c.

{
    return ++lastDumpId;
}

References lastDumpId.

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

findAccessMethodByOid()

AccessMethodInfo * findAccessMethodByOid

(

Oid

oid

)

Definition at line 954 of file common.c.

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

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

Referenced by accessMethodNameCompare().

findCollationByOid()

CollInfo * findCollationByOid

(

Oid

oid

)

Definition at line 972 of file common.c.

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

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

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

findExtensionByOid()

ExtensionInfo * findExtensionByOid

(

Oid

oid

)

Definition at line 1008 of file common.c.

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

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

Referenced by getExtensionMembership().

findFuncByOid()

FuncInfo * findFuncByOid

(

Oid

oid

)

Definition at line 918 of file common.c.

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

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

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

findNamespaceByOid()

NamespaceInfo * findNamespaceByOid

(

Oid

oid

)

Definition at line 990 of file common.c.

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

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

Referenced by findNamespace(), and getPublicationNamespaces().

findObjectByCatalogId()

DumpableObject * findObjectByCatalogId

(

CatalogId

catalogId

)

Definition at line 778 of file common.c.

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

References catalogIdHash, and _catalogIdMapEntry::dobj.

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

findObjectByDumpId()

DumpableObject * findObjectByDumpId

(

DumpId

dumpId

)

Definition at line 765 of file common.c.

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

References allocedDumpIds, and dumpIdMap.

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

findOprByOid()

OprInfo * findOprByOid

(

Oid

oid

)

Definition at line 936 of file common.c.

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

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

Referenced by getFormattedOperatorName().

findOwningExtension()

ExtensionInfo * findOwningExtension

(

CatalogId

catalogId

)

Definition at line 1087 of file common.c.

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

References catalogIdHash, and _catalogIdMapEntry::ext.

Referenced by checkExtensionMembership().

findPublicationByOid()

PublicationInfo * findPublicationByOid

(

Oid

oid

)

Definition at line 1026 of file common.c.

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

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

Referenced by getPublicationNamespaces(), and getPublicationTables().

findSubscriptionByOid()

SubscriptionInfo * findSubscriptionByOid

(

Oid

oid

)

Definition at line 1044 of file common.c.

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

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

Referenced by getSubscriptionRelations().

findTableByOid()

TableInfo * findTableByOid

(

Oid

oid

)

Definition at line 863 of file common.c.

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

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

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

findTypeByOid()

TypeInfo * findTypeByOid

(

Oid

oid

)

Definition at line 899 of file common.c.

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

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

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

getAccessMethods()

void getAccessMethods

(

Archive *

fout

)

Definition at line 6556 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    AccessMethodInfo *aminfo;
    int         i_tableoid;
    int         i_oid;
    int         i_amname;
    int         i_amhandler;
    int         i_amtype;
 
    query = createPQExpBuffer();
 
    /*
     * Select all access methods from pg_am table.  v9.6 introduced CREATE
     * ACCESS METHOD, so earlier versions usually have only built-in access
     * methods.  v9.6 also changed the access method API, replacing dozens of
     * pg_am columns with amhandler.  Even if a user created an access method
     * by "INSERT INTO pg_am", we have no way to translate pre-v9.6 pg_am
     * columns to a v9.6+ CREATE ACCESS METHOD.  Hence, before v9.6, read
     * pg_am just to facilitate findAccessMethodByOid() providing the
     * OID-to-name mapping.
     */
    appendPQExpBufferStr(query, "SELECT tableoid, oid, amname, ");
    if (fout->remoteVersion >= 90600)
        appendPQExpBufferStr(query,
                             "amtype, "
                             "amhandler::pg_catalog.regproc AS amhandler ");
    else
        appendPQExpBufferStr(query,
                             "'i'::pg_catalog.\"char\" AS amtype, "
                             "'-'::pg_catalog.regproc AS amhandler ");
    appendPQExpBufferStr(query, "FROM pg_am");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    aminfo = (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);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

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

Referenced by getSchemaData().

getAggregates()

void getAggregates

(

Archive *

fout

)

Definition at line 6758 of file pg_dump.c.

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

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

Referenced by getSchemaData().

getCasts()

void getCasts

(

Archive *

fout

)

Definition at line 9026 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    CastInfo   *castinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_castsource;
    int         i_casttarget;
    int         i_castfunc;
    int         i_castcontext;
    int         i_castmethod;
 
    if (fout->remoteVersion >= 140000)
    {
        appendPQExpBufferStr(query, "SELECT tableoid, oid, "
                             "castsource, casttarget, castfunc, castcontext, "
                             "castmethod "
                             "FROM pg_cast c "
                             "WHERE NOT EXISTS ( "
                             "SELECT 1 FROM pg_range r "
                             "WHERE c.castsource = r.rngtypid "
                             "AND c.casttarget = r.rngmultitypid "
                             ") "
                             "ORDER BY 3,4");
    }
    else
    {
        appendPQExpBufferStr(query, "SELECT tableoid, oid, "
                             "castsource, casttarget, castfunc, castcontext, "
                             "castmethod "
                             "FROM pg_cast ORDER BY 3,4");
    }
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    castinfo = (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);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

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, ExecuteSqlQuery(), findTypeByOid(), i, initPQExpBuffer(), _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, Archive::remoteVersion, selectDumpableCast(), and CatalogId::tableoid.

Referenced by getSchemaData().

getCollations()

void getCollations

(

Archive *

fout

)

Definition at line 6428 of file pg_dump.c.

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

References appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, _collInfo::collencoding, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_COLLATION, _collInfo::dobj, ExecuteSqlQuery(), findNamespace(), getRoleName(), i, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, _collInfo::rolname, selectDumpableObject(), and CatalogId::tableoid.

Referenced by getSchemaData().

getConstraints()

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

Definition at line 8277 of file pg_dump.c.

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

References addConstrChildIdxDeps(), appendPQExpBuffer(), appendPQExpBufferChar(), appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, _constraintInfo::condef, _constraintInfo::condeferrable, _constraintInfo::condeferred, _constraintInfo::condomain, _constraintInfo::confrelid, _constraintInfo::conindex, _constraintInfo::conislocal, _constraintInfo::contable, _constraintInfo::contype, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_FK_CONSTRAINT, _tableInfo::dobj, _indxInfo::dobj, _constraintInfo::dobj, DUMP_COMPONENT_DEFINITION, ExecuteSqlQuery(), findTableByOid(), i, _tableInfo::indexes, InvalidOid, j, PQExpBufferData::len, _dumpableObject::name, _tableInfo::numIndexes, _dumpableObject::objType, CatalogId::oid, pg_fatal, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, _tableInfo::relkind, Archive::remoteVersion, _constraintInfo::separate, CatalogId::tableoid, and tinfo.

Referenced by getSchemaData().

getConversions()

void getConversions

(

Archive *

fout

)

Definition at line 6494 of file pg_dump.c.

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

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

Referenced by getSchemaData().

getDefaultACLs()

void getDefaultACLs

(

Archive *

fout

)

Definition at line 10569 of file pg_dump.c.

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

References _dumpableAcl::acl, _dumpableAcl::acldefault, appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, _dumpableObject::components, createPQExpBuffer(), _defaultACLInfo::dacl, PQExpBufferData::data, _defaultACLInfo::defaclobjtype, _defaultACLInfo::defaclrole, destroyPQExpBuffer(), DO_DEFAULT_ACL, _defaultACLInfo::dobj, Archive::dopt, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), findNamespace(), getRoleName(), i, _dumpableAcl::initprivs, InvalidOid, _dumpableObject::name, nspid, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, _dumpableAcl::privtype, selectDumpableDefaultACL(), and CatalogId::tableoid.

Referenced by getSchemaData().

getDumpableObjects()

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

Definition at line 797 of file common.c.

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

References allocedDumpIds, dumpIdMap, i, j, and pg_malloc_array.

Referenced by getTableDataFKConstraints(), and main().

getEventTriggers()

void getEventTriggers

(

Archive *

fout

)

Definition at line 8864 of file pg_dump.c.

{
    int         i;
    PQExpBuffer query;
    PGresult   *res;
    EventTriggerInfo *evtinfo;
    int         i_tableoid,
                i_oid,
                i_evtname,
                i_evtevent,
                i_evtowner,
                i_evttags,
                i_evtfname,
                i_evtenabled;
    int         ntups;
 
    /* Before 9.3, there are no event triggers */
    if (fout->remoteVersion < 90300)
        return;
 
    query = createPQExpBuffer();
 
    appendPQExpBufferStr(query,
                         "SELECT e.tableoid, e.oid, evtname, evtenabled, "
                         "evtevent, evtowner, "
                         "array_to_string(array("
                         "select quote_literal(x) "
                         " from unnest(evttags) as t(x)), ', ') as evttags, "
                         "e.evtfoid::regproc as evtfname "
                         "FROM pg_event_trigger e "
                         "ORDER BY e.oid");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    evtinfo = (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 = getRoleName(PQgetvalue(res, i, i_evtowner));
        evtinfo[i].evttags = pg_strdup(PQgetvalue(res, i, i_evttags));
        evtinfo[i].evtfname = pg_strdup(PQgetvalue(res, i, i_evtfname));
        evtinfo[i].evtenabled = *(PQgetvalue(res, i, i_evtenabled));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(evtinfo[i].dobj), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

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

Referenced by getSchemaData().

getExtendedStatistics()

void getExtendedStatistics

(

Archive *

fout

)

Definition at line 8198 of file pg_dump.c.

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

References appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_STATSEXT, _statsExtInfo::dobj, ExecuteSqlQuery(), findNamespace(), findTableByOid(), getRoleName(), i, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, Archive::remoteVersion, _statsExtInfo::rolname, selectDumpableStatisticsObject(), _statsExtInfo::stattable, _statsExtInfo::stattarget, and CatalogId::tableoid.

Referenced by getSchemaData().

getExtensionMembership()

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

Definition at line 19672 of file pg_dump.c.

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

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

Referenced by getSchemaData().

getExtensions()

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

Definition at line 6109 of file pg_dump.c.

{
    DumpOptions *dopt = fout->dopt;
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    ExtensionInfo *extinfo = NULL;
    int         i_tableoid;
    int         i_oid;
    int         i_extname;
    int         i_nspname;
    int         i_extrelocatable;
    int         i_extversion;
    int         i_extconfig;
    int         i_extcondition;
 
    query = createPQExpBuffer();
 
    appendPQExpBufferStr(query, "SELECT x.tableoid, x.oid, "
                         "x.extname, n.nspname, x.extrelocatable, x.extversion, x.extconfig, x.extcondition "
                         "FROM pg_extension x "
                         "JOIN pg_namespace n ON n.oid = x.extnamespace");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
    if (ntups == 0)
        goto cleanup;
 
    extinfo = (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);
    }
 
cleanup:
    PQclear(res);
    destroyPQExpBuffer(query);
 
    *numExtensions = ntups;
 
    return extinfo;
}

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

Referenced by getSchemaData().

getForeignDataWrappers()

void getForeignDataWrappers

(

Archive *

fout

)

Definition at line 10397 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    FdwInfo    *fdwinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_fdwname;
    int         i_fdwowner;
    int         i_fdwhandler;
    int         i_fdwvalidator;
    int         i_fdwacl;
    int         i_acldefault;
    int         i_fdwoptions;
 
    query = createPQExpBuffer();
 
    appendPQExpBufferStr(query, "SELECT tableoid, oid, fdwname, "
                         "fdwowner, "
                         "fdwhandler::pg_catalog.regproc, "
                         "fdwvalidator::pg_catalog.regproc, "
                         "fdwacl, "
                         "acldefault('F', fdwowner) AS acldefault, "
                         "array_to_string(ARRAY("
                         "SELECT quote_ident(option_name) || ' ' || "
                         "quote_literal(option_value) "
                         "FROM pg_options_to_table(fdwoptions) "
                         "ORDER BY option_name"
                         "), E',\n    ') AS fdwoptions "
                         "FROM pg_foreign_data_wrapper");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    fdwinfo = (FdwInfo *) pg_malloc(ntups * sizeof(FdwInfo));
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_fdwname = PQfnumber(res, "fdwname");
    i_fdwowner = PQfnumber(res, "fdwowner");
    i_fdwhandler = PQfnumber(res, "fdwhandler");
    i_fdwvalidator = PQfnumber(res, "fdwvalidator");
    i_fdwacl = PQfnumber(res, "fdwacl");
    i_acldefault = PQfnumber(res, "acldefault");
    i_fdwoptions = PQfnumber(res, "fdwoptions");
 
    for (i = 0; i < ntups; i++)
    {
        fdwinfo[i].dobj.objType = DO_FDW;
        fdwinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        fdwinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&fdwinfo[i].dobj);
        fdwinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_fdwname));
        fdwinfo[i].dobj.namespace = NULL;
        fdwinfo[i].dacl.acl = pg_strdup(PQgetvalue(res, i, i_fdwacl));
        fdwinfo[i].dacl.acldefault = pg_strdup(PQgetvalue(res, i, i_acldefault));
        fdwinfo[i].dacl.privtype = 0;
        fdwinfo[i].dacl.initprivs = NULL;
        fdwinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_fdwowner));
        fdwinfo[i].fdwhandler = pg_strdup(PQgetvalue(res, i, i_fdwhandler));
        fdwinfo[i].fdwvalidator = pg_strdup(PQgetvalue(res, i, i_fdwvalidator));
        fdwinfo[i].fdwoptions = pg_strdup(PQgetvalue(res, i, i_fdwoptions));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(fdwinfo[i].dobj), fout);
 
        /* Mark whether FDW has an ACL */
        if (!PQgetisnull(res, i, i_fdwacl))
            fdwinfo[i].dobj.components |= DUMP_COMPONENT_ACL;
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References _dumpableAcl::acl, _dumpableAcl::acldefault, appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, _dumpableObject::components, createPQExpBuffer(), _fdwInfo::dacl, PQExpBufferData::data, destroyPQExpBuffer(), DO_FDW, _fdwInfo::dobj, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), _fdwInfo::fdwhandler, _fdwInfo::fdwoptions, _fdwInfo::fdwvalidator, getRoleName(), i, _dumpableAcl::initprivs, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, _dumpableAcl::privtype, _fdwInfo::rolname, selectDumpableObject(), and CatalogId::tableoid.

Referenced by getSchemaData().

getForeignServers()

void getForeignServers

(

Archive *

fout

)

Definition at line 10481 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    ForeignServerInfo *srvinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_srvname;
    int         i_srvowner;
    int         i_srvfdw;
    int         i_srvtype;
    int         i_srvversion;
    int         i_srvacl;
    int         i_acldefault;
    int         i_srvoptions;
 
    query = createPQExpBuffer();
 
    appendPQExpBufferStr(query, "SELECT tableoid, oid, srvname, "
                         "srvowner, "
                         "srvfdw, srvtype, srvversion, srvacl, "
                         "acldefault('S', srvowner) AS acldefault, "
                         "array_to_string(ARRAY("
                         "SELECT quote_ident(option_name) || ' ' || "
                         "quote_literal(option_value) "
                         "FROM pg_options_to_table(srvoptions) "
                         "ORDER BY option_name"
                         "), E',\n    ') AS srvoptions "
                         "FROM pg_foreign_server");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    srvinfo = (ForeignServerInfo *) pg_malloc(ntups * sizeof(ForeignServerInfo));
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_srvname = PQfnumber(res, "srvname");
    i_srvowner = PQfnumber(res, "srvowner");
    i_srvfdw = PQfnumber(res, "srvfdw");
    i_srvtype = PQfnumber(res, "srvtype");
    i_srvversion = PQfnumber(res, "srvversion");
    i_srvacl = PQfnumber(res, "srvacl");
    i_acldefault = PQfnumber(res, "acldefault");
    i_srvoptions = PQfnumber(res, "srvoptions");
 
    for (i = 0; i < ntups; i++)
    {
        srvinfo[i].dobj.objType = DO_FOREIGN_SERVER;
        srvinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        srvinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&srvinfo[i].dobj);
        srvinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_srvname));
        srvinfo[i].dobj.namespace = NULL;
        srvinfo[i].dacl.acl = pg_strdup(PQgetvalue(res, i, i_srvacl));
        srvinfo[i].dacl.acldefault = pg_strdup(PQgetvalue(res, i, i_acldefault));
        srvinfo[i].dacl.privtype = 0;
        srvinfo[i].dacl.initprivs = NULL;
        srvinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_srvowner));
        srvinfo[i].srvfdw = atooid(PQgetvalue(res, i, i_srvfdw));
        srvinfo[i].srvtype = pg_strdup(PQgetvalue(res, i, i_srvtype));
        srvinfo[i].srvversion = pg_strdup(PQgetvalue(res, i, i_srvversion));
        srvinfo[i].srvoptions = pg_strdup(PQgetvalue(res, i, i_srvoptions));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(srvinfo[i].dobj), fout);
 
        /* Servers have user mappings */
        srvinfo[i].dobj.components |= DUMP_COMPONENT_USERMAP;
 
        /* Mark whether server has an ACL */
        if (!PQgetisnull(res, i, i_srvacl))
            srvinfo[i].dobj.components |= DUMP_COMPONENT_ACL;
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References _dumpableAcl::acl, _dumpableAcl::acldefault, appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, _dumpableObject::components, createPQExpBuffer(), _foreignServerInfo::dacl, PQExpBufferData::data, destroyPQExpBuffer(), DO_FOREIGN_SERVER, _foreignServerInfo::dobj, DUMP_COMPONENT_ACL, DUMP_COMPONENT_USERMAP, ExecuteSqlQuery(), getRoleName(), i, _dumpableAcl::initprivs, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, _dumpableAcl::privtype, _foreignServerInfo::rolname, selectDumpableObject(), _foreignServerInfo::srvfdw, _foreignServerInfo::srvoptions, _foreignServerInfo::srvtype, _foreignServerInfo::srvversion, and CatalogId::tableoid.

Referenced by getSchemaData().

getFuncs()

void getFuncs

(

Archive *

fout

)

Definition at line 6899 of file pg_dump.c.

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

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

Referenced by getSchemaData().

getIndexes()

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

Definition at line 7829 of file pg_dump.c.

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

References addObjectDependency(), appendPQExpBuffer(), appendPQExpBufferChar(), appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, _constraintInfo::condef, _constraintInfo::condeferrable, _constraintInfo::condeferred, _constraintInfo::condomain, _constraintInfo::confrelid, _constraintInfo::conindex, _constraintInfo::conislocal, _constraintInfo::conperiod, _constraintInfo::contable, _constraintInfo::contype, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_CONSTRAINT, DO_INDEX, _tableInfo::dobj, _indxInfo::dobj, _relStatsInfo::dobj, _constraintInfo::dobj, _dumpableObject::dump, _dumpableObject::dumpId, ExecuteSqlQuery(), getRelationStatistics(), _tableInfo::hasindex, i, _indxInfo::indexconstraint, _indxInfo::indexdef, _tableInfo::indexes, _indxInfo::indextable, _indxInfo::indisclustered, _indxInfo::indisreplident, _indxInfo::indkeys, _indxInfo::indnattrs, _indxInfo::indnkeyattrs, _indxInfo::indnullsnotdistinct, _indxInfo::indreloptions, _indxInfo::indstatcols, _indxInfo::indstatvals, _tableInfo::interesting, InvalidOid, j, PQExpBufferData::len, _dumpableObject::name, _tableInfo::numIndexes, _dumpableObject::objType, CatalogId::oid, _indxInfo::parentidx, parseOidArray(), parsePGArray(), _indxInfo::partattaches, pg_fatal, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, Archive::remoteVersion, _constraintInfo::separate, CatalogId::tableoid, and _indxInfo::tablespace.

Referenced by getSchemaData().

getInherits()

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

Definition at line 7713 of file pg_dump.c.

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

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

Referenced by getSchemaData().

getMaxDumpId()

DumpId getMaxDumpId

(

void

)

Definition at line 754 of file common.c.

{
    return lastDumpId;
}

References lastDumpId.

Referenced by findDependencyLoops(), and TopoSort().

getNamespaces()

void getNamespaces

(

Archive *

fout

)

Definition at line 5977 of file pg_dump.c.

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

References _dumpableAcl::acl, _dumpableAcl::acldefault, appendPGArray(), appendPQExpBufferChar(), appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, _dumpableObject::components, createPQExpBuffer(), _namespaceInfo::dacl, PQExpBufferData::data, destroyPQExpBuffer(), DO_NAMESPACE, _namespaceInfo::dobj, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), getRoleName(), i, _dumpableAcl::initprivs, _dumpableObject::name, _namespaceInfo::nspowner, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, _dumpableAcl::privtype, pstrdup(), quoteAclUserName(), resetPQExpBuffer(), _namespaceInfo::rolname, rolname, selectDumpableNamespace(), and CatalogId::tableoid.

Referenced by getSchemaData().

getOpclasses()

void getOpclasses

(

Archive *

fout

)

Definition at line 6630 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    OpclassInfo *opcinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_opcmethod;
    int         i_opcname;
    int         i_opcnamespace;
    int         i_opcowner;
 
    /*
     * find all opclasses, including builtin opclasses; we filter out
     * system-defined opclasses at dump-out time.
     */
 
    appendPQExpBufferStr(query, "SELECT tableoid, oid, opcmethod, opcname, "
                         "opcnamespace, "
                         "opcowner "
                         "FROM pg_opclass");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    opcinfo = (OpclassInfo *) pg_malloc(ntups * sizeof(OpclassInfo));
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_opcmethod = PQfnumber(res, "opcmethod");
    i_opcname = PQfnumber(res, "opcname");
    i_opcnamespace = PQfnumber(res, "opcnamespace");
    i_opcowner = PQfnumber(res, "opcowner");
 
    for (i = 0; i < ntups; i++)
    {
        opcinfo[i].dobj.objType = DO_OPCLASS;
        opcinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        opcinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&opcinfo[i].dobj);
        opcinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_opcname));
        opcinfo[i].dobj.namespace =
            findNamespace(atooid(PQgetvalue(res, i, i_opcnamespace)));
        opcinfo[i].opcmethod = atooid(PQgetvalue(res, i, i_opcmethod));
        opcinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_opcowner));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(opcinfo[i].dobj), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_OPCLASS, _opclassInfo::dobj, ExecuteSqlQuery(), findNamespace(), getRoleName(), i, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, _opclassInfo::opcmethod, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, _opclassInfo::rolname, selectDumpableObject(), and CatalogId::tableoid.

Referenced by getSchemaData().

getOperators()

void getOperators

(

Archive *

fout

)

Definition at line 6352 of file pg_dump.c.

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

References appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_OPERATOR, _oprInfo::dobj, ExecuteSqlQuery(), findNamespace(), getRoleName(), i, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, _oprInfo::oprcode, _oprInfo::oprkind, _oprInfo::oprleft, _oprInfo::oprright, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, _oprInfo::rolname, selectDumpableObject(), and CatalogId::tableoid.

Referenced by getSchemaData().

getOpfamilies()

void getOpfamilies

(

Archive *

fout

)

Definition at line 6693 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    OpfamilyInfo *opfinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_opfmethod;
    int         i_opfname;
    int         i_opfnamespace;
    int         i_opfowner;
 
    query = createPQExpBuffer();
 
    /*
     * find all opfamilies, including builtin opfamilies; we filter out
     * system-defined opfamilies at dump-out time.
     */
 
    appendPQExpBufferStr(query, "SELECT tableoid, oid, opfmethod, opfname, "
                         "opfnamespace, "
                         "opfowner "
                         "FROM pg_opfamily");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    opfinfo = (OpfamilyInfo *) pg_malloc(ntups * sizeof(OpfamilyInfo));
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_opfname = PQfnumber(res, "opfname");
    i_opfmethod = PQfnumber(res, "opfmethod");
    i_opfnamespace = PQfnumber(res, "opfnamespace");
    i_opfowner = PQfnumber(res, "opfowner");
 
    for (i = 0; i < ntups; i++)
    {
        opfinfo[i].dobj.objType = DO_OPFAMILY;
        opfinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        opfinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&opfinfo[i].dobj);
        opfinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_opfname));
        opfinfo[i].dobj.namespace =
            findNamespace(atooid(PQgetvalue(res, i, i_opfnamespace)));
        opfinfo[i].opfmethod = atooid(PQgetvalue(res, i, i_opfmethod));
        opfinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_opfowner));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(opfinfo[i].dobj), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_OPFAMILY, _opfamilyInfo::dobj, ExecuteSqlQuery(), findNamespace(), getRoleName(), i, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, _opfamilyInfo::opfmethod, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, _opfamilyInfo::rolname, selectDumpableObject(), and CatalogId::tableoid.

Referenced by getSchemaData().

getOwnedSeqs()

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

Definition at line 7648 of file pg_dump.c.

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

References _dumpableObject::catId, _tableInfo::dobj, _dumpableObject::dump, DUMP_COMPONENT_NONE, findTableByOid(), i, _tableInfo::interesting, _tableInfo::is_identity_sequence, CatalogId::oid, OidIsValid, _tableInfo::owning_tab, and pg_fatal.

Referenced by getSchemaData().

getPartitioningInfo()

void getPartitioningInfo

(

Archive *

fout

)

Definition at line 7769 of file pg_dump.c.

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

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

Referenced by getSchemaData().

getPolicies()

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

Definition at line 4233 of file pg_dump.c.

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

References appendPQExpBuffer(), appendPQExpBufferChar(), appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, _dumpableObject::components, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_POLICY, _tableInfo::dobj, _policyInfo::dobj, Archive::dopt, _dumpableObject::dump, DUMP_COMPONENT_POLICY, ExecuteSqlQuery(), findTableByOid(), i, j, PQExpBufferData::len, _dumpableObject::name, _dumpOptions::no_policies, _dumpableObject::objType, CatalogId::oid, pg_log_info, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, _policyInfo::polcmd, _policyInfo::polname, _policyInfo::polpermissive, _policyInfo::polqual, _policyInfo::polroles, _policyInfo::poltable, _policyInfo::polwithcheck, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, printfPQExpBuffer(), _tableInfo::relkind, Archive::remoteVersion, _tableInfo::rowsec, and CatalogId::tableoid.

Referenced by getSchemaData().

getProcLangs()

void getProcLangs

(

Archive *

fout

)

Definition at line 8942 of file pg_dump.c.

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

References _dumpableAcl::acl, _dumpableAcl::acldefault, appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, _dumpableObject::components, createPQExpBuffer(), _procLangInfo::dacl, PQExpBufferData::data, destroyPQExpBuffer(), DO_PROCLANG, _procLangInfo::dobj, DUMP_COMPONENT_ACL, ExecuteSqlQuery(), getRoleName(), i, _dumpableAcl::initprivs, _procLangInfo::laninline, _procLangInfo::lanowner, _procLangInfo::lanplcallfoid, _procLangInfo::lanpltrusted, _procLangInfo::lanvalidator, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, _dumpableAcl::privtype, selectDumpableProcLang(), and CatalogId::tableoid.

Referenced by getSchemaData().

getPublicationNamespaces()

void getPublicationNamespaces

(

Archive *

fout

)

Definition at line 4742 of file pg_dump.c.

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

References appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_PUBLICATION_TABLE_IN_SCHEMA, _namespaceInfo::dobj, _PublicationSchemaInfo::dobj, Archive::dopt, ExecuteSqlQuery(), findNamespaceByOid(), findPublicationByOid(), i, j, _dumpableObject::name, _dumpOptions::no_publications, _dumpableObject::objType, CatalogId::oid, pg_malloc(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, _PublicationSchemaInfo::publication, _PublicationSchemaInfo::pubschema, Archive::remoteVersion, selectDumpablePublicationObject(), and CatalogId::tableoid.

Referenced by getSchemaData().

getPublications()

void getPublications

(

Archive *

fout

)

Definition at line 4523 of file pg_dump.c.

{
    DumpOptions *dopt = fout->dopt;
    PQExpBuffer query;
    PGresult   *res;
    PublicationInfo *pubinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_pubname;
    int         i_pubowner;
    int         i_puballtables;
    int         i_puballsequences;
    int         i_pubinsert;
    int         i_pubupdate;
    int         i_pubdelete;
    int         i_pubtruncate;
    int         i_pubviaroot;
    int         i_pubgencols;
    int         i,
                ntups;
 
    if (dopt->no_publications || fout->remoteVersion < 100000)
        return;
 
    query = createPQExpBuffer();
 
    /* Get the publications. */
    appendPQExpBufferStr(query, "SELECT p.tableoid, p.oid, p.pubname, "
                         "p.pubowner, p.puballtables, p.pubinsert, "
                         "p.pubupdate, p.pubdelete, ");
 
    if (fout->remoteVersion >= 110000)
        appendPQExpBufferStr(query, "p.pubtruncate, ");
    else
        appendPQExpBufferStr(query, "false AS pubtruncate, ");
 
    if (fout->remoteVersion >= 130000)
        appendPQExpBufferStr(query, "p.pubviaroot, ");
    else
        appendPQExpBufferStr(query, "false AS pubviaroot, ");
 
    if (fout->remoteVersion >= 180000)
        appendPQExpBufferStr(query, "p.pubgencols, ");
    else
        appendPQExpBuffer(query, "'%c' AS pubgencols, ", PUBLISH_GENCOLS_NONE);
 
    if (fout->remoteVersion >= 190000)
        appendPQExpBufferStr(query, "p.puballsequences ");
    else
        appendPQExpBufferStr(query, "false AS puballsequences ");
 
    appendPQExpBufferStr(query, "FROM pg_publication p");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    if (ntups == 0)
        goto cleanup;
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_pubname = PQfnumber(res, "pubname");
    i_pubowner = PQfnumber(res, "pubowner");
    i_puballtables = PQfnumber(res, "puballtables");
    i_puballsequences = PQfnumber(res, "puballsequences");
    i_pubinsert = PQfnumber(res, "pubinsert");
    i_pubupdate = PQfnumber(res, "pubupdate");
    i_pubdelete = PQfnumber(res, "pubdelete");
    i_pubtruncate = PQfnumber(res, "pubtruncate");
    i_pubviaroot = PQfnumber(res, "pubviaroot");
    i_pubgencols = PQfnumber(res, "pubgencols");
 
    pubinfo = pg_malloc(ntups * sizeof(PublicationInfo));
 
    for (i = 0; i < ntups; i++)
    {
        pubinfo[i].dobj.objType = DO_PUBLICATION;
        pubinfo[i].dobj.catId.tableoid =
            atooid(PQgetvalue(res, i, i_tableoid));
        pubinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&pubinfo[i].dobj);
        pubinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_pubname));
        pubinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_pubowner));
        pubinfo[i].puballtables =
            (strcmp(PQgetvalue(res, i, i_puballtables), "t") == 0);
        pubinfo[i].puballsequences =
            (strcmp(PQgetvalue(res, i, i_puballsequences), "t") == 0);
        pubinfo[i].pubinsert =
            (strcmp(PQgetvalue(res, i, i_pubinsert), "t") == 0);
        pubinfo[i].pubupdate =
            (strcmp(PQgetvalue(res, i, i_pubupdate), "t") == 0);
        pubinfo[i].pubdelete =
            (strcmp(PQgetvalue(res, i, i_pubdelete), "t") == 0);
        pubinfo[i].pubtruncate =
            (strcmp(PQgetvalue(res, i, i_pubtruncate), "t") == 0);
        pubinfo[i].pubviaroot =
            (strcmp(PQgetvalue(res, i, i_pubviaroot), "t") == 0);
        pubinfo[i].pubgencols_type =
            *(PQgetvalue(res, i, i_pubgencols));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(pubinfo[i].dobj), fout);
    }
 
cleanup:
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBuffer(), appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, cleanup(), createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_PUBLICATION, _PublicationInfo::dobj, Archive::dopt, ExecuteSqlQuery(), getRoleName(), i, _dumpableObject::name, _dumpOptions::no_publications, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, _PublicationInfo::puballsequences, _PublicationInfo::puballtables, _PublicationInfo::pubdelete, _PublicationInfo::pubgencols_type, _PublicationInfo::pubinsert, _PublicationInfo::pubtruncate, _PublicationInfo::pubupdate, _PublicationInfo::pubviaroot, Archive::remoteVersion, _PublicationInfo::rolname, selectDumpableObject(), and CatalogId::tableoid.

Referenced by getSchemaData().

getPublicationTables()

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

Definition at line 4822 of file pg_dump.c.

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

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

Referenced by getSchemaData().

getRules()

void getRules

(

Archive *

fout

)

Definition at line 8571 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    RuleInfo   *ruleinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_rulename;
    int         i_ruletable;
    int         i_ev_type;
    int         i_is_instead;
    int         i_ev_enabled;
 
    appendPQExpBufferStr(query, "SELECT "
                         "tableoid, oid, rulename, "
                         "ev_class AS ruletable, ev_type, is_instead, "
                         "ev_enabled "
                         "FROM pg_rewrite "
                         "ORDER BY oid");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    ruleinfo = (RuleInfo *) pg_malloc(ntups * sizeof(RuleInfo));
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_rulename = PQfnumber(res, "rulename");
    i_ruletable = PQfnumber(res, "ruletable");
    i_ev_type = PQfnumber(res, "ev_type");
    i_is_instead = PQfnumber(res, "is_instead");
    i_ev_enabled = PQfnumber(res, "ev_enabled");
 
    for (i = 0; i < ntups; i++)
    {
        Oid         ruletableoid;
 
        ruleinfo[i].dobj.objType = DO_RULE;
        ruleinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        ruleinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&ruleinfo[i].dobj);
        ruleinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_rulename));
        ruletableoid = atooid(PQgetvalue(res, i, i_ruletable));
        ruleinfo[i].ruletable = findTableByOid(ruletableoid);
        if (ruleinfo[i].ruletable == NULL)
            pg_fatal("failed sanity check, parent table with OID %u of pg_rewrite entry with OID %u not found",
                     ruletableoid, ruleinfo[i].dobj.catId.oid);
        ruleinfo[i].dobj.namespace = ruleinfo[i].ruletable->dobj.namespace;
        ruleinfo[i].dobj.dump = ruleinfo[i].ruletable->dobj.dump;
        ruleinfo[i].ev_type = *(PQgetvalue(res, i, i_ev_type));
        ruleinfo[i].is_instead = *(PQgetvalue(res, i, i_is_instead)) == 't';
        ruleinfo[i].ev_enabled = *(PQgetvalue(res, i, i_ev_enabled));
        if (ruleinfo[i].ruletable)
        {
            /*
             * If the table is a view or materialized view, force its ON
             * SELECT rule to be sorted before the view itself --- this
             * ensures that any dependencies for the rule affect the table's
             * positioning. Other rules are forced to appear after their
             * table.
             */
            if ((ruleinfo[i].ruletable->relkind == RELKIND_VIEW ||
                 ruleinfo[i].ruletable->relkind == RELKIND_MATVIEW) &&
                ruleinfo[i].ev_type == '1' && ruleinfo[i].is_instead)
            {
                addObjectDependency(&ruleinfo[i].ruletable->dobj,
                                    ruleinfo[i].dobj.dumpId);
                /* We'll merge the rule into CREATE VIEW, if possible */
                ruleinfo[i].separate = false;
            }
            else
            {
                addObjectDependency(&ruleinfo[i].dobj,
                                    ruleinfo[i].ruletable->dobj.dumpId);
                ruleinfo[i].separate = true;
            }
        }
        else
            ruleinfo[i].separate = true;
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References addObjectDependency(), appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_RULE, _tableInfo::dobj, _ruleInfo::dobj, _dumpableObject::dump, _dumpableObject::dumpId, _ruleInfo::ev_enabled, _ruleInfo::ev_type, ExecuteSqlQuery(), findTableByOid(), i, _ruleInfo::is_instead, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_fatal, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, _tableInfo::relkind, _ruleInfo::ruletable, _ruleInfo::separate, and CatalogId::tableoid.

Referenced by getSchemaData().

getSchemaData()

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

Definition at line 98 of file common.c.

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

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

Referenced by main().

getSubscriptionRelations()

void getSubscriptionRelations

(

Archive *

fout

)

Definition at line 5313 of file pg_dump.c.

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

References AssignDumpId(), atooid, _dumpOptions::binary_upgrade, _dumpableObject::catId, cleanup(), DO_SUBSCRIPTION_REL, _SubscriptionInfo::dobj, _SubRelInfo::dobj, Archive::dopt, ExecuteSqlQuery(), findSubscriptionByOid(), findTableByOid(), i, InvalidOid, _dumpableObject::name, _dumpOptions::no_subscriptions, _dumpableObject::objType, CatalogId::oid, pg_fatal, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, Archive::remoteVersion, selectDumpableObject(), _SubRelInfo::srsublsn, _SubRelInfo::srsubstate, _SubRelInfo::subinfo, CatalogId::tableoid, and _SubRelInfo::tblinfo.

Referenced by getSchemaData().

getSubscriptions()

void getSubscriptions

(

Archive *

fout

)

Definition at line 5093 of file pg_dump.c.

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

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

Referenced by getSchemaData().

getTableAttrs()

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

Definition at line 9220 of file pg_dump.c.

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

References addObjectDependency(), _attrDefInfo::adef_expr, _attrDefInfo::adnum, _attrDefInfo::adtable, appendPQExpBuffer(), appendPQExpBufferChar(), appendPQExpBufferStr(), AssignDumpId(), atooid, _tableInfo::attalign, _tableInfo::attcollation, _tableInfo::attcompression, _tableInfo::attfdwoptions, _tableInfo::attgenerated, _tableInfo::attidentity, _tableInfo::attisdropped, _tableInfo::attislocal, _tableInfo::attlen, _tableInfo::attmissingval, _tableInfo::attnames, _tableInfo::attoptions, _tableInfo::attrdefs, _tableInfo::attstattarget, _tableInfo::attstorage, _tableInfo::atttypnames, _dumpOptions::binary_upgrade, _dumpableObject::catId, _tableInfo::checkexprs, _constraintInfo::condef, _constraintInfo::condeferrable, _constraintInfo::condeferred, _constraintInfo::condomain, _constraintInfo::confrelid, _constraintInfo::conindex, _constraintInfo::conislocal, _constraintInfo::contable, _constraintInfo::contype, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), determineNotNullFlags(), DO_ATTRDEF, DO_CONSTRAINT, _tableInfo::dobj, _attrDefInfo::dobj, _constraintInfo::dobj, Archive::dopt, _dumpableObject::dump, _dumpableObject::dumpId, _dumpOptions::dumpSchema, ExecuteSqlQuery(), exit_nicely(), i, _tableInfo::interesting, InvalidOid, j, PQExpBufferData::len, _dumpableObject::name, _tableInfo::ncheck, _tableInfo::needs_override, ngettext, _tableInfo::notnull_comment, _tableInfo::notnull_constrs, _tableInfo::notnull_invalid, _tableInfo::notnull_islocal, _tableInfo::notnull_noinh, _tableInfo::numatts, _dumpableObject::objType, CatalogId::oid, pg_fatal, pg_log_error, pg_log_error_hint, pg_log_info, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, printfPQExpBuffer(), _tableInfo::relkind, Archive::remoteVersion, resetPQExpBuffer(), _attrDefInfo::separate, _constraintInfo::separate, shouldPrintColumn(), CatalogId::tableoid, and _tableInfo::typstorage.

Referenced by getSchemaData().

getTables()

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

Definition at line 7171 of file pg_dump.c.

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

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

Referenced by getSchemaData().

getTransforms()

void getTransforms

(

Archive *

fout

)

Definition at line 9136 of file pg_dump.c.

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

References appendPQExpBuffer(), appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_TRANSFORM, _typeInfo::dobj, _transformInfo::dobj, ExecuteSqlQuery(), findTypeByOid(), free, get_language_name(), i, initPQExpBuffer(), _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, Archive::remoteVersion, selectDumpableObject(), CatalogId::tableoid, _transformInfo::trffromsql, _transformInfo::trflang, _transformInfo::trftosql, and _transformInfo::trftype.

Referenced by getSchemaData().

getTriggers()

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

Definition at line 8668 of file pg_dump.c.

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

References appendPQExpBuffer(), appendPQExpBufferChar(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_TRIGGER, _tableInfo::dobj, _triggerInfo::dobj, _dumpableObject::dump, DUMP_COMPONENT_DEFINITION, ExecuteSqlQuery(), _tableInfo::hastriggers, i, j, PQExpBufferData::len, _dumpableObject::name, _tableInfo::numTriggers, _dumpableObject::objType, CatalogId::oid, pg_fatal, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, Archive::remoteVersion, CatalogId::tableoid, _triggerInfo::tgdef, _triggerInfo::tgenabled, _triggerInfo::tgispartition, _triggerInfo::tgtable, and _tableInfo::triggers.

Referenced by getSchemaData().

getTSConfigurations()

void getTSConfigurations

(

Archive *

fout

)

Definition at line 10338 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    TSConfigInfo *cfginfo;
    int         i_tableoid;
    int         i_oid;
    int         i_cfgname;
    int         i_cfgnamespace;
    int         i_cfgowner;
    int         i_cfgparser;
 
    query = createPQExpBuffer();
 
    appendPQExpBufferStr(query, "SELECT tableoid, oid, cfgname, "
                         "cfgnamespace, cfgowner, cfgparser "
                         "FROM pg_ts_config");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    cfginfo = (TSConfigInfo *) pg_malloc(ntups * sizeof(TSConfigInfo));
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_cfgname = PQfnumber(res, "cfgname");
    i_cfgnamespace = PQfnumber(res, "cfgnamespace");
    i_cfgowner = PQfnumber(res, "cfgowner");
    i_cfgparser = PQfnumber(res, "cfgparser");
 
    for (i = 0; i < ntups; i++)
    {
        cfginfo[i].dobj.objType = DO_TSCONFIG;
        cfginfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        cfginfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&cfginfo[i].dobj);
        cfginfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_cfgname));
        cfginfo[i].dobj.namespace =
            findNamespace(atooid(PQgetvalue(res, i, i_cfgnamespace)));
        cfginfo[i].rolname = getRoleName(PQgetvalue(res, i, i_cfgowner));
        cfginfo[i].cfgparser = atooid(PQgetvalue(res, i, i_cfgparser));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(cfginfo[i].dobj), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, _cfgInfo::cfgparser, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_TSCONFIG, _cfgInfo::dobj, ExecuteSqlQuery(), findNamespace(), getRoleName(), i, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, _cfgInfo::rolname, selectDumpableObject(), and CatalogId::tableoid.

Referenced by getSchemaData().

getTSDictionaries()

void getTSDictionaries

(

Archive *

fout

)

Definition at line 10213 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    TSDictInfo *dictinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_dictname;
    int         i_dictnamespace;
    int         i_dictowner;
    int         i_dicttemplate;
    int         i_dictinitoption;
 
    query = createPQExpBuffer();
 
    appendPQExpBufferStr(query, "SELECT tableoid, oid, dictname, "
                         "dictnamespace, dictowner, "
                         "dicttemplate, dictinitoption "
                         "FROM pg_ts_dict");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    dictinfo = (TSDictInfo *) pg_malloc(ntups * sizeof(TSDictInfo));
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_dictname = PQfnumber(res, "dictname");
    i_dictnamespace = PQfnumber(res, "dictnamespace");
    i_dictowner = PQfnumber(res, "dictowner");
    i_dictinitoption = PQfnumber(res, "dictinitoption");
    i_dicttemplate = PQfnumber(res, "dicttemplate");
 
    for (i = 0; i < ntups; i++)
    {
        dictinfo[i].dobj.objType = DO_TSDICT;
        dictinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        dictinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&dictinfo[i].dobj);
        dictinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_dictname));
        dictinfo[i].dobj.namespace =
            findNamespace(atooid(PQgetvalue(res, i, i_dictnamespace)));
        dictinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_dictowner));
        dictinfo[i].dicttemplate = atooid(PQgetvalue(res, i, i_dicttemplate));
        if (PQgetisnull(res, i, i_dictinitoption))
            dictinfo[i].dictinitoption = NULL;
        else
            dictinfo[i].dictinitoption = pg_strdup(PQgetvalue(res, i, i_dictinitoption));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(dictinfo[i].dobj), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), _dictInfo::dictinitoption, _dictInfo::dicttemplate, DO_TSDICT, _dictInfo::dobj, ExecuteSqlQuery(), findNamespace(), getRoleName(), i, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, _dictInfo::rolname, selectDumpableObject(), and CatalogId::tableoid.

Referenced by getSchemaData().

getTSParsers()

void getTSParsers

(

Archive *

fout

)

Definition at line 10139 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    TSParserInfo *prsinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_prsname;
    int         i_prsnamespace;
    int         i_prsstart;
    int         i_prstoken;
    int         i_prsend;
    int         i_prsheadline;
    int         i_prslextype;
 
    query = createPQExpBuffer();
 
    /*
     * find all text search objects, including builtin ones; we filter out
     * system-defined objects at dump-out time.
     */
 
    appendPQExpBufferStr(query, "SELECT tableoid, oid, prsname, prsnamespace, "
                         "prsstart::oid, prstoken::oid, "
                         "prsend::oid, prsheadline::oid, prslextype::oid "
                         "FROM pg_ts_parser");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    prsinfo = (TSParserInfo *) pg_malloc(ntups * sizeof(TSParserInfo));
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_prsname = PQfnumber(res, "prsname");
    i_prsnamespace = PQfnumber(res, "prsnamespace");
    i_prsstart = PQfnumber(res, "prsstart");
    i_prstoken = PQfnumber(res, "prstoken");
    i_prsend = PQfnumber(res, "prsend");
    i_prsheadline = PQfnumber(res, "prsheadline");
    i_prslextype = PQfnumber(res, "prslextype");
 
    for (i = 0; i < ntups; i++)
    {
        prsinfo[i].dobj.objType = DO_TSPARSER;
        prsinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        prsinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&prsinfo[i].dobj);
        prsinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_prsname));
        prsinfo[i].dobj.namespace =
            findNamespace(atooid(PQgetvalue(res, i, i_prsnamespace)));
        prsinfo[i].prsstart = atooid(PQgetvalue(res, i, i_prsstart));
        prsinfo[i].prstoken = atooid(PQgetvalue(res, i, i_prstoken));
        prsinfo[i].prsend = atooid(PQgetvalue(res, i, i_prsend));
        prsinfo[i].prsheadline = atooid(PQgetvalue(res, i, i_prsheadline));
        prsinfo[i].prslextype = atooid(PQgetvalue(res, i, i_prslextype));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(prsinfo[i].dobj), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_TSPARSER, _prsInfo::dobj, ExecuteSqlQuery(), findNamespace(), i, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, _prsInfo::prsend, _prsInfo::prsheadline, _prsInfo::prslextype, _prsInfo::prsstart, _prsInfo::prstoken, selectDumpableObject(), and CatalogId::tableoid.

Referenced by getSchemaData().

getTSTemplates()

void getTSTemplates

(

Archive *

fout

)

Definition at line 10279 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query;
    TSTemplateInfo *tmplinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_tmplname;
    int         i_tmplnamespace;
    int         i_tmplinit;
    int         i_tmpllexize;
 
    query = createPQExpBuffer();
 
    appendPQExpBufferStr(query, "SELECT tableoid, oid, tmplname, "
                         "tmplnamespace, tmplinit::oid, tmpllexize::oid "
                         "FROM pg_ts_template");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    tmplinfo = (TSTemplateInfo *) pg_malloc(ntups * sizeof(TSTemplateInfo));
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_tmplname = PQfnumber(res, "tmplname");
    i_tmplnamespace = PQfnumber(res, "tmplnamespace");
    i_tmplinit = PQfnumber(res, "tmplinit");
    i_tmpllexize = PQfnumber(res, "tmpllexize");
 
    for (i = 0; i < ntups; i++)
    {
        tmplinfo[i].dobj.objType = DO_TSTEMPLATE;
        tmplinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        tmplinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&tmplinfo[i].dobj);
        tmplinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_tmplname));
        tmplinfo[i].dobj.namespace =
            findNamespace(atooid(PQgetvalue(res, i, i_tmplnamespace)));
        tmplinfo[i].tmplinit = atooid(PQgetvalue(res, i, i_tmplinit));
        tmplinfo[i].tmpllexize = atooid(PQgetvalue(res, i, i_tmpllexize));
 
        /* Decide whether we want to dump it */
        selectDumpableObject(&(tmplinfo[i].dobj), fout);
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References appendPQExpBufferStr(), AssignDumpId(), atooid, _dumpableObject::catId, createPQExpBuffer(), PQExpBufferData::data, destroyPQExpBuffer(), DO_TSTEMPLATE, _tmplInfo::dobj, ExecuteSqlQuery(), findNamespace(), i, _dumpableObject::name, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetvalue, PQntuples, selectDumpableObject(), CatalogId::tableoid, _tmplInfo::tmplinit, and _tmplInfo::tmpllexize.

Referenced by getSchemaData().

getTypes()

void getTypes

(

Archive *

fout

)

Definition at line 6184 of file pg_dump.c.

{
    PGresult   *res;
    int         ntups;
    int         i;
    PQExpBuffer query = createPQExpBuffer();
    TypeInfo   *tyinfo;
    ShellTypeInfo *stinfo;
    int         i_tableoid;
    int         i_oid;
    int         i_typname;
    int         i_typnamespace;
    int         i_typacl;
    int         i_acldefault;
    int         i_typowner;
    int         i_typelem;
    int         i_typrelid;
    int         i_typrelkind;
    int         i_typtype;
    int         i_typisdefined;
    int         i_isarray;
    int         i_typarray;
 
    /*
     * we include even the built-in types because those may be used as array
     * elements by user-defined types
     *
     * we filter out the built-in types when we dump out the types
     *
     * same approach for undefined (shell) types and array types
     *
     * Note: as of 8.3 we can reliably detect whether a type is an
     * auto-generated array type by checking the element type's typarray.
     * (Before that the test is capable of generating false positives.) We
     * still check for name beginning with '_', though, so as to avoid the
     * cost of the subselect probe for all standard types.  This would have to
     * be revisited if the backend ever allows renaming of array types.
     */
    appendPQExpBufferStr(query, "SELECT tableoid, oid, typname, "
                         "typnamespace, typacl, "
                         "acldefault('T', typowner) AS acldefault, "
                         "typowner, "
                         "typelem, typrelid, typarray, "
                         "CASE WHEN typrelid = 0 THEN ' '::\"char\" "
                         "ELSE (SELECT relkind FROM pg_class WHERE oid = typrelid) END AS typrelkind, "
                         "typtype, typisdefined, "
                         "typname[0] = '_' AND typelem != 0 AND "
                         "(SELECT typarray FROM pg_type te WHERE oid = pg_type.typelem) = oid AS isarray "
                         "FROM pg_type");
 
    res = ExecuteSqlQuery(fout, query->data, PGRES_TUPLES_OK);
 
    ntups = PQntuples(res);
 
    tyinfo = (TypeInfo *) pg_malloc(ntups * sizeof(TypeInfo));
 
    i_tableoid = PQfnumber(res, "tableoid");
    i_oid = PQfnumber(res, "oid");
    i_typname = PQfnumber(res, "typname");
    i_typnamespace = PQfnumber(res, "typnamespace");
    i_typacl = PQfnumber(res, "typacl");
    i_acldefault = PQfnumber(res, "acldefault");
    i_typowner = PQfnumber(res, "typowner");
    i_typelem = PQfnumber(res, "typelem");
    i_typrelid = PQfnumber(res, "typrelid");
    i_typrelkind = PQfnumber(res, "typrelkind");
    i_typtype = PQfnumber(res, "typtype");
    i_typisdefined = PQfnumber(res, "typisdefined");
    i_isarray = PQfnumber(res, "isarray");
    i_typarray = PQfnumber(res, "typarray");
 
    for (i = 0; i < ntups; i++)
    {
        tyinfo[i].dobj.objType = DO_TYPE;
        tyinfo[i].dobj.catId.tableoid = atooid(PQgetvalue(res, i, i_tableoid));
        tyinfo[i].dobj.catId.oid = atooid(PQgetvalue(res, i, i_oid));
        AssignDumpId(&tyinfo[i].dobj);
        tyinfo[i].dobj.name = pg_strdup(PQgetvalue(res, i, i_typname));
        tyinfo[i].dobj.namespace =
            findNamespace(atooid(PQgetvalue(res, i, i_typnamespace)));
        tyinfo[i].dacl.acl = pg_strdup(PQgetvalue(res, i, i_typacl));
        tyinfo[i].dacl.acldefault = pg_strdup(PQgetvalue(res, i, i_acldefault));
        tyinfo[i].dacl.privtype = 0;
        tyinfo[i].dacl.initprivs = NULL;
        tyinfo[i].ftypname = NULL;  /* may get filled later */
        tyinfo[i].rolname = getRoleName(PQgetvalue(res, i, i_typowner));
        tyinfo[i].typelem = atooid(PQgetvalue(res, i, i_typelem));
        tyinfo[i].typrelid = atooid(PQgetvalue(res, i, i_typrelid));
        tyinfo[i].typrelkind = *PQgetvalue(res, i, i_typrelkind);
        tyinfo[i].typtype = *PQgetvalue(res, i, i_typtype);
        tyinfo[i].shellType = NULL;
 
        if (strcmp(PQgetvalue(res, i, i_typisdefined), "t") == 0)
            tyinfo[i].isDefined = true;
        else
            tyinfo[i].isDefined = false;
 
        if (strcmp(PQgetvalue(res, i, i_isarray), "t") == 0)
            tyinfo[i].isArray = true;
        else
            tyinfo[i].isArray = false;
 
        tyinfo[i].typarray = atooid(PQgetvalue(res, i, i_typarray));
 
        if (tyinfo[i].typtype == TYPTYPE_MULTIRANGE)
            tyinfo[i].isMultirange = true;
        else
            tyinfo[i].isMultirange = false;
 
        /* Decide whether we want to dump it */
        selectDumpableType(&tyinfo[i], fout);
 
        /* Mark whether type has an ACL */
        if (!PQgetisnull(res, i, i_typacl))
            tyinfo[i].dobj.components |= DUMP_COMPONENT_ACL;
 
        /*
         * If it's a domain, fetch info about its constraints, if any
         */
        tyinfo[i].nDomChecks = 0;
        tyinfo[i].domChecks = NULL;
        tyinfo[i].notnull = NULL;
        if ((tyinfo[i].dobj.dump & DUMP_COMPONENT_DEFINITION) &&
            tyinfo[i].typtype == TYPTYPE_DOMAIN)
            getDomainConstraints(fout, &(tyinfo[i]));
 
        /*
         * If it's a base type, make a DumpableObject representing a shell
         * definition of the type.  We will need to dump that ahead of the I/O
         * functions for the type.  Similarly, range types need a shell
         * definition in case they have a canonicalize function.
         *
         * Note: the shell type doesn't have a catId.  You might think it
         * should copy the base type's catId, but then it might capture the
         * pg_depend entries for the type, which we don't want.
         */
        if ((tyinfo[i].dobj.dump & DUMP_COMPONENT_DEFINITION) &&
            (tyinfo[i].typtype == TYPTYPE_BASE ||
             tyinfo[i].typtype == TYPTYPE_RANGE))
        {
            stinfo = (ShellTypeInfo *) pg_malloc(sizeof(ShellTypeInfo));
            stinfo->dobj.objType = DO_SHELL_TYPE;
            stinfo->dobj.catId = nilCatalogId;
            AssignDumpId(&stinfo->dobj);
            stinfo->dobj.name = pg_strdup(tyinfo[i].dobj.name);
            stinfo->dobj.namespace = tyinfo[i].dobj.namespace;
            stinfo->baseType = &(tyinfo[i]);
            tyinfo[i].shellType = stinfo;
 
            /*
             * Initially mark the shell type as not to be dumped.  We'll only
             * dump it if the I/O or canonicalize functions need to be dumped;
             * this is taken care of while sorting dependencies.
             */
            stinfo->dobj.dump = DUMP_COMPONENT_NONE;
        }
    }
 
    PQclear(res);
 
    destroyPQExpBuffer(query);
}

References _dumpableAcl::acl, _dumpableAcl::acldefault, appendPQExpBufferStr(), AssignDumpId(), atooid, _shellTypeInfo::baseType, _dumpableObject::catId, _dumpableObject::components, createPQExpBuffer(), _typeInfo::dacl, PQExpBufferData::data, destroyPQExpBuffer(), DO_SHELL_TYPE, DO_TYPE, _typeInfo::dobj, _shellTypeInfo::dobj, _typeInfo::domChecks, _dumpableObject::dump, DUMP_COMPONENT_ACL, DUMP_COMPONENT_DEFINITION, DUMP_COMPONENT_NONE, ExecuteSqlQuery(), findNamespace(), _typeInfo::ftypname, getDomainConstraints(), getRoleName(), i, _dumpableAcl::initprivs, _typeInfo::isArray, _typeInfo::isDefined, _typeInfo::isMultirange, _dumpableObject::name, _typeInfo::nDomChecks, nilCatalogId, _typeInfo::notnull, _dumpableObject::objType, CatalogId::oid, pg_malloc(), pg_strdup(), PGRES_TUPLES_OK, PQclear, PQfnumber(), PQgetisnull, PQgetvalue, PQntuples, _dumpableAcl::privtype, _typeInfo::rolname, selectDumpableType(), _typeInfo::shellType, CatalogId::tableoid, _typeInfo::typarray, _typeInfo::typelem, _typeInfo::typrelid, _typeInfo::typrelkind, and _typeInfo::typtype.

Referenced by getSchemaData().

parseOidArray()

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

Definition at line 1111 of file common.c.

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

References atooid, InvalidOid, j, pg_fatal, and str.

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

processExtensionTables()

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

Definition at line 19765 of file pg_dump.c.

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

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

Referenced by getSchemaData().

recordAdditionalCatalogID()

void recordAdditionalCatalogID	(	CatalogId	catId,
		DumpableObject *	dobj
	)

Definition at line 719 of file common.c.

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

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

Referenced by getLOs().

recordExtensionMembership()

void recordExtensionMembership	(	CatalogId	catId,
		ExtensionInfo *	ext
	)

Definition at line 1063 of file common.c.

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

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

Referenced by getExtensionMembership().

removeObjectDependency()

void removeObjectDependency	(	DumpableObject *	dobj,
		DumpId	refId
	)

Definition at line 843 of file common.c.

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

References _dumpableObject::dependencies, i, j, and _dumpableObject::nDeps.

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

shouldPrintColumn()

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

Definition at line 10124 of file pg_dump.c.

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

References _tableInfo::attisdropped, _tableInfo::attislocal, _dumpOptions::binary_upgrade, and _tableInfo::ispartition.

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

sortDumpableObjects()

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

Definition at line 548 of file pg_dump_sort.c.

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

References findDependencyLoops(), free, pg_malloc(), postDataBoundId, preDataBoundId, and TopoSort().

Referenced by main().

sortDumpableObjectsByTypeName()

void sortDumpableObjectsByTypeName	(	DumpableObject **	objs,
		int	numObjs
	)

Definition at line 192 of file pg_dump_sort.c.

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

References DOTypeNameCompare(), and qsort.

Referenced by main().