partprune.c File Reference

#include "postgres.h"
#include "access/hash.h"
#include "access/nbtree.h"
#include "catalog/pg_operator.h"
#include "catalog/pg_opfamily.h"
#include "catalog/pg_proc.h"
#include "catalog/pg_type.h"
#include "executor/executor.h"
#include "miscadmin.h"
#include "nodes/makefuncs.h"
#include "nodes/nodeFuncs.h"
#include "optimizer/appendinfo.h"
#include "optimizer/cost.h"
#include "optimizer/optimizer.h"
#include "optimizer/pathnode.h"
#include "parser/parsetree.h"
#include "partitioning/partbounds.h"
#include "partitioning/partprune.h"
#include "rewrite/rewriteManip.h"
#include "utils/array.h"
#include "utils/lsyscache.h"

Include dependency graph for partprune.c:

Go to the source code of this file.

Data Structures
struct	PartClauseInfo
struct	GeneratePruningStepsContext
struct	PruneStepResult

Macros
#define	PartCollMatchesExprColl(partcoll, exprcoll)    ((partcoll) == InvalidOid || (partcoll) == (exprcoll))

Typedefs
typedef struct PartClauseInfo	PartClauseInfo
typedef enum PartClauseMatchStatus	PartClauseMatchStatus
typedef enum PartClauseTarget	PartClauseTarget
typedef struct GeneratePruningStepsContext	GeneratePruningStepsContext
typedef struct PruneStepResult	PruneStepResult

Enumerations
enum	PartClauseMatchStatus {   PARTCLAUSE_NOMATCH , PARTCLAUSE_MATCH_CLAUSE , PARTCLAUSE_MATCH_NULLNESS , PARTCLAUSE_MATCH_STEPS ,   PARTCLAUSE_MATCH_CONTRADICT , PARTCLAUSE_UNSUPPORTED }
enum	PartClauseTarget { PARTTARGET_PLANNER , PARTTARGET_INITIAL , PARTTARGET_EXEC }

Functions
static List *	add_part_relids (List *allpartrelids, Bitmapset *partrelids)
static List *	make_partitionedrel_pruneinfo (PlannerInfo *root, RelOptInfo *parentrel, List *prunequal, Bitmapset *partrelids, int *relid_subplan_map, Bitmapset **matchedsubplans)
static void	gen_partprune_steps (RelOptInfo *rel, List *clauses, PartClauseTarget target, GeneratePruningStepsContext *context)
static List *	gen_partprune_steps_internal (GeneratePruningStepsContext *context, List *clauses)
static PartitionPruneStep *	gen_prune_step_op (GeneratePruningStepsContext *context, StrategyNumber opstrategy, bool op_is_ne, List *exprs, List *cmpfns, Bitmapset *nullkeys)
static PartitionPruneStep *	gen_prune_step_combine (GeneratePruningStepsContext *context, List *source_stepids, PartitionPruneCombineOp combineOp)
static List *	gen_prune_steps_from_opexps (GeneratePruningStepsContext *context, List **keyclauses, Bitmapset *nullkeys)
static PartClauseMatchStatus	match_clause_to_partition_key (GeneratePruningStepsContext *context, Expr *clause, Expr *partkey, int partkeyidx, bool *clause_is_not_null, PartClauseInfo **pc, List **clause_steps)
static List *	get_steps_using_prefix (GeneratePruningStepsContext *context, StrategyNumber step_opstrategy, bool step_op_is_ne, Expr *step_lastexpr, Oid step_lastcmpfn, int step_lastkeyno, Bitmapset *step_nullkeys, List *prefix)
static List *	get_steps_using_prefix_recurse (GeneratePruningStepsContext *context, StrategyNumber step_opstrategy, bool step_op_is_ne, Expr *step_lastexpr, Oid step_lastcmpfn, int step_lastkeyno, Bitmapset *step_nullkeys, List *prefix, ListCell *start, List *step_exprs, List *step_cmpfns)
static PruneStepResult *	get_matching_hash_bounds (PartitionPruneContext *context, StrategyNumber opstrategy, Datum *values, int nvalues, FmgrInfo *partsupfunc, Bitmapset *nullkeys)
static PruneStepResult *	get_matching_list_bounds (PartitionPruneContext *context, StrategyNumber opstrategy, Datum value, int nvalues, FmgrInfo *partsupfunc, Bitmapset *nullkeys)
static PruneStepResult *	get_matching_range_bounds (PartitionPruneContext *context, StrategyNumber opstrategy, Datum *values, int nvalues, FmgrInfo *partsupfunc, Bitmapset *nullkeys)
static Bitmapset *	pull_exec_paramids (Expr *expr)
static bool	pull_exec_paramids_walker (Node *node, Bitmapset **context)
static Bitmapset *	get_partkey_exec_paramids (List *steps)
static PruneStepResult *	perform_pruning_base_step (PartitionPruneContext *context, PartitionPruneStepOp *opstep)
static PruneStepResult *	perform_pruning_combine_step (PartitionPruneContext *context, PartitionPruneStepCombine *cstep, PruneStepResult **step_results)
static PartClauseMatchStatus	match_boolean_partition_clause (Oid partopfamily, Expr *clause, Expr *partkey, Expr **outconst, bool *noteq)
static void	partkey_datum_from_expr (PartitionPruneContext *context, Expr *expr, int stateidx, Datum *value, bool *isnull)
PartitionPruneInfo *	make_partition_pruneinfo (PlannerInfo *root, RelOptInfo *parentrel, List *subpaths, List *prunequal)
Bitmapset *	prune_append_rel_partitions (RelOptInfo *rel)
Bitmapset *	get_matching_partitions (PartitionPruneContext *context, List *pruning_steps)

Macro Definition Documentation

PartCollMatchesExprColl

#define PartCollMatchesExprColl	(		partcoll,
			exprcoll
	)		((partcoll) == InvalidOid || (partcoll) == (exprcoll))

Definition at line 1761 of file partprune.c.

Typedef Documentation

GeneratePruningStepsContext

typedef struct GeneratePruningStepsContext GeneratePruningStepsContext

PartClauseInfo

typedef struct PartClauseInfo PartClauseInfo

PartClauseMatchStatus

typedef enum PartClauseMatchStatus PartClauseMatchStatus

PartClauseTarget

typedef enum PartClauseTarget PartClauseTarget

PruneStepResult

typedef struct PruneStepResult PruneStepResult

Enumeration Type Documentation

PartClauseMatchStatus

enum PartClauseMatchStatus

Enumerator
PARTCLAUSE_NOMATCH
PARTCLAUSE_MATCH_CLAUSE
PARTCLAUSE_MATCH_NULLNESS
PARTCLAUSE_MATCH_STEPS
PARTCLAUSE_MATCH_CONTRADICT
PARTCLAUSE_UNSUPPORTED

Definition at line 78 of file partprune.c.

{
    PARTCLAUSE_NOMATCH,
    PARTCLAUSE_MATCH_CLAUSE,
    PARTCLAUSE_MATCH_NULLNESS,
    PARTCLAUSE_MATCH_STEPS,
    PARTCLAUSE_MATCH_CONTRADICT,
    PARTCLAUSE_UNSUPPORTED
} PartClauseMatchStatus;

PartClauseTarget

enum PartClauseTarget

Enumerator
PARTTARGET_PLANNER
PARTTARGET_INITIAL
PARTTARGET_EXEC

Definition at line 92 of file partprune.c.

{
    PARTTARGET_PLANNER,         /* want to prune during planning */
    PARTTARGET_INITIAL,         /* want to prune during executor startup */
    PARTTARGET_EXEC             /* want to prune during each plan node scan */
} PartClauseTarget;

Function Documentation

add_part_relids()

static List * add_part_relids ( List *  allpartrelids, Bitmapset *  partrelids  )

static

Definition at line 395 of file partprune.c.

{
    Index       targetpart;
    ListCell   *lc;
 
    /* We can easily get the lowest set bit this way: */
    targetpart = bms_next_member(partrelids, -1);
    Assert(targetpart > 0);
 
    /* Look for a matching topmost parent */
    foreach(lc, allpartrelids)
    {
        Bitmapset  *currpartrelids = (Bitmapset *) lfirst(lc);
        Index       currtarget = bms_next_member(currpartrelids, -1);
 
        if (targetpart == currtarget)
        {
            /* Found a match, so add any new RT indexes to this hierarchy */
            currpartrelids = bms_add_members(currpartrelids, partrelids);
            lfirst(lc) = currpartrelids;
            return allpartrelids;
        }
    }
    /* No match, so add the new partition hierarchy to the list */
    return lappend(allpartrelids, partrelids);
}

References Assert(), bms_add_members(), bms_next_member(), lappend(), and lfirst.

Referenced by make_partition_pruneinfo().

gen_partprune_steps()

static void gen_partprune_steps ( RelOptInfo *  rel, List *  clauses, PartClauseTarget  target, GeneratePruningStepsContext *  context  )

static

Definition at line 717 of file partprune.c.

{
    /* Initialize all output values to zero/false/NULL */
    memset(context, 0, sizeof(GeneratePruningStepsContext));
    context->rel = rel;
    context->target = target;
 
    /*
     * If this partitioned table is in turn a partition, and it shares any
     * partition keys with its parent, then it's possible that the hierarchy
     * allows the parent a narrower range of values than some of its
     * partitions (particularly the default one).  This is normally not
     * useful, but it can be to prune the default partition.
     */
    if (partition_bound_has_default(rel->boundinfo) && rel->partition_qual)
    {
        /* Make a copy to avoid modifying the passed-in List */
        clauses = list_concat_copy(clauses, rel->partition_qual);
    }
 
    /* Down into the rabbit-hole. */
    (void) gen_partprune_steps_internal(context, clauses);
}

References gen_partprune_steps_internal(), list_concat_copy(), partition_bound_has_default, RelOptInfo::partition_qual, GeneratePruningStepsContext::rel, and GeneratePruningStepsContext::target.

Referenced by make_partitionedrel_pruneinfo(), and prune_append_rel_partitions().

gen_partprune_steps_internal()

static List * gen_partprune_steps_internal ( GeneratePruningStepsContext *  context, List *  clauses  )

static

Definition at line 964 of file partprune.c.

{
    PartitionScheme part_scheme = context->rel->part_scheme;
    List       *keyclauses[PARTITION_MAX_KEYS];
    Bitmapset  *nullkeys = NULL,
               *notnullkeys = NULL;
    bool        generate_opsteps = false;
    List       *result = NIL;
    ListCell   *lc;
 
    /*
     * If this partitioned relation has a default partition and is itself a
     * partition (as evidenced by partition_qual being not NIL), we first
     * check if the clauses contradict the partition constraint.  If they do,
     * there's no need to generate any steps as it'd already be proven that no
     * partitions need to be scanned.
     *
     * This is a measure of last resort only to be used because the default
     * partition cannot be pruned using the steps generated from clauses that
     * contradict the parent's partition constraint; regular pruning, which is
     * cheaper, is sufficient when no default partition exists.
     */
    if (partition_bound_has_default(context->rel->boundinfo) &&
        predicate_refuted_by(context->rel->partition_qual, clauses, false))
    {
        context->contradictory = true;
        return NIL;
    }
 
    memset(keyclauses, 0, sizeof(keyclauses));
    foreach(lc, clauses)
    {
        Expr       *clause = (Expr *) lfirst(lc);
        int         i;
 
        /* Look through RestrictInfo, if any */
        if (IsA(clause, RestrictInfo))
            clause = ((RestrictInfo *) clause)->clause;
 
        /* Constant-false-or-null is contradictory */
        if (IsA(clause, Const) &&
            (((Const *) clause)->constisnull ||
             !DatumGetBool(((Const *) clause)->constvalue)))
        {
            context->contradictory = true;
            return NIL;
        }
 
        /* Get the BoolExpr's out of the way. */
        if (IsA(clause, BoolExpr))
        {
            /*
             * Generate steps for arguments.
             *
             * While steps generated for the arguments themselves will be
             * added to context->steps during recursion and will be evaluated
             * independently, collect their step IDs to be stored in the
             * combine step we'll be creating.
             */
            if (is_orclause(clause))
            {
                List       *arg_stepids = NIL;
                bool        all_args_contradictory = true;
                ListCell   *lc1;
 
                /*
                 * We can share the outer context area with the recursive
                 * call, but contradictory had better not be true yet.
                 */
                Assert(!context->contradictory);
 
                /*
                 * Get pruning step for each arg.  If we get contradictory for
                 * all args, it means the OR expression is false as a whole.
                 */
                foreach(lc1, ((BoolExpr *) clause)->args)
                {
                    Expr       *arg = lfirst(lc1);
                    bool        arg_contradictory;
                    List       *argsteps;
 
                    argsteps = gen_partprune_steps_internal(context,
                                                            list_make1(arg));
                    arg_contradictory = context->contradictory;
                    /* Keep context->contradictory clear till we're done */
                    context->contradictory = false;
 
                    if (arg_contradictory)
                    {
                        /* Just ignore self-contradictory arguments. */
                        continue;
                    }
                    else
                        all_args_contradictory = false;
 
                    if (argsteps != NIL)
                    {
                        /*
                         * gen_partprune_steps_internal() always adds a single
                         * combine step when it generates multiple steps, so
                         * here we can just pay attention to the last one in
                         * the list.  If it just generated one, then the last
                         * one in the list is still the one we want.
                         */
                        PartitionPruneStep *last = llast(argsteps);
 
                        arg_stepids = lappend_int(arg_stepids, last->step_id);
                    }
                    else
                    {
                        PartitionPruneStep *orstep;
 
                        /*
                         * The arg didn't contain a clause matching this
                         * partition key.  We cannot prune using such an arg.
                         * To indicate that to the pruning code, we must
                         * construct a dummy PartitionPruneStepCombine whose
                         * source_stepids is set to an empty List.
                         */
                        orstep = gen_prune_step_combine(context, NIL,
                                                        PARTPRUNE_COMBINE_UNION);
                        arg_stepids = lappend_int(arg_stepids, orstep->step_id);
                    }
                }
 
                /* If all the OR arms are contradictory, we can stop */
                if (all_args_contradictory)
                {
                    context->contradictory = true;
                    return NIL;
                }
 
                if (arg_stepids != NIL)
                {
                    PartitionPruneStep *step;
 
                    step = gen_prune_step_combine(context, arg_stepids,
                                                  PARTPRUNE_COMBINE_UNION);
                    result = lappend(result, step);
                }
                continue;
            }
            else if (is_andclause(clause))
            {
                List       *args = ((BoolExpr *) clause)->args;
                List       *argsteps;
 
                /*
                 * args may itself contain clauses of arbitrary type, so just
                 * recurse and later combine the component partitions sets
                 * using a combine step.
                 */
                argsteps = gen_partprune_steps_internal(context, args);
 
                /* If any AND arm is contradictory, we can stop immediately */
                if (context->contradictory)
                    return NIL;
 
                /*
                 * gen_partprune_steps_internal() always adds a single combine
                 * step when it generates multiple steps, so here we can just
                 * pay attention to the last one in the list.  If it just
                 * generated one, then the last one in the list is still the
                 * one we want.
                 */
                if (argsteps != NIL)
                    result = lappend(result, llast(argsteps));
 
                continue;
            }
 
            /*
             * Fall-through for a NOT clause, which if it's a Boolean clause,
             * will be handled in match_clause_to_partition_key(). We
             * currently don't perform any pruning for more complex NOT
             * clauses.
             */
        }
 
        /*
         * See if we can match this clause to any of the partition keys.
         */
        for (i = 0; i < part_scheme->partnatts; i++)
        {
            Expr       *partkey = linitial(context->rel->partexprs[i]);
            bool        clause_is_not_null = false;
            PartClauseInfo *pc = NULL;
            List       *clause_steps = NIL;
 
            switch (match_clause_to_partition_key(context,
                                                  clause, partkey, i,
                                                  &clause_is_not_null,
                                                  &pc, &clause_steps))
            {
                case PARTCLAUSE_MATCH_CLAUSE:
                    Assert(pc != NULL);
 
                    /*
                     * Since we only allow strict operators, check for any
                     * contradicting IS NULL.
                     */
                    if (bms_is_member(i, nullkeys))
                    {
                        context->contradictory = true;
                        return NIL;
                    }
                    generate_opsteps = true;
                    keyclauses[i] = lappend(keyclauses[i], pc);
                    break;
 
                case PARTCLAUSE_MATCH_NULLNESS:
                    if (!clause_is_not_null)
                    {
                        /*
                         * check for conflicting IS NOT NULL as well as
                         * contradicting strict clauses
                         */
                        if (bms_is_member(i, notnullkeys) ||
                            keyclauses[i] != NIL)
                        {
                            context->contradictory = true;
                            return NIL;
                        }
                        nullkeys = bms_add_member(nullkeys, i);
                    }
                    else
                    {
                        /* check for conflicting IS NULL */
                        if (bms_is_member(i, nullkeys))
                        {
                            context->contradictory = true;
                            return NIL;
                        }
                        notnullkeys = bms_add_member(notnullkeys, i);
                    }
                    break;
 
                case PARTCLAUSE_MATCH_STEPS:
                    Assert(clause_steps != NIL);
                    result = list_concat(result, clause_steps);
                    break;
 
                case PARTCLAUSE_MATCH_CONTRADICT:
                    /* We've nothing more to do if a contradiction was found. */
                    context->contradictory = true;
                    return NIL;
 
                case PARTCLAUSE_NOMATCH:
 
                    /*
                     * Clause didn't match this key, but it might match the
                     * next one.
                     */
                    continue;
 
                case PARTCLAUSE_UNSUPPORTED:
                    /* This clause cannot be used for pruning. */
                    break;
            }
 
            /* done; go check the next clause. */
            break;
        }
    }
 
    /*-----------
     * Now generate some (more) pruning steps.  We have three strategies:
     *
     * 1) Generate pruning steps based on IS NULL clauses:
     *   a) For list partitioning, null partition keys can only be found in
     *      the designated null-accepting partition, so if there are IS NULL
     *      clauses containing partition keys we should generate a pruning
     *      step that gets rid of all partitions but that one.  We can
     *      disregard any OpExpr we may have found.
     *   b) For range partitioning, only the default partition can contain
     *      NULL values, so the same rationale applies.
     *   c) For hash partitioning, we only apply this strategy if we have
     *      IS NULL clauses for all the keys.  Strategy 2 below will take
     *      care of the case where some keys have OpExprs and others have
     *      IS NULL clauses.
     *
     * 2) If not, generate steps based on OpExprs we have (if any).
     *
     * 3) If this doesn't work either, we may be able to generate steps to
     *    prune just the null-accepting partition (if one exists), if we have
     *    IS NOT NULL clauses for all partition keys.
     */
    if (!bms_is_empty(nullkeys) &&
        (part_scheme->strategy == PARTITION_STRATEGY_LIST ||
         part_scheme->strategy == PARTITION_STRATEGY_RANGE ||
         (part_scheme->strategy == PARTITION_STRATEGY_HASH &&
          bms_num_members(nullkeys) == part_scheme->partnatts)))
    {
        PartitionPruneStep *step;
 
        /* Strategy 1 */
        step = gen_prune_step_op(context, InvalidStrategy,
                                 false, NIL, NIL, nullkeys);
        result = lappend(result, step);
    }
    else if (generate_opsteps)
    {
        List       *opsteps;
 
        /* Strategy 2 */
        opsteps = gen_prune_steps_from_opexps(context, keyclauses, nullkeys);
        result = list_concat(result, opsteps);
    }
    else if (bms_num_members(notnullkeys) == part_scheme->partnatts)
    {
        PartitionPruneStep *step;
 
        /* Strategy 3 */
        step = gen_prune_step_op(context, InvalidStrategy,
                                 false, NIL, NIL, NULL);
        result = lappend(result, step);
    }
 
    /*
     * Finally, if there are multiple steps, since the 'clauses' are mutually
     * ANDed, add an INTERSECT step to combine the partition sets resulting
     * from them and append it to the result list.
     */
    if (list_length(result) > 1)
    {
        List       *step_ids = NIL;
        PartitionPruneStep *final;
 
        foreach(lc, result)
        {
            PartitionPruneStep *step = lfirst(lc);
 
            step_ids = lappend_int(step_ids, step->step_id);
        }
 
        final = gen_prune_step_combine(context, step_ids,
                                       PARTPRUNE_COMBINE_INTERSECT);
        result = lappend(result, final);
    }
 
    return result;
}

References arg, generate_unaccent_rules::args, Assert(), bms_add_member(), bms_is_empty, bms_is_member(), bms_num_members(), GeneratePruningStepsContext::contradictory, DatumGetBool(), gen_prune_step_combine(), gen_prune_step_op(), gen_prune_steps_from_opexps(), i, InvalidStrategy, is_andclause(), is_orclause(), IsA, lappend(), lappend_int(), lfirst, linitial, list_concat(), list_length(), list_make1, llast, match_clause_to_partition_key(), NIL, PARTCLAUSE_MATCH_CLAUSE, PARTCLAUSE_MATCH_CONTRADICT, PARTCLAUSE_MATCH_NULLNESS, PARTCLAUSE_MATCH_STEPS, PARTCLAUSE_NOMATCH, PARTCLAUSE_UNSUPPORTED, partition_bound_has_default, PARTITION_MAX_KEYS, RelOptInfo::partition_qual, PARTITION_STRATEGY_HASH, PARTITION_STRATEGY_LIST, PARTITION_STRATEGY_RANGE, PartitionSchemeData::partnatts, PARTPRUNE_COMBINE_INTERSECT, PARTPRUNE_COMBINE_UNION, predicate_refuted_by(), GeneratePruningStepsContext::rel, PartitionPruneStep::step_id, and PartitionSchemeData::strategy.

Referenced by gen_partprune_steps(), and match_clause_to_partition_key().

gen_prune_step_combine()

static PartitionPruneStep * gen_prune_step_combine ( GeneratePruningStepsContext *  context, List *  source_stepids, PartitionPruneCombineOp  combineOp  )

static

Definition at line 1349 of file partprune.c.

{
    PartitionPruneStepCombine *cstep = makeNode(PartitionPruneStepCombine);
 
    cstep->step.step_id = context->next_step_id++;
    cstep->combineOp = combineOp;
    cstep->source_stepids = source_stepids;
 
    context->steps = lappend(context->steps, cstep);
 
    return (PartitionPruneStep *) cstep;
}

References PartitionPruneStepCombine::combineOp, lappend(), makeNode, GeneratePruningStepsContext::next_step_id, PartitionPruneStepCombine::source_stepids, PartitionPruneStepCombine::step, PartitionPruneStep::step_id, and GeneratePruningStepsContext::steps.

Referenced by gen_partprune_steps_internal().

gen_prune_step_op()

static PartitionPruneStep * gen_prune_step_op ( GeneratePruningStepsContext *  context, StrategyNumber  opstrategy, bool  op_is_ne, List *  exprs, List *  cmpfns, Bitmapset *  nullkeys  )

static

Definition at line 1316 of file partprune.c.

{
    PartitionPruneStepOp *opstep = makeNode(PartitionPruneStepOp);
 
    opstep->step.step_id = context->next_step_id++;
 
    /*
     * For clauses that contain an <> operator, set opstrategy to
     * InvalidStrategy to signal get_matching_list_bounds to do the right
     * thing.
     */
    opstep->opstrategy = op_is_ne ? InvalidStrategy : opstrategy;
    Assert(list_length(exprs) == list_length(cmpfns));
    opstep->exprs = exprs;
    opstep->cmpfns = cmpfns;
    opstep->nullkeys = nullkeys;
 
    context->steps = lappend(context->steps, opstep);
 
    return (PartitionPruneStep *) opstep;
}

References Assert(), PartitionPruneStepOp::cmpfns, PartitionPruneStepOp::exprs, InvalidStrategy, lappend(), list_length(), makeNode, GeneratePruningStepsContext::next_step_id, PartitionPruneStepOp::nullkeys, PartitionPruneStepOp::opstrategy, PartitionPruneStepOp::step, PartitionPruneStep::step_id, and GeneratePruningStepsContext::steps.

Referenced by gen_partprune_steps_internal(), get_steps_using_prefix(), and get_steps_using_prefix_recurse().

gen_prune_steps_from_opexps()

static List * gen_prune_steps_from_opexps ( GeneratePruningStepsContext *  context, List **  keyclauses, Bitmapset *  nullkeys  )

static

Definition at line 1386 of file partprune.c.

{
    PartitionScheme part_scheme = context->rel->part_scheme;
    List       *opsteps = NIL;
    List       *btree_clauses[BTMaxStrategyNumber + 1],
               *hash_clauses[HTMaxStrategyNumber + 1];
    int         i;
    ListCell   *lc;
 
    memset(btree_clauses, 0, sizeof(btree_clauses));
    memset(hash_clauses, 0, sizeof(hash_clauses));
    for (i = 0; i < part_scheme->partnatts; i++)
    {
        List       *clauselist = keyclauses[i];
        bool        consider_next_key = true;
 
        /*
         * For range partitioning, if we have no clauses for the current key,
         * we can't consider any later keys either, so we can stop here.
         */
        if (part_scheme->strategy == PARTITION_STRATEGY_RANGE &&
            clauselist == NIL)
            break;
 
        /*
         * For hash partitioning, if a column doesn't have the necessary
         * equality clause, there should be an IS NULL clause, otherwise
         * pruning is not possible.
         */
        if (part_scheme->strategy == PARTITION_STRATEGY_HASH &&
            clauselist == NIL && !bms_is_member(i, nullkeys))
            return NIL;
 
        foreach(lc, clauselist)
        {
            PartClauseInfo *pc = (PartClauseInfo *) lfirst(lc);
            Oid         lefttype,
                        righttype;
 
            /* Look up the operator's btree/hash strategy number. */
            if (pc->op_strategy == InvalidStrategy)
                get_op_opfamily_properties(pc->opno,
                                           part_scheme->partopfamily[i],
                                           false,
                                           &pc->op_strategy,
                                           &lefttype,
                                           &righttype);
 
            switch (part_scheme->strategy)
            {
                case PARTITION_STRATEGY_LIST:
                case PARTITION_STRATEGY_RANGE:
                    btree_clauses[pc->op_strategy] =
                        lappend(btree_clauses[pc->op_strategy], pc);
 
                    /*
                     * We can't consider subsequent partition keys if the
                     * clause for the current key contains a non-inclusive
                     * operator.
                     */
                    if (pc->op_strategy == BTLessStrategyNumber ||
                        pc->op_strategy == BTGreaterStrategyNumber)
                        consider_next_key = false;
                    break;
 
                case PARTITION_STRATEGY_HASH:
                    if (pc->op_strategy != HTEqualStrategyNumber)
                        elog(ERROR, "invalid clause for hash partitioning");
                    hash_clauses[pc->op_strategy] =
                        lappend(hash_clauses[pc->op_strategy], pc);
                    break;
 
                default:
                    elog(ERROR, "invalid partition strategy: %c",
                         part_scheme->strategy);
                    break;
            }
        }
 
        /*
         * If we've decided that clauses for subsequent partition keys
         * wouldn't be useful for pruning, don't search any further.
         */
        if (!consider_next_key)
            break;
    }
 
    /*
     * Now, we have divided clauses according to their operator strategies.
     * Check for each strategy if we can generate pruning step(s) by
     * collecting a list of expressions whose values will constitute a vector
     * that can be used as a lookup key by a partition bound searching
     * function.
     */
    switch (part_scheme->strategy)
    {
        case PARTITION_STRATEGY_LIST:
        case PARTITION_STRATEGY_RANGE:
            {
                List       *eq_clauses = btree_clauses[BTEqualStrategyNumber];
                List       *le_clauses = btree_clauses[BTLessEqualStrategyNumber];
                List       *ge_clauses = btree_clauses[BTGreaterEqualStrategyNumber];
                int         strat;
 
                /*
                 * For each clause under consideration for a given strategy,
                 * we collect expressions from clauses for earlier keys, whose
                 * operator strategy is inclusive, into a list called
                 * 'prefix'. By appending the clause's own expression to the
                 * 'prefix', we'll generate one step using the so generated
                 * vector and assign the current strategy to it.  Actually,
                 * 'prefix' might contain multiple clauses for the same key,
                 * in which case, we must generate steps for various
                 * combinations of expressions of different keys, which
                 * get_steps_using_prefix takes care of for us.
                 */
                for (strat = 1; strat <= BTMaxStrategyNumber; strat++)
                {
                    foreach(lc, btree_clauses[strat])
                    {
                        PartClauseInfo *pc = lfirst(lc);
                        ListCell   *eq_start;
                        ListCell   *le_start;
                        ListCell   *ge_start;
                        ListCell   *lc1;
                        List       *prefix = NIL;
                        List       *pc_steps;
                        bool        prefix_valid = true;
                        bool        pk_has_clauses;
                        int         keyno;
 
                        /*
                         * If this is a clause for the first partition key,
                         * there are no preceding expressions; generate a
                         * pruning step without a prefix.
                         *
                         * Note that we pass NULL for step_nullkeys, because
                         * we don't search list/range partition bounds where
                         * some keys are NULL.
                         */
                        if (pc->keyno == 0)
                        {
                            Assert(pc->op_strategy == strat);
                            pc_steps = get_steps_using_prefix(context, strat,
                                                              pc->op_is_ne,
                                                              pc->expr,
                                                              pc->cmpfn,
                                                              0,
                                                              NULL,
                                                              NIL);
                            opsteps = list_concat(opsteps, pc_steps);
                            continue;
                        }
 
                        eq_start = list_head(eq_clauses);
                        le_start = list_head(le_clauses);
                        ge_start = list_head(ge_clauses);
 
                        /*
                         * We arrange clauses into prefix in ascending order
                         * of their partition key numbers.
                         */
                        for (keyno = 0; keyno < pc->keyno; keyno++)
                        {
                            pk_has_clauses = false;
 
                            /*
                             * Expressions from = clauses can always be in the
                             * prefix, provided they're from an earlier key.
                             */
                            for_each_cell(lc1, eq_clauses, eq_start)
                            {
                                PartClauseInfo *eqpc = lfirst(lc1);
 
                                if (eqpc->keyno == keyno)
                                {
                                    prefix = lappend(prefix, eqpc);
                                    pk_has_clauses = true;
                                }
                                else
                                {
                                    Assert(eqpc->keyno > keyno);
                                    break;
                                }
                            }
                            eq_start = lc1;
 
                            /*
                             * If we're generating steps for </<= strategy, we
                             * can add other <= clauses to the prefix,
                             * provided they're from an earlier key.
                             */
                            if (strat == BTLessStrategyNumber ||
                                strat == BTLessEqualStrategyNumber)
                            {
                                for_each_cell(lc1, le_clauses, le_start)
                                {
                                    PartClauseInfo *lepc = lfirst(lc1);
 
                                    if (lepc->keyno == keyno)
                                    {
                                        prefix = lappend(prefix, lepc);
                                        pk_has_clauses = true;
                                    }
                                    else
                                    {
                                        Assert(lepc->keyno > keyno);
                                        break;
                                    }
                                }
                                le_start = lc1;
                            }
 
                            /*
                             * If we're generating steps for >/>= strategy, we
                             * can add other >= clauses to the prefix,
                             * provided they're from an earlier key.
                             */
                            if (strat == BTGreaterStrategyNumber ||
                                strat == BTGreaterEqualStrategyNumber)
                            {
                                for_each_cell(lc1, ge_clauses, ge_start)
                                {
                                    PartClauseInfo *gepc = lfirst(lc1);
 
                                    if (gepc->keyno == keyno)
                                    {
                                        prefix = lappend(prefix, gepc);
                                        pk_has_clauses = true;
                                    }
                                    else
                                    {
                                        Assert(gepc->keyno > keyno);
                                        break;
                                    }
                                }
                                ge_start = lc1;
                            }
 
                            /*
                             * If this key has no clauses, prefix is not valid
                             * anymore.
                             */
                            if (!pk_has_clauses)
                            {
                                prefix_valid = false;
                                break;
                            }
                        }
 
                        /*
                         * If prefix_valid, generate PartitionPruneStepOps.
                         * Otherwise, we would not find clauses for a valid
                         * subset of the partition keys anymore for the
                         * strategy; give up on generating partition pruning
                         * steps further for the strategy.
                         *
                         * As mentioned above, if 'prefix' contains multiple
                         * expressions for the same key, the following will
                         * generate multiple steps, one for each combination
                         * of the expressions for different keys.
                         *
                         * Note that we pass NULL for step_nullkeys, because
                         * we don't search list/range partition bounds where
                         * some keys are NULL.
                         */
                        if (prefix_valid)
                        {
                            Assert(pc->op_strategy == strat);
                            pc_steps = get_steps_using_prefix(context, strat,
                                                              pc->op_is_ne,
                                                              pc->expr,
                                                              pc->cmpfn,
                                                              pc->keyno,
                                                              NULL,
                                                              prefix);
                            opsteps = list_concat(opsteps, pc_steps);
                        }
                        else
                            break;
                    }
                }
                break;
            }
 
        case PARTITION_STRATEGY_HASH:
            {
                List       *eq_clauses = hash_clauses[HTEqualStrategyNumber];
 
                /* For hash partitioning, we have just the = strategy. */
                if (eq_clauses != NIL)
                {
                    PartClauseInfo *pc;
                    List       *pc_steps;
                    List       *prefix = NIL;
                    int         last_keyno;
                    ListCell   *lc1;
 
                    /*
                     * Locate the clause for the greatest column.  This may
                     * not belong to the last partition key, but it is the
                     * clause belonging to the last partition key we found a
                     * clause for above.
                     */
                    pc = llast(eq_clauses);
 
                    /*
                     * There might be multiple clauses which matched to that
                     * partition key; find the first such clause.  While at
                     * it, add all the clauses before that one to 'prefix'.
                     */
                    last_keyno = pc->keyno;
                    foreach(lc, eq_clauses)
                    {
                        pc = lfirst(lc);
                        if (pc->keyno == last_keyno)
                            break;
                        prefix = lappend(prefix, pc);
                    }
 
                    /*
                     * For each clause for the "last" column, after appending
                     * the clause's own expression to the 'prefix', we'll
                     * generate one step using the so generated vector and
                     * assign = as its strategy.  Actually, 'prefix' might
                     * contain multiple clauses for the same key, in which
                     * case, we must generate steps for various combinations
                     * of expressions of different keys, which
                     * get_steps_using_prefix will take care of for us.
                     */
                    for_each_cell(lc1, eq_clauses, lc)
                    {
                        pc = lfirst(lc1);
 
                        /*
                         * Note that we pass nullkeys for step_nullkeys,
                         * because we need to tell hash partition bound search
                         * function which of the keys we found IS NULL clauses
                         * for.
                         */
                        Assert(pc->op_strategy == HTEqualStrategyNumber);
                        pc_steps =
                            get_steps_using_prefix(context,
                                                   HTEqualStrategyNumber,
                                                   false,
                                                   pc->expr,
                                                   pc->cmpfn,
                                                   pc->keyno,
                                                   nullkeys,
                                                   prefix);
                        opsteps = list_concat(opsteps, pc_steps);
                    }
                }
                break;
            }
 
        default:
            elog(ERROR, "invalid partition strategy: %c",
                 part_scheme->strategy);
            break;
    }
 
    return opsteps;
}

References Assert(), bms_is_member(), BTEqualStrategyNumber, BTGreaterEqualStrategyNumber, BTGreaterStrategyNumber, BTLessEqualStrategyNumber, BTLessStrategyNumber, BTMaxStrategyNumber, PartClauseInfo::cmpfn, elog(), ERROR, PartClauseInfo::expr, for_each_cell, get_op_opfamily_properties(), get_steps_using_prefix(), HTEqualStrategyNumber, HTMaxStrategyNumber, i, InvalidStrategy, PartClauseInfo::keyno, lappend(), lfirst, list_concat(), list_head(), llast, NIL, PartClauseInfo::op_is_ne, PartClauseInfo::op_strategy, PartClauseInfo::opno, PARTITION_STRATEGY_HASH, PARTITION_STRATEGY_LIST, PARTITION_STRATEGY_RANGE, PartitionSchemeData::partnatts, PartitionSchemeData::partopfamily, GeneratePruningStepsContext::rel, and PartitionSchemeData::strategy.

Referenced by gen_partprune_steps_internal().

get_matching_hash_bounds()

static PruneStepResult * get_matching_hash_bounds ( PartitionPruneContext *  context, StrategyNumber  opstrategy, Datum *  values, int  nvalues, FmgrInfo *  partsupfunc, Bitmapset *  nullkeys  )

static

Definition at line 2585 of file partprune.c.

{
    PruneStepResult *result = (PruneStepResult *) palloc0(sizeof(PruneStepResult));
    PartitionBoundInfo boundinfo = context->boundinfo;
    int        *partindices = boundinfo->indexes;
    int         partnatts = context->partnatts;
    bool        isnull[PARTITION_MAX_KEYS];
    int         i;
    uint64      rowHash;
    int         greatest_modulus;
    Oid        *partcollation = context->partcollation;
 
    Assert(context->strategy == PARTITION_STRATEGY_HASH);
 
    /*
     * For hash partitioning we can only perform pruning based on equality
     * clauses to the partition key or IS NULL clauses.  We also can only
     * prune if we got values for all keys.
     */
    if (nvalues + bms_num_members(nullkeys) == partnatts)
    {
        /*
         * If there are any values, they must have come from clauses
         * containing an equality operator compatible with hash partitioning.
         */
        Assert(opstrategy == HTEqualStrategyNumber || nvalues == 0);
 
        for (i = 0; i < partnatts; i++)
            isnull[i] = bms_is_member(i, nullkeys);
 
        rowHash = compute_partition_hash_value(partnatts, partsupfunc, partcollation,
                                               values, isnull);
 
        greatest_modulus = boundinfo->nindexes;
        if (partindices[rowHash % greatest_modulus] >= 0)
            result->bound_offsets =
                bms_make_singleton(rowHash % greatest_modulus);
    }
    else
    {
        /* Report all valid offsets into the boundinfo->indexes array. */
        result->bound_offsets = bms_add_range(NULL, 0,
                                              boundinfo->nindexes - 1);
    }
 
    /*
     * There is neither a special hash null partition or the default hash
     * partition.
     */
    result->scan_null = result->scan_default = false;
 
    return result;
}

References Assert(), bms_add_range(), bms_is_member(), bms_make_singleton(), bms_num_members(), PruneStepResult::bound_offsets, PartitionPruneContext::boundinfo, compute_partition_hash_value(), HTEqualStrategyNumber, i, PartitionBoundInfoData::indexes, PartitionBoundInfoData::nindexes, palloc0(), PartitionPruneContext::partcollation, PARTITION_MAX_KEYS, PARTITION_STRATEGY_HASH, PartitionPruneContext::partnatts, PruneStepResult::scan_default, PruneStepResult::scan_null, PartitionPruneContext::strategy, and values.

Referenced by perform_pruning_base_step().

get_matching_list_bounds()

static PruneStepResult * get_matching_list_bounds ( PartitionPruneContext *  context, StrategyNumber  opstrategy, Datum  value, int  nvalues, FmgrInfo *  partsupfunc, Bitmapset *  nullkeys  )

static

Definition at line 2662 of file partprune.c.

{
    PruneStepResult *result = (PruneStepResult *) palloc0(sizeof(PruneStepResult));
    PartitionBoundInfo boundinfo = context->boundinfo;
    int         off,
                minoff,
                maxoff;
    bool        is_equal;
    bool        inclusive = false;
    Oid        *partcollation = context->partcollation;
 
    Assert(context->strategy == PARTITION_STRATEGY_LIST);
    Assert(context->partnatts == 1);
 
    result->scan_null = result->scan_default = false;
 
    if (!bms_is_empty(nullkeys))
    {
        /*
         * Nulls may exist in only one partition - the partition whose
         * accepted set of values includes null or the default partition if
         * the former doesn't exist.
         */
        if (partition_bound_accepts_nulls(boundinfo))
            result->scan_null = true;
        else
            result->scan_default = partition_bound_has_default(boundinfo);
        return result;
    }
 
    /*
     * If there are no datums to compare keys with, but there are partitions,
     * just return the default partition if one exists.
     */
    if (boundinfo->ndatums == 0)
    {
        result->scan_default = partition_bound_has_default(boundinfo);
        return result;
    }
 
    minoff = 0;
    maxoff = boundinfo->ndatums - 1;
 
    /*
     * If there are no values to compare with the datums in boundinfo, it
     * means the caller asked for partitions for all non-null datums.  Add
     * indexes of *all* partitions, including the default if any.
     */
    if (nvalues == 0)
    {
        Assert(boundinfo->ndatums > 0);
        result->bound_offsets = bms_add_range(NULL, 0,
                                              boundinfo->ndatums - 1);
        result->scan_default = partition_bound_has_default(boundinfo);
        return result;
    }
 
    /* Special case handling of values coming from a <> operator clause. */
    if (opstrategy == InvalidStrategy)
    {
        /*
         * First match to all bounds.  We'll remove any matching datums below.
         */
        Assert(boundinfo->ndatums > 0);
        result->bound_offsets = bms_add_range(NULL, 0,
                                              boundinfo->ndatums - 1);
 
        off = partition_list_bsearch(partsupfunc, partcollation, boundinfo,
                                     value, &is_equal);
        if (off >= 0 && is_equal)
        {
 
            /* We have a match. Remove from the result. */
            Assert(boundinfo->indexes[off] >= 0);
            result->bound_offsets = bms_del_member(result->bound_offsets,
                                                   off);
        }
 
        /* Always include the default partition if any. */
        result->scan_default = partition_bound_has_default(boundinfo);
 
        return result;
    }
 
    /*
     * With range queries, always include the default list partition, because
     * list partitions divide the key space in a discontinuous manner, not all
     * values in the given range will have a partition assigned.  This may not
     * technically be true for some data types (e.g. integer types), however,
     * we currently lack any sort of infrastructure to provide us with proofs
     * that would allow us to do anything smarter here.
     */
    if (opstrategy != BTEqualStrategyNumber)
        result->scan_default = partition_bound_has_default(boundinfo);
 
    switch (opstrategy)
    {
        case BTEqualStrategyNumber:
            off = partition_list_bsearch(partsupfunc,
                                         partcollation,
                                         boundinfo, value,
                                         &is_equal);
            if (off >= 0 && is_equal)
            {
                Assert(boundinfo->indexes[off] >= 0);
                result->bound_offsets = bms_make_singleton(off);
            }
            else
                result->scan_default = partition_bound_has_default(boundinfo);
            return result;
 
        case BTGreaterEqualStrategyNumber:
            inclusive = true;
            /* fall through */
        case BTGreaterStrategyNumber:
            off = partition_list_bsearch(partsupfunc,
                                         partcollation,
                                         boundinfo, value,
                                         &is_equal);
            if (off >= 0)
            {
                /* We don't want the matched datum to be in the result. */
                if (!is_equal || !inclusive)
                    off++;
            }
            else
            {
                /*
                 * This case means all partition bounds are greater, which in
                 * turn means that all partitions satisfy this key.
                 */
                off = 0;
            }
 
            /*
             * off is greater than the numbers of datums we have partitions
             * for.  The only possible partition that could contain a match is
             * the default partition, but we must've set context->scan_default
             * above anyway if one exists.
             */
            if (off > boundinfo->ndatums - 1)
                return result;
 
            minoff = off;
            break;
 
        case BTLessEqualStrategyNumber:
            inclusive = true;
            /* fall through */
        case BTLessStrategyNumber:
            off = partition_list_bsearch(partsupfunc,
                                         partcollation,
                                         boundinfo, value,
                                         &is_equal);
            if (off >= 0 && is_equal && !inclusive)
                off--;
 
            /*
             * off is smaller than the datums of all non-default partitions.
             * The only possible partition that could contain a match is the
             * default partition, but we must've set context->scan_default
             * above anyway if one exists.
             */
            if (off < 0)
                return result;
 
            maxoff = off;
            break;
 
        default:
            elog(ERROR, "invalid strategy number %d", opstrategy);
            break;
    }
 
    Assert(minoff >= 0 && maxoff >= 0);
    result->bound_offsets = bms_add_range(NULL, minoff, maxoff);
    return result;
}

References Assert(), bms_add_range(), bms_del_member(), bms_is_empty, bms_make_singleton(), PruneStepResult::bound_offsets, PartitionPruneContext::boundinfo, BTEqualStrategyNumber, BTGreaterEqualStrategyNumber, BTGreaterStrategyNumber, BTLessEqualStrategyNumber, BTLessStrategyNumber, elog(), ERROR, PartitionBoundInfoData::indexes, InvalidStrategy, PartitionBoundInfoData::ndatums, palloc0(), PartitionPruneContext::partcollation, partition_bound_accepts_nulls, partition_bound_has_default, partition_list_bsearch(), PARTITION_STRATEGY_LIST, PartitionPruneContext::partnatts, PruneStepResult::scan_default, PruneStepResult::scan_null, PartitionPruneContext::strategy, and value.

Referenced by perform_pruning_base_step().

get_matching_partitions()

Bitmapset* get_matching_partitions	(	PartitionPruneContext *	context,
		List *	pruning_steps
	)

Definition at line 820 of file partprune.c.

{
    Bitmapset  *result;
    int         num_steps = list_length(pruning_steps),
                i;
    PruneStepResult **results,
               *final_result;
    ListCell   *lc;
    bool        scan_default;
 
    /* If there are no pruning steps then all partitions match. */
    if (num_steps == 0)
    {
        Assert(context->nparts > 0);
        return bms_add_range(NULL, 0, context->nparts - 1);
    }
 
    /*
     * Allocate space for individual pruning steps to store its result.  Each
     * slot will hold a PruneStepResult after performing a given pruning step.
     * Later steps may use the result of one or more earlier steps.  The
     * result of applying all pruning steps is the value contained in the slot
     * of the last pruning step.
     */
    results = (PruneStepResult **)
        palloc0(num_steps * sizeof(PruneStepResult *));
    foreach(lc, pruning_steps)
    {
        PartitionPruneStep *step = lfirst(lc);
 
        switch (nodeTag(step))
        {
            case T_PartitionPruneStepOp:
                results[step->step_id] =
                    perform_pruning_base_step(context,
                                              (PartitionPruneStepOp *) step);
                break;
 
            case T_PartitionPruneStepCombine:
                results[step->step_id] =
                    perform_pruning_combine_step(context,
                                                 (PartitionPruneStepCombine *) step,
                                                 results);
                break;
 
            default:
                elog(ERROR, "invalid pruning step type: %d",
                     (int) nodeTag(step));
        }
    }
 
    /*
     * At this point we know the offsets of all the datums whose corresponding
     * partitions need to be in the result, including special null-accepting
     * and default partitions.  Collect the actual partition indexes now.
     */
    final_result = results[num_steps - 1];
    Assert(final_result != NULL);
    i = -1;
    result = NULL;
    scan_default = final_result->scan_default;
    while ((i = bms_next_member(final_result->bound_offsets, i)) >= 0)
    {
        int         partindex;
 
        Assert(i < context->boundinfo->nindexes);
        partindex = context->boundinfo->indexes[i];
 
        if (partindex < 0)
        {
            /*
             * In range partitioning cases, if a partition index is -1 it
             * means that the bound at the offset is the upper bound for a
             * range not covered by any partition (other than a possible
             * default partition).  In hash partitioning, the same means no
             * partition has been defined for the corresponding remainder
             * value.
             *
             * In either case, the value is still part of the queried range of
             * values, so mark to scan the default partition if one exists.
             */
            scan_default |= partition_bound_has_default(context->boundinfo);
            continue;
        }
 
        result = bms_add_member(result, partindex);
    }
 
    /* Add the null and/or default partition if needed and present. */
    if (final_result->scan_null)
    {
        Assert(context->strategy == PARTITION_STRATEGY_LIST);
        Assert(partition_bound_accepts_nulls(context->boundinfo));
        result = bms_add_member(result, context->boundinfo->null_index);
    }
    if (scan_default)
    {
        Assert(context->strategy == PARTITION_STRATEGY_LIST ||
               context->strategy == PARTITION_STRATEGY_RANGE);
        Assert(partition_bound_has_default(context->boundinfo));
        result = bms_add_member(result, context->boundinfo->default_index);
    }
 
    return result;
}

References Assert(), bms_add_member(), bms_add_range(), bms_next_member(), PruneStepResult::bound_offsets, PartitionPruneContext::boundinfo, PartitionBoundInfoData::default_index, elog(), ERROR, i, PartitionBoundInfoData::indexes, lfirst, list_length(), nodeTag, PartitionPruneContext::nparts, PartitionBoundInfoData::null_index, palloc0(), partition_bound_accepts_nulls, partition_bound_has_default, PARTITION_STRATEGY_LIST, PARTITION_STRATEGY_RANGE, perform_pruning_base_step(), perform_pruning_combine_step(), PruneStepResult::scan_default, PruneStepResult::scan_null, PartitionPruneStep::step_id, and PartitionPruneContext::strategy.

Referenced by find_matching_subplans_recurse(), and prune_append_rel_partitions().

get_matching_range_bounds()

static PruneStepResult * get_matching_range_bounds ( PartitionPruneContext *  context, StrategyNumber  opstrategy, Datum *  values, int  nvalues, FmgrInfo *  partsupfunc, Bitmapset *  nullkeys  )

static

Definition at line 2873 of file partprune.c.

{
    PruneStepResult *result = (PruneStepResult *) palloc0(sizeof(PruneStepResult));
    PartitionBoundInfo boundinfo = context->boundinfo;
    Oid        *partcollation = context->partcollation;
    int         partnatts = context->partnatts;
    int        *partindices = boundinfo->indexes;
    int         off,
                minoff,
                maxoff;
    bool        is_equal;
    bool        inclusive = false;
 
    Assert(context->strategy == PARTITION_STRATEGY_RANGE);
    Assert(nvalues <= partnatts);
 
    result->scan_null = result->scan_default = false;
 
    /*
     * If there are no datums to compare keys with, or if we got an IS NULL
     * clause just return the default partition, if it exists.
     */
    if (boundinfo->ndatums == 0 || !bms_is_empty(nullkeys))
    {
        result->scan_default = partition_bound_has_default(boundinfo);
        return result;
    }
 
    minoff = 0;
    maxoff = boundinfo->ndatums;
 
    /*
     * If there are no values to compare with the datums in boundinfo, it
     * means the caller asked for partitions for all non-null datums.  Add
     * indexes of *all* partitions, including the default partition if one
     * exists.
     */
    if (nvalues == 0)
    {
        /* ignore key space not covered by any partitions */
        if (partindices[minoff] < 0)
            minoff++;
        if (partindices[maxoff] < 0)
            maxoff--;
 
        result->scan_default = partition_bound_has_default(boundinfo);
        Assert(partindices[minoff] >= 0 &&
               partindices[maxoff] >= 0);
        result->bound_offsets = bms_add_range(NULL, minoff, maxoff);
 
        return result;
    }
 
    /*
     * If the query does not constrain all key columns, we'll need to scan the
     * default partition, if any.
     */
    if (nvalues < partnatts)
        result->scan_default = partition_bound_has_default(boundinfo);
 
    switch (opstrategy)
    {
        case BTEqualStrategyNumber:
            /* Look for the smallest bound that is = lookup value. */
            off = partition_range_datum_bsearch(partsupfunc,
                                                partcollation,
                                                boundinfo,
                                                nvalues, values,
                                                &is_equal);
 
            if (off >= 0 && is_equal)
            {
                if (nvalues == partnatts)
                {
                    /* There can only be zero or one matching partition. */
                    result->bound_offsets = bms_make_singleton(off + 1);
                    return result;
                }
                else
                {
                    int         saved_off = off;
 
                    /*
                     * Since the lookup value contains only a prefix of keys,
                     * we must find other bounds that may also match the
                     * prefix.  partition_range_datum_bsearch() returns the
                     * offset of one of them, find others by checking adjacent
                     * bounds.
                     */
 
                    /*
                     * First find greatest bound that's smaller than the
                     * lookup value.
                     */
                    while (off >= 1)
                    {
                        int32       cmpval;
 
                        cmpval =
                            partition_rbound_datum_cmp(partsupfunc,
                                                       partcollation,
                                                       boundinfo->datums[off - 1],
                                                       boundinfo->kind[off - 1],
                                                       values, nvalues);
                        if (cmpval != 0)
                            break;
                        off--;
                    }
 
                    Assert(0 ==
                           partition_rbound_datum_cmp(partsupfunc,
                                                      partcollation,
                                                      boundinfo->datums[off],
                                                      boundinfo->kind[off],
                                                      values, nvalues));
 
                    /*
                     * We can treat 'off' as the offset of the smallest bound
                     * to be included in the result, if we know it is the
                     * upper bound of the partition in which the lookup value
                     * could possibly exist.  One case it couldn't is if the
                     * bound, or precisely the matched portion of its prefix,
                     * is not inclusive.
                     */
                    if (boundinfo->kind[off][nvalues] ==
                        PARTITION_RANGE_DATUM_MINVALUE)
                        off++;
 
                    minoff = off;
 
                    /*
                     * Now find smallest bound that's greater than the lookup
                     * value.
                     */
                    off = saved_off;
                    while (off < boundinfo->ndatums - 1)
                    {
                        int32       cmpval;
 
                        cmpval = partition_rbound_datum_cmp(partsupfunc,
                                                            partcollation,
                                                            boundinfo->datums[off + 1],
                                                            boundinfo->kind[off + 1],
                                                            values, nvalues);
                        if (cmpval != 0)
                            break;
                        off++;
                    }
 
                    Assert(0 ==
                           partition_rbound_datum_cmp(partsupfunc,
                                                      partcollation,
                                                      boundinfo->datums[off],
                                                      boundinfo->kind[off],
                                                      values, nvalues));
 
                    /*
                     * off + 1, then would be the offset of the greatest bound
                     * to be included in the result.
                     */
                    maxoff = off + 1;
                }
 
                Assert(minoff >= 0 && maxoff >= 0);
                result->bound_offsets = bms_add_range(NULL, minoff, maxoff);
            }
            else
            {
                /*
                 * The lookup value falls in the range between some bounds in
                 * boundinfo.  'off' would be the offset of the greatest bound
                 * that is <= lookup value, so add off + 1 to the result
                 * instead as the offset of the upper bound of the only
                 * partition that may contain the lookup value.  If 'off' is
                 * -1 indicating that all bounds are greater, then we simply
                 * end up adding the first bound's offset, that is, 0.
                 */
                result->bound_offsets = bms_make_singleton(off + 1);
            }
 
            return result;
 
        case BTGreaterEqualStrategyNumber:
            inclusive = true;
            /* fall through */
        case BTGreaterStrategyNumber:
 
            /*
             * Look for the smallest bound that is > or >= lookup value and
             * set minoff to its offset.
             */
            off = partition_range_datum_bsearch(partsupfunc,
                                                partcollation,
                                                boundinfo,
                                                nvalues, values,
                                                &is_equal);
            if (off < 0)
            {
                /*
                 * All bounds are greater than the lookup value, so include
                 * all of them in the result.
                 */
                minoff = 0;
            }
            else
            {
                if (is_equal && nvalues < partnatts)
                {
                    /*
                     * Since the lookup value contains only a prefix of keys,
                     * we must find other bounds that may also match the
                     * prefix.  partition_range_datum_bsearch() returns the
                     * offset of one of them, find others by checking adjacent
                     * bounds.
                     *
                     * Based on whether the lookup values are inclusive or
                     * not, we must either include the indexes of all such
                     * bounds in the result (that is, set minoff to the index
                     * of smallest such bound) or find the smallest one that's
                     * greater than the lookup values and set minoff to that.
                     */
                    while (off >= 1 && off < boundinfo->ndatums - 1)
                    {
                        int32       cmpval;
                        int         nextoff;
 
                        nextoff = inclusive ? off - 1 : off + 1;
                        cmpval =
                            partition_rbound_datum_cmp(partsupfunc,
                                                       partcollation,
                                                       boundinfo->datums[nextoff],
                                                       boundinfo->kind[nextoff],
                                                       values, nvalues);
                        if (cmpval != 0)
                            break;
 
                        off = nextoff;
                    }
 
                    Assert(0 ==
                           partition_rbound_datum_cmp(partsupfunc,
                                                      partcollation,
                                                      boundinfo->datums[off],
                                                      boundinfo->kind[off],
                                                      values, nvalues));
 
                    minoff = inclusive ? off : off + 1;
                }
                else
                {
 
                    /*
                     * lookup value falls in the range between some bounds in
                     * boundinfo.  off would be the offset of the greatest
                     * bound that is <= lookup value, so add off + 1 to the
                     * result instead as the offset of the upper bound of the
                     * smallest partition that may contain the lookup value.
                     */
                    minoff = off + 1;
                }
            }
            break;
 
        case BTLessEqualStrategyNumber:
            inclusive = true;
            /* fall through */
        case BTLessStrategyNumber:
 
            /*
             * Look for the greatest bound that is < or <= lookup value and
             * set maxoff to its offset.
             */
            off = partition_range_datum_bsearch(partsupfunc,
                                                partcollation,
                                                boundinfo,
                                                nvalues, values,
                                                &is_equal);
            if (off >= 0)
            {
                /*
                 * See the comment above.
                 */
                if (is_equal && nvalues < partnatts)
                {
                    while (off >= 1 && off < boundinfo->ndatums - 1)
                    {
                        int32       cmpval;
                        int         nextoff;
 
                        nextoff = inclusive ? off + 1 : off - 1;
                        cmpval = partition_rbound_datum_cmp(partsupfunc,
                                                            partcollation,
                                                            boundinfo->datums[nextoff],
                                                            boundinfo->kind[nextoff],
                                                            values, nvalues);
                        if (cmpval != 0)
                            break;
 
                        off = nextoff;
                    }
 
                    Assert(0 ==
                           partition_rbound_datum_cmp(partsupfunc,
                                                      partcollation,
                                                      boundinfo->datums[off],
                                                      boundinfo->kind[off],
                                                      values, nvalues));
 
                    maxoff = inclusive ? off + 1 : off;
                }
 
                /*
                 * The lookup value falls in the range between some bounds in
                 * boundinfo.  'off' would be the offset of the greatest bound
                 * that is <= lookup value, so add off + 1 to the result
                 * instead as the offset of the upper bound of the greatest
                 * partition that may contain lookup value.  If the lookup
                 * value had exactly matched the bound, but it isn't
                 * inclusive, no need add the adjacent partition.
                 */
                else if (!is_equal || inclusive)
                    maxoff = off + 1;
                else
                    maxoff = off;
            }
            else
            {
                /*
                 * 'off' is -1 indicating that all bounds are greater, so just
                 * set the first bound's offset as maxoff.
                 */
                maxoff = off + 1;
            }
            break;
 
        default:
            elog(ERROR, "invalid strategy number %d", opstrategy);
            break;
    }
 
    Assert(minoff >= 0 && minoff <= boundinfo->ndatums);
    Assert(maxoff >= 0 && maxoff <= boundinfo->ndatums);
 
    /*
     * If the smallest partition to return has MINVALUE (negative infinity) as
     * its lower bound, increment it to point to the next finite bound
     * (supposedly its upper bound), so that we don't inadvertently end up
     * scanning the default partition.
     */
    if (minoff < boundinfo->ndatums && partindices[minoff] < 0)
    {
        int         lastkey = nvalues - 1;
 
        if (boundinfo->kind[minoff][lastkey] ==
            PARTITION_RANGE_DATUM_MINVALUE)
        {
            minoff++;
            Assert(boundinfo->indexes[minoff] >= 0);
        }
    }
 
    /*
     * If the previous greatest partition has MAXVALUE (positive infinity) as
     * its upper bound (something only possible to do with multi-column range
     * partitioning), we scan switch to it as the greatest partition to
     * return.  Again, so that we don't inadvertently end up scanning the
     * default partition.
     */
    if (maxoff >= 1 && partindices[maxoff] < 0)
    {
        int         lastkey = nvalues - 1;
 
        if (boundinfo->kind[maxoff - 1][lastkey] ==
            PARTITION_RANGE_DATUM_MAXVALUE)
        {
            maxoff--;
            Assert(boundinfo->indexes[maxoff] >= 0);
        }
    }
 
    Assert(minoff >= 0 && maxoff >= 0);
    if (minoff <= maxoff)
        result->bound_offsets = bms_add_range(NULL, minoff, maxoff);
 
    return result;
}

References Assert(), bms_add_range(), bms_is_empty, bms_make_singleton(), PruneStepResult::bound_offsets, PartitionPruneContext::boundinfo, BTEqualStrategyNumber, BTGreaterEqualStrategyNumber, BTGreaterStrategyNumber, BTLessEqualStrategyNumber, BTLessStrategyNumber, PartitionBoundInfoData::datums, elog(), ERROR, PartitionBoundInfoData::indexes, PartitionBoundInfoData::kind, PartitionBoundInfoData::ndatums, palloc0(), PartitionPruneContext::partcollation, partition_bound_has_default, partition_range_datum_bsearch(), PARTITION_RANGE_DATUM_MAXVALUE, PARTITION_RANGE_DATUM_MINVALUE, partition_rbound_datum_cmp(), PARTITION_STRATEGY_RANGE, PartitionPruneContext::partnatts, PruneStepResult::scan_default, PruneStepResult::scan_null, PartitionPruneContext::strategy, and values.

Referenced by perform_pruning_base_step().

get_partkey_exec_paramids()

static Bitmapset * get_partkey_exec_paramids ( List *  steps )

static

Definition at line 3302 of file partprune.c.

{
    Bitmapset  *execparamids = NULL;
    ListCell   *lc;
 
    foreach(lc, steps)
    {
        PartitionPruneStepOp *step = (PartitionPruneStepOp *) lfirst(lc);
        ListCell   *lc2;
 
        if (!IsA(step, PartitionPruneStepOp))
            continue;
 
        foreach(lc2, step->exprs)
        {
            Expr       *expr = lfirst(lc2);
 
            /* We can be quick for plain Consts */
            if (!IsA(expr, Const))
                execparamids = bms_join(execparamids,
                                        pull_exec_paramids(expr));
        }
    }
 
    return execparamids;
}

References bms_join(), PartitionPruneStepOp::exprs, IsA, lfirst, and pull_exec_paramids().

Referenced by make_partitionedrel_pruneinfo().

get_steps_using_prefix()

static List * get_steps_using_prefix ( GeneratePruningStepsContext *  context, StrategyNumber  step_opstrategy, bool  step_op_is_ne, Expr *  step_lastexpr, Oid  step_lastcmpfn, int  step_lastkeyno, Bitmapset *  step_nullkeys, List *  prefix  )

static

Definition at line 2374 of file partprune.c.

{
    Assert(step_nullkeys == NULL ||
           context->rel->part_scheme->strategy == PARTITION_STRATEGY_HASH);
 
    /* Quick exit if there are no values to prefix with. */
    if (prefix == NIL)
    {
        PartitionPruneStep *step;
 
        step = gen_prune_step_op(context,
                                 step_opstrategy,
                                 step_op_is_ne,
                                 list_make1(step_lastexpr),
                                 list_make1_oid(step_lastcmpfn),
                                 step_nullkeys);
        return list_make1(step);
    }
 
    /* Recurse to generate steps for various combinations. */
    return get_steps_using_prefix_recurse(context,
                                          step_opstrategy,
                                          step_op_is_ne,
                                          step_lastexpr,
                                          step_lastcmpfn,
                                          step_lastkeyno,
                                          step_nullkeys,
                                          prefix,
                                          list_head(prefix),
                                          NIL, NIL);
}

References Assert(), gen_prune_step_op(), get_steps_using_prefix_recurse(), list_head(), list_make1, list_make1_oid, NIL, PARTITION_STRATEGY_HASH, and GeneratePruningStepsContext::rel.

Referenced by gen_prune_steps_from_opexps().

get_steps_using_prefix_recurse()

static List * get_steps_using_prefix_recurse ( GeneratePruningStepsContext *  context, StrategyNumber  step_opstrategy, bool  step_op_is_ne, Expr *  step_lastexpr, Oid  step_lastcmpfn, int  step_lastkeyno, Bitmapset *  step_nullkeys, List *  prefix, ListCell *  start, List *  step_exprs, List *  step_cmpfns  )

static

Definition at line 2426 of file partprune.c.

{
    List       *result = NIL;
    ListCell   *lc;
    int         cur_keyno;
 
    /* Actually, recursion would be limited by PARTITION_MAX_KEYS. */
    check_stack_depth();
 
    /* Check if we need to recurse. */
    Assert(start != NULL);
    cur_keyno = ((PartClauseInfo *) lfirst(start))->keyno;
    if (cur_keyno < step_lastkeyno - 1)
    {
        PartClauseInfo *pc;
        ListCell   *next_start;
 
        /*
         * For each clause with cur_keyno, add its expr and cmpfn to
         * step_exprs and step_cmpfns, respectively, and recurse after setting
         * next_start to the ListCell of the first clause for the next
         * partition key.
         */
        for_each_cell(lc, prefix, start)
        {
            pc = lfirst(lc);
 
            if (pc->keyno > cur_keyno)
                break;
        }
        next_start = lc;
 
        for_each_cell(lc, prefix, start)
        {
            List       *moresteps;
            List       *step_exprs1,
                       *step_cmpfns1;
 
            pc = lfirst(lc);
            if (pc->keyno == cur_keyno)
            {
                /* Leave the original step_exprs unmodified. */
                step_exprs1 = list_copy(step_exprs);
                step_exprs1 = lappend(step_exprs1, pc->expr);
 
                /* Leave the original step_cmpfns unmodified. */
                step_cmpfns1 = list_copy(step_cmpfns);
                step_cmpfns1 = lappend_oid(step_cmpfns1, pc->cmpfn);
            }
            else
            {
                Assert(pc->keyno > cur_keyno);
                break;
            }
 
            moresteps = get_steps_using_prefix_recurse(context,
                                                       step_opstrategy,
                                                       step_op_is_ne,
                                                       step_lastexpr,
                                                       step_lastcmpfn,
                                                       step_lastkeyno,
                                                       step_nullkeys,
                                                       prefix,
                                                       next_start,
                                                       step_exprs1,
                                                       step_cmpfns1);
            result = list_concat(result, moresteps);
 
            list_free(step_exprs1);
            list_free(step_cmpfns1);
        }
    }
    else
    {
        /*
         * End the current recursion cycle and start generating steps, one for
         * each clause with cur_keyno, which is all clauses from here onward
         * till the end of the list.  Note that for hash partitioning,
         * step_nullkeys is allowed to be non-empty, in which case step_exprs
         * would only contain expressions for the earlier partition keys that
         * are not specified in step_nullkeys.
         */
        Assert(list_length(step_exprs) == cur_keyno ||
               !bms_is_empty(step_nullkeys));
 
        /*
         * Note also that for hash partitioning, each partition key should
         * have either equality clauses or an IS NULL clause, so if a
         * partition key doesn't have an expression, it would be specified in
         * step_nullkeys.
         */
        Assert(context->rel->part_scheme->strategy
               != PARTITION_STRATEGY_HASH ||
               list_length(step_exprs) + 2 + bms_num_members(step_nullkeys) ==
               context->rel->part_scheme->partnatts);
        for_each_cell(lc, prefix, start)
        {
            PartClauseInfo *pc = lfirst(lc);
            PartitionPruneStep *step;
            List       *step_exprs1,
                       *step_cmpfns1;
 
            Assert(pc->keyno == cur_keyno);
 
            /* Leave the original step_exprs unmodified. */
            step_exprs1 = list_copy(step_exprs);
            step_exprs1 = lappend(step_exprs1, pc->expr);
            step_exprs1 = lappend(step_exprs1, step_lastexpr);
 
            /* Leave the original step_cmpfns unmodified. */
            step_cmpfns1 = list_copy(step_cmpfns);
            step_cmpfns1 = lappend_oid(step_cmpfns1, pc->cmpfn);
            step_cmpfns1 = lappend_oid(step_cmpfns1, step_lastcmpfn);
 
            step = gen_prune_step_op(context,
                                     step_opstrategy, step_op_is_ne,
                                     step_exprs1, step_cmpfns1,
                                     step_nullkeys);
            result = lappend(result, step);
        }
    }
 
    return result;
}

References Assert(), bms_is_empty, bms_num_members(), check_stack_depth(), PartClauseInfo::cmpfn, PartClauseInfo::expr, for_each_cell, gen_prune_step_op(), PartClauseInfo::keyno, lappend(), lappend_oid(), lfirst, list_concat(), list_copy(), list_free(), list_length(), NIL, PARTITION_STRATEGY_HASH, and GeneratePruningStepsContext::rel.

Referenced by get_steps_using_prefix().

make_partition_pruneinfo()

PartitionPruneInfo* make_partition_pruneinfo	(	PlannerInfo *	root,
		RelOptInfo *	parentrel,
		List *	subpaths,
		List *	prunequal
	)

Definition at line 223 of file partprune.c.

{
    PartitionPruneInfo *pruneinfo;
    Bitmapset  *allmatchedsubplans = NULL;
    List       *allpartrelids;
    List       *prunerelinfos;
    int        *relid_subplan_map;
    ListCell   *lc;
    int         i;
 
    /*
     * Scan the subpaths to see which ones are scans of partition child
     * relations, and identify their parent partitioned rels.  (Note: we must
     * restrict the parent partitioned rels to be parentrel or children of
     * parentrel, otherwise we couldn't translate prunequal to match.)
     *
     * Also construct a temporary array to map from partition-child-relation
     * relid to the index in 'subpaths' of the scan plan for that partition.
     * (Use of "subplan" rather than "subpath" is a bit of a misnomer, but
     * we'll let it stand.)  For convenience, we use 1-based indexes here, so
     * that zero can represent an un-filled array entry.
     */
    allpartrelids = NIL;
    relid_subplan_map = palloc0(sizeof(int) * root->simple_rel_array_size);
 
    i = 1;
    foreach(lc, subpaths)
    {
        Path       *path = (Path *) lfirst(lc);
        RelOptInfo *pathrel = path->parent;
 
        /* We don't consider partitioned joins here */
        if (pathrel->reloptkind == RELOPT_OTHER_MEMBER_REL)
        {
            RelOptInfo *prel = pathrel;
            Bitmapset  *partrelids = NULL;
 
            /*
             * Traverse up to the pathrel's topmost partitioned parent,
             * collecting parent relids as we go; but stop if we reach
             * parentrel.  (Normally, a pathrel's topmost partitioned parent
             * is either parentrel or a UNION ALL appendrel child of
             * parentrel.  But when handling partitionwise joins of
             * multi-level partitioning trees, we can see an append path whose
             * parentrel is an intermediate partitioned table.)
             */
            do
            {
                AppendRelInfo *appinfo;
 
                Assert(prel->relid < root->simple_rel_array_size);
                appinfo = root->append_rel_array[prel->relid];
                prel = find_base_rel(root, appinfo->parent_relid);
                if (!IS_PARTITIONED_REL(prel))
                    break;      /* reached a non-partitioned parent */
                /* accept this level as an interesting parent */
                partrelids = bms_add_member(partrelids, prel->relid);
                if (prel == parentrel)
                    break;      /* don't traverse above parentrel */
            } while (prel->reloptkind == RELOPT_OTHER_MEMBER_REL);
 
            if (partrelids)
            {
                /*
                 * Found some relevant parent partitions, which may or may not
                 * overlap with partition trees we already found.  Add new
                 * information to the allpartrelids list.
                 */
                allpartrelids = add_part_relids(allpartrelids, partrelids);
                /* Also record the subplan in relid_subplan_map[] */
                /* No duplicates please */
                Assert(relid_subplan_map[pathrel->relid] == 0);
                relid_subplan_map[pathrel->relid] = i;
            }
        }
        i++;
    }
 
    /*
     * We now build a PartitionedRelPruneInfo for each topmost partitioned rel
     * (omitting any that turn out not to have useful pruning quals).
     */
    prunerelinfos = NIL;
    foreach(lc, allpartrelids)
    {
        Bitmapset  *partrelids = (Bitmapset *) lfirst(lc);
        List       *pinfolist;
        Bitmapset  *matchedsubplans = NULL;
 
        pinfolist = make_partitionedrel_pruneinfo(root, parentrel,
                                                  prunequal,
                                                  partrelids,
                                                  relid_subplan_map,
                                                  &matchedsubplans);
 
        /* When pruning is possible, record the matched subplans */
        if (pinfolist != NIL)
        {
            prunerelinfos = lappend(prunerelinfos, pinfolist);
            allmatchedsubplans = bms_join(matchedsubplans,
                                          allmatchedsubplans);
        }
    }
 
    pfree(relid_subplan_map);
 
    /*
     * If none of the partition hierarchies had any useful run-time pruning
     * quals, then we can just not bother with run-time pruning.
     */
    if (prunerelinfos == NIL)
        return NULL;
 
    /* Else build the result data structure */
    pruneinfo = makeNode(PartitionPruneInfo);
    pruneinfo->prune_infos = prunerelinfos;
 
    /*
     * Some subplans may not belong to any of the identified partitioned rels.
     * This can happen for UNION ALL queries which include a non-partitioned
     * table, or when some of the hierarchies aren't run-time prunable.  Build
     * a bitmapset of the indexes of all such subplans, so that the executor
     * can identify which subplans should never be pruned.
     */
    if (bms_num_members(allmatchedsubplans) < list_length(subpaths))
    {
        Bitmapset  *other_subplans;
 
        /* Create the complement of allmatchedsubplans */
        other_subplans = bms_add_range(NULL, 0, list_length(subpaths) - 1);
        other_subplans = bms_del_members(other_subplans, allmatchedsubplans);
 
        pruneinfo->other_subplans = other_subplans;
    }
    else
        pruneinfo->other_subplans = NULL;
 
    return pruneinfo;
}

References add_part_relids(), Assert(), bms_add_member(), bms_add_range(), bms_del_members(), bms_join(), bms_num_members(), find_base_rel(), i, IS_PARTITIONED_REL, lappend(), lfirst, list_length(), make_partitionedrel_pruneinfo(), makeNode, NIL, PartitionPruneInfo::other_subplans, palloc0(), AppendRelInfo::parent_relid, pfree(), PartitionPruneInfo::prune_infos, RelOptInfo::relid, RELOPT_OTHER_MEMBER_REL, RelOptInfo::reloptkind, and PlannerInfo::simple_rel_array_size.

Referenced by create_append_plan(), and create_merge_append_plan().

make_partitionedrel_pruneinfo()

static List * make_partitionedrel_pruneinfo ( PlannerInfo *  root, RelOptInfo *  parentrel, List *  prunequal, Bitmapset *  partrelids, int *  relid_subplan_map, Bitmapset **  matchedsubplans  )

static

Definition at line 441 of file partprune.c.

{
    RelOptInfo *targetpart = NULL;
    List       *pinfolist = NIL;
    bool        doruntimeprune = false;
    int        *relid_subpart_map;
    Bitmapset  *subplansfound = NULL;
    ListCell   *lc;
    int         rti;
    int         i;
 
    /*
     * Examine each partitioned rel, constructing a temporary array to map
     * from planner relids to index of the partitioned rel, and building a
     * PartitionedRelPruneInfo for each partitioned rel.
     *
     * In this phase we discover whether runtime pruning is needed at all; if
     * not, we can avoid doing further work.
     */
    relid_subpart_map = palloc0(sizeof(int) * root->simple_rel_array_size);
 
    i = 1;
    rti = -1;
    while ((rti = bms_next_member(partrelids, rti)) > 0)
    {
        RelOptInfo *subpart = find_base_rel(root, rti);
        PartitionedRelPruneInfo *pinfo;
        List       *partprunequal;
        List       *initial_pruning_steps;
        List       *exec_pruning_steps;
        Bitmapset  *execparamids;
        GeneratePruningStepsContext context;
 
        /*
         * Fill the mapping array.
         *
         * relid_subpart_map maps relid of a non-leaf partition to the index
         * in the returned PartitionedRelPruneInfo list of the info for that
         * partition.  We use 1-based indexes here, so that zero can represent
         * an un-filled array entry.
         */
        Assert(rti < root->simple_rel_array_size);
        relid_subpart_map[rti] = i++;
 
        /*
         * Translate pruning qual, if necessary, for this partition.
         *
         * The first item in the list is the target partitioned relation.
         */
        if (!targetpart)
        {
            targetpart = subpart;
 
            /*
             * The prunequal is presented to us as a qual for 'parentrel'.
             * Frequently this rel is the same as targetpart, so we can skip
             * an adjust_appendrel_attrs step.  But it might not be, and then
             * we have to translate.  We update the prunequal parameter here,
             * because in later iterations of the loop for child partitions,
             * we want to translate from parent to child variables.
             */
            if (!bms_equal(parentrel->relids, subpart->relids))
            {
                int         nappinfos;
                AppendRelInfo **appinfos = find_appinfos_by_relids(root,
                                                                   subpart->relids,
                                                                   &nappinfos);
 
                prunequal = (List *) adjust_appendrel_attrs(root, (Node *)
                                                            prunequal,
                                                            nappinfos,
                                                            appinfos);
 
                pfree(appinfos);
            }
 
            partprunequal = prunequal;
        }
        else
        {
            /*
             * For sub-partitioned tables the columns may not be in the same
             * order as the parent, so we must translate the prunequal to make
             * it compatible with this relation.
             */
            partprunequal = (List *)
                adjust_appendrel_attrs_multilevel(root,
                                                  (Node *) prunequal,
                                                  subpart,
                                                  targetpart);
        }
 
        /*
         * Convert pruning qual to pruning steps.  We may need to do this
         * twice, once to obtain executor startup pruning steps, and once for
         * executor per-scan pruning steps.  This first pass creates startup
         * pruning steps and detects whether there's any possibly-useful quals
         * that would require per-scan pruning.
         */
        gen_partprune_steps(subpart, partprunequal, PARTTARGET_INITIAL,
                            &context);
 
        if (context.contradictory)
        {
            /*
             * This shouldn't happen as the planner should have detected this
             * earlier. However, we do use additional quals from parameterized
             * paths here. These do only compare Params to the partition key,
             * so this shouldn't cause the discovery of any new qual
             * contradictions that were not previously discovered as the Param
             * values are unknown during planning.  Anyway, we'd better do
             * something sane here, so let's just disable run-time pruning.
             */
            return NIL;
        }
 
        /*
         * If no mutable operators or expressions appear in usable pruning
         * clauses, then there's no point in running startup pruning, because
         * plan-time pruning should have pruned everything prunable.
         */
        if (context.has_mutable_op || context.has_mutable_arg)
            initial_pruning_steps = context.steps;
        else
            initial_pruning_steps = NIL;
 
        /*
         * If no exec Params appear in potentially-usable pruning clauses,
         * then there's no point in even thinking about per-scan pruning.
         */
        if (context.has_exec_param)
        {
            /* ... OK, we'd better think about it */
            gen_partprune_steps(subpart, partprunequal, PARTTARGET_EXEC,
                                &context);
 
            if (context.contradictory)
            {
                /* As above, skip run-time pruning if anything fishy happens */
                return NIL;
            }
 
            exec_pruning_steps = context.steps;
 
            /*
             * Detect which exec Params actually got used; the fact that some
             * were in available clauses doesn't mean we actually used them.
             * Skip per-scan pruning if there are none.
             */
            execparamids = get_partkey_exec_paramids(exec_pruning_steps);
 
            if (bms_is_empty(execparamids))
                exec_pruning_steps = NIL;
        }
        else
        {
            /* No exec Params anywhere, so forget about scan-time pruning */
            exec_pruning_steps = NIL;
            execparamids = NULL;
        }
 
        if (initial_pruning_steps || exec_pruning_steps)
            doruntimeprune = true;
 
        /* Begin constructing the PartitionedRelPruneInfo for this rel */
        pinfo = makeNode(PartitionedRelPruneInfo);
        pinfo->rtindex = rti;
        pinfo->initial_pruning_steps = initial_pruning_steps;
        pinfo->exec_pruning_steps = exec_pruning_steps;
        pinfo->execparamids = execparamids;
        /* Remaining fields will be filled in the next loop */
 
        pinfolist = lappend(pinfolist, pinfo);
    }
 
    if (!doruntimeprune)
    {
        /* No run-time pruning required. */
        pfree(relid_subpart_map);
        return NIL;
    }
 
    /*
     * Run-time pruning will be required, so initialize other information.
     * That includes two maps -- one needed to convert partition indexes of
     * leaf partitions to the indexes of their subplans in the subplan list,
     * another needed to convert partition indexes of sub-partitioned
     * partitions to the indexes of their PartitionedRelPruneInfo in the
     * PartitionedRelPruneInfo list.
     */
    foreach(lc, pinfolist)
    {
        PartitionedRelPruneInfo *pinfo = lfirst(lc);
        RelOptInfo *subpart = find_base_rel(root, pinfo->rtindex);
        Bitmapset  *present_parts;
        int         nparts = subpart->nparts;
        int        *subplan_map;
        int        *subpart_map;
        Oid        *relid_map;
 
        /*
         * Construct the subplan and subpart maps for this partitioning level.
         * Here we convert to zero-based indexes, with -1 for empty entries.
         * Also construct a Bitmapset of all partitions that are present (that
         * is, not pruned already).
         */
        subplan_map = (int *) palloc(nparts * sizeof(int));
        memset(subplan_map, -1, nparts * sizeof(int));
        subpart_map = (int *) palloc(nparts * sizeof(int));
        memset(subpart_map, -1, nparts * sizeof(int));
        relid_map = (Oid *) palloc0(nparts * sizeof(Oid));
        present_parts = NULL;
 
        i = -1;
        while ((i = bms_next_member(subpart->live_parts, i)) >= 0)
        {
            RelOptInfo *partrel = subpart->part_rels[i];
            int         subplanidx;
            int         subpartidx;
 
            Assert(partrel != NULL);
 
            subplan_map[i] = subplanidx = relid_subplan_map[partrel->relid] - 1;
            subpart_map[i] = subpartidx = relid_subpart_map[partrel->relid] - 1;
            relid_map[i] = planner_rt_fetch(partrel->relid, root)->relid;
            if (subplanidx >= 0)
            {
                present_parts = bms_add_member(present_parts, i);
 
                /* Record finding this subplan  */
                subplansfound = bms_add_member(subplansfound, subplanidx);
            }
            else if (subpartidx >= 0)
                present_parts = bms_add_member(present_parts, i);
        }
 
        /*
         * Ensure there were no stray PartitionedRelPruneInfo generated for
         * partitioned tables that we have no sub-paths or
         * sub-PartitionedRelPruneInfo for.
         */
        Assert(!bms_is_empty(present_parts));
 
        /* Record the maps and other information. */
        pinfo->present_parts = present_parts;
        pinfo->nparts = nparts;
        pinfo->subplan_map = subplan_map;
        pinfo->subpart_map = subpart_map;
        pinfo->relid_map = relid_map;
    }
 
    pfree(relid_subpart_map);
 
    *matchedsubplans = subplansfound;
 
    return pinfolist;
}

References adjust_appendrel_attrs(), adjust_appendrel_attrs_multilevel(), Assert(), bms_add_member(), bms_equal(), bms_is_empty, bms_next_member(), GeneratePruningStepsContext::contradictory, PartitionedRelPruneInfo::exec_pruning_steps, PartitionedRelPruneInfo::execparamids, find_appinfos_by_relids(), find_base_rel(), gen_partprune_steps(), get_partkey_exec_paramids(), GeneratePruningStepsContext::has_exec_param, GeneratePruningStepsContext::has_mutable_arg, GeneratePruningStepsContext::has_mutable_op, i, PartitionedRelPruneInfo::initial_pruning_steps, lappend(), lfirst, RelOptInfo::live_parts, makeNode, NIL, RelOptInfo::nparts, PartitionedRelPruneInfo::nparts, palloc(), palloc0(), PARTTARGET_EXEC, PARTTARGET_INITIAL, pfree(), planner_rt_fetch, PartitionedRelPruneInfo::present_parts, RelOptInfo::relid, RelOptInfo::relids, PartitionedRelPruneInfo::rtindex, PlannerInfo::simple_rel_array_size, and GeneratePruningStepsContext::steps.

Referenced by make_partition_pruneinfo().

match_boolean_partition_clause()

static PartClauseMatchStatus match_boolean_partition_clause ( Oid  partopfamily, Expr *  clause, Expr *  partkey, Expr **  outconst, bool *  noteq  )

static

Definition at line 3594 of file partprune.c.

{
    Expr       *leftop;
 
    *outconst = NULL;
    *noteq = false;
 
    /*
     * Partitioning currently can only use built-in AMs, so checking for
     * built-in boolean opfamilies is good enough.
     */
    if (!IsBuiltinBooleanOpfamily(partopfamily))
        return PARTCLAUSE_UNSUPPORTED;
 
    if (IsA(clause, BooleanTest))
    {
        BooleanTest *btest = (BooleanTest *) clause;
 
        /* Only IS [NOT] TRUE/FALSE are any good to us */
        if (btest->booltesttype == IS_UNKNOWN ||
            btest->booltesttype == IS_NOT_UNKNOWN)
            return PARTCLAUSE_UNSUPPORTED;
 
        leftop = btest->arg;
        if (IsA(leftop, RelabelType))
            leftop = ((RelabelType *) leftop)->arg;
 
        if (equal(leftop, partkey))
        {
            switch (btest->booltesttype)
            {
                case IS_NOT_TRUE:
                    *noteq = true;
                    /* fall through */
                case IS_TRUE:
                    *outconst = (Expr *) makeBoolConst(true, false);
                    break;
                case IS_NOT_FALSE:
                    *noteq = true;
                    /* fall through */
                case IS_FALSE:
                    *outconst = (Expr *) makeBoolConst(false, false);
                    break;
                default:
                    return PARTCLAUSE_UNSUPPORTED;
            }
        }
        if (*outconst)
            return PARTCLAUSE_MATCH_CLAUSE;
    }
    else
    {
        bool        is_not_clause = is_notclause(clause);
 
        leftop = is_not_clause ? get_notclausearg(clause) : clause;
 
        if (IsA(leftop, RelabelType))
            leftop = ((RelabelType *) leftop)->arg;
 
        /* Compare to the partition key, and make up a clause ... */
        if (equal(leftop, partkey))
            *outconst = (Expr *) makeBoolConst(!is_not_clause, false);
        else if (equal(negate_clause((Node *) leftop), partkey))
            *outconst = (Expr *) makeBoolConst(is_not_clause, false);
 
        if (*outconst)
            return PARTCLAUSE_MATCH_CLAUSE;
    }
 
    return PARTCLAUSE_NOMATCH;
}

References arg, BooleanTest::arg, BooleanTest::booltesttype, equal(), get_notclausearg(), IS_FALSE, IS_NOT_FALSE, IS_NOT_TRUE, IS_NOT_UNKNOWN, is_notclause(), IS_TRUE, IS_UNKNOWN, IsA, makeBoolConst(), negate_clause(), PARTCLAUSE_MATCH_CLAUSE, PARTCLAUSE_NOMATCH, and PARTCLAUSE_UNSUPPORTED.

Referenced by match_clause_to_partition_key().

match_clause_to_partition_key()

static PartClauseMatchStatus match_clause_to_partition_key ( GeneratePruningStepsContext *  context, Expr *  clause, Expr *  partkey, int  partkeyidx, bool *  clause_is_not_null, PartClauseInfo **  pc, List **  clause_steps  )

static

Definition at line 1796 of file partprune.c.

{
    PartClauseMatchStatus boolmatchstatus;
    PartitionScheme part_scheme = context->rel->part_scheme;
    Oid         partopfamily = part_scheme->partopfamily[partkeyidx],
                partcoll = part_scheme->partcollation[partkeyidx];
    Expr       *expr;
    bool        noteq;
 
    /*
     * Recognize specially shaped clauses that match a Boolean partition key.
     */
    boolmatchstatus = match_boolean_partition_clause(partopfamily, clause,
                                                     partkey, &expr, &noteq);
 
    if (boolmatchstatus == PARTCLAUSE_MATCH_CLAUSE)
    {
        PartClauseInfo *partclause;
 
        partclause = (PartClauseInfo *) palloc(sizeof(PartClauseInfo));
        partclause->keyno = partkeyidx;
        /* Do pruning with the Boolean equality operator. */
        partclause->opno = BooleanEqualOperator;
        partclause->op_is_ne = noteq;
        partclause->expr = expr;
        /* We know that expr is of Boolean type. */
        partclause->cmpfn = part_scheme->partsupfunc[partkeyidx].fn_oid;
        partclause->op_strategy = InvalidStrategy;
 
        *pc = partclause;
 
        return PARTCLAUSE_MATCH_CLAUSE;
    }
    else if (IsA(clause, OpExpr) &&
             list_length(((OpExpr *) clause)->args) == 2)
    {
        OpExpr     *opclause = (OpExpr *) clause;
        Expr       *leftop,
                   *rightop;
        Oid         opno,
                    op_lefttype,
                    op_righttype,
                    negator = InvalidOid;
        Oid         cmpfn;
        int         op_strategy;
        bool        is_opne_listp = false;
        PartClauseInfo *partclause;
 
        leftop = (Expr *) get_leftop(clause);
        if (IsA(leftop, RelabelType))
            leftop = ((RelabelType *) leftop)->arg;
        rightop = (Expr *) get_rightop(clause);
        if (IsA(rightop, RelabelType))
            rightop = ((RelabelType *) rightop)->arg;
        opno = opclause->opno;
 
        /* check if the clause matches this partition key */
        if (equal(leftop, partkey))
            expr = rightop;
        else if (equal(rightop, partkey))
        {
            /*
             * It's only useful if we can commute the operator to put the
             * partkey on the left.  If we can't, the clause can be deemed
             * UNSUPPORTED.  Even if its leftop matches some later partkey, we
             * now know it has Vars on the right, so it's no use.
             */
            opno = get_commutator(opno);
            if (!OidIsValid(opno))
                return PARTCLAUSE_UNSUPPORTED;
            expr = leftop;
        }
        else
            /* clause does not match this partition key, but perhaps next. */
            return PARTCLAUSE_NOMATCH;
 
        /*
         * Partition key match also requires collation match.  There may be
         * multiple partkeys with the same expression but different
         * collations, so failure is NOMATCH.
         */
        if (!PartCollMatchesExprColl(partcoll, opclause->inputcollid))
            return PARTCLAUSE_NOMATCH;
 
        /*
         * See if the operator is relevant to the partitioning opfamily.
         *
         * Normally we only care about operators that are listed as being part
         * of the partitioning operator family.  But there is one exception:
         * the not-equals operators are not listed in any operator family
         * whatsoever, but their negators (equality) are.  We can use one of
         * those if we find it, but only for list partitioning.
         *
         * Note: we report NOMATCH on failure, in case a later partkey has the
         * same expression but different opfamily.  That's unlikely, but not
         * much more so than duplicate expressions with different collations.
         */
        if (op_in_opfamily(opno, partopfamily))
        {
            get_op_opfamily_properties(opno, partopfamily, false,
                                       &op_strategy, &op_lefttype,
                                       &op_righttype);
        }
        else
        {
            if (part_scheme->strategy != PARTITION_STRATEGY_LIST)
                return PARTCLAUSE_NOMATCH;
 
            /* See if the negator is equality */
            negator = get_negator(opno);
            if (OidIsValid(negator) && op_in_opfamily(negator, partopfamily))
            {
                get_op_opfamily_properties(negator, partopfamily, false,
                                           &op_strategy, &op_lefttype,
                                           &op_righttype);
                if (op_strategy == BTEqualStrategyNumber)
                    is_opne_listp = true;   /* bingo */
            }
 
            /* Nope, it's not <> either. */
            if (!is_opne_listp)
                return PARTCLAUSE_NOMATCH;
        }
 
        /*
         * Only allow strict operators.  This will guarantee nulls are
         * filtered.  (This test is likely useless, since btree and hash
         * comparison operators are generally strict.)
         */
        if (!op_strict(opno))
            return PARTCLAUSE_UNSUPPORTED;
 
        /*
         * OK, we have a match to the partition key and a suitable operator.
         * Examine the other argument to see if it's usable for pruning.
         *
         * In most of these cases, we can return UNSUPPORTED because the same
         * failure would occur no matter which partkey it's matched to.  (In
         * particular, now that we've successfully matched one side of the
         * opclause to a partkey, there is no chance that matching the other
         * side to another partkey will produce a usable result, since that'd
         * mean there are Vars on both sides.)
         *
         * Also, if we reject an argument for a target-dependent reason, set
         * appropriate fields of *context to report that.  We postpone these
         * tests until after matching the partkey and the operator, so as to
         * reduce the odds of setting the context fields for clauses that do
         * not end up contributing to pruning steps.
         *
         * First, check for non-Const argument.  (We assume that any immutable
         * subexpression will have been folded to a Const already.)
         */
        if (!IsA(expr, Const))
        {
            Bitmapset  *paramids;
 
            /*
             * When pruning in the planner, we only support pruning using
             * comparisons to constants.  We cannot prune on the basis of
             * anything that's not immutable.  (Note that has_mutable_arg and
             * has_exec_param do not get set for this target value.)
             */
            if (context->target == PARTTARGET_PLANNER)
                return PARTCLAUSE_UNSUPPORTED;
 
            /*
             * We can never prune using an expression that contains Vars.
             */
            if (contain_var_clause((Node *) expr))
                return PARTCLAUSE_UNSUPPORTED;
 
            /*
             * And we must reject anything containing a volatile function.
             * Stable functions are OK though.
             */
            if (contain_volatile_functions((Node *) expr))
                return PARTCLAUSE_UNSUPPORTED;
 
            /*
             * See if there are any exec Params.  If so, we can only use this
             * expression during per-scan pruning.
             */
            paramids = pull_exec_paramids(expr);
            if (!bms_is_empty(paramids))
            {
                context->has_exec_param = true;
                if (context->target != PARTTARGET_EXEC)
                    return PARTCLAUSE_UNSUPPORTED;
            }
            else
            {
                /* It's potentially usable, but mutable */
                context->has_mutable_arg = true;
            }
        }
 
        /*
         * Check whether the comparison operator itself is immutable.  (We
         * assume anything that's in a btree or hash opclass is at least
         * stable, but we need to check for immutability.)
         */
        if (op_volatile(opno) != PROVOLATILE_IMMUTABLE)
        {
            context->has_mutable_op = true;
 
            /*
             * When pruning in the planner, we cannot prune with mutable
             * operators.
             */
            if (context->target == PARTTARGET_PLANNER)
                return PARTCLAUSE_UNSUPPORTED;
        }
 
        /*
         * Now find the procedure to use, based on the types.  If the clause's
         * other argument is of the same type as the partitioning opclass's
         * declared input type, we can use the procedure cached in
         * PartitionKey.  If not, search for a cross-type one in the same
         * opfamily; if one doesn't exist, report no match.
         */
        if (op_righttype == part_scheme->partopcintype[partkeyidx])
            cmpfn = part_scheme->partsupfunc[partkeyidx].fn_oid;
        else
        {
            switch (part_scheme->strategy)
            {
                    /*
                     * For range and list partitioning, we need the ordering
                     * procedure with lefttype being the partition key's type,
                     * and righttype the clause's operator's right type.
                     */
                case PARTITION_STRATEGY_LIST:
                case PARTITION_STRATEGY_RANGE:
                    cmpfn =
                        get_opfamily_proc(part_scheme->partopfamily[partkeyidx],
                                          part_scheme->partopcintype[partkeyidx],
                                          op_righttype, BTORDER_PROC);
                    break;
 
                    /*
                     * For hash partitioning, we need the hashing procedure
                     * for the clause's type.
                     */
                case PARTITION_STRATEGY_HASH:
                    cmpfn =
                        get_opfamily_proc(part_scheme->partopfamily[partkeyidx],
                                          op_righttype, op_righttype,
                                          HASHEXTENDED_PROC);
                    break;
 
                default:
                    elog(ERROR, "invalid partition strategy: %c",
                         part_scheme->strategy);
                    cmpfn = InvalidOid; /* keep compiler quiet */
                    break;
            }
 
            if (!OidIsValid(cmpfn))
                return PARTCLAUSE_NOMATCH;
        }
 
        /*
         * Build the clause, passing the negator if applicable.
         */
        partclause = (PartClauseInfo *) palloc(sizeof(PartClauseInfo));
        partclause->keyno = partkeyidx;
        if (is_opne_listp)
        {
            Assert(OidIsValid(negator));
            partclause->opno = negator;
            partclause->op_is_ne = true;
            partclause->op_strategy = InvalidStrategy;
        }
        else
        {
            partclause->opno = opno;
            partclause->op_is_ne = false;
            partclause->op_strategy = op_strategy;
        }
        partclause->expr = expr;
        partclause->cmpfn = cmpfn;
 
        *pc = partclause;
 
        return PARTCLAUSE_MATCH_CLAUSE;
    }
    else if (IsA(clause, ScalarArrayOpExpr))
    {
        ScalarArrayOpExpr *saop = (ScalarArrayOpExpr *) clause;
        Oid         saop_op = saop->opno;
        Oid         saop_coll = saop->inputcollid;
        Expr       *leftop = (Expr *) linitial(saop->args),
                   *rightop = (Expr *) lsecond(saop->args);
        List       *elem_exprs,
                   *elem_clauses;
        ListCell   *lc1;
 
        if (IsA(leftop, RelabelType))
            leftop = ((RelabelType *) leftop)->arg;
 
        /* check if the LHS matches this partition key */
        if (!equal(leftop, partkey) ||
            !PartCollMatchesExprColl(partcoll, saop->inputcollid))
            return PARTCLAUSE_NOMATCH;
 
        /*
         * See if the operator is relevant to the partitioning opfamily.
         *
         * In case of NOT IN (..), we get a '<>', which we handle if list
         * partitioning is in use and we're able to confirm that it's negator
         * is a btree equality operator belonging to the partitioning operator
         * family.  As above, report NOMATCH for non-matching operator.
         */
        if (!op_in_opfamily(saop_op, partopfamily))
        {
            Oid         negator;
 
            if (part_scheme->strategy != PARTITION_STRATEGY_LIST)
                return PARTCLAUSE_NOMATCH;
 
            negator = get_negator(saop_op);
            if (OidIsValid(negator) && op_in_opfamily(negator, partopfamily))
            {
                int         strategy;
                Oid         lefttype,
                            righttype;
 
                get_op_opfamily_properties(negator, partopfamily,
                                           false, &strategy,
                                           &lefttype, &righttype);
                if (strategy != BTEqualStrategyNumber)
                    return PARTCLAUSE_NOMATCH;
            }
            else
                return PARTCLAUSE_NOMATCH;  /* no useful negator */
        }
 
        /*
         * Only allow strict operators.  This will guarantee nulls are
         * filtered.  (This test is likely useless, since btree and hash
         * comparison operators are generally strict.)
         */
        if (!op_strict(saop_op))
            return PARTCLAUSE_UNSUPPORTED;
 
        /*
         * OK, we have a match to the partition key and a suitable operator.
         * Examine the array argument to see if it's usable for pruning.  This
         * is identical to the logic for a plain OpExpr.
         */
        if (!IsA(rightop, Const))
        {
            Bitmapset  *paramids;
 
            /*
             * When pruning in the planner, we only support pruning using
             * comparisons to constants.  We cannot prune on the basis of
             * anything that's not immutable.  (Note that has_mutable_arg and
             * has_exec_param do not get set for this target value.)
             */
            if (context->target == PARTTARGET_PLANNER)
                return PARTCLAUSE_UNSUPPORTED;
 
            /*
             * We can never prune using an expression that contains Vars.
             */
            if (contain_var_clause((Node *) rightop))
                return PARTCLAUSE_UNSUPPORTED;
 
            /*
             * And we must reject anything containing a volatile function.
             * Stable functions are OK though.
             */
            if (contain_volatile_functions((Node *) rightop))
                return PARTCLAUSE_UNSUPPORTED;
 
            /*
             * See if there are any exec Params.  If so, we can only use this
             * expression during per-scan pruning.
             */
            paramids = pull_exec_paramids(rightop);
            if (!bms_is_empty(paramids))
            {
                context->has_exec_param = true;
                if (context->target != PARTTARGET_EXEC)
                    return PARTCLAUSE_UNSUPPORTED;
            }
            else
            {
                /* It's potentially usable, but mutable */
                context->has_mutable_arg = true;
            }
        }
 
        /*
         * Check whether the comparison operator itself is immutable.  (We
         * assume anything that's in a btree or hash opclass is at least
         * stable, but we need to check for immutability.)
         */
        if (op_volatile(saop_op) != PROVOLATILE_IMMUTABLE)
        {
            context->has_mutable_op = true;
 
            /*
             * When pruning in the planner, we cannot prune with mutable
             * operators.
             */
            if (context->target == PARTTARGET_PLANNER)
                return PARTCLAUSE_UNSUPPORTED;
        }
 
        /*
         * Examine the contents of the array argument.
         */
        elem_exprs = NIL;
        if (IsA(rightop, Const))
        {
            /*
             * For a constant array, convert the elements to a list of Const
             * nodes, one for each array element (excepting nulls).
             */
            Const      *arr = (Const *) rightop;
            ArrayType  *arrval;
            int16       elemlen;
            bool        elembyval;
            char        elemalign;
            Datum      *elem_values;
            bool       *elem_nulls;
            int         num_elems,
                        i;
 
            /* If the array itself is null, the saop returns null */
            if (arr->constisnull)
                return PARTCLAUSE_MATCH_CONTRADICT;
 
            arrval = DatumGetArrayTypeP(arr->constvalue);
            get_typlenbyvalalign(ARR_ELEMTYPE(arrval),
                                 &elemlen, &elembyval, &elemalign);
            deconstruct_array(arrval,
                              ARR_ELEMTYPE(arrval),
                              elemlen, elembyval, elemalign,
                              &elem_values, &elem_nulls,
                              &num_elems);
            for (i = 0; i < num_elems; i++)
            {
                Const      *elem_expr;
 
                /*
                 * A null array element must lead to a null comparison result,
                 * since saop_op is known strict.  We can ignore it in the
                 * useOr case, but otherwise it implies self-contradiction.
                 */
                if (elem_nulls[i])
                {
                    if (saop->useOr)
                        continue;
                    return PARTCLAUSE_MATCH_CONTRADICT;
                }
 
                elem_expr = makeConst(ARR_ELEMTYPE(arrval), -1,
                                      arr->constcollid, elemlen,
                                      elem_values[i], false, elembyval);
                elem_exprs = lappend(elem_exprs, elem_expr);
            }
        }
        else if (IsA(rightop, ArrayExpr))
        {
            ArrayExpr  *arrexpr = castNode(ArrayExpr, rightop);
 
            /*
             * For a nested ArrayExpr, we don't know how to get the actual
             * scalar values out into a flat list, so we give up doing
             * anything with this ScalarArrayOpExpr.
             */
            if (arrexpr->multidims)
                return PARTCLAUSE_UNSUPPORTED;
 
            /*
             * Otherwise, we can just use the list of element values.
             */
            elem_exprs = arrexpr->elements;
        }
        else
        {
            /* Give up on any other clause types. */
            return PARTCLAUSE_UNSUPPORTED;
        }
 
        /*
         * Now generate a list of clauses, one for each array element, of the
         * form leftop saop_op elem_expr
         */
        elem_clauses = NIL;
        foreach(lc1, elem_exprs)
        {
            Expr       *elem_clause;
 
            elem_clause = make_opclause(saop_op, BOOLOID, false,
                                        leftop, lfirst(lc1),
                                        InvalidOid, saop_coll);
            elem_clauses = lappend(elem_clauses, elem_clause);
        }
 
        /*
         * If we have an ANY clause and multiple elements, now turn the list
         * of clauses into an OR expression.
         */
        if (saop->useOr && list_length(elem_clauses) > 1)
            elem_clauses = list_make1(makeBoolExpr(OR_EXPR, elem_clauses, -1));
 
        /* Finally, generate steps */
        *clause_steps = gen_partprune_steps_internal(context, elem_clauses);
        if (context->contradictory)
            return PARTCLAUSE_MATCH_CONTRADICT;
        else if (*clause_steps == NIL)
            return PARTCLAUSE_UNSUPPORTED;  /* step generation failed */
        return PARTCLAUSE_MATCH_STEPS;
    }
    else if (IsA(clause, NullTest))
    {
        NullTest   *nulltest = (NullTest *) clause;
        Expr       *arg = nulltest->arg;
 
        if (IsA(arg, RelabelType))
            arg = ((RelabelType *) arg)->arg;
 
        /* Does arg match with this partition key column? */
        if (!equal(arg, partkey))
            return PARTCLAUSE_NOMATCH;
 
        *clause_is_not_null = (nulltest->nulltesttype == IS_NOT_NULL);
 
        return PARTCLAUSE_MATCH_NULLNESS;
    }
 
    /*
     * If we get here then the return value depends on the result of the
     * match_boolean_partition_clause call above.  If the call returned
     * PARTCLAUSE_UNSUPPORTED then we're either not dealing with a bool qual
     * or the bool qual is not suitable for pruning.  Since the qual didn't
     * match up to any of the other qual types supported here, then trying to
     * match it against any other partition key is a waste of time, so just
     * return PARTCLAUSE_UNSUPPORTED.  If the qual just couldn't be matched to
     * this partition key, then it may match another, so return
     * PARTCLAUSE_NOMATCH.  The only other value that
     * match_boolean_partition_clause can return is PARTCLAUSE_MATCH_CLAUSE,
     * and since that value was already dealt with above, then we can just
     * return boolmatchstatus.
     */
    return boolmatchstatus;
}

References arg, NullTest::arg, generate_unaccent_rules::args, ScalarArrayOpExpr::args, ARR_ELEMTYPE, Assert(), bms_is_empty, BTEqualStrategyNumber, BTORDER_PROC, castNode, PartClauseInfo::cmpfn, contain_var_clause(), contain_volatile_functions(), GeneratePruningStepsContext::contradictory, DatumGetArrayTypeP, deconstruct_array(), ArrayExpr::elements, elog(), equal(), ERROR, PartClauseInfo::expr, FmgrInfo::fn_oid, gen_partprune_steps_internal(), get_commutator(), get_leftop(), get_negator(), get_op_opfamily_properties(), get_opfamily_proc(), get_rightop(), get_typlenbyvalalign(), GeneratePruningStepsContext::has_exec_param, GeneratePruningStepsContext::has_mutable_arg, GeneratePruningStepsContext::has_mutable_op, HASHEXTENDED_PROC, i, InvalidOid, InvalidStrategy, IS_NOT_NULL, IsA, PartClauseInfo::keyno, lappend(), lfirst, linitial, list_length(), list_make1, lsecond, make_opclause(), makeBoolExpr(), makeConst(), match_boolean_partition_clause(), NIL, NullTest::nulltesttype, OidIsValid, op_in_opfamily(), PartClauseInfo::op_is_ne, PartClauseInfo::op_strategy, op_strict(), op_volatile(), PartClauseInfo::opno, OpExpr::opno, ScalarArrayOpExpr::opno, OR_EXPR, palloc(), PARTCLAUSE_MATCH_CLAUSE, PARTCLAUSE_MATCH_CONTRADICT, PARTCLAUSE_MATCH_NULLNESS, PARTCLAUSE_MATCH_STEPS, PARTCLAUSE_NOMATCH, PARTCLAUSE_UNSUPPORTED, PartitionSchemeData::partcollation, PartCollMatchesExprColl, PARTITION_STRATEGY_HASH, PARTITION_STRATEGY_LIST, PARTITION_STRATEGY_RANGE, PartitionSchemeData::partopcintype, PartitionSchemeData::partopfamily, PartitionSchemeData::partsupfunc, PARTTARGET_EXEC, PARTTARGET_PLANNER, pull_exec_paramids(), GeneratePruningStepsContext::rel, PartitionSchemeData::strategy, GeneratePruningStepsContext::target, and ScalarArrayOpExpr::useOr.

Referenced by gen_partprune_steps_internal().

partkey_datum_from_expr()

static void partkey_datum_from_expr ( PartitionPruneContext *  context, Expr *  expr, int  stateidx, Datum *  value, bool *  isnull  )

static

Definition at line 3682 of file partprune.c.

{
    if (IsA(expr, Const))
    {
        /* We can always determine the value of a constant */
        Const      *con = (Const *) expr;
 
        *value = con->constvalue;
        *isnull = con->constisnull;
    }
    else
    {
        ExprState  *exprstate;
        ExprContext *ectx;
 
        /*
         * We should never see a non-Const in a step unless the caller has
         * passed a valid ExprContext.
         *
         * When context->planstate is valid, context->exprcontext is same as
         * context->planstate->ps_ExprContext.
         */
        Assert(context->planstate != NULL || context->exprcontext != NULL);
        Assert(context->planstate == NULL ||
               (context->exprcontext == context->planstate->ps_ExprContext));
 
        exprstate = context->exprstates[stateidx];
        ectx = context->exprcontext;
        *value = ExecEvalExprSwitchContext(exprstate, ectx, isnull);
    }
}

References Assert(), ExecEvalExprSwitchContext(), PartitionPruneContext::exprcontext, PartitionPruneContext::exprstates, IsA, PartitionPruneContext::planstate, PlanState::ps_ExprContext, and value.

Referenced by perform_pruning_base_step().

perform_pruning_base_step()

static PruneStepResult * perform_pruning_base_step ( PartitionPruneContext *  context, PartitionPruneStepOp *  opstep  )

static

Definition at line 3338 of file partprune.c.

{
    ListCell   *lc1,
               *lc2;
    int         keyno,
                nvalues;
    Datum       values[PARTITION_MAX_KEYS];
    FmgrInfo   *partsupfunc;
    int         stateidx;
 
    /*
     * There better be the same number of expressions and compare functions.
     */
    Assert(list_length(opstep->exprs) == list_length(opstep->cmpfns));
 
    nvalues = 0;
    lc1 = list_head(opstep->exprs);
    lc2 = list_head(opstep->cmpfns);
 
    /*
     * Generate the partition lookup key that will be used by one of the
     * get_matching_*_bounds functions called below.
     */
    for (keyno = 0; keyno < context->partnatts; keyno++)
    {
        /*
         * For hash partitioning, it is possible that values of some keys are
         * not provided in operator clauses, but instead the planner found
         * that they appeared in a IS NULL clause.
         */
        if (bms_is_member(keyno, opstep->nullkeys))
            continue;
 
        /*
         * For range partitioning, we must only perform pruning with values
         * for either all partition keys or a prefix thereof.
         */
        if (keyno > nvalues && context->strategy == PARTITION_STRATEGY_RANGE)
            break;
 
        if (lc1 != NULL)
        {
            Expr       *expr;
            Datum       datum;
            bool        isnull;
            Oid         cmpfn;
 
            expr = lfirst(lc1);
            stateidx = PruneCxtStateIdx(context->partnatts,
                                        opstep->step.step_id, keyno);
            partkey_datum_from_expr(context, expr, stateidx,
                                    &datum, &isnull);
 
            /*
             * Since we only allow strict operators in pruning steps, any
             * null-valued comparison value must cause the comparison to fail,
             * so that no partitions could match.
             */
            if (isnull)
            {
                PruneStepResult *result;
 
                result = (PruneStepResult *) palloc(sizeof(PruneStepResult));
                result->bound_offsets = NULL;
                result->scan_default = false;
                result->scan_null = false;
 
                return result;
            }
 
            /* Set up the stepcmpfuncs entry, unless we already did */
            cmpfn = lfirst_oid(lc2);
            Assert(OidIsValid(cmpfn));
            if (cmpfn != context->stepcmpfuncs[stateidx].fn_oid)
            {
                /*
                 * If the needed support function is the same one cached in
                 * the relation's partition key, copy the cached FmgrInfo.
                 * Otherwise (i.e., when we have a cross-type comparison), an
                 * actual lookup is required.
                 */
                if (cmpfn == context->partsupfunc[keyno].fn_oid)
                    fmgr_info_copy(&context->stepcmpfuncs[stateidx],
                                   &context->partsupfunc[keyno],
                                   context->ppccontext);
                else
                    fmgr_info_cxt(cmpfn, &context->stepcmpfuncs[stateidx],
                                  context->ppccontext);
            }
 
            values[keyno] = datum;
            nvalues++;
 
            lc1 = lnext(opstep->exprs, lc1);
            lc2 = lnext(opstep->cmpfns, lc2);
        }
    }
 
    /*
     * Point partsupfunc to the entry for the 0th key of this step; the
     * additional support functions, if any, follow consecutively.
     */
    stateidx = PruneCxtStateIdx(context->partnatts, opstep->step.step_id, 0);
    partsupfunc = &context->stepcmpfuncs[stateidx];
 
    switch (context->strategy)
    {
        case PARTITION_STRATEGY_HASH:
            return get_matching_hash_bounds(context,
                                            opstep->opstrategy,
                                            values, nvalues,
                                            partsupfunc,
                                            opstep->nullkeys);
 
        case PARTITION_STRATEGY_LIST:
            return get_matching_list_bounds(context,
                                            opstep->opstrategy,
                                            values[0], nvalues,
                                            &partsupfunc[0],
                                            opstep->nullkeys);
 
        case PARTITION_STRATEGY_RANGE:
            return get_matching_range_bounds(context,
                                             opstep->opstrategy,
                                             values, nvalues,
                                             partsupfunc,
                                             opstep->nullkeys);
 
        default:
            elog(ERROR, "unexpected partition strategy: %d",
                 (int) context->strategy);
            break;
    }
 
    return NULL;
}

References Assert(), bms_is_member(), PruneStepResult::bound_offsets, PartitionPruneStepOp::cmpfns, elog(), ERROR, PartitionPruneStepOp::exprs, fmgr_info_copy(), fmgr_info_cxt(), FmgrInfo::fn_oid, get_matching_hash_bounds(), get_matching_list_bounds(), get_matching_range_bounds(), lfirst, lfirst_oid, list_head(), list_length(), lnext(), PartitionPruneStepOp::nullkeys, OidIsValid, PartitionPruneStepOp::opstrategy, palloc(), PARTITION_MAX_KEYS, PARTITION_STRATEGY_HASH, PARTITION_STRATEGY_LIST, PARTITION_STRATEGY_RANGE, partkey_datum_from_expr(), PartitionPruneContext::partnatts, PartitionPruneContext::partsupfunc, PartitionPruneContext::ppccontext, PruneCxtStateIdx, PruneStepResult::scan_default, PruneStepResult::scan_null, PartitionPruneStepOp::step, PartitionPruneStep::step_id, PartitionPruneContext::stepcmpfuncs, PartitionPruneContext::strategy, and values.

Referenced by get_matching_partitions().

perform_pruning_combine_step()

static PruneStepResult * perform_pruning_combine_step ( PartitionPruneContext *  context, PartitionPruneStepCombine *  cstep, PruneStepResult **  step_results  )

static

Definition at line 3486 of file partprune.c.

{
    PruneStepResult *result = (PruneStepResult *) palloc0(sizeof(PruneStepResult));
    bool        firststep;
    ListCell   *lc1;
 
    /*
     * A combine step without any source steps is an indication to not perform
     * any partition pruning.  Return all datum indexes in that case.
     */
    if (cstep->source_stepids == NIL)
    {
        PartitionBoundInfo boundinfo = context->boundinfo;
 
        result->bound_offsets =
            bms_add_range(NULL, 0, boundinfo->nindexes - 1);
        result->scan_default = partition_bound_has_default(boundinfo);
        result->scan_null = partition_bound_accepts_nulls(boundinfo);
        return result;
    }
 
    switch (cstep->combineOp)
    {
        case PARTPRUNE_COMBINE_UNION:
            foreach(lc1, cstep->source_stepids)
            {
                int         step_id = lfirst_int(lc1);
                PruneStepResult *step_result;
 
                /*
                 * step_results[step_id] must contain a valid result, which is
                 * confirmed by the fact that cstep's step_id is greater than
                 * step_id and the fact that results of the individual steps
                 * are evaluated in sequence of their step_ids.
                 */
                if (step_id >= cstep->step.step_id)
                    elog(ERROR, "invalid pruning combine step argument");
                step_result = step_results[step_id];
                Assert(step_result != NULL);
 
                /* Record any additional datum indexes from this step */
                result->bound_offsets = bms_add_members(result->bound_offsets,
                                                        step_result->bound_offsets);
 
                /* Update whether to scan null and default partitions. */
                if (!result->scan_null)
                    result->scan_null = step_result->scan_null;
                if (!result->scan_default)
                    result->scan_default = step_result->scan_default;
            }
            break;
 
        case PARTPRUNE_COMBINE_INTERSECT:
            firststep = true;
            foreach(lc1, cstep->source_stepids)
            {
                int         step_id = lfirst_int(lc1);
                PruneStepResult *step_result;
 
                if (step_id >= cstep->step.step_id)
                    elog(ERROR, "invalid pruning combine step argument");
                step_result = step_results[step_id];
                Assert(step_result != NULL);
 
                if (firststep)
                {
                    /* Copy step's result the first time. */
                    result->bound_offsets =
                        bms_copy(step_result->bound_offsets);
                    result->scan_null = step_result->scan_null;
                    result->scan_default = step_result->scan_default;
                    firststep = false;
                }
                else
                {
                    /* Record datum indexes common to both steps */
                    result->bound_offsets =
                        bms_int_members(result->bound_offsets,
                                        step_result->bound_offsets);
 
                    /* Update whether to scan null and default partitions. */
                    if (result->scan_null)
                        result->scan_null = step_result->scan_null;
                    if (result->scan_default)
                        result->scan_default = step_result->scan_default;
                }
            }
            break;
    }
 
    return result;
}

References Assert(), bms_add_members(), bms_add_range(), bms_copy(), bms_int_members(), PruneStepResult::bound_offsets, PartitionPruneContext::boundinfo, PartitionPruneStepCombine::combineOp, elog(), ERROR, lfirst_int, NIL, PartitionBoundInfoData::nindexes, palloc0(), partition_bound_accepts_nulls, partition_bound_has_default, PARTPRUNE_COMBINE_INTERSECT, PARTPRUNE_COMBINE_UNION, PruneStepResult::scan_default, PruneStepResult::scan_null, PartitionPruneStepCombine::source_stepids, PartitionPruneStepCombine::step, and PartitionPruneStep::step_id.

Referenced by get_matching_partitions().

prune_append_rel_partitions()

Bitmapset* prune_append_rel_partitions

(

RelOptInfo *

rel

)

Definition at line 753 of file partprune.c.

{
    List       *clauses = rel->baserestrictinfo;
    List       *pruning_steps;
    GeneratePruningStepsContext gcontext;
    PartitionPruneContext context;
 
    Assert(rel->part_scheme != NULL);
 
    /* If there are no partitions, return the empty set */
    if (rel->nparts == 0)
        return NULL;
 
    /*
     * If pruning is disabled or if there are no clauses to prune with, return
     * all partitions.
     */
    if (!enable_partition_pruning || clauses == NIL)
        return bms_add_range(NULL, 0, rel->nparts - 1);
 
    /*
     * Process clauses to extract pruning steps that are usable at plan time.
     * If the clauses are found to be contradictory, we can return the empty
     * set.
     */
    gen_partprune_steps(rel, clauses, PARTTARGET_PLANNER,
                        &gcontext);
    if (gcontext.contradictory)
        return NULL;
    pruning_steps = gcontext.steps;
 
    /* If there's nothing usable, return all partitions */
    if (pruning_steps == NIL)
        return bms_add_range(NULL, 0, rel->nparts - 1);
 
    /* Set up PartitionPruneContext */
    context.strategy = rel->part_scheme->strategy;
    context.partnatts = rel->part_scheme->partnatts;
    context.nparts = rel->nparts;
    context.boundinfo = rel->boundinfo;
    context.partcollation = rel->part_scheme->partcollation;
    context.partsupfunc = rel->part_scheme->partsupfunc;
    context.stepcmpfuncs = (FmgrInfo *) palloc0(sizeof(FmgrInfo) *
                                                context.partnatts *
                                                list_length(pruning_steps));
    context.ppccontext = CurrentMemoryContext;
 
    /* These are not valid when being called from the planner */
    context.planstate = NULL;
    context.exprcontext = NULL;
    context.exprstates = NULL;
 
    /* Actual pruning happens here. */
    return get_matching_partitions(&context, pruning_steps);
}

References Assert(), RelOptInfo::baserestrictinfo, bms_add_range(), PartitionPruneContext::boundinfo, GeneratePruningStepsContext::contradictory, CurrentMemoryContext, enable_partition_pruning, PartitionPruneContext::exprcontext, PartitionPruneContext::exprstates, gen_partprune_steps(), get_matching_partitions(), list_length(), NIL, RelOptInfo::nparts, PartitionPruneContext::nparts, palloc0(), PartitionPruneContext::partcollation, PartitionPruneContext::partnatts, PartitionPruneContext::partsupfunc, PARTTARGET_PLANNER, PartitionPruneContext::planstate, PartitionPruneContext::ppccontext, PartitionPruneContext::stepcmpfuncs, GeneratePruningStepsContext::steps, and PartitionPruneContext::strategy.

Referenced by expand_partitioned_rtentry().

pull_exec_paramids()

static Bitmapset * pull_exec_paramids ( Expr *  expr )

static

Definition at line 3268 of file partprune.c.

{
    Bitmapset  *result = NULL;
 
    (void) pull_exec_paramids_walker((Node *) expr, &result);
 
    return result;
}

References pull_exec_paramids_walker().

Referenced by get_partkey_exec_paramids(), and match_clause_to_partition_key().

pull_exec_paramids_walker()

static bool pull_exec_paramids_walker ( Node *  node, Bitmapset **  context  )

static

Definition at line 3278 of file partprune.c.

{
    if (node == NULL)
        return false;
    if (IsA(node, Param))
    {
        Param      *param = (Param *) node;
 
        if (param->paramkind == PARAM_EXEC)
            *context = bms_add_member(*context, param->paramid);
        return false;
    }
    return expression_tree_walker(node, pull_exec_paramids_walker,
                                  (void *) context);
}

References bms_add_member(), expression_tree_walker, IsA, PARAM_EXEC, Param::paramid, and Param::paramkind.

Referenced by pull_exec_paramids().