48 bool isSelect,
bool requireColumnNameMatch);
70 bool nulls[Natts_pg_rewrite] = {0};
78 bool is_update =
false;
106 bool replaces[Natts_pg_rewrite] = {0};
111 errmsg(
"rule \"%s\" for relation \"%s\" already exists",
117 replaces[Anum_pg_rewrite_ev_type - 1] =
true;
118 replaces[Anum_pg_rewrite_is_instead - 1] =
true;
119 replaces[Anum_pg_rewrite_ev_qual - 1] =
true;
120 replaces[Anum_pg_rewrite_ev_action - 1] =
true;
136 Anum_pg_rewrite_oid);
157 myself.
classId = RewriteRelationId;
161 referenced.
classId = RelationRelationId;
174 if (event_qual != NULL)
189 return rewriteObjectId;
262 if (event_relation->
rd_rel->relkind != RELKIND_RELATION &&
263 event_relation->
rd_rel->relkind != RELKIND_MATVIEW &&
264 event_relation->
rd_rel->relkind != RELKIND_VIEW &&
265 event_relation->
rd_rel->relkind != RELKIND_PARTITIONED_TABLE)
267 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
268 errmsg(
"relation \"%s\" cannot have rules",
274 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
275 errmsg(
"permission denied: \"%s\" is a system catalog",
291 if (query->resultRelation == 0)
298 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
299 errmsg(
"rule actions on OLD are not implemented"),
300 errhint(
"Use views or triggers instead.")));
303 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
304 errmsg(
"rule actions on NEW are not implemented"),
305 errhint(
"Use triggers instead.")));
315 if (event_relation->
rd_rel->relkind != RELKIND_VIEW &&
316 event_relation->
rd_rel->relkind != RELKIND_MATVIEW)
318 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
319 errmsg(
"relation \"%s\" cannot have ON SELECT rules",
328 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
329 errmsg(
"INSTEAD NOTHING rules on SELECT are not implemented"),
330 errhint(
"Use views instead.")));
337 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
338 errmsg(
"multiple actions for rules on SELECT are not implemented")));
347 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
348 errmsg(
"rules on SELECT must have action INSTEAD SELECT")));
353 if (query->hasModifyingCTE)
355 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
356 errmsg(
"rules on SELECT must not contain data-modifying statements in WITH")));
361 if (event_qual != NULL)
363 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
364 errmsg(
"event qualifications are not implemented for rules on SELECT")));
373 event_relation->
rd_rel->relkind !=
379 if (!replace && event_relation->
rd_rules != NULL)
390 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
391 errmsg(
"\"%s\" is already a view",
410 if (strncmp(rulename,
"_RET", 4) != 0 ||
414 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
415 errmsg(
"view rule for \"%s\" must be named \"%s\"",
431 bool haveReturning =
false;
441 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
442 errmsg(
"cannot have multiple RETURNING lists in a rule")));
443 haveReturning =
true;
444 if (event_qual != NULL)
446 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
447 errmsg(
"RETURNING lists are not supported in conditional rules")));
450 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
451 errmsg(
"RETURNING lists are not supported in non-INSTEAD rules")));
464 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
465 errmsg(
"non-view rule for \"%s\" must not be named \"%s\"",
514 bool requireColumnNameMatch)
520 Assert(isSelect || !requireColumnNameMatch);
523 foreach(tllist, targetList)
535 if (
i > resultDesc->
natts)
537 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
539 errmsg(
"SELECT rule's target list has too many entries") :
540 errmsg(
"RETURNING list has too many entries")));
563 if (attr->attisdropped)
565 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
567 errmsg(
"cannot convert relation containing dropped columns to view") :
568 errmsg(
"cannot create a RETURNING list for a relation containing dropped columns")));
571 if (requireColumnNameMatch && strcmp(tle->resname,
attname) != 0)
573 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
574 errmsg(
"SELECT rule's target entry %d has different column name from column \"%s\"",
576 errdetail(
"SELECT target entry is named \"%s\".",
581 if (attr->atttypid != tletypid)
583 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
585 errmsg(
"SELECT rule's target entry %d has different type from column \"%s\"",
587 errmsg(
"RETURNING list's entry %d has different type from column \"%s\"",
590 errdetail(
"SELECT target entry has type %s, but column has type %s.",
593 errdetail(
"RETURNING list entry has type %s, but column has type %s.",
604 if (attr->atttypmod != tletypmod &&
605 attr->atttypmod != -1 && tletypmod != -1)
607 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
609 errmsg(
"SELECT rule's target entry %d has different size from column \"%s\"",
611 errmsg(
"RETURNING list's entry %d has different size from column \"%s\"",
614 errdetail(
"SELECT target entry has type %s, but column has type %s.",
618 errdetail(
"RETURNING list entry has type %s, but column has type %s.",
624 if (
i != resultDesc->
natts)
626 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
628 errmsg(
"SELECT rule's target list has too few entries") :
629 errmsg(
"RETURNING list has too few entries")));
663 foreach(l, qry->rteperminfos)
688 if (qry->hasSubLinks)
703 Oid eventRelationOid;
706 bool changed =
false;
717 (
errcode(ERRCODE_UNDEFINED_OBJECT),
718 errmsg(
"rule \"%s\" for relation \"%s\" does not exist",
726 eventRelationOid = ruleform->ev_class;
727 Assert(eventRelationOid == owningRel);
775 if (form->relkind != RELKIND_RELATION &&
776 form->relkind != RELKIND_VIEW &&
777 form->relkind != RELKIND_PARTITIONED_TABLE)
779 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
785 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
786 errmsg(
"permission denied: \"%s\" is a system catalog",
832 (
errcode(ERRCODE_UNDEFINED_OBJECT),
833 errmsg(
"rule \"%s\" for relation \"%s\" does not exist",
836 ruleOid = ruleform->oid;
842 errmsg(
"rule \"%s\" for relation \"%s\" already exists",
851 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
852 errmsg(
"renaming an ON SELECT rule is not allowed")));
void aclcheck_error(AclResult aclerr, ObjectType objtype, const char *objectname)
bool object_ownercheck(Oid classid, Oid objectid, Oid roleid)
static Datum values[MAXATTR]
#define CStringGetTextDatum(s)
bool IsSystemRelation(Relation relation)
Oid GetNewOidWithIndex(Relation relation, Oid indexId, AttrNumber oidcolumn)
bool IsSystemClass(Oid relid, Form_pg_class reltuple)
void recordDependencyOnExpr(const ObjectAddress *depender, Node *expr, List *rtable, DependencyType behavior)
int errdetail(const char *fmt,...)
int errhint(const char *fmt,...)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
bool allowSystemTableMods
HeapTuple heap_form_tuple(TupleDesc tupleDescriptor, Datum *values, bool *isnull)
HeapTuple heap_modify_tuple(HeapTuple tuple, TupleDesc tupleDesc, Datum *replValues, bool *replIsnull, bool *doReplace)
void heap_freetuple(HeapTuple htup)
#define HeapTupleIsValid(tuple)
void CatalogTupleUpdate(Relation heapRel, ItemPointer otid, HeapTuple tup)
void CatalogTupleInsert(Relation heapRel, HeapTuple tup)
void CacheInvalidateRelcache(Relation relation)
Assert(fmt[strlen(fmt) - 1] !='\n')
#define AccessExclusiveLock
char get_rel_relkind(Oid relid)
char * get_rel_name(Oid relid)
char * pstrdup(const char *in)
void namestrcpy(Name name, const char *str)
Oid RangeVarGetRelidExtended(const RangeVar *relation, LOCKMODE lockmode, uint32 flags, RangeVarGetRelidCallback callback, void *callback_arg)
#define RangeVarGetRelid(relation, lockmode, missing_ok)
Oid exprType(const Node *expr)
int32 exprTypmod(const Node *expr)
#define query_tree_walker(q, w, c, f)
#define expression_tree_walker(n, w, c)
#define QTW_IGNORE_RC_SUBQUERIES
#define IsA(nodeptr, _type_)
#define castNode(_type_, nodeptr)
#define InvokeObjectPostCreateHook(classId, objectId, subId)
#define InvokeObjectPostAlterHook(classId, objectId, subId)
ObjectType get_relkind_objtype(char relkind)
#define ObjectAddressSet(addr, class_id, object_id)
char * nodeToString(const void *obj)
void transformRuleStmt(RuleStmt *stmt, const char *queryString, List **actions, Node **whereClause)
FormData_pg_attribute * Form_pg_attribute
int errdetail_relkind_not_supported(char relkind)
FormData_pg_class * Form_pg_class
void recordDependencyOn(const ObjectAddress *depender, const ObjectAddress *referenced, DependencyType behavior)
long deleteDependencyRecordsFor(Oid classId, Oid objectId, bool skipExtensionDeps)
#define lfirst_node(type, lc)
static int list_length(const List *l)
#define linitial_node(type, l)
FormData_pg_rewrite * Form_pg_rewrite
static Datum PointerGetDatum(const void *X)
static Datum BoolGetDatum(bool X)
static Datum ObjectIdGetDatum(Oid X)
static Datum NameGetDatum(const NameData *X)
static char DatumGetChar(Datum X)
static Datum CharGetDatum(char X)
#define RelationGetRelid(relation)
#define RelationGetDescr(relation)
#define RelationGetRelationName(relation)
static Oid InsertRule(const char *rulname, int evtype, Oid eventrel_oid, bool evinstead, Node *event_qual, List *action, bool replace)
void setRuleCheckAsUser(Node *node, Oid userid)
static bool setRuleCheckAsUser_walker(Node *node, Oid *context)
ObjectAddress DefineRule(RuleStmt *stmt, const char *queryString)
static void RangeVarCallbackForRenameRule(const RangeVar *rv, Oid relid, Oid oldrelid, void *arg)
static void checkRuleResultList(List *targetList, TupleDesc resultDesc, bool isSelect, bool requireColumnNameMatch)
static void setRuleCheckAsUser_Query(Query *qry, Oid userid)
ObjectAddress DefineQueryRewrite(const char *rulename, Oid event_relid, Node *event_qual, CmdType event_type, bool is_instead, bool replace, List *action)
void EnableDisableRule(Relation rel, const char *rulename, char fires_when)
ObjectAddress RenameRewriteRule(RangeVar *relation, const char *oldName, const char *newName)
#define RULE_FIRES_ON_ORIGIN
Query * getInsertSelectQuery(Query *parsetree, Query ***subquery_ptr)
void SetRelationRuleStatus(Oid relationId, bool relHasRules)
bool IsDefinedRewriteRule(Oid owningRel, const char *ruleName)
#define ViewSelectRuleName
void relation_close(Relation relation, LOCKMODE lockmode)
Relation relation_open(Oid relationId, LOCKMODE lockmode)
#define ERRCODE_DUPLICATE_OBJECT
void ReleaseSysCache(HeapTuple tuple)
HeapTuple SearchSysCache1(int cacheId, Datum key1)
HeapTuple SearchSysCache2(int cacheId, Datum key1, Datum key2)
#define SearchSysCacheCopy2(cacheId, key1, key2)
void table_close(Relation relation, LOCKMODE lockmode)
Relation table_open(Oid relationId, LOCKMODE lockmode)
#define TupleDescAttr(tupdesc, i)