116#define NUM_EXEC_TLIST(parentplan) ((parentplan)->plan_rows)
117#define NUM_EXEC_QUAL(parentplan) ((parentplan)->plan_rows * 2.0)
126#define ISREGCLASSCONST(con) \
127 (((con)->consttype == REGCLASSOID || (con)->consttype == OIDOID) && \
130#define fix_scan_list(root, lst, rtoffset, num_exec) \
131 ((List *) fix_scan_expr(root, (Node *) (lst), rtoffset, num_exec))
161 int rtoffset,
double num_exec);
190 Index acceptable_rel,
208 Index resultRelation,
305 foreach(lc,
root->rowMarks)
315 newrc->
rti += rtoffset;
316 newrc->
prti += rtoffset;
326 foreach(lc,
root->append_rel_list)
344 if (
root->hasAlternativeSubPlans)
346 root->isAltSubplan = (
bool *)
348 root->isUsedSubplan = (
bool *)
363 if (
root->hasAlternativeSubPlans)
375 if (
root->isAltSubplan[ndx] && !
root->isUsedSubplan[ndx])
406 foreach(lc,
root->parse->rtable)
426 foreach(lc,
root->parse->rtable)
437 rti < root->simple_rel_array_size)
466 else if (recursing ||
521 cxt->
query = save_query;
550 newrte->joinaliasvars =
NIL;
551 newrte->joinleftcols =
NIL;
552 newrte->joinrightcols =
NIL;
553 newrte->join_using_alias = NULL;
557 newrte->coltypes =
NIL;
558 newrte->coltypmods =
NIL;
559 newrte->colcollations =
NIL;
560 newrte->groupexprs =
NIL;
561 newrte->securityQuals =
NIL;
591 if (rte->perminfoindex > 0)
605 newrte->perminfoindex = 0;
623 plan->plan_node_id =
root->glob->lastPlanNodeId++;
634 splan->scan.scanrelid += rtoffset;
635 splan->scan.plan.targetlist =
638 splan->scan.plan.qual =
647 splan->scan.scanrelid += rtoffset;
648 splan->scan.plan.targetlist =
651 splan->scan.plan.qual =
663 splan->scan.scanrelid += rtoffset;
664 splan->scan.plan.targetlist =
667 splan->scan.plan.qual =
673 splan->indexqualorig =
676 splan->indexorderby =
679 splan->indexorderbyorig =
684 case T_IndexOnlyScan:
691 case T_BitmapIndexScan:
695 splan->scan.scanrelid += rtoffset;
701 splan->indexqualorig =
706 case T_BitmapHeapScan:
710 splan->scan.scanrelid += rtoffset;
711 splan->scan.plan.targetlist =
714 splan->scan.plan.qual =
717 splan->bitmapqualorig =
726 splan->scan.scanrelid += rtoffset;
727 splan->scan.plan.targetlist =
730 splan->scan.plan.qual =
742 splan->scan.scanrelid += rtoffset;
743 splan->scan.plan.targetlist =
746 splan->scan.plan.qual =
749 splan->tidrangequals =
763 splan->scan.scanrelid += rtoffset;
764 splan->scan.plan.targetlist =
767 splan->scan.plan.qual =
774 case T_TableFuncScan:
778 splan->scan.scanrelid += rtoffset;
779 splan->scan.plan.targetlist =
782 splan->scan.plan.qual =
794 splan->scan.scanrelid += rtoffset;
795 splan->scan.plan.targetlist =
798 splan->scan.plan.qual =
801 splan->values_lists =
810 splan->scan.scanrelid += rtoffset;
811 splan->scan.plan.targetlist =
814 splan->scan.plan.qual =
819 case T_NamedTuplestoreScan:
823 splan->scan.scanrelid += rtoffset;
824 splan->scan.plan.targetlist =
827 splan->scan.plan.qual =
832 case T_WorkTableScan:
836 splan->scan.scanrelid += rtoffset;
837 splan->scan.plan.targetlist =
840 splan->scan.plan.qual =
888 case T_IncrementalSort:
919 foreach(l,
splan->rowMarks)
924 rc->
prti += rtoffset;
1018 if (
splan->plan.lefttree != NULL)
1034 foreach(l,
splan->plan.targetlist)
1045 splan->plan.targetlist =
1053 splan->resconstantqual =
1068 splan->withCheckOptionLists =
1072 if (
splan->returningLists)
1084 lcrr,
splan->resultRelations)
1094 newRL =
lappend(newRL, rlist);
1096 splan->returningLists = newRL;
1117 if (
splan->onConflictSet)
1123 splan->onConflictSet =
1137 splan->exclRelTlist =
1151 if (
splan->mergeActionLists !=
NIL)
1177 lcj,
splan->mergeJoinConditions,
1178 lcr,
splan->resultRelations)
1184 foreach(l, mergeActionList)
1208 mergeJoinCondition = (
Node *)
1210 (
List *) mergeJoinCondition,
1216 newMJC =
lappend(newMJC, mergeJoinCondition);
1218 splan->mergeJoinConditions = newMJC;
1221 splan->nominalRelation += rtoffset;
1222 if (
splan->rootRelation)
1223 splan->rootRelation += rtoffset;
1224 splan->exclRelRTI += rtoffset;
1226 foreach(l,
splan->resultRelations)
1230 foreach(l,
splan->rowMarks)
1234 rc->
rti += rtoffset;
1235 rc->
prti += rtoffset;
1242 root->glob->resultRelations =
1244 splan->resultRelations);
1245 if (
splan->rootRelation)
1247 root->glob->resultRelations =
1249 splan->rootRelation);
1251 root->glob->firstResultRels =
1266 case T_RecursiveUnion:
1278 foreach(l,
splan->bitmapplans)
1293 foreach(l,
splan->bitmapplans)
1302 elog(
ERROR,
"unrecognized node type: %d",
1336 List *stripped_indextlist;
1346 stripped_indextlist =
NIL;
1347 foreach(lc,
plan->indextlist)
1351 if (!indextle->resjunk)
1352 stripped_indextlist =
lappend(stripped_indextlist, indextle);
1357 plan->scan.scanrelid += rtoffset;
1358 plan->scan.plan.targetlist = (
List *)
1360 (
Node *)
plan->scan.plan.targetlist,
1392 pfree(index_itlist);
1434 plan->scan.scanrelid += rtoffset;
1435 plan->scan.plan.targetlist =
1438 plan->scan.plan.qual =
1489 if (
plan->scan.plan.qual !=
NIL)
1497 forboth(lp,
plan->scan.plan.targetlist, lc,
plan->subplan->targetlist)
1502 if (ptle->resjunk != ctle->resjunk)
1555 bool unsafe_initplans;
1558 &initplan_cost, &unsafe_initplans);
1561 if (unsafe_initplans)
1604 fscan->
scan.plan.targetlist = (
List *)
1606 (
Node *) fscan->
scan.plan.targetlist,
1620 fscan->fdw_exprs = (
List *)
1622 (
Node *) fscan->fdw_exprs,
1628 fscan->fdw_recheck_quals = (
List *)
1630 (
Node *) fscan->fdw_recheck_quals,
1638 fscan->fdw_scan_tlist =
1648 fscan->
scan.plan.targetlist =
1651 fscan->scan.plan.
qual =
1657 fscan->fdw_recheck_quals =
1690 cscan->
scan.plan.targetlist = (
List *)
1692 (
Node *) cscan->
scan.plan.targetlist,
1706 cscan->custom_exprs = (
List *)
1708 (
Node *) cscan->custom_exprs,
1716 cscan->custom_scan_tlist =
1723 cscan->
scan.plan.targetlist =
1726 cscan->scan.plan.
qual =
1729 cscan->custom_exprs =
1764 Assert(part_prune_index >= 0 &&
1775 foreach(l2, prune_infos)
1780 prelinfo->
rtindex += rtoffset;
1795 if (prelinfo->leafpart_rti_map[
i])
1797 prelinfo->leafpart_rti_map[
i] += rtoffset;
1800 prelinfo->leafpart_rti_map[
i]);
1875 return (
Plan *) aplan;
1943 return (
Plan *) mplan;
2034 ((
Aggref *) node)->aggfnoid);
2050 ((
OpExpr *) node)->opfuncid);
2083 root->glob->relationOids =
2101 foreach(lc, g->refs)
2127 int subqueryid = p->
paramid >> 16;
2128 int colno = p->
paramid & 0xFFFF;
2131 if (subqueryid <= 0 ||
2175 if (bestplan == NULL || curcost <= bestcost)
2186 root->isUsedSubplan[bestplan->
plan_id - 1] =
true;
2188 return (
Node *) bestplan;
2218 if (rtoffset != 0 ||
2219 root->multiexpr_params !=
NIL ||
2220 root->glob->lastPHId != 0 ||
2222 root->hasAlternativeSubPlans)
2264 if (var->varnosyn > 0)
2265 var->varnosyn += context->
rtoffset;
2266 return (
Node *) var;
2277 if (aggparam != NULL)
2290 return (
Node *) cexpr;
2332 Plan *outer_plan = join->plan.lefttree;
2333 Plan *inner_plan = join->plan.righttree;
2387 elog(
ERROR,
"NestLoopParam was not reduced to a simple Var");
2440 join->plan.targetlist,
2456 pfree(outer_itlist);
2457 pfree(inner_itlist);
2483 List *output_targetlist;
2497 root->group_rtindex > 0 &&
2510 output_targetlist =
NIL;
2511 foreach(l,
plan->targetlist)
2543 output_targetlist =
lappend(output_targetlist, tle);
2545 plan->targetlist = output_targetlist;
2556 pfree(subplan_itlist);
2571 if (
plan->lefttree->extParam)
2577 for (proot =
root; proot != NULL; proot = proot->parent_root)
2642 memcpy(child_agg, orig_agg,
sizeof(
Aggref));
2671 return (
Node *) parent_agg;
2692 List *output_targetlist;
2695 output_targetlist =
NIL;
2696 foreach(l,
plan->targetlist)
2711 output_targetlist =
lappend(output_targetlist, tle);
2722 oldvar->varnosyn > 0)
2724 newvar->varnosyn = oldvar->varnosyn + rtoffset;
2725 newvar->varattnosyn = oldvar->varattnosyn;
2729 newvar->varnosyn = 0;
2730 newvar->varattnosyn = 0;
2735 output_targetlist =
lappend(output_targetlist, tle);
2737 plan->targetlist = output_targetlist;
2768 itlist->
tlist = tlist;
2773 vinfo = itlist->
vars;
2819 itlist->
tlist = tlist;
2824 vinfo = itlist->
vars;
2867 int newvarno,
int rtoffset,
2870 int varno = var->
varno;
2875 vinfo = itlist->
vars;
2898 if (!(varattno <= 0 ||
2904 elog(
ERROR,
"wrong varnullingrels %s (expected %s) for Var %d/%d",
2909 newvar->
varno = newvarno;
2911 if (newvar->varnosyn > 0)
2912 newvar->varnosyn += rtoffset;
2937 foreach(lc, itlist->
tlist)
2960 elog(
ERROR,
"wrong phnullingrels %s (expected %s) for PlaceHolderVar %d",
2967 newvar->varnosyn = 0;
2968 newvar->varattnosyn = 0;
3006 newvar->varnosyn = 0;
3007 newvar->varattnosyn = 0;
3031 foreach(lc, itlist->
tlist)
3050 newvar->varnosyn = 0;
3051 newvar->varattnosyn = 0;
3106 Index acceptable_rel,
3143 elog(
ERROR,
"variable returning old/new found outside RETURNING list");
3145 elog(
ERROR,
"wrong varno %d (expected %d) for variable returning old/new",
3158 return (
Node *) newvar;
3170 return (
Node *) newvar;
3178 if (var->varnosyn > 0)
3179 var->varnosyn += context->
rtoffset;
3180 return (
Node *) var;
3184 elog(
ERROR,
"variable not found in subplan target lists");
3198 return (
Node *) newvar;
3207 return (
Node *) newvar;
3221 return (
Node *) newvar;
3229 return (
Node *) newvar;
3312 elog(
ERROR,
"variable not found in subplan target list");
3313 return (
Node *) newvar;
3327 return (
Node *) newvar;
3340 return (
Node *) newvar;
3352 if (aggparam != NULL)
3400 Index resultRelation,
3455 return (
Node *) newvar;
3456 elog(
ERROR,
"WindowFunc not found in subplan target lists");
3521 if (
root->minmax_aggs !=
NIL &&
3527 foreach(lc,
root->minmax_aggs)
3533 return mminfo->
param;
3571 inval_item->
cacheId = PROCOID;
3607 inval_item->
cacheId = TYPEOID;
3634 List **relationOids,
3636 bool *hasRowSecurity)
3642 MemSet(&glob, 0,
sizeof(glob));
3643 glob.type = T_PlannerGlobal;
3650 root.type = T_PlannerInfo;
3710 if (query->hasRowSecurity)
3714 foreach(lc, query->
rtable)
Bitmapset * bms_make_singleton(int x)
Bitmapset * bms_intersect(const Bitmapset *a, const Bitmapset *b)
bool bms_equal(const Bitmapset *a, const Bitmapset *b)
int bms_next_member(const Bitmapset *a, int prevbit)
bool bms_is_subset(const Bitmapset *a, const Bitmapset *b)
Bitmapset * bms_add_member(Bitmapset *a, int x)
#define FLEXIBLE_ARRAY_MEMBER
#define MemSet(start, val, len)
#define OidIsValid(objectId)
bool equal(const void *a, const void *b)
Assert(PointerIsAligned(start, uint64))
if(TABLE==NULL||TABLE_index==NULL)
List * lappend(List *list, void *datum)
List * list_concat(List *list1, const List *list2)
List * lappend_int(List *list, int datum)
List * lappend_oid(List *list, Oid datum)
Datum lca(PG_FUNCTION_ARGS)
Var * makeVarFromTargetEntry(int varno, TargetEntry *tle)
Var * makeVar(int varno, AttrNumber varattno, Oid vartype, int32 vartypmod, Oid varcollid, Index varlevelsup)
Const * makeNullConst(Oid consttype, int32 consttypmod, Oid constcollid)
TargetEntry * makeTargetEntry(Expr *expr, AttrNumber resno, char *resname, bool resjunk)
TargetEntry * flatCopyTargetEntry(TargetEntry *src_tle)
void pfree(void *pointer)
void * palloc0(Size size)
Oid exprType(const Node *expr)
int32 exprTypmod(const Node *expr)
Oid exprCollation(const Node *expr)
void set_sa_opfuncid(ScalarArrayOpExpr *opexpr)
void set_opfuncid(OpExpr *opexpr)
#define expression_tree_mutator(n, m, c)
#define query_tree_walker(q, w, c, f)
#define expression_tree_walker(n, w, c)
#define QTW_EXAMINE_RTES_BEFORE
#define IsA(nodeptr, _type_)
#define DO_AGGSPLIT_COMBINE(as)
@ AGGSPLIT_FINAL_DESERIAL
@ AGGSPLIT_INITIAL_SERIAL
char * bmsToString(const Bitmapset *bms)
RTEPermissionInfo * getRTEPermissionInfo(List *rteperminfos, RangeTblEntry *rte)
RTEPermissionInfo * addRTEPermissionInfo(List **rteperminfos, RangeTblEntry *rte)
#define lfirst_node(type, lc)
static int list_length(const List *l)
#define forboth(cell1, list1, cell2, list2)
#define foreach_current_index(var_or_cell)
#define forthree(cell1, list1, cell2, list2, cell3, list3)
static void * list_nth(const List *list, int n)
#define list_nth_node(type, list, n)
void mark_partial_aggref(Aggref *agg, AggSplit aggsplit)
@ SUBQUERY_SCAN_NONTRIVIAL
static Oid DatumGetObjectId(Datum X)
static Datum ObjectIdGetDatum(Oid X)
#define IS_SPECIAL_VARNO(varno)
RelOptInfo * find_base_rel(PlannerInfo *root, int relid)
RelOptInfo * fetch_upper_rel(PlannerInfo *root, UpperRelationKind kind, Relids relids)
Node * remove_nulling_relids(Node *node, const Bitmapset *removable_relids, const Bitmapset *except_relids)
void record_plan_type_dependency(PlannerInfo *root, Oid typid)
#define NUM_EXEC_QUAL(parentplan)
static void set_hash_references(PlannerInfo *root, Plan *plan, int rtoffset)
static void fix_expr_common(PlannerInfo *root, Node *node)
static void add_rtes_to_flat_rtable(PlannerInfo *root, bool recursing)
static Node * fix_join_expr_mutator(Node *node, fix_join_expr_context *context)
static void add_rte_to_flat_rtable(PlannerGlobal *glob, List *rteperminfos, RangeTblEntry *rte)
static Plan * set_append_references(PlannerInfo *root, Append *aplan, int rtoffset)
Plan * set_plan_references(PlannerInfo *root, Plan *plan)
static Plan * set_mergeappend_references(PlannerInfo *root, MergeAppend *mplan, int rtoffset)
static List * set_returning_clause_references(PlannerInfo *root, List *rlist, Plan *topplan, Index resultRelation, int rtoffset)
static Node * fix_param_node(PlannerInfo *root, Param *p)
void record_plan_function_dependency(PlannerInfo *root, Oid funcid)
static Relids offset_relid_set(Relids relids, int rtoffset)
static bool flatten_rtes_walker(Node *node, flatten_rtes_walker_context *cxt)
static indexed_tlist * build_tlist_index(List *tlist)
static List * set_windowagg_runcondition_references(PlannerInfo *root, List *runcondition, Plan *plan)
bool trivial_subqueryscan(SubqueryScan *plan)
static void set_upper_references(PlannerInfo *root, Plan *plan, int rtoffset)
static Var * search_indexed_tlist_for_sortgroupref(Expr *node, Index sortgroupref, indexed_tlist *itlist, int newvarno)
static void flatten_unplanned_rtes(PlannerGlobal *glob, RangeTblEntry *rte)
static Node * fix_upper_expr(PlannerInfo *root, Node *node, indexed_tlist *subplan_itlist, int newvarno, int rtoffset, NullingRelsMatch nrm_match, double num_exec)
static void set_param_references(PlannerInfo *root, Plan *plan)
static Var * search_indexed_tlist_for_non_var(Expr *node, indexed_tlist *itlist, int newvarno)
static Node * fix_upper_expr_mutator(Node *node, fix_upper_expr_context *context)
Param * find_minmax_agg_replacement_param(PlannerInfo *root, Aggref *aggref)
static Node * fix_scan_expr_mutator(Node *node, fix_scan_expr_context *context)
static void set_foreignscan_references(PlannerInfo *root, ForeignScan *fscan, int rtoffset)
static Plan * set_subqueryscan_references(PlannerInfo *root, SubqueryScan *plan, int rtoffset)
static Var * search_indexed_tlist_for_phv(PlaceHolderVar *phv, indexed_tlist *itlist, int newvarno, NullingRelsMatch nrm_match)
static Plan * set_indexonlyscan_references(PlannerInfo *root, IndexOnlyScan *plan, int rtoffset)
static List * fix_join_expr(PlannerInfo *root, List *clauses, indexed_tlist *outer_itlist, indexed_tlist *inner_itlist, Index acceptable_rel, int rtoffset, NullingRelsMatch nrm_match, double num_exec)
static Node * convert_combining_aggrefs(Node *node, void *context)
static void set_dummy_tlist_references(Plan *plan, int rtoffset)
static int register_partpruneinfo(PlannerInfo *root, int part_prune_index, int rtoffset)
static void set_customscan_references(PlannerInfo *root, CustomScan *cscan, int rtoffset)
#define ISREGCLASSCONST(con)
void extract_query_dependencies(Node *query, List **relationOids, List **invalItems, bool *hasRowSecurity)
static Node * fix_windowagg_condition_expr_mutator(Node *node, fix_windowagg_cond_context *context)
static Var * copyVar(Var *var)
bool extract_query_dependencies_walker(Node *node, PlannerInfo *context)
static List * fix_windowagg_condition_expr(PlannerInfo *root, List *runcondition, indexed_tlist *subplan_itlist)
#define NUM_EXEC_TLIST(parentplan)
static Node * fix_alternative_subplan(PlannerInfo *root, AlternativeSubPlan *asplan, double num_exec)
static void set_join_references(PlannerInfo *root, Join *join, int rtoffset)
static indexed_tlist * build_tlist_index_other_vars(List *tlist, int ignore_rel)
static Plan * clean_up_removed_plan_level(Plan *parent, Plan *child)
static Node * fix_scan_expr(PlannerInfo *root, Node *node, int rtoffset, double num_exec)
static Plan * set_plan_refs(PlannerInfo *root, Plan *plan, int rtoffset)
static bool fix_scan_expr_walker(Node *node, fix_scan_expr_context *context)
static Var * search_indexed_tlist_for_var(Var *var, indexed_tlist *itlist, int newvarno, int rtoffset, NullingRelsMatch nrm_match)
#define fix_scan_list(root, lst, rtoffset, num_exec)
Bitmapset * custom_relids
Bitmapset * fs_base_relids
List * initial_pruning_steps
List * exec_pruning_steps
Bitmapset * prunableRelids
struct TableSampleClause * tablesample
VarReturningType varreturningtype
NullingRelsMatch nrm_match
indexed_tlist * outer_itlist
indexed_tlist * inner_itlist
indexed_tlist * subplan_itlist
NullingRelsMatch nrm_match
indexed_tlist * subplan_itlist
tlist_vinfo vars[FLEXIBLE_ARRAY_MEMBER]
Bitmapset * varnullingrels
void SS_compute_initplan_cost(List *init_plans, Cost *initplan_cost_p, bool *unsafe_initplans_p)
#define GetSysCacheHashValue1(cacheId, key1)
TargetEntry * tlist_member(Expr *node, List *targetlist)
void apply_tlist_labeling(List *dest_tlist, List *src_tlist)
#define FirstUnpinnedObjectId
Query * UtilityContainsQuery(Node *parsetree)