analyzejoins.c File Reference

#include "postgres.h"
#include "catalog/pg_class.h"
#include "nodes/nodeFuncs.h"
#include "optimizer/joininfo.h"
#include "optimizer/optimizer.h"
#include "optimizer/pathnode.h"
#include "optimizer/paths.h"
#include "optimizer/placeholder.h"
#include "optimizer/planmain.h"
#include "optimizer/restrictinfo.h"
#include "rewrite/rewriteManip.h"
#include "utils/lsyscache.h"

Include dependency graph for analyzejoins.c:

Go to the source code of this file.

Data Structures
struct	SelfJoinCandidate

Functions
static bool	join_is_removable (PlannerInfo *root, SpecialJoinInfo *sjinfo)
static void	remove_leftjoinrel_from_query (PlannerInfo *root, int relid, SpecialJoinInfo *sjinfo)
static void	remove_rel_from_restrictinfo (RestrictInfo *rinfo, int relid, int ojrelid)
static void	remove_rel_from_eclass (EquivalenceClass *ec, SpecialJoinInfo *sjinfo, int relid, int subst)
static List *	remove_rel_from_joinlist (List *joinlist, int relid, int *nremoved)
static bool	rel_supports_distinctness (PlannerInfo *root, RelOptInfo *rel)
static bool	rel_is_distinct_for (PlannerInfo *root, RelOptInfo *rel, List *clause_list, List **extra_clauses)
static Oid	distinct_col_search (int colno, List *colnos, List *opids)
static bool	is_innerrel_unique_for (PlannerInfo *root, Relids joinrelids, Relids outerrelids, RelOptInfo *innerrel, JoinType jointype, List *restrictlist, List **extra_clauses)
static int	self_join_candidates_cmp (const void *a, const void *b)
List *	remove_useless_joins (PlannerInfo *root, List *joinlist)
static void	remove_rel_from_query (PlannerInfo *root, RelOptInfo *rel, int subst, SpecialJoinInfo *sjinfo, Relids joinrelids)
void	reduce_unique_semijoins (PlannerInfo *root)
bool	query_supports_distinctness (Query *query)
bool	query_is_distinct_for (Query *query, List *colnos, List *opids)
bool	innerrel_is_unique (PlannerInfo *root, Relids joinrelids, Relids outerrelids, RelOptInfo *innerrel, JoinType jointype, List *restrictlist, bool force_cache)
bool	innerrel_is_unique_ext (PlannerInfo *root, Relids joinrelids, Relids outerrelids, RelOptInfo *innerrel, JoinType jointype, List *restrictlist, bool force_cache, List **extra_clauses)
static void	update_eclasses (EquivalenceClass *ec, int from, int to)
static bool	restrict_infos_logically_equal (RestrictInfo *a, RestrictInfo *b)
static void	add_non_redundant_clauses (PlannerInfo *root, List *rinfo_candidates, List **keep_rinfo_list, Index removed_relid)
static void	remove_self_join_rel (PlannerInfo *root, PlanRowMark *kmark, PlanRowMark *rmark, RelOptInfo *toKeep, RelOptInfo *toRemove, List *restrictlist)
static void	split_selfjoin_quals (PlannerInfo *root, List *joinquals, List **selfjoinquals, List **otherjoinquals, int from, int to)
static bool	match_unique_clauses (PlannerInfo *root, RelOptInfo *outer, List *uclauses, Index relid)
static Relids	remove_self_joins_one_group (PlannerInfo *root, Relids relids)
static Relids	remove_self_joins_recurse (PlannerInfo *root, List *joinlist, Relids toRemove)
List *	remove_useless_self_joins (PlannerInfo *root, List *joinlist)

Variables
bool	enable_self_join_elimination

Function Documentation

add_non_redundant_clauses()

static void add_non_redundant_clauses ( PlannerInfo *  root, List *  rinfo_candidates, List **  keep_rinfo_list, Index  removed_relid  )

static

Definition at line 1638 of file analyzejoins.c.

{
    foreach_node(RestrictInfo, rinfo, rinfo_candidates)
    {
        bool        is_redundant = false;
 
        Assert(!bms_is_member(removed_relid, rinfo->required_relids));
 
        foreach_node(RestrictInfo, src, (*keep_rinfo_list))
        {
            if (!bms_equal(src->clause_relids, rinfo->clause_relids))
                /* Can't compare trivially different clauses */
                continue;
 
            if (src == rinfo ||
                (rinfo->parent_ec != NULL &&
                 src->parent_ec == rinfo->parent_ec) ||
                restrict_infos_logically_equal(rinfo, src))
            {
                is_redundant = true;
                break;
            }
        }
        if (!is_redundant)
            distribute_restrictinfo_to_rels(root, rinfo);
    }
}

References Assert(), bms_equal(), bms_is_member(), distribute_restrictinfo_to_rels(), foreach_node, restrict_infos_logically_equal(), and root.

Referenced by remove_self_join_rel().

distinct_col_search()

static Oid distinct_col_search ( int  colno, List *  colnos, List *  opids  )

static

Definition at line 1248 of file analyzejoins.c.

{
    ListCell   *lc1,
               *lc2;
 
    forboth(lc1, colnos, lc2, opids)
    {
        if (colno == lfirst_int(lc1))
            return lfirst_oid(lc2);
    }
    return InvalidOid;
}

References forboth, InvalidOid, lfirst_int, and lfirst_oid.

Referenced by query_is_distinct_for().

innerrel_is_unique()

bool innerrel_is_unique	(	PlannerInfo *	root,
		Relids	joinrelids,
		Relids	outerrelids,
		RelOptInfo *	innerrel,
		JoinType	jointype,
		List *	restrictlist,
		bool	force_cache
	)

Definition at line 1288 of file analyzejoins.c.

{
    return innerrel_is_unique_ext(root, joinrelids, outerrelids, innerrel,
                                  jointype, restrictlist, force_cache, NULL);
}

References innerrel_is_unique_ext(), and root.

Referenced by add_paths_to_joinrel(), and reduce_unique_semijoins().

innerrel_is_unique_ext()

bool innerrel_is_unique_ext	(	PlannerInfo *	root,
		Relids	joinrelids,
		Relids	outerrelids,
		RelOptInfo *	innerrel,
		JoinType	jointype,
		List *	restrictlist,
		bool	force_cache,
		List **	extra_clauses
	)

Definition at line 1310 of file analyzejoins.c.

{
    MemoryContext old_context;
    ListCell   *lc;
    UniqueRelInfo *uniqueRelInfo;
    List       *outer_exprs = NIL;
    bool        self_join = (extra_clauses != NULL);
 
    /* Certainly can't prove uniqueness when there are no joinclauses */
    if (restrictlist == NIL)
        return false;
 
    /*
     * Make a quick check to eliminate cases in which we will surely be unable
     * to prove uniqueness of the innerrel.
     */
    if (!rel_supports_distinctness(root, innerrel))
        return false;
 
    /*
     * Query the cache to see if we've managed to prove that innerrel is
     * unique for any subset of this outerrel.  For non-self-join search, we
     * don't need an exact match, as extra outerrels can't make the innerrel
     * any less unique (or more formally, the restrictlist for a join to a
     * superset outerrel must be a superset of the conditions we successfully
     * used before). For self-join search, we require an exact match of
     * outerrels because we need extra clauses to be valid for our case. Also,
     * for self-join checking we've filtered the clauses list.  Thus, we can
     * match only the result cached for a self-join search for another
     * self-join check.
     */
    foreach(lc, innerrel->unique_for_rels)
    {
        uniqueRelInfo = (UniqueRelInfo *) lfirst(lc);
 
        if ((!self_join && bms_is_subset(uniqueRelInfo->outerrelids, outerrelids)) ||
            (self_join && bms_equal(uniqueRelInfo->outerrelids, outerrelids) &&
             uniqueRelInfo->self_join))
        {
            if (extra_clauses)
                *extra_clauses = uniqueRelInfo->extra_clauses;
            return true;        /* Success! */
        }
    }
 
    /*
     * Conversely, we may have already determined that this outerrel, or some
     * superset thereof, cannot prove this innerrel to be unique.
     */
    foreach(lc, innerrel->non_unique_for_rels)
    {
        Relids      unique_for_rels = (Relids) lfirst(lc);
 
        if (bms_is_subset(outerrelids, unique_for_rels))
            return false;
    }
 
    /* No cached information, so try to make the proof. */
    if (is_innerrel_unique_for(root, joinrelids, outerrelids, innerrel,
                               jointype, restrictlist,
                               self_join ? &outer_exprs : NULL))
    {
        /*
         * Cache the positive result for future probes, being sure to keep it
         * in the planner_cxt even if we are working in GEQO.
         *
         * Note: one might consider trying to isolate the minimal subset of
         * the outerrels that proved the innerrel unique.  But it's not worth
         * the trouble, because the planner builds up joinrels incrementally
         * and so we'll see the minimally sufficient outerrels before any
         * supersets of them anyway.
         */
        old_context = MemoryContextSwitchTo(root->planner_cxt);
        uniqueRelInfo = makeNode(UniqueRelInfo);
        uniqueRelInfo->outerrelids = bms_copy(outerrelids);
        uniqueRelInfo->self_join = self_join;
        uniqueRelInfo->extra_clauses = outer_exprs;
        innerrel->unique_for_rels = lappend(innerrel->unique_for_rels,
                                            uniqueRelInfo);
        MemoryContextSwitchTo(old_context);
 
        if (extra_clauses)
            *extra_clauses = outer_exprs;
        return true;            /* Success! */
    }
    else
    {
        /*
         * None of the join conditions for outerrel proved innerrel unique, so
         * we can safely reject this outerrel or any subset of it in future
         * checks.
         *
         * However, in normal planning mode, caching this knowledge is totally
         * pointless; it won't be queried again, because we build up joinrels
         * from smaller to larger.  It is useful in GEQO mode, where the
         * knowledge can be carried across successive planning attempts; and
         * it's likely to be useful when using join-search plugins, too. Hence
         * cache when join_search_private is non-NULL.  (Yeah, that's a hack,
         * but it seems reasonable.)
         *
         * Also, allow callers to override that heuristic and force caching;
         * that's useful for reduce_unique_semijoins, which calls here before
         * the normal join search starts.
         */
        if (force_cache || root->join_search_private)
        {
            old_context = MemoryContextSwitchTo(root->planner_cxt);
            innerrel->non_unique_for_rels =
                lappend(innerrel->non_unique_for_rels,
                        bms_copy(outerrelids));
            MemoryContextSwitchTo(old_context);
        }
 
        return false;
    }
}

References bms_copy(), bms_equal(), bms_is_subset(), UniqueRelInfo::extra_clauses, is_innerrel_unique_for(), lappend(), lfirst, makeNode, MemoryContextSwitchTo(), NIL, RelOptInfo::non_unique_for_rels, UniqueRelInfo::outerrelids, rel_supports_distinctness(), root, UniqueRelInfo::self_join, and RelOptInfo::unique_for_rels.

Referenced by innerrel_is_unique(), and remove_self_joins_one_group().

is_innerrel_unique_for()

static bool is_innerrel_unique_for ( PlannerInfo *  root, Relids  joinrelids, Relids  outerrelids, RelOptInfo *  innerrel, JoinType  jointype, List *  restrictlist, List **  extra_clauses  )

static

Definition at line 1440 of file analyzejoins.c.

{
    List       *clause_list = NIL;
    ListCell   *lc;
 
    /*
     * Search for mergejoinable clauses that constrain the inner rel against
     * the outer rel.  If an operator is mergejoinable then it behaves like
     * equality for some btree opclass, so it's what we want.  The
     * mergejoinability test also eliminates clauses containing volatile
     * functions, which we couldn't depend on.
     */
    foreach(lc, restrictlist)
    {
        RestrictInfo *restrictinfo = (RestrictInfo *) lfirst(lc);
 
        /*
         * As noted above, if it's a pushed-down clause and we're at an outer
         * join, we can't use it.
         */
        if (IS_OUTER_JOIN(jointype) &&
            RINFO_IS_PUSHED_DOWN(restrictinfo, joinrelids))
            continue;
 
        /* Ignore if it's not a mergejoinable clause */
        if (!restrictinfo->can_join ||
            restrictinfo->mergeopfamilies == NIL)
            continue;           /* not mergejoinable */
 
        /*
         * Check if the clause has the form "outer op inner" or "inner op
         * outer", and if so mark which side is inner.
         */
        if (!clause_sides_match_join(restrictinfo, outerrelids,
                                     innerrel->relids))
            continue;           /* no good for these input relations */
 
        /* OK, add to the list */
        clause_list = lappend(clause_list, restrictinfo);
    }
 
    /* Let rel_is_distinct_for() do the hard work */
    return rel_is_distinct_for(root, innerrel, clause_list, extra_clauses);
}

References clause_sides_match_join(), IS_OUTER_JOIN, lappend(), lfirst, NIL, rel_is_distinct_for(), RelOptInfo::relids, RINFO_IS_PUSHED_DOWN, and root.

Referenced by innerrel_is_unique_ext().

join_is_removable()

static bool join_is_removable ( PlannerInfo *  root, SpecialJoinInfo *  sjinfo  )

static

Definition at line 153 of file analyzejoins.c.

{
    int         innerrelid;
    RelOptInfo *innerrel;
    Relids      inputrelids;
    Relids      joinrelids;
    List       *clause_list = NIL;
    ListCell   *l;
    int         attroff;
 
    /*
     * Must be a left join to a single baserel, else we aren't going to be
     * able to do anything with it.
     */
    if (sjinfo->jointype != JOIN_LEFT)
        return false;
 
    if (!bms_get_singleton_member(sjinfo->min_righthand, &innerrelid))
        return false;
 
    /*
     * Never try to eliminate a left join to the query result rel.  Although
     * the case is syntactically impossible in standard SQL, MERGE will build
     * a join tree that looks exactly like that.
     */
    if (innerrelid == root->parse->resultRelation)
        return false;
 
    innerrel = find_base_rel(root, innerrelid);
 
    /*
     * Before we go to the effort of checking whether any innerrel variables
     * are needed above the join, make a quick check to eliminate cases in
     * which we will surely be unable to prove uniqueness of the innerrel.
     */
    if (!rel_supports_distinctness(root, innerrel))
        return false;
 
    /* Compute the relid set for the join we are considering */
    inputrelids = bms_union(sjinfo->min_lefthand, sjinfo->min_righthand);
    Assert(sjinfo->ojrelid != 0);
    joinrelids = bms_copy(inputrelids);
    joinrelids = bms_add_member(joinrelids, sjinfo->ojrelid);
 
    /*
     * We can't remove the join if any inner-rel attributes are used above the
     * join.  Here, "above" the join includes pushed-down conditions, so we
     * should reject if attr_needed includes the OJ's own relid; therefore,
     * compare to inputrelids not joinrelids.
     *
     * As a micro-optimization, it seems better to start with max_attr and
     * count down rather than starting with min_attr and counting up, on the
     * theory that the system attributes are somewhat less likely to be wanted
     * and should be tested last.
     */
    for (attroff = innerrel->max_attr - innerrel->min_attr;
         attroff >= 0;
         attroff--)
    {
        if (!bms_is_subset(innerrel->attr_needed[attroff], inputrelids))
            return false;
    }
 
    /*
     * Similarly check that the inner rel isn't needed by any PlaceHolderVars
     * that will be used above the join.  The PHV case is a little bit more
     * complicated, because PHVs may have been assigned a ph_eval_at location
     * that includes the innerrel, yet their contained expression might not
     * actually reference the innerrel (it could be just a constant, for
     * instance).  If such a PHV is due to be evaluated above the join then it
     * needn't prevent join removal.
     */
    foreach(l, root->placeholder_list)
    {
        PlaceHolderInfo *phinfo = (PlaceHolderInfo *) lfirst(l);
 
        if (bms_overlap(phinfo->ph_lateral, innerrel->relids))
            return false;       /* it references innerrel laterally */
        if (!bms_overlap(phinfo->ph_eval_at, innerrel->relids))
            continue;           /* it definitely doesn't reference innerrel */
        if (bms_is_subset(phinfo->ph_needed, inputrelids))
            continue;           /* PHV is not used above the join */
        if (!bms_is_member(sjinfo->ojrelid, phinfo->ph_eval_at))
            return false;       /* it has to be evaluated below the join */
 
        /*
         * We need to be sure there will still be a place to evaluate the PHV
         * if we remove the join, ie that ph_eval_at wouldn't become empty.
         */
        if (!bms_overlap(sjinfo->min_lefthand, phinfo->ph_eval_at))
            return false;       /* there isn't any other place to eval PHV */
        /* Check contained expression last, since this is a bit expensive */
        if (bms_overlap(pull_varnos(root, (Node *) phinfo->ph_var->phexpr),
                        innerrel->relids))
            return false;       /* contained expression references innerrel */
    }
 
    /*
     * Search for mergejoinable clauses that constrain the inner rel against
     * either the outer rel or a pseudoconstant.  If an operator is
     * mergejoinable then it behaves like equality for some btree opclass, so
     * it's what we want.  The mergejoinability test also eliminates clauses
     * containing volatile functions, which we couldn't depend on.
     */
    foreach(l, innerrel->joininfo)
    {
        RestrictInfo *restrictinfo = (RestrictInfo *) lfirst(l);
 
        /*
         * If the current join commutes with some other outer join(s) via
         * outer join identity 3, there will be multiple clones of its join
         * clauses in the joininfo list.  We want to consider only the
         * has_clone form of such clauses.  Processing more than one form
         * would be wasteful, and also some of the others would confuse the
         * RINFO_IS_PUSHED_DOWN test below.
         */
        if (restrictinfo->is_clone)
            continue;           /* ignore it */
 
        /*
         * If it's not a join clause for this outer join, we can't use it.
         * Note that if the clause is pushed-down, then it is logically from
         * above the outer join, even if it references no other rels (it might
         * be from WHERE, for example).
         */
        if (RINFO_IS_PUSHED_DOWN(restrictinfo, joinrelids))
            continue;           /* ignore; not useful here */
 
        /* Ignore if it's not a mergejoinable clause */
        if (!restrictinfo->can_join ||
            restrictinfo->mergeopfamilies == NIL)
            continue;           /* not mergejoinable */
 
        /*
         * Check if the clause has the form "outer op inner" or "inner op
         * outer", and if so mark which side is inner.
         */
        if (!clause_sides_match_join(restrictinfo, sjinfo->min_lefthand,
                                     innerrel->relids))
            continue;           /* no good for these input relations */
 
        /* OK, add to list */
        clause_list = lappend(clause_list, restrictinfo);
    }
 
    /*
     * Now that we have the relevant equality join clauses, try to prove the
     * innerrel distinct.
     */
    if (rel_is_distinct_for(root, innerrel, clause_list, NULL))
        return true;
 
    /*
     * Some day it would be nice to check for other methods of establishing
     * distinctness.
     */
    return false;
}

References Assert(), bms_add_member(), bms_copy(), bms_get_singleton_member(), bms_is_member(), bms_is_subset(), bms_overlap(), bms_union(), clause_sides_match_join(), find_base_rel(), RestrictInfo::is_clone, JOIN_LEFT, RelOptInfo::joininfo, SpecialJoinInfo::jointype, lappend(), lfirst, RelOptInfo::max_attr, RelOptInfo::min_attr, SpecialJoinInfo::min_lefthand, SpecialJoinInfo::min_righthand, NIL, SpecialJoinInfo::ojrelid, PlaceHolderInfo::ph_eval_at, PlaceHolderInfo::ph_lateral, PlaceHolderInfo::ph_needed, PlaceHolderInfo::ph_var, pull_varnos(), rel_is_distinct_for(), rel_supports_distinctness(), RelOptInfo::relids, RINFO_IS_PUSHED_DOWN, and root.

Referenced by remove_useless_joins().

match_unique_clauses()

static bool match_unique_clauses ( PlannerInfo *  root, RelOptInfo *  outer, List *  uclauses, Index  relid  )

static

Definition at line 1931 of file analyzejoins.c.

{
    foreach_node(RestrictInfo, rinfo, uclauses)
    {
        Expr       *clause;
        Node       *iclause;
        Node       *c1;
        bool        matched = false;
 
        Assert(outer->relid > 0 && relid > 0);
 
        /* Only filters like f(R.x1,...,R.xN) == expr we should consider. */
        Assert(bms_is_empty(rinfo->left_relids) ^
               bms_is_empty(rinfo->right_relids));
 
        clause = (Expr *) copyObject(rinfo->clause);
        ChangeVarNodes((Node *) clause, relid, outer->relid, 0);
 
        iclause = bms_is_empty(rinfo->left_relids) ? get_rightop(clause) :
            get_leftop(clause);
        c1 = bms_is_empty(rinfo->left_relids) ? get_leftop(clause) :
            get_rightop(clause);
 
        /*
         * Compare these left and right sides with the corresponding sides of
         * the outer's filters. If no one is detected - return immediately.
         */
        foreach_node(RestrictInfo, orinfo, outer->baserestrictinfo)
        {
            Node       *oclause;
            Node       *c2;
 
            if (orinfo->mergeopfamilies == NIL)
                /* Don't consider clauses that aren't similar to 'F(X)=G(Y)' */
                continue;
 
            Assert(is_opclause(orinfo->clause));
 
            oclause = bms_is_empty(orinfo->left_relids) ?
                get_rightop(orinfo->clause) : get_leftop(orinfo->clause);
            c2 = (bms_is_empty(orinfo->left_relids) ?
                  get_leftop(orinfo->clause) : get_rightop(orinfo->clause));
 
            if (equal(iclause, oclause) && equal(c1, c2))
            {
                matched = true;
                break;
            }
        }
 
        if (!matched)
            return false;
    }
 
    return true;
}

References Assert(), RelOptInfo::baserestrictinfo, bms_is_empty, ChangeVarNodes(), copyObject, equal(), foreach_node, get_leftop(), get_rightop(), is_opclause(), NIL, and RelOptInfo::relid.

Referenced by remove_self_joins_one_group().

query_is_distinct_for()

bool query_is_distinct_for	(	Query *	query,
		List *	colnos,
		List *	opids
	)

Definition at line 1099 of file analyzejoins.c.

{
    ListCell   *l;
    Oid         opid;
 
    Assert(list_length(colnos) == list_length(opids));
 
    /*
     * DISTINCT (including DISTINCT ON) guarantees uniqueness if all the
     * columns in the DISTINCT clause appear in colnos and operator semantics
     * match.  This is true even if there are SRFs in the DISTINCT columns or
     * elsewhere in the tlist.
     */
    if (query->distinctClause)
    {
        foreach(l, query->distinctClause)
        {
            SortGroupClause *sgc = (SortGroupClause *) lfirst(l);
            TargetEntry *tle = get_sortgroupclause_tle(sgc,
                                                       query->targetList);
 
            opid = distinct_col_search(tle->resno, colnos, opids);
            if (!OidIsValid(opid) ||
                !equality_ops_are_compatible(opid, sgc->eqop))
                break;          /* exit early if no match */
        }
        if (l == NULL)          /* had matches for all? */
            return true;
    }
 
    /*
     * Otherwise, a set-returning function in the query's targetlist can
     * result in returning duplicate rows, despite any grouping that might
     * occur before tlist evaluation.  (If all tlist SRFs are within GROUP BY
     * columns, it would be safe because they'd be expanded before grouping.
     * But it doesn't currently seem worth the effort to check for that.)
     */
    if (query->hasTargetSRFs)
        return false;
 
    /*
     * Similarly, GROUP BY without GROUPING SETS guarantees uniqueness if all
     * the grouped columns appear in colnos and operator semantics match.
     */
    if (query->groupClause && !query->groupingSets)
    {
        foreach(l, query->groupClause)
        {
            SortGroupClause *sgc = (SortGroupClause *) lfirst(l);
            TargetEntry *tle = get_sortgroupclause_tle(sgc,
                                                       query->targetList);
 
            opid = distinct_col_search(tle->resno, colnos, opids);
            if (!OidIsValid(opid) ||
                !equality_ops_are_compatible(opid, sgc->eqop))
                break;          /* exit early if no match */
        }
        if (l == NULL)          /* had matches for all? */
            return true;
    }
    else if (query->groupingSets)
    {
        /*
         * If we have grouping sets with expressions, we probably don't have
         * uniqueness and analysis would be hard. Punt.
         */
        if (query->groupClause)
            return false;
 
        /*
         * If we have no groupClause (therefore no grouping expressions), we
         * might have one or many empty grouping sets. If there's just one,
         * then we're returning only one row and are certainly unique. But
         * otherwise, we know we're certainly not unique.
         */
        if (list_length(query->groupingSets) == 1 &&
            ((GroupingSet *) linitial(query->groupingSets))->kind == GROUPING_SET_EMPTY)
            return true;
        else
            return false;
    }
    else
    {
        /*
         * If we have no GROUP BY, but do have aggregates or HAVING, then the
         * result is at most one row so it's surely unique, for any operators.
         */
        if (query->hasAggs || query->havingQual)
            return true;
    }
 
    /*
     * UNION, INTERSECT, EXCEPT guarantee uniqueness of the whole output row,
     * except with ALL.
     */
    if (query->setOperations)
    {
        SetOperationStmt *topop = castNode(SetOperationStmt, query->setOperations);
 
        Assert(topop->op != SETOP_NONE);
 
        if (!topop->all)
        {
            ListCell   *lg;
 
            /* We're good if all the nonjunk output columns are in colnos */
            lg = list_head(topop->groupClauses);
            foreach(l, query->targetList)
            {
                TargetEntry *tle = (TargetEntry *) lfirst(l);
                SortGroupClause *sgc;
 
                if (tle->resjunk)
                    continue;   /* ignore resjunk columns */
 
                /* non-resjunk columns should have grouping clauses */
                Assert(lg != NULL);
                sgc = (SortGroupClause *) lfirst(lg);
                lg = lnext(topop->groupClauses, lg);
 
                opid = distinct_col_search(tle->resno, colnos, opids);
                if (!OidIsValid(opid) ||
                    !equality_ops_are_compatible(opid, sgc->eqop))
                    break;      /* exit early if no match */
            }
            if (l == NULL)      /* had matches for all? */
                return true;
        }
    }
 
    /*
     * XXX Are there any other cases in which we can easily see the result
     * must be distinct?
     *
     * If you do add more smarts to this function, be sure to update
     * query_supports_distinctness() to match.
     */
 
    return false;
}

References SetOperationStmt::all, Assert(), castNode, distinct_col_search(), Query::distinctClause, SortGroupClause::eqop, equality_ops_are_compatible(), get_sortgroupclause_tle(), Query::groupClause, GROUPING_SET_EMPTY, Query::groupingSets, Query::havingQual, lfirst, linitial, list_head(), list_length(), lnext(), OidIsValid, SetOperationStmt::op, TargetEntry::resno, SETOP_NONE, Query::setOperations, and Query::targetList.

Referenced by create_unique_path(), and rel_is_distinct_for().

query_supports_distinctness()

bool query_supports_distinctness

(

Query *

query

)

Definition at line 1061 of file analyzejoins.c.

{
    /* SRFs break distinctness except with DISTINCT, see below */
    if (query->hasTargetSRFs && query->distinctClause == NIL)
        return false;
 
    /* check for features we can prove distinctness with */
    if (query->distinctClause != NIL ||
        query->groupClause != NIL ||
        query->groupingSets != NIL ||
        query->hasAggs ||
        query->havingQual ||
        query->setOperations)
        return true;
 
    return false;
}

References Query::distinctClause, Query::groupClause, Query::groupingSets, Query::havingQual, NIL, and Query::setOperations.

Referenced by create_unique_path(), and rel_supports_distinctness().

reduce_unique_semijoins()

void reduce_unique_semijoins

(

PlannerInfo *

root

)

Definition at line 826 of file analyzejoins.c.

{
    ListCell   *lc;
 
    /*
     * Scan the join_info_list to find semijoins.
     */
    foreach(lc, root->join_info_list)
    {
        SpecialJoinInfo *sjinfo = (SpecialJoinInfo *) lfirst(lc);
        int         innerrelid;
        RelOptInfo *innerrel;
        Relids      joinrelids;
        List       *restrictlist;
 
        /*
         * Must be a semijoin to a single baserel, else we aren't going to be
         * able to do anything with it.
         */
        if (sjinfo->jointype != JOIN_SEMI)
            continue;
 
        if (!bms_get_singleton_member(sjinfo->min_righthand, &innerrelid))
            continue;
 
        innerrel = find_base_rel(root, innerrelid);
 
        /*
         * Before we trouble to run generate_join_implied_equalities, make a
         * quick check to eliminate cases in which we will surely be unable to
         * prove uniqueness of the innerrel.
         */
        if (!rel_supports_distinctness(root, innerrel))
            continue;
 
        /* Compute the relid set for the join we are considering */
        joinrelids = bms_union(sjinfo->min_lefthand, sjinfo->min_righthand);
        Assert(sjinfo->ojrelid == 0);   /* SEMI joins don't have RT indexes */
 
        /*
         * Since we're only considering a single-rel RHS, any join clauses it
         * has must be clauses linking it to the semijoin's min_lefthand.  We
         * can also consider EC-derived join clauses.
         */
        restrictlist =
            list_concat(generate_join_implied_equalities(root,
                                                         joinrelids,
                                                         sjinfo->min_lefthand,
                                                         innerrel,
                                                         NULL),
                        innerrel->joininfo);
 
        /* Test whether the innerrel is unique for those clauses. */
        if (!innerrel_is_unique(root,
                                joinrelids, sjinfo->min_lefthand, innerrel,
                                JOIN_SEMI, restrictlist, true))
            continue;
 
        /* OK, remove the SpecialJoinInfo from the list. */
        root->join_info_list = foreach_delete_current(root->join_info_list, lc);
    }
}

References Assert(), bms_get_singleton_member(), bms_union(), find_base_rel(), foreach_delete_current, generate_join_implied_equalities(), innerrel_is_unique(), JOIN_SEMI, RelOptInfo::joininfo, SpecialJoinInfo::jointype, lfirst, list_concat(), SpecialJoinInfo::min_lefthand, SpecialJoinInfo::min_righthand, SpecialJoinInfo::ojrelid, rel_supports_distinctness(), and root.

Referenced by query_planner().

rel_is_distinct_for()

static bool rel_is_distinct_for ( PlannerInfo *  root, RelOptInfo *  rel, List *  clause_list, List **  extra_clauses  )

static

Definition at line 962 of file analyzejoins.c.

{
    /*
     * We could skip a couple of tests here if we assume all callers checked
     * rel_supports_distinctness first, but it doesn't seem worth taking any
     * risk for.
     */
    if (rel->reloptkind != RELOPT_BASEREL)
        return false;
    if (rel->rtekind == RTE_RELATION)
    {
        /*
         * Examine the indexes to see if we have a matching unique index.
         * relation_has_unique_index_ext automatically adds any usable
         * restriction clauses for the rel, so we needn't do that here.
         */
        if (relation_has_unique_index_ext(root, rel, clause_list, NIL, NIL,
                                          extra_clauses))
            return true;
    }
    else if (rel->rtekind == RTE_SUBQUERY)
    {
        Index       relid = rel->relid;
        Query      *subquery = root->simple_rte_array[relid]->subquery;
        List       *colnos = NIL;
        List       *opids = NIL;
        ListCell   *l;
 
        /*
         * Build the argument lists for query_is_distinct_for: a list of
         * output column numbers that the query needs to be distinct over, and
         * a list of equality operators that the output columns need to be
         * distinct according to.
         *
         * (XXX we are not considering restriction clauses attached to the
         * subquery; is that worth doing?)
         */
        foreach(l, clause_list)
        {
            RestrictInfo *rinfo = lfirst_node(RestrictInfo, l);
            Oid         op;
            Var        *var;
 
            /*
             * Get the equality operator we need uniqueness according to.
             * (This might be a cross-type operator and thus not exactly the
             * same operator the subquery would consider; that's all right
             * since query_is_distinct_for can resolve such cases.)  The
             * caller's mergejoinability test should have selected only
             * OpExprs.
             */
            op = castNode(OpExpr, rinfo->clause)->opno;
 
            /* caller identified the inner side for us */
            if (rinfo->outer_is_left)
                var = (Var *) get_rightop(rinfo->clause);
            else
                var = (Var *) get_leftop(rinfo->clause);
 
            /*
             * We may ignore any RelabelType node above the operand.  (There
             * won't be more than one, since eval_const_expressions() has been
             * applied already.)
             */
            if (var && IsA(var, RelabelType))
                var = (Var *) ((RelabelType *) var)->arg;
 
            /*
             * If inner side isn't a Var referencing a subquery output column,
             * this clause doesn't help us.
             */
            if (!var || !IsA(var, Var) ||
                var->varno != relid || var->varlevelsup != 0)
                continue;
 
            colnos = lappend_int(colnos, var->varattno);
            opids = lappend_oid(opids, op);
        }
 
        if (query_is_distinct_for(subquery, colnos, opids))
            return true;
    }
    return false;
}

References castNode, RestrictInfo::clause, get_leftop(), get_rightop(), IsA, lappend_int(), lappend_oid(), lfirst_node, NIL, query_is_distinct_for(), relation_has_unique_index_ext(), RelOptInfo::relid, RELOPT_BASEREL, RelOptInfo::reloptkind, root, RTE_RELATION, RTE_SUBQUERY, RelOptInfo::rtekind, Var::varattno, Var::varlevelsup, and Var::varno.

Referenced by is_innerrel_unique_for(), and join_is_removable().

rel_supports_distinctness()

static bool rel_supports_distinctness ( PlannerInfo *  root, RelOptInfo *  rel  )

static

Definition at line 902 of file analyzejoins.c.

{
    /* We only know about baserels ... */
    if (rel->reloptkind != RELOPT_BASEREL)
        return false;
    if (rel->rtekind == RTE_RELATION)
    {
        /*
         * For a plain relation, we only know how to prove uniqueness by
         * reference to unique indexes.  Make sure there's at least one
         * suitable unique index.  It must be immediately enforced, and not a
         * partial index. (Keep these conditions in sync with
         * relation_has_unique_index_for!)
         */
        ListCell   *lc;
 
        foreach(lc, rel->indexlist)
        {
            IndexOptInfo *ind = (IndexOptInfo *) lfirst(lc);
 
            if (ind->unique && ind->immediate && ind->indpred == NIL)
                return true;
        }
    }
    else if (rel->rtekind == RTE_SUBQUERY)
    {
        Query      *subquery = root->simple_rte_array[rel->relid]->subquery;
 
        /* Check if the subquery has any qualities that support distinctness */
        if (query_supports_distinctness(subquery))
            return true;
    }
    /* We have no proof rules for any other rtekinds. */
    return false;
}

References RelOptInfo::indexlist, lfirst, NIL, query_supports_distinctness(), RelOptInfo::relid, RELOPT_BASEREL, RelOptInfo::reloptkind, root, RTE_RELATION, RTE_SUBQUERY, and RelOptInfo::rtekind.

Referenced by innerrel_is_unique_ext(), join_is_removable(), and reduce_unique_semijoins().

remove_leftjoinrel_from_query()

static void remove_leftjoinrel_from_query ( PlannerInfo *  root, int  relid, SpecialJoinInfo *  sjinfo  )

static

Definition at line 528 of file analyzejoins.c.

{
    RelOptInfo *rel = find_base_rel(root, relid);
    int         ojrelid = sjinfo->ojrelid;
    Relids      joinrelids;
    Relids      join_plus_commute;
    List       *joininfos;
    ListCell   *l;
 
    /* Compute the relid set for the join we are considering */
    joinrelids = bms_union(sjinfo->min_lefthand, sjinfo->min_righthand);
    Assert(ojrelid != 0);
    joinrelids = bms_add_member(joinrelids, ojrelid);
 
    remove_rel_from_query(root, rel, -1, sjinfo, joinrelids);
 
    /*
     * Remove any joinquals referencing the rel from the joininfo lists.
     *
     * In some cases, a joinqual has to be put back after deleting its
     * reference to the target rel.  This can occur for pseudoconstant and
     * outerjoin-delayed quals, which can get marked as requiring the rel in
     * order to force them to be evaluated at or above the join.  We can't
     * just discard them, though.  Only quals that logically belonged to the
     * outer join being discarded should be removed from the query.
     *
     * We might encounter a qual that is a clone of a deletable qual with some
     * outer-join relids added (see deconstruct_distribute_oj_quals).  To
     * ensure we get rid of such clones as well, add the relids of all OJs
     * commutable with this one to the set we test against for
     * pushed-down-ness.
     */
    join_plus_commute = bms_union(joinrelids,
                                  sjinfo->commute_above_r);
    join_plus_commute = bms_add_members(join_plus_commute,
                                        sjinfo->commute_below_l);
 
    /*
     * We must make a copy of the rel's old joininfo list before starting the
     * loop, because otherwise remove_join_clause_from_rels would destroy the
     * list while we're scanning it.
     */
    joininfos = list_copy(rel->joininfo);
    foreach(l, joininfos)
    {
        RestrictInfo *rinfo = (RestrictInfo *) lfirst(l);
 
        remove_join_clause_from_rels(root, rinfo, rinfo->required_relids);
 
        if (RINFO_IS_PUSHED_DOWN(rinfo, join_plus_commute))
        {
            /*
             * There might be references to relid or ojrelid in the
             * RestrictInfo's relid sets, as a consequence of PHVs having had
             * ph_eval_at sets that include those.  We already checked above
             * that any such PHV is safe (and updated its ph_eval_at), so we
             * can just drop those references.
             */
            remove_rel_from_restrictinfo(rinfo, relid, ojrelid);
 
            /*
             * Cross-check that the clause itself does not reference the
             * target rel or join.
             */
#ifdef USE_ASSERT_CHECKING
            {
                Relids      clause_varnos = pull_varnos(root,
                                                        (Node *) rinfo->clause);
 
                Assert(!bms_is_member(relid, clause_varnos));
                Assert(!bms_is_member(ojrelid, clause_varnos));
            }
#endif
            /* Now throw it back into the joininfo lists */
            distribute_restrictinfo_to_rels(root, rinfo);
        }
    }
 
    /*
     * There may be references to the rel in root->fkey_list, but if so,
     * match_foreign_keys_to_quals() will get rid of them.
     */
 
    /*
     * Now remove the rel from the baserel array to prevent it from being
     * referenced again.  (We can't do this earlier because
     * remove_join_clause_from_rels will touch it.)
     */
    root->simple_rel_array[relid] = NULL;
 
    /* And nuke the RelOptInfo, just in case there's another access path */
    pfree(rel);
 
    /*
     * Now repeat construction of attr_needed bits coming from all other
     * sources.
     */
    rebuild_placeholder_attr_needed(root);
    rebuild_joinclause_attr_needed(root);
    rebuild_eclass_attr_needed(root);
    rebuild_lateral_attr_needed(root);
}

References Assert(), bms_add_member(), bms_add_members(), bms_is_member(), bms_union(), RestrictInfo::clause, SpecialJoinInfo::commute_above_r, SpecialJoinInfo::commute_below_l, distribute_restrictinfo_to_rels(), find_base_rel(), RelOptInfo::joininfo, lfirst, list_copy(), SpecialJoinInfo::min_lefthand, SpecialJoinInfo::min_righthand, SpecialJoinInfo::ojrelid, pfree(), pull_varnos(), rebuild_eclass_attr_needed(), rebuild_joinclause_attr_needed(), rebuild_lateral_attr_needed(), rebuild_placeholder_attr_needed(), remove_join_clause_from_rels(), remove_rel_from_query(), remove_rel_from_restrictinfo(), RestrictInfo::required_relids, RINFO_IS_PUSHED_DOWN, and root.

Referenced by remove_useless_joins().

remove_rel_from_eclass()

static void remove_rel_from_eclass ( EquivalenceClass *  ec, SpecialJoinInfo *  sjinfo, int  relid, int  subst  )

static

Definition at line 702 of file analyzejoins.c.

{
    ListCell   *lc;
 
    /* Fix up the EC's overall relids */
    ec->ec_relids = adjust_relid_set(ec->ec_relids, relid, subst);
    if (sjinfo != NULL)
        ec->ec_relids = adjust_relid_set(ec->ec_relids,
                                         sjinfo->ojrelid, subst);
 
    /*
     * We don't expect any EC child members to exist at this point.  Ensure
     * that's the case, otherwise, we might be getting asked to do something
     * this function hasn't been coded for.
     */
    Assert(ec->ec_childmembers == NULL);
 
    /*
     * Fix up the member expressions.  Any non-const member that ends with
     * empty em_relids must be a Var or PHV of the removed relation.  We don't
     * need it anymore, so we can drop it.
     */
    foreach(lc, ec->ec_members)
    {
        EquivalenceMember *cur_em = (EquivalenceMember *) lfirst(lc);
 
        if (bms_is_member(relid, cur_em->em_relids) ||
            (sjinfo != NULL && bms_is_member(sjinfo->ojrelid,
                                             cur_em->em_relids)))
        {
            Assert(!cur_em->em_is_const);
            cur_em->em_relids = adjust_relid_set(cur_em->em_relids, relid, subst);
            if (sjinfo != NULL)
                cur_em->em_relids = adjust_relid_set(cur_em->em_relids,
                                                     sjinfo->ojrelid, subst);
            if (bms_is_empty(cur_em->em_relids))
                ec->ec_members = foreach_delete_current(ec->ec_members, lc);
        }
    }
 
    /* Fix up the source clauses, in case we can re-use them later */
    foreach(lc, ec->ec_sources)
    {
        RestrictInfo *rinfo = (RestrictInfo *) lfirst(lc);
 
        if (sjinfo == NULL)
            ChangeVarNodes((Node *) rinfo, relid, subst, 0);
        else
            remove_rel_from_restrictinfo(rinfo, relid, sjinfo->ojrelid);
    }
 
    /*
     * Rather than expend code on fixing up any already-derived clauses, just
     * drop them.  (At this point, any such clauses would be base restriction
     * clauses, which we'd not need anymore anyway.)
     */
    ec_clear_derived_clauses(ec);
}

References adjust_relid_set(), Assert(), bms_is_empty, bms_is_member(), ChangeVarNodes(), EquivalenceClass::ec_childmembers, ec_clear_derived_clauses(), EquivalenceClass::ec_members, EquivalenceClass::ec_relids, EquivalenceClass::ec_sources, EquivalenceMember::em_is_const, EquivalenceMember::em_relids, foreach_delete_current, lfirst, SpecialJoinInfo::ojrelid, and remove_rel_from_restrictinfo().

Referenced by remove_rel_from_query().

remove_rel_from_joinlist()

static List * remove_rel_from_joinlist ( List *  joinlist, int  relid, int *  nremoved  )

static

Definition at line 772 of file analyzejoins.c.

{
    List       *result = NIL;
    ListCell   *jl;
 
    foreach(jl, joinlist)
    {
        Node       *jlnode = (Node *) lfirst(jl);
 
        if (IsA(jlnode, RangeTblRef))
        {
            int         varno = ((RangeTblRef *) jlnode)->rtindex;
 
            if (varno == relid)
                (*nremoved)++;
            else
                result = lappend(result, jlnode);
        }
        else if (IsA(jlnode, List))
        {
            /* Recurse to handle subproblem */
            List       *sublist;
 
            sublist = remove_rel_from_joinlist((List *) jlnode,
                                               relid, nremoved);
            /* Avoid including empty sub-lists in the result */
            if (sublist)
                result = lappend(result, sublist);
        }
        else
        {
            elog(ERROR, "unrecognized joinlist node type: %d",
                 (int) nodeTag(jlnode));
        }
    }
 
    return result;
}

References elog, ERROR, IsA, lappend(), lfirst, NIL, nodeTag, and remove_rel_from_joinlist().

Referenced by remove_rel_from_joinlist(), remove_useless_joins(), and remove_useless_self_joins().

remove_rel_from_query()

static void remove_rel_from_query ( PlannerInfo *  root, RelOptInfo *  rel, int  subst, SpecialJoinInfo *  sjinfo, Relids  joinrelids  )

static

Definition at line 323 of file analyzejoins.c.

{
    int         relid = rel->relid;
    Index       rti;
    ListCell   *l;
 
    /*
     * Update all_baserels and related relid sets.
     */
    root->all_baserels = adjust_relid_set(root->all_baserels, relid, subst);
    root->all_query_rels = adjust_relid_set(root->all_query_rels, relid, subst);
 
    if (sjinfo != NULL)
    {
        root->outer_join_rels = bms_del_member(root->outer_join_rels,
                                               sjinfo->ojrelid);
        root->all_query_rels = bms_del_member(root->all_query_rels,
                                              sjinfo->ojrelid);
    }
 
    /*
     * Likewise remove references from SpecialJoinInfo data structures.
     *
     * This is relevant in case the outer join we're deleting is nested inside
     * other outer joins: the upper joins' relid sets have to be adjusted. The
     * RHS of the target outer join will be made empty here, but that's OK
     * since caller will delete that SpecialJoinInfo entirely.
     */
    foreach(l, root->join_info_list)
    {
        SpecialJoinInfo *sjinf = (SpecialJoinInfo *) lfirst(l);
 
        /*
         * initsplan.c is fairly cavalier about allowing SpecialJoinInfos'
         * lefthand/righthand relid sets to be shared with other data
         * structures.  Ensure that we don't modify the original relid sets.
         * (The commute_xxx sets are always per-SpecialJoinInfo though.)
         */
        sjinf->min_lefthand = bms_copy(sjinf->min_lefthand);
        sjinf->min_righthand = bms_copy(sjinf->min_righthand);
        sjinf->syn_lefthand = bms_copy(sjinf->syn_lefthand);
        sjinf->syn_righthand = bms_copy(sjinf->syn_righthand);
        /* Now remove relid from the sets: */
        sjinf->min_lefthand = adjust_relid_set(sjinf->min_lefthand, relid, subst);
        sjinf->min_righthand = adjust_relid_set(sjinf->min_righthand, relid, subst);
        sjinf->syn_lefthand = adjust_relid_set(sjinf->syn_lefthand, relid, subst);
        sjinf->syn_righthand = adjust_relid_set(sjinf->syn_righthand, relid, subst);
 
        if (sjinfo != NULL)
        {
            Assert(subst <= 0);
 
            /* Remove sjinfo->ojrelid bits from the sets: */
            sjinf->min_lefthand = bms_del_member(sjinf->min_lefthand,
                                                 sjinfo->ojrelid);
            sjinf->min_righthand = bms_del_member(sjinf->min_righthand,
                                                  sjinfo->ojrelid);
            sjinf->syn_lefthand = bms_del_member(sjinf->syn_lefthand,
                                                 sjinfo->ojrelid);
            sjinf->syn_righthand = bms_del_member(sjinf->syn_righthand,
                                                  sjinfo->ojrelid);
            /* relid cannot appear in these fields, but ojrelid can: */
            sjinf->commute_above_l = bms_del_member(sjinf->commute_above_l,
                                                    sjinfo->ojrelid);
            sjinf->commute_above_r = bms_del_member(sjinf->commute_above_r,
                                                    sjinfo->ojrelid);
            sjinf->commute_below_l = bms_del_member(sjinf->commute_below_l,
                                                    sjinfo->ojrelid);
            sjinf->commute_below_r = bms_del_member(sjinf->commute_below_r,
                                                    sjinfo->ojrelid);
        }
        else
        {
            Assert(subst > 0);
 
            ChangeVarNodes((Node *) sjinf->semi_rhs_exprs, relid, subst, 0);
        }
    }
 
    /*
     * Likewise remove references from PlaceHolderVar data structures,
     * removing any no-longer-needed placeholders entirely.
     *
     * Removal is a bit trickier than it might seem: we can remove PHVs that
     * are used at the target rel and/or in the join qual, but not those that
     * are used at join partner rels or above the join.  It's not that easy to
     * distinguish PHVs used at partner rels from those used in the join qual,
     * since they will both have ph_needed sets that are subsets of
     * joinrelids.  However, a PHV used at a partner rel could not have the
     * target rel in ph_eval_at, so we check that while deciding whether to
     * remove or just update the PHV.  There is no corresponding test in
     * join_is_removable because it doesn't need to distinguish those cases.
     */
    foreach(l, root->placeholder_list)
    {
        PlaceHolderInfo *phinfo = (PlaceHolderInfo *) lfirst(l);
 
        Assert(sjinfo == NULL || !bms_is_member(relid, phinfo->ph_lateral));
        if (bms_is_subset(phinfo->ph_needed, joinrelids) &&
            bms_is_member(relid, phinfo->ph_eval_at) &&
            (sjinfo == NULL || !bms_is_member(sjinfo->ojrelid, phinfo->ph_eval_at)))
        {
            root->placeholder_list = foreach_delete_current(root->placeholder_list,
                                                            l);
            root->placeholder_array[phinfo->phid] = NULL;
        }
        else
        {
            PlaceHolderVar *phv = phinfo->ph_var;
 
            phinfo->ph_eval_at = adjust_relid_set(phinfo->ph_eval_at, relid, subst);
            if (sjinfo != NULL)
                phinfo->ph_eval_at = adjust_relid_set(phinfo->ph_eval_at,
                                                      sjinfo->ojrelid, subst);
            Assert(!bms_is_empty(phinfo->ph_eval_at));  /* checked previously */
            /* Reduce ph_needed to contain only "relation 0"; see below */
            if (bms_is_member(0, phinfo->ph_needed))
                phinfo->ph_needed = bms_make_singleton(0);
            else
                phinfo->ph_needed = NULL;
 
            phinfo->ph_lateral = adjust_relid_set(phinfo->ph_lateral, relid, subst);
 
            /*
             * ph_lateral might contain rels mentioned in ph_eval_at after the
             * replacement, remove them.
             */
            phinfo->ph_lateral = bms_difference(phinfo->ph_lateral, phinfo->ph_eval_at);
            /* ph_lateral might or might not be empty */
 
            phv->phrels = adjust_relid_set(phv->phrels, relid, subst);
            if (sjinfo != NULL)
                phv->phrels = adjust_relid_set(phv->phrels,
                                               sjinfo->ojrelid, subst);
            Assert(!bms_is_empty(phv->phrels));
 
            ChangeVarNodes((Node *) phv->phexpr, relid, subst, 0);
 
            Assert(phv->phnullingrels == NULL); /* no need to adjust */
        }
    }
 
    /*
     * Likewise remove references from EquivalenceClasses.
     */
    foreach(l, root->eq_classes)
    {
        EquivalenceClass *ec = (EquivalenceClass *) lfirst(l);
 
        if (bms_is_member(relid, ec->ec_relids) ||
            (sjinfo == NULL || bms_is_member(sjinfo->ojrelid, ec->ec_relids)))
            remove_rel_from_eclass(ec, sjinfo, relid, subst);
    }
 
    /*
     * Finally, we must recompute per-Var attr_needed and per-PlaceHolderVar
     * ph_needed relid sets.  These have to be known accurately, else we may
     * fail to remove other now-removable outer joins.  And our removal of the
     * join clause(s) for this outer join may mean that Vars that were
     * formerly needed no longer are.  So we have to do this honestly by
     * repeating the construction of those relid sets.  We can cheat to one
     * small extent: we can avoid re-examining the targetlist and HAVING qual
     * by preserving "relation 0" bits from the existing relid sets.  This is
     * safe because we'd never remove such references.
     *
     * So, start by removing all other bits from attr_needed sets and
     * lateral_vars lists.  (We already did this above for ph_needed.)
     */
    for (rti = 1; rti < root->simple_rel_array_size; rti++)
    {
        RelOptInfo *otherrel = root->simple_rel_array[rti];
        int         attroff;
 
        /* there may be empty slots corresponding to non-baserel RTEs */
        if (otherrel == NULL)
            continue;
 
        Assert(otherrel->relid == rti); /* sanity check on array */
 
        for (attroff = otherrel->max_attr - otherrel->min_attr;
             attroff >= 0;
             attroff--)
        {
            if (bms_is_member(0, otherrel->attr_needed[attroff]))
                otherrel->attr_needed[attroff] = bms_make_singleton(0);
            else
                otherrel->attr_needed[attroff] = NULL;
        }
 
        if (subst > 0)
            ChangeVarNodes((Node *) otherrel->lateral_vars, relid, subst, 0);
    }
}

References adjust_relid_set(), Assert(), bms_copy(), bms_del_member(), bms_difference(), bms_is_empty, bms_is_member(), bms_is_subset(), bms_make_singleton(), ChangeVarNodes(), SpecialJoinInfo::commute_above_l, SpecialJoinInfo::commute_above_r, SpecialJoinInfo::commute_below_l, SpecialJoinInfo::commute_below_r, EquivalenceClass::ec_relids, foreach_delete_current, RelOptInfo::lateral_vars, lfirst, RelOptInfo::max_attr, RelOptInfo::min_attr, SpecialJoinInfo::min_lefthand, SpecialJoinInfo::min_righthand, SpecialJoinInfo::ojrelid, PlaceHolderInfo::ph_eval_at, PlaceHolderInfo::ph_lateral, PlaceHolderInfo::ph_needed, PlaceHolderInfo::ph_var, PlaceHolderInfo::phid, PlaceHolderVar::phnullingrels, RelOptInfo::relid, remove_rel_from_eclass(), root, SpecialJoinInfo::semi_rhs_exprs, SpecialJoinInfo::syn_lefthand, and SpecialJoinInfo::syn_righthand.

Referenced by remove_leftjoinrel_from_query(), and remove_self_join_rel().

remove_rel_from_restrictinfo()

static void remove_rel_from_restrictinfo ( RestrictInfo *  rinfo, int  relid, int  ojrelid  )

static

Definition at line 641 of file analyzejoins.c.

{
    /*
     * initsplan.c is fairly cavalier about allowing RestrictInfos to share
     * relid sets with other RestrictInfos, and SpecialJoinInfos too.  Make
     * sure this RestrictInfo has its own relid sets before we modify them.
     * (In present usage, clause_relids is probably not shared, but
     * required_relids could be; let's not assume anything.)
     */
    rinfo->clause_relids = bms_copy(rinfo->clause_relids);
    rinfo->clause_relids = bms_del_member(rinfo->clause_relids, relid);
    rinfo->clause_relids = bms_del_member(rinfo->clause_relids, ojrelid);
    /* Likewise for required_relids */
    rinfo->required_relids = bms_copy(rinfo->required_relids);
    rinfo->required_relids = bms_del_member(rinfo->required_relids, relid);
    rinfo->required_relids = bms_del_member(rinfo->required_relids, ojrelid);
 
    /* If it's an OR, recurse to clean up sub-clauses */
    if (restriction_is_or_clause(rinfo))
    {
        ListCell   *lc;
 
        Assert(is_orclause(rinfo->orclause));
        foreach(lc, ((BoolExpr *) rinfo->orclause)->args)
        {
            Node       *orarg = (Node *) lfirst(lc);
 
            /* OR arguments should be ANDs or sub-RestrictInfos */
            if (is_andclause(orarg))
            {
                List       *andargs = ((BoolExpr *) orarg)->args;
                ListCell   *lc2;
 
                foreach(lc2, andargs)
                {
                    RestrictInfo *rinfo2 = lfirst_node(RestrictInfo, lc2);
 
                    remove_rel_from_restrictinfo(rinfo2, relid, ojrelid);
                }
            }
            else
            {
                RestrictInfo *rinfo2 = castNode(RestrictInfo, orarg);
 
                remove_rel_from_restrictinfo(rinfo2, relid, ojrelid);
            }
        }
    }
}

References Assert(), bms_copy(), bms_del_member(), castNode, is_andclause(), is_orclause(), lfirst, lfirst_node, remove_rel_from_restrictinfo(), RestrictInfo::required_relids, and restriction_is_or_clause().

Referenced by remove_leftjoinrel_from_query(), remove_rel_from_eclass(), and remove_rel_from_restrictinfo().

remove_self_join_rel()

static void remove_self_join_rel ( PlannerInfo *  root, PlanRowMark *  kmark, PlanRowMark *  rmark, RelOptInfo *  toKeep, RelOptInfo *  toRemove, List *  restrictlist  )

static

Definition at line 1694 of file analyzejoins.c.

{
    List       *joininfos;
    ListCell   *lc;
    int         i;
    List       *jinfo_candidates = NIL;
    List       *binfo_candidates = NIL;
 
    Assert(toKeep->relid > 0);
    Assert(toRemove->relid > 0);
 
    /*
     * Replace the index of the removing table with the keeping one. The
     * technique of removing/distributing restrictinfo is used here to attach
     * just appeared (for keeping relation) join clauses and avoid adding
     * duplicates of those that already exist in the joininfo list.
     */
    joininfos = list_copy(toRemove->joininfo);
    foreach_node(RestrictInfo, rinfo, joininfos)
    {
        remove_join_clause_from_rels(root, rinfo, rinfo->required_relids);
        ChangeVarNodes((Node *) rinfo, toRemove->relid, toKeep->relid, 0);
 
        if (bms_membership(rinfo->required_relids) == BMS_MULTIPLE)
            jinfo_candidates = lappend(jinfo_candidates, rinfo);
        else
            binfo_candidates = lappend(binfo_candidates, rinfo);
    }
 
    /*
     * Concatenate restrictlist to the list of base restrictions of the
     * removing table just to simplify the replacement procedure: all of them
     * weren't connected to any keeping relations and need to be added to some
     * rels.
     */
    toRemove->baserestrictinfo = list_concat(toRemove->baserestrictinfo,
                                             restrictlist);
    foreach_node(RestrictInfo, rinfo, toRemove->baserestrictinfo)
    {
        ChangeVarNodes((Node *) rinfo, toRemove->relid, toKeep->relid, 0);
 
        if (bms_membership(rinfo->required_relids) == BMS_MULTIPLE)
            jinfo_candidates = lappend(jinfo_candidates, rinfo);
        else
            binfo_candidates = lappend(binfo_candidates, rinfo);
    }
 
    /*
     * Now, add all non-redundant clauses to the keeping relation.
     */
    add_non_redundant_clauses(root, binfo_candidates,
                              &toKeep->baserestrictinfo, toRemove->relid);
    add_non_redundant_clauses(root, jinfo_candidates,
                              &toKeep->joininfo, toRemove->relid);
 
    list_free(binfo_candidates);
    list_free(jinfo_candidates);
 
    /*
     * Arrange equivalence classes, mentioned removing a table, with the
     * keeping one: varno of removing table should be replaced in members and
     * sources lists. Also, remove duplicated elements if this replacement
     * procedure created them.
     */
    i = -1;
    while ((i = bms_next_member(toRemove->eclass_indexes, i)) >= 0)
    {
        EquivalenceClass *ec = (EquivalenceClass *) list_nth(root->eq_classes, i);
 
        update_eclasses(ec, toRemove->relid, toKeep->relid);
        toKeep->eclass_indexes = bms_add_member(toKeep->eclass_indexes, i);
    }
 
    /*
     * Transfer the targetlist and attr_needed flags.
     */
 
    foreach(lc, toRemove->reltarget->exprs)
    {
        Node       *node = lfirst(lc);
 
        ChangeVarNodes(node, toRemove->relid, toKeep->relid, 0);
        if (!list_member(toKeep->reltarget->exprs, node))
            toKeep->reltarget->exprs = lappend(toKeep->reltarget->exprs, node);
    }
 
    for (i = toKeep->min_attr; i <= toKeep->max_attr; i++)
    {
        int         attno = i - toKeep->min_attr;
 
        toRemove->attr_needed[attno] = adjust_relid_set(toRemove->attr_needed[attno],
                                                        toRemove->relid, toKeep->relid);
        toKeep->attr_needed[attno] = bms_add_members(toKeep->attr_needed[attno],
                                                     toRemove->attr_needed[attno]);
    }
 
    /*
     * If the removed relation has a row mark, transfer it to the remaining
     * one.
     *
     * If both rels have row marks, just keep the one corresponding to the
     * remaining relation because we verified earlier that they have the same
     * strength.
     */
    if (rmark)
    {
        if (kmark)
        {
            Assert(kmark->markType == rmark->markType);
 
            root->rowMarks = list_delete_ptr(root->rowMarks, rmark);
        }
        else
        {
            /* Shouldn't have inheritance children here. */
            Assert(rmark->rti == rmark->prti);
 
            rmark->rti = rmark->prti = toKeep->relid;
        }
    }
 
    /*
     * Replace varno in all the query structures, except nodes RangeTblRef
     * otherwise later remove_rel_from_joinlist will yield errors.
     */
    ChangeVarNodesExtended((Node *) root->parse, toRemove->relid, toKeep->relid, 0, false);
 
    /* Replace links in the planner info */
    remove_rel_from_query(root, toRemove, toKeep->relid, NULL, NULL);
 
    /* At last, replace varno in root targetlist and HAVING clause */
    ChangeVarNodes((Node *) root->processed_tlist, toRemove->relid, toKeep->relid, 0);
    ChangeVarNodes((Node *) root->processed_groupClause, toRemove->relid, toKeep->relid, 0);
 
    adjust_relid_set(root->all_result_relids, toRemove->relid, toKeep->relid);
    adjust_relid_set(root->leaf_result_relids, toRemove->relid, toKeep->relid);
 
    /*
     * There may be references to the rel in root->fkey_list, but if so,
     * match_foreign_keys_to_quals() will get rid of them.
     */
 
    /*
     * Finally, remove the rel from the baserel array to prevent it from being
     * referenced again.  (We can't do this earlier because
     * remove_join_clause_from_rels will touch it.)
     */
    root->simple_rel_array[toRemove->relid] = NULL;
 
    /* And nuke the RelOptInfo, just in case there's another access path. */
    pfree(toRemove);
 
    /*
     * Now repeat construction of attr_needed bits coming from all other
     * sources.
     */
    rebuild_placeholder_attr_needed(root);
    rebuild_joinclause_attr_needed(root);
    rebuild_eclass_attr_needed(root);
    rebuild_lateral_attr_needed(root);
}

References add_non_redundant_clauses(), adjust_relid_set(), Assert(), RelOptInfo::baserestrictinfo, bms_add_member(), bms_add_members(), bms_membership(), BMS_MULTIPLE, bms_next_member(), ChangeVarNodes(), ChangeVarNodesExtended(), RelOptInfo::eclass_indexes, PathTarget::exprs, foreach_node, i, RelOptInfo::joininfo, lappend(), lfirst, list_concat(), list_copy(), list_delete_ptr(), list_free(), list_member(), list_nth(), PlanRowMark::markType, RelOptInfo::min_attr, NIL, pfree(), PlanRowMark::prti, rebuild_eclass_attr_needed(), rebuild_joinclause_attr_needed(), rebuild_lateral_attr_needed(), rebuild_placeholder_attr_needed(), RelOptInfo::relid, RelOptInfo::reltarget, remove_join_clause_from_rels(), remove_rel_from_query(), root, PlanRowMark::rti, and update_eclasses().

Referenced by remove_self_joins_one_group().

remove_self_joins_one_group()

static Relids remove_self_joins_one_group ( PlannerInfo *  root, Relids  relids  )

static

Definition at line 1996 of file analyzejoins.c.

{
    Relids      result = NULL;
    int         k;              /* Index of kept relation */
    int         r = -1;         /* Index of removed relation */
 
    while ((r = bms_next_member(relids, r)) > 0)
    {
        RelOptInfo *inner = root->simple_rel_array[r];
 
        k = r;
 
        while ((k = bms_next_member(relids, k)) > 0)
        {
            Relids      joinrelids = NULL;
            RelOptInfo *outer = root->simple_rel_array[k];
            List       *restrictlist;
            List       *selfjoinquals;
            List       *otherjoinquals;
            ListCell   *lc;
            bool        jinfo_check = true;
            PlanRowMark *omark = NULL;
            PlanRowMark *imark = NULL;
            List       *uclauses = NIL;
 
            /* A sanity check: the relations have the same Oid. */
            Assert(root->simple_rte_array[k]->relid ==
                   root->simple_rte_array[r]->relid);
 
            /*
             * It is impossible to eliminate the join of two relations if they
             * belong to different rules of order. Otherwise, the planner
             * can't find any variants of the correct query plan.
             */
            foreach(lc, root->join_info_list)
            {
                SpecialJoinInfo *info = (SpecialJoinInfo *) lfirst(lc);
 
                if ((bms_is_member(k, info->syn_lefthand) ^
                     bms_is_member(r, info->syn_lefthand)) ||
                    (bms_is_member(k, info->syn_righthand) ^
                     bms_is_member(r, info->syn_righthand)))
                {
                    jinfo_check = false;
                    break;
                }
            }
            if (!jinfo_check)
                continue;
 
            /*
             * Check Row Marks equivalence. We can't remove the join if the
             * relations have row marks of different strength (e.g., one is
             * locked FOR UPDATE, and another just has ROW_MARK_REFERENCE for
             * EvalPlanQual rechecking).
             */
            foreach(lc, root->rowMarks)
            {
                PlanRowMark *rowMark = (PlanRowMark *) lfirst(lc);
 
                if (rowMark->rti == k)
                {
                    Assert(imark == NULL);
                    imark = rowMark;
                }
                else if (rowMark->rti == r)
                {
                    Assert(omark == NULL);
                    omark = rowMark;
                }
 
                if (omark && imark)
                    break;
            }
            if (omark && imark && omark->markType != imark->markType)
                continue;
 
            /*
             * We only deal with base rels here, so their relids bitset
             * contains only one member -- their relid.
             */
            joinrelids = bms_add_member(joinrelids, r);
            joinrelids = bms_add_member(joinrelids, k);
 
            /*
             * PHVs should not impose any constraints on removing self-joins.
             */
 
            /*
             * At this stage, joininfo lists of inner and outer can contain
             * only clauses required for a superior outer join that can't
             * influence this optimization. So, we can avoid to call the
             * build_joinrel_restrictlist() routine.
             */
            restrictlist = generate_join_implied_equalities(root, joinrelids,
                                                            inner->relids,
                                                            outer, NULL);
            if (restrictlist == NIL)
                continue;
 
            /*
             * Process restrictlist to separate the self-join quals from the
             * other quals. e.g., "x = x" goes to selfjoinquals and "a = b" to
             * otherjoinquals.
             */
            split_selfjoin_quals(root, restrictlist, &selfjoinquals,
                                 &otherjoinquals, inner->relid, outer->relid);
 
            Assert(list_length(restrictlist) ==
                   (list_length(selfjoinquals) + list_length(otherjoinquals)));
 
            /*
             * To enable SJE for the only degenerate case without any self
             * join clauses at all, add baserestrictinfo to this list. The
             * degenerate case works only if both sides have the same clause.
             * So doesn't matter which side to add.
             */
            selfjoinquals = list_concat(selfjoinquals, outer->baserestrictinfo);
 
            /*
             * Determine if the inner table can duplicate outer rows.  We must
             * bypass the unique rel cache here since we're possibly using a
             * subset of join quals. We can use 'force_cache' == true when all
             * join quals are self-join quals.  Otherwise, we could end up
             * putting false negatives in the cache.
             */
            if (!innerrel_is_unique_ext(root, joinrelids, inner->relids,
                                        outer, JOIN_INNER, selfjoinquals,
                                        list_length(otherjoinquals) == 0,
                                        &uclauses))
                continue;
 
            /*
             * 'uclauses' is the copy of outer->baserestrictinfo that are
             * associated with an index.  We proved by matching selfjoinquals
             * to a unique index that the outer relation has at most one
             * matching row for each inner row.  Sometimes that is not enough.
             * e.g. "WHERE s1.b = s2.b AND s1.a = 1 AND s2.a = 2" when the
             * unique index is (a,b).  Having non-empty uclauses, we must
             * validate that the inner baserestrictinfo contains the same
             * expressions, or we won't match the same row on each side of the
             * join.
             */
            if (!match_unique_clauses(root, inner, uclauses, outer->relid))
                continue;
 
            /*
             * We can remove either relation, so remove the inner one in order
             * to simplify this loop.
             */
            remove_self_join_rel(root, omark, imark, outer, inner, restrictlist);
 
            result = bms_add_member(result, r);
 
            /* We have removed the outer relation, try the next one. */
            break;
        }
    }
 
    return result;
}

References Assert(), RelOptInfo::baserestrictinfo, bms_add_member(), bms_is_member(), bms_next_member(), generate_join_implied_equalities(), innerrel_is_unique_ext(), JOIN_INNER, lfirst, list_concat(), list_length(), PlanRowMark::markType, match_unique_clauses(), NIL, RelOptInfo::relid, RelOptInfo::relids, remove_self_join_rel(), root, PlanRowMark::rti, split_selfjoin_quals(), SpecialJoinInfo::syn_lefthand, and SpecialJoinInfo::syn_righthand.

Referenced by remove_self_joins_recurse().

remove_self_joins_recurse()

static Relids remove_self_joins_recurse ( PlannerInfo *  root, List *  joinlist, Relids  toRemove  )

static

Definition at line 2163 of file analyzejoins.c.

{
    ListCell   *jl;
    Relids      relids = NULL;
    SelfJoinCandidate *candidates = NULL;
    int         i;
    int         j;
    int         numRels;
 
    /* Collect indexes of base relations of the join tree */
    foreach(jl, joinlist)
    {
        Node       *jlnode = (Node *) lfirst(jl);
 
        if (IsA(jlnode, RangeTblRef))
        {
            int         varno = ((RangeTblRef *) jlnode)->rtindex;
            RangeTblEntry *rte = root->simple_rte_array[varno];
 
            /*
             * We only consider ordinary relations as candidates to be
             * removed, and these relations should not have TABLESAMPLE
             * clauses specified.  Removing a relation with TABLESAMPLE clause
             * could potentially change the syntax of the query. Because of
             * UPDATE/DELETE EPQ mechanism, currently Query->resultRelation or
             * Query->mergeTargetRelation associated rel cannot be eliminated.
             */
            if (rte->rtekind == RTE_RELATION &&
                rte->relkind == RELKIND_RELATION &&
                rte->tablesample == NULL &&
                varno != root->parse->resultRelation &&
                varno != root->parse->mergeTargetRelation)
            {
                Assert(!bms_is_member(varno, relids));
                relids = bms_add_member(relids, varno);
            }
        }
        else if (IsA(jlnode, List))
        {
            /* Recursively go inside the sub-joinlist */
            toRemove = remove_self_joins_recurse(root, (List *) jlnode,
                                                 toRemove);
        }
        else
            elog(ERROR, "unrecognized joinlist node type: %d",
                 (int) nodeTag(jlnode));
    }
 
    numRels = bms_num_members(relids);
 
    /* Need at least two relations for the join */
    if (numRels < 2)
        return toRemove;
 
    /*
     * In order to find relations with the same oid we first build an array of
     * candidates and then sort it by oid.
     */
    candidates = (SelfJoinCandidate *) palloc(sizeof(SelfJoinCandidate) *
                                              numRels);
    i = -1;
    j = 0;
    while ((i = bms_next_member(relids, i)) >= 0)
    {
        candidates[j].relid = i;
        candidates[j].reloid = root->simple_rte_array[i]->relid;
        j++;
    }
 
    qsort(candidates, numRels, sizeof(SelfJoinCandidate),
          self_join_candidates_cmp);
 
    /*
     * Iteratively form a group of relation indexes with the same oid and
     * launch the routine that detects self-joins in this group and removes
     * excessive range table entries.
     *
     * At the end of the iteration, exclude the group from the overall relids
     * list. So each next iteration of the cycle will involve less and less
     * value of relids.
     */
    i = 0;
    for (j = 1; j < numRels + 1; j++)
    {
        if (j == numRels || candidates[j].reloid != candidates[i].reloid)
        {
            if (j - i >= 2)
            {
                /* Create a group of relation indexes with the same oid */
                Relids      group = NULL;
                Relids      removed;
 
                while (i < j)
                {
                    group = bms_add_member(group, candidates[i].relid);
                    i++;
                }
                relids = bms_del_members(relids, group);
 
                /*
                 * Try to remove self-joins from a group of identical entries.
                 * Make the next attempt iteratively - if something is deleted
                 * from a group, changes in clauses and equivalence classes
                 * can give us a chance to find more candidates.
                 */
                do
                {
                    Assert(!bms_overlap(group, toRemove));
                    removed = remove_self_joins_one_group(root, group);
                    toRemove = bms_add_members(toRemove, removed);
                    group = bms_del_members(group, removed);
                } while (!bms_is_empty(removed) &&
                         bms_membership(group) == BMS_MULTIPLE);
                bms_free(removed);
                bms_free(group);
            }
            else
            {
                /* Single relation, just remove it from the set */
                relids = bms_del_member(relids, candidates[i].relid);
                i = j;
            }
        }
    }
 
    Assert(bms_is_empty(relids));
 
    return toRemove;
}

References Assert(), bms_add_member(), bms_add_members(), bms_del_member(), bms_del_members(), bms_free(), bms_is_empty, bms_is_member(), bms_membership(), BMS_MULTIPLE, bms_next_member(), bms_num_members(), bms_overlap(), elog, ERROR, i, IsA, j, lfirst, nodeTag, palloc(), qsort, SelfJoinCandidate::relid, SelfJoinCandidate::reloid, remove_self_joins_one_group(), remove_self_joins_recurse(), root, RTE_RELATION, RangeTblEntry::rtekind, self_join_candidates_cmp(), and RangeTblEntry::tablesample.

Referenced by remove_self_joins_recurse(), and remove_useless_self_joins().

remove_useless_joins()

List * remove_useless_joins	(	PlannerInfo *	root,
		List *	joinlist
	)

Definition at line 88 of file analyzejoins.c.

{
    ListCell   *lc;
 
    /*
     * We are only interested in relations that are left-joined to, so we can
     * scan the join_info_list to find them easily.
     */
restart:
    foreach(lc, root->join_info_list)
    {
        SpecialJoinInfo *sjinfo = (SpecialJoinInfo *) lfirst(lc);
        int         innerrelid;
        int         nremoved;
 
        /* Skip if not removable */
        if (!join_is_removable(root, sjinfo))
            continue;
 
        /*
         * Currently, join_is_removable can only succeed when the sjinfo's
         * righthand is a single baserel.  Remove that rel from the query and
         * joinlist.
         */
        innerrelid = bms_singleton_member(sjinfo->min_righthand);
 
        remove_leftjoinrel_from_query(root, innerrelid, sjinfo);
 
        /* We verify that exactly one reference gets removed from joinlist */
        nremoved = 0;
        joinlist = remove_rel_from_joinlist(joinlist, innerrelid, &nremoved);
        if (nremoved != 1)
            elog(ERROR, "failed to find relation %d in joinlist", innerrelid);
 
        /*
         * We can delete this SpecialJoinInfo from the list too, since it's no
         * longer of interest.  (Since we'll restart the foreach loop
         * immediately, we don't bother with foreach_delete_current.)
         */
        root->join_info_list = list_delete_cell(root->join_info_list, lc);
 
        /*
         * Restart the scan.  This is necessary to ensure we find all
         * removable joins independently of ordering of the join_info_list
         * (note that removal of attr_needed bits may make a join appear
         * removable that did not before).
         */
        goto restart;
    }
 
    return joinlist;
}

References bms_singleton_member(), elog, ERROR, join_is_removable(), lfirst, list_delete_cell(), SpecialJoinInfo::min_righthand, remove_leftjoinrel_from_query(), remove_rel_from_joinlist(), and root.

Referenced by query_planner().

remove_useless_self_joins()

List * remove_useless_self_joins	(	PlannerInfo *	root,
		List *	joinlist
	)

Definition at line 2344 of file analyzejoins.c.

{
    Relids      toRemove = NULL;
    int         relid = -1;
 
    if (!enable_self_join_elimination || joinlist == NIL ||
        (list_length(joinlist) == 1 && !IsA(linitial(joinlist), List)))
        return joinlist;
 
    /*
     * Merge pairs of relations participated in self-join. Remove unnecessary
     * range table entries.
     */
    toRemove = remove_self_joins_recurse(root, joinlist, toRemove);
 
    if (unlikely(toRemove != NULL))
    {
        /* At the end, remove orphaned relation links */
        while ((relid = bms_next_member(toRemove, relid)) >= 0)
        {
            int         nremoved = 0;
 
            joinlist = remove_rel_from_joinlist(joinlist, relid, &nremoved);
            if (nremoved != 1)
                elog(ERROR, "failed to find relation %d in joinlist", relid);
        }
    }
 
    return joinlist;
}

References bms_next_member(), elog, enable_self_join_elimination, ERROR, IsA, linitial, list_length(), NIL, remove_rel_from_joinlist(), remove_self_joins_recurse(), root, and unlikely.

Referenced by query_planner().

restrict_infos_logically_equal()

static bool restrict_infos_logically_equal ( RestrictInfo *  a, RestrictInfo *  b  )

static

Definition at line 1612 of file analyzejoins.c.

{
    int         saved_rinfo_serial = a->rinfo_serial;
    bool        result;
 
    a->rinfo_serial = b->rinfo_serial;
    result = equal(a, b);
    a->rinfo_serial = saved_rinfo_serial;
 
    return result;
}

References a, b, and equal().

Referenced by add_non_redundant_clauses().

self_join_candidates_cmp()

static int self_join_candidates_cmp ( const void *  a, const void *  b  )

static

Definition at line 2297 of file analyzejoins.c.

{
    const SelfJoinCandidate *ca = (const SelfJoinCandidate *) a;
    const SelfJoinCandidate *cb = (const SelfJoinCandidate *) b;
 
    if (ca->reloid != cb->reloid)
        return (ca->reloid < cb->reloid ? -1 : 1);
    else
        return 0;
}

References a, b, and SelfJoinCandidate::reloid.

Referenced by remove_self_joins_recurse().

split_selfjoin_quals()

static void split_selfjoin_quals ( PlannerInfo *  root, List *  joinquals, List **  selfjoinquals, List **  otherjoinquals, int  from, int  to  )

static

Definition at line 1868 of file analyzejoins.c.

{
    List       *sjoinquals = NIL;
    List       *ojoinquals = NIL;
 
    foreach_node(RestrictInfo, rinfo, joinquals)
    {
        OpExpr     *expr;
        Node       *leftexpr;
        Node       *rightexpr;
 
        /* In general, clause looks like F(arg1) = G(arg2) */
        if (!rinfo->mergeopfamilies ||
            bms_num_members(rinfo->clause_relids) != 2 ||
            bms_membership(rinfo->left_relids) != BMS_SINGLETON ||
            bms_membership(rinfo->right_relids) != BMS_SINGLETON)
        {
            ojoinquals = lappend(ojoinquals, rinfo);
            continue;
        }
 
        expr = (OpExpr *) rinfo->clause;
 
        if (!IsA(expr, OpExpr) || list_length(expr->args) != 2)
        {
            ojoinquals = lappend(ojoinquals, rinfo);
            continue;
        }
 
        leftexpr = get_leftop(rinfo->clause);
        rightexpr = copyObject(get_rightop(rinfo->clause));
 
        if (leftexpr && IsA(leftexpr, RelabelType))
            leftexpr = (Node *) ((RelabelType *) leftexpr)->arg;
        if (rightexpr && IsA(rightexpr, RelabelType))
            rightexpr = (Node *) ((RelabelType *) rightexpr)->arg;
 
        /*
         * Quite an expensive operation, narrowing the use case. For example,
         * when we have cast of the same var to different (but compatible)
         * types.
         */
        ChangeVarNodes(rightexpr, bms_singleton_member(rinfo->right_relids),
                       bms_singleton_member(rinfo->left_relids), 0);
 
        if (equal(leftexpr, rightexpr))
            sjoinquals = lappend(sjoinquals, rinfo);
        else
            ojoinquals = lappend(ojoinquals, rinfo);
    }
 
    *selfjoinquals = sjoinquals;
    *otherjoinquals = ojoinquals;
}

References arg, OpExpr::args, bms_membership(), bms_num_members(), BMS_SINGLETON, bms_singleton_member(), ChangeVarNodes(), copyObject, equal(), foreach_node, get_leftop(), get_rightop(), if(), IsA, lappend(), list_length(), and NIL.

Referenced by remove_self_joins_one_group().

update_eclasses()

static void update_eclasses ( EquivalenceClass *  ec, int  from, int  to  )

static

Definition at line 1514 of file analyzejoins.c.

{
    List       *new_members = NIL;
    List       *new_sources = NIL;
 
    /*
     * We don't expect any EC child members to exist at this point.  Ensure
     * that's the case, otherwise, we might be getting asked to do something
     * this function hasn't been coded for.
     */
    Assert(ec->ec_childmembers == NULL);
 
    foreach_node(EquivalenceMember, em, ec->ec_members)
    {
        bool        is_redundant = false;
 
        if (!bms_is_member(from, em->em_relids))
        {
            new_members = lappend(new_members, em);
            continue;
        }
 
        em->em_relids = adjust_relid_set(em->em_relids, from, to);
        em->em_jdomain->jd_relids = adjust_relid_set(em->em_jdomain->jd_relids, from, to);
 
        /* We only process inner joins */
        ChangeVarNodes((Node *) em->em_expr, from, to, 0);
 
        foreach_node(EquivalenceMember, other, new_members)
        {
            if (!equal(em->em_relids, other->em_relids))
                continue;
 
            if (equal(em->em_expr, other->em_expr))
            {
                is_redundant = true;
                break;
            }
        }
 
        if (!is_redundant)
            new_members = lappend(new_members, em);
    }
 
    list_free(ec->ec_members);
    ec->ec_members = new_members;
 
    ec_clear_derived_clauses(ec);
 
    /* Update EC source expressions */
    foreach_node(RestrictInfo, rinfo, ec->ec_sources)
    {
        bool        is_redundant = false;
 
        if (!bms_is_member(from, rinfo->required_relids))
        {
            new_sources = lappend(new_sources, rinfo);
            continue;
        }
 
        ChangeVarNodes((Node *) rinfo, from, to, 0);
 
        /*
         * After switching the clause to the remaining relation, check it for
         * redundancy with existing ones. We don't have to check for
         * redundancy with derived clauses, because we've just deleted them.
         */
        foreach_node(RestrictInfo, other, new_sources)
        {
            if (!equal(rinfo->clause_relids, other->clause_relids))
                continue;
 
            if (equal(rinfo->clause, other->clause))
            {
                is_redundant = true;
                break;
            }
        }
 
        if (!is_redundant)
            new_sources = lappend(new_sources, rinfo);
    }
 
    list_free(ec->ec_sources);
    ec->ec_sources = new_sources;
    ec->ec_relids = adjust_relid_set(ec->ec_relids, from, to);
}

References adjust_relid_set(), Assert(), bms_is_member(), ChangeVarNodes(), EquivalenceClass::ec_childmembers, ec_clear_derived_clauses(), EquivalenceClass::ec_members, EquivalenceClass::ec_relids, EquivalenceClass::ec_sources, equal(), foreach_node, lappend(), list_free(), and NIL.

Referenced by remove_self_join_rel().

Variable Documentation

enable_self_join_elimination

bool enable_self_join_elimination

Definition at line 53 of file analyzejoins.c.

Referenced by remove_useless_self_joins().