PostgreSQL Source Code  git master
rewriteManip.h File Reference
#include "nodes/parsenodes.h"
Include dependency graph for rewriteManip.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures

struct  replace_rte_variables_context
 

Typedefs

typedef struct replace_rte_variables_context replace_rte_variables_context
 
typedef Node *(* replace_rte_variables_callback) (Var *var, replace_rte_variables_context *context)
 
typedef enum ReplaceVarsNoMatchOption ReplaceVarsNoMatchOption
 

Enumerations

enum  ReplaceVarsNoMatchOption { REPLACEVARS_REPORT_ERROR, REPLACEVARS_CHANGE_VARNO, REPLACEVARS_SUBSTITUTE_NULL }
 

Functions

void OffsetVarNodes (Node *node, int offset, int sublevels_up)
 
void ChangeVarNodes (Node *node, int old_varno, int new_varno, int sublevels_up)
 
void IncrementVarSublevelsUp (Node *node, int delta_sublevels_up, int min_sublevels_up)
 
void IncrementVarSublevelsUp_rtable (List *rtable, int delta_sublevels_up, int min_sublevels_up)
 
bool rangeTableEntry_used (Node *node, int rt_index, int sublevels_up)
 
QuerygetInsertSelectQuery (Query *parsetree, Query ***subquery_ptr)
 
void AddQual (Query *parsetree, Node *qual)
 
void AddInvertedQual (Query *parsetree, Node *qual)
 
bool contain_aggs_of_level (Node *node, int levelsup)
 
int locate_agg_of_level (Node *node, int levelsup)
 
bool contain_windowfuncs (Node *node)
 
int locate_windowfunc (Node *node)
 
bool checkExprHasSubLink (Node *node)
 
Nodereplace_rte_variables (Node *node, int target_varno, int sublevels_up, replace_rte_variables_callback callback, void *callback_arg, bool *outer_hasSubLinks)
 
Nodereplace_rte_variables_mutator (Node *node, replace_rte_variables_context *context)
 
Nodemap_variable_attnos (Node *node, int target_varno, int sublevels_up, const struct AttrMap *attno_map, Oid to_rowtype, bool *found_whole_row)
 
NodeReplaceVarsFromTargetList (Node *node, int target_varno, int sublevels_up, RangeTblEntry *target_rte, List *targetlist, ReplaceVarsNoMatchOption nomatch_option, int nomatch_varno, bool *outer_hasSubLinks)
 

Typedef Documentation

◆ replace_rte_variables_callback

typedef Node*(* replace_rte_variables_callback) (Var *var, replace_rte_variables_context *context)

Definition at line 24 of file rewriteManip.h.

◆ replace_rte_variables_context

◆ ReplaceVarsNoMatchOption

Enumeration Type Documentation

◆ ReplaceVarsNoMatchOption

Enumerator
REPLACEVARS_REPORT_ERROR 
REPLACEVARS_CHANGE_VARNO 
REPLACEVARS_SUBSTITUTE_NULL 

Definition at line 36 of file rewriteManip.h.

37 {
38  REPLACEVARS_REPORT_ERROR, /* throw error if no match */
39  REPLACEVARS_CHANGE_VARNO, /* change the Var's varno, nothing else */
40  REPLACEVARS_SUBSTITUTE_NULL /* replace with a NULL Const */
ReplaceVarsNoMatchOption
Definition: rewriteManip.h:36

Function Documentation

◆ AddInvertedQual()

void AddInvertedQual ( Query parsetree,
Node qual 
)

Definition at line 1047 of file rewriteManip.c.

References AddQual(), BooleanTest::arg, BooleanTest::booltesttype, IS_NOT_TRUE, BooleanTest::location, and makeNode.

Referenced by CopyAndAddInvertedQual().

1048 {
1049  BooleanTest *invqual;
1050 
1051  if (qual == NULL)
1052  return;
1053 
1054  /* Need not copy input qual, because AddQual will... */
1055  invqual = makeNode(BooleanTest);
1056  invqual->arg = (Expr *) qual;
1057  invqual->booltesttype = IS_NOT_TRUE;
1058  invqual->location = -1;
1059 
1060  AddQual(parsetree, (Node *) invqual);
1061 }
Definition: nodes.h:525
Expr * arg
Definition: primnodes.h:1242
BoolTestType booltesttype
Definition: primnodes.h:1243
#define makeNode(_type_)
Definition: nodes.h:573
void AddQual(Query *parsetree, Node *qual)
Definition: rewriteManip.c:979

◆ AddQual()

void AddQual ( Query parsetree,
Node qual 
)

Definition at line 979 of file rewriteManip.c.

References Assert, checkExprHasSubLink(), CMD_UTILITY, Query::commandType, contain_aggs_of_level(), copyObject, ereport, errcode(), errmsg(), ERROR, Query::hasSubLinks, IsA, Query::jointree, make_and_qual(), FromExpr::quals, Query::setOperations, and Query::utilityStmt.

Referenced by AddInvertedQual(), rewriteRuleAction(), and rewriteTargetView().

980 {
981  Node *copy;
982 
983  if (qual == NULL)
984  return;
985 
986  if (parsetree->commandType == CMD_UTILITY)
987  {
988  /*
989  * There's noplace to put the qual on a utility statement.
990  *
991  * If it's a NOTIFY, silently ignore the qual; this means that the
992  * NOTIFY will execute, whether or not there are any qualifying rows.
993  * While clearly wrong, this is much more useful than refusing to
994  * execute the rule at all, and extra NOTIFY events are harmless for
995  * typical uses of NOTIFY.
996  *
997  * If it isn't a NOTIFY, error out, since unconditional execution of
998  * other utility stmts is unlikely to be wanted. (This case is not
999  * currently allowed anyway, but keep the test for safety.)
1000  */
1001  if (parsetree->utilityStmt && IsA(parsetree->utilityStmt, NotifyStmt))
1002  return;
1003  else
1004  ereport(ERROR,
1005  (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1006  errmsg("conditional utility statements are not implemented")));
1007  }
1008 
1009  if (parsetree->setOperations != NULL)
1010  {
1011  /*
1012  * There's noplace to put the qual on a setop statement, either. (This
1013  * could be fixed, but right now the planner simply ignores any qual
1014  * condition on a setop query.)
1015  */
1016  ereport(ERROR,
1017  (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1018  errmsg("conditional UNION/INTERSECT/EXCEPT statements are not implemented")));
1019  }
1020 
1021  /* INTERSECT wants the original, but we need to copy - Jan */
1022  copy = copyObject(qual);
1023 
1024  parsetree->jointree->quals = make_and_qual(parsetree->jointree->quals,
1025  copy);
1026 
1027  /*
1028  * We had better not have stuck an aggregate into the WHERE clause.
1029  */
1030  Assert(!contain_aggs_of_level(copy, 0));
1031 
1032  /*
1033  * Make sure query is marked correctly if added qual has sublinks. Need
1034  * not search qual when query is already marked.
1035  */
1036  if (!parsetree->hasSubLinks)
1037  parsetree->hasSubLinks = checkExprHasSubLink(copy);
1038 }
#define IsA(nodeptr, _type_)
Definition: nodes.h:576
FromExpr * jointree
Definition: parsenodes.h:138
bool checkExprHasSubLink(Node *node)
Definition: rewriteManip.c:277
Definition: nodes.h:525
int errcode(int sqlerrcode)
Definition: elog.c:608
Node * make_and_qual(Node *qual1, Node *qual2)
Definition: makefuncs.c:686
Node * utilityStmt
Definition: parsenodes.h:120
Node * quals
Definition: primnodes.h:1511
#define ERROR
Definition: elog.h:43
#define ereport(elevel, rest)
Definition: elog.h:141
CmdType commandType
Definition: parsenodes.h:112
#define Assert(condition)
Definition: c.h:739
bool contain_aggs_of_level(Node *node, int levelsup)
Definition: rewriteManip.c:67
Node * setOperations
Definition: parsenodes.h:165
int errmsg(const char *fmt,...)
Definition: elog.c:822
bool hasSubLinks
Definition: parsenodes.h:128
#define copyObject(obj)
Definition: nodes.h:641

◆ ChangeVarNodes()

void ChangeVarNodes ( Node node,
int  old_varno,
int  new_varno,
int  sublevels_up 
)

Definition at line 610 of file rewriteManip.c.

References ChangeVarNodes_walker(), OnConflictExpr::exclRelIndex, IsA, lfirst, ChangeVarNodes_context::new_index, Query::onConflict, query_tree_walker(), Query::resultRelation, Query::rowMarks, ChangeVarNodes_context::rt_index, RowMarkClause::rti, and ChangeVarNodes_context::sublevels_up.

Referenced by add_security_quals(), add_with_check_options(), ApplyRetrieveRule(), CopyAndAddInvertedQual(), get_relation_constraints(), get_relation_info(), inheritance_planner(), rewriteRuleAction(), rewriteTargetView(), set_baserel_partition_constraint(), set_baserel_partition_key_exprs(), and TriggerEnabled().

611 {
612  ChangeVarNodes_context context;
613 
614  context.rt_index = rt_index;
615  context.new_index = new_index;
616  context.sublevels_up = sublevels_up;
617 
618  /*
619  * Must be prepared to start with a Query or a bare expression tree; if
620  * it's a Query, go straight to query_tree_walker to make sure that
621  * sublevels_up doesn't get incremented prematurely.
622  */
623  if (node && IsA(node, Query))
624  {
625  Query *qry = (Query *) node;
626 
627  /*
628  * If we are starting at a Query, and sublevels_up is zero, then we
629  * must also fix rangetable indexes in the Query itself --- namely
630  * resultRelation and rowMarks entries. sublevels_up cannot be zero
631  * when recursing into a subquery, so there's no need to have the same
632  * logic inside ChangeVarNodes_walker.
633  */
634  if (sublevels_up == 0)
635  {
636  ListCell *l;
637 
638  if (qry->resultRelation == rt_index)
639  qry->resultRelation = new_index;
640 
641  /* this is unlikely to ever be used, but ... */
642  if (qry->onConflict && qry->onConflict->exclRelIndex == rt_index)
643  qry->onConflict->exclRelIndex = new_index;
644 
645  foreach(l, qry->rowMarks)
646  {
647  RowMarkClause *rc = (RowMarkClause *) lfirst(l);
648 
649  if (rc->rti == rt_index)
650  rc->rti = new_index;
651  }
652  }
654  (void *) &context, 0);
655  }
656  else
657  ChangeVarNodes_walker(node, &context);
658 }
bool query_tree_walker(Query *query, bool(*walker)(), void *context, int flags)
Definition: nodeFuncs.c:2273
#define IsA(nodeptr, _type_)
Definition: nodes.h:576
OnConflictExpr * onConflict
Definition: parsenodes.h:144
int resultRelation
Definition: parsenodes.h:122
List * rowMarks
Definition: parsenodes.h:163
#define lfirst(lc)
Definition: pg_list.h:190
static bool ChangeVarNodes_walker(Node *node, ChangeVarNodes_context *context)
Definition: rewriteManip.c:505

◆ checkExprHasSubLink()

bool checkExprHasSubLink ( Node node)

Definition at line 277 of file rewriteManip.c.

References checkExprHasSubLink_walker(), QTW_IGNORE_RC_SUBQUERIES, and query_or_expression_tree_walker().

Referenced by AddQual(), flatten_join_alias_vars_mutator(), RelationBuildRowSecurity(), replace_rte_variables_mutator(), rewriteRuleAction(), and rewriteTargetView().

278 {
279  /*
280  * If a Query is passed, examine it --- but we should not recurse into
281  * sub-Queries that are in its rangetable or CTE list.
282  */
285  NULL,
287 }
static bool checkExprHasSubLink_walker(Node *node, void *context)
Definition: rewriteManip.c:290
#define QTW_IGNORE_RC_SUBQUERIES
Definition: nodeFuncs.h:22
bool query_or_expression_tree_walker(Node *node, bool(*walker)(), void *context, int flags)
Definition: nodeFuncs.c:3363

◆ contain_aggs_of_level()

bool contain_aggs_of_level ( Node node,
int  levelsup 
)

Definition at line 67 of file rewriteManip.c.

References contain_aggs_of_level_walker(), query_or_expression_tree_walker(), and contain_aggs_of_level_context::sublevels_up.

Referenced by AddQual(), checkTargetlistEntrySQL92(), and convert_EXISTS_to_ANY().

68 {
70 
71  context.sublevels_up = levelsup;
72 
73  /*
74  * Must be prepared to start with a Query or a bare expression tree; if
75  * it's a Query, we don't want to increment sublevels_up.
76  */
79  (void *) &context,
80  0);
81 }
bool query_or_expression_tree_walker(Node *node, bool(*walker)(), void *context, int flags)
Definition: nodeFuncs.c:3363
static bool contain_aggs_of_level_walker(Node *node, contain_aggs_of_level_context *context)
Definition: rewriteManip.c:84

◆ contain_windowfuncs()

bool contain_windowfuncs ( Node node)

Definition at line 197 of file rewriteManip.c.

References contain_windowfuncs_walker(), and query_or_expression_tree_walker().

Referenced by checkTargetlistEntrySQL92(), contain_window_function(), and transformWindowFuncCall().

198 {
199  /*
200  * Must be prepared to start with a Query or a bare expression tree; if
201  * it's a Query, we don't want to increment sublevels_up.
202  */
205  NULL,
206  0);
207 }
static bool contain_windowfuncs_walker(Node *node, void *context)
Definition: rewriteManip.c:210
bool query_or_expression_tree_walker(Node *node, bool(*walker)(), void *context, int flags)
Definition: nodeFuncs.c:3363

◆ getInsertSelectQuery()

Query* getInsertSelectQuery ( Query parsetree,
Query ***  subquery_ptr 
)

Definition at line 924 of file rewriteManip.c.

References Assert, CMD_INSERT, CMD_SELECT, Query::commandType, elog, ERROR, FromExpr::fromlist, IsA, Query::jointree, linitial, list_length(), PRS2_NEW_VARNO, PRS2_OLD_VARNO, rt_fetch, Query::rtable, RangeTblRef::rtindex, and RangeTblEntry::subquery.

Referenced by DefineQueryRewrite(), InsertRule(), make_ruledef(), rewriteRuleAction(), and transformRuleStmt().

925 {
926  Query *selectquery;
927  RangeTblEntry *selectrte;
928  RangeTblRef *rtr;
929 
930  if (subquery_ptr)
931  *subquery_ptr = NULL;
932 
933  if (parsetree == NULL)
934  return parsetree;
935  if (parsetree->commandType != CMD_INSERT)
936  return parsetree;
937 
938  /*
939  * Currently, this is ONLY applied to rule-action queries, and so we
940  * expect to find the OLD and NEW placeholder entries in the given query.
941  * If they're not there, it must be an INSERT/SELECT in which they've been
942  * pushed down to the SELECT.
943  */
944  if (list_length(parsetree->rtable) >= 2 &&
945  strcmp(rt_fetch(PRS2_OLD_VARNO, parsetree->rtable)->eref->aliasname,
946  "old") == 0 &&
947  strcmp(rt_fetch(PRS2_NEW_VARNO, parsetree->rtable)->eref->aliasname,
948  "new") == 0)
949  return parsetree;
950  Assert(parsetree->jointree && IsA(parsetree->jointree, FromExpr));
951  if (list_length(parsetree->jointree->fromlist) != 1)
952  elog(ERROR, "expected to find SELECT subquery");
953  rtr = (RangeTblRef *) linitial(parsetree->jointree->fromlist);
954  Assert(IsA(rtr, RangeTblRef));
955  selectrte = rt_fetch(rtr->rtindex, parsetree->rtable);
956  selectquery = selectrte->subquery;
957  if (!(selectquery && IsA(selectquery, Query) &&
958  selectquery->commandType == CMD_SELECT))
959  elog(ERROR, "expected to find SELECT subquery");
960  if (list_length(selectquery->rtable) >= 2 &&
961  strcmp(rt_fetch(PRS2_OLD_VARNO, selectquery->rtable)->eref->aliasname,
962  "old") == 0 &&
963  strcmp(rt_fetch(PRS2_NEW_VARNO, selectquery->rtable)->eref->aliasname,
964  "new") == 0)
965  {
966  if (subquery_ptr)
967  *subquery_ptr = &(selectrte->subquery);
968  return selectquery;
969  }
970  elog(ERROR, "could not find rule placeholders");
971  return NULL; /* not reached */
972 }
#define IsA(nodeptr, _type_)
Definition: nodes.h:576
FromExpr * jointree
Definition: parsenodes.h:138
List * fromlist
Definition: primnodes.h:1510
#define linitial(l)
Definition: pg_list.h:195
List * rtable
Definition: parsenodes.h:137
#define ERROR
Definition: elog.h:43
#define rt_fetch(rangetable_index, rangetable)
Definition: parsetree.h:31
#define PRS2_OLD_VARNO
Definition: primnodes.h:178
CmdType commandType
Definition: parsenodes.h:112
#define Assert(condition)
Definition: c.h:739
static int list_length(const List *l)
Definition: pg_list.h:169
Query * subquery
Definition: parsenodes.h:1009
#define elog(elevel,...)
Definition: elog.h:228
#define PRS2_NEW_VARNO
Definition: primnodes.h:179

◆ IncrementVarSublevelsUp()

void IncrementVarSublevelsUp ( Node node,
int  delta_sublevels_up,
int  min_sublevels_up 
)

Definition at line 776 of file rewriteManip.c.

References IncrementVarSublevelsUp_context::delta_sublevels_up, IncrementVarSublevelsUp_walker(), IncrementVarSublevelsUp_context::min_sublevels_up, QTW_EXAMINE_RTES_BEFORE, and query_or_expression_tree_walker().

Referenced by assign_param_for_placeholdervar(), build_minmax_path(), convert_EXISTS_sublink_to_join(), convert_EXISTS_to_ANY(), extract_lateral_references(), flatten_join_alias_vars_mutator(), inline_cte_walker(), pull_up_simple_subquery(), pullup_replace_vars_callback(), replace_outer_agg(), replace_outer_grouping(), ReplaceVarsFromTargetList_callback(), and substitute_actual_srf_parameters_mutator().

778 {
780 
781  context.delta_sublevels_up = delta_sublevels_up;
782  context.min_sublevels_up = min_sublevels_up;
783 
784  /*
785  * Must be prepared to start with a Query or a bare expression tree; if
786  * it's a Query, we don't want to increment sublevels_up.
787  */
790  (void *) &context,
792 }
#define QTW_EXAMINE_RTES_BEFORE
Definition: nodeFuncs.h:25
static bool IncrementVarSublevelsUp_walker(Node *node, IncrementVarSublevelsUp_context *context)
Definition: rewriteManip.c:703
bool query_or_expression_tree_walker(Node *node, bool(*walker)(), void *context, int flags)
Definition: nodeFuncs.c:3363

◆ IncrementVarSublevelsUp_rtable()

void IncrementVarSublevelsUp_rtable ( List rtable,
int  delta_sublevels_up,
int  min_sublevels_up 
)

Definition at line 799 of file rewriteManip.c.

References IncrementVarSublevelsUp_context::delta_sublevels_up, IncrementVarSublevelsUp_walker(), IncrementVarSublevelsUp_context::min_sublevels_up, QTW_EXAMINE_RTES_BEFORE, and range_table_walker().

Referenced by pull_up_simple_union_all().

801 {
803 
804  context.delta_sublevels_up = delta_sublevels_up;
805  context.min_sublevels_up = min_sublevels_up;
806 
807  range_table_walker(rtable,
809  (void *) &context,
811 }
#define QTW_EXAMINE_RTES_BEFORE
Definition: nodeFuncs.h:25
static bool IncrementVarSublevelsUp_walker(Node *node, IncrementVarSublevelsUp_context *context)
Definition: rewriteManip.c:703
bool range_table_walker(List *rtable, bool(*walker)(), void *context, int flags)
Definition: nodeFuncs.c:2372

◆ locate_agg_of_level()

int locate_agg_of_level ( Node node,
int  levelsup 
)

Definition at line 131 of file rewriteManip.c.

References locate_agg_of_level_context::agg_location, locate_agg_of_level_walker(), query_or_expression_tree_walker(), and locate_agg_of_level_context::sublevels_up.

Referenced by check_agg_arguments(), checkTargetlistEntrySQL92(), and parseCheckAggregates().

132 {
134 
135  context.agg_location = -1; /* in case we find nothing */
136  context.sublevels_up = levelsup;
137 
138  /*
139  * Must be prepared to start with a Query or a bare expression tree; if
140  * it's a Query, we don't want to increment sublevels_up.
141  */
144  (void *) &context,
145  0);
146 
147  return context.agg_location;
148 }
bool query_or_expression_tree_walker(Node *node, bool(*walker)(), void *context, int flags)
Definition: nodeFuncs.c:3363
static bool locate_agg_of_level_walker(Node *node, locate_agg_of_level_context *context)
Definition: rewriteManip.c:151

◆ locate_windowfunc()

int locate_windowfunc ( Node node)

Definition at line 235 of file rewriteManip.c.

References locate_windowfunc_walker(), query_or_expression_tree_walker(), and locate_windowfunc_context::win_location.

Referenced by checkTargetlistEntrySQL92(), and transformWindowFuncCall().

236 {
238 
239  context.win_location = -1; /* in case we find nothing */
240 
241  /*
242  * Must be prepared to start with a Query or a bare expression tree; if
243  * it's a Query, we don't want to increment sublevels_up.
244  */
247  (void *) &context,
248  0);
249 
250  return context.win_location;
251 }
bool query_or_expression_tree_walker(Node *node, bool(*walker)(), void *context, int flags)
Definition: nodeFuncs.c:3363
static bool locate_windowfunc_walker(Node *node, locate_windowfunc_context *context)
Definition: rewriteManip.c:254

◆ map_variable_attnos()

Node* map_variable_attnos ( Node node,
int  target_varno,
int  sublevels_up,
const struct AttrMap attno_map,
Oid  to_rowtype,
bool found_whole_row 
)

◆ OffsetVarNodes()

void OffsetVarNodes ( Node node,
int  offset,
int  sublevels_up 
)

Definition at line 425 of file rewriteManip.c.

References OnConflictExpr::exclRelIndex, IsA, lfirst, OffsetVarNodes_context::offset, OffsetVarNodes_walker(), Query::onConflict, query_tree_walker(), Query::resultRelation, Query::rowMarks, RowMarkClause::rti, and OffsetVarNodes_context::sublevels_up.

Referenced by convert_EXISTS_sublink_to_join(), pull_up_simple_subquery(), rewriteRuleAction(), and UpdateRangeTableOfViewParse().

426 {
427  OffsetVarNodes_context context;
428 
429  context.offset = offset;
430  context.sublevels_up = sublevels_up;
431 
432  /*
433  * Must be prepared to start with a Query or a bare expression tree; if
434  * it's a Query, go straight to query_tree_walker to make sure that
435  * sublevels_up doesn't get incremented prematurely.
436  */
437  if (node && IsA(node, Query))
438  {
439  Query *qry = (Query *) node;
440 
441  /*
442  * If we are starting at a Query, and sublevels_up is zero, then we
443  * must also fix rangetable indexes in the Query itself --- namely
444  * resultRelation, exclRelIndex and rowMarks entries. sublevels_up
445  * cannot be zero when recursing into a subquery, so there's no need
446  * to have the same logic inside OffsetVarNodes_walker.
447  */
448  if (sublevels_up == 0)
449  {
450  ListCell *l;
451 
452  if (qry->resultRelation)
453  qry->resultRelation += offset;
454 
455  if (qry->onConflict && qry->onConflict->exclRelIndex)
456  qry->onConflict->exclRelIndex += offset;
457 
458  foreach(l, qry->rowMarks)
459  {
460  RowMarkClause *rc = (RowMarkClause *) lfirst(l);
461 
462  rc->rti += offset;
463  }
464  }
466  (void *) &context, 0);
467  }
468  else
469  OffsetVarNodes_walker(node, &context);
470 }
bool query_tree_walker(Query *query, bool(*walker)(), void *context, int flags)
Definition: nodeFuncs.c:2273
#define IsA(nodeptr, _type_)
Definition: nodes.h:576
OnConflictExpr * onConflict
Definition: parsenodes.h:144
int resultRelation
Definition: parsenodes.h:122
static bool OffsetVarNodes_walker(Node *node, OffsetVarNodes_context *context)
Definition: rewriteManip.c:340
List * rowMarks
Definition: parsenodes.h:163
#define lfirst(lc)
Definition: pg_list.h:190

◆ rangeTableEntry_used()

bool rangeTableEntry_used ( Node node,
int  rt_index,
int  sublevels_up 
)

Definition at line 892 of file rewriteManip.c.

References query_or_expression_tree_walker(), rangeTableEntry_used_walker(), rangeTableEntry_used_context::rt_index, and rangeTableEntry_used_context::sublevels_up.

Referenced by fireRIRrules(), matchLocks(), rewriteRuleAction(), and transformRuleStmt().

893 {
895 
896  context.rt_index = rt_index;
897  context.sublevels_up = sublevels_up;
898 
899  /*
900  * Must be prepared to start with a Query or a bare expression tree; if
901  * it's a Query, we don't want to increment sublevels_up.
902  */
905  (void *) &context,
906  0);
907 }
bool query_or_expression_tree_walker(Node *node, bool(*walker)(), void *context, int flags)
Definition: nodeFuncs.c:3363
static bool rangeTableEntry_used_walker(Node *node, rangeTableEntry_used_context *context)
Definition: rewriteManip.c:826

◆ replace_rte_variables()

Node* replace_rte_variables ( Node node,
int  target_varno,
int  sublevels_up,
replace_rte_variables_callback  callback,
void *  callback_arg,
bool outer_hasSubLinks 
)

Definition at line 1087 of file rewriteManip.c.

References replace_rte_variables_context::callback, callback(), replace_rte_variables_context::callback_arg, elog, ERROR, replace_rte_variables_context::inserted_sublink, IsA, query_or_expression_tree_mutator(), replace_rte_variables_mutator(), replace_rte_variables_context::sublevels_up, and replace_rte_variables_context::target_varno.

Referenced by pullup_replace_vars(), pullup_replace_vars_subquery(), and ReplaceVarsFromTargetList().

1091 {
1092  Node *result;
1094 
1095  context.callback = callback;
1096  context.callback_arg = callback_arg;
1097  context.target_varno = target_varno;
1098  context.sublevels_up = sublevels_up;
1099 
1100  /*
1101  * We try to initialize inserted_sublink to true if there is no need to
1102  * detect new sublinks because the query already has some.
1103  */
1104  if (node && IsA(node, Query))
1105  context.inserted_sublink = ((Query *) node)->hasSubLinks;
1106  else if (outer_hasSubLinks)
1107  context.inserted_sublink = *outer_hasSubLinks;
1108  else
1109  context.inserted_sublink = false;
1110 
1111  /*
1112  * Must be prepared to start with a Query or a bare expression tree; if
1113  * it's a Query, we don't want to increment sublevels_up.
1114  */
1115  result = query_or_expression_tree_mutator(node,
1117  (void *) &context,
1118  0);
1119 
1120  if (context.inserted_sublink)
1121  {
1122  if (result && IsA(result, Query))
1123  ((Query *) result)->hasSubLinks = true;
1124  else if (outer_hasSubLinks)
1125  *outer_hasSubLinks = true;
1126  else
1127  elog(ERROR, "replace_rte_variables inserted a SubLink, but has noplace to record it");
1128  }
1129 
1130  return result;
1131 }
#define IsA(nodeptr, _type_)
Definition: nodes.h:576
Definition: nodes.h:525
replace_rte_variables_callback callback
Definition: rewriteManip.h:29
#define ERROR
Definition: elog.h:43
Node * replace_rte_variables_mutator(Node *node, replace_rte_variables_context *context)
static void callback(struct sockaddr *addr, struct sockaddr *mask, void *unused)
Definition: test_ifaddrs.c:48
Node * query_or_expression_tree_mutator(Node *node, Node *(*mutator)(), void *context, int flags)
Definition: nodeFuncs.c:3386
#define elog(elevel,...)
Definition: elog.h:228

◆ replace_rte_variables_mutator()

Node* replace_rte_variables_mutator ( Node node,
replace_rte_variables_context context 
)

Definition at line 1134 of file rewriteManip.c.

References replace_rte_variables_context::callback, checkExprHasSubLink(), CurrentOfExpr::cvarno, ereport, errcode(), errmsg(), ERROR, expression_tree_mutator(), Query::hasSubLinks, replace_rte_variables_context::inserted_sublink, IsA, query_tree_mutator(), replace_rte_variables_mutator(), replace_rte_variables_context::sublevels_up, replace_rte_variables_context::target_varno, Var::varlevelsup, and Var::varno.

Referenced by pullup_replace_vars_callback(), replace_rte_variables(), replace_rte_variables_mutator(), and ReplaceVarsFromTargetList_callback().

1136 {
1137  if (node == NULL)
1138  return NULL;
1139  if (IsA(node, Var))
1140  {
1141  Var *var = (Var *) node;
1142 
1143  if (var->varno == context->target_varno &&
1144  var->varlevelsup == context->sublevels_up)
1145  {
1146  /* Found a matching variable, make the substitution */
1147  Node *newnode;
1148 
1149  newnode = context->callback(var, context);
1150  /* Detect if we are adding a sublink to query */
1151  if (!context->inserted_sublink)
1152  context->inserted_sublink = checkExprHasSubLink(newnode);
1153  return newnode;
1154  }
1155  /* otherwise fall through to copy the var normally */
1156  }
1157  else if (IsA(node, CurrentOfExpr))
1158  {
1159  CurrentOfExpr *cexpr = (CurrentOfExpr *) node;
1160 
1161  if (cexpr->cvarno == context->target_varno &&
1162  context->sublevels_up == 0)
1163  {
1164  /*
1165  * We get here if a WHERE CURRENT OF expression turns out to apply
1166  * to a view. Someday we might be able to translate the
1167  * expression to apply to an underlying table of the view, but
1168  * right now it's not implemented.
1169  */
1170  ereport(ERROR,
1171  (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1172  errmsg("WHERE CURRENT OF on a view is not implemented")));
1173  }
1174  /* otherwise fall through to copy the expr normally */
1175  }
1176  else if (IsA(node, Query))
1177  {
1178  /* Recurse into RTE subquery or not-yet-planned sublink subquery */
1179  Query *newnode;
1180  bool save_inserted_sublink;
1181 
1182  context->sublevels_up++;
1183  save_inserted_sublink = context->inserted_sublink;
1184  context->inserted_sublink = ((Query *) node)->hasSubLinks;
1185  newnode = query_tree_mutator((Query *) node,
1187  (void *) context,
1188  0);
1189  newnode->hasSubLinks |= context->inserted_sublink;
1190  context->inserted_sublink = save_inserted_sublink;
1191  context->sublevels_up--;
1192  return (Node *) newnode;
1193  }
1195  (void *) context);
1196 }
#define IsA(nodeptr, _type_)
Definition: nodes.h:576
Index varlevelsup
Definition: primnodes.h:191
Node * expression_tree_mutator(Node *node, Node *(*mutator)(), void *context)
Definition: nodeFuncs.c:2516
bool checkExprHasSubLink(Node *node)
Definition: rewriteManip.c:277
Definition: nodes.h:525
int errcode(int sqlerrcode)
Definition: elog.c:608
replace_rte_variables_callback callback
Definition: rewriteManip.h:29
Definition: primnodes.h:181
#define ERROR
Definition: elog.h:43
Node * replace_rte_variables_mutator(Node *node, replace_rte_variables_context *context)
#define ereport(elevel, rest)
Definition: elog.h:141
Index varno
Definition: primnodes.h:184
int errmsg(const char *fmt,...)
Definition: elog.c:822
bool hasSubLinks
Definition: parsenodes.h:128
Query * query_tree_mutator(Query *query, Node *(*mutator)(), void *context, int flags)
Definition: nodeFuncs.c:3202

◆ ReplaceVarsFromTargetList()

Node* ReplaceVarsFromTargetList ( Node node,
int  target_varno,
int  sublevels_up,
RangeTblEntry target_rte,
List targetlist,
ReplaceVarsNoMatchOption  nomatch_option,
int  nomatch_varno,
bool outer_hasSubLinks 
)

Definition at line 1514 of file rewriteManip.c.

References ReplaceVarsFromTargetList_context::nomatch_option, ReplaceVarsFromTargetList_context::nomatch_varno, replace_rte_variables(), ReplaceVarsFromTargetList_callback(), ReplaceVarsFromTargetList_context::target_rte, and ReplaceVarsFromTargetList_context::targetlist.

Referenced by CopyAndAddInvertedQual(), rewriteRuleAction(), rewriteTargetView(), and subquery_push_qual().

1521 {
1523 
1524  context.target_rte = target_rte;
1525  context.targetlist = targetlist;
1526  context.nomatch_option = nomatch_option;
1527  context.nomatch_varno = nomatch_varno;
1528 
1529  return replace_rte_variables(node, target_varno, sublevels_up,
1531  (void *) &context,
1532  outer_hasSubLinks);
1533 }
static Node * ReplaceVarsFromTargetList_callback(Var *var, replace_rte_variables_context *context)
Node * replace_rte_variables(Node *node, int target_varno, int sublevels_up, replace_rte_variables_callback callback, void *callback_arg, bool *outer_hasSubLinks)
ReplaceVarsNoMatchOption nomatch_option