_int_selfuncs.c File Reference

#include "postgres.h"
#include "_int.h"
#include "access/htup_details.h"
#include "catalog/pg_operator.h"
#include "catalog/pg_statistic.h"
#include "catalog/pg_type.h"
#include "miscadmin.h"
#include "utils/fmgrprotos.h"
#include "utils/lsyscache.h"
#include "utils/selfuncs.h"

Include dependency graph for _int_selfuncs.c:

Go to the source code of this file.

Functions
	PG_FUNCTION_INFO_V1 (_int_overlap_sel)
	PG_FUNCTION_INFO_V1 (_int_contains_sel)
	PG_FUNCTION_INFO_V1 (_int_contained_sel)
	PG_FUNCTION_INFO_V1 (_int_overlap_joinsel)
	PG_FUNCTION_INFO_V1 (_int_contains_joinsel)
	PG_FUNCTION_INFO_V1 (_int_contained_joinsel)
	PG_FUNCTION_INFO_V1 (_int_matchsel)
static Selectivity	int_query_opr_selec (ITEM *item, Datum *mcelems, float4 *mcefreqs, int nmcelems, float4 minfreq)
static int	compare_val_int4 (const void *a, const void *b)
Datum	_int_overlap_sel (PG_FUNCTION_ARGS)
Datum	_int_contains_sel (PG_FUNCTION_ARGS)
Datum	_int_contained_sel (PG_FUNCTION_ARGS)
Datum	_int_overlap_joinsel (PG_FUNCTION_ARGS)
Datum	_int_contains_joinsel (PG_FUNCTION_ARGS)
Datum	_int_contained_joinsel (PG_FUNCTION_ARGS)
Datum	_int_matchsel (PG_FUNCTION_ARGS)

Function Documentation

_int_contained_joinsel()

Datum _int_contained_joinsel

(

PG_FUNCTION_ARGS

)

Definition at line 107 of file _int_selfuncs.c.

{
    PG_RETURN_DATUM(DirectFunctionCall5(arraycontjoinsel,
                                        PG_GETARG_DATUM(0),
                                        ObjectIdGetDatum(OID_ARRAY_CONTAINED_OP),
                                        PG_GETARG_DATUM(2),
                                        PG_GETARG_DATUM(3),
                                        PG_GETARG_DATUM(4)));
}

References arraycontjoinsel(), DirectFunctionCall5, fb(), ObjectIdGetDatum(), PG_GETARG_DATUM, and PG_RETURN_DATUM.

_int_contained_sel()

Datum _int_contained_sel

(

PG_FUNCTION_ARGS

)

Definition at line 75 of file _int_selfuncs.c.

{
    PG_RETURN_DATUM(DirectFunctionCall4(arraycontsel,
                                        PG_GETARG_DATUM(0),
                                        ObjectIdGetDatum(OID_ARRAY_CONTAINED_OP),
                                        PG_GETARG_DATUM(2),
                                        PG_GETARG_DATUM(3)));
}

References arraycontsel(), DirectFunctionCall4, fb(), ObjectIdGetDatum(), PG_GETARG_DATUM, and PG_RETURN_DATUM.

_int_contains_joinsel()

Datum _int_contains_joinsel

(

PG_FUNCTION_ARGS

)

Definition at line 96 of file _int_selfuncs.c.

{
    PG_RETURN_DATUM(DirectFunctionCall5(arraycontjoinsel,
                                        PG_GETARG_DATUM(0),
                                        ObjectIdGetDatum(OID_ARRAY_CONTAINS_OP),
                                        PG_GETARG_DATUM(2),
                                        PG_GETARG_DATUM(3),
                                        PG_GETARG_DATUM(4)));
}

References arraycontjoinsel(), DirectFunctionCall5, fb(), ObjectIdGetDatum(), PG_GETARG_DATUM, and PG_RETURN_DATUM.

_int_contains_sel()

Datum _int_contains_sel

(

PG_FUNCTION_ARGS

)

Definition at line 65 of file _int_selfuncs.c.

{
    PG_RETURN_DATUM(DirectFunctionCall4(arraycontsel,
                                        PG_GETARG_DATUM(0),
                                        ObjectIdGetDatum(OID_ARRAY_CONTAINS_OP),
                                        PG_GETARG_DATUM(2),
                                        PG_GETARG_DATUM(3)));
}

References arraycontsel(), DirectFunctionCall4, fb(), ObjectIdGetDatum(), PG_GETARG_DATUM, and PG_RETURN_DATUM.

_int_matchsel()

Datum _int_matchsel

(

PG_FUNCTION_ARGS

)

Definition at line 122 of file _int_selfuncs.c.

{
    PlannerInfo *root = (PlannerInfo *) PG_GETARG_POINTER(0);
 
    List       *args = (List *) PG_GETARG_POINTER(2);
    int         varRelid = PG_GETARG_INT32(3);
    VariableStatData vardata;
    Node       *other;
    bool        varonleft;
    Selectivity selec;
    QUERYTYPE  *query;
    Datum      *mcelems = NULL;
    float4     *mcefreqs = NULL;
    int         nmcelems = 0;
    float4      minfreq = 0.0;
    float4      nullfrac = 0.0;
    AttStatsSlot sslot;
 
    /*
     * If expression is not "variable @@ something" or "something @@ variable"
     * then punt and return a default estimate.
     */
    if (!get_restriction_variable(root, args, varRelid,
                                  &vardata, &other, &varonleft))
        PG_RETURN_FLOAT8(DEFAULT_EQ_SEL);
 
    /*
     * Variable should be int[]. We don't support cases where variable is
     * query_int.
     */
    if (vardata.vartype != INT4ARRAYOID)
        PG_RETURN_FLOAT8(DEFAULT_EQ_SEL);
 
    /*
     * Can't do anything useful if the something is not a constant, either.
     */
    if (!IsA(other, Const))
    {
        ReleaseVariableStats(vardata);
        PG_RETURN_FLOAT8(DEFAULT_EQ_SEL);
    }
 
    /*
     * The "@@" operator is strict, so we can cope with NULL right away.
     */
    if (((Const *) other)->constisnull)
    {
        ReleaseVariableStats(vardata);
        PG_RETURN_FLOAT8(0.0);
    }
 
    /* The caller made sure the const is a query, so get it now */
    query = DatumGetQueryTypeP(((Const *) other)->constvalue);
 
    /* Empty query matches nothing */
    if (query->size == 0)
    {
        ReleaseVariableStats(vardata);
        PG_RETURN_FLOAT8(0.0);
    }
 
    /*
     * Get the statistics for the intarray column.
     *
     * We're interested in the Most-Common-Elements list, and the NULL
     * fraction.
     */
    if (HeapTupleIsValid(vardata.statsTuple))
    {
        Form_pg_statistic stats;
 
        stats = (Form_pg_statistic) GETSTRUCT(vardata.statsTuple);
        nullfrac = stats->stanullfrac;
 
        /*
         * For an int4 array, the default array type analyze function will
         * collect a Most Common Elements list, which is an array of int4s.
         */
        if (get_attstatsslot(&sslot, vardata.statsTuple,
                             STATISTIC_KIND_MCELEM, InvalidOid,
                             ATTSTATSSLOT_VALUES | ATTSTATSSLOT_NUMBERS))
        {
            Assert(sslot.valuetype == INT4OID);
 
            /*
             * There should be three more Numbers than Values, because the
             * last three (for intarray) cells are taken for minimal, maximal
             * and nulls frequency. Punt if not.
             */
            if (sslot.nnumbers == sslot.nvalues + 3)
            {
                /* Grab the minimal MCE frequency. */
                minfreq = sslot.numbers[sslot.nvalues];
 
                mcelems = sslot.values;
                mcefreqs = sslot.numbers;
                nmcelems = sslot.nvalues;
            }
        }
    }
    else
        memset(&sslot, 0, sizeof(sslot));
 
    /* Process the logical expression in the query, using the stats */
    selec = int_query_opr_selec(GETQUERY(query) + query->size - 1,
                                mcelems, mcefreqs, nmcelems, minfreq);
 
    /* MCE stats count only non-null rows, so adjust for null rows. */
    selec *= (1.0 - nullfrac);
 
    free_attstatsslot(&sslot);
    ReleaseVariableStats(vardata);
 
    CLAMP_PROBABILITY(selec);
 
    PG_RETURN_FLOAT8((float8) selec);
}

References Assert, ATTSTATSSLOT_NUMBERS, ATTSTATSSLOT_VALUES, CLAMP_PROBABILITY, DatumGetQueryTypeP, DEFAULT_EQ_SEL, fb(), free_attstatsslot(), get_attstatsslot(), get_restriction_variable(), GETQUERY, GETSTRUCT(), HeapTupleIsValid, int_query_opr_selec(), InvalidOid, IsA, PG_GETARG_INT32, PG_GETARG_POINTER, PG_RETURN_FLOAT8, ReleaseVariableStats, root, and QUERYTYPE::size.

_int_overlap_joinsel()

Datum _int_overlap_joinsel

(

PG_FUNCTION_ARGS

)

Definition at line 85 of file _int_selfuncs.c.

{
    PG_RETURN_DATUM(DirectFunctionCall5(arraycontjoinsel,
                                        PG_GETARG_DATUM(0),
                                        ObjectIdGetDatum(OID_ARRAY_OVERLAP_OP),
                                        PG_GETARG_DATUM(2),
                                        PG_GETARG_DATUM(3),
                                        PG_GETARG_DATUM(4)));
}

References arraycontjoinsel(), DirectFunctionCall5, fb(), ObjectIdGetDatum(), PG_GETARG_DATUM, and PG_RETURN_DATUM.

_int_overlap_sel()

Datum _int_overlap_sel

(

PG_FUNCTION_ARGS

)

Definition at line 55 of file _int_selfuncs.c.

{
    PG_RETURN_DATUM(DirectFunctionCall4(arraycontsel,
                                        PG_GETARG_DATUM(0),
                                        ObjectIdGetDatum(OID_ARRAY_OVERLAP_OP),
                                        PG_GETARG_DATUM(2),
                                        PG_GETARG_DATUM(3)));
}

References arraycontsel(), DirectFunctionCall4, fb(), ObjectIdGetDatum(), PG_GETARG_DATUM, and PG_RETURN_DATUM.

compare_val_int4()

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

static

Definition at line 329 of file _int_selfuncs.c.

{
    int32       key = *(const int32 *) a;
    int32       value = DatumGetInt32(*(const Datum *) b);
 
    if (key < value)
        return -1;
    else if (key > value)
        return 1;
    else
        return 0;
}

References a, b, DatumGetInt32(), and value.

Referenced by int_query_opr_selec().

int_query_opr_selec()

static Selectivity int_query_opr_selec ( ITEM *  item, Datum *  mcelems, float4 *  mcefreqs, int  nmcelems, float4  minfreq  )

static

Definition at line 244 of file _int_selfuncs.c.

{
    Selectivity selec;
 
    /* since this function recurses, it could be driven to stack overflow */
    check_stack_depth();
 
    if (item->type == VAL)
    {
        Datum      *searchres;
 
        if (mcelems == NULL)
            return (Selectivity) DEFAULT_EQ_SEL;
 
        searchres = (Datum *) bsearch(&item->val, mcelems, nmcelems,
                                      sizeof(Datum), compare_val_int4);
        if (searchres)
        {
            /*
             * The element is in MCELEM.  Return precise selectivity (or at
             * least as precise as ANALYZE could find out).
             */
            selec = mcefreqs[searchres - mcelems];
        }
        else
        {
            /*
             * The element is not in MCELEM.  Estimate its frequency as half
             * that of the least-frequent MCE.  (We know it cannot be more
             * than minfreq, and it could be a great deal less.  Half seems
             * like a good compromise.)  For probably-historical reasons,
             * clamp to not more than DEFAULT_EQ_SEL.
             */
            selec = Min(DEFAULT_EQ_SEL, minfreq / 2);
        }
    }
    else if (item->type == OPR)
    {
        /* Current query node is an operator */
        Selectivity s1,
                    s2;
 
        s1 = int_query_opr_selec(item - 1, mcelems, mcefreqs, nmcelems,
                                 minfreq);
        switch (item->val)
        {
            case (int32) '!':
                selec = 1.0 - s1;
                break;
 
            case (int32) '&':
                s2 = int_query_opr_selec(item + item->left, mcelems, mcefreqs,
                                         nmcelems, minfreq);
                selec = s1 * s2;
                break;
 
            case (int32) '|':
                s2 = int_query_opr_selec(item + item->left, mcelems, mcefreqs,
                                         nmcelems, minfreq);
                selec = s1 + s2 - s1 * s2;
                break;
 
            default:
                elog(ERROR, "unrecognized operator: %d", item->val);
                selec = 0;      /* keep compiler quiet */
                break;
        }
    }
    else
    {
        elog(ERROR, "unrecognized int query item type: %u", item->type);
        selec = 0;              /* keep compiler quiet */
    }
 
    /* Clamp intermediate results to stay sane despite roundoff error */
    CLAMP_PROBABILITY(selec);
 
    return selec;
}

References check_stack_depth(), CLAMP_PROBABILITY, compare_val_int4(), DEFAULT_EQ_SEL, elog, ERROR, fb(), int_query_opr_selec(), ITEM::left, Min, OPR, s1, s2, ITEM::type, ITEM::val, and VAL.

Referenced by _int_matchsel(), and int_query_opr_selec().

PG_FUNCTION_INFO_V1() [1/7]

PG_FUNCTION_INFO_V1

(

_int_contained_joinsel

)

PG_FUNCTION_INFO_V1() [2/7]

PG_FUNCTION_INFO_V1

(

_int_contained_sel

)

PG_FUNCTION_INFO_V1() [3/7]

PG_FUNCTION_INFO_V1

(

_int_contains_joinsel

)

PG_FUNCTION_INFO_V1() [4/7]

PG_FUNCTION_INFO_V1

(

_int_contains_sel

)

PG_FUNCTION_INFO_V1() [5/7]

PG_FUNCTION_INFO_V1

(

_int_matchsel

)

PG_FUNCTION_INFO_V1() [6/7]

PG_FUNCTION_INFO_V1

(

_int_overlap_joinsel

)

PG_FUNCTION_INFO_V1() [7/7]

PG_FUNCTION_INFO_V1

(

_int_overlap_sel

)