107 Index security_level,
110 Relids outerjoin_nonnullable,
111 Relids incompatible_relids,
112 bool allow_equivalence,
115 List **postponed_oj_qual_list);
119 Index security_level,
122 Relids outerjoin_nonnullable,
123 Relids incompatible_relids,
124 bool allow_equivalence,
127 List **postponed_oj_qual_list);
183 elog(
ERROR,
"unrecognized node type: %d",
199 for (rti = 1; rti <
root->simple_rel_array_size; rti++)
241 if (tlist_vars !=
NIL)
251 if (
root->parse->havingQual)
257 if (having_vars !=
NIL)
300 if (rel->attr_needed[attno] == NULL)
310 var->varnullingrels = NULL;
363 if (!
root->hasLateralRTEs)
369 for (rti = 1; rti <
root->simple_rel_array_size; rti++)
471 newvars =
lappend(newvars, node);
503 bool found_laterals =
false;
508 if (!
root->hasLateralRTEs)
517 for (rti = 1; rti <
root->simple_rel_array_size; rti++)
532 lateral_relids = NULL;
543 found_laterals =
true;
552 found_laterals =
true;
578 foreach(lc,
root->placeholder_list)
588 found_laterals =
true;
633 root->hasLateralRTEs =
false;
648 for (rti = 1; rti <
root->simple_rel_array_size; rti++)
651 Relids outer_lateral_relids;
659 if (outer_lateral_relids == NULL)
663 for (rti2 = 1; rti2 <
root->simple_rel_array_size; rti2++)
673 outer_lateral_relids);
682 for (rti = 1; rti <
root->simple_rel_array_size; rti++)
752 root->placeholdersFrozen =
true;
763 root->all_baserels = NULL;
764 root->outer_join_rels = NULL;
778 foreach(lc, item_list)
789 if (
root->join_info_list)
791 foreach(lc, item_list)
844 jtitem->
jdomain = parent_domain;
860 jtitem->
jdomain = parent_domain;
889 if (sub_members <= 1 ||
893 joinlist =
lappend(joinlist, sub_joinlist);
920 jtitem->
jdomain = parent_domain;
947 jtitem->
jdomain = child_domain;
986 jtitem->
jdomain = parent_domain;
1060 elog(
ERROR,
"unrecognized join type: %d",
1062 leftjoinlist = rightjoinlist =
NIL;
1079 joinlist =
list_concat(leftjoinlist, rightjoinlist);
1091 leftpart = (
Node *) leftjoinlist;
1095 rightpart = (
Node *) rightjoinlist;
1101 elog(
ERROR,
"unrecognized node type: %d",
1107 *item_list =
lappend(*item_list, jtitem);
1129 if (
root->qual_security_level > 0)
1145 root->qual_security_level,
1157 root->qual_security_level,
1169 List **postponed_oj_qual_list;
1233 postponed_oj_qual_list = NULL;
1239 root->qual_security_level,
1245 postponed_oj_qual_list);
1253 elog(
ERROR,
"unrecognized node type: %d",
1276 Index security_level = 0;
1285 foreach(lc, rte->securityQuals)
1310 Assert(security_level <= root->qual_security_level);
1397 foreach(l,
root->parse->rowMarks)
1404 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1407 errmsg(
"%s cannot be applied to the nullable side of an outer join",
1468 commute_below_l = commute_below_r = NULL;
1469 foreach(l,
root->join_info_list)
1472 bool have_unsafe_phvs;
1516 have_unsafe_phvs =
false;
1539 (have_unsafe_phvs ||
1625 foreach(l,
root->placeholder_list)
1671 if (commute_below_l || commute_below_r)
1676 foreach(l,
root->join_info_list)
1702 List *semi_operators;
1703 List *semi_rhs_exprs;
1744 semi_operators =
NIL;
1745 semi_rhs_exprs =
NIL;
1787 all_varnos =
bms_union(left_varnos, right_varnos);
1818 right_expr = left_expr;
1840 if (!(all_btree || all_hash))
1844 semi_operators =
lappend_oid(semi_operators, opno);
1849 if (semi_rhs_exprs ==
NIL)
1905 Relids incompatible_joins;
1908 int save_last_rinfo_serial;
1944 incompatible_joins =
bms_union(joins_below, joins_above);
1956 save_last_rinfo_serial =
root->last_rinfo_serial;
1958 joins_so_far = NULL;
1959 foreach(lc, jtitems)
1963 bool below_sjinfo =
false;
1964 bool above_sjinfo =
false;
1967 bool allow_equivalence,
1971 if (othersj == NULL)
1977 below_sjinfo =
true;
1979 else if (othersj ==
sjinfo)
1987 above_sjinfo =
true;
1996 root->last_rinfo_serial = save_last_rinfo_serial;
2023 this_ojscope =
bms_union(ojscope, joins_so_far);
2051 allow_equivalence = (joins_so_far == NULL);
2052 has_clone = allow_equivalence;
2053 is_clone = !has_clone;
2058 root->qual_security_level,
2096 root->qual_security_level,
2122 Index security_level,
2125 Relids outerjoin_nonnullable,
2126 Relids incompatible_relids,
2127 bool allow_equivalence,
2130 List **postponed_oj_qual_list)
2134 foreach(lc, clauses)
2144 outerjoin_nonnullable,
2145 incompatible_relids,
2149 postponed_oj_qual_list);
2200 Index security_level,
2203 Relids outerjoin_nonnullable,
2204 Relids incompatible_relids,
2205 bool allow_equivalence,
2208 List **postponed_oj_qual_list)
2211 bool is_pushed_down;
2212 bool pseudoconstant =
false;
2213 bool maybe_equivalence;
2214 bool maybe_outer_join;
2255 elog(
ERROR,
"failed to postpone qual containing lateral reference");
2263 elog(
ERROR,
"JOIN qualification cannot refer to other relations");
2315 pseudoconstant =
true;
2317 root->hasPseudoConstantQuals =
true;
2362 if (postponed_oj_qual_list != NULL)
2364 *postponed_oj_qual_list =
lappend(*postponed_oj_qual_list, clause);
2375 is_pushed_down =
false;
2376 maybe_equivalence =
false;
2377 maybe_outer_join =
true;
2396 is_pushed_down =
true;
2408 maybe_equivalence = allow_equivalence;
2414 maybe_outer_join =
false;
2428 incompatible_relids,
2429 outerjoin_nonnullable);
2460 where_needed = relids;
2504 if (restrictinfo->mergeopfamilies)
2506 if (maybe_equivalence)
2511 if (restrictinfo->mergeopfamilies)
2515 else if (maybe_outer_join && restrictinfo->can_join)
2522 outerjoin_nonnullable) &&
2524 outerjoin_nonnullable))
2529 ojcinfo->
rinfo = restrictinfo;
2536 outerjoin_nonnullable) &&
2538 outerjoin_nonnullable))
2543 ojcinfo->
rinfo = restrictinfo;
2554 ojcinfo->
rinfo = restrictinfo;
2586 Var *forced_null_var;
2591 if (forced_null_var == NULL)
2600 if (forced_null_var->varnullingrels == NULL)
2603 foreach(lc,
root->join_info_list)
2652 if (!rte->
inh || rte->relkind == RELKIND_PARTITIONED_TABLE)
2671 restrictinfo->pseudoconstant,
2758 foreach(lc, ((
BoolExpr *) restrictinfo->orclause)->args)
2812 foreach(lc, ((
BoolExpr *) restrictinfo->orclause)->args)
2885 elog(
ERROR,
"cannot cope with variable-free clause");
2927 Index security_level,
2933 bool pseudoconstant =
false;
2958 if (!cclause->constisnull &&
DatumGetBool(cclause->constvalue))
2984 pseudoconstant =
true;
2986 root->hasPseudoConstantQuals =
true;
3043 return restrictinfo;
3066 Index security_level)
3102 return restrictinfo;
3139 foreach(lc,
root->join_info_list)
3174 foreach(lc,
root->fkey_list)
3191 if (con_rel == NULL)
3194 if (ref_rel == NULL)
3213 for (colno = 0; colno < fkinfo->
nkeys; colno++)
3235 con_attno = fkinfo->conkey[colno];
3236 ref_attno = fkinfo->confkey[colno];
3256 if (!(leftvar &&
IsA(leftvar,
Var)))
3260 if (!(rightvar &&
IsA(rightvar,
Var)))
3264 if (fkinfo->
ref_relid == leftvar->varno &&
3265 ref_attno == leftvar->varattno &&
3267 con_attno == rightvar->varattno)
3270 if (clause->
opno == fkinfo->conpfeqop[colno])
3277 else if (fkinfo->
ref_relid == rightvar->varno &&
3278 ref_attno == rightvar->varattno &&
3280 con_attno == leftvar->varattno)
3291 if (clause->
opno == fpeqop)
3300 if (fkinfo->
rinfos[colno])
3311 newlist =
lappend(newlist, fkinfo);
3314 root->fkey_list = newlist;
3340 if (restrictinfo->pseudoconstant)
3347 opno = ((
OpExpr *) clause)->opno;
3377 if (restrictinfo->pseudoconstant)
3384 opno = ((
OpExpr *) clause)->opno;
3389 restrictinfo->hashjoinoperator = opno;
3406 if (restrictinfo->pseudoconstant)
3419 restrictinfo->left_hasheqoperator = typentry->
eq_opr;
3427 if (lefttype != righttype)
3432 restrictinfo->right_hasheqoperator = typentry->
eq_opr;
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)
bool bms_is_member(int x, const Bitmapset *a)
Bitmapset * bms_make_singleton(int x)
Bitmapset * bms_add_member(Bitmapset *a, int x)
Bitmapset * bms_union(const Bitmapset *a, const Bitmapset *b)
Bitmapset * bms_intersect(const Bitmapset *a, const Bitmapset *b)
Bitmapset * bms_add_members(Bitmapset *a, const Bitmapset *b)
Bitmapset * bms_del_members(Bitmapset *a, const Bitmapset *b)
Bitmapset * bms_int_members(Bitmapset *a, const Bitmapset *b)
Bitmapset * bms_del_member(Bitmapset *a, int x)
BMS_Membership bms_membership(const Bitmapset *a)
bool bms_overlap(const Bitmapset *a, const Bitmapset *b)
Bitmapset * bms_copy(const Bitmapset *a)
bool bms_get_singleton_member(const Bitmapset *a, int *member)
#define Assert(condition)
#define OidIsValid(objectId)
Var * find_forced_null_var(Node *node)
Relids find_nonnullable_rels(Node *clause)
Node * eval_const_expressions(PlannerInfo *root, Node *node)
bool contain_volatile_functions(Node *clause)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
bool process_equivalence(PlannerInfo *root, RestrictInfo **p_restrictinfo, JoinDomain *jdomain)
EquivalenceClass * match_eclasses_to_foreign_key_col(PlannerInfo *root, ForeignKeyOptInfo *fkinfo, int colno)
#define palloc0_object(type)
void expand_inherited_rtentry(PlannerInfo *root, RelOptInfo *rel, RangeTblEntry *rte, Index rti)
static void check_hashjoinable(RestrictInfo *restrictinfo)
static void extract_lateral_references(PlannerInfo *root, RelOptInfo *brel, Index rtindex)
List * deconstruct_jointree(PlannerInfo *root)
static void check_mergejoinable(RestrictInfo *restrictinfo)
void distribute_restrictinfo_to_rels(PlannerInfo *root, RestrictInfo *restrictinfo)
static List * deconstruct_recurse(PlannerInfo *root, Node *jtnode, JoinDomain *parent_domain, JoinTreeItem *parent_jtitem, List **item_list)
static void compute_semijoin_info(PlannerInfo *root, SpecialJoinInfo *sjinfo, List *clause)
struct JoinTreeItem JoinTreeItem
void match_foreign_keys_to_quals(PlannerInfo *root)
void find_lateral_references(PlannerInfo *root)
static void add_base_clause_to_rel(PlannerInfo *root, Index relid, RestrictInfo *restrictinfo)
void add_base_rels_to_query(PlannerInfo *root, Node *jtnode)
void build_base_rel_tlists(PlannerInfo *root, List *final_tlist)
bool restriction_is_always_true(PlannerInfo *root, RestrictInfo *restrictinfo)
static void deconstruct_distribute_oj_quals(PlannerInfo *root, List *jtitems, JoinTreeItem *jtitem)
static void distribute_quals_to_rels(PlannerInfo *root, List *clauses, JoinTreeItem *jtitem, SpecialJoinInfo *sjinfo, Index security_level, Relids qualscope, Relids ojscope, Relids outerjoin_nonnullable, Relids incompatible_relids, bool allow_equivalence, bool has_clone, bool is_clone, List **postponed_oj_qual_list)
static SpecialJoinInfo * make_outerjoininfo(PlannerInfo *root, Relids left_rels, Relids right_rels, Relids inner_join_rels, JoinType jointype, Index ojrelid, List *clause)
void add_vars_to_targetlist(PlannerInfo *root, List *vars, Relids where_needed)
bool restriction_is_always_false(PlannerInfo *root, RestrictInfo *restrictinfo)
static void distribute_qual_to_rels(PlannerInfo *root, Node *clause, JoinTreeItem *jtitem, SpecialJoinInfo *sjinfo, Index security_level, Relids qualscope, Relids ojscope, Relids outerjoin_nonnullable, Relids incompatible_relids, bool allow_equivalence, bool has_clone, bool is_clone, List **postponed_oj_qual_list)
static bool check_redundant_nullability_qual(PlannerInfo *root, Node *clause)
RestrictInfo * build_implied_join_equality(PlannerInfo *root, Oid opno, Oid collation, Expr *item1, Expr *item2, Relids qualscope, Index security_level)
static bool expr_is_nonnullable(PlannerInfo *root, Expr *expr)
void add_other_rels_to_query(PlannerInfo *root)
static void mark_rels_nulled_by_join(PlannerInfo *root, Index ojrelid, Relids lower_rels)
void create_lateral_join_info(PlannerInfo *root)
static void process_security_barrier_quals(PlannerInfo *root, int rti, JoinTreeItem *jtitem)
RestrictInfo * process_implied_equality(PlannerInfo *root, Oid opno, Oid collation, Expr *item1, Expr *item2, Relids qualscope, Index security_level, bool both_const)
static void deconstruct_distribute(PlannerInfo *root, JoinTreeItem *jtitem)
static void check_memoizable(RestrictInfo *restrictinfo)
static Relids get_join_domain_min_rels(PlannerInfo *root, Relids domain_relids)
if(TABLE==NULL||TABLE_index==NULL)
void add_join_clause_to_rels(PlannerInfo *root, RestrictInfo *restrictinfo, Relids join_relids)
List * lappend(List *list, void *datum)
List * lappend_oid(List *list, Oid datum)
void list_free(List *list)
List * list_concat(List *list1, const List *list2)
void list_free_deep(List *list)
List * get_mergejoin_opfamilies(Oid opno)
bool op_hashjoinable(Oid opno, Oid inputtype)
bool op_mergejoinable(Oid opno, Oid inputtype)
Oid get_commutator(Oid opno)
Expr * make_opclause(Oid opno, Oid opresulttype, bool opretset, Expr *leftop, Expr *rightop, Oid opcollid, Oid inputcollid)
Node * makeBoolConst(bool value, bool isnull)
Oid exprType(const Node *expr)
static bool is_orclause(const void *clause)
static bool is_opclause(const void *clause)
static Node * get_rightop(const void *clause)
static Node * get_leftop(const void *clause)
#define IsA(nodeptr, _type_)
#define PVC_RECURSE_AGGREGATES
#define PVC_RECURSE_WINDOWFUNCS
#define PVC_INCLUDE_PLACEHOLDERS
const char * LCS_asString(LockClauseStrength strength)
void initialize_mergeclause_eclasses(PlannerInfo *root, RestrictInfo *restrictinfo)
static int list_length(const List *l)
#define linitial_node(type, l)
#define list_make2(x1, x2)
bool contain_placeholder_references_to(PlannerInfo *root, Node *clause, int relid)
PlaceHolderInfo * find_placeholder_info(PlannerInfo *root, PlaceHolderVar *phv)
Expr * preprocess_phv_expression(PlannerInfo *root, Expr *expr)
static bool DatumGetBool(Datum X)
RelOptInfo * find_base_rel(PlannerInfo *root, int relid)
RelOptInfo * build_simple_rel(PlannerInfo *root, int relid, RelOptInfo *parent)
RelOptInfo * find_base_rel_ignore_join(PlannerInfo *root, int relid)
bool restriction_is_or_clause(RestrictInfo *restrictinfo)
RestrictInfo * make_restrictinfo(PlannerInfo *root, Expr *clause, bool is_pushed_down, bool has_clone, bool is_clone, bool pseudoconstant, Index security_level, Relids required_relids, Relids incompatible_relids, Relids outer_relids)
Node * remove_nulling_relids(Node *node, const Bitmapset *removable_relids, const Bitmapset *except_relids)
Node * add_nulling_relids(Node *node, const Bitmapset *target_relids, const Bitmapset *added_relids)
void IncrementVarSublevelsUp(Node *node, int delta_sublevels_up, int min_sublevels_up)
List * rinfos[INDEX_MAX_KEYS]
struct JoinTreeItem * jti_parent
NullTestType nulltesttype
struct TableSampleClause * tablesample
Bitmapset * notnullattnums
struct PathTarget * reltarget
Relids lateral_referencers
Relids direct_lateral_relids
Index baserestrict_min_security
Relids incompatible_relids
LockClauseStrength strength
TypeCacheEntry * lookup_type_cache(Oid type_id, int flags)
#define TYPECACHE_HASH_PROC
List * pull_vars_of_level(Node *node, int levelsup)
List * pull_var_clause(Node *node, int flags)
Relids pull_varnos(PlannerInfo *root, Node *node)