objectaddress.c File Reference

#include "postgres.h"
#include "access/genam.h"
#include "access/htup_details.h"
#include "access/relation.h"
#include "access/sysattr.h"
#include "access/table.h"
#include "catalog/catalog.h"
#include "catalog/objectaddress.h"
#include "catalog/pg_am.h"
#include "catalog/pg_amop.h"
#include "catalog/pg_amproc.h"
#include "catalog/pg_attrdef.h"
#include "catalog/pg_authid.h"
#include "catalog/pg_auth_members.h"
#include "catalog/pg_cast.h"
#include "catalog/pg_collation.h"
#include "catalog/pg_constraint.h"
#include "catalog/pg_conversion.h"
#include "catalog/pg_database.h"
#include "catalog/pg_default_acl.h"
#include "catalog/pg_enum.h"
#include "catalog/pg_event_trigger.h"
#include "catalog/pg_extension.h"
#include "catalog/pg_foreign_data_wrapper.h"
#include "catalog/pg_foreign_server.h"
#include "catalog/pg_language.h"
#include "catalog/pg_largeobject.h"
#include "catalog/pg_largeobject_metadata.h"
#include "catalog/pg_namespace.h"
#include "catalog/pg_opclass.h"
#include "catalog/pg_operator.h"
#include "catalog/pg_opfamily.h"
#include "catalog/pg_parameter_acl.h"
#include "catalog/pg_policy.h"
#include "catalog/pg_proc.h"
#include "catalog/pg_publication.h"
#include "catalog/pg_publication_namespace.h"
#include "catalog/pg_publication_rel.h"
#include "catalog/pg_rewrite.h"
#include "catalog/pg_statistic_ext.h"
#include "catalog/pg_subscription.h"
#include "catalog/pg_tablespace.h"
#include "catalog/pg_transform.h"
#include "catalog/pg_trigger.h"
#include "catalog/pg_ts_config.h"
#include "catalog/pg_ts_dict.h"
#include "catalog/pg_ts_parser.h"
#include "catalog/pg_ts_template.h"
#include "catalog/pg_type.h"
#include "catalog/pg_user_mapping.h"
#include "commands/dbcommands.h"
#include "commands/defrem.h"
#include "commands/event_trigger.h"
#include "commands/extension.h"
#include "commands/policy.h"
#include "commands/proclang.h"
#include "commands/tablespace.h"
#include "commands/trigger.h"
#include "foreign/foreign.h"
#include "funcapi.h"
#include "miscadmin.h"
#include "nodes/makefuncs.h"
#include "parser/parse_func.h"
#include "parser/parse_oper.h"
#include "parser/parse_type.h"
#include "rewrite/rewriteSupport.h"
#include "storage/large_object.h"
#include "storage/lmgr.h"
#include "storage/sinval.h"
#include "utils/acl.h"
#include "utils/builtins.h"
#include "utils/fmgroids.h"
#include "utils/lsyscache.h"
#include "utils/memutils.h"
#include "utils/regproc.h"
#include "utils/syscache.h"

Include dependency graph for objectaddress.c:

Go to the source code of this file.

Data Structures
struct	ObjectPropertyType
struct	object_type_map

Functions
static ObjectAddress	get_object_address_unqualified (ObjectType objtype, String *strval, bool missing_ok)
static ObjectAddress	get_relation_by_qualified_name (ObjectType objtype, List *object, Relation *relp, LOCKMODE lockmode, bool missing_ok)
static ObjectAddress	get_object_address_relobject (ObjectType objtype, List *object, Relation *relp, bool missing_ok)
static ObjectAddress	get_object_address_attribute (ObjectType objtype, List *object, Relation *relp, LOCKMODE lockmode, bool missing_ok)
static ObjectAddress	get_object_address_attrdef (ObjectType objtype, List *object, Relation *relp, LOCKMODE lockmode, bool missing_ok)
static ObjectAddress	get_object_address_type (ObjectType objtype, TypeName *typename, bool missing_ok)
static ObjectAddress	get_object_address_opcf (ObjectType objtype, List *object, bool missing_ok)
static ObjectAddress	get_object_address_opf_member (ObjectType objtype, List *object, bool missing_ok)
static ObjectAddress	get_object_address_usermapping (List *object, bool missing_ok)
static ObjectAddress	get_object_address_publication_rel (List *object, Relation *relp, bool missing_ok)
static ObjectAddress	get_object_address_publication_schema (List *object, bool missing_ok)
static ObjectAddress	get_object_address_defacl (List *object, bool missing_ok)
static const ObjectPropertyType *	get_object_property_data (Oid class_id)
static void	getRelationDescription (StringInfo buffer, Oid relid, bool missing_ok)
static void	getOpFamilyDescription (StringInfo buffer, Oid opfid, bool missing_ok)
static void	getRelationTypeDescription (StringInfo buffer, Oid relid, int32 objectSubId, bool missing_ok)
static void	getProcedureTypeDescription (StringInfo buffer, Oid procid, bool missing_ok)
static void	getConstraintTypeDescription (StringInfo buffer, Oid constroid, bool missing_ok)
static void	getOpFamilyIdentity (StringInfo buffer, Oid opfid, List **object, bool missing_ok)
static void	getRelationIdentity (StringInfo buffer, Oid relid, List **object, bool missing_ok)
ObjectAddress	get_object_address (ObjectType objtype, Node *object, Relation *relp, LOCKMODE lockmode, bool missing_ok)
ObjectAddress	get_object_address_rv (ObjectType objtype, RangeVar *rel, List *object, Relation *relp, LOCKMODE lockmode, bool missing_ok)
static List *	textarray_to_strvaluelist (ArrayType *arr)
Datum	pg_get_object_address (PG_FUNCTION_ARGS)
void	check_object_ownership (Oid roleid, ObjectType objtype, ObjectAddress address, Node *object, Relation relation)
Oid	get_object_namespace (const ObjectAddress *address)
int	read_objtype_from_string (const char *objtype)
const char *	get_object_class_descr (Oid class_id)
Oid	get_object_oid_index (Oid class_id)
int	get_object_catcache_oid (Oid class_id)
int	get_object_catcache_name (Oid class_id)
AttrNumber	get_object_attnum_oid (Oid class_id)
AttrNumber	get_object_attnum_name (Oid class_id)
AttrNumber	get_object_attnum_namespace (Oid class_id)
AttrNumber	get_object_attnum_owner (Oid class_id)
AttrNumber	get_object_attnum_acl (Oid class_id)
ObjectType	get_object_type (Oid class_id, Oid object_id)
bool	get_object_namensp_unique (Oid class_id)
bool	is_objectclass_supported (Oid class_id)
HeapTuple	get_catalog_object_by_oid (Relation catalog, AttrNumber oidcol, Oid objectId)
static bool	getPublicationSchemaInfo (const ObjectAddress *object, bool missing_ok, char **pubname, char **nspname)
char *	getObjectDescription (const ObjectAddress *object, bool missing_ok)
char *	getObjectDescriptionOids (Oid classid, Oid objid)
Datum	pg_describe_object (PG_FUNCTION_ARGS)
Datum	pg_identify_object (PG_FUNCTION_ARGS)
Datum	pg_identify_object_as_address (PG_FUNCTION_ARGS)
char *	getObjectTypeDescription (const ObjectAddress *object, bool missing_ok)
char *	getObjectIdentity (const ObjectAddress *object, bool missing_ok)
char *	getObjectIdentityParts (const ObjectAddress *object, List **objname, List **objargs, bool missing_ok)
ArrayType *	strlist_to_textarray (List *list)
ObjectType	get_relkind_objtype (char relkind)

Variables
static const ObjectPropertyType	ObjectProperty []
static const struct object_type_map	ObjectTypeMap []
const ObjectAddress	InvalidObjectAddress

Function Documentation

check_object_ownership()

void check_object_ownership	(	Oid	roleid,
		ObjectType	objtype,
		ObjectAddress	address,
		Node *	object,
		Relation	relation
	)

Definition at line 2426 of file objectaddress.c.

{
    switch (objtype)
    {
        case OBJECT_INDEX:
        case OBJECT_SEQUENCE:
        case OBJECT_TABLE:
        case OBJECT_VIEW:
        case OBJECT_MATVIEW:
        case OBJECT_FOREIGN_TABLE:
        case OBJECT_COLUMN:
        case OBJECT_RULE:
        case OBJECT_TRIGGER:
        case OBJECT_POLICY:
        case OBJECT_TABCONSTRAINT:
            if (!object_ownercheck(RelationRelationId, RelationGetRelid(relation), roleid))
                aclcheck_error(ACLCHECK_NOT_OWNER, objtype,
                               RelationGetRelationName(relation));
            break;
        case OBJECT_TYPE:
        case OBJECT_DOMAIN:
        case OBJECT_ATTRIBUTE:
            if (!object_ownercheck(address.classId, address.objectId, roleid))
                aclcheck_error_type(ACLCHECK_NOT_OWNER, address.objectId);
            break;
        case OBJECT_DOMCONSTRAINT:
            {
                HeapTuple   tuple;
                Oid         contypid;
 
                tuple = SearchSysCache1(CONSTROID,
                                        ObjectIdGetDatum(address.objectId));
                if (!HeapTupleIsValid(tuple))
                    elog(ERROR, "constraint with OID %u does not exist",
                         address.objectId);
 
                contypid = ((Form_pg_constraint) GETSTRUCT(tuple))->contypid;
 
                ReleaseSysCache(tuple);
 
                /*
                 * Fallback to type ownership check in this case as this is
                 * what domain constraints rely on.
                 */
                if (!object_ownercheck(TypeRelationId, contypid, roleid))
                    aclcheck_error_type(ACLCHECK_NOT_OWNER, contypid);
            }
            break;
        case OBJECT_AGGREGATE:
        case OBJECT_FUNCTION:
        case OBJECT_PROCEDURE:
        case OBJECT_ROUTINE:
        case OBJECT_OPERATOR:
            if (!object_ownercheck(address.classId, address.objectId, roleid))
                aclcheck_error(ACLCHECK_NOT_OWNER, objtype,
                               NameListToString((castNode(ObjectWithArgs, object))->objname));
            break;
        case OBJECT_DATABASE:
        case OBJECT_EVENT_TRIGGER:
        case OBJECT_EXTENSION:
        case OBJECT_FDW:
        case OBJECT_FOREIGN_SERVER:
        case OBJECT_LANGUAGE:
        case OBJECT_PUBLICATION:
        case OBJECT_SCHEMA:
        case OBJECT_SUBSCRIPTION:
        case OBJECT_TABLESPACE:
            if (!object_ownercheck(address.classId, address.objectId, roleid))
                aclcheck_error(ACLCHECK_NOT_OWNER, objtype,
                               strVal(object));
            break;
        case OBJECT_COLLATION:
        case OBJECT_CONVERSION:
        case OBJECT_OPCLASS:
        case OBJECT_OPFAMILY:
        case OBJECT_STATISTIC_EXT:
        case OBJECT_TSDICTIONARY:
        case OBJECT_TSCONFIGURATION:
            if (!object_ownercheck(address.classId, address.objectId, roleid))
                aclcheck_error(ACLCHECK_NOT_OWNER, objtype,
                               NameListToString(castNode(List, object)));
            break;
        case OBJECT_LARGEOBJECT:
            if (!lo_compat_privileges &&
                !object_ownercheck(address.classId, address.objectId, roleid))
                ereport(ERROR,
                        (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
                         errmsg("must be owner of large object %u",
                                address.objectId)));
            break;
        case OBJECT_CAST:
            {
                /* We can only check permissions on the source/target types */
                TypeName   *sourcetype = linitial_node(TypeName, castNode(List, object));
                TypeName   *targettype = lsecond_node(TypeName, castNode(List, object));
                Oid         sourcetypeid = typenameTypeId(NULL, sourcetype);
                Oid         targettypeid = typenameTypeId(NULL, targettype);
 
                if (!object_ownercheck(TypeRelationId, sourcetypeid, roleid)
                    && !object_ownercheck(TypeRelationId, targettypeid, roleid))
                    ereport(ERROR,
                            (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
                             errmsg("must be owner of type %s or type %s",
                                    format_type_be(sourcetypeid),
                                    format_type_be(targettypeid))));
            }
            break;
        case OBJECT_TRANSFORM:
            {
                TypeName   *typename = linitial_node(TypeName, castNode(List, object));
                Oid         typeid = typenameTypeId(NULL, typename);
 
                if (!object_ownercheck(TypeRelationId, typeid, roleid))
                    aclcheck_error_type(ACLCHECK_NOT_OWNER, typeid);
            }
            break;
        case OBJECT_ROLE:
 
            /*
             * We treat roles as being "owned" by those with CREATEROLE priv,
             * provided that they also have admin option on the role.
             *
             * However, superusers are only owned by superusers.
             */
            if (superuser_arg(address.objectId))
            {
                if (!superuser_arg(roleid))
                    ereport(ERROR,
                            (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
                             errmsg("permission denied"),
                             errdetail("The current user must have the %s attribute.",
                                       "SUPERUSER")));
            }
            else
            {
                if (!has_createrole_privilege(roleid))
                    ereport(ERROR,
                            (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
                             errmsg("permission denied"),
                             errdetail("The current user must have the %s attribute.",
                                       "CREATEROLE")));
                if (!is_admin_of_role(roleid, address.objectId))
                    ereport(ERROR,
                            (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
                             errmsg("permission denied"),
                             errdetail("The current user must have the %s option on role \"%s\".",
                                       "ADMIN",
                                       GetUserNameFromId(address.objectId,
                                                         true))));
            }
            break;
        case OBJECT_TSPARSER:
        case OBJECT_TSTEMPLATE:
        case OBJECT_ACCESS_METHOD:
        case OBJECT_PARAMETER_ACL:
            /* We treat these object types as being owned by superusers */
            if (!superuser_arg(roleid))
                ereport(ERROR,
                        (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
                         errmsg("must be superuser")));
            break;
        case OBJECT_AMOP:
        case OBJECT_AMPROC:
        case OBJECT_DEFAULT:
        case OBJECT_DEFACL:
        case OBJECT_PUBLICATION_NAMESPACE:
        case OBJECT_PUBLICATION_REL:
        case OBJECT_USER_MAPPING:
            /* These are currently not supported or don't make sense here. */
            elog(ERROR, "unsupported object type: %d", (int) objtype);
            break;
    }
}

References aclcheck_error(), aclcheck_error_type(), ACLCHECK_NOT_OWNER, castNode, ObjectAddress::classId, CONSTROID, elog(), ereport, errcode(), errdetail(), errmsg(), ERROR, format_type_be(), GETSTRUCT, GetUserNameFromId(), has_createrole_privilege(), HeapTupleIsValid, is_admin_of_role(), linitial_node, lo_compat_privileges, lsecond_node, NameListToString(), OBJECT_ACCESS_METHOD, OBJECT_AGGREGATE, OBJECT_AMOP, OBJECT_AMPROC, OBJECT_ATTRIBUTE, OBJECT_CAST, OBJECT_COLLATION, OBJECT_COLUMN, OBJECT_CONVERSION, OBJECT_DATABASE, OBJECT_DEFACL, OBJECT_DEFAULT, OBJECT_DOMAIN, OBJECT_DOMCONSTRAINT, OBJECT_EVENT_TRIGGER, OBJECT_EXTENSION, OBJECT_FDW, OBJECT_FOREIGN_SERVER, OBJECT_FOREIGN_TABLE, OBJECT_FUNCTION, OBJECT_INDEX, OBJECT_LANGUAGE, OBJECT_LARGEOBJECT, OBJECT_MATVIEW, OBJECT_OPCLASS, OBJECT_OPERATOR, OBJECT_OPFAMILY, object_ownercheck(), OBJECT_PARAMETER_ACL, OBJECT_POLICY, OBJECT_PROCEDURE, OBJECT_PUBLICATION, OBJECT_PUBLICATION_NAMESPACE, OBJECT_PUBLICATION_REL, OBJECT_ROLE, OBJECT_ROUTINE, OBJECT_RULE, OBJECT_SCHEMA, OBJECT_SEQUENCE, OBJECT_STATISTIC_EXT, OBJECT_SUBSCRIPTION, OBJECT_TABCONSTRAINT, OBJECT_TABLE, OBJECT_TABLESPACE, OBJECT_TRANSFORM, OBJECT_TRIGGER, OBJECT_TSCONFIGURATION, OBJECT_TSDICTIONARY, OBJECT_TSPARSER, OBJECT_TSTEMPLATE, OBJECT_TYPE, OBJECT_USER_MAPPING, OBJECT_VIEW, ObjectAddress::objectId, ObjectIdGetDatum(), RelationGetRelationName, RelationGetRelid, ReleaseSysCache(), SearchSysCache1(), strVal, superuser_arg(), and typenameTypeId().

Referenced by CommentObject(), ExecAlterExtensionContentsStmt(), ExecAlterObjectDependsStmt(), ExecSecLabelStmt(), and RemoveObjects().

get_catalog_object_by_oid()

HeapTuple get_catalog_object_by_oid	(	Relation	catalog,
		AttrNumber	oidcol,
		Oid	objectId
	)

Definition at line 2825 of file objectaddress.c.

{
    HeapTuple   tuple;
    Oid         classId = RelationGetRelid(catalog);
    int         oidCacheId = get_object_catcache_oid(classId);
 
    if (oidCacheId > 0)
    {
        tuple = SearchSysCacheCopy1(oidCacheId, ObjectIdGetDatum(objectId));
        if (!HeapTupleIsValid(tuple))   /* should not happen */
            return NULL;
    }
    else
    {
        Oid         oidIndexId = get_object_oid_index(classId);
        SysScanDesc scan;
        ScanKeyData skey;
 
        Assert(OidIsValid(oidIndexId));
 
        ScanKeyInit(&skey,
                    oidcol,
                    BTEqualStrategyNumber, F_OIDEQ,
                    ObjectIdGetDatum(objectId));
 
        scan = systable_beginscan(catalog, oidIndexId, true,
                                  NULL, 1, &skey);
        tuple = systable_getnext(scan);
        if (!HeapTupleIsValid(tuple))
        {
            systable_endscan(scan);
            return NULL;
        }
        tuple = heap_copytuple(tuple);
 
        systable_endscan(scan);
    }
 
    return tuple;
}

References Assert(), BTEqualStrategyNumber, get_object_catcache_oid(), get_object_oid_index(), heap_copytuple(), HeapTupleIsValid, ObjectIdGetDatum(), OidIsValid, RelationGetRelid, ScanKeyInit(), SearchSysCacheCopy1, systable_beginscan(), systable_endscan(), and systable_getnext().

Referenced by AlterObjectOwner_internal(), EventTriggerSQLDropAddObject(), getConstraintTypeDescription(), getObjectIdentityParts(), pg_event_trigger_ddl_commands(), and pg_identify_object().

get_object_address()

ObjectAddress get_object_address	(	ObjectType	objtype,
		Node *	object,
		Relation *	relp,
		LOCKMODE	lockmode,
		bool	missing_ok
	)

Definition at line 966 of file objectaddress.c.

{
    ObjectAddress address = {InvalidOid, InvalidOid, 0};
    ObjectAddress old_address = {InvalidOid, InvalidOid, 0};
    Relation    relation = NULL;
    uint64      inval_count;
 
    /* Some kind of lock must be taken. */
    Assert(lockmode != NoLock);
 
    for (;;)
    {
        /*
         * Remember this value, so that, after looking up the object name and
         * locking it, we can check whether any invalidation messages have
         * been processed that might require a do-over.
         */
        inval_count = SharedInvalidMessageCounter;
 
        /* Look up object address. */
        switch (objtype)
        {
            case OBJECT_INDEX:
            case OBJECT_SEQUENCE:
            case OBJECT_TABLE:
            case OBJECT_VIEW:
            case OBJECT_MATVIEW:
            case OBJECT_FOREIGN_TABLE:
                address =
                    get_relation_by_qualified_name(objtype, castNode(List, object),
                                                   &relation, lockmode,
                                                   missing_ok);
                break;
            case OBJECT_ATTRIBUTE:
            case OBJECT_COLUMN:
                address =
                    get_object_address_attribute(objtype, castNode(List, object),
                                                 &relation, lockmode,
                                                 missing_ok);
                break;
            case OBJECT_DEFAULT:
                address =
                    get_object_address_attrdef(objtype, castNode(List, object),
                                               &relation, lockmode,
                                               missing_ok);
                break;
            case OBJECT_RULE:
            case OBJECT_TRIGGER:
            case OBJECT_TABCONSTRAINT:
            case OBJECT_POLICY:
                address = get_object_address_relobject(objtype, castNode(List, object),
                                                       &relation, missing_ok);
                break;
            case OBJECT_DOMCONSTRAINT:
                {
                    List       *objlist;
                    ObjectAddress domaddr;
                    char       *constrname;
 
                    objlist = castNode(List, object);
                    domaddr = get_object_address_type(OBJECT_DOMAIN,
                                                      linitial_node(TypeName, objlist),
                                                      missing_ok);
                    constrname = strVal(lsecond(objlist));
 
                    address.classId = ConstraintRelationId;
                    address.objectId = get_domain_constraint_oid(domaddr.objectId,
                                                                 constrname, missing_ok);
                    address.objectSubId = 0;
                }
                break;
            case OBJECT_DATABASE:
            case OBJECT_EXTENSION:
            case OBJECT_TABLESPACE:
            case OBJECT_ROLE:
            case OBJECT_SCHEMA:
            case OBJECT_LANGUAGE:
            case OBJECT_FDW:
            case OBJECT_FOREIGN_SERVER:
            case OBJECT_EVENT_TRIGGER:
            case OBJECT_PARAMETER_ACL:
            case OBJECT_ACCESS_METHOD:
            case OBJECT_PUBLICATION:
            case OBJECT_SUBSCRIPTION:
                address = get_object_address_unqualified(objtype,
                                                         castNode(String, object), missing_ok);
                break;
            case OBJECT_TYPE:
            case OBJECT_DOMAIN:
                address = get_object_address_type(objtype, castNode(TypeName, object), missing_ok);
                break;
            case OBJECT_AGGREGATE:
            case OBJECT_FUNCTION:
            case OBJECT_PROCEDURE:
            case OBJECT_ROUTINE:
                address.classId = ProcedureRelationId;
                address.objectId = LookupFuncWithArgs(objtype, castNode(ObjectWithArgs, object), missing_ok);
                address.objectSubId = 0;
                break;
            case OBJECT_OPERATOR:
                address.classId = OperatorRelationId;
                address.objectId = LookupOperWithArgs(castNode(ObjectWithArgs, object), missing_ok);
                address.objectSubId = 0;
                break;
            case OBJECT_COLLATION:
                address.classId = CollationRelationId;
                address.objectId = get_collation_oid(castNode(List, object), missing_ok);
                address.objectSubId = 0;
                break;
            case OBJECT_CONVERSION:
                address.classId = ConversionRelationId;
                address.objectId = get_conversion_oid(castNode(List, object), missing_ok);
                address.objectSubId = 0;
                break;
            case OBJECT_OPCLASS:
            case OBJECT_OPFAMILY:
                address = get_object_address_opcf(objtype, castNode(List, object), missing_ok);
                break;
            case OBJECT_AMOP:
            case OBJECT_AMPROC:
                address = get_object_address_opf_member(objtype, castNode(List, object), missing_ok);
                break;
            case OBJECT_LARGEOBJECT:
                address.classId = LargeObjectRelationId;
                address.objectId = oidparse(object);
                address.objectSubId = 0;
                if (!LargeObjectExists(address.objectId))
                {
                    if (!missing_ok)
                        ereport(ERROR,
                                (errcode(ERRCODE_UNDEFINED_OBJECT),
                                 errmsg("large object %u does not exist",
                                        address.objectId)));
                }
                break;
            case OBJECT_CAST:
                {
                    TypeName   *sourcetype = linitial_node(TypeName, castNode(List, object));
                    TypeName   *targettype = lsecond_node(TypeName, castNode(List, object));
                    Oid         sourcetypeid;
                    Oid         targettypeid;
 
                    sourcetypeid = LookupTypeNameOid(NULL, sourcetype, missing_ok);
                    targettypeid = LookupTypeNameOid(NULL, targettype, missing_ok);
                    address.classId = CastRelationId;
                    address.objectId =
                        get_cast_oid(sourcetypeid, targettypeid, missing_ok);
                    address.objectSubId = 0;
                }
                break;
            case OBJECT_TRANSFORM:
                {
                    TypeName   *typename = linitial_node(TypeName, castNode(List, object));
                    char       *langname = strVal(lsecond(castNode(List, object)));
                    Oid         type_id = LookupTypeNameOid(NULL, typename, missing_ok);
                    Oid         lang_id = get_language_oid(langname, missing_ok);
 
                    address.classId = TransformRelationId;
                    address.objectId =
                        get_transform_oid(type_id, lang_id, missing_ok);
                    address.objectSubId = 0;
                }
                break;
            case OBJECT_TSPARSER:
                address.classId = TSParserRelationId;
                address.objectId = get_ts_parser_oid(castNode(List, object), missing_ok);
                address.objectSubId = 0;
                break;
            case OBJECT_TSDICTIONARY:
                address.classId = TSDictionaryRelationId;
                address.objectId = get_ts_dict_oid(castNode(List, object), missing_ok);
                address.objectSubId = 0;
                break;
            case OBJECT_TSTEMPLATE:
                address.classId = TSTemplateRelationId;
                address.objectId = get_ts_template_oid(castNode(List, object), missing_ok);
                address.objectSubId = 0;
                break;
            case OBJECT_TSCONFIGURATION:
                address.classId = TSConfigRelationId;
                address.objectId = get_ts_config_oid(castNode(List, object), missing_ok);
                address.objectSubId = 0;
                break;
            case OBJECT_USER_MAPPING:
                address = get_object_address_usermapping(castNode(List, object),
                                                         missing_ok);
                break;
            case OBJECT_PUBLICATION_NAMESPACE:
                address = get_object_address_publication_schema(castNode(List, object),
                                                                missing_ok);
                break;
            case OBJECT_PUBLICATION_REL:
                address = get_object_address_publication_rel(castNode(List, object),
                                                             &relation,
                                                             missing_ok);
                break;
            case OBJECT_DEFACL:
                address = get_object_address_defacl(castNode(List, object),
                                                    missing_ok);
                break;
            case OBJECT_STATISTIC_EXT:
                address.classId = StatisticExtRelationId;
                address.objectId = get_statistics_object_oid(castNode(List, object),
                                                             missing_ok);
                address.objectSubId = 0;
                break;
                /* no default, to let compiler warn about missing case */
        }
 
        if (!address.classId)
            elog(ERROR, "unrecognized object type: %d", (int) objtype);
 
        /*
         * If we could not find the supplied object, return without locking.
         */
        if (!OidIsValid(address.objectId))
        {
            Assert(missing_ok);
            return address;
        }
 
        /*
         * If we're retrying, see if we got the same answer as last time.  If
         * so, we're done; if not, we locked the wrong thing, so give up our
         * lock.
         */
        if (OidIsValid(old_address.classId))
        {
            if (old_address.classId == address.classId
                && old_address.objectId == address.objectId
                && old_address.objectSubId == address.objectSubId)
                break;
            if (old_address.classId != RelationRelationId)
            {
                if (IsSharedRelation(old_address.classId))
                    UnlockSharedObject(old_address.classId,
                                       old_address.objectId,
                                       0, lockmode);
                else
                    UnlockDatabaseObject(old_address.classId,
                                         old_address.objectId,
                                         0, lockmode);
            }
        }
 
        /*
         * If we're dealing with a relation or attribute, then the relation is
         * already locked.  Otherwise, we lock it now.
         */
        if (address.classId != RelationRelationId)
        {
            if (IsSharedRelation(address.classId))
                LockSharedObject(address.classId, address.objectId, 0,
                                 lockmode);
            else
                LockDatabaseObject(address.classId, address.objectId, 0,
                                   lockmode);
        }
 
        /*
         * At this point, we've resolved the name to an OID and locked the
         * corresponding database object.  However, it's possible that by the
         * time we acquire the lock on the object, concurrent DDL has modified
         * the database in such a way that the name we originally looked up no
         * longer resolves to that OID.
         *
         * We can be certain that this isn't an issue if (a) no shared
         * invalidation messages have been processed or (b) we've locked a
         * relation somewhere along the line.  All the relation name lookups
         * in this module ultimately use RangeVarGetRelid() to acquire a
         * relation lock, and that function protects against the same kinds of
         * races we're worried about here.  Even when operating on a
         * constraint, rule, or trigger, we still acquire AccessShareLock on
         * the relation, which is enough to freeze out any concurrent DDL.
         *
         * In all other cases, however, it's possible that the name we looked
         * up no longer refers to the object we locked, so we retry the lookup
         * and see whether we get the same answer.
         */
        if (inval_count == SharedInvalidMessageCounter || relation != NULL)
            break;
        old_address = address;
    }
 
    /* Return the object address and the relation. */
    *relp = relation;
    return address;
}

References Assert(), castNode, ObjectAddress::classId, elog(), ereport, errcode(), errmsg(), ERROR, get_cast_oid(), get_collation_oid(), get_conversion_oid(), get_domain_constraint_oid(), get_language_oid(), get_object_address_attrdef(), get_object_address_attribute(), get_object_address_defacl(), get_object_address_opcf(), get_object_address_opf_member(), get_object_address_publication_rel(), get_object_address_publication_schema(), get_object_address_relobject(), get_object_address_type(), get_object_address_unqualified(), get_object_address_usermapping(), get_relation_by_qualified_name(), get_statistics_object_oid(), get_transform_oid(), get_ts_config_oid(), get_ts_dict_oid(), get_ts_parser_oid(), get_ts_template_oid(), InvalidOid, IsSharedRelation(), LargeObjectExists(), linitial_node, LockDatabaseObject(), LockSharedObject(), LookupFuncWithArgs(), LookupOperWithArgs(), LookupTypeNameOid(), lsecond, lsecond_node, NoLock, OBJECT_ACCESS_METHOD, OBJECT_AGGREGATE, OBJECT_AMOP, OBJECT_AMPROC, OBJECT_ATTRIBUTE, OBJECT_CAST, OBJECT_COLLATION, OBJECT_COLUMN, OBJECT_CONVERSION, OBJECT_DATABASE, OBJECT_DEFACL, OBJECT_DEFAULT, OBJECT_DOMAIN, OBJECT_DOMCONSTRAINT, OBJECT_EVENT_TRIGGER, OBJECT_EXTENSION, OBJECT_FDW, OBJECT_FOREIGN_SERVER, OBJECT_FOREIGN_TABLE, OBJECT_FUNCTION, OBJECT_INDEX, OBJECT_LANGUAGE, OBJECT_LARGEOBJECT, OBJECT_MATVIEW, OBJECT_OPCLASS, OBJECT_OPERATOR, OBJECT_OPFAMILY, OBJECT_PARAMETER_ACL, OBJECT_POLICY, OBJECT_PROCEDURE, OBJECT_PUBLICATION, OBJECT_PUBLICATION_NAMESPACE, OBJECT_PUBLICATION_REL, OBJECT_ROLE, OBJECT_ROUTINE, OBJECT_RULE, OBJECT_SCHEMA, OBJECT_SEQUENCE, OBJECT_STATISTIC_EXT, OBJECT_SUBSCRIPTION, OBJECT_TABCONSTRAINT, OBJECT_TABLE, OBJECT_TABLESPACE, OBJECT_TRANSFORM, OBJECT_TRIGGER, OBJECT_TSCONFIGURATION, OBJECT_TSDICTIONARY, OBJECT_TSPARSER, OBJECT_TSTEMPLATE, OBJECT_TYPE, OBJECT_USER_MAPPING, OBJECT_VIEW, ObjectAddress::objectId, ObjectAddress::objectSubId, OidIsValid, oidparse(), SharedInvalidMessageCounter, strVal, UnlockDatabaseObject(), and UnlockSharedObject().

Referenced by CommentObject(), ExecAlterExtensionContentsStmt(), ExecAlterObjectDependsStmt(), ExecAlterObjectSchemaStmt(), ExecAlterOwnerStmt(), ExecRenameStmt(), ExecSecLabelStmt(), get_object_address_rv(), pg_get_object_address(), and RemoveObjects().

get_object_address_attrdef()

static ObjectAddress get_object_address_attrdef ( ObjectType  objtype, List *  object, Relation *  relp, LOCKMODE  lockmode, bool  missing_ok  )

static

Definition at line 1589 of file objectaddress.c.

{
    ObjectAddress address;
    List       *relname;
    Oid         reloid;
    Relation    relation;
    const char *attname;
    AttrNumber  attnum;
    TupleDesc   tupdesc;
    Oid         defoid;
 
    /* Extract relation name and open relation. */
    if (list_length(object) < 2)
        ereport(ERROR,
                (errcode(ERRCODE_SYNTAX_ERROR),
                 errmsg("column name must be qualified")));
    attname = strVal(llast(object));
    relname = list_copy_head(object, list_length(object) - 1);
    /* XXX no missing_ok support here */
    relation = relation_openrv(makeRangeVarFromNameList(relname), lockmode);
    reloid = RelationGetRelid(relation);
 
    tupdesc = RelationGetDescr(relation);
 
    /* Look up attribute number and fetch the pg_attrdef OID */
    attnum = get_attnum(reloid, attname);
    defoid = InvalidOid;
    if (attnum != InvalidAttrNumber && tupdesc->constr != NULL)
        defoid = GetAttrDefaultOid(reloid, attnum);
    if (!OidIsValid(defoid))
    {
        if (!missing_ok)
            ereport(ERROR,
                    (errcode(ERRCODE_UNDEFINED_COLUMN),
                     errmsg("default value for column \"%s\" of relation \"%s\" does not exist",
                            attname, NameListToString(relname))));
 
        address.classId = AttrDefaultRelationId;
        address.objectId = InvalidOid;
        address.objectSubId = InvalidAttrNumber;
        relation_close(relation, lockmode);
        return address;
    }
 
    address.classId = AttrDefaultRelationId;
    address.objectId = defoid;
    address.objectSubId = 0;
 
    *relp = relation;
    return address;
}

References attname, attnum, ObjectAddress::classId, TupleDescData::constr, ereport, errcode(), errmsg(), ERROR, get_attnum(), GetAttrDefaultOid(), InvalidAttrNumber, InvalidOid, list_copy_head(), list_length(), llast, makeRangeVarFromNameList(), NameListToString(), ObjectAddress::objectId, ObjectAddress::objectSubId, OidIsValid, relation_close(), relation_openrv(), RelationGetDescr, RelationGetRelid, relname, and strVal.

Referenced by get_object_address().

get_object_address_attribute()

static ObjectAddress get_object_address_attribute ( ObjectType  objtype, List *  object, Relation *  relp, LOCKMODE  lockmode, bool  missing_ok  )

static

Definition at line 1538 of file objectaddress.c.

{
    ObjectAddress address;
    List       *relname;
    Oid         reloid;
    Relation    relation;
    const char *attname;
    AttrNumber  attnum;
 
    /* Extract relation name and open relation. */
    if (list_length(object) < 2)
        ereport(ERROR,
                (errcode(ERRCODE_SYNTAX_ERROR),
                 errmsg("column name must be qualified")));
    attname = strVal(llast(object));
    relname = list_copy_head(object, list_length(object) - 1);
    /* XXX no missing_ok support here */
    relation = relation_openrv(makeRangeVarFromNameList(relname), lockmode);
    reloid = RelationGetRelid(relation);
 
    /* Look up attribute and construct return value. */
    attnum = get_attnum(reloid, attname);
    if (attnum == InvalidAttrNumber)
    {
        if (!missing_ok)
            ereport(ERROR,
                    (errcode(ERRCODE_UNDEFINED_COLUMN),
                     errmsg("column \"%s\" of relation \"%s\" does not exist",
                            attname, NameListToString(relname))));
 
        address.classId = RelationRelationId;
        address.objectId = InvalidOid;
        address.objectSubId = InvalidAttrNumber;
        relation_close(relation, lockmode);
        return address;
    }
 
    address.classId = RelationRelationId;
    address.objectId = reloid;
    address.objectSubId = attnum;
 
    *relp = relation;
    return address;
}

References attname, attnum, ObjectAddress::classId, ereport, errcode(), errmsg(), ERROR, get_attnum(), InvalidAttrNumber, InvalidOid, list_copy_head(), list_length(), llast, makeRangeVarFromNameList(), NameListToString(), ObjectAddress::objectId, ObjectAddress::objectSubId, relation_close(), relation_openrv(), RelationGetRelid, relname, and strVal.

Referenced by get_object_address().

get_object_address_defacl()

static ObjectAddress get_object_address_defacl ( List *  object, bool  missing_ok  )

static

Definition at line 2002 of file objectaddress.c.

{
    HeapTuple   tp;
    Oid         userid;
    Oid         schemaid;
    char       *username;
    char       *schema;
    char        objtype;
    char       *objtype_str;
    ObjectAddress address;
 
    ObjectAddressSet(address, DefaultAclRelationId, InvalidOid);
 
    /*
     * First figure out the textual attributes so that they can be used for
     * error reporting.
     */
    username = strVal(lsecond(object));
    if (list_length(object) >= 3)
        schema = (char *) strVal(lthird(object));
    else
        schema = NULL;
 
    /*
     * Decode defaclobjtype.  Only first char is considered; the rest of the
     * string, if any, is blissfully ignored.
     */
    objtype = ((char *) strVal(linitial(object)))[0];
    switch (objtype)
    {
        case DEFACLOBJ_RELATION:
            objtype_str = "tables";
            break;
        case DEFACLOBJ_SEQUENCE:
            objtype_str = "sequences";
            break;
        case DEFACLOBJ_FUNCTION:
            objtype_str = "functions";
            break;
        case DEFACLOBJ_TYPE:
            objtype_str = "types";
            break;
        case DEFACLOBJ_NAMESPACE:
            objtype_str = "schemas";
            break;
        default:
            ereport(ERROR,
                    (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
                     errmsg("unrecognized default ACL object type \"%c\"", objtype),
                     errhint("Valid object types are \"%c\", \"%c\", \"%c\", \"%c\", \"%c\".",
                             DEFACLOBJ_RELATION,
                             DEFACLOBJ_SEQUENCE,
                             DEFACLOBJ_FUNCTION,
                             DEFACLOBJ_TYPE,
                             DEFACLOBJ_NAMESPACE)));
    }
 
    /*
     * Look up user ID.  Behave as "default ACL not found" if the user doesn't
     * exist.
     */
    tp = SearchSysCache1(AUTHNAME,
                         CStringGetDatum(username));
    if (!HeapTupleIsValid(tp))
        goto not_found;
    userid = ((Form_pg_authid) GETSTRUCT(tp))->oid;
    ReleaseSysCache(tp);
 
    /*
     * If a schema name was given, look up its OID.  If it doesn't exist,
     * behave as "default ACL not found".
     */
    if (schema)
    {
        schemaid = get_namespace_oid(schema, true);
        if (schemaid == InvalidOid)
            goto not_found;
    }
    else
        schemaid = InvalidOid;
 
    /* Finally, look up the pg_default_acl object */
    tp = SearchSysCache3(DEFACLROLENSPOBJ,
                         ObjectIdGetDatum(userid),
                         ObjectIdGetDatum(schemaid),
                         CharGetDatum(objtype));
    if (!HeapTupleIsValid(tp))
        goto not_found;
 
    address.objectId = ((Form_pg_default_acl) GETSTRUCT(tp))->oid;
    ReleaseSysCache(tp);
 
    return address;
 
not_found:
    if (!missing_ok)
    {
        if (schema)
            ereport(ERROR,
                    (errcode(ERRCODE_UNDEFINED_OBJECT),
                     errmsg("default ACL for user \"%s\" in schema \"%s\" on %s does not exist",
                            username, schema, objtype_str)));
        else
            ereport(ERROR,
                    (errcode(ERRCODE_UNDEFINED_OBJECT),
                     errmsg("default ACL for user \"%s\" on %s does not exist",
                            username, objtype_str)));
    }
    return address;
}

References AUTHNAME, CharGetDatum(), CStringGetDatum(), DEFACLROLENSPOBJ, ereport, errcode(), errhint(), errmsg(), ERROR, get_namespace_oid(), GETSTRUCT, HeapTupleIsValid, InvalidOid, linitial, list_length(), lsecond, lthird, ObjectAddressSet, ObjectAddress::objectId, ObjectIdGetDatum(), ReleaseSysCache(), SearchSysCache1(), SearchSysCache3(), strVal, and username.

Referenced by get_object_address().

get_object_address_opcf()

static ObjectAddress get_object_address_opcf ( ObjectType  objtype, List *  object, bool  missing_ok  )

static

Definition at line 1686 of file objectaddress.c.

{
    Oid         amoid;
    ObjectAddress address;
 
    /* XXX no missing_ok support here */
    amoid = get_index_am_oid(strVal(linitial(object)), false);
    object = list_copy_tail(object, 1);
 
    switch (objtype)
    {
        case OBJECT_OPCLASS:
            address.classId = OperatorClassRelationId;
            address.objectId = get_opclass_oid(amoid, object, missing_ok);
            address.objectSubId = 0;
            break;
        case OBJECT_OPFAMILY:
            address.classId = OperatorFamilyRelationId;
            address.objectId = get_opfamily_oid(amoid, object, missing_ok);
            address.objectSubId = 0;
            break;
        default:
            elog(ERROR, "unrecognized object type: %d", (int) objtype);
            /* placate compiler, which doesn't know elog won't return */
            address.classId = InvalidOid;
            address.objectId = InvalidOid;
            address.objectSubId = 0;
    }
 
    return address;
}

References ObjectAddress::classId, elog(), ERROR, get_index_am_oid(), get_opclass_oid(), get_opfamily_oid(), InvalidOid, linitial, list_copy_tail(), OBJECT_OPCLASS, OBJECT_OPFAMILY, ObjectAddress::objectId, ObjectAddress::objectSubId, and strVal.

Referenced by get_object_address(), and get_object_address_opf_member().

get_object_address_opf_member()

static ObjectAddress get_object_address_opf_member ( ObjectType  objtype, List *  object, bool  missing_ok  )

static

Definition at line 1724 of file objectaddress.c.

{
    ObjectAddress famaddr;
    ObjectAddress address;
    ListCell   *cell;
    List       *copy;
    TypeName   *typenames[2];
    Oid         typeoids[2];
    int         membernum;
    int         i;
 
    /*
     * The last element of the object list contains the strategy or procedure
     * number.  We need to strip that out before getting the opclass/family
     * address.  The rest can be used directly by get_object_address_opcf().
     */
    membernum = atoi(strVal(llast(linitial(object))));
    copy = list_copy_head(linitial(object), list_length(linitial(object)) - 1);
 
    /* no missing_ok support here */
    famaddr = get_object_address_opcf(OBJECT_OPFAMILY, copy, false);
 
    /* find out left/right type names and OIDs */
    typenames[0] = typenames[1] = NULL;
    typeoids[0] = typeoids[1] = InvalidOid;
    i = 0;
    foreach(cell, lsecond(object))
    {
        ObjectAddress typaddr;
 
        typenames[i] = lfirst_node(TypeName, cell);
        typaddr = get_object_address_type(OBJECT_TYPE, typenames[i], missing_ok);
        typeoids[i] = typaddr.objectId;
        if (++i >= 2)
            break;
    }
 
    switch (objtype)
    {
        case OBJECT_AMOP:
            {
                HeapTuple   tp;
 
                ObjectAddressSet(address, AccessMethodOperatorRelationId,
                                 InvalidOid);
 
                tp = SearchSysCache4(AMOPSTRATEGY,
                                     ObjectIdGetDatum(famaddr.objectId),
                                     ObjectIdGetDatum(typeoids[0]),
                                     ObjectIdGetDatum(typeoids[1]),
                                     Int16GetDatum(membernum));
                if (!HeapTupleIsValid(tp))
                {
                    if (!missing_ok)
                        ereport(ERROR,
                                (errcode(ERRCODE_UNDEFINED_OBJECT),
                                 errmsg("operator %d (%s, %s) of %s does not exist",
                                        membernum,
                                        TypeNameToString(typenames[0]),
                                        TypeNameToString(typenames[1]),
                                        getObjectDescription(&famaddr, false))));
                }
                else
                {
                    address.objectId = ((Form_pg_amop) GETSTRUCT(tp))->oid;
                    ReleaseSysCache(tp);
                }
            }
            break;
 
        case OBJECT_AMPROC:
            {
                HeapTuple   tp;
 
                ObjectAddressSet(address, AccessMethodProcedureRelationId,
                                 InvalidOid);
 
                tp = SearchSysCache4(AMPROCNUM,
                                     ObjectIdGetDatum(famaddr.objectId),
                                     ObjectIdGetDatum(typeoids[0]),
                                     ObjectIdGetDatum(typeoids[1]),
                                     Int16GetDatum(membernum));
                if (!HeapTupleIsValid(tp))
                {
                    if (!missing_ok)
                        ereport(ERROR,
                                (errcode(ERRCODE_UNDEFINED_OBJECT),
                                 errmsg("function %d (%s, %s) of %s does not exist",
                                        membernum,
                                        TypeNameToString(typenames[0]),
                                        TypeNameToString(typenames[1]),
                                        getObjectDescription(&famaddr, false))));
                }
                else
                {
                    address.objectId = ((Form_pg_amproc) GETSTRUCT(tp))->oid;
                    ReleaseSysCache(tp);
                }
            }
            break;
        default:
            elog(ERROR, "unrecognized object type: %d", (int) objtype);
    }
 
    return address;
}

References AMOPSTRATEGY, AMPROCNUM, elog(), ereport, errcode(), errmsg(), ERROR, get_object_address_opcf(), get_object_address_type(), getObjectDescription(), GETSTRUCT, HeapTupleIsValid, i, Int16GetDatum(), InvalidOid, lfirst_node, linitial, list_copy_head(), list_length(), llast, lsecond, OBJECT_AMOP, OBJECT_AMPROC, OBJECT_OPFAMILY, OBJECT_TYPE, ObjectAddressSet, ObjectAddress::objectId, ObjectIdGetDatum(), ReleaseSysCache(), SearchSysCache4(), strVal, typenames, and TypeNameToString().

Referenced by get_object_address().

get_object_address_publication_rel()

static ObjectAddress get_object_address_publication_rel ( List *  object, Relation *  relp, bool  missing_ok  )

static

Definition at line 1907 of file objectaddress.c.

{
    ObjectAddress address;
    Relation    relation;
    List       *relname;
    char       *pubname;
    Publication *pub;
 
    ObjectAddressSet(address, PublicationRelRelationId, InvalidOid);
 
    relname = linitial(object);
    relation = relation_openrv_extended(makeRangeVarFromNameList(relname),
                                        AccessShareLock, missing_ok);
    if (!relation)
        return address;
 
    /* fetch publication name from input list */
    pubname = strVal(lsecond(object));
 
    /* Now look up the pg_publication tuple */
    pub = GetPublicationByName(pubname, missing_ok);
    if (!pub)
    {
        relation_close(relation, AccessShareLock);
        return address;
    }
 
    /* Find the publication relation mapping in syscache. */
    address.objectId =
        GetSysCacheOid2(PUBLICATIONRELMAP, Anum_pg_publication_rel_oid,
                        ObjectIdGetDatum(RelationGetRelid(relation)),
                        ObjectIdGetDatum(pub->oid));
    if (!OidIsValid(address.objectId))
    {
        if (!missing_ok)
            ereport(ERROR,
                    (errcode(ERRCODE_UNDEFINED_OBJECT),
                     errmsg("publication relation \"%s\" in publication \"%s\" does not exist",
                            RelationGetRelationName(relation), pubname)));
        relation_close(relation, AccessShareLock);
        return address;
    }
 
    *relp = relation;
    return address;
}

References AccessShareLock, ereport, errcode(), errmsg(), ERROR, GetPublicationByName(), GetSysCacheOid2, InvalidOid, linitial, lsecond, makeRangeVarFromNameList(), ObjectAddressSet, ObjectAddress::objectId, ObjectIdGetDatum(), Publication::oid, OidIsValid, PUBLICATIONRELMAP, relation_close(), relation_openrv_extended(), RelationGetRelationName, RelationGetRelid, relname, and strVal.

Referenced by get_object_address().

get_object_address_publication_schema()

static ObjectAddress get_object_address_publication_schema ( List *  object, bool  missing_ok  )

static

Definition at line 1960 of file objectaddress.c.

{
    ObjectAddress address;
    Publication *pub;
    char       *pubname;
    char       *schemaname;
    Oid         schemaid;
 
    ObjectAddressSet(address, PublicationNamespaceRelationId, InvalidOid);
 
    /* Fetch schema name and publication name from input list */
    schemaname = strVal(linitial(object));
    pubname = strVal(lsecond(object));
 
    schemaid = get_namespace_oid(schemaname, missing_ok);
    if (!OidIsValid(schemaid))
        return address;
 
    /* Now look up the pg_publication tuple */
    pub = GetPublicationByName(pubname, missing_ok);
    if (!pub)
        return address;
 
    /* Find the publication schema mapping in syscache */
    address.objectId =
        GetSysCacheOid2(PUBLICATIONNAMESPACEMAP,
                        Anum_pg_publication_namespace_oid,
                        ObjectIdGetDatum(schemaid),
                        ObjectIdGetDatum(pub->oid));
    if (!OidIsValid(address.objectId) && !missing_ok)
        ereport(ERROR,
                (errcode(ERRCODE_UNDEFINED_OBJECT),
                 errmsg("publication schema \"%s\" in publication \"%s\" does not exist",
                        schemaname, pubname)));
 
    return address;
}

References ereport, errcode(), errmsg(), ERROR, get_namespace_oid(), GetPublicationByName(), GetSysCacheOid2, InvalidOid, linitial, lsecond, ObjectAddressSet, ObjectAddress::objectId, ObjectIdGetDatum(), Publication::oid, OidIsValid, PUBLICATIONNAMESPACEMAP, and strVal.

Referenced by get_object_address().

get_object_address_relobject()

static ObjectAddress get_object_address_relobject ( ObjectType  objtype, List *  object, Relation *  relp, bool  missing_ok  )

static

Definition at line 1459 of file objectaddress.c.

{
    ObjectAddress address;
    Relation    relation = NULL;
    int         nnames;
    const char *depname;
    List       *relname;
    Oid         reloid;
 
    /* Extract name of dependent object. */
    depname = strVal(llast(object));
 
    /* Separate relation name from dependent object name. */
    nnames = list_length(object);
    if (nnames < 2)
        ereport(ERROR,
                (errcode(ERRCODE_SYNTAX_ERROR),
                 errmsg("must specify relation and object name")));
 
    /* Extract relation name and open relation. */
    relname = list_copy_head(object, nnames - 1);
    relation = table_openrv_extended(makeRangeVarFromNameList(relname),
                                     AccessShareLock,
                                     missing_ok);
 
    reloid = relation ? RelationGetRelid(relation) : InvalidOid;
 
    switch (objtype)
    {
        case OBJECT_RULE:
            address.classId = RewriteRelationId;
            address.objectId = relation ?
                get_rewrite_oid(reloid, depname, missing_ok) : InvalidOid;
            address.objectSubId = 0;
            break;
        case OBJECT_TRIGGER:
            address.classId = TriggerRelationId;
            address.objectId = relation ?
                get_trigger_oid(reloid, depname, missing_ok) : InvalidOid;
            address.objectSubId = 0;
            break;
        case OBJECT_TABCONSTRAINT:
            address.classId = ConstraintRelationId;
            address.objectId = relation ?
                get_relation_constraint_oid(reloid, depname, missing_ok) :
                InvalidOid;
            address.objectSubId = 0;
            break;
        case OBJECT_POLICY:
            address.classId = PolicyRelationId;
            address.objectId = relation ?
                get_relation_policy_oid(reloid, depname, missing_ok) :
                InvalidOid;
            address.objectSubId = 0;
            break;
        default:
            elog(ERROR, "unrecognized object type: %d", (int) objtype);
    }
 
    /* Avoid relcache leak when object not found. */
    if (!OidIsValid(address.objectId))
    {
        if (relation != NULL)
            table_close(relation, AccessShareLock);
 
        relation = NULL;        /* department of accident prevention */
        return address;
    }
 
    /* Done. */
    *relp = relation;
    return address;
}

References AccessShareLock, ObjectAddress::classId, elog(), ereport, errcode(), errmsg(), ERROR, get_relation_constraint_oid(), get_relation_policy_oid(), get_rewrite_oid(), get_trigger_oid(), InvalidOid, list_copy_head(), list_length(), llast, makeRangeVarFromNameList(), OBJECT_POLICY, OBJECT_RULE, OBJECT_TABCONSTRAINT, OBJECT_TRIGGER, ObjectAddress::objectId, ObjectAddress::objectSubId, OidIsValid, RelationGetRelid, relname, strVal, table_close(), and table_openrv_extended().

Referenced by get_object_address().

get_object_address_rv()

ObjectAddress get_object_address_rv	(	ObjectType	objtype,
		RangeVar *	rel,
		List *	object,
		Relation *	relp,
		LOCKMODE	lockmode,
		bool	missing_ok
	)

Definition at line 1264 of file objectaddress.c.

{
    if (rel)
    {
        object = lcons(makeString(rel->relname), object);
        if (rel->schemaname)
            object = lcons(makeString(rel->schemaname), object);
        if (rel->catalogname)
            object = lcons(makeString(rel->catalogname), object);
    }
 
    return get_object_address(objtype, (Node *) object,
                              relp, lockmode, missing_ok);
}

References RangeVar::catalogname, get_object_address(), lcons(), makeString(), RangeVar::relname, and RangeVar::schemaname.

Referenced by ExecAlterObjectDependsStmt().

get_object_address_type()

static ObjectAddress get_object_address_type ( ObjectType  objtype, TypeName *  typename, bool  missing_ok  )

static

Definition at line 1647 of file objectaddress.c.

{
    ObjectAddress address;
    Type        tup;
 
    address.classId = TypeRelationId;
    address.objectId = InvalidOid;
    address.objectSubId = 0;
 
    tup = LookupTypeName(NULL, typename, NULL, missing_ok);
    if (!HeapTupleIsValid(tup))
    {
        if (!missing_ok)
            ereport(ERROR,
                    (errcode(ERRCODE_UNDEFINED_OBJECT),
                     errmsg("type \"%s\" does not exist",
                            TypeNameToString(typename))));
        return address;
    }
    address.objectId = typeTypeId(tup);
 
    if (objtype == OBJECT_DOMAIN)
    {
        if (((Form_pg_type) GETSTRUCT(tup))->typtype != TYPTYPE_DOMAIN)
            ereport(ERROR,
                    (errcode(ERRCODE_WRONG_OBJECT_TYPE),
                     errmsg("\"%s\" is not a domain",
                            TypeNameToString(typename))));
    }
 
    ReleaseSysCache(tup);
 
    return address;
}

References ObjectAddress::classId, ereport, errcode(), errmsg(), ERROR, GETSTRUCT, HeapTupleIsValid, InvalidOid, LookupTypeName(), OBJECT_DOMAIN, ObjectAddress::objectId, ObjectAddress::objectSubId, ReleaseSysCache(), TypeNameToString(), and typeTypeId().

Referenced by get_object_address(), and get_object_address_opf_member().

get_object_address_unqualified()

static ObjectAddress get_object_address_unqualified ( ObjectType  objtype, String *  strval, bool  missing_ok  )

static

Definition at line 1286 of file objectaddress.c.

{
    const char *name;
    ObjectAddress address;
 
    name = strVal(strval);
 
    /* Translate name to OID. */
    switch (objtype)
    {
        case OBJECT_ACCESS_METHOD:
            address.classId = AccessMethodRelationId;
            address.objectId = get_am_oid(name, missing_ok);
            address.objectSubId = 0;
            break;
        case OBJECT_DATABASE:
            address.classId = DatabaseRelationId;
            address.objectId = get_database_oid(name, missing_ok);
            address.objectSubId = 0;
            break;
        case OBJECT_EXTENSION:
            address.classId = ExtensionRelationId;
            address.objectId = get_extension_oid(name, missing_ok);
            address.objectSubId = 0;
            break;
        case OBJECT_TABLESPACE:
            address.classId = TableSpaceRelationId;
            address.objectId = get_tablespace_oid(name, missing_ok);
            address.objectSubId = 0;
            break;
        case OBJECT_ROLE:
            address.classId = AuthIdRelationId;
            address.objectId = get_role_oid(name, missing_ok);
            address.objectSubId = 0;
            break;
        case OBJECT_SCHEMA:
            address.classId = NamespaceRelationId;
            address.objectId = get_namespace_oid(name, missing_ok);
            address.objectSubId = 0;
            break;
        case OBJECT_LANGUAGE:
            address.classId = LanguageRelationId;
            address.objectId = get_language_oid(name, missing_ok);
            address.objectSubId = 0;
            break;
        case OBJECT_FDW:
            address.classId = ForeignDataWrapperRelationId;
            address.objectId = get_foreign_data_wrapper_oid(name, missing_ok);
            address.objectSubId = 0;
            break;
        case OBJECT_FOREIGN_SERVER:
            address.classId = ForeignServerRelationId;
            address.objectId = get_foreign_server_oid(name, missing_ok);
            address.objectSubId = 0;
            break;
        case OBJECT_EVENT_TRIGGER:
            address.classId = EventTriggerRelationId;
            address.objectId = get_event_trigger_oid(name, missing_ok);
            address.objectSubId = 0;
            break;
        case OBJECT_PARAMETER_ACL:
            address.classId = ParameterAclRelationId;
            address.objectId = ParameterAclLookup(name, missing_ok);
            address.objectSubId = 0;
            break;
        case OBJECT_PUBLICATION:
            address.classId = PublicationRelationId;
            address.objectId = get_publication_oid(name, missing_ok);
            address.objectSubId = 0;
            break;
        case OBJECT_SUBSCRIPTION:
            address.classId = SubscriptionRelationId;
            address.objectId = get_subscription_oid(name, missing_ok);
            address.objectSubId = 0;
            break;
        default:
            elog(ERROR, "unrecognized object type: %d", (int) objtype);
            /* placate compiler, which doesn't know elog won't return */
            address.classId = InvalidOid;
            address.objectId = InvalidOid;
            address.objectSubId = 0;
    }
 
    return address;
}

References ObjectAddress::classId, elog(), ERROR, get_am_oid(), get_database_oid(), get_event_trigger_oid(), get_extension_oid(), get_foreign_data_wrapper_oid(), get_foreign_server_oid(), get_language_oid(), get_namespace_oid(), get_publication_oid(), get_role_oid(), get_subscription_oid(), get_tablespace_oid(), InvalidOid, name, OBJECT_ACCESS_METHOD, OBJECT_DATABASE, OBJECT_EVENT_TRIGGER, OBJECT_EXTENSION, OBJECT_FDW, OBJECT_FOREIGN_SERVER, OBJECT_LANGUAGE, OBJECT_PARAMETER_ACL, OBJECT_PUBLICATION, OBJECT_ROLE, OBJECT_SCHEMA, OBJECT_SUBSCRIPTION, OBJECT_TABLESPACE, ObjectAddress::objectId, ObjectAddress::objectSubId, ParameterAclLookup(), and strVal.

Referenced by get_object_address().

get_object_address_usermapping()

static ObjectAddress get_object_address_usermapping ( List *  object, bool  missing_ok  )

static

Definition at line 1836 of file objectaddress.c.

{
    ObjectAddress address;
    Oid         userid;
    char       *username;
    char       *servername;
    ForeignServer *server;
    HeapTuple   tp;
 
    ObjectAddressSet(address, UserMappingRelationId, InvalidOid);
 
    /* fetch string names from input lists, for error messages */
    username = strVal(linitial(object));
    servername = strVal(lsecond(object));
 
    /* look up pg_authid OID of mapped user; InvalidOid if PUBLIC */
    if (strcmp(username, "public") == 0)
        userid = InvalidOid;
    else
    {
        tp = SearchSysCache1(AUTHNAME,
                             CStringGetDatum(username));
        if (!HeapTupleIsValid(tp))
        {
            if (!missing_ok)
                ereport(ERROR,
                        (errcode(ERRCODE_UNDEFINED_OBJECT),
                         errmsg("user mapping for user \"%s\" on server \"%s\" does not exist",
                                username, servername)));
            return address;
        }
        userid = ((Form_pg_authid) GETSTRUCT(tp))->oid;
        ReleaseSysCache(tp);
    }
 
    /* Now look up the pg_user_mapping tuple */
    server = GetForeignServerByName(servername, true);
    if (!server)
    {
        if (!missing_ok)
            ereport(ERROR,
                    (errcode(ERRCODE_UNDEFINED_OBJECT),
                     errmsg("server \"%s\" does not exist", servername)));
        return address;
    }
    tp = SearchSysCache2(USERMAPPINGUSERSERVER,
                         ObjectIdGetDatum(userid),
                         ObjectIdGetDatum(server->serverid));
    if (!HeapTupleIsValid(tp))
    {
        if (!missing_ok)
            ereport(ERROR,
                    (errcode(ERRCODE_UNDEFINED_OBJECT),
                     errmsg("user mapping for user \"%s\" on server \"%s\" does not exist",
                            username, servername)));
        return address;
    }
 
    address.objectId = ((Form_pg_user_mapping) GETSTRUCT(tp))->oid;
 
    ReleaseSysCache(tp);
 
    return address;
}

References AUTHNAME, CStringGetDatum(), ereport, errcode(), errmsg(), ERROR, GetForeignServerByName(), GETSTRUCT, HeapTupleIsValid, InvalidOid, linitial, lsecond, ObjectAddressSet, ObjectAddress::objectId, ObjectIdGetDatum(), ReleaseSysCache(), SearchSysCache1(), SearchSysCache2(), ForeignServer::serverid, strVal, and username.

Referenced by get_object_address().

get_object_attnum_acl()

AttrNumber get_object_attnum_acl

(

Oid

class_id

)

Definition at line 2728 of file objectaddress.c.

{
    const ObjectPropertyType *prop = get_object_property_data(class_id);
 
    return prop->attnum_acl;
}

References ObjectPropertyType::attnum_acl, and get_object_property_data().

Referenced by AlterObjectOwner_internal(), ExecGrant_common(), object_aclmask(), and recordExtObjInitPriv().

get_object_attnum_name()

AttrNumber get_object_attnum_name

(

Oid

class_id

)

Definition at line 2704 of file objectaddress.c.

{
    const ObjectPropertyType *prop = get_object_property_data(class_id);
 
    return prop->attnum_name;
}

References ObjectPropertyType::attnum_name, and get_object_property_data().

Referenced by AlterObjectNamespace_internal(), AlterObjectOwner_internal(), AlterObjectRename_internal(), EventTriggerSQLDropAddObject(), ExecGrant_common(), and pg_identify_object().

get_object_attnum_namespace()

AttrNumber get_object_attnum_namespace

(

Oid

class_id

)

Definition at line 2712 of file objectaddress.c.

{
    const ObjectPropertyType *prop = get_object_property_data(class_id);
 
    return prop->attnum_namespace;
}

References ObjectPropertyType::attnum_namespace, and get_object_property_data().

Referenced by AlterObjectNamespace_internal(), AlterObjectOwner_internal(), AlterObjectRename_internal(), EventTriggerSQLDropAddObject(), pg_event_trigger_ddl_commands(), and pg_identify_object().

get_object_attnum_oid()

AttrNumber get_object_attnum_oid

(

Oid

class_id

)

Definition at line 2696 of file objectaddress.c.

{
    const ObjectPropertyType *prop = get_object_property_data(class_id);
 
    return prop->attnum_oid;
}

References ObjectPropertyType::attnum_oid, and get_object_property_data().

Referenced by AlterObjectOwner_internal(), DropObjectById(), EventTriggerSQLDropAddObject(), object_ownercheck(), pg_event_trigger_ddl_commands(), and pg_identify_object().

get_object_attnum_owner()

AttrNumber get_object_attnum_owner

(

Oid

class_id

)

Definition at line 2720 of file objectaddress.c.

{
    const ObjectPropertyType *prop = get_object_property_data(class_id);
 
    return prop->attnum_owner;
}

References ObjectPropertyType::attnum_owner, and get_object_property_data().

Referenced by AlterObjectNamespace_internal(), AlterObjectOwner_internal(), AlterObjectRename_internal(), ExecGrant_common(), object_aclmask(), and object_ownercheck().

get_object_catcache_name()

int get_object_catcache_name

(

Oid

class_id

)

Definition at line 2688 of file objectaddress.c.

{
    const ObjectPropertyType *prop = get_object_property_data(class_id);
 
    return prop->name_catcache_id;
}

References get_object_property_data(), and ObjectPropertyType::name_catcache_id.

Referenced by AlterObjectNamespace_internal(), and AlterObjectRename_internal().

get_object_catcache_oid()

int get_object_catcache_oid

(

Oid

class_id

)

Definition at line 2680 of file objectaddress.c.

{
    const ObjectPropertyType *prop = get_object_property_data(class_id);
 
    return prop->oid_catcache_id;
}

References get_object_property_data(), and ObjectPropertyType::oid_catcache_id.

Referenced by AlterObjectNamespace_internal(), AlterObjectRename_internal(), DropObjectById(), ExecGrant_common(), get_catalog_object_by_oid(), object_aclmask(), object_ownercheck(), and recordExtObjInitPriv().

get_object_class_descr()

const char* get_object_class_descr

(

Oid

class_id

)

Definition at line 2664 of file objectaddress.c.

{
    const ObjectPropertyType *prop = get_object_property_data(class_id);
 
    return prop->class_descr;
}

References ObjectPropertyType::class_descr, and get_object_property_data().

Referenced by DropObjectById(), ExecGrant_common(), object_aclmask(), object_ownercheck(), and recordExtObjInitPriv().

get_object_namensp_unique()

bool get_object_namensp_unique

(

Oid

class_id

)

Definition at line 2761 of file objectaddress.c.

{
    const ObjectPropertyType *prop = get_object_property_data(class_id);
 
    return prop->is_nsp_name_unique;
}

References get_object_property_data(), and ObjectPropertyType::is_nsp_name_unique.

Referenced by EventTriggerSQLDropAddObject(), and pg_identify_object().

get_object_namespace()

Oid get_object_namespace

(

const ObjectAddress *

address

)

Definition at line 2608 of file objectaddress.c.

{
    int         cache;
    HeapTuple   tuple;
    Oid         oid;
    const ObjectPropertyType *property;
 
    /* If not owned by a namespace, just return InvalidOid. */
    property = get_object_property_data(address->classId);
    if (property->attnum_namespace == InvalidAttrNumber)
        return InvalidOid;
 
    /* Currently, we can only handle object types with system caches. */
    cache = property->oid_catcache_id;
    Assert(cache != -1);
 
    /* Fetch tuple from syscache and extract namespace attribute. */
    tuple = SearchSysCache1(cache, ObjectIdGetDatum(address->objectId));
    if (!HeapTupleIsValid(tuple))
        elog(ERROR, "cache lookup failed for cache %d oid %u",
             cache, address->objectId);
    oid = DatumGetObjectId(SysCacheGetAttrNotNull(cache,
                                                  tuple,
                                                  property->attnum_namespace));
    ReleaseSysCache(tuple);
 
    return oid;
}

References Assert(), ObjectPropertyType::attnum_namespace, ObjectAddress::classId, DatumGetObjectId(), elog(), ERROR, get_object_property_data(), HeapTupleIsValid, InvalidAttrNumber, InvalidOid, ObjectAddress::objectId, ObjectIdGetDatum(), ReleaseSysCache(), SearchSysCache1(), and SysCacheGetAttrNotNull().

Referenced by RemoveObjects().

get_object_oid_index()

Oid get_object_oid_index

(

Oid

class_id

)

Definition at line 2672 of file objectaddress.c.

{
    const ObjectPropertyType *prop = get_object_property_data(class_id);
 
    return prop->oid_index_oid;
}

References get_object_property_data(), and ObjectPropertyType::oid_index_oid.

Referenced by DropObjectById(), get_catalog_object_by_oid(), and object_ownercheck().

get_object_property_data()

static const ObjectPropertyType * get_object_property_data ( Oid  class_id )

static

Definition at line 2790 of file objectaddress.c.

{
    static const ObjectPropertyType *prop_last = NULL;
    int         index;
 
    /*
     * A shortcut to speed up multiple consecutive lookups of a particular
     * object class.
     */
    if (prop_last && prop_last->class_oid == class_id)
        return prop_last;
 
    for (index = 0; index < lengthof(ObjectProperty); index++)
    {
        if (ObjectProperty[index].class_oid == class_id)
        {
            prop_last = &ObjectProperty[index];
            return &ObjectProperty[index];
        }
    }
 
    ereport(ERROR,
            (errmsg_internal("unrecognized class ID: %u", class_id)));
 
    return NULL;                /* keep MSC compiler happy */
}

References ObjectPropertyType::class_oid, ereport, errmsg_internal(), ERROR, lengthof, and ObjectProperty.

Referenced by get_object_attnum_acl(), get_object_attnum_name(), get_object_attnum_namespace(), get_object_attnum_oid(), get_object_attnum_owner(), get_object_catcache_name(), get_object_catcache_oid(), get_object_class_descr(), get_object_namensp_unique(), get_object_namespace(), get_object_oid_index(), and get_object_type().

get_object_type()

ObjectType get_object_type	(	Oid	class_id,
		Oid	object_id
	)

Definition at line 2743 of file objectaddress.c.

{
    const ObjectPropertyType *prop = get_object_property_data(class_id);
 
    if (prop->objtype == OBJECT_TABLE)
    {
        /*
         * If the property data says it's a table, dig a little deeper to get
         * the real relation kind, so that callers can produce more precise
         * error messages.
         */
        return get_relkind_objtype(get_rel_relkind(object_id));
    }
    else
        return prop->objtype;
}

References get_object_property_data(), get_rel_relkind(), get_relkind_objtype(), OBJECT_TABLE, and ObjectPropertyType::objtype.

Referenced by AlterObjectNamespace_internal(), AlterObjectOwner_internal(), AlterObjectRename_internal(), ExecGrant_common(), and object_aclmask().

get_relation_by_qualified_name()

static ObjectAddress get_relation_by_qualified_name ( ObjectType  objtype, List *  object, Relation *  relp, LOCKMODE  lockmode, bool  missing_ok  )

static

Definition at line 1377 of file objectaddress.c.

{
    Relation    relation;
    ObjectAddress address;
 
    address.classId = RelationRelationId;
    address.objectId = InvalidOid;
    address.objectSubId = 0;
 
    relation = relation_openrv_extended(makeRangeVarFromNameList(object),
                                        lockmode, missing_ok);
    if (!relation)
        return address;
 
    switch (objtype)
    {
        case OBJECT_INDEX:
            if (relation->rd_rel->relkind != RELKIND_INDEX &&
                relation->rd_rel->relkind != RELKIND_PARTITIONED_INDEX)
                ereport(ERROR,
                        (errcode(ERRCODE_WRONG_OBJECT_TYPE),
                         errmsg("\"%s\" is not an index",
                                RelationGetRelationName(relation))));
            break;
        case OBJECT_SEQUENCE:
            if (relation->rd_rel->relkind != RELKIND_SEQUENCE)
                ereport(ERROR,
                        (errcode(ERRCODE_WRONG_OBJECT_TYPE),
                         errmsg("\"%s\" is not a sequence",
                                RelationGetRelationName(relation))));
            break;
        case OBJECT_TABLE:
            if (relation->rd_rel->relkind != RELKIND_RELATION &&
                relation->rd_rel->relkind != RELKIND_PARTITIONED_TABLE)
                ereport(ERROR,
                        (errcode(ERRCODE_WRONG_OBJECT_TYPE),
                         errmsg("\"%s\" is not a table",
                                RelationGetRelationName(relation))));
            break;
        case OBJECT_VIEW:
            if (relation->rd_rel->relkind != RELKIND_VIEW)
                ereport(ERROR,
                        (errcode(ERRCODE_WRONG_OBJECT_TYPE),
                         errmsg("\"%s\" is not a view",
                                RelationGetRelationName(relation))));
            break;
        case OBJECT_MATVIEW:
            if (relation->rd_rel->relkind != RELKIND_MATVIEW)
                ereport(ERROR,
                        (errcode(ERRCODE_WRONG_OBJECT_TYPE),
                         errmsg("\"%s\" is not a materialized view",
                                RelationGetRelationName(relation))));
            break;
        case OBJECT_FOREIGN_TABLE:
            if (relation->rd_rel->relkind != RELKIND_FOREIGN_TABLE)
                ereport(ERROR,
                        (errcode(ERRCODE_WRONG_OBJECT_TYPE),
                         errmsg("\"%s\" is not a foreign table",
                                RelationGetRelationName(relation))));
            break;
        default:
            elog(ERROR, "unrecognized object type: %d", (int) objtype);
            break;
    }
 
    /* Done. */
    address.objectId = RelationGetRelid(relation);
    *relp = relation;
 
    return address;
}

References ObjectAddress::classId, elog(), ereport, errcode(), errmsg(), ERROR, InvalidOid, makeRangeVarFromNameList(), OBJECT_FOREIGN_TABLE, OBJECT_INDEX, OBJECT_MATVIEW, OBJECT_SEQUENCE, OBJECT_TABLE, OBJECT_VIEW, ObjectAddress::objectId, ObjectAddress::objectSubId, RelationData::rd_rel, relation_openrv_extended(), RelationGetRelationName, and RelationGetRelid.

Referenced by get_object_address().

get_relkind_objtype()

ObjectType get_relkind_objtype

(

char

relkind

)

Definition at line 6106 of file objectaddress.c.

{
    switch (relkind)
    {
        case RELKIND_RELATION:
        case RELKIND_PARTITIONED_TABLE:
            return OBJECT_TABLE;
        case RELKIND_INDEX:
        case RELKIND_PARTITIONED_INDEX:
            return OBJECT_INDEX;
        case RELKIND_SEQUENCE:
            return OBJECT_SEQUENCE;
        case RELKIND_VIEW:
            return OBJECT_VIEW;
        case RELKIND_MATVIEW:
            return OBJECT_MATVIEW;
        case RELKIND_FOREIGN_TABLE:
            return OBJECT_FOREIGN_TABLE;
        case RELKIND_TOASTVALUE:
            return OBJECT_TABLE;
        default:
            /* Per above, don't raise an error */
            return OBJECT_TABLE;
    }
}

References OBJECT_FOREIGN_TABLE, OBJECT_INDEX, OBJECT_MATVIEW, OBJECT_SEQUENCE, OBJECT_TABLE, and OBJECT_VIEW.

Referenced by AlterTableMoveAll(), ATExecChangeOwner(), ATSimplePermissions(), checkFkeyPermissions(), CreateStatistics(), CreateTriggerFiringOn(), currtid_internal(), DefineQueryRewrite(), EnableDisableRule(), ExecCheckPermissions(), get_object_type(), get_rel_from_relname(), heap_force_common(), LockViewRecurse_walker(), LogicalRepSyncTableStart(), MergeAttributes(), pg_prewarm(), pgrowlocks(), PublicationAddTables(), RangeVarCallbackForAlterRelation(), RangeVarCallbackForDropRelation(), RangeVarCallbackForLockTable(), RangeVarCallbackForPolicy(), RangeVarCallbackForRenameRule(), RangeVarCallbackForRenameTrigger(), RangeVarCallbackOwnsRelation(), RangeVarCallbackOwnsTable(), RangeVarGetAndCheckCreationNamespace(), renameatt_check(), TargetPrivilegesCheck(), transformTableLikeClause(), and truncate_check_perms().

getConstraintTypeDescription()

static void getConstraintTypeDescription ( StringInfo  buffer, Oid  constroid, bool  missing_ok  )

static

Definition at line 4673 of file objectaddress.c.

{
    Relation    constrRel;
    HeapTuple   constrTup;
    Form_pg_constraint constrForm;
 
    constrRel = table_open(ConstraintRelationId, AccessShareLock);
    constrTup = get_catalog_object_by_oid(constrRel, Anum_pg_constraint_oid,
                                          constroid);
    if (!HeapTupleIsValid(constrTup))
    {
        if (!missing_ok)
            elog(ERROR, "cache lookup failed for constraint %u", constroid);
 
        table_close(constrRel, AccessShareLock);
 
        /* fallback to "constraint" for an undefined object */
        appendStringInfoString(buffer, "constraint");
        return;
    }
 
    constrForm = (Form_pg_constraint) GETSTRUCT(constrTup);
 
    if (OidIsValid(constrForm->conrelid))
        appendStringInfoString(buffer, "table constraint");
    else if (OidIsValid(constrForm->contypid))
        appendStringInfoString(buffer, "domain constraint");
    else
        elog(ERROR, "invalid constraint %u", constrForm->oid);
 
    table_close(constrRel, AccessShareLock);
}

References AccessShareLock, appendStringInfoString(), elog(), ERROR, get_catalog_object_by_oid(), GETSTRUCT, HeapTupleIsValid, OidIsValid, table_close(), and table_open().

Referenced by getObjectTypeDescription().

getObjectDescription()

char* getObjectDescription	(	const ObjectAddress *	object,
		bool	missing_ok
	)

Definition at line 2922 of file objectaddress.c.

{
    StringInfoData buffer;
 
    initStringInfo(&buffer);
 
    switch (getObjectClass(object))
    {
        case OCLASS_CLASS:
            if (object->objectSubId == 0)
                getRelationDescription(&buffer, object->objectId, missing_ok);
            else
            {
                /* column, not whole relation */
                StringInfoData rel;
                char       *attname = get_attname(object->objectId,
                                                  object->objectSubId,
                                                  missing_ok);
 
                if (!attname)
                    break;
 
                initStringInfo(&rel);
                getRelationDescription(&rel, object->objectId, missing_ok);
                /* translator: second %s is, e.g., "table %s" */
                appendStringInfo(&buffer, _("column %s of %s"),
                                 attname, rel.data);
                pfree(rel.data);
            }
            break;
 
        case OCLASS_PROC:
            {
                bits16      flags = FORMAT_PROC_INVALID_AS_NULL;
                char       *proname = format_procedure_extended(object->objectId,
                                                                flags);
 
                if (proname == NULL)
                    break;
 
                appendStringInfo(&buffer, _("function %s"), proname);
                break;
            }
 
        case OCLASS_TYPE:
            {
                bits16      flags = FORMAT_TYPE_INVALID_AS_NULL;
                char       *typname = format_type_extended(object->objectId, -1,
                                                           flags);
 
                if (typname == NULL)
                    break;
 
                appendStringInfo(&buffer, _("type %s"), typname);
                break;
            }
 
        case OCLASS_CAST:
            {
                Relation    castDesc;
                ScanKeyData skey[1];
                SysScanDesc rcscan;
                HeapTuple   tup;
                Form_pg_cast castForm;
 
                castDesc = table_open(CastRelationId, AccessShareLock);
 
                ScanKeyInit(&skey[0],
                            Anum_pg_cast_oid,
                            BTEqualStrategyNumber, F_OIDEQ,
                            ObjectIdGetDatum(object->objectId));
 
                rcscan = systable_beginscan(castDesc, CastOidIndexId, true,
                                            NULL, 1, skey);
 
                tup = systable_getnext(rcscan);
 
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for cast %u",
                             object->objectId);
 
                    systable_endscan(rcscan);
                    table_close(castDesc, AccessShareLock);
                    break;
                }
 
                castForm = (Form_pg_cast) GETSTRUCT(tup);
 
                appendStringInfo(&buffer, _("cast from %s to %s"),
                                 format_type_be(castForm->castsource),
                                 format_type_be(castForm->casttarget));
 
                systable_endscan(rcscan);
                table_close(castDesc, AccessShareLock);
                break;
            }
 
        case OCLASS_COLLATION:
            {
                HeapTuple   collTup;
                Form_pg_collation coll;
                char       *nspname;
 
                collTup = SearchSysCache1(COLLOID,
                                          ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(collTup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for collation %u",
                             object->objectId);
                    break;
                }
 
                coll = (Form_pg_collation) GETSTRUCT(collTup);
 
                /* Qualify the name if not visible in search path */
                if (CollationIsVisible(object->objectId))
                    nspname = NULL;
                else
                    nspname = get_namespace_name(coll->collnamespace);
 
                appendStringInfo(&buffer, _("collation %s"),
                                 quote_qualified_identifier(nspname,
                                                            NameStr(coll->collname)));
                ReleaseSysCache(collTup);
                break;
            }
 
        case OCLASS_CONSTRAINT:
            {
                HeapTuple   conTup;
                Form_pg_constraint con;
 
                conTup = SearchSysCache1(CONSTROID,
                                         ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(conTup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for constraint %u",
                             object->objectId);
                    break;
                }
 
                con = (Form_pg_constraint) GETSTRUCT(conTup);
 
                if (OidIsValid(con->conrelid))
                {
                    StringInfoData rel;
 
                    initStringInfo(&rel);
                    getRelationDescription(&rel, con->conrelid, false);
                    /* translator: second %s is, e.g., "table %s" */
                    appendStringInfo(&buffer, _("constraint %s on %s"),
                                     NameStr(con->conname), rel.data);
                    pfree(rel.data);
                }
                else
                {
                    appendStringInfo(&buffer, _("constraint %s"),
                                     NameStr(con->conname));
                }
 
                ReleaseSysCache(conTup);
                break;
            }
 
        case OCLASS_CONVERSION:
            {
                HeapTuple   conTup;
                Form_pg_conversion conv;
                char       *nspname;
 
                conTup = SearchSysCache1(CONVOID,
                                         ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(conTup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for conversion %u",
                             object->objectId);
                    break;
                }
 
                conv = (Form_pg_conversion) GETSTRUCT(conTup);
 
                /* Qualify the name if not visible in search path */
                if (ConversionIsVisible(object->objectId))
                    nspname = NULL;
                else
                    nspname = get_namespace_name(conv->connamespace);
 
                appendStringInfo(&buffer, _("conversion %s"),
                                 quote_qualified_identifier(nspname,
                                                            NameStr(conv->conname)));
                ReleaseSysCache(conTup);
                break;
            }
 
        case OCLASS_DEFAULT:
            {
                ObjectAddress colobject;
 
                colobject = GetAttrDefaultColumnAddress(object->objectId);
 
                if (!OidIsValid(colobject.objectId))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for attrdef %u",
                             object->objectId);
                    break;
                }
 
                /* translator: %s is typically "column %s of table %s" */
                appendStringInfo(&buffer, _("default value for %s"),
                                 getObjectDescription(&colobject, false));
                break;
            }
 
        case OCLASS_LANGUAGE:
            {
                char       *langname = get_language_name(object->objectId,
                                                         missing_ok);
 
                if (langname)
                    appendStringInfo(&buffer, _("language %s"),
                                     get_language_name(object->objectId, false));
                break;
            }
 
        case OCLASS_LARGEOBJECT:
            if (!LargeObjectExists(object->objectId))
                break;
            appendStringInfo(&buffer, _("large object %u"),
                             object->objectId);
            break;
 
        case OCLASS_OPERATOR:
            {
                bits16      flags = FORMAT_OPERATOR_INVALID_AS_NULL;
                char       *oprname = format_operator_extended(object->objectId,
                                                               flags);
 
                if (oprname == NULL)
                    break;
 
                appendStringInfo(&buffer, _("operator %s"), oprname);
                break;
            }
 
        case OCLASS_OPCLASS:
            {
                HeapTuple   opcTup;
                Form_pg_opclass opcForm;
                HeapTuple   amTup;
                Form_pg_am  amForm;
                char       *nspname;
 
                opcTup = SearchSysCache1(CLAOID,
                                         ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(opcTup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for opclass %u",
                             object->objectId);
                    break;
                }
 
                opcForm = (Form_pg_opclass) GETSTRUCT(opcTup);
 
                amTup = SearchSysCache1(AMOID,
                                        ObjectIdGetDatum(opcForm->opcmethod));
                if (!HeapTupleIsValid(amTup))
                    elog(ERROR, "cache lookup failed for access method %u",
                         opcForm->opcmethod);
                amForm = (Form_pg_am) GETSTRUCT(amTup);
 
                /* Qualify the name if not visible in search path */
                if (OpclassIsVisible(object->objectId))
                    nspname = NULL;
                else
                    nspname = get_namespace_name(opcForm->opcnamespace);
 
                appendStringInfo(&buffer, _("operator class %s for access method %s"),
                                 quote_qualified_identifier(nspname,
                                                            NameStr(opcForm->opcname)),
                                 NameStr(amForm->amname));
 
                ReleaseSysCache(amTup);
                ReleaseSysCache(opcTup);
                break;
            }
 
        case OCLASS_OPFAMILY:
            getOpFamilyDescription(&buffer, object->objectId, missing_ok);
            break;
 
        case OCLASS_AM:
            {
                HeapTuple   tup;
 
                tup = SearchSysCache1(AMOID,
                                      ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for access method %u",
                             object->objectId);
                    break;
                }
 
                appendStringInfo(&buffer, _("access method %s"),
                                 NameStr(((Form_pg_am) GETSTRUCT(tup))->amname));
                ReleaseSysCache(tup);
                break;
            }
 
        case OCLASS_AMOP:
            {
                Relation    amopDesc;
                HeapTuple   tup;
                ScanKeyData skey[1];
                SysScanDesc amscan;
                Form_pg_amop amopForm;
                StringInfoData opfam;
 
                amopDesc = table_open(AccessMethodOperatorRelationId,
                                      AccessShareLock);
 
                ScanKeyInit(&skey[0],
                            Anum_pg_amop_oid,
                            BTEqualStrategyNumber, F_OIDEQ,
                            ObjectIdGetDatum(object->objectId));
 
                amscan = systable_beginscan(amopDesc, AccessMethodOperatorOidIndexId, true,
                                            NULL, 1, skey);
 
                tup = systable_getnext(amscan);
 
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for amop entry %u",
                             object->objectId);
 
                    systable_endscan(amscan);
                    table_close(amopDesc, AccessShareLock);
                    break;
                }
 
                amopForm = (Form_pg_amop) GETSTRUCT(tup);
 
                initStringInfo(&opfam);
                getOpFamilyDescription(&opfam, amopForm->amopfamily, false);
 
                /*------
                   translator: %d is the operator strategy (a number), the
                   first two %s's are data type names, the third %s is the
                   description of the operator family, and the last %s is the
                   textual form of the operator with arguments.  */
                appendStringInfo(&buffer, _("operator %d (%s, %s) of %s: %s"),
                                 amopForm->amopstrategy,
                                 format_type_be(amopForm->amoplefttype),
                                 format_type_be(amopForm->amoprighttype),
                                 opfam.data,
                                 format_operator(amopForm->amopopr));
 
                pfree(opfam.data);
 
                systable_endscan(amscan);
                table_close(amopDesc, AccessShareLock);
                break;
            }
 
        case OCLASS_AMPROC:
            {
                Relation    amprocDesc;
                ScanKeyData skey[1];
                SysScanDesc amscan;
                HeapTuple   tup;
                Form_pg_amproc amprocForm;
                StringInfoData opfam;
 
                amprocDesc = table_open(AccessMethodProcedureRelationId,
                                        AccessShareLock);
 
                ScanKeyInit(&skey[0],
                            Anum_pg_amproc_oid,
                            BTEqualStrategyNumber, F_OIDEQ,
                            ObjectIdGetDatum(object->objectId));
 
                amscan = systable_beginscan(amprocDesc, AccessMethodProcedureOidIndexId, true,
                                            NULL, 1, skey);
 
                tup = systable_getnext(amscan);
 
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for amproc entry %u",
                             object->objectId);
 
                    systable_endscan(amscan);
                    table_close(amprocDesc, AccessShareLock);
                    break;
                }
 
                amprocForm = (Form_pg_amproc) GETSTRUCT(tup);
 
                initStringInfo(&opfam);
                getOpFamilyDescription(&opfam, amprocForm->amprocfamily, false);
 
                /*------
                   translator: %d is the function number, the first two %s's
                   are data type names, the third %s is the description of the
                   operator family, and the last %s is the textual form of the
                   function with arguments.  */
                appendStringInfo(&buffer, _("function %d (%s, %s) of %s: %s"),
                                 amprocForm->amprocnum,
                                 format_type_be(amprocForm->amproclefttype),
                                 format_type_be(amprocForm->amprocrighttype),
                                 opfam.data,
                                 format_procedure(amprocForm->amproc));
 
                pfree(opfam.data);
 
                systable_endscan(amscan);
                table_close(amprocDesc, AccessShareLock);
                break;
            }
 
        case OCLASS_REWRITE:
            {
                Relation    ruleDesc;
                ScanKeyData skey[1];
                SysScanDesc rcscan;
                HeapTuple   tup;
                Form_pg_rewrite rule;
                StringInfoData rel;
 
                ruleDesc = table_open(RewriteRelationId, AccessShareLock);
 
                ScanKeyInit(&skey[0],
                            Anum_pg_rewrite_oid,
                            BTEqualStrategyNumber, F_OIDEQ,
                            ObjectIdGetDatum(object->objectId));
 
                rcscan = systable_beginscan(ruleDesc, RewriteOidIndexId, true,
                                            NULL, 1, skey);
 
                tup = systable_getnext(rcscan);
 
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for rule %u",
                             object->objectId);
 
                    systable_endscan(rcscan);
                    table_close(ruleDesc, AccessShareLock);
                    break;
                }
 
                rule = (Form_pg_rewrite) GETSTRUCT(tup);
 
                initStringInfo(&rel);
                getRelationDescription(&rel, rule->ev_class, false);
 
                /* translator: second %s is, e.g., "table %s" */
                appendStringInfo(&buffer, _("rule %s on %s"),
                                 NameStr(rule->rulename), rel.data);
                pfree(rel.data);
                systable_endscan(rcscan);
                table_close(ruleDesc, AccessShareLock);
                break;
            }
 
        case OCLASS_TRIGGER:
            {
                Relation    trigDesc;
                ScanKeyData skey[1];
                SysScanDesc tgscan;
                HeapTuple   tup;
                Form_pg_trigger trig;
                StringInfoData rel;
 
                trigDesc = table_open(TriggerRelationId, AccessShareLock);
 
                ScanKeyInit(&skey[0],
                            Anum_pg_trigger_oid,
                            BTEqualStrategyNumber, F_OIDEQ,
                            ObjectIdGetDatum(object->objectId));
 
                tgscan = systable_beginscan(trigDesc, TriggerOidIndexId, true,
                                            NULL, 1, skey);
 
                tup = systable_getnext(tgscan);
 
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for trigger %u",
                             object->objectId);
 
                    systable_endscan(tgscan);
                    table_close(trigDesc, AccessShareLock);
                    break;
                }
 
                trig = (Form_pg_trigger) GETSTRUCT(tup);
 
                initStringInfo(&rel);
                getRelationDescription(&rel, trig->tgrelid, false);
 
                /* translator: second %s is, e.g., "table %s" */
                appendStringInfo(&buffer, _("trigger %s on %s"),
                                 NameStr(trig->tgname), rel.data);
                pfree(rel.data);
                systable_endscan(tgscan);
                table_close(trigDesc, AccessShareLock);
                break;
            }
 
        case OCLASS_SCHEMA:
            {
                char       *nspname;
 
                nspname = get_namespace_name(object->objectId);
                if (!nspname)
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for namespace %u",
                             object->objectId);
                    break;
                }
                appendStringInfo(&buffer, _("schema %s"), nspname);
                break;
            }
 
        case OCLASS_STATISTIC_EXT:
            {
                HeapTuple   stxTup;
                Form_pg_statistic_ext stxForm;
                char       *nspname;
 
                stxTup = SearchSysCache1(STATEXTOID,
                                         ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(stxTup))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for statistics object %u",
                             object->objectId);
                    break;
                }
 
                stxForm = (Form_pg_statistic_ext) GETSTRUCT(stxTup);
 
                /* Qualify the name if not visible in search path */
                if (StatisticsObjIsVisible(object->objectId))
                    nspname = NULL;
                else
                    nspname = get_namespace_name(stxForm->stxnamespace);
 
                appendStringInfo(&buffer, _("statistics object %s"),
                                 quote_qualified_identifier(nspname,
                                                            NameStr(stxForm->stxname)));
 
                ReleaseSysCache(stxTup);
                break;
            }
 
        case OCLASS_TSPARSER:
            {
                HeapTuple   tup;
                Form_pg_ts_parser prsForm;
                char       *nspname;
 
                tup = SearchSysCache1(TSPARSEROID,
                                      ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for text search parser %u",
                             object->objectId);
                    break;
                }
                prsForm = (Form_pg_ts_parser) GETSTRUCT(tup);
 
                /* Qualify the name if not visible in search path */
                if (TSParserIsVisible(object->objectId))
                    nspname = NULL;
                else
                    nspname = get_namespace_name(prsForm->prsnamespace);
 
                appendStringInfo(&buffer, _("text search parser %s"),
                                 quote_qualified_identifier(nspname,
                                                            NameStr(prsForm->prsname)));
                ReleaseSysCache(tup);
                break;
            }
 
        case OCLASS_TSDICT:
            {
                HeapTuple   tup;
                Form_pg_ts_dict dictForm;
                char       *nspname;
 
                tup = SearchSysCache1(TSDICTOID,
                                      ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for text search dictionary %u",
                             object->objectId);
                    break;
                }
 
                dictForm = (Form_pg_ts_dict) GETSTRUCT(tup);
 
                /* Qualify the name if not visible in search path */
                if (TSDictionaryIsVisible(object->objectId))
                    nspname = NULL;
                else
                    nspname = get_namespace_name(dictForm->dictnamespace);
 
                appendStringInfo(&buffer, _("text search dictionary %s"),
                                 quote_qualified_identifier(nspname,
                                                            NameStr(dictForm->dictname)));
                ReleaseSysCache(tup);
                break;
            }
 
        case OCLASS_TSTEMPLATE:
            {
                HeapTuple   tup;
                Form_pg_ts_template tmplForm;
                char       *nspname;
 
                tup = SearchSysCache1(TSTEMPLATEOID,
                                      ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for text search template %u",
                             object->objectId);
                    break;
                }
 
                tmplForm = (Form_pg_ts_template) GETSTRUCT(tup);
 
                /* Qualify the name if not visible in search path */
                if (TSTemplateIsVisible(object->objectId))
                    nspname = NULL;
                else
                    nspname = get_namespace_name(tmplForm->tmplnamespace);
 
                appendStringInfo(&buffer, _("text search template %s"),
                                 quote_qualified_identifier(nspname,
                                                            NameStr(tmplForm->tmplname)));
                ReleaseSysCache(tup);
                break;
            }
 
        case OCLASS_TSCONFIG:
            {
                HeapTuple   tup;
                Form_pg_ts_config cfgForm;
                char       *nspname;
 
                tup = SearchSysCache1(TSCONFIGOID,
                                      ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for text search configuration %u",
                             object->objectId);
                    break;
                }
 
                cfgForm = (Form_pg_ts_config) GETSTRUCT(tup);
 
                /* Qualify the name if not visible in search path */
                if (TSConfigIsVisible(object->objectId))
                    nspname = NULL;
                else
                    nspname = get_namespace_name(cfgForm->cfgnamespace);
 
                appendStringInfo(&buffer, _("text search configuration %s"),
                                 quote_qualified_identifier(nspname,
                                                            NameStr(cfgForm->cfgname)));
                ReleaseSysCache(tup);
                break;
            }
 
        case OCLASS_ROLE:
            {
                char       *username = GetUserNameFromId(object->objectId,
                                                         missing_ok);
 
                if (username)
                    appendStringInfo(&buffer, _("role %s"), username);
                break;
            }
 
        case OCLASS_ROLE_MEMBERSHIP:
            {
                Relation    amDesc;
                ScanKeyData skey[1];
                SysScanDesc rcscan;
                HeapTuple   tup;
                Form_pg_auth_members amForm;
 
                amDesc = table_open(AuthMemRelationId, AccessShareLock);
 
                ScanKeyInit(&skey[0],
                            Anum_pg_auth_members_oid,
                            BTEqualStrategyNumber, F_OIDEQ,
                            ObjectIdGetDatum(object->objectId));
 
                rcscan = systable_beginscan(amDesc, AuthMemOidIndexId, true,
                                            NULL, 1, skey);
 
                tup = systable_getnext(rcscan);
 
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for role membership %u",
                             object->objectId);
 
                    systable_endscan(rcscan);
                    table_close(amDesc, AccessShareLock);
                    break;
                }
 
                amForm = (Form_pg_auth_members) GETSTRUCT(tup);
 
                appendStringInfo(&buffer, _("membership of role %s in role %s"),
                                 GetUserNameFromId(amForm->member, false),
                                 GetUserNameFromId(amForm->roleid, false));
 
                systable_endscan(rcscan);
                table_close(amDesc, AccessShareLock);
                break;
            }
 
        case OCLASS_DATABASE:
            {
                char       *datname;
 
                datname = get_database_name(object->objectId);
                if (!datname)
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for database %u",
                             object->objectId);
                    break;
                }
                appendStringInfo(&buffer, _("database %s"), datname);
                break;
            }
 
        case OCLASS_TBLSPACE:
            {
                char       *tblspace;
 
                tblspace = get_tablespace_name(object->objectId);
                if (!tblspace)
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for tablespace %u",
                             object->objectId);
                    break;
                }
                appendStringInfo(&buffer, _("tablespace %s"), tblspace);
                break;
            }
 
        case OCLASS_FDW:
            {
                ForeignDataWrapper *fdw;
 
                fdw = GetForeignDataWrapperExtended(object->objectId,
                                                    missing_ok);
                if (fdw)
                    appendStringInfo(&buffer, _("foreign-data wrapper %s"), fdw->fdwname);
                break;
            }
 
        case OCLASS_FOREIGN_SERVER:
            {
                ForeignServer *srv;
 
                srv = GetForeignServerExtended(object->objectId, missing_ok);
                if (srv)
                    appendStringInfo(&buffer, _("server %s"), srv->servername);
                break;
            }
 
        case OCLASS_USER_MAPPING:
            {
                HeapTuple   tup;
                Oid         useid;
                char       *usename;
                Form_pg_user_mapping umform;
                ForeignServer *srv;
 
                tup = SearchSysCache1(USERMAPPINGOID,
                                      ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for user mapping %u",
                             object->objectId);
                    break;
                }
 
                umform = (Form_pg_user_mapping) GETSTRUCT(tup);
                useid = umform->umuser;
                srv = GetForeignServer(umform->umserver);
 
                ReleaseSysCache(tup);
 
                if (OidIsValid(useid))
                    usename = GetUserNameFromId(useid, false);
                else
                    usename = "public";
 
                appendStringInfo(&buffer, _("user mapping for %s on server %s"), usename,
                                 srv->servername);
                break;
            }
 
        case OCLASS_DEFACL:
            {
                Relation    defaclrel;
                ScanKeyData skey[1];
                SysScanDesc rcscan;
                HeapTuple   tup;
                Form_pg_default_acl defacl;
                char       *rolename;
                char       *nspname;
 
                defaclrel = table_open(DefaultAclRelationId, AccessShareLock);
 
                ScanKeyInit(&skey[0],
                            Anum_pg_default_acl_oid,
                            BTEqualStrategyNumber, F_OIDEQ,
                            ObjectIdGetDatum(object->objectId));
 
                rcscan = systable_beginscan(defaclrel, DefaultAclOidIndexId,
                                            true, NULL, 1, skey);
 
                tup = systable_getnext(rcscan);
 
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for default ACL %u",
                             object->objectId);
 
                    systable_endscan(rcscan);
                    table_close(defaclrel, AccessShareLock);
                    break;
                }
 
                defacl = (Form_pg_default_acl) GETSTRUCT(tup);
 
                rolename = GetUserNameFromId(defacl->defaclrole, false);
 
                if (OidIsValid(defacl->defaclnamespace))
                    nspname = get_namespace_name(defacl->defaclnamespace);
                else
                    nspname = NULL;
 
                switch (defacl->defaclobjtype)
                {
                    case DEFACLOBJ_RELATION:
                        if (nspname)
                            appendStringInfo(&buffer,
                                             _("default privileges on new relations belonging to role %s in schema %s"),
                                             rolename, nspname);
                        else
                            appendStringInfo(&buffer,
                                             _("default privileges on new relations belonging to role %s"),
                                             rolename);
                        break;
                    case DEFACLOBJ_SEQUENCE:
                        if (nspname)
                            appendStringInfo(&buffer,
                                             _("default privileges on new sequences belonging to role %s in schema %s"),
                                             rolename, nspname);
                        else
                            appendStringInfo(&buffer,
                                             _("default privileges on new sequences belonging to role %s"),
                                             rolename);
                        break;
                    case DEFACLOBJ_FUNCTION:
                        if (nspname)
                            appendStringInfo(&buffer,
                                             _("default privileges on new functions belonging to role %s in schema %s"),
                                             rolename, nspname);
                        else
                            appendStringInfo(&buffer,
                                             _("default privileges on new functions belonging to role %s"),
                                             rolename);
                        break;
                    case DEFACLOBJ_TYPE:
                        if (nspname)
                            appendStringInfo(&buffer,
                                             _("default privileges on new types belonging to role %s in schema %s"),
                                             rolename, nspname);
                        else
                            appendStringInfo(&buffer,
                                             _("default privileges on new types belonging to role %s"),
                                             rolename);
                        break;
                    case DEFACLOBJ_NAMESPACE:
                        Assert(!nspname);
                        appendStringInfo(&buffer,
                                         _("default privileges on new schemas belonging to role %s"),
                                         rolename);
                        break;
                    default:
                        /* shouldn't get here */
                        if (nspname)
                            appendStringInfo(&buffer,
                                             _("default privileges belonging to role %s in schema %s"),
                                             rolename, nspname);
                        else
                            appendStringInfo(&buffer,
                                             _("default privileges belonging to role %s"),
                                             rolename);
                        break;
                }
 
                systable_endscan(rcscan);
                table_close(defaclrel, AccessShareLock);
                break;
            }
 
        case OCLASS_EXTENSION:
            {
                char       *extname;
 
                extname = get_extension_name(object->objectId);
                if (!extname)
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for extension %u",
                             object->objectId);
                    break;
                }
                appendStringInfo(&buffer, _("extension %s"), extname);
                break;
            }
 
        case OCLASS_EVENT_TRIGGER:
            {
                HeapTuple   tup;
 
                tup = SearchSysCache1(EVENTTRIGGEROID,
                                      ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for event trigger %u",
                             object->objectId);
                    break;
                }
                appendStringInfo(&buffer, _("event trigger %s"),
                                 NameStr(((Form_pg_event_trigger) GETSTRUCT(tup))->evtname));
                ReleaseSysCache(tup);
                break;
            }
 
        case OCLASS_PARAMETER_ACL:
            {
                HeapTuple   tup;
                Datum       nameDatum;
                char       *parname;
 
                tup = SearchSysCache1(PARAMETERACLOID,
                                      ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for parameter ACL %u",
                             object->objectId);
                    break;
                }
                nameDatum = SysCacheGetAttrNotNull(PARAMETERACLOID, tup,
                                                   Anum_pg_parameter_acl_parname);
                parname = TextDatumGetCString(nameDatum);
                appendStringInfo(&buffer, _("parameter %s"), parname);
                ReleaseSysCache(tup);
                break;
            }
 
        case OCLASS_POLICY:
            {
                Relation    policy_rel;
                ScanKeyData skey[1];
                SysScanDesc sscan;
                HeapTuple   tuple;
                Form_pg_policy form_policy;
                StringInfoData rel;
 
                policy_rel = table_open(PolicyRelationId, AccessShareLock);
 
                ScanKeyInit(&skey[0],
                            Anum_pg_policy_oid,
                            BTEqualStrategyNumber, F_OIDEQ,
                            ObjectIdGetDatum(object->objectId));
 
                sscan = systable_beginscan(policy_rel, PolicyOidIndexId,
                                           true, NULL, 1, skey);
 
                tuple = systable_getnext(sscan);
 
                if (!HeapTupleIsValid(tuple))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for policy %u",
                             object->objectId);
 
                    systable_endscan(sscan);
                    table_close(policy_rel, AccessShareLock);
                    break;
                }
 
                form_policy = (Form_pg_policy) GETSTRUCT(tuple);
 
                initStringInfo(&rel);
                getRelationDescription(&rel, form_policy->polrelid, false);
 
                /* translator: second %s is, e.g., "table %s" */
                appendStringInfo(&buffer, _("policy %s on %s"),
                                 NameStr(form_policy->polname), rel.data);
                pfree(rel.data);
                systable_endscan(sscan);
                table_close(policy_rel, AccessShareLock);
                break;
            }
 
        case OCLASS_PUBLICATION:
            {
                char       *pubname = get_publication_name(object->objectId,
                                                           missing_ok);
 
                if (pubname)
                    appendStringInfo(&buffer, _("publication %s"), pubname);
                break;
            }
 
        case OCLASS_PUBLICATION_NAMESPACE:
            {
                char       *pubname;
                char       *nspname;
 
                if (!getPublicationSchemaInfo(object, missing_ok,
                                              &pubname, &nspname))
                    break;
 
                appendStringInfo(&buffer, _("publication of schema %s in publication %s"),
                                 nspname, pubname);
                pfree(pubname);
                pfree(nspname);
                break;
            }
 
        case OCLASS_PUBLICATION_REL:
            {
                HeapTuple   tup;
                char       *pubname;
                Form_pg_publication_rel prform;
                StringInfoData rel;
 
                tup = SearchSysCache1(PUBLICATIONREL,
                                      ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for publication table %u",
                             object->objectId);
                    break;
                }
 
                prform = (Form_pg_publication_rel) GETSTRUCT(tup);
                pubname = get_publication_name(prform->prpubid, false);
 
                initStringInfo(&rel);
                getRelationDescription(&rel, prform->prrelid, false);
 
                /* translator: first %s is, e.g., "table %s" */
                appendStringInfo(&buffer, _("publication of %s in publication %s"),
                                 rel.data, pubname);
                pfree(rel.data);
                ReleaseSysCache(tup);
                break;
            }
 
        case OCLASS_SUBSCRIPTION:
            {
                char       *subname = get_subscription_name(object->objectId,
                                                            missing_ok);
 
                if (subname)
                    appendStringInfo(&buffer, _("subscription %s"), subname);
                break;
            }
 
        case OCLASS_TRANSFORM:
            {
                HeapTuple   trfTup;
                Form_pg_transform trfForm;
 
                trfTup = SearchSysCache1(TRFOID,
                                         ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(trfTup))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for transform %u",
                             object->objectId);
                    break;
                }
 
                trfForm = (Form_pg_transform) GETSTRUCT(trfTup);
 
                appendStringInfo(&buffer, _("transform for %s language %s"),
                                 format_type_be(trfForm->trftype),
                                 get_language_name(trfForm->trflang, false));
 
                ReleaseSysCache(trfTup);
                break;
            }
 
            /*
             * There's intentionally no default: case here; we want the
             * compiler to warn if a new OCLASS hasn't been handled above.
             */
    }
 
    /* an empty buffer is equivalent to no object found */
    if (buffer.len == 0)
        return NULL;
 
    return buffer.data;
}

References _, AccessShareLock, AMOID, appendStringInfo(), Assert(), attname, BTEqualStrategyNumber, CLAOID, CollationIsVisible(), COLLOID, CONSTROID, ConversionIsVisible(), CONVOID, StringInfoData::data, datname, elog(), ERROR, EVENTTRIGGEROID, ForeignDataWrapper::fdwname, format_operator(), format_operator_extended(), FORMAT_OPERATOR_INVALID_AS_NULL, FORMAT_PROC_INVALID_AS_NULL, format_procedure(), format_procedure_extended(), format_type_be(), format_type_extended(), FORMAT_TYPE_INVALID_AS_NULL, get_attname(), get_database_name(), get_extension_name(), get_language_name(), get_namespace_name(), get_publication_name(), get_subscription_name(), get_tablespace_name(), GetAttrDefaultColumnAddress(), GetForeignDataWrapperExtended(), GetForeignServer(), GetForeignServerExtended(), getObjectClass(), getOpFamilyDescription(), getPublicationSchemaInfo(), getRelationDescription(), GETSTRUCT, GetUserNameFromId(), HeapTupleIsValid, initStringInfo(), LargeObjectExists(), StringInfoData::len, NameStr, ObjectAddress::objectId, ObjectIdGetDatum(), ObjectAddress::objectSubId, OCLASS_AM, OCLASS_AMOP, OCLASS_AMPROC, OCLASS_CAST, OCLASS_CLASS, OCLASS_COLLATION, OCLASS_CONSTRAINT, OCLASS_CONVERSION, OCLASS_DATABASE, OCLASS_DEFACL, OCLASS_DEFAULT, OCLASS_EVENT_TRIGGER, OCLASS_EXTENSION, OCLASS_FDW, OCLASS_FOREIGN_SERVER, OCLASS_LANGUAGE, OCLASS_LARGEOBJECT, OCLASS_OPCLASS, OCLASS_OPERATOR, OCLASS_OPFAMILY, OCLASS_PARAMETER_ACL, OCLASS_POLICY, OCLASS_PROC, OCLASS_PUBLICATION, OCLASS_PUBLICATION_NAMESPACE, OCLASS_PUBLICATION_REL, OCLASS_REWRITE, OCLASS_ROLE, OCLASS_ROLE_MEMBERSHIP, OCLASS_SCHEMA, OCLASS_STATISTIC_EXT, OCLASS_SUBSCRIPTION, OCLASS_TBLSPACE, OCLASS_TRANSFORM, OCLASS_TRIGGER, OCLASS_TSCONFIG, OCLASS_TSDICT, OCLASS_TSPARSER, OCLASS_TSTEMPLATE, OCLASS_TYPE, OCLASS_USER_MAPPING, OidIsValid, OpclassIsVisible(), PARAMETERACLOID, pfree(), proname, PUBLICATIONREL, quote_qualified_identifier(), ReleaseSysCache(), ScanKeyInit(), SearchSysCache1(), ForeignServer::servername, STATEXTOID, StatisticsObjIsVisible(), subname, SysCacheGetAttrNotNull(), systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), table_open(), TextDatumGetCString, TRFOID, TSConfigIsVisible(), TSCONFIGOID, TSDictionaryIsVisible(), TSDICTOID, TSParserIsVisible(), TSPARSEROID, TSTemplateIsVisible(), TSTEMPLATEOID, typname, USERMAPPINGOID, and username.

Referenced by AlterExtensionNamespace(), ATExecAlterColumnType(), changeDependenciesOn(), check_relation_privileges(), checkMembershipInCurrentExtension(), checkSharedDependencies(), ExecAlterExtensionContentsStmt(), findDependentObjects(), get_altertable_subcmdinfo(), get_object_address_opf_member(), getObjectDescriptionOids(), pg_describe_object(), recordDependencyOnCurrentExtension(), reportDependentObjects(), sepgsql_fmgr_hook(), shdepDropOwned(), shdepReassignOwned(), and storeObjectDescription().

getObjectDescriptionOids()

char* getObjectDescriptionOids	(	Oid	classid,
		Oid	objid
	)

Definition at line 4076 of file objectaddress.c.

{
    ObjectAddress address;
 
    address.classId = classid;
    address.objectId = objid;
    address.objectSubId = 0;
 
    return getObjectDescription(&address, false);
}

References ObjectAddress::classId, getObjectDescription(), ObjectAddress::objectId, and ObjectAddress::objectSubId.

Referenced by AlterObjectNamespace_internal(), and AlterObjectRename_internal().

getObjectIdentity()

char* getObjectIdentity	(	const ObjectAddress *	object,
		bool	missing_ok
	)

Definition at line 4747 of file objectaddress.c.

{
    return getObjectIdentityParts(object, NULL, NULL, missing_ok);
}

References getObjectIdentityParts().

Referenced by check_relation_privileges(), check_schema_perms(), pg_event_trigger_ddl_commands(), pg_identify_object(), sepgsql_attribute_drop(), sepgsql_attribute_post_create(), sepgsql_attribute_relabel(), sepgsql_attribute_setattr(), sepgsql_database_drop(), sepgsql_database_relabel(), sepgsql_database_setattr(), sepgsql_proc_drop(), sepgsql_proc_execute(), sepgsql_proc_post_create(), sepgsql_proc_relabel(), sepgsql_proc_setattr(), sepgsql_relation_drop(), sepgsql_relation_post_create(), sepgsql_relation_relabel(), sepgsql_relation_setattr(), sepgsql_relation_truncate(), sepgsql_schema_drop(), and sepgsql_schema_relabel().

getObjectIdentityParts()

char* getObjectIdentityParts	(	const ObjectAddress *	object,
		List **	objname,
		List **	objargs,
		bool	missing_ok
	)

Definition at line 4762 of file objectaddress.c.

{
    StringInfoData buffer;
 
    initStringInfo(&buffer);
 
    /*
     * Make sure that both objname and objargs were passed, or none was; and
     * initialize them to empty lists.  For objname this is useless because it
     * will be initialized in all cases inside the switch; but we do it anyway
     * so that we can test below that no branch leaves it unset.
     */
    Assert(PointerIsValid(objname) == PointerIsValid(objargs));
    if (objname)
    {
        *objname = NIL;
        *objargs = NIL;
    }
 
    switch (getObjectClass(object))
    {
        case OCLASS_CLASS:
            {
                char       *attr = NULL;
 
                /*
                 * Check for the attribute first, so as if it is missing we
                 * can skip the entire relation description.
                 */
                if (object->objectSubId != 0)
                {
                    attr = get_attname(object->objectId,
                                       object->objectSubId,
                                       missing_ok);
 
                    if (missing_ok && attr == NULL)
                        break;
                }
 
                getRelationIdentity(&buffer, object->objectId, objname,
                                    missing_ok);
                if (objname && *objname == NIL)
                    break;
 
                if (attr)
                {
                    appendStringInfo(&buffer, ".%s",
                                     quote_identifier(attr));
                    if (objname)
                        *objname = lappend(*objname, attr);
                }
            }
            break;
 
        case OCLASS_PROC:
            {
                bits16      flags = FORMAT_PROC_FORCE_QUALIFY | FORMAT_PROC_INVALID_AS_NULL;
                char       *proname = format_procedure_extended(object->objectId,
                                                                flags);
 
                if (proname == NULL)
                    break;
 
                appendStringInfoString(&buffer, proname);
                if (objname)
                    format_procedure_parts(object->objectId, objname, objargs,
                                           missing_ok);
                break;
            }
 
        case OCLASS_TYPE:
            {
                bits16      flags = FORMAT_TYPE_INVALID_AS_NULL | FORMAT_TYPE_FORCE_QUALIFY;
                char       *typeout;
 
                typeout = format_type_extended(object->objectId, -1, flags);
 
                if (typeout == NULL)
                    break;
 
                appendStringInfoString(&buffer, typeout);
                if (objname)
                    *objname = list_make1(typeout);
            }
            break;
 
        case OCLASS_CAST:
            {
                Relation    castRel;
                HeapTuple   tup;
                Form_pg_cast castForm;
 
                castRel = table_open(CastRelationId, AccessShareLock);
 
                tup = get_catalog_object_by_oid(castRel, Anum_pg_cast_oid,
                                                object->objectId);
 
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for cast %u",
                             object->objectId);
 
                    table_close(castRel, AccessShareLock);
                    break;
                }
 
                castForm = (Form_pg_cast) GETSTRUCT(tup);
 
                appendStringInfo(&buffer, "(%s AS %s)",
                                 format_type_be_qualified(castForm->castsource),
                                 format_type_be_qualified(castForm->casttarget));
 
                if (objname)
                {
                    *objname = list_make1(format_type_be_qualified(castForm->castsource));
                    *objargs = list_make1(format_type_be_qualified(castForm->casttarget));
                }
 
                table_close(castRel, AccessShareLock);
                break;
            }
 
        case OCLASS_COLLATION:
            {
                HeapTuple   collTup;
                Form_pg_collation coll;
                char       *schema;
 
                collTup = SearchSysCache1(COLLOID,
                                          ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(collTup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for collation %u",
                             object->objectId);
                    break;
                }
                coll = (Form_pg_collation) GETSTRUCT(collTup);
                schema = get_namespace_name_or_temp(coll->collnamespace);
                appendStringInfoString(&buffer,
                                       quote_qualified_identifier(schema,
                                                                  NameStr(coll->collname)));
                if (objname)
                    *objname = list_make2(schema,
                                          pstrdup(NameStr(coll->collname)));
                ReleaseSysCache(collTup);
                break;
            }
 
        case OCLASS_CONSTRAINT:
            {
                HeapTuple   conTup;
                Form_pg_constraint con;
 
                conTup = SearchSysCache1(CONSTROID,
                                         ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(conTup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for constraint %u",
                             object->objectId);
                    break;
                }
                con = (Form_pg_constraint) GETSTRUCT(conTup);
 
                if (OidIsValid(con->conrelid))
                {
                    appendStringInfo(&buffer, "%s on ",
                                     quote_identifier(NameStr(con->conname)));
                    getRelationIdentity(&buffer, con->conrelid, objname,
                                        false);
                    if (objname)
                        *objname = lappend(*objname, pstrdup(NameStr(con->conname)));
                }
                else
                {
                    ObjectAddress domain;
 
                    Assert(OidIsValid(con->contypid));
                    domain.classId = TypeRelationId;
                    domain.objectId = con->contypid;
                    domain.objectSubId = 0;
 
                    appendStringInfo(&buffer, "%s on %s",
                                     quote_identifier(NameStr(con->conname)),
                                     getObjectIdentityParts(&domain, objname,
                                                            objargs, false));
 
                    if (objname)
                        *objargs = lappend(*objargs, pstrdup(NameStr(con->conname)));
                }
 
                ReleaseSysCache(conTup);
                break;
            }
 
        case OCLASS_CONVERSION:
            {
                HeapTuple   conTup;
                Form_pg_conversion conForm;
                char       *schema;
 
                conTup = SearchSysCache1(CONVOID,
                                         ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(conTup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for conversion %u",
                             object->objectId);
                    break;
                }
                conForm = (Form_pg_conversion) GETSTRUCT(conTup);
                schema = get_namespace_name_or_temp(conForm->connamespace);
                appendStringInfoString(&buffer,
                                       quote_qualified_identifier(schema,
                                                                  NameStr(conForm->conname)));
                if (objname)
                    *objname = list_make2(schema,
                                          pstrdup(NameStr(conForm->conname)));
                ReleaseSysCache(conTup);
                break;
            }
 
        case OCLASS_DEFAULT:
            {
                ObjectAddress colobject;
 
                colobject = GetAttrDefaultColumnAddress(object->objectId);
 
                if (!OidIsValid(colobject.objectId))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for attrdef %u",
                             object->objectId);
                    break;
                }
 
                appendStringInfo(&buffer, "for %s",
                                 getObjectIdentityParts(&colobject,
                                                        objname, objargs,
                                                        false));
                break;
            }
 
        case OCLASS_LANGUAGE:
            {
                HeapTuple   langTup;
                Form_pg_language langForm;
 
                langTup = SearchSysCache1(LANGOID,
                                          ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(langTup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for language %u",
                             object->objectId);
                    break;
                }
                langForm = (Form_pg_language) GETSTRUCT(langTup);
                appendStringInfoString(&buffer,
                                       quote_identifier(NameStr(langForm->lanname)));
                if (objname)
                    *objname = list_make1(pstrdup(NameStr(langForm->lanname)));
                ReleaseSysCache(langTup);
                break;
            }
        case OCLASS_LARGEOBJECT:
            if (!LargeObjectExists(object->objectId))
                break;
            appendStringInfo(&buffer, "%u",
                             object->objectId);
            if (objname)
                *objname = list_make1(psprintf("%u", object->objectId));
            break;
 
        case OCLASS_OPERATOR:
            {
                bits16      flags = FORMAT_OPERATOR_FORCE_QUALIFY | FORMAT_OPERATOR_INVALID_AS_NULL;
                char       *oprname = format_operator_extended(object->objectId,
                                                               flags);
 
                if (oprname == NULL)
                    break;
 
                appendStringInfoString(&buffer, oprname);
                if (objname)
                    format_operator_parts(object->objectId, objname, objargs, missing_ok);
                break;
            }
 
        case OCLASS_OPCLASS:
            {
                HeapTuple   opcTup;
                Form_pg_opclass opcForm;
                HeapTuple   amTup;
                Form_pg_am  amForm;
                char       *schema;
 
                opcTup = SearchSysCache1(CLAOID,
                                         ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(opcTup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for opclass %u",
                             object->objectId);
                    break;
                }
                opcForm = (Form_pg_opclass) GETSTRUCT(opcTup);
                schema = get_namespace_name_or_temp(opcForm->opcnamespace);
 
                amTup = SearchSysCache1(AMOID,
                                        ObjectIdGetDatum(opcForm->opcmethod));
                if (!HeapTupleIsValid(amTup))
                    elog(ERROR, "cache lookup failed for access method %u",
                         opcForm->opcmethod);
                amForm = (Form_pg_am) GETSTRUCT(amTup);
 
                appendStringInfo(&buffer, "%s USING %s",
                                 quote_qualified_identifier(schema,
                                                            NameStr(opcForm->opcname)),
                                 quote_identifier(NameStr(amForm->amname)));
                if (objname)
                    *objname = list_make3(pstrdup(NameStr(amForm->amname)),
                                          schema,
                                          pstrdup(NameStr(opcForm->opcname)));
 
                ReleaseSysCache(amTup);
                ReleaseSysCache(opcTup);
                break;
            }
 
        case OCLASS_OPFAMILY:
            getOpFamilyIdentity(&buffer, object->objectId, objname,
                                missing_ok);
            break;
 
        case OCLASS_AM:
            {
                char       *amname;
 
                amname = get_am_name(object->objectId);
                if (!amname)
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for access method %u",
                             object->objectId);
                    break;
                }
                appendStringInfoString(&buffer, quote_identifier(amname));
                if (objname)
                    *objname = list_make1(amname);
            }
            break;
 
        case OCLASS_AMOP:
            {
                Relation    amopDesc;
                HeapTuple   tup;
                ScanKeyData skey[1];
                SysScanDesc amscan;
                Form_pg_amop amopForm;
                StringInfoData opfam;
                char       *ltype;
                char       *rtype;
 
                amopDesc = table_open(AccessMethodOperatorRelationId,
                                      AccessShareLock);
 
                ScanKeyInit(&skey[0],
                            Anum_pg_amop_oid,
                            BTEqualStrategyNumber, F_OIDEQ,
                            ObjectIdGetDatum(object->objectId));
 
                amscan = systable_beginscan(amopDesc, AccessMethodOperatorOidIndexId, true,
                                            NULL, 1, skey);
 
                tup = systable_getnext(amscan);
 
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for amop entry %u",
                             object->objectId);
 
                    systable_endscan(amscan);
                    table_close(amopDesc, AccessShareLock);
                    break;
                }
 
                amopForm = (Form_pg_amop) GETSTRUCT(tup);
 
                initStringInfo(&opfam);
                getOpFamilyIdentity(&opfam, amopForm->amopfamily, objname,
                                    false);
 
                ltype = format_type_be_qualified(amopForm->amoplefttype);
                rtype = format_type_be_qualified(amopForm->amoprighttype);
 
                if (objname)
                {
                    *objname = lappend(*objname,
                                       psprintf("%d", amopForm->amopstrategy));
                    *objargs = list_make2(ltype, rtype);
                }
 
                appendStringInfo(&buffer, "operator %d (%s, %s) of %s",
                                 amopForm->amopstrategy,
                                 ltype, rtype, opfam.data);
 
                pfree(opfam.data);
 
                systable_endscan(amscan);
                table_close(amopDesc, AccessShareLock);
                break;
            }
 
        case OCLASS_AMPROC:
            {
                Relation    amprocDesc;
                ScanKeyData skey[1];
                SysScanDesc amscan;
                HeapTuple   tup;
                Form_pg_amproc amprocForm;
                StringInfoData opfam;
                char       *ltype;
                char       *rtype;
 
                amprocDesc = table_open(AccessMethodProcedureRelationId,
                                        AccessShareLock);
 
                ScanKeyInit(&skey[0],
                            Anum_pg_amproc_oid,
                            BTEqualStrategyNumber, F_OIDEQ,
                            ObjectIdGetDatum(object->objectId));
 
                amscan = systable_beginscan(amprocDesc, AccessMethodProcedureOidIndexId, true,
                                            NULL, 1, skey);
 
                tup = systable_getnext(amscan);
 
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for amproc entry %u",
                             object->objectId);
 
                    systable_endscan(amscan);
                    table_close(amprocDesc, AccessShareLock);
                    break;
                }
 
                amprocForm = (Form_pg_amproc) GETSTRUCT(tup);
 
                initStringInfo(&opfam);
                getOpFamilyIdentity(&opfam, amprocForm->amprocfamily, objname,
                                    false);
 
                ltype = format_type_be_qualified(amprocForm->amproclefttype);
                rtype = format_type_be_qualified(amprocForm->amprocrighttype);
 
                if (objname)
                {
                    *objname = lappend(*objname,
                                       psprintf("%d", amprocForm->amprocnum));
                    *objargs = list_make2(ltype, rtype);
                }
 
                appendStringInfo(&buffer, "function %d (%s, %s) of %s",
                                 amprocForm->amprocnum,
                                 ltype, rtype, opfam.data);
 
                pfree(opfam.data);
 
                systable_endscan(amscan);
                table_close(amprocDesc, AccessShareLock);
                break;
            }
 
        case OCLASS_REWRITE:
            {
                Relation    ruleDesc;
                HeapTuple   tup;
                Form_pg_rewrite rule;
 
                ruleDesc = table_open(RewriteRelationId, AccessShareLock);
 
                tup = get_catalog_object_by_oid(ruleDesc, Anum_pg_rewrite_oid,
                                                object->objectId);
 
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for rule %u",
                             object->objectId);
 
                    table_close(ruleDesc, AccessShareLock);
                    break;
                }
 
                rule = (Form_pg_rewrite) GETSTRUCT(tup);
 
                appendStringInfo(&buffer, "%s on ",
                                 quote_identifier(NameStr(rule->rulename)));
                getRelationIdentity(&buffer, rule->ev_class, objname, false);
                if (objname)
                    *objname = lappend(*objname, pstrdup(NameStr(rule->rulename)));
 
                table_close(ruleDesc, AccessShareLock);
                break;
            }
 
        case OCLASS_TRIGGER:
            {
                Relation    trigDesc;
                HeapTuple   tup;
                Form_pg_trigger trig;
 
                trigDesc = table_open(TriggerRelationId, AccessShareLock);
 
                tup = get_catalog_object_by_oid(trigDesc, Anum_pg_trigger_oid,
                                                object->objectId);
 
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for trigger %u",
                             object->objectId);
 
                    table_close(trigDesc, AccessShareLock);
                    break;
                }
 
                trig = (Form_pg_trigger) GETSTRUCT(tup);
 
                appendStringInfo(&buffer, "%s on ",
                                 quote_identifier(NameStr(trig->tgname)));
                getRelationIdentity(&buffer, trig->tgrelid, objname, false);
                if (objname)
                    *objname = lappend(*objname, pstrdup(NameStr(trig->tgname)));
 
                table_close(trigDesc, AccessShareLock);
                break;
            }
 
        case OCLASS_SCHEMA:
            {
                char       *nspname;
 
                nspname = get_namespace_name_or_temp(object->objectId);
                if (!nspname)
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for namespace %u",
                             object->objectId);
                    break;
                }
                appendStringInfoString(&buffer,
                                       quote_identifier(nspname));
                if (objname)
                    *objname = list_make1(nspname);
                break;
            }
 
        case OCLASS_STATISTIC_EXT:
            {
                HeapTuple   tup;
                Form_pg_statistic_ext formStatistic;
                char       *schema;
 
                tup = SearchSysCache1(STATEXTOID,
                                      ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for statistics object %u",
                             object->objectId);
                    break;
                }
                formStatistic = (Form_pg_statistic_ext) GETSTRUCT(tup);
                schema = get_namespace_name_or_temp(formStatistic->stxnamespace);
                appendStringInfoString(&buffer,
                                       quote_qualified_identifier(schema,
                                                                  NameStr(formStatistic->stxname)));
                if (objname)
                    *objname = list_make2(schema,
                                          pstrdup(NameStr(formStatistic->stxname)));
                ReleaseSysCache(tup);
            }
            break;
 
        case OCLASS_TSPARSER:
            {
                HeapTuple   tup;
                Form_pg_ts_parser formParser;
                char       *schema;
 
                tup = SearchSysCache1(TSPARSEROID,
                                      ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for text search parser %u",
                             object->objectId);
                    break;
                }
                formParser = (Form_pg_ts_parser) GETSTRUCT(tup);
                schema = get_namespace_name_or_temp(formParser->prsnamespace);
                appendStringInfoString(&buffer,
                                       quote_qualified_identifier(schema,
                                                                  NameStr(formParser->prsname)));
                if (objname)
                    *objname = list_make2(schema,
                                          pstrdup(NameStr(formParser->prsname)));
                ReleaseSysCache(tup);
                break;
            }
 
        case OCLASS_TSDICT:
            {
                HeapTuple   tup;
                Form_pg_ts_dict formDict;
                char       *schema;
 
                tup = SearchSysCache1(TSDICTOID,
                                      ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for text search dictionary %u",
                             object->objectId);
                    break;
                }
                formDict = (Form_pg_ts_dict) GETSTRUCT(tup);
                schema = get_namespace_name_or_temp(formDict->dictnamespace);
                appendStringInfoString(&buffer,
                                       quote_qualified_identifier(schema,
                                                                  NameStr(formDict->dictname)));
                if (objname)
                    *objname = list_make2(schema,
                                          pstrdup(NameStr(formDict->dictname)));
                ReleaseSysCache(tup);
                break;
            }
 
        case OCLASS_TSTEMPLATE:
            {
                HeapTuple   tup;
                Form_pg_ts_template formTmpl;
                char       *schema;
 
                tup = SearchSysCache1(TSTEMPLATEOID,
                                      ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for text search template %u",
                             object->objectId);
                    break;
                }
                formTmpl = (Form_pg_ts_template) GETSTRUCT(tup);
                schema = get_namespace_name_or_temp(formTmpl->tmplnamespace);
                appendStringInfoString(&buffer,
                                       quote_qualified_identifier(schema,
                                                                  NameStr(formTmpl->tmplname)));
                if (objname)
                    *objname = list_make2(schema,
                                          pstrdup(NameStr(formTmpl->tmplname)));
                ReleaseSysCache(tup);
                break;
            }
 
        case OCLASS_TSCONFIG:
            {
                HeapTuple   tup;
                Form_pg_ts_config formCfg;
                char       *schema;
 
                tup = SearchSysCache1(TSCONFIGOID,
                                      ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for text search configuration %u",
                             object->objectId);
                    break;
                }
                formCfg = (Form_pg_ts_config) GETSTRUCT(tup);
                schema = get_namespace_name_or_temp(formCfg->cfgnamespace);
                appendStringInfoString(&buffer,
                                       quote_qualified_identifier(schema,
                                                                  NameStr(formCfg->cfgname)));
                if (objname)
                    *objname = list_make2(schema,
                                          pstrdup(NameStr(formCfg->cfgname)));
                ReleaseSysCache(tup);
                break;
            }
 
        case OCLASS_ROLE:
            {
                char       *username;
 
                username = GetUserNameFromId(object->objectId, missing_ok);
                if (!username)
                    break;
                if (objname)
                    *objname = list_make1(username);
                appendStringInfoString(&buffer,
                                       quote_identifier(username));
                break;
            }
 
        case OCLASS_ROLE_MEMBERSHIP:
            {
                Relation    authMemDesc;
                ScanKeyData skey[1];
                SysScanDesc amscan;
                HeapTuple   tup;
                Form_pg_auth_members amForm;
 
                authMemDesc = table_open(AuthMemRelationId,
                                         AccessShareLock);
 
                ScanKeyInit(&skey[0],
                            Anum_pg_auth_members_oid,
                            BTEqualStrategyNumber, F_OIDEQ,
                            ObjectIdGetDatum(object->objectId));
 
                amscan = systable_beginscan(authMemDesc, AuthMemOidIndexId, true,
                                            NULL, 1, skey);
 
                tup = systable_getnext(amscan);
 
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for pg_auth_members entry %u",
                             object->objectId);
 
                    systable_endscan(amscan);
                    table_close(authMemDesc, AccessShareLock);
                    break;
                }
 
                amForm = (Form_pg_auth_members) GETSTRUCT(tup);
 
                appendStringInfo(&buffer, _("membership of role %s in role %s"),
                                 GetUserNameFromId(amForm->member, false),
                                 GetUserNameFromId(amForm->roleid, false));
 
                systable_endscan(amscan);
                table_close(authMemDesc, AccessShareLock);
                break;
            }
 
        case OCLASS_DATABASE:
            {
                char       *datname;
 
                datname = get_database_name(object->objectId);
                if (!datname)
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for database %u",
                             object->objectId);
                    break;
                }
                if (objname)
                    *objname = list_make1(datname);
                appendStringInfoString(&buffer,
                                       quote_identifier(datname));
                break;
            }
 
        case OCLASS_TBLSPACE:
            {
                char       *tblspace;
 
                tblspace = get_tablespace_name(object->objectId);
                if (!tblspace)
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for tablespace %u",
                             object->objectId);
                    break;
                }
                if (objname)
                    *objname = list_make1(tblspace);
                appendStringInfoString(&buffer,
                                       quote_identifier(tblspace));
                break;
            }
 
        case OCLASS_FDW:
            {
                ForeignDataWrapper *fdw;
 
                fdw = GetForeignDataWrapperExtended(object->objectId,
                                                    missing_ok);
                if (fdw)
                {
                    appendStringInfoString(&buffer, quote_identifier(fdw->fdwname));
                    if (objname)
                        *objname = list_make1(pstrdup(fdw->fdwname));
                }
                break;
            }
 
        case OCLASS_FOREIGN_SERVER:
            {
                ForeignServer *srv;
 
                srv = GetForeignServerExtended(object->objectId,
                                               missing_ok);
                if (srv)
                {
                    appendStringInfoString(&buffer,
                                           quote_identifier(srv->servername));
                    if (objname)
                        *objname = list_make1(pstrdup(srv->servername));
                }
                break;
            }
 
        case OCLASS_USER_MAPPING:
            {
                HeapTuple   tup;
                Oid         useid;
                Form_pg_user_mapping umform;
                ForeignServer *srv;
                const char *usename;
 
                tup = SearchSysCache1(USERMAPPINGOID,
                                      ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for user mapping %u",
                             object->objectId);
                    break;
                }
                umform = (Form_pg_user_mapping) GETSTRUCT(tup);
                useid = umform->umuser;
                srv = GetForeignServer(umform->umserver);
 
                ReleaseSysCache(tup);
 
                if (OidIsValid(useid))
                    usename = GetUserNameFromId(useid, false);
                else
                    usename = "public";
 
                if (objname)
                {
                    *objname = list_make1(pstrdup(usename));
                    *objargs = list_make1(pstrdup(srv->servername));
                }
 
                appendStringInfo(&buffer, "%s on server %s",
                                 quote_identifier(usename),
                                 srv->servername);
                break;
            }
 
        case OCLASS_DEFACL:
            {
                Relation    defaclrel;
                ScanKeyData skey[1];
                SysScanDesc rcscan;
                HeapTuple   tup;
                Form_pg_default_acl defacl;
                char       *schema;
                char       *username;
 
                defaclrel = table_open(DefaultAclRelationId, AccessShareLock);
 
                ScanKeyInit(&skey[0],
                            Anum_pg_default_acl_oid,
                            BTEqualStrategyNumber, F_OIDEQ,
                            ObjectIdGetDatum(object->objectId));
 
                rcscan = systable_beginscan(defaclrel, DefaultAclOidIndexId,
                                            true, NULL, 1, skey);
 
                tup = systable_getnext(rcscan);
 
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for default ACL %u",
                             object->objectId);
 
                    systable_endscan(rcscan);
                    table_close(defaclrel, AccessShareLock);
                    break;
                }
 
                defacl = (Form_pg_default_acl) GETSTRUCT(tup);
 
                username = GetUserNameFromId(defacl->defaclrole, false);
                appendStringInfo(&buffer,
                                 "for role %s",
                                 quote_identifier(username));
 
                if (OidIsValid(defacl->defaclnamespace))
                {
                    schema = get_namespace_name_or_temp(defacl->defaclnamespace);
                    appendStringInfo(&buffer,
                                     " in schema %s",
                                     quote_identifier(schema));
                }
                else
                    schema = NULL;
 
                switch (defacl->defaclobjtype)
                {
                    case DEFACLOBJ_RELATION:
                        appendStringInfoString(&buffer,
                                               " on tables");
                        break;
                    case DEFACLOBJ_SEQUENCE:
                        appendStringInfoString(&buffer,
                                               " on sequences");
                        break;
                    case DEFACLOBJ_FUNCTION:
                        appendStringInfoString(&buffer,
                                               " on functions");
                        break;
                    case DEFACLOBJ_TYPE:
                        appendStringInfoString(&buffer,
                                               " on types");
                        break;
                    case DEFACLOBJ_NAMESPACE:
                        appendStringInfoString(&buffer,
                                               " on schemas");
                        break;
                }
 
                if (objname)
                {
                    *objname = list_make1(username);
                    if (schema)
                        *objname = lappend(*objname, schema);
                    *objargs = list_make1(psprintf("%c", defacl->defaclobjtype));
                }
 
                systable_endscan(rcscan);
                table_close(defaclrel, AccessShareLock);
                break;
            }
 
        case OCLASS_EXTENSION:
            {
                char       *extname;
 
                extname = get_extension_name(object->objectId);
                if (!extname)
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for extension %u",
                             object->objectId);
                    break;
                }
                appendStringInfoString(&buffer, quote_identifier(extname));
                if (objname)
                    *objname = list_make1(extname);
                break;
            }
 
        case OCLASS_EVENT_TRIGGER:
            {
                HeapTuple   tup;
                Form_pg_event_trigger trigForm;
                char       *evtname;
 
                tup = SearchSysCache1(EVENTTRIGGEROID,
                                      ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for event trigger %u",
                             object->objectId);
                    break;
                }
                trigForm = (Form_pg_event_trigger) GETSTRUCT(tup);
                evtname = pstrdup(NameStr(trigForm->evtname));
                appendStringInfoString(&buffer, quote_identifier(evtname));
                if (objname)
                    *objname = list_make1(evtname);
                ReleaseSysCache(tup);
                break;
            }
 
        case OCLASS_PARAMETER_ACL:
            {
                HeapTuple   tup;
                Datum       nameDatum;
                char       *parname;
 
                tup = SearchSysCache1(PARAMETERACLOID,
                                      ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for parameter ACL %u",
                             object->objectId);
                    break;
                }
                nameDatum = SysCacheGetAttrNotNull(PARAMETERACLOID, tup,
                                                   Anum_pg_parameter_acl_parname);
                parname = TextDatumGetCString(nameDatum);
                appendStringInfoString(&buffer, parname);
                if (objname)
                    *objname = list_make1(parname);
                ReleaseSysCache(tup);
                break;
            }
 
        case OCLASS_POLICY:
            {
                Relation    polDesc;
                HeapTuple   tup;
                Form_pg_policy policy;
 
                polDesc = table_open(PolicyRelationId, AccessShareLock);
 
                tup = get_catalog_object_by_oid(polDesc, Anum_pg_policy_oid,
                                                object->objectId);
 
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for policy %u",
                             object->objectId);
 
                    table_close(polDesc, AccessShareLock);
                    break;
                }
 
                policy = (Form_pg_policy) GETSTRUCT(tup);
 
                appendStringInfo(&buffer, "%s on ",
                                 quote_identifier(NameStr(policy->polname)));
                getRelationIdentity(&buffer, policy->polrelid, objname, false);
                if (objname)
                    *objname = lappend(*objname, pstrdup(NameStr(policy->polname)));
 
                table_close(polDesc, AccessShareLock);
                break;
            }
 
        case OCLASS_PUBLICATION:
            {
                char       *pubname;
 
                pubname = get_publication_name(object->objectId, missing_ok);
                if (pubname)
                {
                    appendStringInfoString(&buffer,
                                           quote_identifier(pubname));
                    if (objname)
                        *objname = list_make1(pubname);
                }
                break;
            }
 
        case OCLASS_PUBLICATION_NAMESPACE:
            {
                char       *pubname;
                char       *nspname;
 
                if (!getPublicationSchemaInfo(object, missing_ok, &pubname,
                                              &nspname))
                    break;
                appendStringInfo(&buffer, "%s in publication %s",
                                 nspname, pubname);
 
                if (objargs)
                    *objargs = list_make1(pubname);
                else
                    pfree(pubname);
 
                if (objname)
                    *objname = list_make1(nspname);
                else
                    pfree(nspname);
 
                break;
            }
 
        case OCLASS_PUBLICATION_REL:
            {
                HeapTuple   tup;
                char       *pubname;
                Form_pg_publication_rel prform;
 
                tup = SearchSysCache1(PUBLICATIONREL,
                                      ObjectIdGetDatum(object->objectId));
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "cache lookup failed for publication table %u",
                             object->objectId);
                    break;
                }
 
                prform = (Form_pg_publication_rel) GETSTRUCT(tup);
                pubname = get_publication_name(prform->prpubid, false);
 
                getRelationIdentity(&buffer, prform->prrelid, objname, false);
                appendStringInfo(&buffer, " in publication %s", pubname);
 
                if (objargs)
                    *objargs = list_make1(pubname);
 
                ReleaseSysCache(tup);
                break;
            }
 
        case OCLASS_SUBSCRIPTION:
            {
                char       *subname;
 
                subname = get_subscription_name(object->objectId, missing_ok);
                if (subname)
                {
                    appendStringInfoString(&buffer,
                                           quote_identifier(subname));
                    if (objname)
                        *objname = list_make1(subname);
                }
                break;
            }
 
        case OCLASS_TRANSFORM:
            {
                Relation    transformDesc;
                HeapTuple   tup;
                Form_pg_transform transform;
                char       *transformLang;
                char       *transformType;
 
                transformDesc = table_open(TransformRelationId, AccessShareLock);
 
                tup = get_catalog_object_by_oid(transformDesc,
                                                Anum_pg_transform_oid,
                                                object->objectId);
 
                if (!HeapTupleIsValid(tup))
                {
                    if (!missing_ok)
                        elog(ERROR, "could not find tuple for transform %u",
                             object->objectId);
 
                    table_close(transformDesc, AccessShareLock);
                    break;
                }
 
                transform = (Form_pg_transform) GETSTRUCT(tup);
 
                transformType =