108 Index security_level,
111 Relids outerjoin_nonnullable,
112 bool allow_equivalence,
115 List **postponed_oj_qual_list);
119 Index security_level,
122 Relids outerjoin_nonnullable,
123 bool allow_equivalence,
126 List **postponed_oj_qual_list);
182 elog(
ERROR,
"unrecognized node type: %d",
200 RelOptInfo *rel = root->simple_rel_array[rti];
240 if (tlist_vars !=
NIL)
256 if (having_vars !=
NIL)
299 if (rel->attr_needed[attno] == NULL)
309 var->varnullingrels = NULL;
370 RelOptInfo *brel = root->simple_rel_array[rti];
470 newvars =
lappend(newvars, node);
502 bool found_laterals =
false;
518 RelOptInfo *brel = root->simple_rel_array[rti];
531 lateral_relids = NULL;
542 found_laterals =
true;
551 found_laterals =
true;
586 found_laterals =
true;
639 RelOptInfo *brel = root->simple_rel_array[rti];
640 Relids outer_lateral_relids;
648 if (outer_lateral_relids == NULL)
654 RelOptInfo *brel2 = root->simple_rel_array[rti2];
662 outer_lateral_relids);
673 RelOptInfo *brel = root->simple_rel_array[rti];
692 RelOptInfo *brel2 = root->simple_rel_array[rti2];
767 foreach(lc, item_list)
780 foreach(lc, item_list)
833 jtitem->
jdomain = parent_domain;
849 jtitem->
jdomain = parent_domain;
878 if (sub_members <= 1 ||
882 joinlist =
lappend(joinlist, sub_joinlist);
909 jtitem->
jdomain = parent_domain;
936 jtitem->
jdomain = child_domain;
975 jtitem->
jdomain = parent_domain;
1049 elog(
ERROR,
"unrecognized join type: %d",
1051 leftjoinlist = rightjoinlist =
NIL;
1068 joinlist =
list_concat(leftjoinlist, rightjoinlist);
1080 leftpart = (
Node *) leftjoinlist;
1084 rightpart = (
Node *) rightjoinlist;
1090 elog(
ERROR,
"unrecognized node type: %d",
1096 *item_list =
lappend(*item_list, jtitem);
1156 List **postponed_oj_qual_list;
1220 postponed_oj_qual_list = NULL;
1231 postponed_oj_qual_list);
1239 elog(
ERROR,
"unrecognized node type: %d",
1262 Index security_level = 0;
1295 Assert(security_level <= root->qual_security_level);
1314 RelOptInfo *rel = root->simple_rel_array[relid];
1389 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1392 errmsg(
"%s cannot be applied to the nullable side of an outer join",
1452 commute_below_l = commute_below_r = NULL;
1456 bool have_unsafe_phvs;
1500 have_unsafe_phvs =
false;
1523 (have_unsafe_phvs ||
1649 if (commute_below_l || commute_below_r)
1661 commute_below =
bms_union(commute_below_l, commute_below_r);
1693 List *semi_operators;
1694 List *semi_rhs_exprs;
1735 semi_operators =
NIL;
1736 semi_rhs_exprs =
NIL;
1778 all_varnos =
bms_union(left_varnos, right_varnos);
1809 right_expr = left_expr;
1831 if (!(all_btree || all_hash))
1835 semi_operators =
lappend_oid(semi_operators, opno);
1840 if (semi_rhs_exprs ==
NIL)
1899 int save_last_rinfo_serial;
1941 joins_so_far = NULL;
1942 foreach(lc, jtitems)
1946 bool below_sjinfo =
false;
1947 bool above_sjinfo =
false;
1950 bool allow_equivalence,
1954 if (othersj == NULL)
1960 below_sjinfo =
true;
1962 else if (othersj ==
sjinfo)
1970 above_sjinfo =
true;
2000 this_ojscope =
bms_union(ojscope, joins_so_far);
2028 allow_equivalence = (joins_so_far == NULL);
2029 has_clone = allow_equivalence;
2030 is_clone = !has_clone;
2093 Index security_level,
2096 Relids outerjoin_nonnullable,
2097 bool allow_equivalence,
2100 List **postponed_oj_qual_list)
2104 foreach(lc, clauses)
2114 outerjoin_nonnullable,
2118 postponed_oj_qual_list);
2166 Index security_level,
2169 Relids outerjoin_nonnullable,
2170 bool allow_equivalence,
2173 List **postponed_oj_qual_list)
2176 bool is_pushed_down;
2177 bool pseudoconstant =
false;
2178 bool maybe_equivalence;
2179 bool maybe_outer_join;
2220 elog(
ERROR,
"failed to postpone qual containing lateral reference");
2228 elog(
ERROR,
"JOIN qualification cannot refer to other relations");
2280 pseudoconstant =
true;
2327 if (postponed_oj_qual_list != NULL)
2329 *postponed_oj_qual_list =
lappend(*postponed_oj_qual_list, clause);
2340 is_pushed_down =
false;
2341 maybe_equivalence =
false;
2342 maybe_outer_join =
true;
2361 is_pushed_down =
true;
2373 maybe_equivalence = allow_equivalence;
2379 maybe_outer_join =
false;
2391 outerjoin_nonnullable);
2426 where_needed = relids;
2470 if (restrictinfo->mergeopfamilies)
2472 if (maybe_equivalence)
2477 if (restrictinfo->mergeopfamilies)
2481 else if (maybe_outer_join && restrictinfo->can_join)
2488 outerjoin_nonnullable) &&
2490 outerjoin_nonnullable))
2495 ojcinfo->
rinfo = restrictinfo;
2502 outerjoin_nonnullable) &&
2504 outerjoin_nonnullable))
2509 ojcinfo->
rinfo = restrictinfo;
2520 ojcinfo->
rinfo = restrictinfo;
2552 Var *forced_null_var;
2557 if (forced_null_var == NULL)
2566 if (forced_null_var->varnullingrels == NULL)
2650 elog(
ERROR,
"cannot cope with variable-free clause");
2693 Index security_level,
2699 bool pseudoconstant =
false;
2724 if (!cclause->constisnull &&
DatumGetBool(cclause->constvalue))
2750 pseudoconstant =
true;
2806 return restrictinfo;
2829 Index security_level)
2862 return restrictinfo;
2950 con_rel = root->simple_rel_array[fkinfo->
con_relid];
2951 if (con_rel == NULL)
2953 ref_rel = root->simple_rel_array[fkinfo->
ref_relid];
2954 if (ref_rel == NULL)
2973 for (colno = 0; colno < fkinfo->
nkeys; colno++)
2995 con_attno = fkinfo->conkey[colno];
2996 ref_attno = fkinfo->confkey[colno];
3016 if (!(leftvar &&
IsA(leftvar,
Var)))
3020 if (!(rightvar &&
IsA(rightvar,
Var)))
3024 if (fkinfo->
ref_relid == leftvar->varno &&
3025 ref_attno == leftvar->varattno &&
3027 con_attno == rightvar->varattno)
3030 if (clause->
opno == fkinfo->conpfeqop[colno])
3037 else if (fkinfo->
ref_relid == rightvar->varno &&
3038 ref_attno == rightvar->varattno &&
3040 con_attno == leftvar->varattno)
3051 if (clause->
opno == fpeqop)
3060 if (fkinfo->
rinfos[colno])
3071 newlist =
lappend(newlist, fkinfo);
3100 if (restrictinfo->pseudoconstant)
3107 opno = ((
OpExpr *) clause)->opno;
3137 if (restrictinfo->pseudoconstant)
3144 opno = ((
OpExpr *) clause)->opno;
3149 restrictinfo->hashjoinoperator = opno;
3166 if (restrictinfo->pseudoconstant)
3179 restrictinfo->left_hasheqoperator = typentry->
eq_opr;
3187 if (lefttype != righttype)
3192 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)
int bms_singleton_member(const Bitmapset *a)
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 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)
elog(ERROR, "%s: %s", p2, msg)
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 distribute_quals_to_rels(PlannerInfo *root, List *clauses, JoinTreeItem *jtitem, SpecialJoinInfo *sjinfo, Index security_level, Relids qualscope, Relids ojscope, Relids outerjoin_nonnullable, bool allow_equivalence, bool has_clone, bool is_clone, List **postponed_oj_qual_list)
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)
void add_base_rels_to_query(PlannerInfo *root, Node *jtnode)
void build_base_rel_tlists(PlannerInfo *root, List *final_tlist)
static void deconstruct_distribute_oj_quals(PlannerInfo *root, List *jtitems, JoinTreeItem *jtitem)
static void distribute_qual_to_rels(PlannerInfo *root, Node *clause, JoinTreeItem *jtitem, SpecialJoinInfo *sjinfo, Index security_level, Relids qualscope, Relids ojscope, Relids outerjoin_nonnullable, 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)
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)
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)
Assert(fmt[strlen(fmt) - 1] !='\n')
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)
Oid exprType(const Node *expr)
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)
RestrictInfo * make_restrictinfo(PlannerInfo *root, Expr *clause, bool is_pushed_down, bool pseudoconstant, Index security_level, Relids required_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
int simple_rel_array_size
Index qual_security_level
List * right_join_clauses
bool hasPseudoConstantQuals
struct TableSampleClause * tablesample
struct PathTarget * reltarget
Relids lateral_referencers
Relids direct_lateral_relids
Index baserestrict_min_security
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)