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);
785 elog(
ERROR,
"cannot push down CurrentOfExpr");
833 context->min_sublevels_up--;
842 int min_sublevels_up)
865 int min_sublevels_up)
949 (
void *) context, 0);
950 context->sublevels_up--;
997 *subquery_ptr = NULL;
999 if (parsetree == NULL)
1018 elog(
ERROR,
"expected to find SELECT subquery");
1021 elog(
ERROR,
"expected to find SELECT subquery");
1027 elog(
ERROR,
"expected to find SELECT subquery");
1036 *subquery_ptr = &(selectrte->
subquery);
1039 elog(
ERROR,
"could not find rule placeholders");
1074 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1075 errmsg(
"conditional utility statements are not implemented")));
1086 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1087 errmsg(
"conditional UNION/INTERSECT/EXCEPT statements are not implemented")));
1105 if (!parsetree->hasSubLinks)
1173 var->varnullingrels = newnullingrels;
1174 return (
Node *) var;
1198 return (
Node *) phv;
1212 context->sublevels_up--;
1213 return (
Node *) newnode;
1260 return (
Node *) var;
1289 return (
Node *) phv;
1303 context->sublevels_up--;
1304 return (
Node *) newnode;
1337 bool *outer_hasSubLinks)
1353 else if (outer_hasSubLinks)
1370 ((
Query *) result)->hasSubLinks =
true;
1371 else if (outer_hasSubLinks)
1372 *outer_hasSubLinks =
true;
1374 elog(
ERROR,
"replace_rte_variables inserted a SubLink, but has noplace to record it");
1396 newnode = context->
callback(var, context);
1418 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1419 errmsg(
"WHERE CURRENT OF on a view is not implemented")));
1427 bool save_inserted_sublink;
1436 newnode->hasSubLinks |= context->inserted_sublink;
1437 context->inserted_sublink = save_inserted_sublink;
1438 context->sublevels_up--;
1439 return (
Node *) newnode;
1503 elog(
ERROR,
"unexpected varattno %d in expression to be mapped",
1508 newvar->varattnosyn = newvar->
varattno;
1510 else if (attno == 0)
1522 Assert(var->vartype != RECORDOID);
1540 return (
Node *) newvar;
1572 Assert(var->vartype != RECORDOID);
1579 newnode->
arg = (
Expr *) newvar;
1581 return (
Node *) newnode;
1595 context->sublevels_up--;
1596 return (
Node *) newnode;
1604 int target_varno,
int sublevels_up,
1606 Oid to_rowtype,
bool *found_whole_row)
1616 *found_whole_row =
false;
1679 (var->vartype != RECORDOID),
1680 &colnames, &fields);
1685 rowexpr->
args = fields;
1686 rowexpr->row_typeid = var->vartype;
1688 rowexpr->colnames = (var->vartype == RECORDOID) ? colnames :
NIL;
1691 return (
Node *) rowexpr;
1697 if (tle == NULL || tle->resjunk)
1710 return (
Node *) var;
1728 elog(
ERROR,
"could not find replacement targetlist entry for attno %d",
1753 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1754 errmsg(
"NEW variables in ON UPDATE rules cannot reference columns that are part of a multiple assignment in the subject UPDATE command")));
1756 return (
Node *) newnode;
1762 int target_varno,
int sublevels_up,
1767 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)
#define IS_SPECIAL_VARNO(varno)
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)