45 #ifdef USE_ASSERT_CHECKING
117 #define NUM_EXEC_TLIST(parentplan) ((parentplan)->plan_rows)
118 #define NUM_EXEC_QUAL(parentplan) ((parentplan)->plan_rows * 2.0)
127 #define ISREGCLASSCONST(con) \
128 (((con)->consttype == REGCLASSOID || (con)->consttype == OIDOID) && \
131 #define fix_scan_list(root, lst, rtoffset, num_exec) \
132 ((List *) fix_scan_expr(root, (Node *) (lst), rtoffset, num_exec))
162 int rtoffset,
double num_exec);
191 Index acceptable_rel,
209 Index resultRelation,
316 newrc->
rti += rtoffset;
317 newrc->
prti += rtoffset;
347 root->isAltSubplan = (
bool *)
349 root->isUsedSubplan = (
bool *)
376 if (root->isAltSubplan[ndx] && !root->isUsedSubplan[ndx])
394 foreach(l2, prune_infos)
463 rti < root->simple_rel_array_size)
465 RelOptInfo *rel = root->simple_rel_array[rti];
492 else if (recursing ||
547 cxt->query = save_query;
654 splan->scan.scanrelid += rtoffset;
655 splan->scan.plan.targetlist =
658 splan->scan.plan.qual =
667 splan->scan.scanrelid += rtoffset;
668 splan->scan.plan.targetlist =
671 splan->scan.plan.qual =
683 splan->scan.scanrelid += rtoffset;
684 splan->scan.plan.targetlist =
687 splan->scan.plan.qual =
693 splan->indexqualorig =
696 splan->indexorderby =
699 splan->indexorderbyorig =
704 case T_IndexOnlyScan:
711 case T_BitmapIndexScan:
715 splan->scan.scanrelid += rtoffset;
721 splan->indexqualorig =
726 case T_BitmapHeapScan:
730 splan->scan.scanrelid += rtoffset;
731 splan->scan.plan.targetlist =
734 splan->scan.plan.qual =
737 splan->bitmapqualorig =
746 splan->scan.scanrelid += rtoffset;
747 splan->scan.plan.targetlist =
750 splan->scan.plan.qual =
762 splan->scan.scanrelid += rtoffset;
763 splan->scan.plan.targetlist =
766 splan->scan.plan.qual =
769 splan->tidrangequals =
783 splan->scan.scanrelid += rtoffset;
784 splan->scan.plan.targetlist =
787 splan->scan.plan.qual =
794 case T_TableFuncScan:
798 splan->scan.scanrelid += rtoffset;
799 splan->scan.plan.targetlist =
802 splan->scan.plan.qual =
814 splan->scan.scanrelid += rtoffset;
815 splan->scan.plan.targetlist =
818 splan->scan.plan.qual =
821 splan->values_lists =
830 splan->scan.scanrelid += rtoffset;
831 splan->scan.plan.targetlist =
834 splan->scan.plan.qual =
839 case T_NamedTuplestoreScan:
843 splan->scan.scanrelid += rtoffset;
844 splan->scan.plan.targetlist =
847 splan->scan.plan.qual =
852 case T_WorkTableScan:
856 splan->scan.scanrelid += rtoffset;
857 splan->scan.plan.targetlist =
860 splan->scan.plan.qual =
908 case T_IncrementalSort:
939 foreach(l,
splan->rowMarks)
944 rc->
prti += rtoffset;
979 plan->targetlist = (
List *)
982 plan->qual = (
List *)
1038 if (
splan->plan.lefttree != NULL)
1054 foreach(l,
splan->plan.targetlist)
1065 splan->plan.targetlist =
1073 splan->resconstantqual =
1088 splan->withCheckOptionLists =
1092 if (
splan->returningLists)
1104 lcrr,
splan->resultRelations)
1114 newRL =
lappend(newRL, rlist);
1116 splan->returningLists = newRL;
1137 if (
splan->onConflictSet)
1143 splan->onConflictSet =
1157 splan->exclRelTlist =
1171 if (
splan->mergeActionLists !=
NIL)
1195 lcr,
splan->resultRelations)
1200 foreach(l, mergeActionList)
1225 splan->nominalRelation += rtoffset;
1226 if (
splan->rootRelation)
1227 splan->rootRelation += rtoffset;
1228 splan->exclRelRTI += rtoffset;
1230 foreach(l,
splan->resultRelations)
1234 foreach(l,
splan->rowMarks)
1238 rc->
rti += rtoffset;
1239 rc->
prti += rtoffset;
1248 splan->resultRelations);
1249 if (
splan->rootRelation)
1253 splan->rootRelation);
1267 case T_RecursiveUnion:
1279 foreach(l,
splan->bitmapplans)
1294 foreach(l,
splan->bitmapplans)
1303 elog(
ERROR,
"unrecognized node type: %d",
1337 List *stripped_indextlist;
1347 stripped_indextlist =
NIL;
1352 if (!indextle->resjunk)
1353 stripped_indextlist =
lappend(stripped_indextlist, indextle);
1359 plan->
scan.plan.targetlist = (
List *)
1361 (
Node *) plan->
scan.plan.targetlist,
1393 pfree(index_itlist);
1395 return (
Plan *) plan;
1436 plan->
scan.plan.targetlist =
1439 plan->scan.plan.
qual =
1443 result = (
Plan *) plan;
1490 if (plan->
scan.plan.qual !=
NIL)
1503 if (ptle->resjunk != ctle->resjunk)
1582 fscan->
scan.plan.targetlist = (
List *)
1584 (
Node *) fscan->
scan.plan.targetlist,
1598 fscan->fdw_exprs = (
List *)
1600 (
Node *) fscan->fdw_exprs,
1606 fscan->fdw_recheck_quals = (
List *)
1608 (
Node *) fscan->fdw_recheck_quals,
1616 fscan->fdw_scan_tlist =
1626 fscan->
scan.plan.targetlist =
1629 fscan->scan.plan.
qual =
1635 fscan->fdw_recheck_quals =
1668 cscan->
scan.plan.targetlist = (
List *)
1670 (
Node *) cscan->
scan.plan.targetlist,
1684 cscan->custom_exprs = (
List *)
1686 (
Node *) cscan->custom_exprs,
1694 cscan->custom_scan_tlist =
1701 cscan->
scan.plan.targetlist =
1704 cscan->scan.plan.
qual =
1707 cscan->custom_exprs =
1784 return (
Plan *) aplan;
1851 return (
Plan *) mplan;
1942 ((
Aggref *) node)->aggfnoid);
1958 ((
OpExpr *) node)->opfuncid);
1998 AttrNumber *grouping_map = root->grouping_map;
2009 foreach(lc, g->refs)
2035 int subqueryid = p->
paramid >> 16;
2036 int colno = p->
paramid & 0xFFFF;
2039 if (subqueryid <= 0 ||
2083 if (bestplan == NULL || curcost <= bestcost)
2090 root->isAltSubplan[curplan->
plan_id - 1] =
true;
2094 root->isUsedSubplan[bestplan->
plan_id - 1] =
true;
2096 return (
Node *) bestplan;
2122 context.
root = root;
2126 if (rtoffset != 0 ||
2172 if (var->varnosyn > 0)
2173 var->varnosyn += context->
rtoffset;
2174 return (
Node *) var;
2206 return (
Node *) cexpr;
2250 Plan *outer_plan = join->plan.lefttree;
2251 Plan *inner_plan = join->plan.righttree;
2303 elog(
ERROR,
"NestLoopParam was not reduced to a simple Var");
2356 join->plan.targetlist,
2372 pfree(outer_itlist);
2373 pfree(inner_itlist);
2399 List *output_targetlist;
2404 output_targetlist =
NIL;
2437 output_targetlist =
lappend(output_targetlist, tle);
2450 pfree(subplan_itlist);
2471 for (proot = root; proot != NULL; proot = proot->parent_root)
2490 ((
Gather *) plan)->initParam =
2536 memcpy(child_agg, orig_agg,
sizeof(
Aggref));
2565 return (
Node *) parent_agg;
2587 List *output_targetlist;
2590 output_targetlist =
NIL;
2606 output_targetlist =
lappend(output_targetlist, tle);
2617 oldvar->varnosyn > 0)
2619 newvar->varnosyn = oldvar->varnosyn + rtoffset;
2620 newvar->varattnosyn = oldvar->varattnosyn;
2624 newvar->varnosyn = 0;
2625 newvar->varattnosyn = 0;
2630 output_targetlist =
lappend(output_targetlist, tle);
2663 itlist->
tlist = tlist;
2668 vinfo = itlist->
vars;
2680 #ifdef USE_ASSERT_CHECKING
2681 vinfo->varnullingrels = var->varnullingrels;
2716 itlist->
tlist = tlist;
2721 vinfo = itlist->
vars;
2735 #ifdef USE_ASSERT_CHECKING
2736 vinfo->varnullingrels = var->varnullingrels;
2766 int newvarno,
int rtoffset,
2769 int varno = var->
varno;
2774 vinfo = itlist->
vars;
2802 bms_equal(vinfo->varnullingrels, var->varnullingrels)));
2804 newvar->
varno = newvarno;
2806 if (newvar->varnosyn > 0)
2807 newvar->varnosyn += rtoffset;
2832 foreach(lc, itlist->
tlist)
2858 newvar->varnosyn = 0;
2859 newvar->varattnosyn = 0;
2897 newvar->varnosyn = 0;
2898 newvar->varattnosyn = 0;
2922 foreach(lc, itlist->
tlist)
2934 newvar->varnosyn = 0;
2935 newvar->varattnosyn = 0;
2990 Index acceptable_rel,
2997 context.
root = root;
3027 return (
Node *) newvar;
3039 return (
Node *) newvar;
3047 if (var->varnosyn > 0)
3048 var->varnosyn += context->
rtoffset;
3049 return (
Node *) var;
3053 elog(
ERROR,
"variable not found in subplan target lists");
3067 return (
Node *) newvar;
3076 return (
Node *) newvar;
3090 return (
Node *) newvar;
3098 return (
Node *) newvar;
3157 context.
root = root;
3183 elog(
ERROR,
"variable not found in subplan target list");
3184 return (
Node *) newvar;
3198 return (
Node *) newvar;
3211 return (
Node *) newvar;
3281 Index resultRelation,
3336 return (
Node *) newvar;
3337 elog(
ERROR,
"WindowFunc not found in subplan target lists");
3358 context.
root = root;
3483 List **relationOids,
3485 bool *hasRowSecurity)
3491 MemSet(&glob, 0,
sizeof(glob));
3492 glob.type = T_PlannerGlobal;
3498 MemSet(&root, 0,
sizeof(root));
3499 root.type = T_PlannerInfo;
3540 if (query->hasRowSecurity)
3544 foreach(lc, query->
rtable)
3557 (
void *) context, 0);
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)
Bitmapset * bms_intersect(const Bitmapset *a, const Bitmapset *b)
#define FLEXIBLE_ARRAY_MEMBER
#define MemSet(start, val, len)
#define OidIsValid(objectId)
elog(ERROR, "%s: %s", p2, msg)
bool equal(const void *a, const void *b)
if(TABLE==NULL||TABLE_index==NULL)
Assert(fmt[strlen(fmt) - 1] !='\n')
List * lappend(List *list, void *datum)
List * lappend_int(List *list, int datum)
List * lappend_oid(List *list, Oid datum)
List * list_concat(List *list1, const List *list2)
Datum lca(PG_FUNCTION_ARGS)
Var * makeVarFromTargetEntry(int varno, TargetEntry *tle)
TargetEntry * makeTargetEntry(Expr *expr, AttrNumber resno, char *resname, bool resjunk)
Const * makeNullConst(Oid consttype, int32 consttypmod, Oid constcollid)
Var * makeVar(int varno, AttrNumber varattno, Oid vartype, int32 vartypmod, Oid varcollid, Index varlevelsup)
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
RTEPermissionInfo * addRTEPermissionInfo(List **rteperminfos, RangeTblEntry *rte)
RTEPermissionInfo * getRTEPermissionInfo(List *rteperminfos, RangeTblEntry *rte)
#define lfirst_node(type, lc)
static int list_length(const List *l)
#define forboth(cell1, list1, cell2, list2)
static void * list_nth(const List *list, int n)
#define foreach_current_index(cell)
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)
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)
static Node * fix_param_node(PlannerInfo *root, Param *p)
static Plan * set_mergeappend_references(PlannerInfo *root, MergeAppend *mplan, int rtoffset)
static indexed_tlist * build_tlist_index_other_vars(List *tlist, int ignore_rel)
static List * set_returning_clause_references(PlannerInfo *root, List *rlist, Plan *topplan, Index resultRelation, int rtoffset)
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 Node * fix_alternative_subplan(PlannerInfo *root, AlternativeSubPlan *asplan, double num_exec)
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)
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 void set_customscan_references(PlannerInfo *root, CustomScan *cscan, int rtoffset)
static Node * fix_windowagg_condition_expr_mutator(Node *node, fix_windowagg_cond_context *context)
#define ISREGCLASSCONST(con)
Plan * set_plan_references(PlannerInfo *root, Plan *plan)
void extract_query_dependencies(Node *query, List **relationOids, List **invalItems, bool *hasRowSecurity)
bool extract_query_dependencies_walker(Node *node, PlannerInfo *context)
static Var * copyVar(Var *var)
#define NUM_EXEC_TLIST(parentplan)
static void set_join_references(PlannerInfo *root, Join *join, int rtoffset)
static List * fix_windowagg_condition_expr(PlannerInfo *root, List *runcondition, indexed_tlist *subplan_itlist)
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
Bitmapset * root_parent_relids
bool hasAlternativeSubPlans
struct TableSampleClause * tablesample
SubqueryScanStatus scanstatus
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]
#define GetSysCacheHashValue1(cacheId, key1)
void apply_tlist_labeling(List *dest_tlist, List *src_tlist)
TargetEntry * tlist_member(Expr *node, List *targetlist)
#define FirstUnpinnedObjectId
Query * UtilityContainsQuery(Node *parsetree)