85 #include "utils/fmgroids.h"
123 AccessMethodRelationId,
136 "access method operator",
137 AccessMethodOperatorRelationId,
138 AccessMethodOperatorOidIndexId,
150 "access method procedure",
151 AccessMethodProcedureRelationId,
152 AccessMethodProcedureOidIndexId,
183 Anum_pg_collation_oid,
184 Anum_pg_collation_collname,
185 Anum_pg_collation_collnamespace,
186 Anum_pg_collation_collowner,
193 ConstraintRelationId,
194 ConstraintOidIndexId,
197 Anum_pg_constraint_oid,
198 Anum_pg_constraint_conname,
199 Anum_pg_constraint_connamespace,
207 ConversionRelationId,
208 ConversionOidIndexId,
211 Anum_pg_conversion_oid,
212 Anum_pg_conversion_conname,
213 Anum_pg_conversion_connamespace,
214 Anum_pg_conversion_conowner,
225 Anum_pg_database_oid,
226 Anum_pg_database_datname,
228 Anum_pg_database_datdba,
229 Anum_pg_database_datacl,
235 DefaultAclRelationId,
236 DefaultAclOidIndexId,
239 Anum_pg_default_acl_oid,
253 Anum_pg_extension_oid,
254 Anum_pg_extension_extname,
256 Anum_pg_extension_extowner,
262 "foreign-data wrapper",
263 ForeignDataWrapperRelationId,
264 ForeignDataWrapperOidIndexId,
265 FOREIGNDATAWRAPPEROID,
266 FOREIGNDATAWRAPPERNAME,
267 Anum_pg_foreign_data_wrapper_oid,
268 Anum_pg_foreign_data_wrapper_fdwname,
270 Anum_pg_foreign_data_wrapper_fdwowner,
271 Anum_pg_foreign_data_wrapper_fdwacl,
277 ForeignServerRelationId,
278 ForeignServerOidIndexId,
281 Anum_pg_foreign_server_oid,
282 Anum_pg_foreign_server_srvname,
284 Anum_pg_foreign_server_srvowner,
285 Anum_pg_foreign_server_srvacl,
296 Anum_pg_proc_proname,
297 Anum_pg_proc_pronamespace,
298 Anum_pg_proc_proowner,
309 Anum_pg_language_oid,
310 Anum_pg_language_lanname,
312 Anum_pg_language_lanowner,
313 Anum_pg_language_lanacl,
318 "large object metadata",
319 LargeObjectMetadataRelationId,
320 LargeObjectMetadataOidIndexId,
323 Anum_pg_largeobject_metadata_oid,
326 Anum_pg_largeobject_metadata_lomowner,
327 Anum_pg_largeobject_metadata_lomacl,
333 OperatorClassRelationId,
338 Anum_pg_opclass_opcname,
339 Anum_pg_opclass_opcnamespace,
340 Anum_pg_opclass_opcowner,
351 Anum_pg_operator_oid,
352 Anum_pg_operator_oprname,
353 Anum_pg_operator_oprnamespace,
354 Anum_pg_operator_oprowner,
361 OperatorFamilyRelationId,
365 Anum_pg_opfamily_oid,
366 Anum_pg_opfamily_opfname,
367 Anum_pg_opfamily_opfnamespace,
368 Anum_pg_opfamily_opfowner,
380 Anum_pg_authid_rolname,
393 Anum_pg_auth_members_oid,
396 Anum_pg_auth_members_grantor,
408 Anum_pg_rewrite_rulename,
421 Anum_pg_namespace_oid,
422 Anum_pg_namespace_nspname,
424 Anum_pg_namespace_nspowner,
425 Anum_pg_namespace_nspacl,
436 Anum_pg_class_relname,
437 Anum_pg_class_relnamespace,
438 Anum_pg_class_relowner,
439 Anum_pg_class_relacl,
445 TableSpaceRelationId,
446 TablespaceOidIndexId,
449 Anum_pg_tablespace_oid,
450 Anum_pg_tablespace_spcname,
452 Anum_pg_tablespace_spcowner,
453 Anum_pg_tablespace_spcacl,
463 Anum_pg_transform_oid,
478 Anum_pg_trigger_tgname,
492 Anum_pg_policy_polname,
501 EventTriggerRelationId,
502 EventTriggerOidIndexId,
505 Anum_pg_event_trigger_oid,
506 Anum_pg_event_trigger_evtname,
508 Anum_pg_event_trigger_evtowner,
514 "text search configuration",
519 Anum_pg_ts_config_oid,
520 Anum_pg_ts_config_cfgname,
521 Anum_pg_ts_config_cfgnamespace,
522 Anum_pg_ts_config_cfgowner,
528 "text search dictionary",
529 TSDictionaryRelationId,
530 TSDictionaryOidIndexId,
534 Anum_pg_ts_dict_dictname,
535 Anum_pg_ts_dict_dictnamespace,
536 Anum_pg_ts_dict_dictowner,
542 "text search parser",
547 Anum_pg_ts_parser_oid,
548 Anum_pg_ts_parser_prsname,
549 Anum_pg_ts_parser_prsnamespace,
556 "text search template",
557 TSTemplateRelationId,
558 TSTemplateOidIndexId,
561 Anum_pg_ts_template_oid,
562 Anum_pg_ts_template_tmplname,
563 Anum_pg_ts_template_tmplnamespace,
576 Anum_pg_type_typname,
577 Anum_pg_type_typnamespace,
578 Anum_pg_type_typowner,
585 PublicationRelationId,
586 PublicationObjectIndexId,
589 Anum_pg_publication_oid,
590 Anum_pg_publication_pubname,
592 Anum_pg_publication_pubowner,
599 SubscriptionRelationId,
600 SubscriptionObjectIndexId,
603 Anum_pg_subscription_oid,
604 Anum_pg_subscription_subname,
606 Anum_pg_subscription_subowner,
612 "extended statistics",
613 StatisticExtRelationId,
614 StatisticExtOidIndexId,
617 Anum_pg_statistic_ext_oid,
618 Anum_pg_statistic_ext_stxname,
619 Anum_pg_statistic_ext_stxnamespace,
620 Anum_pg_statistic_ext_stxowner,
627 UserMappingRelationId,
628 UserMappingOidIndexId,
631 Anum_pg_user_mapping_oid,
690 "sequence column", -1
693 "toast table column", -1
699 "materialized view column", -1
702 "composite type column", -1
810 "role membership", -1
886 String *strval,
bool missing_ok);
889 LOCKMODE lockmode,
bool missing_ok);
894 LOCKMODE lockmode,
bool missing_ok);
899 TypeName *
typename,
bool missing_ok);
903 List *
object,
bool missing_ok);
921 int32 objectSubId,
bool missing_ok);
1001 &relation, lockmode,
1007 &relation, lockmode,
1015 &relation, missing_ok);
1029 address.
classId = ConstraintRelationId;
1031 constrname, missing_ok);
1059 address.
classId = ProcedureRelationId;
1064 address.
classId = OperatorRelationId;
1069 address.
classId = CollationRelationId;
1074 address.
classId = ConversionRelationId;
1087 address.
classId = LargeObjectRelationId;
1094 (
errcode(ERRCODE_UNDEFINED_OBJECT),
1095 errmsg(
"large object %u does not exist",
1108 address.
classId = CastRelationId;
1121 address.
classId = TransformRelationId;
1128 address.
classId = TSParserRelationId;
1133 address.
classId = TSDictionaryRelationId;
1138 address.
classId = TSTemplateRelationId;
1143 address.
classId = TSConfigRelationId;
1165 address.
classId = StatisticExtRelationId;
1174 elog(
ERROR,
"unrecognized object type: %d", (
int) objtype);
1196 if (old_address.
classId != RelationRelationId)
1213 if (address.
classId != RelationRelationId)
1245 old_address = address;
1275 relp, lockmode, missing_ok);
1284 String *strval,
bool missing_ok)
1295 address.
classId = AccessMethodRelationId;
1300 address.
classId = DatabaseRelationId;
1305 address.
classId = ExtensionRelationId;
1310 address.
classId = TableSpaceRelationId;
1315 address.
classId = AuthIdRelationId;
1320 address.
classId = NamespaceRelationId;
1325 address.
classId = LanguageRelationId;
1330 address.
classId = ForeignDataWrapperRelationId;
1335 address.
classId = ForeignServerRelationId;
1340 address.
classId = EventTriggerRelationId;
1345 address.
classId = ParameterAclRelationId;
1350 address.
classId = PublicationRelationId;
1355 address.
classId = SubscriptionRelationId;
1360 elog(
ERROR,
"unrecognized object type: %d", (
int) objtype);
1381 address.
classId = RelationRelationId;
1386 lockmode, missing_ok);
1393 if (relation->
rd_rel->relkind != RELKIND_INDEX &&
1394 relation->
rd_rel->relkind != RELKIND_PARTITIONED_INDEX)
1396 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1397 errmsg(
"\"%s\" is not an index",
1401 if (relation->
rd_rel->relkind != RELKIND_SEQUENCE)
1403 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1404 errmsg(
"\"%s\" is not a sequence",
1408 if (relation->
rd_rel->relkind != RELKIND_RELATION &&
1409 relation->
rd_rel->relkind != RELKIND_PARTITIONED_TABLE)
1411 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1412 errmsg(
"\"%s\" is not a table",
1416 if (relation->
rd_rel->relkind != RELKIND_VIEW)
1418 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1419 errmsg(
"\"%s\" is not a view",
1423 if (relation->
rd_rel->relkind != RELKIND_MATVIEW)
1425 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1426 errmsg(
"\"%s\" is not a materialized view",
1430 if (relation->
rd_rel->relkind != RELKIND_FOREIGN_TABLE)
1432 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1433 errmsg(
"\"%s\" is not a foreign table",
1437 elog(
ERROR,
"unrecognized object type: %d", (
int) objtype);
1462 const char *depname;
1473 (
errcode(ERRCODE_SYNTAX_ERROR),
1474 errmsg(
"must specify relation and object name")));
1487 address.
classId = RewriteRelationId;
1493 address.
classId = TriggerRelationId;
1499 address.
classId = ConstraintRelationId;
1506 address.
classId = PolicyRelationId;
1513 elog(
ERROR,
"unrecognized object type: %d", (
int) objtype);
1519 if (relation != NULL)
1549 (
errcode(ERRCODE_SYNTAX_ERROR),
1550 errmsg(
"column name must be qualified")));
1563 (
errcode(ERRCODE_UNDEFINED_COLUMN),
1564 errmsg(
"column \"%s\" of relation \"%s\" does not exist",
1567 address.
classId = RelationRelationId;
1574 address.
classId = RelationRelationId;
1602 (
errcode(ERRCODE_SYNTAX_ERROR),
1603 errmsg(
"column name must be qualified")));
1621 (
errcode(ERRCODE_UNDEFINED_COLUMN),
1622 errmsg(
"default value for column \"%s\" of relation \"%s\" does not exist",
1625 address.
classId = AttrDefaultRelationId;
1632 address.
classId = AttrDefaultRelationId;
1649 address.
classId = TypeRelationId;
1658 (
errcode(ERRCODE_UNDEFINED_OBJECT),
1659 errmsg(
"type \"%s\" does not exist",
1669 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1670 errmsg(
"\"%s\" is not a domain",
1695 address.
classId = OperatorClassRelationId;
1700 address.
classId = OperatorFamilyRelationId;
1705 elog(
ERROR,
"unrecognized object type: %d", (
int) objtype);
1722 List *
object,
bool missing_ok)
1748 foreach(cell,
lsecond(
object))
1777 (
errcode(ERRCODE_UNDEFINED_OBJECT),
1778 errmsg(
"operator %d (%s, %s) of %s does not exist",
1808 (
errcode(ERRCODE_UNDEFINED_OBJECT),
1809 errmsg(
"function %d (%s, %s) of %s does not exist",
1823 elog(
ERROR,
"unrecognized object type: %d", (
int) objtype);
1849 if (strcmp(
username,
"public") == 0)
1859 (
errcode(ERRCODE_UNDEFINED_OBJECT),
1860 errmsg(
"user mapping for user \"%s\" on server \"%s\" does not exist",
1874 (
errcode(ERRCODE_UNDEFINED_OBJECT),
1875 errmsg(
"server \"%s\" does not exist", servername)));
1885 (
errcode(ERRCODE_UNDEFINED_OBJECT),
1886 errmsg(
"user mapping for user \"%s\" on server \"%s\" does not exist",
1941 (
errcode(ERRCODE_UNDEFINED_OBJECT),
1942 errmsg(
"publication relation \"%s\" in publication \"%s\" does not exist",
1983 Anum_pg_publication_namespace_oid,
1988 (
errcode(ERRCODE_UNDEFINED_OBJECT),
1989 errmsg(
"publication schema \"%s\" in publication \"%s\" does not exist",
1990 schemaname, pubname)));
2029 case DEFACLOBJ_RELATION:
2030 objtype_str =
"tables";
2032 case DEFACLOBJ_SEQUENCE:
2033 objtype_str =
"sequences";
2035 case DEFACLOBJ_FUNCTION:
2036 objtype_str =
"functions";
2038 case DEFACLOBJ_TYPE:
2039 objtype_str =
"types";
2041 case DEFACLOBJ_NAMESPACE:
2042 objtype_str =
"schemas";
2046 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2047 errmsg(
"unrecognized default ACL object type \"%c\"", objtype),
2048 errhint(
"Valid object types are \"%c\", \"%c\", \"%c\", \"%c\", \"%c\".",
2053 DEFACLOBJ_NAMESPACE)));
2098 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2099 errmsg(
"default ACL for user \"%s\" in schema \"%s\" on %s does not exist",
2103 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2104 errmsg(
"default ACL for user \"%s\" on %s does not exist",
2125 for (
i = 0;
i < nelems;
i++)
2129 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2130 errmsg(
"name or argument lists may not contain nulls")));
2151 Node *objnode = NULL;
2163 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2164 errmsg(
"unsupported object type \"%s\"", ttype)));
2182 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2183 errmsg(
"name list length must be exactly %d", 1)));
2186 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2187 errmsg(
"name or argument lists may not contain nulls")));
2199 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2200 errmsg(
"name list length must be exactly %d", 1)));
2203 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2204 errmsg(
"large object OID may not be null")));
2212 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2213 errmsg(
"name list length must be at least %d", 1)));
2237 for (
i = 0;
i < nelems;
i++)
2241 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2242 errmsg(
"name or argument lists may not contain nulls")));
2264 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2265 errmsg(
"name list length must be exactly %d", 1)));
2275 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2276 errmsg(
"argument list length must be exactly %d", 1)));
2282 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2283 errmsg(
"name list length must be at least %d", 2)));
2289 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2290 errmsg(
"name list length must be at least %d", 3)));
2296 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2297 errmsg(
"argument list length must be exactly %d", 2)));
2348 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2349 errmsg(
"name list length must be exactly %d", 1)));
2354 objnode = (
Node *)
typename;
2385 objnode = (
Node *) owa;
2394 if (objnode == NULL)
2405 elog(
ERROR,
"return type must be a row type");
2457 elog(
ERROR,
"constraint with OID %u does not exist",
2510 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2511 errmsg(
"must be owner of large object %u",
2525 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2526 errmsg(
"must be owner of type %s or type %s",
2552 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2553 errmsg(
"permission denied"),
2554 errdetail(
"The current user must have the %s attribute.",
2561 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2562 errmsg(
"permission denied"),
2563 errdetail(
"The current user must have the %s attribute.",
2567 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2568 errmsg(
"permission denied"),
2569 errdetail(
"The current user must have the %s option on role \"%s\".",
2582 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
2583 errmsg(
"must be superuser")));
2593 elog(
ERROR,
"unsupported object type: %d", (
int) objtype);
2618 cache =
property->oid_catcache_id;
2624 elog(
ERROR,
"cache lookup failed for cache %d oid %u",
2651 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
2652 errmsg(
"unrecognized object type \"%s\"", objtype)));
2796 if (prop_last && prop_last->
class_oid == class_id)
2872 char **pubname,
char **nspname)
2882 elog(
ERROR,
"cache lookup failed for publication schema %u",
2898 Oid schemaid = pnform->pnnspid;
2903 elog(
ERROR,
"cache lookup failed for schema %u",
2999 elog(
ERROR,
"could not find tuple for cast %u",
3029 elog(
ERROR,
"cache lookup failed for collation %u",
3059 elog(
ERROR,
"cache lookup failed for constraint %u",
3098 elog(
ERROR,
"cache lookup failed for conversion %u",
3127 elog(
ERROR,
"could not find tuple for attrdef %u",
3162 if (oprname == NULL)
3182 elog(
ERROR,
"cache lookup failed for opclass %u",
3192 elog(
ERROR,
"cache lookup failed for access method %u",
3193 opcForm->opcmethod);
3225 elog(
ERROR,
"cache lookup failed for access method %u",
3245 amopDesc =
table_open(AccessMethodOperatorRelationId,
3261 elog(
ERROR,
"could not find tuple for amop entry %u",
3280 amopForm->amopstrategy,
3302 amprocDesc =
table_open(AccessMethodProcedureRelationId,
3318 elog(
ERROR,
"could not find tuple for amproc entry %u",
3337 amprocForm->amprocnum,
3362 Anum_pg_rewrite_oid,
3374 elog(
ERROR,
"could not find tuple for rule %u",
3408 Anum_pg_trigger_oid,
3420 elog(
ERROR,
"could not find tuple for trigger %u",
3450 elog(
ERROR,
"cache lookup failed for namespace %u",
3469 elog(
ERROR,
"could not find tuple for statistics object %u",
3501 elog(
ERROR,
"cache lookup failed for text search parser %u",
3531 elog(
ERROR,
"cache lookup failed for text search dictionary %u",
3546 NameStr(dictForm->dictname)));
3562 elog(
ERROR,
"cache lookup failed for text search template %u",
3577 NameStr(tmplForm->tmplname)));
3593 elog(
ERROR,
"cache lookup failed for text search configuration %u",
3634 Anum_pg_auth_members_oid,
3646 elog(
ERROR,
"could not find tuple for role membership %u",
3673 elog(
ERROR,
"cache lookup failed for database %u",
3689 elog(
ERROR,
"cache lookup failed for tablespace %u",
3731 elog(
ERROR,
"cache lookup failed for user mapping %u",
3737 useid = umform->umuser;
3765 Anum_pg_default_acl_oid,
3770 true, NULL, 1, skey);
3777 elog(
ERROR,
"could not find tuple for default ACL %u",
3794 switch (defacl->defaclobjtype)
3796 case DEFACLOBJ_RELATION:
3799 _(
"default privileges on new relations belonging to role %s in schema %s"),
3803 _(
"default privileges on new relations belonging to role %s"),
3806 case DEFACLOBJ_SEQUENCE:
3809 _(
"default privileges on new sequences belonging to role %s in schema %s"),
3813 _(
"default privileges on new sequences belonging to role %s"),
3816 case DEFACLOBJ_FUNCTION:
3819 _(
"default privileges on new functions belonging to role %s in schema %s"),
3823 _(
"default privileges on new functions belonging to role %s"),
3826 case DEFACLOBJ_TYPE:
3829 _(
"default privileges on new types belonging to role %s in schema %s"),
3833 _(
"default privileges on new types belonging to role %s"),
3836 case DEFACLOBJ_NAMESPACE:
3839 _(
"default privileges on new schemas belonging to role %s"),
3846 _(
"default privileges belonging to role %s in schema %s"),
3850 _(
"default privileges belonging to role %s"),
3868 elog(
ERROR,
"cache lookup failed for extension %u",
3885 elog(
ERROR,
"cache lookup failed for event trigger %u",
3906 elog(
ERROR,
"cache lookup failed for parameter ACL %u",
3911 Anum_pg_parameter_acl_parname);
3935 true, NULL, 1, skey);
3942 elog(
ERROR,
"could not find tuple for policy %u",
3980 &pubname, &nspname))
4002 elog(
ERROR,
"cache lookup failed for publication table %u",
4041 elog(
ERROR,
"could not find tuple for transform %u",
4063 if (buffer.
len == 0)
4102 elog(
ERROR,
"cache lookup failed for relation %u", relid);
4115 switch (relForm->relkind)
4117 case RELKIND_RELATION:
4118 case RELKIND_PARTITIONED_TABLE:
4123 case RELKIND_PARTITIONED_INDEX:
4127 case RELKIND_SEQUENCE:
4131 case RELKIND_TOASTVALUE:
4139 case RELKIND_MATVIEW:
4143 case RELKIND_COMPOSITE_TYPE:
4147 case RELKIND_FOREIGN_TABLE:
4177 elog(
ERROR,
"cache lookup failed for opfamily %u", opfid);
4184 elog(
ERROR,
"cache lookup failed for access method %u",
4185 opfForm->opfmethod);
4241 const char *objname = NULL;
4254 elog(
ERROR,
"return type must be a row type");
4276 elog(
ERROR,
"invalid null namespace in object %u/%u/%d",
4294 elog(
ERROR,
"invalid null name in object %u/%u/%d",
4326 if (objname && objidentity)
4371 elog(
ERROR,
"return type must be a row type");
4379 if (identity == NULL)
4618 elog(
ERROR,
"cache lookup failed for relation %u", relid);
4626 switch (relForm->relkind)
4628 case RELKIND_RELATION:
4629 case RELKIND_PARTITIONED_TABLE:
4633 case RELKIND_PARTITIONED_INDEX:
4636 case RELKIND_SEQUENCE:
4639 case RELKIND_TOASTVALUE:
4645 case RELKIND_MATVIEW:
4648 case RELKIND_COMPOSITE_TYPE:
4651 case RELKIND_FOREIGN_TABLE:
4660 if (objectSubId != 0)
4682 elog(
ERROR,
"cache lookup failed for constraint %u", constroid);
4698 elog(
ERROR,
"invalid constraint %u", constrForm->oid);
4718 elog(
ERROR,
"cache lookup failed for procedure %u", procid);
4726 if (procForm->prokind == PROKIND_AGGREGATE)
4728 else if (procForm->prokind == PROKIND_PROCEDURE)
4796 if (missing_ok && attr == NULL)
4802 if (objname && *objname ==
NIL)
4810 *objname =
lappend(*objname, attr);
4838 if (typeout == NULL)
4861 elog(
ERROR,
"could not find tuple for cast %u",
4895 elog(
ERROR,
"cache lookup failed for collation %u",
4921 elog(
ERROR,
"cache lookup failed for constraint %u",
4941 domain.
classId = TypeRelationId;
4969 elog(
ERROR,
"cache lookup failed for conversion %u",
4994 elog(
ERROR,
"could not find tuple for attrdef %u",
5016 elog(
ERROR,
"cache lookup failed for language %u",
5043 if (oprname == NULL)
5065 elog(
ERROR,
"cache lookup failed for opclass %u",
5075 elog(
ERROR,
"cache lookup failed for access method %u",
5076 opcForm->opcmethod);
5106 elog(
ERROR,
"cache lookup failed for access method %u",
5127 amopDesc =
table_open(AccessMethodOperatorRelationId,
5143 elog(
ERROR,
"could not find tuple for amop entry %u",
5163 psprintf(
"%d", amopForm->amopstrategy));
5168 amopForm->amopstrategy,
5169 ltype, rtype, opfam.
data);
5189 amprocDesc =
table_open(AccessMethodProcedureRelationId,
5205 elog(
ERROR,
"could not find tuple for amproc entry %u",
5225 psprintf(
"%d", amprocForm->amprocnum));
5230 amprocForm->amprocnum,
5231 ltype, rtype, opfam.
data);
5254 elog(
ERROR,
"could not find tuple for rule %u",
5287 elog(
ERROR,
"could not find tuple for trigger %u",
5314 elog(
ERROR,
"cache lookup failed for namespace %u",
5336 elog(
ERROR,
"cache lookup failed for statistics object %u",
5344 NameStr(formStatistic->stxname)));
5363 elog(
ERROR,
"cache lookup failed for text search parser %u",
5371 NameStr(formParser->prsname)));
5390 elog(
ERROR,
"cache lookup failed for text search dictionary %u",
5398 NameStr(formDict->dictname)));
5417 elog(
ERROR,
"cache lookup failed for text search template %u",
5425 NameStr(formTmpl->tmplname)));
5444 elog(
ERROR,
"cache lookup failed for text search configuration %u",
5486 Anum_pg_auth_members_oid,
5498 elog(
ERROR,
"could not find tuple for pg_auth_members entry %u",
5525 elog(
ERROR,
"cache lookup failed for database %u",
5544 elog(
ERROR,
"cache lookup failed for tablespace %u",
5592 const char *usename;
5599 elog(
ERROR,
"cache lookup failed for user mapping %u",
5604 useid = umform->umuser;
5639 Anum_pg_default_acl_oid,
5644 true, NULL, 1, skey);
5651 elog(
ERROR,
"could not find tuple for default ACL %u",
5676 switch (defacl->defaclobjtype)
5678 case DEFACLOBJ_RELATION:
5682 case DEFACLOBJ_SEQUENCE:
5686 case DEFACLOBJ_FUNCTION:
5690 case DEFACLOBJ_TYPE:
5694 case DEFACLOBJ_NAMESPACE:
5704 *objname =
lappend(*objname, schema);
5721 elog(
ERROR,
"cache lookup failed for extension %u",
5742 elog(
ERROR,
"cache lookup failed for event trigger %u",
5766 elog(
ERROR,
"cache lookup failed for parameter ACL %u",
5771 Anum_pg_parameter_acl_parname);
5794 elog(
ERROR,
"could not find tuple for policy %u",
5863 elog(
ERROR,
"cache lookup failed for publication table %u",
5901 char *transformLang;
5902 char *transformType;
5907 Anum_pg_transform_oid,
5913 elog(
ERROR,
"could not find tuple for transform %u",
5951 if (objname && *objname ==
NIL)
5952 elog(
ERROR,
"requested object address for unsupported object class %d: text result \"%s\"",
5958 if (buffer.
len == 0)
5960 Assert((objname == NULL || *objname ==
NIL) &&
5961 (objargs == NULL || *objargs ==
NIL));
5983 elog(
ERROR,
"cache lookup failed for opfamily %u", opfid);
5990 elog(
ERROR,
"cache lookup failed for access method %u",
5991 opfForm->opfmethod);
6026 elog(
ERROR,
"cache lookup failed for relation %u", relid);
6085 lb, TEXTOID, -1,
false, TYPALIGN_INT);
6107 case RELKIND_RELATION:
6108 case RELKIND_PARTITIONED_TABLE:
6111 case RELKIND_PARTITIONED_INDEX:
6113 case RELKIND_SEQUENCE:
6117 case RELKIND_MATVIEW:
6119 case RELKIND_FOREIGN_TABLE:
6121 case RELKIND_TOASTVALUE:
bool is_admin_of_role(Oid member, Oid role)
Oid get_role_oid(const char *rolname, bool missing_ok)
void aclcheck_error(AclResult aclerr, ObjectType objtype, const char *objectname)
bool object_ownercheck(Oid classid, Oid objectid, Oid roleid)
void aclcheck_error_type(AclResult aclerr, Oid typeOid)
bool has_createrole_privilege(Oid roleid)
Oid get_index_am_oid(const char *amname, bool missing_ok)
char * get_am_name(Oid amOid)
Oid get_am_oid(const char *amname, bool missing_ok)
#define PG_GETARG_ARRAYTYPE_P(n)
ArrayType * construct_empty_array(Oid elmtype)
void deconstruct_array_builtin(ArrayType *array, Oid elmtype, Datum **elemsp, bool **nullsp, int *nelemsp)
ArrayType * construct_md_array(Datum *elems, bool *nulls, int ndims, int *dims, int *lbs, Oid elmtype, int elmlen, bool elmbyval, char elmalign)
#define InvalidAttrNumber
char * get_tablespace_name(Oid spc_oid)
Oid get_tablespace_oid(const char *tablespacename, bool missing_ok)
static Datum values[MAXATTR]
#define CStringGetTextDatum(s)
#define TextDatumGetCString(d)
#define FORMAT_TYPE_INVALID_AS_NULL
#define FORMAT_TYPE_FORCE_QUALIFY
#define PointerIsValid(pointer)
#define OidIsValid(objectId)
bool IsSharedRelation(Oid relationId)
char * get_database_name(Oid dbid)
Oid get_database_oid(const char *dbname, bool missing_ok)
ObjectClass getObjectClass(const ObjectAddress *object)
@ OCLASS_PUBLICATION_NAMESPACE
int errmsg_internal(const char *fmt,...)
int errdetail(const char *fmt,...)
int errhint(const char *fmt,...)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
Oid get_event_trigger_oid(const char *trigname, bool missing_ok)
Oid get_extension_oid(const char *extname, bool missing_ok)
char * get_extension_name(Oid ext_oid)
#define PG_GETARG_DATUM(n)
#define PG_RETURN_TEXT_P(x)
#define PG_GETARG_INT32(n)
#define PG_RETURN_DATUM(x)
ForeignServer * GetForeignServerExtended(Oid serverid, bits16 flags)
Oid get_foreign_server_oid(const char *servername, bool missing_ok)
ForeignDataWrapper * GetForeignDataWrapperExtended(Oid fdwid, bits16 flags)
ForeignServer * GetForeignServer(Oid serverid)
ForeignServer * GetForeignServerByName(const char *srvname, bool missing_ok)
Oid get_foreign_data_wrapper_oid(const char *fdwname, bool missing_ok)
TypeFuncClass get_call_result_type(FunctionCallInfo fcinfo, Oid *resultTypeId, TupleDesc *resultTupleDesc)
static Datum HeapTupleGetDatum(const HeapTupleData *tuple)
Oid get_transform_oid(Oid type_id, Oid lang_id, bool missing_ok)
void systable_endscan(SysScanDesc sysscan)
HeapTuple systable_getnext(SysScanDesc sysscan)
SysScanDesc systable_beginscan(Relation heapRelation, Oid indexId, bool indexOK, Snapshot snapshot, int nkeys, ScanKey key)
HeapTuple heap_copytuple(HeapTuple tuple)
HeapTuple heap_form_tuple(TupleDesc tupleDescriptor, const Datum *values, const bool *isnull)
#define HeapTupleIsValid(tuple)
static Datum heap_getattr(HeapTuple tup, int attnum, TupleDesc tupleDesc, bool *isnull)
bool lo_compat_privileges
Assert(fmt[strlen(fmt) - 1] !='\n')
List * lappend(List *list, void *datum)
List * list_copy_head(const List *oldlist, int len)
List * list_copy_tail(const List *oldlist, int nskip)
List * lcons(void *datum, List *list)
void LockSharedObject(Oid classid, Oid objid, uint16 objsubid, LOCKMODE lockmode)
void LockDatabaseObject(Oid classid, Oid objid, uint16 objsubid, LOCKMODE lockmode)
void UnlockSharedObject(Oid classid, Oid objid, uint16 objsubid, LOCKMODE lockmode)
void UnlockDatabaseObject(Oid classid, Oid objid, uint16 objsubid, LOCKMODE lockmode)
char * get_language_name(Oid langoid, bool missing_ok)
Oid get_cast_oid(Oid sourcetypeid, Oid targettypeid, bool missing_ok)
AttrNumber get_attnum(Oid relid, const char *attname)
char * get_namespace_name_or_temp(Oid nspid)
char * get_namespace_name(Oid nspid)
char get_rel_relkind(Oid relid)
Oid get_publication_oid(const char *pubname, bool missing_ok)
char * get_publication_name(Oid pubid, bool missing_ok)
Oid get_subscription_oid(const char *subname, bool missing_ok)
char * get_subscription_name(Oid subid, bool missing_ok)
char * get_attname(Oid relid, AttrNumber attnum, bool missing_ok)
char * pstrdup(const char *in)
void pfree(void *pointer)
MemoryContext CurrentMemoryContext
void MemoryContextDelete(MemoryContext context)
#define AllocSetContextCreate
#define ALLOCSET_DEFAULT_SIZES
char * GetUserNameFromId(Oid roleid, bool noerr)
bool TSTemplateIsVisible(Oid tmplId)
bool OpfamilyIsVisible(Oid opfid)
bool CollationIsVisible(Oid collid)
bool ConversionIsVisible(Oid conid)
Oid get_statistics_object_oid(List *names, bool missing_ok)
Oid get_collation_oid(List *collname, bool missing_ok)
Oid get_namespace_oid(const char *nspname, bool missing_ok)
bool RelationIsVisible(Oid relid)
bool OpclassIsVisible(Oid opcid)
RangeVar * makeRangeVarFromNameList(const List *names)
bool TSParserIsVisible(Oid prsId)
Oid get_conversion_oid(List *conname, bool missing_ok)
Oid get_ts_dict_oid(List *names, bool missing_ok)
Oid get_ts_parser_oid(List *names, bool missing_ok)
char * NameListToString(const List *names)
Oid get_ts_config_oid(List *names, bool missing_ok)
bool TSConfigIsVisible(Oid cfgid)
bool StatisticsObjIsVisible(Oid stxid)
bool TSDictionaryIsVisible(Oid dictId)
Oid get_ts_template_oid(List *names, bool missing_ok)
#define castNode(_type_, nodeptr)
static void getRelationDescription(StringInfo buffer, Oid relid, bool missing_ok)
int get_object_catcache_name(Oid class_id)
bool get_object_namensp_unique(Oid class_id)
ObjectAddress get_object_address_rv(ObjectType objtype, RangeVar *rel, List *object, Relation *relp, LOCKMODE lockmode, bool missing_ok)
AttrNumber get_object_attnum_owner(Oid class_id)
ArrayType * strlist_to_textarray(List *list)
Datum pg_identify_object(PG_FUNCTION_ARGS)
HeapTuple get_catalog_object_by_oid(Relation catalog, AttrNumber oidcol, Oid objectId)
AttrNumber get_object_attnum_oid(Oid class_id)
char * getObjectDescriptionOids(Oid classid, Oid objid)
static const ObjectPropertyType ObjectProperty[]
ObjectType get_relkind_objtype(char relkind)
AttrNumber get_object_attnum_namespace(Oid class_id)
char * getObjectDescription(const ObjectAddress *object, bool missing_ok)
void check_object_ownership(Oid roleid, ObjectType objtype, ObjectAddress address, Node *object, Relation relation)
static ObjectAddress get_object_address_publication_schema(List *object, bool missing_ok)
AttrNumber get_object_attnum_name(Oid class_id)
static ObjectAddress get_object_address_relobject(ObjectType objtype, List *object, Relation *relp, bool missing_ok)
static void getConstraintTypeDescription(StringInfo buffer, Oid constroid, bool missing_ok)
static void getProcedureTypeDescription(StringInfo buffer, Oid procid, bool missing_ok)
static void getOpFamilyIdentity(StringInfo buffer, Oid opfid, List **object, bool missing_ok)
static ObjectAddress get_object_address_defacl(List *object, bool missing_ok)
static bool getPublicationSchemaInfo(const ObjectAddress *object, bool missing_ok, char **pubname, char **nspname)
AttrNumber get_object_attnum_acl(Oid class_id)
char * getObjectIdentity(const ObjectAddress *object, bool missing_ok)
char * getObjectTypeDescription(const ObjectAddress *object, bool missing_ok)
static void getRelationTypeDescription(StringInfo buffer, Oid relid, int32 objectSubId, bool missing_ok)
int get_object_catcache_oid(Oid class_id)
static void getOpFamilyDescription(StringInfo buffer, Oid opfid, bool missing_ok)
Oid get_object_oid_index(Oid class_id)
static ObjectAddress get_object_address_unqualified(ObjectType objtype, String *strval, bool missing_ok)
char * getObjectIdentityParts(const ObjectAddress *object, List **objname, List **objargs, bool missing_ok)
int read_objtype_from_string(const char *objtype)
const ObjectAddress InvalidObjectAddress
ObjectType get_object_type(Oid class_id, Oid object_id)
static ObjectAddress get_object_address_publication_rel(List *object, Relation *relp, bool missing_ok)
static ObjectAddress get_object_address_opf_member(ObjectType objtype, List *object, bool missing_ok)
static const ObjectPropertyType * get_object_property_data(Oid class_id)
static ObjectAddress get_object_address_type(ObjectType objtype, TypeName *typename, bool missing_ok)
static ObjectAddress get_object_address_usermapping(List *object, bool missing_ok)
static const struct object_type_map ObjectTypeMap[]
static void getRelationIdentity(StringInfo buffer, Oid relid, List **object, bool missing_ok)
static ObjectAddress get_object_address_opcf(ObjectType objtype, List *object, bool missing_ok)
Datum pg_identify_object_as_address(PG_FUNCTION_ARGS)
ObjectAddress get_object_address(ObjectType objtype, Node *object, Relation *relp, LOCKMODE lockmode, bool missing_ok)
Datum pg_describe_object(PG_FUNCTION_ARGS)
Datum pg_get_object_address(PG_FUNCTION_ARGS)
static ObjectAddress get_object_address_attribute(ObjectType objtype, List *object, Relation *relp, LOCKMODE lockmode, bool missing_ok)
static ObjectAddress get_relation_by_qualified_name(ObjectType objtype, List *object, Relation *relp, LOCKMODE lockmode, bool missing_ok)
const char * get_object_class_descr(Oid class_id)
static List * textarray_to_strvaluelist(ArrayType *arr)
Oid get_object_namespace(const ObjectAddress *address)
static ObjectAddress get_object_address_attrdef(ObjectType objtype, List *object, Relation *relp, LOCKMODE lockmode, bool missing_ok)
bool is_objectclass_supported(Oid class_id)
#define ObjectAddressSet(addr, class_id, object_id)
Oid get_opclass_oid(Oid amID, List *opclassname, bool missing_ok)
Oid get_opfamily_oid(Oid amID, List *opfamilyname, bool missing_ok)
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Oid LookupFuncWithArgs(ObjectType objtype, ObjectWithArgs *func, bool missing_ok)
Oid LookupOperWithArgs(ObjectWithArgs *oper, bool noError)
Type LookupTypeName(ParseState *pstate, const TypeName *typeName, int32 *typmod_p, bool missing_ok)
char * TypeNameToString(const TypeName *typeName)
TypeName * typeStringToTypeName(const char *str, Node *escontext)
Oid typenameTypeId(ParseState *pstate, const TypeName *typeName)
Oid LookupTypeNameOid(ParseState *pstate, const TypeName *typeName, bool missing_ok)
@ OBJECT_PUBLICATION_NAMESPACE
FormData_pg_am * Form_pg_am
FormData_pg_amop * Form_pg_amop
FormData_pg_amproc * Form_pg_amproc
Oid GetAttrDefaultOid(Oid relid, AttrNumber attnum)
ObjectAddress GetAttrDefaultColumnAddress(Oid attrdefoid)
FormData_pg_auth_members * Form_pg_auth_members
FormData_pg_authid * Form_pg_authid
FormData_pg_cast * Form_pg_cast
FormData_pg_class * Form_pg_class
FormData_pg_collation * Form_pg_collation
Oid get_relation_constraint_oid(Oid relid, const char *conname, bool missing_ok)
Oid get_domain_constraint_oid(Oid typid, const char *conname, bool missing_ok)
FormData_pg_constraint * Form_pg_constraint
FormData_pg_conversion * Form_pg_conversion
FormData_pg_default_acl * Form_pg_default_acl
FormData_pg_event_trigger * Form_pg_event_trigger
FormData_pg_language * Form_pg_language
bool LargeObjectExists(Oid loid)
#define lfirst_node(type, lc)
static int list_length(const List *l)
#define linitial_node(type, l)
#define lsecond_node(type, l)
#define list_make3(x1, x2, x3)
#define list_make2(x1, x2)
FormData_pg_opclass * Form_pg_opclass
FormData_pg_opfamily * Form_pg_opfamily
Oid ParameterAclLookup(const char *parameter, bool missing_ok)
FormData_pg_policy * Form_pg_policy
FormData_pg_proc * Form_pg_proc
Publication * GetPublicationByName(const char *pubname, bool missing_ok)
FormData_pg_publication_namespace * Form_pg_publication_namespace
FormData_pg_publication_rel * Form_pg_publication_rel
FormData_pg_rewrite * Form_pg_rewrite
FormData_pg_statistic_ext * Form_pg_statistic_ext
FormData_pg_trigger * Form_pg_trigger
FormData_pg_ts_config * Form_pg_ts_config
FormData_pg_ts_dict * Form_pg_ts_dict
FormData_pg_ts_parser * Form_pg_ts_parser
FormData_pg_ts_template * Form_pg_ts_template
FormData_pg_type * Form_pg_type
FormData_pg_user_mapping * Form_pg_user_mapping
Oid get_relation_policy_oid(Oid relid, const char *policy_name, bool missing_ok)
static Datum PointerGetDatum(const void *X)
static Name DatumGetName(Datum X)
static Oid DatumGetObjectId(Datum X)
static Datum Int16GetDatum(int16 X)
static Datum ObjectIdGetDatum(Oid X)
static Datum CStringGetDatum(const char *X)
static Datum Int32GetDatum(int32 X)
static Datum CharGetDatum(char X)
Oid get_language_oid(const char *langname, bool missing_ok)
char * psprintf(const char *fmt,...)
char * format_operator(Oid operator_oid)
char * format_procedure(Oid procedure_oid)
char * format_operator_extended(Oid operator_oid, bits16 flags)
char * format_procedure_extended(Oid procedure_oid, bits16 flags)
void format_operator_parts(Oid operator_oid, List **objnames, List **objargs, bool missing_ok)
void format_procedure_parts(Oid procedure_oid, List **objnames, List **objargs, bool missing_ok)
#define FORMAT_OPERATOR_INVALID_AS_NULL
#define FORMAT_OPERATOR_FORCE_QUALIFY
#define FORMAT_PROC_FORCE_QUALIFY
#define FORMAT_PROC_INVALID_AS_NULL
#define RelationGetRelid(relation)
#define RelationGetDescr(relation)
#define RelationGetRelationName(relation)
Oid get_rewrite_oid(Oid relid, const char *rulename, bool missing_ok)
const char * quote_identifier(const char *ident)
char * quote_qualified_identifier(const char *qualifier, const char *ident)
void ScanKeyInit(ScanKey entry, AttrNumber attributeNumber, StrategyNumber strategy, RegProcedure procedure, Datum argument)
uint64 SharedInvalidMessageCounter
Relation relation_openrv_extended(const RangeVar *relation, LOCKMODE lockmode, bool missing_ok)
void relation_close(Relation relation, LOCKMODE lockmode)
Relation relation_openrv(const RangeVar *relation, LOCKMODE lockmode)
#define BTEqualStrategyNumber
void appendStringInfo(StringInfo str, const char *fmt,...)
void appendStringInfoString(StringInfo str, const char *s)
void initStringInfo(StringInfo str)
AttrNumber attnum_namespace
bool superuser_arg(Oid roleid)
void ReleaseSysCache(HeapTuple tuple)
HeapTuple SearchSysCache1(int cacheId, Datum key1)
HeapTuple SearchSysCache3(int cacheId, Datum key1, Datum key2, Datum key3)
HeapTuple SearchSysCache2(int cacheId, Datum key1, Datum key2)
HeapTuple SearchSysCache4(int cacheId, Datum key1, Datum key2, Datum key3, Datum key4)
Datum SysCacheGetAttrNotNull(int cacheId, HeapTuple tup, AttrNumber attributeNumber)
#define SearchSysCacheCopy1(cacheId, key1)
#define GetSysCacheOid2(cacheId, oidcol, key1, key2)
void table_close(Relation relation, LOCKMODE lockmode)
Relation table_open(Oid relationId, LOCKMODE lockmode)
Relation table_openrv_extended(const RangeVar *relation, LOCKMODE lockmode, bool missing_ok)
Oid get_trigger_oid(Oid relid, const char *trigname, bool missing_ok)
Float * makeFloat(char *numericStr)
String * makeString(char *str)
text * cstring_to_text(const char *s)