PostgreSQL Source Code  git master
Data Structures | Macros | Typedefs | Functions | Variables
objectaddress.h File Reference
#include "access/htup.h"
#include "nodes/parsenodes.h"
#include "storage/lockdefs.h"
#include "utils/relcache.h"
Include dependency graph for objectaddress.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures

struct  ObjectAddress
 

Macros

#define ObjectAddressSubSet(addr, class_id, object_id, object_sub_id)
 
#define ObjectAddressSet(addr, class_id, object_id)    ObjectAddressSubSet(addr, class_id, object_id, 0)
 

Typedefs

typedef struct ObjectAddress ObjectAddress
 

Functions

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)
 
void check_object_ownership (Oid roleid, ObjectType objtype, ObjectAddress address, Node *object, Relation relation)
 
Oid get_object_namespace (const ObjectAddress *address)
 
bool is_objectclass_supported (Oid class_id)
 
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)
 
HeapTuple get_catalog_object_by_oid (Relation catalog, AttrNumber oidcol, Oid objectId)
 
char * getObjectDescription (const ObjectAddress *object, bool missing_ok)
 
char * getObjectDescriptionOids (Oid classid, Oid objid)
 
int read_objtype_from_string (const char *objtype)
 
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)
 
struct ArrayType * strlist_to_textarray (List *list)
 
ObjectType get_relkind_objtype (char relkind)
 

Variables

PGDLLIMPORT const ObjectAddress InvalidObjectAddress
 

Macro Definition Documentation

◆ ObjectAddressSet

#define ObjectAddressSet (   addr,
  class_id,
  object_id 
)     ObjectAddressSubSet(addr, class_id, object_id, 0)

Definition at line 40 of file objectaddress.h.

◆ ObjectAddressSubSet

#define ObjectAddressSubSet (   addr,
  class_id,
  object_id,
  object_sub_id 
)
Value:
do { \
(addr).classId = (class_id); \
(addr).objectId = (object_id); \
(addr).objectSubId = (object_sub_id); \
} while (0)

Definition at line 33 of file objectaddress.h.

Typedef Documentation

◆ ObjectAddress

typedef struct ObjectAddress ObjectAddress

Function Documentation

◆ check_object_ownership()

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

Definition at line 2420 of file objectaddress.c.

2422 {
2423  switch (objtype)
2424  {
2425  case OBJECT_INDEX:
2426  case OBJECT_SEQUENCE:
2427  case OBJECT_TABLE:
2428  case OBJECT_VIEW:
2429  case OBJECT_MATVIEW:
2430  case OBJECT_FOREIGN_TABLE:
2431  case OBJECT_COLUMN:
2432  case OBJECT_RULE:
2433  case OBJECT_TRIGGER:
2434  case OBJECT_POLICY:
2435  case OBJECT_TABCONSTRAINT:
2436  if (!object_ownercheck(RelationRelationId, RelationGetRelid(relation), roleid))
2437  aclcheck_error(ACLCHECK_NOT_OWNER, objtype,
2438  RelationGetRelationName(relation));
2439  break;
2440  case OBJECT_TYPE:
2441  case OBJECT_DOMAIN:
2442  case OBJECT_ATTRIBUTE:
2443  if (!object_ownercheck(address.classId, address.objectId, roleid))
2444  aclcheck_error_type(ACLCHECK_NOT_OWNER, address.objectId);
2445  break;
2446  case OBJECT_DOMCONSTRAINT:
2447  {
2448  HeapTuple tuple;
2449  Oid contypid;
2450 
2451  tuple = SearchSysCache1(CONSTROID,
2452  ObjectIdGetDatum(address.objectId));
2453  if (!HeapTupleIsValid(tuple))
2454  elog(ERROR, "constraint with OID %u does not exist",
2455  address.objectId);
2456 
2457  contypid = ((Form_pg_constraint) GETSTRUCT(tuple))->contypid;
2458 
2459  ReleaseSysCache(tuple);
2460 
2461  /*
2462  * Fallback to type ownership check in this case as this is
2463  * what domain constraints rely on.
2464  */
2465  if (!object_ownercheck(TypeRelationId, contypid, roleid))
2466  aclcheck_error_type(ACLCHECK_NOT_OWNER, contypid);
2467  }
2468  break;
2469  case OBJECT_AGGREGATE:
2470  case OBJECT_FUNCTION:
2471  case OBJECT_PROCEDURE:
2472  case OBJECT_ROUTINE:
2473  case OBJECT_OPERATOR:
2474  if (!object_ownercheck(address.classId, address.objectId, roleid))
2475  aclcheck_error(ACLCHECK_NOT_OWNER, objtype,
2476  NameListToString((castNode(ObjectWithArgs, object))->objname));
2477  break;
2478  case OBJECT_DATABASE:
2479  case OBJECT_EVENT_TRIGGER:
2480  case OBJECT_EXTENSION:
2481  case OBJECT_FDW:
2482  case OBJECT_FOREIGN_SERVER:
2483  case OBJECT_LANGUAGE:
2484  case OBJECT_PUBLICATION:
2485  case OBJECT_SCHEMA:
2486  case OBJECT_SUBSCRIPTION:
2487  case OBJECT_TABLESPACE:
2488  if (!object_ownercheck(address.classId, address.objectId, roleid))
2489  aclcheck_error(ACLCHECK_NOT_OWNER, objtype,
2490  strVal(object));
2491  break;
2492  case OBJECT_COLLATION:
2493  case OBJECT_CONVERSION:
2494  case OBJECT_OPCLASS:
2495  case OBJECT_OPFAMILY:
2496  case OBJECT_STATISTIC_EXT:
2497  case OBJECT_TSDICTIONARY:
2498  case OBJECT_TSCONFIGURATION:
2499  if (!object_ownercheck(address.classId, address.objectId, roleid))
2500  aclcheck_error(ACLCHECK_NOT_OWNER, objtype,
2501  NameListToString(castNode(List, object)));
2502  break;
2503  case OBJECT_LARGEOBJECT:
2504  if (!lo_compat_privileges &&
2505  !object_ownercheck(address.classId, address.objectId, roleid))
2506  ereport(ERROR,
2507  (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2508  errmsg("must be owner of large object %u",
2509  address.objectId)));
2510  break;
2511  case OBJECT_CAST:
2512  {
2513  /* We can only check permissions on the source/target types */
2514  TypeName *sourcetype = linitial_node(TypeName, castNode(List, object));
2515  TypeName *targettype = lsecond_node(TypeName, castNode(List, object));
2516  Oid sourcetypeid = typenameTypeId(NULL, sourcetype);
2517  Oid targettypeid = typenameTypeId(NULL, targettype);
2518 
2519  if (!object_ownercheck(TypeRelationId, sourcetypeid, roleid)
2520  && !object_ownercheck(TypeRelationId, targettypeid, roleid))
2521  ereport(ERROR,
2522  (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2523  errmsg("must be owner of type %s or type %s",
2524  format_type_be(sourcetypeid),
2525  format_type_be(targettypeid))));
2526  }
2527  break;
2528  case OBJECT_TRANSFORM:
2529  {
2530  TypeName *typename = linitial_node(TypeName, castNode(List, object));
2531  Oid typeid = typenameTypeId(NULL, typename);
2532 
2533  if (!object_ownercheck(TypeRelationId, typeid, roleid))
2534  aclcheck_error_type(ACLCHECK_NOT_OWNER, typeid);
2535  }
2536  break;
2537  case OBJECT_ROLE:
2538 
2539  /*
2540  * We treat roles as being "owned" by those with CREATEROLE priv,
2541  * provided that they also have admin option on the role.
2542  *
2543  * However, superusers are only owned by superusers.
2544  */
2545  if (superuser_arg(address.objectId))
2546  {
2547  if (!superuser_arg(roleid))
2548  ereport(ERROR,
2549  (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2550  errmsg("permission denied"),
2551  errdetail("The current user must have the %s attribute.",
2552  "SUPERUSER")));
2553  }
2554  else
2555  {
2556  if (!has_createrole_privilege(roleid))
2557  ereport(ERROR,
2558  (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2559  errmsg("permission denied"),
2560  errdetail("The current user must have the %s attribute.",
2561  "CREATEROLE")));
2562  if (!is_admin_of_role(roleid, address.objectId))
2563  ereport(ERROR,
2564  (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2565  errmsg("permission denied"),
2566  errdetail("The current user must have the %s option on role \"%s\".",
2567  "ADMIN",
2568  GetUserNameFromId(address.objectId,
2569  true))));
2570  }
2571  break;
2572  case OBJECT_TSPARSER:
2573  case OBJECT_TSTEMPLATE:
2574  case OBJECT_ACCESS_METHOD:
2575  case OBJECT_PARAMETER_ACL:
2576  /* We treat these object types as being owned by superusers */
2577  if (!superuser_arg(roleid))
2578  ereport(ERROR,
2579  (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2580  errmsg("must be superuser")));
2581  break;
2582  case OBJECT_AMOP:
2583  case OBJECT_AMPROC:
2584  case OBJECT_DEFAULT:
2585  case OBJECT_DEFACL:
2586  case OBJECT_PUBLICATION_NAMESPACE:
2587  case OBJECT_PUBLICATION_REL:
2588  case OBJECT_USER_MAPPING:
2589  /* These are currently not supported or don't make sense here. */
2590  elog(ERROR, "unsupported object type: %d", (int) objtype);
2591  break;
2592  }
2593 }
is_admin_of_role
bool is_admin_of_role(Oid member, Oid role)
Definition: acl.c:5099
ACLCHECK_NOT_OWNER
@ ACLCHECK_NOT_OWNER
Definition: acl.h:185
aclcheck_error
void aclcheck_error(AclResult aclerr, ObjectType objtype, const char *objectname)
Definition: aclchk.c:2673
object_ownercheck
bool object_ownercheck(Oid classid, Oid objectid, Oid roleid)
Definition: aclchk.c:3976
aclcheck_error_type
void aclcheck_error_type(AclResult aclerr, Oid typeOid)
Definition: aclchk.c:2992
has_createrole_privilege
bool has_createrole_privilege(Oid roleid)
Definition: aclchk.c:4053
errdetail
int errdetail(const char *fmt,...)
Definition: elog.c:1202
errcode
int errcode(int sqlerrcode)
Definition: elog.c:858
errmsg
int errmsg(const char *fmt,...)
Definition: elog.c:1069
ERROR
#define ERROR
Definition: elog.h:39
ereport
#define ereport(elevel,...)
Definition: elog.h:149
format_type_be
char * format_type_be(Oid type_oid)
Definition: format_type.c:339
HeapTupleIsValid
#define HeapTupleIsValid(tuple)
Definition: htup.h:78
GETSTRUCT
#define GETSTRUCT(TUP)
Definition: htup_details.h:653
lo_compat_privileges
bool lo_compat_privileges
Definition: inv_api.c:58
GetUserNameFromId
char * GetUserNameFromId(Oid roleid, bool noerr)
Definition: miscinit.c:984
NameListToString
char * NameListToString(List *names)
Definition: namespace.c:3145
castNode
#define castNode(_type_, nodeptr)
Definition: nodes.h:197
typenameTypeId
Oid typenameTypeId(ParseState *pstate, const TypeName *typeName)
Definition: parse_type.c:291
OBJECT_EVENT_TRIGGER
@ OBJECT_EVENT_TRIGGER
Definition: parsenodes.h:2096
OBJECT_FDW
@ OBJECT_FDW
Definition: parsenodes.h:2098
OBJECT_TSPARSER
@ OBJECT_TSPARSER
Definition: parsenodes.h:2129
OBJECT_COLLATION
@ OBJECT_COLLATION
Definition: parsenodes.h:2089
OBJECT_USER_MAPPING
@ OBJECT_USER_MAPPING
Definition: parsenodes.h:2132
OBJECT_ACCESS_METHOD
@ OBJECT_ACCESS_METHOD
Definition: parsenodes.h:2082
OBJECT_OPCLASS
@ OBJECT_OPCLASS
Definition: parsenodes.h:2106
OBJECT_DEFACL
@ OBJECT_DEFACL
Definition: parsenodes.h:2093
OBJECT_AGGREGATE
@ OBJECT_AGGREGATE
Definition: parsenodes.h:2083
OBJECT_MATVIEW
@ OBJECT_MATVIEW
Definition: parsenodes.h:2105
OBJECT_SCHEMA
@ OBJECT_SCHEMA
Definition: parsenodes.h:2118
OBJECT_POLICY
@ OBJECT_POLICY
Definition: parsenodes.h:2110
OBJECT_OPERATOR
@ OBJECT_OPERATOR
Definition: parsenodes.h:2107
OBJECT_FOREIGN_TABLE
@ OBJECT_FOREIGN_TABLE
Definition: parsenodes.h:2100
OBJECT_TSCONFIGURATION
@ OBJECT_TSCONFIGURATION
Definition: parsenodes.h:2127
OBJECT_OPFAMILY
@ OBJECT_OPFAMILY
Definition: parsenodes.h:2108
OBJECT_DOMAIN
@ OBJECT_DOMAIN
Definition: parsenodes.h:2094
OBJECT_COLUMN
@ OBJECT_COLUMN
Definition: parsenodes.h:2088
OBJECT_TABLESPACE
@ OBJECT_TABLESPACE
Definition: parsenodes.h:2124
OBJECT_ROLE
@ OBJECT_ROLE
Definition: parsenodes.h:2115
OBJECT_ROUTINE
@ OBJECT_ROUTINE
Definition: parsenodes.h:2116
OBJECT_LARGEOBJECT
@ OBJECT_LARGEOBJECT
Definition: parsenodes.h:2104
OBJECT_PUBLICATION_NAMESPACE
@ OBJECT_PUBLICATION_NAMESPACE
Definition: parsenodes.h:2113
OBJECT_PROCEDURE
@ OBJECT_PROCEDURE
Definition: parsenodes.h:2111
OBJECT_EXTENSION
@ OBJECT_EXTENSION
Definition: parsenodes.h:2097
OBJECT_INDEX
@ OBJECT_INDEX
Definition: parsenodes.h:2102
OBJECT_DEFAULT
@ OBJECT_DEFAULT
Definition: parsenodes.h:2092
OBJECT_DATABASE
@ OBJECT_DATABASE
Definition: parsenodes.h:2091
OBJECT_SEQUENCE
@ OBJECT_SEQUENCE
Definition: parsenodes.h:2119
OBJECT_TSTEMPLATE
@ OBJECT_TSTEMPLATE
Definition: parsenodes.h:2130
OBJECT_LANGUAGE
@ OBJECT_LANGUAGE
Definition: parsenodes.h:2103
OBJECT_AMOP
@ OBJECT_AMOP
Definition: parsenodes.h:2084
OBJECT_PUBLICATION_REL
@ OBJECT_PUBLICATION_REL
Definition: parsenodes.h:2114
OBJECT_FOREIGN_SERVER
@ OBJECT_FOREIGN_SERVER
Definition: parsenodes.h:2099
OBJECT_TSDICTIONARY
@ OBJECT_TSDICTIONARY
Definition: parsenodes.h:2128
OBJECT_ATTRIBUTE
@ OBJECT_ATTRIBUTE
Definition: parsenodes.h:2086
OBJECT_PUBLICATION
@ OBJECT_PUBLICATION
Definition: parsenodes.h:2112
OBJECT_RULE
@ OBJECT_RULE
Definition: parsenodes.h:2117
OBJECT_CONVERSION
@ OBJECT_CONVERSION
Definition: parsenodes.h:2090
OBJECT_AMPROC
@ OBJECT_AMPROC
Definition: parsenodes.h:2085
OBJECT_TABLE
@ OBJECT_TABLE
Definition: parsenodes.h:2123
OBJECT_VIEW
@ OBJECT_VIEW
Definition: parsenodes.h:2133
OBJECT_PARAMETER_ACL
@ OBJECT_PARAMETER_ACL
Definition: parsenodes.h:2109
OBJECT_TYPE
@ OBJECT_TYPE
Definition: parsenodes.h:2131
OBJECT_FUNCTION
@ OBJECT_FUNCTION
Definition: parsenodes.h:2101
OBJECT_TABCONSTRAINT
@ OBJECT_TABCONSTRAINT
Definition: parsenodes.h:2122
OBJECT_DOMCONSTRAINT
@ OBJECT_DOMCONSTRAINT
Definition: parsenodes.h:2095
OBJECT_SUBSCRIPTION
@ OBJECT_SUBSCRIPTION
Definition: parsenodes.h:2120
OBJECT_STATISTIC_EXT
@ OBJECT_STATISTIC_EXT
Definition: parsenodes.h:2121
OBJECT_CAST
@ OBJECT_CAST
Definition: parsenodes.h:2087
OBJECT_TRIGGER
@ OBJECT_TRIGGER
Definition: parsenodes.h:2126
OBJECT_TRANSFORM
@ OBJECT_TRANSFORM
Definition: parsenodes.h:2125
Form_pg_constraint
FormData_pg_constraint * Form_pg_constraint
Definition: pg_constraint.h:165
linitial_node
#define linitial_node(type, l)
Definition: pg_list.h:181
lsecond_node
#define lsecond_node(type, l)
Definition: pg_list.h:186
ObjectIdGetDatum
static Datum ObjectIdGetDatum(Oid X)
Definition: postgres.h:252
Oid
unsigned int Oid
Definition: postgres_ext.h:31
RelationGetRelid
#define RelationGetRelid(relation)
Definition: rel.h:504
RelationGetRelationName
#define RelationGetRelationName(relation)
Definition: rel.h:538
List
Definition: pg_list.h:54
superuser_arg
bool superuser_arg(Oid roleid)
Definition: superuser.c:56
ReleaseSysCache
void ReleaseSysCache(HeapTuple tuple)
Definition: syscache.c:866
SearchSysCache1
HeapTuple SearchSysCache1(int cacheId, Datum key1)
Definition: syscache.c:818
CONSTROID
@ CONSTROID
Definition: syscache.h:53
strVal
#define strVal(v)
Definition: value.h:82

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 2819 of file objectaddress.c.

2820 {
2821  HeapTuple tuple;
2822  Oid classId = RelationGetRelid(catalog);
2823  int oidCacheId = get_object_catcache_oid(classId);
2824 
2825  if (oidCacheId > 0)
2826  {
2827  tuple = SearchSysCacheCopy1(oidCacheId, ObjectIdGetDatum(objectId));
2828  if (!HeapTupleIsValid(tuple)) /* should not happen */
2829  return NULL;
2830  }
2831  else
2832  {
2833  Oid oidIndexId = get_object_oid_index(classId);
2834  SysScanDesc scan;
2835  ScanKeyData skey;
2836 
2837  Assert(OidIsValid(oidIndexId));
2838 
2839  ScanKeyInit(&skey,
2840  oidcol,
2841  BTEqualStrategyNumber, F_OIDEQ,
2842  ObjectIdGetDatum(objectId));
2843 
2844  scan = systable_beginscan(catalog, oidIndexId, true,
2845  NULL, 1, &skey);
2846  tuple = systable_getnext(scan);
2847  if (!HeapTupleIsValid(tuple))
2848  {
2849  systable_endscan(scan);
2850  return NULL;
2851  }
2852  tuple = heap_copytuple(tuple);
2853 
2854  systable_endscan(scan);
2855  }
2856 
2857  return tuple;
2858 }
OidIsValid
#define OidIsValid(objectId)
Definition: c.h:759
systable_endscan
void systable_endscan(SysScanDesc sysscan)
Definition: genam.c:599
systable_getnext
HeapTuple systable_getnext(SysScanDesc sysscan)
Definition: genam.c:506
systable_beginscan
SysScanDesc systable_beginscan(Relation heapRelation, Oid indexId, bool indexOK, Snapshot snapshot, int nkeys, ScanKey key)
Definition: genam.c:387
heap_copytuple
HeapTuple heap_copytuple(HeapTuple tuple)
Definition: heaptuple.c:680
Assert
Assert(fmt[strlen(fmt) - 1] !='\n')
get_object_catcache_oid
int get_object_catcache_oid(Oid class_id)
Definition: objectaddress.c:2674
get_object_oid_index
Oid get_object_oid_index(Oid class_id)
Definition: objectaddress.c:2666
ScanKeyInit
void ScanKeyInit(ScanKey entry, AttrNumber attributeNumber, StrategyNumber strategy, RegProcedure procedure, Datum argument)
Definition: scankey.c:76
BTEqualStrategyNumber
#define BTEqualStrategyNumber
Definition: stratnum.h:31
SearchSysCacheCopy1
#define SearchSysCacheCopy1(cacheId, key1)
Definition: syscache.h:182

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 960 of file objectaddress.c.

962 {
963  ObjectAddress address = {InvalidOid, InvalidOid, 0};
964  ObjectAddress old_address = {InvalidOid, InvalidOid, 0};
965  Relation relation = NULL;
966  uint64 inval_count;
967 
968  /* Some kind of lock must be taken. */
969  Assert(lockmode != NoLock);
970 
971  for (;;)
972  {
973  /*
974  * Remember this value, so that, after looking up the object name and
975  * locking it, we can check whether any invalidation messages have
976  * been processed that might require a do-over.
977  */
978  inval_count = SharedInvalidMessageCounter;
979 
980  /* Look up object address. */
981  switch (objtype)
982  {
983  case OBJECT_INDEX:
984  case OBJECT_SEQUENCE:
985  case OBJECT_TABLE:
986  case OBJECT_VIEW:
987  case OBJECT_MATVIEW:
988  case OBJECT_FOREIGN_TABLE:
989  address =
990  get_relation_by_qualified_name(objtype, castNode(List, object),
991  &relation, lockmode,
992  missing_ok);
993  break;
994  case OBJECT_ATTRIBUTE:
995  case OBJECT_COLUMN:
996  address =
997  get_object_address_attribute(objtype, castNode(List, object),
998  &relation, lockmode,
999  missing_ok);
1000  break;
1001  case OBJECT_DEFAULT:
1002  address =
1003  get_object_address_attrdef(objtype, castNode(List, object),
1004  &relation, lockmode,
1005  missing_ok);
1006  break;
1007  case OBJECT_RULE:
1008  case OBJECT_TRIGGER:
1009  case OBJECT_TABCONSTRAINT:
1010  case OBJECT_POLICY:
1011  address = get_object_address_relobject(objtype, castNode(List, object),
1012  &relation, missing_ok);
1013  break;
1014  case OBJECT_DOMCONSTRAINT:
1015  {
1016  List *objlist;
1017  ObjectAddress domaddr;
1018  char *constrname;
1019 
1020  objlist = castNode(List, object);
1021  domaddr = get_object_address_type(OBJECT_DOMAIN,
1022  linitial_node(TypeName, objlist),
1023  missing_ok);
1024  constrname = strVal(lsecond(objlist));
1025 
1026  address.classId = ConstraintRelationId;
1027  address.objectId = get_domain_constraint_oid(domaddr.objectId,
1028  constrname, missing_ok);
1029  address.objectSubId = 0;
1030  }
1031  break;
1032  case OBJECT_DATABASE:
1033  case OBJECT_EXTENSION:
1034  case OBJECT_TABLESPACE:
1035  case OBJECT_ROLE:
1036  case OBJECT_SCHEMA:
1037  case OBJECT_LANGUAGE:
1038  case OBJECT_FDW:
1039  case OBJECT_FOREIGN_SERVER:
1040  case OBJECT_EVENT_TRIGGER:
1041  case OBJECT_PARAMETER_ACL:
1042  case OBJECT_ACCESS_METHOD:
1043  case OBJECT_PUBLICATION:
1044  case OBJECT_SUBSCRIPTION:
1045  address = get_object_address_unqualified(objtype,
1046  castNode(String, object), missing_ok);
1047  break;
1048  case OBJECT_TYPE:
1049  case OBJECT_DOMAIN:
1050  address = get_object_address_type(objtype, castNode(TypeName, object), missing_ok);
1051  break;
1052  case OBJECT_AGGREGATE:
1053  case OBJECT_FUNCTION:
1054  case OBJECT_PROCEDURE:
1055  case OBJECT_ROUTINE:
1056  address.classId = ProcedureRelationId;
1057  address.objectId = LookupFuncWithArgs(objtype, castNode(ObjectWithArgs, object), missing_ok);
1058  address.objectSubId = 0;
1059  break;
1060  case OBJECT_OPERATOR:
1061  address.classId = OperatorRelationId;
1062  address.objectId = LookupOperWithArgs(castNode(ObjectWithArgs, object), missing_ok);
1063  address.objectSubId = 0;
1064  break;
1065  case OBJECT_COLLATION:
1066  address.classId = CollationRelationId;
1067  address.objectId = get_collation_oid(castNode(List, object), missing_ok);
1068  address.objectSubId = 0;
1069  break;
1070  case OBJECT_CONVERSION:
1071  address.classId = ConversionRelationId;
1072  address.objectId = get_conversion_oid(castNode(List, object), missing_ok);
1073  address.objectSubId = 0;
1074  break;
1075  case OBJECT_OPCLASS:
1076  case OBJECT_OPFAMILY:
1077  address = get_object_address_opcf(objtype, castNode(List, object), missing_ok);
1078  break;
1079  case OBJECT_AMOP:
1080  case OBJECT_AMPROC:
1081  address = get_object_address_opf_member(objtype, castNode(List, object), missing_ok);
1082  break;
1083  case OBJECT_LARGEOBJECT:
1084  address.classId = LargeObjectRelationId;
1085  address.objectId = oidparse(object);
1086  address.objectSubId = 0;
1087  if (!LargeObjectExists(address.objectId))
1088  {
1089  if (!missing_ok)
1090  ereport(ERROR,
1091  (errcode(ERRCODE_UNDEFINED_OBJECT),
1092  errmsg("large object %u does not exist",
1093  address.objectId)));
1094  }
1095  break;
1096  case OBJECT_CAST:
1097  {
1098  TypeName *sourcetype = linitial_node(TypeName, castNode(List, object));
1099  TypeName *targettype = lsecond_node(TypeName, castNode(List, object));
1100  Oid sourcetypeid;
1101  Oid targettypeid;
1102 
1103  sourcetypeid = LookupTypeNameOid(NULL, sourcetype, missing_ok);
1104  targettypeid = LookupTypeNameOid(NULL, targettype, missing_ok);
1105  address.classId = CastRelationId;
1106  address.objectId =
1107  get_cast_oid(sourcetypeid, targettypeid, missing_ok);
1108  address.objectSubId = 0;
1109  }
1110  break;
1111  case OBJECT_TRANSFORM:
1112  {
1113  TypeName *typename = linitial_node(TypeName, castNode(List, object));
1114  char *langname = strVal(lsecond(castNode(List, object)));
1115  Oid type_id = LookupTypeNameOid(NULL, typename, missing_ok);
1116  Oid lang_id = get_language_oid(langname, missing_ok);
1117 
1118  address.classId = TransformRelationId;
1119  address.objectId =
1120  get_transform_oid(type_id, lang_id, missing_ok);
1121  address.objectSubId = 0;
1122  }
1123  break;
1124  case OBJECT_TSPARSER:
1125  address.classId = TSParserRelationId;
1126  address.objectId = get_ts_parser_oid(castNode(List, object), missing_ok);
1127  address.objectSubId = 0;
1128  break;
1129  case OBJECT_TSDICTIONARY:
1130  address.classId = TSDictionaryRelationId;
1131  address.objectId = get_ts_dict_oid(castNode(List, object), missing_ok);
1132  address.objectSubId = 0;
1133  break;
1134  case OBJECT_TSTEMPLATE:
1135  address.classId = TSTemplateRelationId;
1136  address.objectId = get_ts_template_oid(castNode(List, object), missing_ok);
1137  address.objectSubId = 0;
1138  break;
1139  case OBJECT_TSCONFIGURATION:
1140  address.classId = TSConfigRelationId;
1141  address.objectId = get_ts_config_oid(castNode(List, object), missing_ok);
1142  address.objectSubId = 0;
1143  break;
1144  case OBJECT_USER_MAPPING:
1145  address = get_object_address_usermapping(castNode(List, object),
1146  missing_ok);
1147  break;
1148  case OBJECT_PUBLICATION_NAMESPACE:
1149  address = get_object_address_publication_schema(castNode(List, object),
1150  missing_ok);
1151  break;
1152  case OBJECT_PUBLICATION_REL:
1153  address = get_object_address_publication_rel(castNode(List, object),
1154  &relation,
1155  missing_ok);
1156  break;
1157  case OBJECT_DEFACL:
1158  address = get_object_address_defacl(castNode(List, object),
1159  missing_ok);
1160  break;
1161  case OBJECT_STATISTIC_EXT:
1162  address.classId = StatisticExtRelationId;
1163  address.objectId = get_statistics_object_oid(castNode(List, object),
1164  missing_ok);
1165  address.objectSubId = 0;
1166  break;
1167  /* no default, to let compiler warn about missing case */
1168  }
1169 
1170  if (!address.classId)
1171  elog(ERROR, "unrecognized object type: %d", (int) objtype);
1172 
1173  /*
1174  * If we could not find the supplied object, return without locking.
1175  */
1176  if (!OidIsValid(address.objectId))
1177  {
1178  Assert(missing_ok);
1179  return address;
1180  }
1181 
1182  /*
1183  * If we're retrying, see if we got the same answer as last time. If
1184  * so, we're done; if not, we locked the wrong thing, so give up our
1185  * lock.
1186  */
1187  if (OidIsValid(old_address.classId))
1188  {
1189  if (old_address.classId == address.classId
1190  && old_address.objectId == address.objectId
1191  && old_address.objectSubId == address.objectSubId)
1192  break;
1193  if (old_address.classId != RelationRelationId)
1194  {
1195  if (IsSharedRelation(old_address.classId))
1196  UnlockSharedObject(old_address.classId,
1197  old_address.objectId,
1198  0, lockmode);
1199  else
1200  UnlockDatabaseObject(old_address.classId,
1201  old_address.objectId,
1202  0, lockmode);
1203  }
1204  }
1205 
1206  /*
1207  * If we're dealing with a relation or attribute, then the relation is
1208  * already locked. Otherwise, we lock it now.
1209  */
1210  if (address.classId != RelationRelationId)
1211  {
1212  if (IsSharedRelation(address.classId))
1213  LockSharedObject(address.classId, address.objectId, 0,
1214  lockmode);
1215  else
1216  LockDatabaseObject(address.classId, address.objectId, 0,
1217  lockmode);
1218  }
1219 
1220  /*
1221  * At this point, we've resolved the name to an OID and locked the
1222  * corresponding database object. However, it's possible that by the
1223  * time we acquire the lock on the object, concurrent DDL has modified
1224  * the database in such a way that the name we originally looked up no
1225  * longer resolves to that OID.
1226  *
1227  * We can be certain that this isn't an issue if (a) no shared
1228  * invalidation messages have been processed or (b) we've locked a
1229  * relation somewhere along the line. All the relation name lookups
1230  * in this module ultimately use RangeVarGetRelid() to acquire a
1231  * relation lock, and that function protects against the same kinds of
1232  * races we're worried about here. Even when operating on a
1233  * constraint, rule, or trigger, we still acquire AccessShareLock on
1234  * the relation, which is enough to freeze out any concurrent DDL.
1235  *
1236  * In all other cases, however, it's possible that the name we looked
1237  * up no longer refers to the object we locked, so we retry the lookup
1238  * and see whether we get the same answer.
1239  */
1240  if (inval_count == SharedInvalidMessageCounter || relation != NULL)
1241  break;
1242  old_address = address;
1243  }
1244 
1245  /* Return the object address and the relation. */
1246  *relp = relation;
1247  return address;
1248 }
IsSharedRelation
bool IsSharedRelation(Oid relationId)
Definition: catalog.c:245
get_transform_oid
Oid get_transform_oid(Oid type_id, Oid lang_id, bool missing_ok)
Definition: functioncmds.c:2007
LockSharedObject
void LockSharedObject(Oid classid, Oid objid, uint16 objsubid, LOCKMODE lockmode)
Definition: lmgr.c:1046
LockDatabaseObject
void LockDatabaseObject(Oid classid, Oid objid, uint16 objsubid, LOCKMODE lockmode)
Definition: lmgr.c:1005
UnlockSharedObject
void UnlockSharedObject(Oid classid, Oid objid, uint16 objsubid, LOCKMODE lockmode)
Definition: lmgr.c:1067
UnlockDatabaseObject
void UnlockDatabaseObject(Oid classid, Oid objid, uint16 objsubid, LOCKMODE lockmode)
Definition: lmgr.c:1026
NoLock
#define NoLock
Definition: lockdefs.h:34
get_cast_oid
Oid get_cast_oid(Oid sourcetypeid, Oid targettypeid, bool missing_ok)
Definition: lsyscache.c:1033
get_statistics_object_oid
Oid get_statistics_object_oid(List *names, bool missing_ok)
Definition: namespace.c:2221
get_collation_oid
Oid get_collation_oid(List *collname, bool missing_ok)
Definition: namespace.c:3648
get_conversion_oid
Oid get_conversion_oid(List *conname, bool missing_ok)
Definition: namespace.c:3702
get_ts_dict_oid
Oid get_ts_dict_oid(List *names, bool missing_ok)
Definition: namespace.c:2469
get_ts_parser_oid
Oid get_ts_parser_oid(List *names, bool missing_ok)
Definition: namespace.c:2343
get_ts_config_oid
Oid get_ts_config_oid(List *names, bool missing_ok)
Definition: namespace.c:2722
get_ts_template_oid
Oid get_ts_template_oid(List *names, bool missing_ok)
Definition: namespace.c:2596
get_object_address_publication_schema
static ObjectAddress get_object_address_publication_schema(List *object, bool missing_ok)
Definition: objectaddress.c:1954
get_object_address_relobject
static ObjectAddress get_object_address_relobject(ObjectType objtype, List *object, Relation *relp, bool missing_ok)
Definition: objectaddress.c:1453
get_object_address_defacl
static ObjectAddress get_object_address_defacl(List *object, bool missing_ok)
Definition: objectaddress.c:1996
get_object_address_unqualified
static ObjectAddress get_object_address_unqualified(ObjectType objtype, String *strval, bool missing_ok)
Definition: objectaddress.c:1280
get_object_address_publication_rel
static ObjectAddress get_object_address_publication_rel(List *object, Relation *relp, bool missing_ok)
Definition: objectaddress.c:1901
get_object_address_opf_member
static ObjectAddress get_object_address_opf_member(ObjectType objtype, List *object, bool missing_ok)
Definition: objectaddress.c:1718
get_object_address_type
static ObjectAddress get_object_address_type(ObjectType objtype, TypeName *typename, bool missing_ok)
Definition: objectaddress.c:1641
get_object_address_usermapping
static ObjectAddress get_object_address_usermapping(List *object, bool missing_ok)
Definition: objectaddress.c:1830
get_object_address_opcf
static ObjectAddress get_object_address_opcf(ObjectType objtype, List *object, bool missing_ok)
Definition: objectaddress.c:1680
get_object_address_attribute
static ObjectAddress get_object_address_attribute(ObjectType objtype, List *object, Relation *relp, LOCKMODE lockmode, bool missing_ok)
Definition: objectaddress.c:1532
get_relation_by_qualified_name
static ObjectAddress get_relation_by_qualified_name(ObjectType objtype, List *object, Relation *relp, LOCKMODE lockmode, bool missing_ok)
Definition: objectaddress.c:1371
get_object_address_attrdef
static ObjectAddress get_object_address_attrdef(ObjectType objtype, List *object, Relation *relp, LOCKMODE lockmode, bool missing_ok)
Definition: objectaddress.c:1583
oidparse
Oid oidparse(Node *node)
Definition: oid.c:234
LookupFuncWithArgs
Oid LookupFuncWithArgs(ObjectType objtype, ObjectWithArgs *func, bool missing_ok)
Definition: parse_func.c:2205
LookupOperWithArgs
Oid LookupOperWithArgs(ObjectWithArgs *oper, bool noError)
Definition: parse_oper.c:145
LookupTypeNameOid
Oid LookupTypeNameOid(ParseState *pstate, const TypeName *typeName, bool missing_ok)
Definition: parse_type.c:232
get_domain_constraint_oid
Oid get_domain_constraint_oid(Oid typid, const char *conname, bool missing_ok)
Definition: pg_constraint.c:1047
LargeObjectExists
bool LargeObjectExists(Oid loid)
Definition: pg_largeobject.c:158
lsecond
#define lsecond(l)
Definition: pg_list.h:183
InvalidOid
#define InvalidOid
Definition: postgres_ext.h:36
get_language_oid
Oid get_language_oid(const char *langname, bool missing_ok)
Definition: proclang.c:228
SharedInvalidMessageCounter
uint64 SharedInvalidMessageCounter
Definition: sinval.c:26
String
Definition: value.h:64

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_rv()

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

Definition at line 1258 of file objectaddress.c.

1261 {
1262  if (rel)
1263  {
1264  object = lcons(makeString(rel->relname), object);
1265  if (rel->schemaname)
1266  object = lcons(makeString(rel->schemaname), object);
1267  if (rel->catalogname)
1268  object = lcons(makeString(rel->catalogname), object);
1269  }
1270 
1271  return get_object_address(objtype, (Node *) object,
1272  relp, lockmode, missing_ok);
1273 }
lcons
List * lcons(void *datum, List *list)
Definition: list.c:494
get_object_address
ObjectAddress get_object_address(ObjectType objtype, Node *object, Relation *relp, LOCKMODE lockmode, bool missing_ok)
Definition: objectaddress.c:960
Node
Definition: nodes.h:129
RangeVar::relname
char * relname
Definition: primnodes.h:74
RangeVar::catalogname
char * catalogname
Definition: primnodes.h:68
RangeVar::schemaname
char * schemaname
Definition: primnodes.h:71
makeString
String * makeString(char *str)
Definition: value.c:63

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

Referenced by ExecAlterObjectDependsStmt().

◆ get_object_attnum_acl()

AttrNumber get_object_attnum_acl ( Oid  class_id)

Definition at line 2722 of file objectaddress.c.

2723 {
2724  const ObjectPropertyType *prop = get_object_property_data(class_id);
2725 
2726  return prop->attnum_acl;
2727 }
get_object_property_data
static const ObjectPropertyType * get_object_property_data(Oid class_id)
Definition: objectaddress.c:2784
ObjectPropertyType::attnum_acl
AttrNumber attnum_acl
Definition: objectaddress.c:114

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 2698 of file objectaddress.c.

2699 {
2700  const ObjectPropertyType *prop = get_object_property_data(class_id);
2701 
2702  return prop->attnum_name;
2703 }
ObjectPropertyType::attnum_name
AttrNumber attnum_name
Definition: objectaddress.c:111

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 2706 of file objectaddress.c.

2707 {
2708  const ObjectPropertyType *prop = get_object_property_data(class_id);
2709 
2710  return prop->attnum_namespace;
2711 }
ObjectPropertyType::attnum_namespace
AttrNumber attnum_namespace
Definition: objectaddress.c:112

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 2690 of file objectaddress.c.

2691 {
2692  const ObjectPropertyType *prop = get_object_property_data(class_id);
2693 
2694  return prop->attnum_oid;
2695 }
ObjectPropertyType::attnum_oid
AttrNumber attnum_oid
Definition: objectaddress.c:110

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 2714 of file objectaddress.c.

2715 {
2716  const ObjectPropertyType *prop = get_object_property_data(class_id);
2717 
2718  return prop->attnum_owner;
2719 }
ObjectPropertyType::attnum_owner
AttrNumber attnum_owner
Definition: objectaddress.c:113

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 2682 of file objectaddress.c.

2683 {
2684  const ObjectPropertyType *prop = get_object_property_data(class_id);
2685 
2686  return prop->name_catcache_id;
2687 }

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 2674 of file objectaddress.c.

2675 {
2676  const ObjectPropertyType *prop = get_object_property_data(class_id);
2677 
2678  return prop->oid_catcache_id;
2679 }

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 2658 of file objectaddress.c.

2659 {
2660  const ObjectPropertyType *prop = get_object_property_data(class_id);
2661 
2662  return prop->class_descr;
2663 }
ObjectPropertyType::class_descr
const char * class_descr
Definition: objectaddress.c:102

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 2755 of file objectaddress.c.

2756 {
2757  const ObjectPropertyType *prop = get_object_property_data(class_id);
2758 
2759  return prop->is_nsp_name_unique;
2760 }

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 2602 of file objectaddress.c.

2603 {
2604  int cache;
2605  HeapTuple tuple;
2606  Oid oid;
2607  const ObjectPropertyType *property;
2608 
2609  /* If not owned by a namespace, just return InvalidOid. */
2610  property = get_object_property_data(address->classId);
2611  if (property->attnum_namespace == InvalidAttrNumber)
2612  return InvalidOid;
2613 
2614  /* Currently, we can only handle object types with system caches. */
2615  cache = property->oid_catcache_id;
2616  Assert(cache != -1);
2617 
2618  /* Fetch tuple from syscache and extract namespace attribute. */
2619  tuple = SearchSysCache1(cache, ObjectIdGetDatum(address->objectId));
2620  if (!HeapTupleIsValid(tuple))
2621  elog(ERROR, "cache lookup failed for cache %d oid %u",
2622  cache, address->objectId);
2623  oid = DatumGetObjectId(SysCacheGetAttrNotNull(cache,
2624  tuple,
2625  property->attnum_namespace));
2626  ReleaseSysCache(tuple);
2627 
2628  return oid;
2629 }
InvalidAttrNumber
#define InvalidAttrNumber
Definition: attnum.h:23
DatumGetObjectId
static Oid DatumGetObjectId(Datum X)
Definition: postgres.h:242
SysCacheGetAttrNotNull
Datum SysCacheGetAttrNotNull(int cacheId, HeapTuple tup, AttrNumber attributeNumber)
Definition: syscache.c:1110

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 2666 of file objectaddress.c.

2667 {
2668  const ObjectPropertyType *prop = get_object_property_data(class_id);
2669 
2670  return prop->oid_index_oid;
2671 }

References get_object_property_data(), and ObjectPropertyType::oid_index_oid.

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

◆ get_object_type()

ObjectType get_object_type ( Oid  class_id,
Oid  object_id 
)

Definition at line 2737 of file objectaddress.c.

2738 {
2739  const ObjectPropertyType *prop = get_object_property_data(class_id);
2740 
2741  if (prop->objtype == OBJECT_TABLE)
2742  {
2743  /*
2744  * If the property data says it's a table, dig a little deeper to get
2745  * the real relation kind, so that callers can produce more precise
2746  * error messages.
2747  */
2748  return get_relkind_objtype(get_rel_relkind(object_id));
2749  }
2750  else
2751  return prop->objtype;
2752 }
get_rel_relkind
char get_rel_relkind(Oid relid)
Definition: lsyscache.c:1985
get_relkind_objtype
ObjectType get_relkind_objtype(char relkind)
Definition: objectaddress.c:6100

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_relkind_objtype()

ObjectType get_relkind_objtype ( char  relkind)

Definition at line 6100 of file objectaddress.c.

6101 {
6102  switch (relkind)
6103  {
6104  case RELKIND_RELATION:
6105  case RELKIND_PARTITIONED_TABLE:
6106  return OBJECT_TABLE;
6107  case RELKIND_INDEX:
6108  case RELKIND_PARTITIONED_INDEX:
6109  return OBJECT_INDEX;
6110  case RELKIND_SEQUENCE:
6111  return OBJECT_SEQUENCE;
6112  case RELKIND_VIEW:
6113  return OBJECT_VIEW;
6114  case RELKIND_MATVIEW:
6115  return OBJECT_MATVIEW;
6116  case RELKIND_FOREIGN_TABLE:
6117  return OBJECT_FOREIGN_TABLE;
6118  case RELKIND_TOASTVALUE:
6119  return OBJECT_TABLE;
6120  default:
6121  /* Per above, don't raise an error */
6122  return OBJECT_TABLE;
6123  }
6124 }

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(), RangeVarGetAndCheckCreationNamespace(), renameatt_check(), TargetPrivilegesCheck(), transformTableLikeClause(), and truncate_check_perms().

◆ getObjectDescription()

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

Definition at line 2916 of file objectaddress.c.

2917 {
2918  StringInfoData buffer;
2919 
2920  initStringInfo(&buffer);
2921 
2922  switch (getObjectClass(object))
2923  {
2924  case OCLASS_CLASS:
2925  if (object->objectSubId == 0)
2926  getRelationDescription(&buffer, object->objectId, missing_ok);
2927  else
2928  {
2929  /* column, not whole relation */
2930  StringInfoData rel;
2931  char *attname = get_attname(object->objectId,
2932  object->objectSubId,
2933  missing_ok);
2934 
2935  if (!attname)
2936  break;
2937 
2938  initStringInfo(&rel);
2939  getRelationDescription(&rel, object->objectId, missing_ok);
2940  /* translator: second %s is, e.g., "table %s" */
2941  appendStringInfo(&buffer, _("column %s of %s"),
2942  attname, rel.data);
2943  pfree(rel.data);
2944  }
2945  break;
2946 
2947  case OCLASS_PROC:
2948  {
2949  bits16 flags = FORMAT_PROC_INVALID_AS_NULL;
2950  char *proname = format_procedure_extended(object->objectId,
2951  flags);
2952 
2953  if (proname == NULL)
2954  break;
2955 
2956  appendStringInfo(&buffer, _("function %s"), proname);
2957  break;
2958  }
2959 
2960  case OCLASS_TYPE:
2961  {
2962  bits16 flags = FORMAT_TYPE_INVALID_AS_NULL;
2963  char *typname = format_type_extended(object->objectId, -1,
2964  flags);
2965 
2966  if (typname == NULL)
2967  break;
2968 
2969  appendStringInfo(&buffer, _("type %s"), typname);
2970  break;
2971  }
2972 
2973  case OCLASS_CAST:
2974  {
2975  Relation castDesc;
2976  ScanKeyData skey[1];
2977  SysScanDesc rcscan;
2978  HeapTuple tup;
2979  Form_pg_cast castForm;
2980 
2981  castDesc = table_open(CastRelationId, AccessShareLock);
2982 
2983  ScanKeyInit(&skey[0],
2984  Anum_pg_cast_oid,
2985  BTEqualStrategyNumber, F_OIDEQ,
2986  ObjectIdGetDatum(object->objectId));
2987 
2988  rcscan = systable_beginscan(castDesc, CastOidIndexId, true,
2989  NULL, 1, skey);
2990 
2991  tup = systable_getnext(rcscan);
2992 
2993  if (!HeapTupleIsValid(tup))
2994  {
2995  if (!missing_ok)
2996  elog(ERROR, "could not find tuple for cast %u",
2997  object->objectId);
2998 
2999  systable_endscan(rcscan);
3000  table_close(castDesc, AccessShareLock);
3001  break;
3002  }
3003 
3004  castForm = (Form_pg_cast) GETSTRUCT(tup);
3005 
3006  appendStringInfo(&buffer, _("cast from %s to %s"),
3007  format_type_be(castForm->castsource),
3008  format_type_be(castForm->casttarget));
3009 
3010  systable_endscan(rcscan);
3011  table_close(castDesc, AccessShareLock);
3012  break;
3013  }
3014 
3015  case OCLASS_COLLATION:
3016  {
3017  HeapTuple collTup;
3018  Form_pg_collation coll;
3019  char *nspname;
3020 
3021  collTup = SearchSysCache1(COLLOID,
3022  ObjectIdGetDatum(object->objectId));
3023  if (!HeapTupleIsValid(collTup))
3024  {
3025  if (!missing_ok)
3026  elog(ERROR, "cache lookup failed for collation %u",
3027  object->objectId);
3028  break;
3029  }
3030 
3031  coll = (Form_pg_collation) GETSTRUCT(collTup);
3032 
3033  /* Qualify the name if not visible in search path */
3034  if (CollationIsVisible(object->objectId))
3035  nspname = NULL;
3036  else
3037  nspname = get_namespace_name(coll->collnamespace);
3038 
3039  appendStringInfo(&buffer, _("collation %s"),
3040  quote_qualified_identifier(nspname,
3041  NameStr(coll->collname)));
3042  ReleaseSysCache(collTup);
3043  break;
3044  }
3045 
3046  case OCLASS_CONSTRAINT:
3047  {
3048  HeapTuple conTup;
3049  Form_pg_constraint con;
3050 
3051  conTup = SearchSysCache1(CONSTROID,
3052  ObjectIdGetDatum(object->objectId));
3053  if (!HeapTupleIsValid(conTup))
3054  {
3055  if (!missing_ok)
3056  elog(ERROR, "cache lookup failed for constraint %u",
3057  object->objectId);
3058  break;
3059  }
3060 
3061  con = (Form_pg_constraint) GETSTRUCT(conTup);
3062 
3063  if (OidIsValid(con->conrelid))
3064  {
3065  StringInfoData rel;
3066 
3067  initStringInfo(&rel);
3068  getRelationDescription(&rel, con->conrelid, false);
3069  /* translator: second %s is, e.g., "table %s" */
3070  appendStringInfo(&buffer, _("constraint %s on %s"),
3071  NameStr(con->conname), rel.data);
3072  pfree(rel.data);
3073  }
3074  else
3075  {
3076  appendStringInfo(&buffer, _("constraint %s"),
3077  NameStr(con->conname));
3078  }
3079 
3080  ReleaseSysCache(conTup);
3081  break;
3082  }
3083 
3084  case OCLASS_CONVERSION:
3085  {
3086  HeapTuple conTup;
3087  Form_pg_conversion conv;
3088  char *nspname;
3089 
3090  conTup = SearchSysCache1(CONVOID,
3091  ObjectIdGetDatum(object->objectId));
3092  if (!HeapTupleIsValid(conTup))
3093  {
3094  if (!missing_ok)
3095  elog(ERROR, "cache lookup failed for conversion %u",
3096  object->objectId);
3097  break;
3098  }
3099 
3100  conv = (Form_pg_conversion) GETSTRUCT(conTup);
3101 
3102  /* Qualify the name if not visible in search path */
3103  if (ConversionIsVisible(object->objectId))
3104  nspname = NULL;
3105  else
3106  nspname = get_namespace_name(conv->connamespace);
3107 
3108  appendStringInfo(&buffer, _("conversion %s"),
3109  quote_qualified_identifier(nspname,
3110  NameStr(conv->conname)));
3111  ReleaseSysCache(conTup);
3112  break;
3113  }
3114 
3115  case OCLASS_DEFAULT:
3116  {
3117  ObjectAddress colobject;
3118 
3119  colobject = GetAttrDefaultColumnAddress(object->objectId);
3120 
3121  if (!OidIsValid(colobject.objectId))
3122  {
3123  if (!missing_ok)
3124  elog(ERROR, "could not find tuple for attrdef %u",
3125  object->objectId);
3126  break;
3127  }
3128 
3129  /* translator: %s is typically "column %s of table %s" */
3130  appendStringInfo(&buffer, _("default value for %s"),
3131  getObjectDescription(&colobject, false));
3132  break;
3133  }
3134 
3135  case OCLASS_LANGUAGE:
3136  {
3137  char *langname = get_language_name(object->objectId,
3138  missing_ok);
3139 
3140  if (langname)
3141  appendStringInfo(&buffer, _("language %s"),
3142  get_language_name(object->objectId, false));
3143  break;
3144  }
3145 
3146  case OCLASS_LARGEOBJECT:
3147  if (!LargeObjectExists(object->objectId))
3148  break;
3149  appendStringInfo(&buffer, _("large object %u"),
3150  object->objectId);
3151  break;
3152 
3153  case OCLASS_OPERATOR:
3154  {
3155  bits16 flags = FORMAT_OPERATOR_INVALID_AS_NULL;
3156  char *oprname = format_operator_extended(object->objectId,
3157  flags);
3158 
3159  if (oprname == NULL)
3160  break;
3161 
3162  appendStringInfo(&buffer, _("operator %s"), oprname);
3163  break;
3164  }
3165 
3166  case OCLASS_OPCLASS:
3167  {
3168  HeapTuple opcTup;
3169  Form_pg_opclass opcForm;
3170  HeapTuple amTup;
3171  Form_pg_am amForm;
3172  char *nspname;
3173 
3174  opcTup = SearchSysCache1(CLAOID,
3175  ObjectIdGetDatum(object->objectId));
3176  if (!HeapTupleIsValid(opcTup))
3177  {
3178  if (!missing_ok)
3179  elog(ERROR, "cache lookup failed for opclass %u",
3180  object->objectId);
3181  break;
3182  }
3183 
3184  opcForm = (Form_pg_opclass) GETSTRUCT(opcTup);
3185 
3186  amTup = SearchSysCache1(AMOID,
3187  ObjectIdGetDatum(opcForm->opcmethod));
3188  if (!HeapTupleIsValid(amTup))
3189  elog(ERROR, "cache lookup failed for access method %u",
3190  opcForm->opcmethod);
3191  amForm = (Form_pg_am) GETSTRUCT(amTup);
3192 
3193  /* Qualify the name if not visible in search path */
3194  if (OpclassIsVisible(object->objectId))
3195  nspname = NULL;
3196  else
3197  nspname = get_namespace_name(opcForm->opcnamespace);
3198 
3199  appendStringInfo(&buffer, _("operator class %s for access method %s"),
3200  quote_qualified_identifier(nspname,
3201  NameStr(opcForm->opcname)),
3202  NameStr(amForm->amname));
3203 
3204  ReleaseSysCache(amTup);
3205  ReleaseSysCache(opcTup);
3206  break;
3207  }
3208 
3209  case OCLASS_OPFAMILY:
3210  getOpFamilyDescription(&buffer, object->objectId, missing_ok);
3211  break;
3212 
3213  case OCLASS_AM:
3214  {
3215  HeapTuple tup;
3216 
3217  tup = SearchSysCache1(AMOID,
3218  ObjectIdGetDatum(object->objectId));
3219  if (!HeapTupleIsValid(tup))
3220  {
3221  if (!missing_ok)
3222  elog(ERROR, "cache lookup failed for access method %u",
3223  object->objectId);
3224  break;
3225  }
3226 
3227  appendStringInfo(&buffer, _("access method %s"),
3228  NameStr(((Form_pg_am) GETSTRUCT(tup))->amname));
3229  ReleaseSysCache(tup);
3230  break;
3231  }
3232 
3233  case OCLASS_AMOP:
3234  {
3235  Relation amopDesc;
3236  HeapTuple tup;
3237  ScanKeyData skey[1];
3238  SysScanDesc amscan;
3239  Form_pg_amop amopForm;
3240  StringInfoData opfam;
3241 
3242  amopDesc = table_open(AccessMethodOperatorRelationId,
3243  AccessShareLock);
3244 
3245  ScanKeyInit(&skey[0],
3246  Anum_pg_amop_oid,
3247  BTEqualStrategyNumber, F_OIDEQ,
3248  ObjectIdGetDatum(object->objectId));
3249 
3250  amscan = systable_beginscan(amopDesc, AccessMethodOperatorOidIndexId, true,
3251  NULL, 1, skey);
3252 
3253  tup = systable_getnext(amscan);
3254 
3255  if (!HeapTupleIsValid(tup))
3256  {
3257  if (!missing_ok)
3258  elog(ERROR, "could not find tuple for amop entry %u",
3259  object->objectId);
3260 
3261  systable_endscan(amscan);
3262  table_close(amopDesc, AccessShareLock);
3263  break;
3264  }
3265 
3266  amopForm = (Form_pg_amop) GETSTRUCT(tup);
3267 
3268  initStringInfo(&opfam);
3269  getOpFamilyDescription(&opfam, amopForm->amopfamily, false);
3270 
3271  /*------
3272  translator: %d is the operator strategy (a number), the
3273  first two %s's are data type names, the third %s is the
3274  description of the operator family, and the last %s is the
3275  textual form of the operator with arguments. */
3276  appendStringInfo(&buffer, _("operator %d (%s, %s) of %s: %s"),
3277  amopForm->amopstrategy,
3278  format_type_be(amopForm->amoplefttype),
3279  format_type_be(amopForm->amoprighttype),
3280  opfam.data,
3281  format_operator(amopForm->amopopr));
3282 
3283  pfree(opfam.data);
3284 
3285  systable_endscan(amscan);
3286  table_close(amopDesc, AccessShareLock);
3287  break;
3288  }
3289 
3290  case OCLASS_AMPROC:
3291  {
3292  Relation amprocDesc;
3293  ScanKeyData skey[1];
3294  SysScanDesc amscan;
3295  HeapTuple tup;
3296  Form_pg_amproc amprocForm;
3297  StringInfoData opfam;
3298 
3299  amprocDesc = table_open(AccessMethodProcedureRelationId,
3300  AccessShareLock);
3301 
3302  ScanKeyInit(&skey[0],
3303  Anum_pg_amproc_oid,
3304  BTEqualStrategyNumber, F_OIDEQ,
3305  ObjectIdGetDatum(object->objectId));
3306 
3307  amscan = systable_beginscan(amprocDesc, AccessMethodProcedureOidIndexId, true,
3308  NULL, 1, skey);
3309 
3310  tup = systable_getnext(amscan);
3311 
3312  if (!HeapTupleIsValid(tup))
3313  {
3314  if (!missing_ok)
3315  elog(ERROR, "could not find tuple for amproc entry %u",
3316  object->objectId);
3317 
3318  systable_endscan(amscan);
3319  table_close(amprocDesc, AccessShareLock);
3320  break;
3321  }
3322 
3323  amprocForm = (Form_pg_amproc) GETSTRUCT(tup);
3324 
3325  initStringInfo(&opfam);
3326  getOpFamilyDescription(&opfam, amprocForm->amprocfamily, false);
3327 
3328  /*------
3329  translator: %d is the function number, the first two %s's
3330  are data type names, the third %s is the description of the
3331  operator family, and the last %s is the textual form of the
3332  function with arguments. */
3333  appendStringInfo(&buffer, _("function %d (%s, %s) of %s: %s"),
3334  amprocForm->amprocnum,
3335  format_type_be(amprocForm->amproclefttype),
3336  format_type_be(amprocForm->amprocrighttype),
3337  opfam.data,
3338  format_procedure(amprocForm->amproc));
3339 
3340  pfree(opfam.data);
3341 
3342  systable_endscan(amscan);
3343  table_close(amprocDesc, AccessShareLock);
3344  break;
3345  }
3346 
3347  case OCLASS_REWRITE:
3348  {
3349  Relation ruleDesc;
3350  ScanKeyData skey[1];
3351  SysScanDesc rcscan;
3352  HeapTuple tup;
3353  Form_pg_rewrite rule;
3354  StringInfoData rel;
3355 
3356  ruleDesc = table_open(RewriteRelationId, AccessShareLock);
3357 
3358  ScanKeyInit(&skey[0],
3359  Anum_pg_rewrite_oid,
3360  BTEqualStrategyNumber, F_OIDEQ,
3361  ObjectIdGetDatum(object->objectId));
3362 
3363  rcscan = systable_beginscan(ruleDesc, RewriteOidIndexId, true,
3364  NULL, 1, skey);
3365 
3366  tup = systable_getnext(rcscan);
3367 
3368  if (!HeapTupleIsValid(tup))
3369  {
3370  if (!missing_ok)
3371  elog(ERROR, "could not find tuple for rule %u",
3372  object->objectId);
3373 
3374  systable_endscan(rcscan);
3375  table_close(ruleDesc, AccessShareLock);
3376  break;
3377  }
3378 
3379  rule = (Form_pg_rewrite) GETSTRUCT(tup);
3380 
3381  initStringInfo(&rel);
3382  getRelationDescription(&rel, rule->ev_class, false);
3383 
3384  /* translator: second %s is, e.g., "table %s" */
3385  appendStringInfo(&buffer, _("rule %s on %s"),
3386  NameStr(rule->rulename), rel.data);
3387  pfree(rel.data);
3388  systable_endscan(rcscan);
3389  table_close(ruleDesc, AccessShareLock);
3390  break;
3391  }
3392 
3393  case OCLASS_TRIGGER:
3394  {
3395  Relation trigDesc;
3396  ScanKeyData skey[1];
3397  SysScanDesc tgscan;
3398  HeapTuple tup;
3399  Form_pg_trigger trig;
3400  StringInfoData rel;
3401 
3402  trigDesc = table_open(TriggerRelationId, AccessShareLock);
3403 
3404  ScanKeyInit(&skey[0],
3405  Anum_pg_trigger_oid,
3406  BTEqualStrategyNumber, F_OIDEQ,
3407  ObjectIdGetDatum(object->objectId));
3408 
3409  tgscan = systable_beginscan(trigDesc, TriggerOidIndexId, true,
3410  NULL, 1, skey);
3411 
3412  tup = systable_getnext(tgscan);
3413 
3414  if (!HeapTupleIsValid(tup))
3415  {
3416  if (!missing_ok)
3417  elog(ERROR, "could not find tuple for trigger %u",
3418  object->objectId);
3419 
3420  systable_endscan(tgscan);
3421  table_close(trigDesc, AccessShareLock);
3422  break;
3423  }
3424 
3425  trig = (Form_pg_trigger) GETSTRUCT(tup);
3426 
3427  initStringInfo(&rel);
3428  getRelationDescription(&rel, trig->tgrelid, false);
3429 
3430  /* translator: second %s is, e.g., "table %s" */
3431  appendStringInfo(&buffer, _("trigger %s on %s"),
3432  NameStr(trig->tgname), rel.data);
3433  pfree(rel.data);
3434  systable_endscan(tgscan);
3435  table_close(trigDesc, AccessShareLock);
3436  break;
3437  }
3438 
3439  case OCLASS_SCHEMA:
3440  {
3441  char *nspname;
3442 
3443  nspname = get_namespace_name(object->objectId);
3444  if (!nspname)
3445  {
3446  if (!missing_ok)
3447  elog(ERROR, "cache lookup failed for namespace %u",
3448  object->objectId);
3449  break;
3450  }
3451  appendStringInfo(&buffer, _("schema %s"), nspname);
3452  break;
3453  }
3454 
3455  case OCLASS_STATISTIC_EXT:
3456  {
3457  HeapTuple stxTup;
3458  Form_pg_statistic_ext stxForm;
3459  char *nspname;
3460 
3461  stxTup = SearchSysCache1(STATEXTOID,
3462  ObjectIdGetDatum(object->objectId));
3463  if (!HeapTupleIsValid(stxTup))
3464  {
3465  if (!missing_ok)
3466  elog(ERROR, "could not find tuple for statistics object %u",
3467  object->objectId);
3468  break;
3469  }
3470 
3471  stxForm = (Form_pg_statistic_ext) GETSTRUCT(stxTup);
3472 
3473  /* Qualify the name if not visible in search path */
3474  if (StatisticsObjIsVisible(object->objectId))
3475  nspname = NULL;
3476  else
3477  nspname = get_namespace_name(stxForm->stxnamespace);
3478 
3479  appendStringInfo(&buffer, _("statistics object %s"),
3480  quote_qualified_identifier(nspname,
3481  NameStr(stxForm->stxname)));
3482 
3483  ReleaseSysCache(stxTup);
3484  break;
3485  }
3486 
3487  case OCLASS_TSPARSER:
3488  {
3489  HeapTuple tup;
3490  Form_pg_ts_parser prsForm;
3491  char *nspname;
3492 
3493  tup = SearchSysCache1(TSPARSEROID,
3494  ObjectIdGetDatum(object->objectId));
3495  if (!HeapTupleIsValid(tup))
3496  {
3497  if (!missing_ok)
3498  elog(ERROR, "cache lookup failed for text search parser %u",
3499  object->objectId);
3500  break;
3501  }
3502  prsForm = (Form_pg_ts_parser) GETSTRUCT(tup);
3503 
3504  /* Qualify the name if not visible in search path */
3505  if (TSParserIsVisible(object->objectId))
3506  nspname = NULL;
3507  else
3508  nspname = get_namespace_name(prsForm->prsnamespace);
3509 
3510  appendStringInfo(&buffer, _("text search parser %s"),
3511  quote_qualified_identifier(nspname,
3512  NameStr(prsForm->prsname)));
3513  ReleaseSysCache(tup);
3514  break;
3515  }
3516 
3517  case OCLASS_TSDICT:
3518  {
3519  HeapTuple tup;
3520  Form_pg_ts_dict dictForm;
3521  char *nspname;
3522 
3523  tup = SearchSysCache1(TSDICTOID,
3524  ObjectIdGetDatum(object->objectId));
3525  if (!HeapTupleIsValid(tup))
3526  {
3527  if (!missing_ok)
3528  elog(ERROR, "cache lookup failed for text search dictionary %u",
3529  object->objectId);
3530  break;
3531  }
3532 
3533  dictForm = (Form_pg_ts_dict) GETSTRUCT(tup);
3534 
3535  /* Qualify the name if not visible in search path */
3536  if (TSDictionaryIsVisible(object->objectId))
3537  nspname = NULL;
3538  else
3539  nspname = get_namespace_name(dictForm->dictnamespace);
3540 
3541  appendStringInfo(&buffer, _("text search dictionary %s"),
3542  quote_qualified_identifier(nspname,
3543  NameStr(dictForm->dictname)));
3544  ReleaseSysCache(tup);
3545  break;
3546  }
3547 
3548  case OCLASS_TSTEMPLATE:
3549  {
3550  HeapTuple tup;
3551  Form_pg_ts_template tmplForm;
3552  char *nspname;
3553 
3554  tup = SearchSysCache1(TSTEMPLATEOID,
3555  ObjectIdGetDatum(object->objectId));
3556  if (!HeapTupleIsValid(tup))
3557  {
3558  if (!missing_ok)
3559  elog(ERROR, "cache lookup failed for text search template %u",
3560  object->objectId);
3561  break;
3562  }
3563 
3564  tmplForm = (Form_pg_ts_template) GETSTRUCT(tup);
3565 
3566  /* Qualify the name if not visible in search path */
3567  if (TSTemplateIsVisible(object->objectId))
3568  nspname = NULL;
3569  else
3570  nspname = get_namespace_name(tmplForm->tmplnamespace);
3571 
3572  appendStringInfo(&buffer, _("text search template %s"),
3573  quote_qualified_identifier(nspname,
3574  NameStr(tmplForm->tmplname)));
3575  ReleaseSysCache(tup);
3576  break;
3577  }
3578 
3579  case OCLASS_TSCONFIG:
3580  {
3581  HeapTuple tup;
3582  Form_pg_ts_config cfgForm;
3583  char *nspname;
3584 
3585  tup = SearchSysCache1(TSCONFIGOID,
3586  ObjectIdGetDatum(object->objectId));
3587  if (!HeapTupleIsValid(tup))
3588  {
3589  if (!missing_ok)
3590  elog(ERROR, "cache lookup failed for text search configuration %u",
3591  object->objectId);
3592  break;
3593  }
3594 
3595  cfgForm = (Form_pg_ts_config) GETSTRUCT(tup);
3596 
3597  /* Qualify the name if not visible in search path */
3598  if (TSConfigIsVisible(object->objectId))
3599  nspname = NULL;
3600  else
3601  nspname = get_namespace_name(cfgForm->cfgnamespace);
3602 
3603  appendStringInfo(&buffer, _("text search configuration %s"),
3604  quote_qualified_identifier(nspname,
3605  NameStr(cfgForm->cfgname)));
3606  ReleaseSysCache(tup);
3607  break;
3608  }
3609 
3610  case OCLASS_ROLE:
3611  {
3612  char *username = GetUserNameFromId(object->objectId,
3613  missing_ok);
3614 
3615  if (username)
3616  appendStringInfo(&buffer, _("role %s"), username);
3617  break;
3618  }
3619 
3620  case OCLASS_ROLE_MEMBERSHIP:
3621  {
3622  Relation amDesc;
3623  ScanKeyData skey[1];
3624  SysScanDesc rcscan;
3625  HeapTuple tup;
3626  Form_pg_auth_members amForm;
3627 
3628  amDesc = table_open(AuthMemRelationId, AccessShareLock);
3629 
3630  ScanKeyInit(&skey[0],
3631  Anum_pg_auth_members_oid,
3632  BTEqualStrategyNumber, F_OIDEQ,
3633  ObjectIdGetDatum(object->objectId));
3634 
3635  rcscan = systable_beginscan(amDesc, AuthMemOidIndexId, true,
3636  NULL, 1, skey);
3637 
3638  tup = systable_getnext(rcscan);
3639 
3640  if (!HeapTupleIsValid(tup))
3641  {
3642  if (!missing_ok)
3643  elog(ERROR, "could not find tuple for role membership %u",
3644  object->objectId);
3645 
3646  systable_endscan(rcscan);
3647  table_close(amDesc, AccessShareLock);
3648  break;
3649  }
3650 
3651  amForm = (Form_pg_auth_members) GETSTRUCT(tup);
3652 
3653  appendStringInfo(&buffer, _("membership of role %s in role %s"),
3654  GetUserNameFromId(amForm->member, false),
3655  GetUserNameFromId(amForm->roleid, false));
3656 
3657  systable_endscan(rcscan);
3658  table_close(amDesc, AccessShareLock);
3659  break;
3660  }
3661 
3662  case OCLASS_DATABASE:
3663  {
3664  char *datname;
3665 
3666  datname = get_database_name(object->objectId);
3667  if (!datname)
3668  {
3669  if (!missing_ok)
3670  elog(ERROR, "cache lookup failed for database %u",
3671  object->objectId);
3672  break;
3673  }
3674  appendStringInfo(&buffer, _("database %s"), datname);
3675  break;
3676  }
3677 
3678  case OCLASS_TBLSPACE:
3679  {
3680  char *tblspace;
3681 
3682  tblspace = get_tablespace_name(object->objectId);
3683  if (!tblspace)
3684  {
3685  if (!missing_ok)
3686  elog(ERROR, "cache lookup failed for tablespace %u",
3687  object->objectId);
3688  break;
3689  }
3690  appendStringInfo(&buffer, _("tablespace %s"), tblspace);
3691  break;
3692  }
3693 
3694  case OCLASS_FDW:
3695  {
3696  ForeignDataWrapper *fdw;
3697 
3698  fdw = GetForeignDataWrapperExtended(object->objectId,
3699  missing_ok);
3700  if (fdw)
3701  appendStringInfo(&buffer, _("foreign-data wrapper %s"), fdw->fdwname);
3702  break;
3703  }
3704 
3705  case OCLASS_FOREIGN_SERVER:
3706  {
3707  ForeignServer *srv;
3708 
3709  srv = GetForeignServerExtended(object->objectId, missing_ok);
3710  if (srv)
3711  appendStringInfo(&buffer, _("server %s"), srv->servername);
3712  break;
3713  }
3714 
3715  case OCLASS_USER_MAPPING:
3716  {
3717  HeapTuple tup;
3718  Oid useid;
3719  char *usename;
3720  Form_pg_user_mapping umform;
3721  ForeignServer *srv;
3722 
3723  tup = SearchSysCache1(USERMAPPINGOID,
3724  ObjectIdGetDatum(object->objectId));
3725  if (!HeapTupleIsValid(tup))
3726  {
3727  if (!missing_ok)
3728  elog(ERROR, "cache lookup failed for user mapping %u",
3729  object->objectId);
3730  break;
3731  }
3732 
3733  umform = (Form_pg_user_mapping) GETSTRUCT(tup);
3734  useid = umform->umuser;
3735  srv = GetForeignServer(umform->umserver);
3736 
3737  ReleaseSysCache(tup);
3738 
3739  if (OidIsValid(useid))
3740  usename = GetUserNameFromId(useid, false);
3741  else
3742  usename = "public";
3743 
3744  appendStringInfo(&buffer, _("user mapping for %s on server %s"), usename,
3745  srv->servername);
3746  break;
3747  }
3748 
3749  case OCLASS_DEFACL:
3750  {
3751  Relation defaclrel;
3752  ScanKeyData skey[1];
3753  SysScanDesc rcscan;
3754  HeapTuple tup;
3755  Form_pg_default_acl defacl;
3756  char *rolename;
3757  char *nspname;
3758 
3759  defaclrel = table_open(DefaultAclRelationId, AccessShareLock);
3760 
3761  ScanKeyInit(&skey[0],
3762  Anum_pg_default_acl_oid,
3763  BTEqualStrategyNumber, F_OIDEQ,
3764  ObjectIdGetDatum(object->objectId));
3765 
3766  rcscan = systable_beginscan(defaclrel, DefaultAclOidIndexId,
3767  true, NULL, 1, skey);
3768 
3769  tup = systable_getnext(rcscan);
3770 
3771  if (!HeapTupleIsValid(tup))
3772  {
3773  if (!missing_ok)
3774  elog(ERROR, "could not find tuple for default ACL %u",
3775  object->objectId);
3776 
3777  systable_endscan(rcscan);
3778  table_close(defaclrel, AccessShareLock);
3779  break;
3780  }
3781 
3782  defacl = (Form_pg_default_acl) GETSTRUCT(tup);
3783 
3784  rolename = GetUserNameFromId(defacl->defaclrole, false);
3785 
3786  if (OidIsValid(defacl->defaclnamespace))
3787  nspname = get_namespace_name(defacl->defaclnamespace);
3788  else
3789  nspname = NULL;
3790 
3791  switch (defacl->defaclobjtype)
3792  {
3793  case DEFACLOBJ_RELATION:
3794  if (nspname)
3795  appendStringInfo(&buffer,
3796  _("default privileges on new relations belonging to role %s in schema %s"),
3797  rolename, nspname);
3798  else
3799  appendStringInfo(&buffer,
3800  _("default privileges on new relations belonging to role %s"),
3801  rolename);
3802  break;
3803  case DEFACLOBJ_SEQUENCE:
3804  if (nspname)
3805  appendStringInfo(&buffer,
3806  _("default privileges on new sequences belonging to role %s in schema %s"),
3807  rolename, nspname);
3808  else
3809  appendStringInfo(&buffer,
3810  _("default privileges on new sequences belonging to role %s"),
3811  rolename);
3812  break;
3813  case DEFACLOBJ_FUNCTION:
3814  if (nspname)
3815  appendStringInfo(&buffer,
3816  _("default privileges on new functions belonging to role %s in schema %s"),
3817  rolename, nspname);
3818  else
3819  appendStringInfo(&buffer,
3820  _("default privileges on new functions belonging to role %s"),
3821  rolename);
3822  break;
3823  case DEFACLOBJ_TYPE:
3824  if (nspname)
3825  appendStringInfo(&buffer,
3826  _("default privileges on new types belonging to role %s in schema %s"),
3827  rolename, nspname);
3828  else
3829  appendStringInfo(&buffer,
3830  _("default privileges on new types belonging to role %s"),
3831  rolename);
3832  break;
3833  case DEFACLOBJ_NAMESPACE:
3834  Assert(!nspname);
3835  appendStringInfo(&buffer,
3836  _("default privileges on new schemas belonging to role %s"),
3837  rolename);
3838  break;
3839  default:
3840  /* shouldn't get here */
3841  if (nspname)
3842  appendStringInfo(&buffer,
3843  _("default privileges belonging to role %s in schema %s"),
3844  rolename, nspname);
3845  else
3846  appendStringInfo(&buffer,
3847  _("default privileges belonging to role %s"),
3848  rolename);
3849  break;
3850  }
3851 
3852  systable_endscan(rcscan);
3853  table_close(defaclrel, AccessShareLock);
3854  break;
3855  }
3856 
3857  case OCLASS_EXTENSION:
3858  {
3859  char *extname;
3860 
3861  extname = get_extension_name(object->objectId);
3862  if (!extname)
3863  {
3864  if (!missing_ok)
3865  elog(ERROR, "cache lookup failed for extension %u",
3866  object->objectId);
3867  break;
3868  }
3869  appendStringInfo(&buffer, _("extension %s"), extname);
3870  break;
3871  }
3872 
3873  case OCLASS_EVENT_TRIGGER:
3874  {
3875  HeapTuple tup;
3876 
3877  tup = SearchSysCache1(EVENTTRIGGEROID,
3878  ObjectIdGetDatum(object->objectId));
3879  if (!HeapTupleIsValid(tup))
3880  {
3881  if (!missing_ok)
3882  elog(ERROR, "cache lookup failed for event trigger %u",
3883  object->objectId);
3884  break;
3885  }
3886  appendStringInfo(&buffer, _("event trigger %s"),
3887  NameStr(((Form_pg_event_trigger) GETSTRUCT(tup))->evtname));
3888  ReleaseSysCache(tup);
3889  break;
3890  }
3891 
3892  case OCLASS_PARAMETER_ACL:
3893  {
3894  HeapTuple tup;
3895  Datum nameDatum;
3896  char *parname;
3897 
3898  tup = SearchSysCache1(PARAMETERACLOID,
3899  ObjectIdGetDatum(object->objectId));
3900  if (!HeapTupleIsValid(tup))
3901  {
3902  if (!missing_ok)
3903  elog(ERROR, "cache lookup failed for parameter ACL %u",
3904  object->objectId);
3905  break;
3906  }
3907  nameDatum = SysCacheGetAttrNotNull(PARAMETERACLOID, tup,
3908  Anum_pg_parameter_acl_parname);
3909  parname = TextDatumGetCString(nameDatum);
3910  appendStringInfo(&buffer, _("parameter %s"), parname);
3911  ReleaseSysCache(tup);
3912  break;
3913  }
3914 
3915  case OCLASS_POLICY:
3916  {
3917  Relation policy_rel;
3918  ScanKeyData skey[1];
3919  SysScanDesc sscan;
3920  HeapTuple tuple;
3921  Form_pg_policy form_policy;
3922  StringInfoData rel;
3923 
3924  policy_rel = table_open(PolicyRelationId, AccessShareLock);
3925 
3926  ScanKeyInit(&skey[0],
3927  Anum_pg_policy_oid,
3928  BTEqualStrategyNumber, F_OIDEQ,
3929  ObjectIdGetDatum(object->objectId));
3930 
3931  sscan = systable_beginscan(policy_rel, PolicyOidIndexId,
3932  true, NULL, 1, skey);
3933 
3934  tuple = systable_getnext(sscan);
3935 
3936  if (!HeapTupleIsValid(tuple))
3937  {
3938  if (!missing_ok)
3939  elog(ERROR, "could not find tuple for policy %u",
3940  object->objectId);
3941 
3942  systable_endscan(sscan);
3943  table_close(policy_rel, AccessShareLock);
3944  break;
3945  }
3946 
3947  form_policy = (Form_pg_policy) GETSTRUCT(tuple);
3948 
3949  initStringInfo(&rel);
3950  getRelationDescription(&rel, form_policy->polrelid, false);
3951 
3952  /* translator: second %s is, e.g., "table %s" */
3953  appendStringInfo(&buffer, _("policy %s on %s"),
3954  NameStr(form_policy->polname), rel.data);
3955  pfree(rel.data);
3956  systable_endscan(sscan);
3957  table_close(policy_rel, AccessShareLock);
3958  break;
3959  }
3960 
3961  case OCLASS_PUBLICATION:
3962  {
3963  char *pubname = get_publication_name(object->objectId,
3964  missing_ok);
3965 
3966  if (pubname)
3967  appendStringInfo(&buffer, _("publication %s"), pubname);
3968  break;
3969  }
3970 
3971  case OCLASS_PUBLICATION_NAMESPACE:
3972  {
3973  char *pubname;
3974  char *nspname;
3975 
3976  if (!getPublicationSchemaInfo(object, missing_ok,
3977  &pubname, &nspname))
3978  break;
3979 
3980  appendStringInfo(&buffer, _("publication of schema %s in publication %s"),
3981  nspname, pubname);
3982  pfree(pubname);
3983  pfree(nspname);
3984  break;
3985  }
3986 
3987  case OCLASS_PUBLICATION_REL:
3988  {
3989  HeapTuple tup;
3990  char *pubname;
3991  Form_pg_publication_rel prform;
3992  StringInfoData rel;
3993 
3994  tup = SearchSysCache1(PUBLICATIONREL,
3995  ObjectIdGetDatum(object->objectId));
3996  if (!HeapTupleIsValid(tup))
3997  {
3998  if (!missing_ok)
3999  elog(ERROR, "cache lookup failed for publication table %u",
4000  object->objectId);
4001  break;
4002  }
4003 
4004  prform = (Form_pg_publication_rel) GETSTRUCT(tup);
4005  pubname = get_publication_name(prform->prpubid, false);
4006 
4007  initStringInfo(&rel);
4008  getRelationDescription(&rel, prform->prrelid, false);
4009 
4010  /* translator: first %s is, e.g., "table %s" */
4011  appendStringInfo(&buffer, _("publication of %s in publication %s"),
4012  rel.data, pubname);
4013  pfree(rel.data);
4014  ReleaseSysCache(tup);
4015  break;
4016  }
4017 
4018  case OCLASS_SUBSCRIPTION:
4019  {
4020  char *subname = get_subscription_name(object->objectId,
4021  missing_ok);
4022 
4023  if (subname)
4024  appendStringInfo(&buffer, _("subscription %s"), subname);
4025  break;
4026  }
4027 
4028  case OCLASS_TRANSFORM:
4029  {
4030  HeapTuple trfTup;
4031  Form_pg_transform trfForm;
4032 
4033  trfTup = SearchSysCache1(TRFOID,
4034  ObjectIdGetDatum(object->objectId));
4035  if (!HeapTupleIsValid(trfTup))
4036  {
4037  if (!missing_ok)
4038  elog(ERROR, "could not find tuple for transform %u",
4039  object->objectId);
4040  break;
4041  }
4042 
4043  trfForm = (Form_pg_transform) GETSTRUCT(trfTup);
4044 
4045  appendStringInfo(&buffer, _("transform for %s language %s"),
4046  format_type_be(trfForm->trftype),
4047  get_language_name(trfForm->trflang, false));
4048 
4049  ReleaseSysCache(trfTup);
4050  break;
4051  }
4052 
4053  /*
4054  * There's intentionally no default: case here; we want the
4055  * compiler to warn if a new OCLASS hasn't been handled above.
4056  */
4057  }
4058 
4059  /* an empty buffer is equivalent to no object found */
4060  if (buffer.len == 0)
4061  return NULL;
4062 
4063  return buffer.data;
4064 }
get_tablespace_name
char * get_tablespace_name(Oid spc_oid)
Definition: tablespace.c:1478
TextDatumGetCString
#define TextDatumGetCString(d)
Definition: builtins.h:95
FORMAT_TYPE_INVALID_AS_NULL
#define FORMAT_TYPE_INVALID_AS_NULL
Definition: builtins.h:124
NameStr
#define NameStr(name)
Definition: c.h:730
bits16
uint16 bits16
Definition: c.h:498
get_database_name
char * get_database_name(Oid dbid)
Definition: dbcommands.c:3043
getObjectClass
ObjectClass getObjectClass(const ObjectAddress *object)
Definition: dependency.c:2836
OCLASS_OPERATOR
@ OCLASS_OPERATOR
Definition: dependency.h:100
OCLASS_PARAMETER_ACL
@ OCLASS_PARAMETER_ACL
Definition: dependency.h:124
OCLASS_LARGEOBJECT
@ OCLASS_LARGEOBJECT
Definition: dependency.h:99
OCLASS_FDW
@ OCLASS_FDW
Definition: dependency.h:118
OCLASS_OPFAMILY
@ OCLASS_OPFAMILY
Definition: dependency.h:102
OCLASS_DEFACL
@ OCLASS_DEFACL
Definition: dependency.h:121
OCLASS_TSPARSER
@ OCLASS_TSPARSER
Definition: dependency.h:110
OCLASS_TRIGGER
@ OCLASS_TRIGGER
Definition: dependency.h:107
OCLASS_DEFAULT
@ OCLASS_DEFAULT
Definition: dependency.h:97
OCLASS_TSTEMPLATE
@ OCLASS_TSTEMPLATE
Definition: dependency.h:112
OCLASS_AMPROC
@ OCLASS_AMPROC
Definition: dependency.h:105
OCLASS_TBLSPACE
@ OCLASS_TBLSPACE
Definition: dependency.h:117
OCLASS_TSCONFIG
@ OCLASS_TSCONFIG
Definition: dependency.h:113
OCLASS_TYPE
@ OCLASS_TYPE
Definition: dependency.h:92
OCLASS_LANGUAGE
@ OCLASS_LANGUAGE
Definition: dependency.h:98
OCLASS_CAST
@ OCLASS_CAST
Definition: dependency.h:93
OCLASS_SUBSCRIPTION
@ OCLASS_SUBSCRIPTION
Definition: dependency.h:129
OCLASS_PUBLICATION_NAMESPACE
@ OCLASS_PUBLICATION_NAMESPACE
Definition: dependency.h:127
OCLASS_EXTENSION
@ OCLASS_EXTENSION
Definition: dependency.h:122
OCLASS_COLLATION
@ OCLASS_COLLATION
Definition: dependency.h:94
OCLASS_FOREIGN_SERVER
@ OCLASS_FOREIGN_SERVER
Definition: dependency.h:119
OCLASS_REWRITE
@ OCLASS_REWRITE
Definition: dependency.h:106
OCLASS_STATISTIC_EXT
@ OCLASS_STATISTIC_EXT
Definition: dependency.h:109
OCLASS_PROC
@ OCLASS_PROC
Definition: dependency.h:91
OCLASS_OPCLASS
@ OCLASS_OPCLASS
Definition: dependency.h:101
OCLASS_CONVERSION
@ OCLASS_CONVERSION
Definition: dependency.h:96
OCLASS_DATABASE
@ OCLASS_DATABASE
Definition: dependency.h:116
OCLASS_ROLE_MEMBERSHIP
@ OCLASS_ROLE_MEMBERSHIP
Definition: dependency.h:115
OCLASS_SCHEMA
@ OCLASS_SCHEMA
Definition: dependency.h:108
OCLASS_EVENT_TRIGGER
@ OCLASS_EVENT_TRIGGER
Definition: dependency.h:123
OCLASS_CLASS
@ OCLASS_CLASS
Definition: dependency.h:90
OCLASS_TRANSFORM
@ OCLASS_TRANSFORM
Definition: dependency.h:130
OCLASS_ROLE
@ OCLASS_ROLE
Definition: dependency.h:114
OCLASS_CONSTRAINT
@ OCLASS_CONSTRAINT
Definition: dependency.h:95
OCLASS_POLICY
@ OCLASS_POLICY
Definition: dependency.h:125
OCLASS_USER_MAPPING
@ OCLASS_USER_MAPPING
Definition: dependency.h:120
OCLASS_PUBLICATION_REL
@ OCLASS_PUBLICATION_REL
Definition: dependency.h:128
OCLASS_AM
@ OCLASS_AM
Definition: dependency.h:103
OCLASS_TSDICT
@ OCLASS_TSDICT
Definition: dependency.h:111
OCLASS_PUBLICATION
@ OCLASS_PUBLICATION
Definition: dependency.h:126
OCLASS_AMOP
@ OCLASS_AMOP
Definition: dependency.h:104
_
#define _(x)
Definition: elog.c:91
get_extension_name
char * get_extension_name(Oid ext_oid)
Definition: extension.c:189
GetForeignServerExtended
ForeignServer * GetForeignServerExtended(Oid serverid, bits16 flags)
Definition: foreign.c:123
GetForeignDataWrapperExtended
ForeignDataWrapper * GetForeignDataWrapperExtended(Oid fdwid, bits16 flags)
Definition: foreign.c:49
GetForeignServer
ForeignServer * GetForeignServer(Oid serverid)
Definition: foreign.c:111
format_type_extended
char * format_type_extended(Oid type_oid, int32 typemod, bits16 flags)
Definition: format_type.c:112
AccessShareLock
#define AccessShareLock
Definition: lockdefs.h:36
get_language_name
char * get_language_name(Oid langoid, bool missing_ok)
Definition: lsyscache.c:1165
get_namespace_name
char * get_namespace_name(Oid nspid)
Definition: lsyscache.c:3324
get_publication_name
char * get_publication_name(Oid pubid, bool missing_ok)
Definition: lsyscache.c:3603
get_subscription_name
char * get_subscription_name(Oid subid, bool missing_ok)
Definition: lsyscache.c:3653
get_attname
char * get_attname(Oid relid, AttrNumber attnum, bool missing_ok)
Definition: lsyscache.c:826
pfree
void pfree(void *pointer)
Definition: mcxt.c:1456
TSTemplateIsVisible
bool TSTemplateIsVisible(Oid tmplId)
Definition: namespace.c:2654
CollationIsVisible
bool CollationIsVisible(Oid collid)
Definition: namespace.c:2091
ConversionIsVisible
bool ConversionIsVisible(Oid conid)
Definition: namespace.c:2174
OpclassIsVisible
bool OpclassIsVisible(Oid opcid)
Definition: namespace.c:1876
StatisticsObjIsVisible
bool StatisticsObjIsVisible(Oid relid)
Definition: namespace.c:2278
TSParserIsVisible
bool TSParserIsVisible(Oid prsId)
Definition: namespace.c:2401
TSConfigIsVisible
bool TSConfigIsVisible(Oid cfgid)
Definition: namespace.c:2780
TSDictionaryIsVisible
bool TSDictionaryIsVisible(Oid dictId)
Definition: namespace.c:2527
getRelationDescription
static void getRelationDescription(StringInfo buffer, Oid relid, bool missing_ok)
Definition: objectaddress.c:4087
getObjectDescription
char * getObjectDescription(const ObjectAddress *object, bool missing_ok)
Definition: objectaddress.c:2916
getPublicationSchemaInfo
static bool getPublicationSchemaInfo(const ObjectAddress *object, bool missing_ok, char **pubname, char **nspname)
Definition: objectaddress.c:2868
getOpFamilyDescription
static void getOpFamilyDescription(StringInfo buffer, Oid opfid, bool missing_ok)
Definition: objectaddress.c:4162
Form_pg_am
FormData_pg_am * Form_pg_am
Definition: pg_am.h:48
Form_pg_amop
FormData_pg_amop * Form_pg_amop
Definition: pg_amop.h:88
Form_pg_amproc
FormData_pg_amproc * Form_pg_amproc
Definition: pg_amproc.h:68
GetAttrDefaultColumnAddress
ObjectAddress GetAttrDefaultColumnAddress(Oid attrdefoid)
Definition: pg_attrdef.c:381
attname
NameData attname
Definition: pg_attribute.h:41
Form_pg_auth_members
FormData_pg_auth_members * Form_pg_auth_members
Definition: pg_auth_members.h:46
Form_pg_cast
FormData_pg_cast * Form_pg_cast
Definition: pg_cast.h:57
Form_pg_collation
FormData_pg_collation * Form_pg_collation
Definition: pg_collation.h:58
Form_pg_conversion
FormData_pg_conversion * Form_pg_conversion
Definition: pg_conversion.h:61
datname
NameData datname
Definition: pg_database.h:35
Form_pg_default_acl
FormData_pg_default_acl * Form_pg_default_acl
Definition: pg_default_acl.h:50
Form_pg_event_trigger
FormData_pg_event_trigger * Form_pg_event_trigger
Definition: pg_event_trigger.h:50
Form_pg_opclass
FormData_pg_opclass * Form_pg_opclass
Definition: pg_opclass.h:83
Form_pg_policy
FormData_pg_policy * Form_pg_policy
Definition: pg_policy.h:51
proname
NameData proname
Definition: pg_proc.h:35
Form_pg_publication_rel
FormData_pg_publication_rel * Form_pg_publication_rel
Definition: pg_publication_rel.h:46
Form_pg_rewrite
FormData_pg_rewrite * Form_pg_rewrite
Definition: pg_rewrite.h:52
Form_pg_statistic_ext
FormData_pg_statistic_ext * Form_pg_statistic_ext
Definition: pg_statistic_ext.h:69
subname
NameData subname
Definition: pg_subscription.h:73
Form_pg_transform
FormData_pg_transform * Form_pg_transform
Definition: pg_transform.h:43
Form_pg_trigger
FormData_pg_trigger * Form_pg_trigger
Definition: pg_trigger.h:80
Form_pg_ts_config
FormData_pg_ts_config * Form_pg_ts_config
Definition: pg_ts_config.h:48
Form_pg_ts_dict
FormData_pg_ts_dict * Form_pg_ts_dict
Definition: pg_ts_dict.h:52
Form_pg_ts_parser
FormData_pg_ts_parser * Form_pg_ts_parser
Definition: pg_ts_parser.h:55
Form_pg_ts_template
FormData_pg_ts_template * Form_pg_ts_template
Definition: pg_ts_template.h:46
typname
NameData typname
Definition: pg_type.h:41
Form_pg_user_mapping
FormData_pg_user_mapping * Form_pg_user_mapping
Definition: pg_user_mapping.h:48
username
const char * username
Definition: pgbench.c:306
Datum
uintptr_t Datum
Definition: postgres.h:64
format_operator
char * format_operator(Oid operator_oid)
Definition: regproc.c:793
format_procedure
char * format_procedure(Oid procedure_oid)
Definition: regproc.c:299
format_operator_extended
char * format_operator_extended(Oid operator_oid, bits16 flags)
Definition: regproc.c:722
format_procedure_extended
char * format_procedure_extended(Oid procedure_oid, bits16 flags)
Definition: regproc.c:326
FORMAT_OPERATOR_INVALID_AS_NULL
#define FORMAT_OPERATOR_INVALID_AS_NULL
Definition: regproc.h:24
FORMAT_PROC_INVALID_AS_NULL
#define FORMAT_PROC_INVALID_AS_NULL
Definition: regproc.h:19
quote_qualified_identifier
char * quote_qualified_identifier(const char *qualifier, const char *ident)
Definition: ruleutils.c:12014
appendStringInfo
void appendStringInfo(StringInfo str, const char *fmt,...)
Definition: stringinfo.c:91
initStringInfo
void initStringInfo(StringInfo str)
Definition: stringinfo.c:59
ForeignDataWrapper::fdwname
char * fdwname
Definition: foreign.h:28
ForeignServer::servername
char * servername
Definition: foreign.h:39
rule
Definition: localtime.c:73
PARAMETERACLOID
@ PARAMETERACLOID
Definition: syscache.h:76
TSTEMPLATEOID
@ TSTEMPLATEOID
Definition: syscache.h:112
TSDICTOID
@ TSDICTOID
Definition: syscache.h:108
PUBLICATIONREL
@ PUBLICATIONREL
Definition: syscache.h:84
STATEXTOID
@ STATEXTOID
Definition: syscache.h:96
AMOID
@ AMOID
Definition: syscache.h:36
EVENTTRIGGEROID
@ EVENTTRIGGEROID
Definition: syscache.h:60
CONVOID
@ CONVOID
Definition: syscache.h:54
COLLOID
@ COLLOID
Definition: syscache.h:50
TRFOID
@ TRFOID
Definition: syscache.h:102
CLAOID
@ CLAOID
Definition: syscache.h:48
USERMAPPINGOID
@ USERMAPPINGOID
Definition: syscache.h:115
TSPARSEROID
@ TSPARSEROID
Definition: syscache.h:110
TSCONFIGOID
@ TSCONFIGOID
Definition: syscache.h:106
table_close
void table_close(Relation relation, LOCKMODE lockmode)
Definition: table.c:126
table_open
Relation table_open(Oid relationId, LOCKMODE lockmode)
Definition: table.c:40

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 4070 of file objectaddress.c.

4071 {
4072  ObjectAddress address;
4073 
4074  address.classId = classid;
4075  address.objectId = objid;
4076  address.objectSubId = 0;
4077 
4078  return getObjectDescription(&address, false);
4079 }

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 4741 of file objectaddress.c.

4742 {
4743  return getObjectIdentityParts(object, NULL, NULL, missing_ok);
4744 }
getObjectIdentityParts
char * getObjectIdentityParts(const ObjectAddress *object, List **objname, List **objargs, bool missing_ok)
Definition: objectaddress.c:4756

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 4756 of file objectaddress.c.

4759 {
4760  StringInfoData buffer;
4761 
4762  initStringInfo(&buffer);
4763 
4764  /*
4765  * Make sure that both objname and objargs were passed, or none was; and
4766  * initialize them to empty lists. For objname this is useless because it
4767  * will be initialized in all cases inside the switch; but we do it anyway
4768  * so that we can test below that no branch leaves it unset.
4769  */
4770  Assert(PointerIsValid(objname) == PointerIsValid(objargs));
4771  if (objname)
4772  {
4773  *objname = NIL;
4774  *objargs = NIL;
4775  }
4776 
4777  switch (getObjectClass(object))
4778  {
4779  case OCLASS_CLASS:
4780  {
4781  char *attr = NULL;
4782 
4783  /*
4784  * Check for the attribute first, so as if it is missing we
4785  * can skip the entire relation description.
4786  */
4787  if (object->objectSubId != 0)
4788  {
4789  attr = get_attname(object->objectId,
4790  object->objectSubId,
4791  missing_ok);
4792 
4793  if (missing_ok && attr == NULL)
4794  break;
4795  }
4796 
4797  getRelationIdentity(&buffer, object->objectId, objname,
4798  missing_ok);
4799  if (objname && *objname == NIL)
4800  break;
4801 
4802  if (attr)
4803  {
4804  appendStringInfo(&buffer, ".%s",
4805  quote_identifier(attr));
4806  if (objname)
4807  *objname = lappend(*objname, attr);
4808  }
4809  }
4810  break;
4811 
4812  case OCLASS_PROC:
4813  {
4814  bits16 flags = FORMAT_PROC_FORCE_QUALIFY | FORMAT_PROC_INVALID_AS_NULL;
4815  char *proname = format_procedure_extended(object->objectId,
4816  flags);
4817 
4818  if (proname == NULL)
4819  break;
4820 
4821  appendStringInfoString(&buffer, proname);
4822  if (objname)
4823  format_procedure_parts(object->objectId, objname, objargs,
4824  missing_ok);
4825  break;
4826  }
4827 
4828  case OCLASS_TYPE:
4829  {
4830  bits16 flags = FORMAT_TYPE_INVALID_AS_NULL | FORMAT_TYPE_FORCE_QUALIFY;
4831  char *typeout;
4832 
4833  typeout = format_type_extended(object->objectId, -1, flags);
4834 
4835  if (typeout == NULL)
4836  break;
4837 
4838  appendStringInfoString(&buffer, typeout);
4839  if (objname)
4840  *objname = list_make1(typeout);
4841  }
4842  break;
4843 
4844  case OCLASS_CAST:
4845  {
4846  Relation castRel;
4847  HeapTuple tup;
4848  Form_pg_cast castForm;
4849 
4850  castRel = table_open(CastRelationId, AccessShareLock);
4851 
4852  tup = get_catalog_object_by_oid(castRel, Anum_pg_cast_oid,
4853  object->objectId);
4854 
4855  if (!HeapTupleIsValid(tup))
4856  {
4857  if (!missing_ok)
4858  elog(ERROR, "could not find tuple for cast %u",
4859  object->objectId);
4860 
4861  table_close(castRel, AccessShareLock);
4862  break;
4863  }
4864 
4865  castForm = (Form_pg_cast) GETSTRUCT(tup);
4866 
4867  appendStringInfo(&buffer, "(%s AS %s)",
4868  format_type_be_qualified(castForm->castsource),
4869  format_type_be_qualified(castForm->casttarget));
4870 
4871  if (objname)
4872  {
4873  *objname = list_make1(format_type_be_qualified(castForm->castsource));
4874  *objargs = list_make1(format_type_be_qualified(castForm->casttarget));
4875  }
4876 
4877  table_close(castRel, AccessShareLock);
4878  break;
4879  }
4880 
4881  case OCLASS_COLLATION:
4882  {
4883  HeapTuple collTup;
4884  Form_pg_collation coll;
4885  char *schema;
4886 
4887  collTup = SearchSysCache1(COLLOID,
4888  ObjectIdGetDatum(object->objectId));
4889  if (!HeapTupleIsValid(collTup))
4890  {
4891  if (!missing_ok)
4892  elog(ERROR, "cache lookup failed for collation %u",
4893  object->objectId);
4894  break;
4895  }
4896  coll = (Form_pg_collation) GETSTRUCT(collTup);
4897  schema = get_namespace_name_or_temp(coll->collnamespace);
4898  appendStringInfoString(&buffer,
4899  quote_qualified_identifier(schema,
4900  NameStr(coll->collname)));
4901  if (objname)
4902  *objname = list_make2(schema,
4903  pstrdup(NameStr(coll->collname)));
4904  ReleaseSysCache(collTup);
4905  break;
4906  }
4907 
4908  case OCLASS_CONSTRAINT:
4909  {
4910  HeapTuple conTup;
4911  Form_pg_constraint con;
4912 
4913  conTup = SearchSysCache1(CONSTROID,
4914  ObjectIdGetDatum(object->objectId));
4915  if (!HeapTupleIsValid(conTup))
4916  {
4917  if (!missing_ok)
4918  elog(ERROR, "cache lookup failed for constraint %u",
4919  object->objectId);
4920  break;
4921  }
4922  con = (Form_pg_constraint) GETSTRUCT(conTup);
4923 
4924  if (OidIsValid(con->conrelid))
4925  {
4926  appendStringInfo(&buffer, "%s on ",
4927  quote_identifier(NameStr(con->conname)));
4928  getRelationIdentity(&buffer, con->conrelid, objname,
4929  false);
4930  if (objname)
4931  *objname = lappend(*objname, pstrdup(NameStr(con->conname)));
4932  }
4933  else
4934  {
4935  ObjectAddress domain;
4936 
4937  Assert(OidIsValid(con->contypid));
4938  domain.classId = TypeRelationId;
4939  domain.objectId = con->contypid;
4940  domain.objectSubId = 0;
4941 
4942  appendStringInfo(&buffer, "%s on %s",
4943  quote_identifier(NameStr(con->conname)),
4944  getObjectIdentityParts(&domain, objname,
4945  objargs, false));
4946 
4947  if (objname)
4948  *objargs = lappend(*objargs, pstrdup(NameStr(con->conname)));
4949  }
4950 
4951  ReleaseSysCache(conTup);
4952  break;
4953  }
4954 
4955  case OCLASS_CONVERSION:
4956  {
4957  HeapTuple conTup;
4958  Form_pg_conversion conForm;
4959  char *schema;
4960 
4961  conTup = SearchSysCache1(CONVOID,
4962  ObjectIdGetDatum(object->objectId));
4963  if (!HeapTupleIsValid(conTup))
4964  {
4965  if (!missing_ok)
4966  elog(ERROR, "cache lookup failed for conversion %u",
4967  object->objectId);
4968  break;
4969  }
4970  conForm = (Form_pg_conversion) GETSTRUCT(conTup);
4971  schema = get_namespace_name_or_temp(conForm->connamespace);
4972  appendStringInfoString(&buffer,
4973  quote_qualified_identifier(schema,
4974  NameStr(conForm->conname)));
4975  if (objname)
4976  *objname = list_make2(schema,
4977  pstrdup(NameStr(conForm->conname)));
4978  ReleaseSysCache(conTup);
4979  break;
4980  }
4981 
4982  case OCLASS_DEFAULT:
4983  {
4984  ObjectAddress colobject;
4985 
4986  colobject = GetAttrDefaultColumnAddress(object->objectId);
4987 
4988  if (!OidIsValid(colobject.objectId))
4989  {
4990  if (!missing_ok)
4991  elog(ERROR, "could not find tuple for attrdef %u",
4992  object->objectId);
4993  break;
4994  }
4995 
4996  appendStringInfo(&buffer, "for %s",
4997  getObjectIdentityParts(&colobject,
4998  objname, objargs,
4999  false));
5000  break;
5001  }
5002 
5003  case OCLASS_LANGUAGE:
5004  {
5005  HeapTuple langTup;
5006  Form_pg_language langForm;
5007 
5008  langTup = SearchSysCache1(LANGOID,
5009  ObjectIdGetDatum(object->objectId));
5010  if (!HeapTupleIsValid(langTup))
5011  {
5012  if (!missing_ok)
5013  elog(ERROR, "cache lookup failed for language %u",
5014  object->objectId);
5015  break;
5016  }
5017  langForm = (Form_pg_language) GETSTRUCT(langTup);
5018  appendStringInfoString(&buffer,
5019  quote_identifier(NameStr(langForm->lanname)));
5020  if (objname)
5021  *objname = list_make1(pstrdup(NameStr(langForm->lanname)));
5022  ReleaseSysCache(langTup);
5023  break;
5024  }
5025  case OCLASS_LARGEOBJECT:
5026  if (!LargeObjectExists(object->objectId))
5027  break;
5028  appendStringInfo(&buffer, "%u",
5029  object->objectId);
5030  if (objname)
5031  *objname = list_make1(psprintf("%u", object->objectId));
5032  break;
5033 
5034  case OCLASS_OPERATOR:
5035  {
5036  bits16 flags = FORMAT_OPERATOR_FORCE_QUALIFY | FORMAT_OPERATOR_INVALID_AS_NULL;
5037  char *oprname = format_operator_extended(object->objectId,
5038  flags);
5039 
5040  if (oprname == NULL)
5041  break;
5042 
5043  appendStringInfoString(&buffer, oprname);
5044  if (objname)
5045  format_operator_parts(object->objectId, objname, objargs, missing_ok);
5046  break;
5047  }
5048 
5049  case OCLASS_OPCLASS:
5050  {
5051  HeapTuple opcTup;
5052  Form_pg_opclass opcForm;
5053  HeapTuple amTup;
5054  Form_pg_am amForm;
5055  char *schema;
5056 
5057  opcTup = SearchSysCache1(CLAOID,
5058  ObjectIdGetDatum(object->objectId));
5059  if (!HeapTupleIsValid(opcTup))
5060  {
5061  if (!missing_ok)
5062  elog(ERROR, "cache lookup failed for opclass %u",
5063  object->objectId);
5064  break;
5065  }
5066  opcForm = (Form_pg_opclass) GETSTRUCT(opcTup);
5067  schema = get_namespace_name_or_temp(opcForm->opcnamespace);
5068 
5069  amTup = SearchSysCache1(AMOID,
5070  ObjectIdGetDatum(opcForm->opcmethod));
5071  if (!HeapTupleIsValid(amTup))
5072  elog(ERROR, "cache lookup failed for access method %u",
5073  opcForm->opcmethod);
5074  amForm = (Form_pg_am) GETSTRUCT(amTup);
5075 
5076  appendStringInfo(&buffer, "%s USING %s",
5077  quote_qualified_identifier(schema,
5078  NameStr(opcForm->opcname)),
5079  quote_identifier(NameStr(amForm->amname)));
5080  if (objname)
5081  *objname = list_make3(pstrdup(NameStr(amForm->amname)),
5082  schema,
5083  pstrdup(NameStr(opcForm->opcname)));
5084 
5085  ReleaseSysCache(amTup);
5086  ReleaseSysCache(opcTup);
5087  break;
5088  }
5089 
5090  case OCLASS_OPFAMILY:
5091  getOpFamilyIdentity(&buffer, object->objectId, objname,
5092  missing_ok);
5093  break;
5094 
5095  case OCLASS_AM:
5096  {
5097  char *amname;
5098 
5099  amname = get_am_name(object->objectId);
5100  if (!amname)
5101  {
5102  if (!missing_ok)
5103  elog(ERROR, "cache lookup failed for access method %u",
5104  object->objectId);
5105  break;
5106  }
5107  appendStringInfoString(&buffer, quote_identifier(amname));
5108  if (objname)
5109  *objname = list_make1(amname);
5110  }
5111  break;
5112 
5113  case OCLASS_AMOP:
5114  {
5115  Relation amopDesc;
5116  HeapTuple tup;
5117  ScanKeyData skey[1];
5118  SysScanDesc amscan;
5119  Form_pg_amop amopForm;
5120  StringInfoData opfam;
5121  char *ltype;
5122  char *rtype;
5123 
5124  amopDesc = table_open(AccessMethodOperatorRelationId,
5125  AccessShareLock);
5126 
5127  ScanKeyInit(&skey[0],
5128  Anum_pg_amop_oid,
5129  BTEqualStrategyNumber, F_OIDEQ,
5130  ObjectIdGetDatum(object->objectId));
5131 
5132  amscan = systable_beginscan(amopDesc, AccessMethodOperatorOidIndexId, true,
5133  NULL, 1, skey);
5134 
5135  tup = systable_getnext(amscan);
5136 
5137  if (!HeapTupleIsValid(tup))
5138  {
5139  if (!missing_ok)
5140  elog(ERROR, "could not find tuple for amop entry %u",
5141  object->objectId);
5142 
5143  systable_endscan(amscan);
5144  table_close(amopDesc, AccessShareLock);
5145  break;
5146  }
5147 
5148  amopForm = (Form_pg_amop) GETSTRUCT(tup);
5149 
5150  initStringInfo(&opfam);
5151  getOpFamilyIdentity(&opfam, amopForm->amopfamily, objname,
5152  false);
5153 
5154  ltype = format_type_be_qualified(amopForm->amoplefttype);
5155  rtype = format_type_be_qualified(amopForm->amoprighttype);
5156 
5157  if (objname)
5158  {
5159  *objname = lappend(*objname,
5160  psprintf("%d", amopForm->amopstrategy));
5161  *objargs = list_make2(ltype, rtype);
5162  }
5163 
5164  appendStringInfo(&buffer, "operator %d (%s, %s) of %s",
5165  amopForm->amopstrategy,
5166  ltype, rtype, opfam.data);
5167 
5168  pfree(opfam.data);
5169 
5170  systable_endscan(amscan);
5171  table_close(amopDesc, AccessShareLock);
5172  break;
5173  }
5174 
5175  case OCLASS_AMPROC:
5176  {
5177  Relation amprocDesc;
5178  ScanKeyData skey[1];
5179  SysScanDesc amscan;
5180  HeapTuple tup;
5181  Form_pg_amproc amprocForm;
5182  StringInfoData opfam;
5183  char *ltype;
5184  char *rtype;
5185 
5186  amprocDesc = table_open(AccessMethodProcedureRelationId,
5187  AccessShareLock);
5188 
5189  ScanKeyInit(&skey[0],
5190  Anum_pg_amproc_oid,
5191  BTEqualStrategyNumber, F_OIDEQ,
5192  ObjectIdGetDatum(object->objectId));
5193 
5194  amscan = systable_beginscan(amprocDesc, AccessMethodProcedureOidIndexId, true,
5195  NULL, 1, skey);
5196 
5197  tup = systable_getnext(amscan);
5198 
5199  if (!HeapTupleIsValid(tup))
5200  {
5201  if (!missing_ok)
5202  elog(ERROR, "could not find tuple for amproc entry %u",
5203  object->objectId);
5204 
5205  systable_endscan(amscan);
5206  table_close(amprocDesc, AccessShareLock);
5207  break;
5208  }
5209 
5210  amprocForm = (Form_pg_amproc) GETSTRUCT(tup);
5211 
5212  initStringInfo(&opfam);
5213  getOpFamilyIdentity(&opfam, amprocForm->amprocfamily, objname,
5214  false);
5215 
5216  ltype = format_type_be_qualified(amprocForm->amproclefttype);
5217  rtype = format_type_be_qualified(amprocForm->amprocrighttype);
5218 
5219  if (objname)
5220  {
5221  *objname = lappend(*objname,
5222  psprintf("%d", amprocForm->amprocnum));
5223  *objargs = list_make2(ltype, rtype);
5224  }
5225 
5226  appendStringInfo(&buffer, "function %d (%s, %s) of %s",
5227  amprocForm->amprocnum,
5228  ltype, rtype, opfam.data);
5229 
5230  pfree(opfam.data);
5231 
5232  systable_endscan(amscan);
5233  table_close(amprocDesc, AccessShareLock);
5234  break;
5235  }
5236 
5237  case OCLASS_REWRITE:
5238  {
5239  Relation ruleDesc;
5240  HeapTuple tup;
5241  Form_pg_rewrite rule;
5242 
5243  ruleDesc = table_open(RewriteRelationId, AccessShareLock);
5244 
5245  tup = get_catalog_object_by_oid(ruleDesc, Anum_pg_rewrite_oid,
5246  object->objectId);
5247 
5248  if (!HeapTupleIsValid(tup))
5249  {
5250  if (!missing_ok)
5251  elog(ERROR, "could not find tuple for rule %u",
5252  object->objectId);
5253 
5254  table_close(ruleDesc, AccessShareLock);
5255  break;
5256  }
5257 
5258  rule = (Form_pg_rewrite) GETSTRUCT(tup);
5259 
5260  appendStringInfo(&buffer, "%s on ",
5261  quote_identifier(NameStr(rule->rulename)));
5262  getRelationIdentity(&buffer, rule->ev_class, objname, false);
5263  if (objname)
5264  *objname = lappend(*objname, pstrdup(NameStr(rule->rulename)));
5265 
5266  table_close(ruleDesc, AccessShareLock);
5267  break;
5268  }
5269 
5270  case OCLASS_TRIGGER:
5271  {
5272  Relation trigDesc;
5273  HeapTuple tup;
5274  Form_pg_trigger trig;
5275 
5276  trigDesc = table_open(TriggerRelationId, AccessShareLock);
5277 
5278  tup = get_catalog_object_by_oid(trigDesc, Anum_pg_trigger_oid,
5279  object->objectId);
5280 
5281  if (!HeapTupleIsValid(tup))
5282  {
5283  if (!missing_ok)
5284  elog(ERROR, "could not find tuple for trigger %u",
5285  object->objectId);
5286 
5287  table_close(trigDesc, AccessShareLock);
5288  break;
5289  }
5290 
5291  trig = (Form_pg_trigger) GETSTRUCT(tup);
5292 
5293  appendStringInfo(&buffer, "%s on ",
5294  quote_identifier(NameStr(trig->tgname)));
5295  getRelationIdentity(&buffer, trig->tgrelid, objname, false);
5296  if (objname)
5297  *objname = lappend(*objname, pstrdup(NameStr(trig->tgname)));
5298 
5299  table_close(trigDesc, AccessShareLock);
5300  break;
5301  }
5302 
5303  case OCLASS_SCHEMA:
5304  {
5305  char *nspname;
5306 
5307  nspname = get_namespace_name_or_temp(object->objectId);
5308  if (!nspname)
5309  {
5310  if (!missing_ok)
5311  elog(ERROR, "cache lookup failed for namespace %u",
5312  object->objectId);
5313  break;
5314  }
5315  appendStringInfoString(&buffer,
5316  quote_identifier(nspname));
5317  if (objname)
5318  *objname = list_make1(nspname);
5319  break;
5320  }
5321 
5322  case OCLASS_STATISTIC_EXT:
5323  {
5324  HeapTuple tup;
5325  Form_pg_statistic_ext formStatistic;
5326  char *schema;
5327 
5328  tup = SearchSysCache1(STATEXTOID,
5329  ObjectIdGetDatum(object->objectId));
5330  if (!HeapTupleIsValid(tup))
5331  {
5332  if (!missing_ok)
5333  elog(ERROR, "cache lookup failed for statistics object %u",
5334  object->objectId);
5335  break;
5336  }
5337  formStatistic = (Form_pg_statistic_ext) GETSTRUCT(tup);
5338  schema = get_namespace_name_or_temp(formStatistic->stxnamespace);
5339  appendStringInfoString(&buffer,
5340  quote_qualified_identifier(schema,
5341  NameStr(formStatistic->stxname)));
5342  if (objname)
5343  *objname = list_make2(schema,
5344  pstrdup(NameStr(formStatistic->stxname)));
5345  ReleaseSysCache(tup);
5346  }
5347  break;
5348 
5349  case OCLASS_TSPARSER:
5350  {
5351  HeapTuple tup;
5352  Form_pg_ts_parser formParser;
5353  char *schema;
5354 
5355  tup = SearchSysCache1(TSPARSEROID,
5356  ObjectIdGetDatum(object->objectId));
5357  if (!HeapTupleIsValid(tup))
5358  {
5359  if (!missing_ok)
5360  elog(ERROR, "cache lookup failed for text search parser %u",
5361  object->objectId);
5362  break;
5363  }
5364  formParser = (Form_pg_ts_parser) GETSTRUCT(tup);
5365  schema = get_namespace_name_or_temp(formParser->prsnamespace);
5366  appendStringInfoString(&buffer,
5367  quote_qualified_identifier(schema,
5368  NameStr(formParser->prsname)));
5369  if (objname)
5370  *objname = list_make2(schema,
5371  pstrdup(NameStr(formParser->prsname)));
5372  ReleaseSysCache(tup);
5373  break;
5374  }
5375 
5376  case OCLASS_TSDICT:
5377  {
5378  HeapTuple tup;
5379  Form_pg_ts_dict formDict;
5380  char *schema;
5381 
5382  tup = SearchSysCache1(TSDICTOID,
5383  ObjectIdGetDatum(object->objectId));
5384  if (!HeapTupleIsValid(tup))
5385  {
5386  if (!missing_ok)
5387  elog(ERROR, "cache lookup failed for text search dictionary %u",
5388  object->objectId);
5389  break;
5390  }
5391  formDict = (Form_pg_ts_dict) GETSTRUCT(tup);
5392  schema = get_namespace_name_or_temp(formDict->dictnamespace);
5393  appendStringInfoString(&buffer,
5394  quote_qualified_identifier(schema,
5395  NameStr(formDict->dictname)));
5396  if (objname)
5397  *objname = list_make2(schema,
5398  pstrdup(NameStr(formDict->dictname)));
5399  ReleaseSysCache(tup);
5400  break;
5401  }
5402 
5403  case OCLASS_TSTEMPLATE:
5404  {
5405  HeapTuple tup;
5406  Form_pg_ts_template formTmpl;
5407  char *schema;
5408 
5409  tup = SearchSysCache1(TSTEMPLATEOID,
5410  ObjectIdGetDatum(object->objectId));
5411  if (!HeapTupleIsValid(tup))
5412  {
5413  if (!missing_ok)
5414  elog(ERROR, "cache lookup failed for text search template %u",
5415  object->objectId);
5416  break;
5417  }
5418  formTmpl = (Form_pg_ts_template) GETSTRUCT(tup);
5419  schema = get_namespace_name_or_temp(formTmpl->tmplnamespace);
5420  appendStringInfoString(&buffer,
5421  quote_qualified_identifier(schema,
5422  NameStr(formTmpl->tmplname)));
5423  if (objname)
5424  *objname = list_make2(schema,
5425  pstrdup(NameStr(formTmpl->tmplname)));
5426  ReleaseSysCache(tup);
5427  break;
5428  }
5429 
5430  case OCLASS_TSCONFIG:
5431  {
5432  HeapTuple tup;
5433  Form_pg_ts_config formCfg;
5434  char *schema;
5435 
5436  tup = SearchSysCache1(TSCONFIGOID,
5437  ObjectIdGetDatum(object->objectId));
5438  if (!HeapTupleIsValid(tup))
5439  {
5440  if (!missing_ok)
5441  elog(ERROR, "cache lookup failed for text search configuration %u",
5442  object->objectId);
5443  break;
5444  }
5445  formCfg = (Form_pg_ts_config) GETSTRUCT(tup);
5446  schema = get_namespace_name_or_temp(formCfg->cfgnamespace);
5447  appendStringInfoString(&buffer,
5448  quote_qualified_identifier(schema,
5449  NameStr(formCfg->cfgname)));
5450  if (objname)
5451  *objname = list_make2(schema,
5452  pstrdup(NameStr(formCfg->cfgname)));
5453  ReleaseSysCache(tup);
5454  break;
5455  }
5456 
5457  case OCLASS_ROLE:
5458  {
5459  char *username;
5460 
5461  username = GetUserNameFromId(object->objectId, missing_ok);
5462  if (!username)
5463  break;
5464  if (objname)
5465  *objname = list_make1(username);
5466  appendStringInfoString(&buffer,
5467  quote_identifier(username));
5468  break;
5469  }
5470 
5471  case OCLASS_ROLE_MEMBERSHIP:
5472  {
5473  Relation authMemDesc;
5474  ScanKeyData skey[1];
5475  SysScanDesc amscan;
5476  HeapTuple tup;
5477  Form_pg_auth_members amForm;
5478 
5479  authMemDesc = table_open(AuthMemRelationId,
5480  AccessShareLock);
5481 
5482  ScanKeyInit(&skey[0],
5483  Anum_pg_auth_members_oid,
5484  BTEqualStrategyNumber, F_OIDEQ,
5485  ObjectIdGetDatum(object->objectId));
5486 
5487  amscan = systable_beginscan(authMemDesc, AuthMemOidIndexId, true,
5488  NULL, 1, skey);
5489 
5490  tup = systable_getnext(amscan);
5491 
5492  if (!HeapTupleIsValid(tup))
5493  {
5494  if (!missing_ok)
5495  elog(ERROR, "could not find tuple for pg_auth_members entry %u",
5496  object->objectId);
5497 
5498  systable_endscan(amscan);
5499  table_close(authMemDesc, AccessShareLock);
5500  break;
5501  }
5502 
5503  amForm = (Form_pg_auth_members) GETSTRUCT(tup);
5504 
5505  appendStringInfo(&buffer, _("membership of role %s in role %s"),
5506  GetUserNameFromId(amForm->member, false),
5507  GetUserNameFromId(amForm->roleid, false));
5508 
5509  systable_endscan(amscan);
5510  table_close(authMemDesc, AccessShareLock);
5511  break;
5512  }
5513 
5514  case OCLASS_DATABASE:
5515  {
5516  char *datname;
5517 
5518  datname = get_database_name(object->objectId);
5519  if (!datname)
5520  {
5521  if (!missing_ok)
5522  elog(ERROR, "cache lookup failed for database %u",
5523  object->objectId);
5524  break;
5525  }
5526  if (objname)
5527  *objname = list_make1(datname);
5528  appendStringInfoString(&buffer,
5529  quote_identifier(datname));
5530  break;
5531  }
5532 
5533  case OCLASS_TBLSPACE:
5534  {
5535  char *tblspace;
5536 
5537  tblspace = get_tablespace_name(object->objectId);
5538  if (!tblspace)
5539  {
5540  if (!missing_ok)
5541  elog(ERROR, "cache lookup failed for tablespace %u",
5542  object->objectId);
5543  break;
5544  }
5545  if (objname)
5546  *objname = list_make1(tblspace);
5547  appendStringInfoString(&buffer,
5548  quote_identifier(tblspace));
5549  break;
5550  }
5551 
5552  case OCLASS_FDW:
5553  {
5554  ForeignDataWrapper *fdw;
5555 
5556  fdw = GetForeignDataWrapperExtended(object->objectId,
5557  missing_ok);
5558  if (fdw)
5559  {
5560  appendStringInfoString(&buffer, quote_identifier(fdw->fdwname));
5561  if (objname)
5562  *objname = list_make1(pstrdup(fdw->fdwname));
5563  }
5564  break;
5565  }
5566 
5567  case OCLASS_FOREIGN_SERVER:
5568  {
5569  ForeignServer *srv;
5570 
5571  srv = GetForeignServerExtended(object->objectId,
5572  missing_ok);
5573  if (srv)
5574  {
5575  appendStringInfoString(&buffer,
5576  quote_identifier(srv->servername));
5577  if (objname)
5578  *objname = list_make1(pstrdup(srv->servername));
5579  }
5580  break;
5581  }
5582 
5583  case OCLASS_USER_MAPPING:
5584  {
5585  HeapTuple tup;
5586  Oid useid;
5587  Form_pg_user_mapping umform;
5588  ForeignServer *srv;
5589  const char *usename;
5590 
5591  tup = SearchSysCache1(USERMAPPINGOID,
5592  ObjectIdGetDatum(object->objectId));
5593  if (!HeapTupleIsValid(tup))
5594  {
5595  if (!missing_ok)
5596  elog(ERROR, "cache lookup failed for user mapping %u",
5597  object->objectId);
5598  break;
5599  }
5600  umform = (Form_pg_user_mapping) GETSTRUCT(tup);
5601  useid = umform->umuser;
5602  srv = GetForeignServer(umform->umserver);
5603 
5604  ReleaseSysCache(tup);
5605 
5606  if (OidIsValid(useid))
5607  usename = GetUserNameFromId(useid, false);
5608  else
5609  usename = "public";
5610 
5611  if (objname)
5612  {
5613  *objname = list_make1(pstrdup(usename));
5614  *objargs = list_make1(pstrdup(srv->servername));
5615  }
5616 
5617  appendStringInfo(&buffer, "%s on server %s",
5618  quote_identifier(usename),
5619  srv->servername);
5620  break;
5621  }
5622 
5623  case OCLASS_DEFACL:
5624  {
5625  Relation defaclrel;
5626  ScanKeyData skey[1];
5627  SysScanDesc rcscan;
5628  HeapTuple tup;
5629  Form_pg_default_acl defacl;
5630  char *schema;
5631  char *username;
5632 
5633  defaclrel = table_open(DefaultAclRelationId, AccessShareLock);
5634 
5635  ScanKeyInit(&skey[0],
5636  Anum_pg_default_acl_oid,
5637  BTEqualStrategyNumber, F_OIDEQ,
5638  ObjectIdGetDatum(object->objectId));
5639 
5640  rcscan = systable_beginscan(defaclrel, DefaultAclOidIndexId,
5641  true, NULL, 1, skey);
5642 
5643  tup = systable_getnext(rcscan);
5644 
5645  if (!HeapTupleIsValid(tup))
5646  {
5647  if (!missing_ok)
5648  elog(ERROR, "could not find tuple for default ACL %u",
5649  object->objectId);
5650 
5651  systable_endscan(rcscan);
5652  table_close(defaclrel, AccessShareLock);
5653  break;
5654  }
5655 
5656  defacl = (Form_pg_default_acl) GETSTRUCT(tup);
5657 
5658  username = GetUserNameFromId(defacl->defaclrole, false);
5659  appendStringInfo(&buffer,
5660  "for role %s",
5661  quote_identifier(username));
5662 
5663  if (OidIsValid(defacl->defaclnamespace))
5664  {
5665  schema = get_namespace_name_or_temp(defacl->defaclnamespace);
5666  appendStringInfo(&buffer,
5667  " in schema %s",
5668  quote_identifier(schema));
5669  }
5670  else
5671  schema = NULL;
5672 
5673  switch (defacl->defaclobjtype)
5674  {
5675  case DEFACLOBJ_RELATION:
5676  appendStringInfoString(&buffer,
5677  " on tables");
5678  break;
5679  case DEFACLOBJ_SEQUENCE:
5680  appendStringInfoString(&buffer,
5681  " on sequences");
5682  break;
5683  case DEFACLOBJ_FUNCTION:
5684  appendStringInfoString(&buffer,
5685  " on functions");
5686  break;
5687  case DEFACLOBJ_TYPE:
5688  appendStringInfoString(&buffer,
5689  " on types");
5690  break;
5691  case DEFACLOBJ_NAMESPACE:
5692  appendStringInfoString(&buffer,
5693  " on schemas");
5694  break;
5695  }
5696 
5697  if (objname)
5698  {
5699  *objname = list_make1(username);
5700  if (schema)
5701  *objname = lappend(*objname, schema);
5702  *objargs = list_make1(psprintf("%c", defacl->defaclobjtype));
5703  }
5704 
5705  systable_endscan(rcscan);
5706  table_close(defaclrel, AccessShareLock);
5707  break;
5708  }
5709 
5710  case OCLASS_EXTENSION:
5711  {
5712  char *extname;
5713 
5714  extname = get_extension_name(object->objectId);
5715  if (!extname)
5716  {
5717  if (!missing_ok)
5718  elog(ERROR, "cache lookup failed for extension %u",
5719  object->objectId);
5720  break;
5721  }
5722  appendStringInfoString(&buffer, quote_identifier(extname));
5723  if (objname)
5724  *objname = list_make1(extname);
5725  break;
5726  }
5727 
5728  case OCLASS_EVENT_TRIGGER:
5729  {
5730  HeapTuple tup;
5731  Form_pg_event_trigger trigForm;
5732  char *evtname;
5733 
5734  tup = SearchSysCache1(EVENTTRIGGEROID,
5735  ObjectIdGetDatum(object->objectId));
5736  if (!HeapTupleIsValid(tup))
5737  {
5738  if (!missing_ok)
5739  elog(ERROR, "cache lookup failed for event trigger %u",
5740  object->objectId);
5741  break;
5742  }
5743  trigForm = (Form_pg_event_trigger) GETSTRUCT(tup);
5744  evtname = pstrdup(NameStr(trigForm->evtname));
5745  appendStringInfoString(&buffer, quote_identifier(evtname));
5746  if (objname)
5747  *objname = list_make1(evtname);
5748  ReleaseSysCache(tup);
5749  break;
5750  }
5751 
5752  case OCLASS_PARAMETER_ACL:
5753  {
5754  HeapTuple tup;
5755  Datum nameDatum;
5756  char *parname;
5757 
5758  tup = SearchSysCache1(PARAMETERACLOID,
5759  ObjectIdGetDatum(object->objectId));
5760  if (!HeapTupleIsValid(tup))
5761  {
5762  if (!missing_ok)
5763  elog(ERROR, "cache lookup failed for parameter ACL %u",
5764  object->objectId);
5765  break;
5766  }
5767  nameDatum = SysCacheGetAttrNotNull(PARAMETERACLOID, tup,
5768  Anum_pg_parameter_acl_parname);
5769  parname = TextDatumGetCString(nameDatum);
5770  appendStringInfoString(&buffer, parname);
5771  if (objname)
5772  *objname = list_make1(parname);
5773  ReleaseSysCache(tup);
5774  break;
5775  }
5776 
5777  case OCLASS_POLICY:
5778  {
5779  Relation polDesc;
5780  HeapTuple tup;
5781  Form_pg_policy policy;
5782 
5783  polDesc = table_open(PolicyRelationId, AccessShareLock);
5784 
5785  tup = get_catalog_object_by_oid(polDesc, Anum_pg_policy_oid,
5786  object->objectId);
5787 
5788  if (!HeapTupleIsValid(tup))
5789  {
5790  if (!missing_ok)
5791  elog(ERROR, "could not find tuple for policy %u",
5792  object->objectId);
5793 
5794  table_close(polDesc, AccessShareLock);
5795  break;
5796  }
5797 
5798  policy = (Form_pg_policy) GETSTRUCT(tup);
5799 
5800  appendStringInfo(&buffer, "%s on ",
5801  quote_identifier(NameStr(policy->polname)));
5802  getRelationIdentity(&buffer, policy->polrelid, objname, false);
5803  if (objname)
5804  *objname = lappend(*objname, pstrdup(NameStr(policy->polname)));
5805 
5806  table_close(polDesc, AccessShareLock);
5807  break;
5808  }
5809 
5810  case OCLASS_PUBLICATION:
5811  {
5812  char *pubname;
5813 
5814  pubname = get_publication_name(object->objectId, missing_ok);
5815  if (pubname)
5816  {
5817  appendStringInfoString(&buffer,
5818  quote_identifier(pubname));
5819  if (objname)
5820  *objname = list_make1(pubname);
5821  }
5822  break;
5823  }
5824 
5825  case OCLASS_PUBLICATION_NAMESPACE:
5826  {
5827  char *pubname;
5828  char *nspname;
5829 
5830  if (!getPublicationSchemaInfo(object, missing_ok, &pubname,
5831  &nspname))
5832  break;
5833  appendStringInfo(&buffer, "%s in publication %s",
5834  nspname, pubname);
5835 
5836  if (objargs)
5837  *objargs = list_make1(pubname);
5838  else
5839  pfree(pubname);
5840 
5841  if (objname)
5842  *objname = list_make1(nspname);
5843  else
5844  pfree(nspname);
5845 
5846  break;
5847  }
5848 
5849  case OCLASS_PUBLICATION_REL:
5850  {
5851  HeapTuple tup;
5852  char *pubname;
5853  Form_pg_publication_rel prform;
5854 
5855  tup = SearchSysCache1(PUBLICATIONREL,
5856  ObjectIdGetDatum(object->objectId));
5857  if (!HeapTupleIsValid(tup))
5858  {
5859  if (!missing_ok)
5860  elog(ERROR, "cache lookup failed for publication table %u",
5861  object->objectId);
5862  break;
5863  }
5864 
5865  prform = (Form_pg_publication_rel) GETSTRUCT(tup);
5866  pubname = get_publication_name(prform->prpubid, false);
5867 
5868  getRelationIdentity(&buffer, prform->prrelid, objname, false);
5869  appendStringInfo(&buffer, " in publication %s", pubname);
5870 
5871  if (objargs)
5872  *objargs = list_make1(pubname);
5873 
5874  ReleaseSysCache(tup);
5875  break;
5876  }
5877 
5878  case OCLASS_SUBSCRIPTION:
5879  {
5880  char *subname;
5881 
5882  subname = get_subscription_name(object->objectId, missing_ok);
5883  if (subname)
5884  {
5885  appendStringInfoString(&buffer,
5886  quote_identifier(subname));
5887  if (objname)
5888  *objname = list_make1(subname);
5889  }
5890  break;
5891  }
5892 
5893  case OCLASS_TRANSFORM:
5894  {
5895  Relation transformDesc;
5896  HeapTuple tup;
5897  Form_pg_transform transform;
5898  char *transformLang;
5899  char *transformType;
5900 
5901  transformDesc = table_open(TransformRelationId, AccessShareLock);
5902 
5903  tup = get_catalog_object_by_oid(transformDesc,
5904  Anum_pg_transform_oid,
5905  object->objectId);
5906 
5907  if (!HeapTupleIsValid(tup))
5908  {
5909  if (!missing_ok)
5910  elog(ERROR, "could not find tuple for transform %u",
5911  object->objectId);
5912 
5913  table_close(transformDesc, AccessShareLock);
5914  break;
5915  }
5916 
5917  transform = (Form_pg_transform) GETSTRUCT(tup);
5918 
5919  transformType = format_type_be_qualified(transform->trftype);
5920  transformLang = get_language_name(transform->trflang, false);
5921 
5922  appendStringInfo(&buffer, "for %s language %s",
5923  transformType,
5924  transformLang);
5925  if (objname)
5926  {
5927  *objname = list_make1(transformType);
5928  *objargs = list_make1(pstrdup(transformLang));
5929  }
5930 
5931  table_close(transformDesc, AccessShareLock);
5932  }
5933  break;
5934 
5935  /*
5936  * There's intentionally no default: case here; we want the
5937  * compiler to warn if a new OCLASS hasn't been handled above.
5938  */
5939  }
5940 
5941  if (!missing_ok)
5942  {
5943  /*
5944  * If a get_object_address() representation was requested, make sure
5945  * we are providing one. We don't check objargs, because many of the
5946  * cases above leave it as NIL.
5947  */
5948  if (objname && *objname == NIL)
5949  elog(ERROR, "requested object address for unsupported object class %d: text result \"%s\"",
5950  (int) getObjectClass(object), buffer.data);
5951  }
5952  else
5953  {
5954  /* an empty buffer is equivalent to no object found */
5955  if (buffer.len == 0)
5956  {
5957  Assert((objname == NULL || *objname == NIL) &&
5958  (objargs == NULL || *objargs == NIL));
5959  return NULL;
5960  }
5961  }
5962 
5963  return buffer.data;
5964 }
get_am_name
char * get_am_name(Oid amOid)
Definition: amcmds.c:192
FORMAT_TYPE_FORCE_QUALIFY
#define FORMAT_TYPE_FORCE_QUALIFY
Definition: builtins.h:123
PointerIsValid
#define PointerIsValid(pointer)
Definition: c.h:747
format_type_be_qualified
char * format_type_be_qualified(Oid type_oid)
Definition: format_type.c:349
lappend
List * lappend(List *list, void *datum)
Definition: list.c:338
get_namespace_name_or_temp
char * get_namespace_name_or_temp(Oid nspid)
Definition: lsyscache.c:3348
pstrdup
char * pstrdup(const char *in)
Definition: mcxt.c:1644
get_catalog_object_by_oid
HeapTuple get_catalog_object_by_oid(Relation catalog, AttrNumber oidcol, Oid objectId)
Definition: objectaddress.c:2819
getOpFamilyIdentity
static void getOpFamilyIdentity(StringInfo buffer, Oid opfid, List **object, bool missing_ok)
Definition: objectaddress.c:5967
getRelationIdentity
static void getRelationIdentity(StringInfo buffer, Oid relid, List **object, bool missing_ok)
Definition: objectaddress.c:6011
Form_pg_language
FormData_pg_language * Form_pg_language
Definition: pg_language.h:65
NIL
#define NIL
Definition: pg_list.h:68
list_make1
#define list_make1(x1)
Definition: pg_list.h:212
list_make3
#define list_make3(x1, x2, x3)
Definition: pg_list.h:216
list_make2
#define list_make2(x1, x2)
Definition: pg_list.h:214
psprintf
char * psprintf(const char *fmt,...)
Definition: psprintf.c:46
format_operator_parts
void format_operator_parts(Oid operator_oid, List **objnames, List **objargs, bool missing_ok)
Definition: regproc.c:806
format_procedure_parts
void format_procedure_parts(Oid procedure_oid, List **objnames, List **objargs, bool missing_ok)
Definition: regproc.c:398
FORMAT_OPERATOR_FORCE_QUALIFY
#define FORMAT_OPERATOR_FORCE_QUALIFY
Definition: regproc.h:25
FORMAT_PROC_FORCE_QUALIFY
#define FORMAT_PROC_FORCE_QUALIFY
Definition: regproc.h:20
quote_identifier
const char * quote_identifier(const char *ident)
Definition: ruleutils.c:11930
appendStringInfoString
void appendStringInfoString(StringInfo str, const char *s)
Definition: stringinfo.c:176
LANGOID
@ LANGOID
Definition: syscache.h:68

References _, AccessShareLock, AMOID, appendStringInfo(), appendStringInfoString(), Assert(), BTEqualStrategyNumber, CLAOID, ObjectAddress::classId, COLLOID, CONSTROID, CONVOID, StringInfoData::data, datname, elog(), ERROR, EVENTTRIGGEROID, ForeignDataWrapper::fdwname, format_operator_extended(), FORMAT_OPERATOR_FORCE_QUALIFY, FORMAT_OPERATOR_INVALID_AS_NULL, format_operator_parts(), FORMAT_PROC_FORCE_QUALIFY, FORMAT_PROC_INVALID_AS_NULL, format_procedure_extended(), format_procedure_parts(), format_type_be_qualified(), format_type_extended(), FORMAT_TYPE_FORCE_QUALIFY, FORMAT_TYPE_INVALID_AS_NULL, get_am_name(), get_attname(), get_catalog_object_by_oid(), get_database_name(), get_extension_name(), get_language_name(), get_namespace_name_or_temp(), get_publication_name(), get_subscription_name(), get_tablespace_name(), GetAttrDefaultColumnAddress(), GetForeignDataWrapperExtended(), GetForeignServer(), GetForeignServerExtended(), getObjectClass(), getOpFamilyIdentity(), getPublicationSchemaInfo(), getRelationIdentity(), GETSTRUCT, GetUserNameFromId(), HeapTupleIsValid, initStringInfo(), LANGOID, lappend(), LargeObjectExists(), StringInfoData::len, list_make1, list_make2, list_make3, NameStr, NIL, 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, PARAMETERACLOID, pfree(), PointerIsValid, proname, psprintf(), pstrdup(), PUBLICATIONREL, quote_identifier(), quote_qualified_identifier(), ReleaseSysCache(), ScanKeyInit(), SearchSysCache1(), ForeignServer::servername, STATEXTOID, subname, SysCacheGetAttrNotNull(), systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), table_open(), TextDatumGetCString, TSCONFIGOID, TSDICTOID, TSPARSEROID, TSTEMPLATEOID, USERMAPPINGOID, and username.

Referenced by EventTriggerSQLDropAddObject(), getObjectIdentity(), and pg_identify_object_as_address().

◆ getObjectTypeDescription()

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

Definition at line 4412 of file objectaddress.c.

4413 {
4414  StringInfoData buffer;
4415 
4416  initStringInfo(&buffer);
4417 
4418  switch (getObjectClass(object))
4419  {
4420  case OCLASS_CLASS:
4421  getRelationTypeDescription(&buffer, object->objectId,
4422  object->objectSubId,
4423  missing_ok);
4424  break;
4425 
4426  case OCLASS_PROC:
4427  getProcedureTypeDescription(&buffer, object->objectId,
4428  missing_ok);
4429  break;
4430 
4431  case OCLASS_TYPE:
4432  appendStringInfoString(&buffer, "type");
4433  break;
4434 
4435  case OCLASS_CAST:
4436  appendStringInfoString(&buffer, "cast");
4437  break;
4438 
4439  case OCLASS_COLLATION:
4440  appendStringInfoString(&buffer, "collation");
4441  break;
4442 
4443  case OCLASS_CONSTRAINT:
4444  getConstraintTypeDescription(&buffer, object->objectId,
4445  missing_ok);
4446  break;
4447 
4448  case OCLASS_CONVERSION:
4449  appendStringInfoString(&buffer, "conversion");
4450  break;
4451 
4452  case OCLASS_DEFAULT:
4453  appendStringInfoString(&buffer, "default value");
4454  break;
4455 
4456  case OCLASS_LANGUAGE:
4457  appendStringInfoString(&buffer, "language");
4458  break;
4459 
4460  case OCLASS_LARGEOBJECT:
4461  appendStringInfoString(&buffer, "large object");
4462  break;
4463 
4464  case OCLASS_OPERATOR:
4465  appendStringInfoString(&buffer, "operator");
4466  break;
4467 
4468  case OCLASS_OPCLASS:
4469  appendStringInfoString(&buffer, "operator class");
4470  break;
4471 
4472  case OCLASS_OPFAMILY:
4473  appendStringInfoString(&buffer, "operator family");
4474  break;
4475 
4476  case OCLASS_AM:
4477  appendStringInfoString(&buffer, "access method");
4478  break;
4479 
4480  case OCLASS_AMOP:
4481  appendStringInfoString(&buffer, "operator of access method");
4482  break;
4483 
4484  case OCLASS_AMPROC:
4485  appendStringInfoString(&buffer, "function of access method");
4486  break;
4487 
4488  case OCLASS_REWRITE:
4489  appendStringInfoString(&buffer, "rule");
4490  break;
4491 
4492  case OCLASS_TRIGGER:
4493  appendStringInfoString(&buffer, "trigger");
4494  break;
4495 
4496  case OCLASS_SCHEMA:
4497  appendStringInfoString(&buffer, "schema");
4498  break;
4499 
4500  case OCLASS_STATISTIC_EXT:
4501  appendStringInfoString(&buffer, "statistics object");
4502  break;
4503 
4504  case OCLASS_TSPARSER:
4505  appendStringInfoString(&buffer, "text search parser");
4506  break;
4507 
4508  case OCLASS_TSDICT:
4509  appendStringInfoString(&buffer, "text search dictionary");
4510  break;
4511 
4512  case OCLASS_TSTEMPLATE:
4513  appendStringInfoString(&buffer, "text search template");
4514  break;
4515 
4516  case OCLASS_TSCONFIG:
4517  appendStringInfoString(&buffer, "text search configuration");
4518  break;
4519 
4520  case OCLASS_ROLE:
4521  appendStringInfoString(&buffer, "role");
4522  break;
4523 
4524  case OCLASS_ROLE_MEMBERSHIP:
4525  appendStringInfoString(&buffer, "role membership");
4526  break;
4527 
4528  case OCLASS_DATABASE:
4529  appendStringInfoString(&buffer, "database");
4530  break;
4531 
4532  case OCLASS_TBLSPACE:
4533  appendStringInfoString(&buffer, "tablespace");
4534  break;
4535 
4536  case OCLASS_FDW:
4537  appendStringInfoString(&buffer, "foreign-data wrapper");
4538  break;
4539 
4540  case OCLASS_FOREIGN_SERVER:
4541  appendStringInfoString(&buffer, "server");
4542  break;
4543 
4544  case OCLASS_USER_MAPPING:
4545  appendStringInfoString(&buffer, "user mapping");
4546  break;
4547 
4548  case OCLASS_DEFACL:
4549  appendStringInfoString(&buffer, "default acl");
4550  break;
4551 
4552  case OCLASS_EXTENSION:
4553  appendStringInfoString(&buffer, "extension");
4554  break;
4555 
4556  case OCLASS_EVENT_TRIGGER:
4557  appendStringInfoString(&buffer, "event trigger");
4558  break;
4559 
4560  case OCLASS_PARAMETER_ACL:
4561  appendStringInfoString(&buffer, "parameter ACL");
4562  break;
4563 
4564  case OCLASS_POLICY:
4565  appendStringInfoString(&buffer, "policy");
4566  break;
4567 
4568  case OCLASS_PUBLICATION:
4569  appendStringInfoString(&buffer, "publication");
4570  break;
4571 
4572  case OCLASS_PUBLICATION_NAMESPACE:
4573  appendStringInfoString(&buffer, "publication namespace");
4574  break;
4575 
4576  case OCLASS_PUBLICATION_REL:
4577  appendStringInfoString(&buffer, "publication relation");
4578  break;
4579 
4580  case OCLASS_SUBSCRIPTION:
4581  appendStringInfoString(&buffer, "subscription");
4582  break;
4583 
4584  case OCLASS_TRANSFORM:
4585  appendStringInfoString(&buffer, "transform");
4586  break;
4587 
4588  /*
4589  * There's intentionally no default: case here; we want the
4590  * compiler to warn if a new OCLASS hasn't been handled above.
4591  */
4592  }
4593 
4594  /* the result can never be empty */
4595  Assert(buffer.len > 0);
4596 
4597  return buffer.data;
4598 }
getConstraintTypeDescription
static void getConstraintTypeDescription(StringInfo buffer, Oid constroid, bool missing_ok)
Definition: objectaddress.c:4667
getProcedureTypeDescription
static void getProcedureTypeDescription(StringInfo buffer, Oid procid, bool missing_ok)
Definition: objectaddress.c:4704
getRelationTypeDescription
static void getRelationTypeDescription(StringInfo buffer, Oid relid, int32 objectSubId, bool missing_ok)
Definition: objectaddress.c:4604

References appendStringInfoString(), Assert(), StringInfoData::data, getConstraintTypeDescription(), getObjectClass(), getProcedureTypeDescription(), getRelationTypeDescription(), initStringInfo(), StringInfoData::len, ObjectAddress::objectId, 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, and OCLASS_USER_MAPPING.

Referenced by EventTriggerSQLDropAddObject(), pg_event_trigger_ddl_commands(), pg_identify_object(), pg_identify_object_as_address(), and sepgsql_object_relabel().

◆ is_objectclass_supported()

bool is_objectclass_supported ( Oid  class_id)

Definition at line 2767 of file objectaddress.c.

2768 {
2769  int index;
2770 
2771  for (index = 0; index < lengthof(ObjectProperty); index++)
2772  {
2773  if (ObjectProperty[index].class_oid == class_id)
2774  return true;
2775  }
2776 
2777  return false;
2778 }
lengthof
#define lengthof(array)
Definition: c.h:772
ObjectProperty
static const ObjectPropertyType ObjectProperty[]
Definition: objectaddress.c:122
index
Definition: type.h:95

References lengthof, and ObjectProperty.

Referenced by EventTriggerSQLDropAddObject(), pg_event_trigger_ddl_commands(), and pg_identify_object().

◆ read_objtype_from_string()

int read_objtype_from_string ( const char *  objtype)

Definition at line 2638 of file objectaddress.c.

2639 {
2640  int i;
2641 
2642  for (i = 0; i < lengthof(ObjectTypeMap); i++)
2643  {
2644  if (strcmp(ObjectTypeMap[i].tm_name, objtype) == 0)
2645  return ObjectTypeMap[i].tm_type;
2646  }
2647  ereport(ERROR,
2648  (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2649  errmsg("unrecognized object type \"%s\"", objtype)));
2650 
2651  return -1; /* keep compiler quiet */
2652 }
i
int i
Definition: isn.c:73
ObjectTypeMap
static const struct object_type_map ObjectTypeMap[]

References ereport, errcode(), errmsg(), ERROR, i, lengthof, and ObjectTypeMap.

Referenced by pg_get_object_address().

◆ strlist_to_textarray()

struct ArrayType* strlist_to_textarray ( List *  list)

Definition at line 6045 of file objectaddress.c.

6046 {
6047  ArrayType *arr;
6048  Datum *datums;
6049  bool *nulls;
6050  int j = 0;
6051  ListCell *cell;
6052  MemoryContext memcxt;
6053  MemoryContext oldcxt;
6054  int lb[1];
6055 
6056  /* Work in a temp context; easier than individually pfree'ing the Datums */
6057  memcxt = AllocSetContextCreate(CurrentMemoryContext,
6058  "strlist to array",
6059  ALLOCSET_DEFAULT_SIZES);
6060  oldcxt = MemoryContextSwitchTo(memcxt);
6061 
6062  datums = (Datum *) palloc(sizeof(Datum) * list_length(list));
6063  nulls = palloc(sizeof(bool) * list_length(list));
6064 
6065  foreach(cell, list)
6066  {
6067  char *name = lfirst(cell);
6068 
6069  if (name)
6070  {
6071  nulls[j] = false;
6072  datums[j++] = CStringGetTextDatum(name);
6073  }
6074  else
6075  nulls[j] = true;
6076  }
6077 
6078  MemoryContextSwitchTo(oldcxt);
6079 
6080  lb[0] = 1;
6081  arr = construct_md_array(datums, nulls, 1, &j,
6082  lb, TEXTOID, -1, false, TYPALIGN_INT);
6083 
6084  MemoryContextDelete(memcxt);
6085 
6086  return arr;
6087 }
construct_md_array
ArrayType * construct_md_array(Datum *elems, bool *nulls, int ndims, int *dims, int *lbs, Oid elmtype, int elmlen, bool elmbyval, char elmalign)
Definition: arrayfuncs.c:3462
CStringGetTextDatum
#define CStringGetTextDatum(s)
Definition: builtins.h:94
name
const char * name
Definition: encode.c:571
j
int j
Definition: isn.c:74
CurrentMemoryContext
MemoryContext CurrentMemoryContext
Definition: mcxt.c:135
MemoryContextDelete
void MemoryContextDelete(MemoryContext context)
Definition: mcxt.c:403
palloc
void * palloc(Size size)
Definition: mcxt.c:1226
AllocSetContextCreate
#define AllocSetContextCreate
Definition: memutils.h:129
ALLOCSET_DEFAULT_SIZES
#define ALLOCSET_DEFAULT_SIZES
Definition: memutils.h:153
MemoryContextSwitchTo
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Definition: palloc.h:138
lfirst
#define lfirst(lc)
Definition: pg_list.h:172
list_length
static int list_length(const List *l)
Definition: pg_list.h:152

References ALLOCSET_DEFAULT_SIZES, AllocSetContextCreate, construct_md_array(), CStringGetTextDatum, CurrentMemoryContext, j, lfirst, sort-test::list, list_length(), MemoryContextDelete(), MemoryContextSwitchTo(), name, and palloc().

Referenced by fill_hba_line(), pg_event_trigger_dropped_objects(), and pg_identify_object_as_address().

Variable Documentation

◆ InvalidObjectAddress

PGDLLIMPORT const ObjectAddress InvalidObjectAddress
extern

Definition at line 875 of file objectaddress.c.

Referenced by AlterDomainNotNull(), AlterExtensionNamespace(), AlterPublicationOptions(), AlterSequence(), AlterStatistics(), AlterTableNamespace(), ATAddCheckConstraint(), ATExecAddColumn(), ATExecAddConstraint(), ATExecAlterColumnGenericOptions(), ATExecAlterConstraint(), ATExecCmd(), ATExecDropColumn(), ATExecDropExpression(), ATExecDropIdentity(), ATExecDropNotNull(), ATExecSetIdentity(), ATExecSetNotNull(), ATExecValidateConstraint(), CommentObject(), CreateExtension(), CreateForeignServer(), CreateOpFamily(), CreateSchemaCommand(), CreateStatistics(), CreateUserMapping(), DefineCollation(), DefineSequence(), ExecAlterExtensionStmt(), ExecAlterObjectSchemaStmt(), ExecAlterOwnerStmt(), ExecCreateTableAs(), ExecRenameStmt(), GetAttrDefaultColumnAddress(), ProcessUtilitySlow(), publication_add_relation(), publication_add_schema(), PublicationAddSchemas(), PublicationAddTables(), renameatt(), RenameConstraint(), and RenameRelation().