127 (
void *) context, 0);
128 context->sublevels_up--;
177 ((
Aggref *) node)->location >= 0)
201 (
void *) context, 0);
202 context->sublevels_up--;
351 List *src_rtable,
List *src_perminfos)
358 foreach(l, src_rtable)
367 *dst_perminfos =
list_concat(*dst_perminfos, src_perminfos);
368 *dst_rtable =
list_concat(*dst_rtable, src_rtable);
404 if (var->varnosyn > 0)
405 var->varnosyn += context->
offset;
471 (
void *) context, 0);
472 context->sublevels_up--;
503 if (sublevels_up == 0)
507 if (qry->resultRelation)
508 qry->resultRelation += offset;
521 (
void *) &context, 0);
575 if (var->varnosyn == context->
rt_index)
661 (
void *) context, 0);
662 context->sublevels_up--;
694 if (sublevels_up == 0)
698 if (qry->resultRelation == rt_index)
699 qry->resultRelation = new_index;
709 if (rc->
rti == rt_index)
714 (
void *) &context, 0);
780 elog(
ERROR,
"cannot push down CurrentOfExpr");
828 context->min_sublevels_up--;
837 int min_sublevels_up)
860 int min_sublevels_up)
944 (
void *) context, 0);
945 context->sublevels_up--;
992 *subquery_ptr = NULL;
994 if (parsetree == NULL)
1013 elog(
ERROR,
"expected to find SELECT subquery");
1016 elog(
ERROR,
"expected to find SELECT subquery");
1022 elog(
ERROR,
"expected to find SELECT subquery");
1031 *subquery_ptr = &(selectrte->
subquery);
1034 elog(
ERROR,
"could not find rule placeholders");
1069 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1070 errmsg(
"conditional utility statements are not implemented")));
1081 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1082 errmsg(
"conditional UNION/INTERSECT/EXCEPT statements are not implemented")));
1100 if (!parsetree->hasSubLinks)
1168 var->varnullingrels = newnullingrels;
1169 return (
Node *) var;
1193 return (
Node *) phv;
1207 context->sublevels_up--;
1208 return (
Node *) newnode;
1255 return (
Node *) var;
1284 return (
Node *) phv;
1298 context->sublevels_up--;
1299 return (
Node *) newnode;
1332 bool *outer_hasSubLinks)
1348 else if (outer_hasSubLinks)
1365 ((
Query *) result)->hasSubLinks =
true;
1366 else if (outer_hasSubLinks)
1367 *outer_hasSubLinks =
true;
1369 elog(
ERROR,
"replace_rte_variables inserted a SubLink, but has noplace to record it");
1391 newnode = context->
callback(var, context);
1413 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1414 errmsg(
"WHERE CURRENT OF on a view is not implemented")));
1422 bool save_inserted_sublink;
1431 newnode->hasSubLinks |= context->inserted_sublink;
1432 context->inserted_sublink = save_inserted_sublink;
1433 context->sublevels_up--;
1434 return (
Node *) newnode;
1498 elog(
ERROR,
"unexpected varattno %d in expression to be mapped",
1503 newvar->varattnosyn = newvar->
varattno;
1505 else if (attno == 0)
1517 Assert(var->vartype != RECORDOID);
1535 return (
Node *) newvar;
1567 Assert(var->vartype != RECORDOID);
1574 newnode->
arg = (
Expr *) newvar;
1576 return (
Node *) newnode;
1590 context->sublevels_up--;
1591 return (
Node *) newnode;
1599 int target_varno,
int sublevels_up,
1601 Oid to_rowtype,
bool *found_whole_row)
1611 *found_whole_row =
false;
1674 (var->vartype != RECORDOID),
1675 &colnames, &fields);
1680 rowexpr->
args = fields;
1681 rowexpr->row_typeid = var->vartype;
1683 rowexpr->colnames = (var->vartype == RECORDOID) ? colnames :
NIL;
1686 return (
Node *) rowexpr;
1692 if (tle == NULL || tle->resjunk)
1705 return (
Node *) var;
1723 elog(
ERROR,
"could not find replacement targetlist entry for attno %d",
1748 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1749 errmsg(
"NEW variables in ON UPDATE rules cannot reference columns that are part of a multiple assignment in the subject UPDATE command")));
1751 return (
Node *) newnode;
1757 int target_varno,
int sublevels_up,
1762 bool *outer_hasSubLinks)
#define InvalidAttrNumber
int bms_next_member(const Bitmapset *a, int prevbit)
bool bms_is_member(int x, const Bitmapset *a)
Bitmapset * bms_add_member(Bitmapset *a, int x)
Bitmapset * bms_union(const Bitmapset *a, const Bitmapset *b)
Bitmapset * bms_difference(const Bitmapset *a, const Bitmapset *b)
Bitmapset * bms_del_member(Bitmapset *a, int x)
bool bms_overlap(const Bitmapset *a, const Bitmapset *b)
Bitmapset * bms_copy(const Bitmapset *a)
#define OidIsValid(objectId)
elog(ERROR, "%s: %s", p2, msg)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
if(TABLE==NULL||TABLE_index==NULL)
Assert(fmt[strlen(fmt) - 1] !='\n')
List * list_concat(List *list1, const List *list2)
Const * makeNullConst(Oid consttype, int32 consttypmod, Oid constcollid)
Node * make_and_qual(Node *qual1, Node *qual2)
#define expression_tree_mutator(n, m, c)
#define query_or_expression_tree_mutator(n, m, c, f)
#define range_table_walker(rt, w, c, f)
#define query_tree_walker(q, w, c, f)
#define query_or_expression_tree_walker(n, w, c, f)
#define expression_tree_walker(n, w, c)
#define query_tree_mutator(q, m, c, f)
#define QTW_IGNORE_RC_SUBQUERIES
#define QTW_EXAMINE_RTES_BEFORE
#define IsA(nodeptr, _type_)
Node * coerce_to_domain(Node *arg, Oid baseTypeId, int32 baseTypeMod, Oid typeId, CoercionContext ccontext, CoercionForm cformat, int location, bool hideInputCoercion)
TargetEntry * get_tle_by_resno(List *tlist, AttrNumber resno)
void expandRTE(RangeTblEntry *rte, int rtindex, int sublevels_up, int location, bool include_dropped, List **colnames, List **colvars)
#define rt_fetch(rangetable_index, rangetable)
#define lfirst_node(type, lc)
static int list_length(const List *l)
bool contain_windowfuncs(Node *node)
static Node * remove_nulling_relids_mutator(Node *node, remove_nulling_relids_context *context)
Node * ReplaceVarsFromTargetList(Node *node, int target_varno, int sublevels_up, RangeTblEntry *target_rte, List *targetlist, ReplaceVarsNoMatchOption nomatch_option, int nomatch_varno, bool *outer_hasSubLinks)
void IncrementVarSublevelsUp_rtable(List *rtable, int delta_sublevels_up, int min_sublevels_up)
void ChangeVarNodes(Node *node, int rt_index, int new_index, int sublevels_up)
static bool contain_windowfuncs_walker(Node *node, void *context)
static Relids adjust_relid_set(Relids relids, int oldrelid, int newrelid)
Node * replace_rte_variables_mutator(Node *node, replace_rte_variables_context *context)
static bool contains_multiexpr_param(Node *node, void *context)
void OffsetVarNodes(Node *node, int offset, int sublevels_up)
bool checkExprHasSubLink(Node *node)
Node * map_variable_attnos(Node *node, int target_varno, int sublevels_up, const AttrMap *attno_map, Oid to_rowtype, bool *found_whole_row)
static bool locate_windowfunc_walker(Node *node, locate_windowfunc_context *context)
Query * getInsertSelectQuery(Query *parsetree, Query ***subquery_ptr)
void CombineRangeTables(List **dst_rtable, List **dst_perminfos, List *src_rtable, List *src_perminfos)
static bool rangeTableEntry_used_walker(Node *node, rangeTableEntry_used_context *context)
void AddQual(Query *parsetree, Node *qual)
Node * remove_nulling_relids(Node *node, const Bitmapset *removable_relids, const Bitmapset *except_relids)
Node * replace_rte_variables(Node *node, int target_varno, int sublevels_up, replace_rte_variables_callback callback, void *callback_arg, bool *outer_hasSubLinks)
int locate_agg_of_level(Node *node, int levelsup)
static bool checkExprHasSubLink_walker(Node *node, void *context)
static bool IncrementVarSublevelsUp_walker(Node *node, IncrementVarSublevelsUp_context *context)
static bool ChangeVarNodes_walker(Node *node, ChangeVarNodes_context *context)
static bool locate_agg_of_level_walker(Node *node, locate_agg_of_level_context *context)
bool rangeTableEntry_used(Node *node, int rt_index, int sublevels_up)
static bool contain_aggs_of_level_walker(Node *node, contain_aggs_of_level_context *context)
bool contain_aggs_of_level(Node *node, int levelsup)
int locate_windowfunc(Node *node)
void AddInvertedQual(Query *parsetree, Node *qual)
static bool OffsetVarNodes_walker(Node *node, OffsetVarNodes_context *context)
Node * add_nulling_relids(Node *node, const Bitmapset *target_relids, const Bitmapset *added_relids)
static Node * ReplaceVarsFromTargetList_callback(Var *var, replace_rte_variables_context *context)
static Node * map_variable_attnos_mutator(Node *node, map_variable_attnos_context *context)
static Node * add_nulling_relids_mutator(Node *node, add_nulling_relids_context *context)
void IncrementVarSublevelsUp(Node *node, int delta_sublevels_up, int min_sublevels_up)
static Relids offset_relid_set(Relids relids, int offset)
Node *(* replace_rte_variables_callback)(Var *var, replace_rte_variables_context *context)
@ REPLACEVARS_SUBSTITUTE_NULL
@ REPLACEVARS_CHANGE_VARNO
@ REPLACEVARS_REPORT_ERROR
BoolTestType booltesttype
OnConflictExpr * onConflict
ReplaceVarsNoMatchOption nomatch_option
RangeTblEntry * target_rte
const Bitmapset * target_relids
const Bitmapset * added_relids
const AttrMap * attno_map
const Bitmapset * removable_relids
const Bitmapset * except_relids
replace_rte_variables_callback callback
static void callback(struct sockaddr *addr, struct sockaddr *mask, void *unused)