attribute_stats.c File Reference

#include "postgres.h"
#include "access/heapam.h"
#include "catalog/indexing.h"
#include "catalog/namespace.h"
#include "catalog/pg_operator.h"
#include "nodes/makefuncs.h"
#include "statistics/statistics.h"
#include "statistics/stat_utils.h"
#include "utils/array.h"
#include "utils/builtins.h"
#include "utils/fmgroids.h"
#include "utils/lsyscache.h"
#include "utils/syscache.h"

Include dependency graph for attribute_stats.c:

Go to the source code of this file.

Enumerations
enum	attribute_stats_argnum {   ATTRELSCHEMA_ARG = 0 , ATTRELNAME_ARG , ATTNAME_ARG , ATTNUM_ARG ,   INHERITED_ARG , NULL_FRAC_ARG , AVG_WIDTH_ARG , N_DISTINCT_ARG ,   MOST_COMMON_VALS_ARG , MOST_COMMON_FREQS_ARG , HISTOGRAM_BOUNDS_ARG , CORRELATION_ARG ,   MOST_COMMON_ELEMS_ARG , MOST_COMMON_ELEM_FREQS_ARG , ELEM_COUNT_HISTOGRAM_ARG , RANGE_LENGTH_HISTOGRAM_ARG ,   RANGE_EMPTY_FRAC_ARG , RANGE_BOUNDS_HISTOGRAM_ARG , NUM_ATTRIBUTE_STATS_ARGS }
enum	clear_attribute_stats_argnum {   C_ATTRELSCHEMA_ARG = 0 , C_ATTRELNAME_ARG , C_ATTNAME_ARG , C_INHERITED_ARG ,   C_NUM_ATTRIBUTE_STATS_ARGS }

Functions
static bool	attribute_statistics_update (FunctionCallInfo fcinfo)
static bool	attribute_statistics_update_internal (Oid reloid, const char *attname, AttrNumber attnum, bool inherited, FunctionCallInfo fcinfo)
static void	upsert_pg_statistic (Relation starel, HeapTuple oldtup, const Datum *values, const bool *nulls, const bool *replaces)
static bool	delete_pg_statistic (Oid reloid, AttrNumber attnum, bool stainherit)
Datum	pg_clear_attribute_stats (PG_FUNCTION_ARGS)
Datum	pg_restore_attribute_stats (PG_FUNCTION_ARGS)
bool	import_attribute_statistics (Relation rel, AttrNumber attnum, bool inherited, const NullableDatum *version, const NullableDatum *null_frac, const NullableDatum *avg_width, const NullableDatum *n_distinct, const NullableDatum *most_common_vals, const NullableDatum *most_common_freqs, const NullableDatum *histogram_bounds, const NullableDatum *correlation, const NullableDatum *most_common_elems, const NullableDatum *most_common_elem_freqs, const NullableDatum *elem_count_histogram, const NullableDatum *range_length_histogram, const NullableDatum *range_empty_frac, const NullableDatum *range_bounds_histogram)
bool	delete_attribute_statistics (Relation rel, AttrNumber attnum, bool inherited)

Variables
static struct StatsArgInfo	attarginfo []
static struct StatsArgInfo	cleararginfo []

Enumeration Type Documentation

attribute_stats_argnum

enum attribute_stats_argnum

Enumerator
ATTRELSCHEMA_ARG
ATTRELNAME_ARG
ATTNAME_ARG
ATTNUM_ARG
INHERITED_ARG
NULL_FRAC_ARG
AVG_WIDTH_ARG
N_DISTINCT_ARG
MOST_COMMON_VALS_ARG
MOST_COMMON_FREQS_ARG
HISTOGRAM_BOUNDS_ARG
CORRELATION_ARG
MOST_COMMON_ELEMS_ARG
MOST_COMMON_ELEM_FREQS_ARG
ELEM_COUNT_HISTOGRAM_ARG
RANGE_LENGTH_HISTOGRAM_ARG
RANGE_EMPTY_FRAC_ARG
RANGE_BOUNDS_HISTOGRAM_ARG
NUM_ATTRIBUTE_STATS_ARGS

Definition at line 38 of file attribute_stats.c.

{
    ATTRELSCHEMA_ARG = 0,
    ATTRELNAME_ARG,
    ATTNAME_ARG,
    ATTNUM_ARG,
    INHERITED_ARG,
    NULL_FRAC_ARG,
    AVG_WIDTH_ARG,
    N_DISTINCT_ARG,
    MOST_COMMON_VALS_ARG,
    MOST_COMMON_FREQS_ARG,
    HISTOGRAM_BOUNDS_ARG,
    CORRELATION_ARG,
    MOST_COMMON_ELEMS_ARG,
    MOST_COMMON_ELEM_FREQS_ARG,
    ELEM_COUNT_HISTOGRAM_ARG,
    RANGE_LENGTH_HISTOGRAM_ARG,
    RANGE_EMPTY_FRAC_ARG,
    RANGE_BOUNDS_HISTOGRAM_ARG,
    NUM_ATTRIBUTE_STATS_ARGS
};

clear_attribute_stats_argnum

enum clear_attribute_stats_argnum

Enumerator
C_ATTRELSCHEMA_ARG
C_ATTRELNAME_ARG
C_ATTNAME_ARG
C_INHERITED_ARG
C_NUM_ATTRIBUTE_STATS_ARGS

Definition at line 89 of file attribute_stats.c.

{
    C_ATTRELSCHEMA_ARG = 0,
    C_ATTRELNAME_ARG,
    C_ATTNAME_ARG,
    C_INHERITED_ARG,
    C_NUM_ATTRIBUTE_STATS_ARGS
};

Function Documentation

attribute_statistics_update()

static bool attribute_statistics_update ( FunctionCallInfo  fcinfo )

static

Definition at line 134 of file attribute_stats.c.

{
    char       *nspname;
    char       *relname;
    Oid         reloid;
    char       *attname;
    AttrNumber  attnum;
    bool        inherited;
    Oid         locked_table = InvalidOid;
 
    stats_check_required_arg(fcinfo, attarginfo, ATTRELSCHEMA_ARG);
    stats_check_required_arg(fcinfo, attarginfo, ATTRELNAME_ARG);
 
    nspname = TextDatumGetCString(PG_GETARG_DATUM(ATTRELSCHEMA_ARG));
    relname = TextDatumGetCString(PG_GETARG_DATUM(ATTRELNAME_ARG));
 
    if (RecoveryInProgress())
        ereport(ERROR,
                (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
                 errmsg("recovery is in progress"),
                 errhint("Statistics cannot be modified during recovery.")));
 
    /* lock before looking up attribute */
    reloid = RangeVarGetRelidExtended(makeRangeVar(nspname, relname, -1),
                                      ShareUpdateExclusiveLock, 0,
                                      RangeVarCallbackForStats, &locked_table);
 
    /* user can specify either attname or attnum, but not both */
    if (!PG_ARGISNULL(ATTNAME_ARG))
    {
        if (!PG_ARGISNULL(ATTNUM_ARG))
            ereport(ERROR,
                    (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
                     errmsg("cannot specify both \"%s\" and \"%s\"", "attname", "attnum")));
        attname = TextDatumGetCString(PG_GETARG_DATUM(ATTNAME_ARG));
        attnum = get_attnum(reloid, attname);
        /* note that this test covers attisdropped cases too: */
        if (attnum == InvalidAttrNumber)
            ereport(ERROR,
                    (errcode(ERRCODE_UNDEFINED_COLUMN),
                     errmsg("column \"%s\" of relation \"%s\" does not exist",
                            attname, relname)));
    }
    else if (!PG_ARGISNULL(ATTNUM_ARG))
    {
        attnum = PG_GETARG_INT16(ATTNUM_ARG);
        attname = get_attname(reloid, attnum, true);
        /* annoyingly, get_attname doesn't check attisdropped */
        if (attname == NULL ||
            !SearchSysCacheExistsAttName(reloid, attname))
            ereport(ERROR,
                    (errcode(ERRCODE_UNDEFINED_COLUMN),
                     errmsg("column %d of relation \"%s\" does not exist",
                            attnum, relname)));
    }
    else
    {
        ereport(ERROR,
                (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
                 errmsg("must specify either \"%s\" or \"%s\"", "attname", "attnum")));
        attname = NULL;         /* keep compiler quiet */
        attnum = 0;
    }
 
    if (attnum < 0)
        ereport(ERROR,
                (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
                 errmsg("cannot modify statistics on system column \"%s\"",
                        attname)));
 
    stats_check_required_arg(fcinfo, attarginfo, INHERITED_ARG);
    inherited = PG_GETARG_BOOL(INHERITED_ARG);
 
    return attribute_statistics_update_internal(reloid, attname, attnum,
                                                inherited, fcinfo);
}

References attarginfo, attname, ATTNAME_ARG, attnum, ATTNUM_ARG, ATTRELNAME_ARG, ATTRELSCHEMA_ARG, attribute_statistics_update_internal(), ereport, errcode(), errhint(), errmsg, ERROR, fb(), get_attname(), get_attnum(), INHERITED_ARG, InvalidAttrNumber, InvalidOid, makeRangeVar(), PG_ARGISNULL, PG_GETARG_BOOL, PG_GETARG_DATUM, PG_GETARG_INT16, RangeVarCallbackForStats(), RangeVarGetRelidExtended(), RecoveryInProgress(), relname, SearchSysCacheExistsAttName(), ShareUpdateExclusiveLock, stats_check_required_arg(), and TextDatumGetCString.

Referenced by pg_restore_attribute_stats().

attribute_statistics_update_internal()

static bool attribute_statistics_update_internal ( Oid  reloid, const char *  attname, AttrNumber  attnum, bool  inherited, FunctionCallInfo  fcinfo  )

static

Definition at line 215 of file attribute_stats.c.

{
    Relation    starel;
    HeapTuple   statup;
 
    Oid         atttypid = InvalidOid;
    int32       atttypmod;
    char        atttyptype;
    Oid         atttypcoll = InvalidOid;
    Oid         eq_opr = InvalidOid;
    Oid         lt_opr = InvalidOid;
 
    Oid         elemtypid = InvalidOid;
    Oid         elem_eq_opr = InvalidOid;
 
    FmgrInfo    array_in_fn;
 
    bool        do_mcv = !PG_ARGISNULL(MOST_COMMON_FREQS_ARG) &&
        !PG_ARGISNULL(MOST_COMMON_VALS_ARG);
    bool        do_histogram = !PG_ARGISNULL(HISTOGRAM_BOUNDS_ARG);
    bool        do_correlation = !PG_ARGISNULL(CORRELATION_ARG);
    bool        do_mcelem = !PG_ARGISNULL(MOST_COMMON_ELEMS_ARG) &&
        !PG_ARGISNULL(MOST_COMMON_ELEM_FREQS_ARG);
    bool        do_dechist = !PG_ARGISNULL(ELEM_COUNT_HISTOGRAM_ARG);
    bool        do_bounds_histogram = !PG_ARGISNULL(RANGE_BOUNDS_HISTOGRAM_ARG);
    bool        do_range_length_histogram = !PG_ARGISNULL(RANGE_LENGTH_HISTOGRAM_ARG) &&
        !PG_ARGISNULL(RANGE_EMPTY_FRAC_ARG);
 
    Datum       values[Natts_pg_statistic] = {0};
    bool        nulls[Natts_pg_statistic] = {0};
    bool        replaces[Natts_pg_statistic] = {0};
 
    bool        result = true;
 
    /*
     * Check argument sanity. If some arguments are unusable, emit a WARNING
     * and set the corresponding argument to NULL in fcinfo.
     */
 
    if (!stats_check_arg_array(fcinfo, attarginfo, MOST_COMMON_FREQS_ARG))
    {
        do_mcv = false;
        result = false;
    }
 
    if (!stats_check_arg_array(fcinfo, attarginfo, MOST_COMMON_ELEM_FREQS_ARG))
    {
        do_mcelem = false;
        result = false;
    }
    if (!stats_check_arg_array(fcinfo, attarginfo, ELEM_COUNT_HISTOGRAM_ARG))
    {
        do_dechist = false;
        result = false;
    }
 
    if (!stats_check_arg_pair(fcinfo, attarginfo,
                              MOST_COMMON_VALS_ARG, MOST_COMMON_FREQS_ARG))
    {
        do_mcv = false;
        result = false;
    }
 
    if (!stats_check_arg_pair(fcinfo, attarginfo,
                              MOST_COMMON_ELEMS_ARG,
                              MOST_COMMON_ELEM_FREQS_ARG))
    {
        do_mcelem = false;
        result = false;
    }
 
    if (!stats_check_arg_pair(fcinfo, attarginfo,
                              RANGE_LENGTH_HISTOGRAM_ARG,
                              RANGE_EMPTY_FRAC_ARG))
    {
        do_range_length_histogram = false;
        result = false;
    }
 
    /* derive information from attribute */
    statatt_get_type(reloid, attnum,
                     &atttypid, &atttypmod,
                     &atttyptype, &atttypcoll,
                     &eq_opr, &lt_opr);
 
    /* if needed, derive element type */
    if (do_mcelem || do_dechist)
    {
        if (!statatt_get_elem_type(atttypid, atttyptype,
                                   &elemtypid, &elem_eq_opr))
        {
            ereport(WARNING,
                    (errmsg("could not determine element type of column \"%s\"", attname),
                     errdetail("Cannot set %s or %s.",
                               "STATISTIC_KIND_MCELEM", "STATISTIC_KIND_DECHIST")));
            elemtypid = InvalidOid;
            elem_eq_opr = InvalidOid;
 
            do_mcelem = false;
            do_dechist = false;
            result = false;
        }
    }
 
    /* histogram and correlation require less-than operator */
    if ((do_histogram || do_correlation) && !OidIsValid(lt_opr))
    {
        ereport(WARNING,
                (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
                 errmsg("could not determine less-than operator for column \"%s\"", attname),
                 errdetail("Cannot set %s or %s.",
                           "STATISTIC_KIND_HISTOGRAM", "STATISTIC_KIND_CORRELATION")));
 
        do_histogram = false;
        do_correlation = false;
        result = false;
    }
 
    /* only range types can have range stats */
    if ((do_range_length_histogram || do_bounds_histogram) &&
        !(atttyptype == TYPTYPE_RANGE || atttyptype == TYPTYPE_MULTIRANGE))
    {
        ereport(WARNING,
                (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
                 errmsg("column \"%s\" is not a range type", attname),
                 errdetail("Cannot set %s or %s.",
                           "STATISTIC_KIND_RANGE_LENGTH_HISTOGRAM", "STATISTIC_KIND_BOUNDS_HISTOGRAM")));
 
        do_bounds_histogram = false;
        do_range_length_histogram = false;
        result = false;
    }
 
    fmgr_info(F_ARRAY_IN, &array_in_fn);
 
    starel = table_open(StatisticRelationId, RowExclusiveLock);
 
    statup = SearchSysCache3(STATRELATTINH, ObjectIdGetDatum(reloid), Int16GetDatum(attnum), BoolGetDatum(inherited));
 
    /* initialize from existing tuple if exists */
    if (HeapTupleIsValid(statup))
        heap_deform_tuple(statup, RelationGetDescr(starel), values, nulls);
    else
        statatt_init_empty_tuple(reloid, attnum, inherited, values, nulls,
                                 replaces);
 
    /* if specified, set to argument values */
    if (!PG_ARGISNULL(NULL_FRAC_ARG))
    {
        values[Anum_pg_statistic_stanullfrac - 1] = PG_GETARG_DATUM(NULL_FRAC_ARG);
        replaces[Anum_pg_statistic_stanullfrac - 1] = true;
    }
    if (!PG_ARGISNULL(AVG_WIDTH_ARG))
    {
        values[Anum_pg_statistic_stawidth - 1] = PG_GETARG_DATUM(AVG_WIDTH_ARG);
        replaces[Anum_pg_statistic_stawidth - 1] = true;
    }
    if (!PG_ARGISNULL(N_DISTINCT_ARG))
    {
        values[Anum_pg_statistic_stadistinct - 1] = PG_GETARG_DATUM(N_DISTINCT_ARG);
        replaces[Anum_pg_statistic_stadistinct - 1] = true;
    }
 
    /* STATISTIC_KIND_MCV */
    if (do_mcv)
    {
        bool        converted;
        Datum       stanumbers = PG_GETARG_DATUM(MOST_COMMON_FREQS_ARG);
        Datum       stavalues = statatt_build_stavalues("most_common_vals",
                                                        &array_in_fn,
                                                        PG_GETARG_DATUM(MOST_COMMON_VALS_ARG),
                                                        atttypid, atttypmod,
                                                        &converted);
 
        if (converted)
        {
            ArrayType  *vals_arr = DatumGetArrayTypeP(stavalues);
            ArrayType  *nums_arr = DatumGetArrayTypeP(stanumbers);
            int         nvals = ARR_DIMS(vals_arr)[0];
            int         nnums = ARR_DIMS(nums_arr)[0];
 
            if (nvals != nnums)
            {
                ereport(WARNING,
                        (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
                         errmsg("could not parse \"%s\": incorrect number of elements (same as \"%s\" required)",
                                "most_common_vals",
                                "most_common_freqs")));
                result = false;
            }
            else
            {
                statatt_set_slot(values, nulls, replaces,
                                 STATISTIC_KIND_MCV,
                                 eq_opr, atttypcoll,
                                 stanumbers, false, stavalues, false);
            }
        }
        else
            result = false;
    }
 
    /* STATISTIC_KIND_HISTOGRAM */
    if (do_histogram)
    {
        Datum       stavalues;
        bool        converted = false;
 
        stavalues = statatt_build_stavalues("histogram_bounds",
                                            &array_in_fn,
                                            PG_GETARG_DATUM(HISTOGRAM_BOUNDS_ARG),
                                            atttypid, atttypmod,
                                            &converted);
 
        if (converted)
        {
            statatt_set_slot(values, nulls, replaces,
                             STATISTIC_KIND_HISTOGRAM,
                             lt_opr, atttypcoll,
                             0, true, stavalues, false);
        }
        else
            result = false;
    }
 
    /* STATISTIC_KIND_CORRELATION */
    if (do_correlation)
    {
        Datum       elems[] = {PG_GETARG_DATUM(CORRELATION_ARG)};
        ArrayType  *arry = construct_array_builtin(elems, 1, FLOAT4OID);
        Datum       stanumbers = PointerGetDatum(arry);
 
        statatt_set_slot(values, nulls, replaces,
                         STATISTIC_KIND_CORRELATION,
                         lt_opr, atttypcoll,
                         stanumbers, false, 0, true);
    }
 
    /* STATISTIC_KIND_MCELEM */
    if (do_mcelem)
    {
        Datum       stanumbers = PG_GETARG_DATUM(MOST_COMMON_ELEM_FREQS_ARG);
        bool        converted = false;
        Datum       stavalues;
 
        stavalues = statatt_build_stavalues("most_common_elems",
                                            &array_in_fn,
                                            PG_GETARG_DATUM(MOST_COMMON_ELEMS_ARG),
                                            elemtypid, atttypmod,
                                            &converted);
 
        if (converted)
        {
            statatt_set_slot(values, nulls, replaces,
                             STATISTIC_KIND_MCELEM,
                             elem_eq_opr, atttypcoll,
                             stanumbers, false, stavalues, false);
        }
        else
            result = false;
    }
 
    /* STATISTIC_KIND_DECHIST */
    if (do_dechist)
    {
        Datum       stanumbers = PG_GETARG_DATUM(ELEM_COUNT_HISTOGRAM_ARG);
 
        statatt_set_slot(values, nulls, replaces,
                         STATISTIC_KIND_DECHIST,
                         elem_eq_opr, atttypcoll,
                         stanumbers, false, 0, true);
    }
 
    /*
     * STATISTIC_KIND_BOUNDS_HISTOGRAM
     *
     * This stakind appears before STATISTIC_KIND_RANGE_LENGTH_HISTOGRAM even
     * though it is numerically greater, and all other stakinds appear in
     * numerical order. We duplicate this quirk for consistency.
     */
    if (do_bounds_histogram)
    {
        bool        converted = false;
        Datum       stavalues;
 
        stavalues = statatt_build_stavalues("range_bounds_histogram",
                                            &array_in_fn,
                                            PG_GETARG_DATUM(RANGE_BOUNDS_HISTOGRAM_ARG),
                                            atttypid, atttypmod,
                                            &converted);
 
        if (converted &&
            statatt_check_bounds_histogram(stavalues))
        {
            statatt_set_slot(values, nulls, replaces,
                             STATISTIC_KIND_BOUNDS_HISTOGRAM,
                             InvalidOid, InvalidOid,
                             0, true, stavalues, false);
        }
        else
            result = false;
    }
 
    /* STATISTIC_KIND_RANGE_LENGTH_HISTOGRAM */
    if (do_range_length_histogram)
    {
        /* The anyarray is always a float8[] for this stakind */
        Datum       elems[] = {PG_GETARG_DATUM(RANGE_EMPTY_FRAC_ARG)};
        ArrayType  *arry = construct_array_builtin(elems, 1, FLOAT4OID);
        Datum       stanumbers = PointerGetDatum(arry);
 
        bool        converted = false;
        Datum       stavalues;
 
        stavalues = statatt_build_stavalues("range_length_histogram",
                                            &array_in_fn,
                                            PG_GETARG_DATUM(RANGE_LENGTH_HISTOGRAM_ARG),
                                            FLOAT8OID, 0, &converted);
 
        if (converted)
        {
            statatt_set_slot(values, nulls, replaces,
                             STATISTIC_KIND_RANGE_LENGTH_HISTOGRAM,
                             Float8LessOperator, InvalidOid,
                             stanumbers, false, stavalues, false);
        }
        else
            result = false;
    }
 
    upsert_pg_statistic(starel, statup, values, nulls, replaces);
 
    if (HeapTupleIsValid(statup))
        ReleaseSysCache(statup);
    table_close(starel, RowExclusiveLock);
 
    return result;
}

References ARR_DIMS, attarginfo, attname, attnum, AVG_WIDTH_ARG, BoolGetDatum(), construct_array_builtin(), CORRELATION_ARG, DatumGetArrayTypeP, ELEM_COUNT_HISTOGRAM_ARG, ereport, errcode(), errdetail(), errmsg, fb(), fmgr_info(), heap_deform_tuple(), HeapTupleIsValid, HISTOGRAM_BOUNDS_ARG, Int16GetDatum(), InvalidOid, MOST_COMMON_ELEM_FREQS_ARG, MOST_COMMON_ELEMS_ARG, MOST_COMMON_FREQS_ARG, MOST_COMMON_VALS_ARG, N_DISTINCT_ARG, NULL_FRAC_ARG, ObjectIdGetDatum(), OidIsValid, PG_ARGISNULL, PG_GETARG_DATUM, PointerGetDatum, RANGE_BOUNDS_HISTOGRAM_ARG, RANGE_EMPTY_FRAC_ARG, RANGE_LENGTH_HISTOGRAM_ARG, RelationGetDescr, ReleaseSysCache(), result, RowExclusiveLock, SearchSysCache3(), statatt_build_stavalues(), statatt_check_bounds_histogram(), statatt_get_elem_type(), statatt_get_type(), statatt_init_empty_tuple(), statatt_set_slot(), stats_check_arg_array(), stats_check_arg_pair(), table_close(), table_open(), upsert_pg_statistic(), values, and WARNING.

Referenced by attribute_statistics_update(), and import_attribute_statistics().

delete_attribute_statistics()

bool delete_attribute_statistics	(	Relation	rel,
		AttrNumber	attnum,
		bool	inherited
	)

Definition at line 798 of file attribute_stats.c.

{
    return delete_pg_statistic(RelationGetRelid(rel), attnum, inherited);
}

References attnum, delete_pg_statistic(), fb(), and RelationGetRelid.

Referenced by import_fetched_statistics().

delete_pg_statistic()

static bool delete_pg_statistic ( Oid  reloid, AttrNumber  attnum, bool  stainherit  )

static

Definition at line 586 of file attribute_stats.c.

{
    Relation    sd = table_open(StatisticRelationId, RowExclusiveLock);
    HeapTuple   oldtup;
    bool        result = false;
 
    /* Is there already a pg_statistic tuple for this attribute? */
    oldtup = SearchSysCache3(STATRELATTINH,
                             ObjectIdGetDatum(reloid),
                             Int16GetDatum(attnum),
                             BoolGetDatum(stainherit));
 
    if (HeapTupleIsValid(oldtup))
    {
        CatalogTupleDelete(sd, &oldtup->t_self);
        ReleaseSysCache(oldtup);
        result = true;
    }
 
    table_close(sd, RowExclusiveLock);
 
    CommandCounterIncrement();
 
    return result;
}

References attnum, BoolGetDatum(), CatalogTupleDelete(), CommandCounterIncrement(), fb(), HeapTupleIsValid, Int16GetDatum(), ObjectIdGetDatum(), ReleaseSysCache(), result, RowExclusiveLock, SearchSysCache3(), table_close(), and table_open().

Referenced by delete_attribute_statistics(), and pg_clear_attribute_stats().

import_attribute_statistics()

bool import_attribute_statistics	(	Relation	rel,
		AttrNumber	attnum,
		bool	inherited,
		const NullableDatum *	version,
		const NullableDatum *	null_frac,
		const NullableDatum *	avg_width,
		const NullableDatum *	n_distinct,
		const NullableDatum *	most_common_vals,
		const NullableDatum *	most_common_freqs,
		const NullableDatum *	histogram_bounds,
		const NullableDatum *	correlation,
		const NullableDatum *	most_common_elems,
		const NullableDatum *	most_common_elem_freqs,
		const NullableDatum *	elem_count_histogram,
		const NullableDatum *	range_length_histogram,
		const NullableDatum *	range_empty_frac,
		const NullableDatum *	range_bounds_histogram
	)

Definition at line 718 of file attribute_stats.c.

{
    LOCAL_FCINFO(newfcinfo, NUM_ATTRIBUTE_STATS_ARGS);
    Oid         reloid = RelationGetRelid(rel);
    char       *relname = RelationGetRelationName(rel);
    char       *attname = get_attname(reloid, attnum, true);
 
    Assert(null_frac);
    Assert(avg_width);
    Assert(n_distinct);
    Assert(most_common_vals);
    Assert(most_common_freqs);
    Assert(histogram_bounds);
    Assert(correlation);
    Assert(most_common_elems);
    Assert(most_common_elem_freqs);
    Assert(elem_count_histogram);
    Assert(range_length_histogram);
    Assert(range_empty_frac);
    Assert(range_bounds_histogram);
 
    /* annoyingly, get_attname doesn't check attisdropped */
    if (attname == NULL ||
        !SearchSysCacheExistsAttName(reloid, attname))
        ereport(ERROR,
                (errcode(ERRCODE_UNDEFINED_COLUMN),
                 errmsg("column %d of relation \"%s\" does not exist",
                        attnum, relname)));
 
    InitFunctionCallInfoData(*newfcinfo, NULL, NUM_ATTRIBUTE_STATS_ARGS,
                             InvalidOid, NULL, NULL);
 
    newfcinfo->args[ATTRELSCHEMA_ARG].value =
        CStringGetTextDatum(get_namespace_name(RelationGetNamespace(rel)));
    newfcinfo->args[ATTRELSCHEMA_ARG].isnull = false;
    newfcinfo->args[ATTRELNAME_ARG].value = CStringGetTextDatum(relname);
    newfcinfo->args[ATTRELNAME_ARG].isnull = false;
    newfcinfo->args[ATTNAME_ARG].value = CStringGetTextDatum(attname);
    newfcinfo->args[ATTNAME_ARG].isnull = false;
    newfcinfo->args[ATTNUM_ARG].value = Int16GetDatum(attnum);
    newfcinfo->args[ATTNUM_ARG].isnull = false;
    newfcinfo->args[INHERITED_ARG].value = BoolGetDatum(inherited);
    newfcinfo->args[INHERITED_ARG].isnull = false;
 
    newfcinfo->args[NULL_FRAC_ARG] = *null_frac;
    newfcinfo->args[AVG_WIDTH_ARG] = *avg_width;
    newfcinfo->args[N_DISTINCT_ARG] = *n_distinct;
    newfcinfo->args[MOST_COMMON_VALS_ARG] = *most_common_vals;
    newfcinfo->args[MOST_COMMON_FREQS_ARG] = *most_common_freqs;
    newfcinfo->args[HISTOGRAM_BOUNDS_ARG] = *histogram_bounds;
    newfcinfo->args[CORRELATION_ARG] = *correlation;
    newfcinfo->args[MOST_COMMON_ELEMS_ARG] = *most_common_elems;
    newfcinfo->args[MOST_COMMON_ELEM_FREQS_ARG] = *most_common_elem_freqs;
    newfcinfo->args[ELEM_COUNT_HISTOGRAM_ARG] = *elem_count_histogram;
    newfcinfo->args[RANGE_LENGTH_HISTOGRAM_ARG] = *range_length_histogram;
    newfcinfo->args[RANGE_EMPTY_FRAC_ARG] = *range_empty_frac;
    newfcinfo->args[RANGE_BOUNDS_HISTOGRAM_ARG] = *range_bounds_histogram;
 
    return attribute_statistics_update_internal(reloid, attname, attnum,
                                                inherited, newfcinfo);
}

References Assert, attname, ATTNAME_ARG, attnum, ATTNUM_ARG, ATTRELNAME_ARG, ATTRELSCHEMA_ARG, attribute_statistics_update_internal(), AVG_WIDTH_ARG, BoolGetDatum(), CORRELATION_ARG, CStringGetTextDatum, ELEM_COUNT_HISTOGRAM_ARG, ereport, errcode(), errmsg, ERROR, fb(), get_attname(), get_namespace_name(), HISTOGRAM_BOUNDS_ARG, INHERITED_ARG, InitFunctionCallInfoData, Int16GetDatum(), InvalidOid, LOCAL_FCINFO, MOST_COMMON_ELEM_FREQS_ARG, MOST_COMMON_ELEMS_ARG, MOST_COMMON_FREQS_ARG, MOST_COMMON_VALS_ARG, N_DISTINCT_ARG, NULL_FRAC_ARG, NUM_ATTRIBUTE_STATS_ARGS, RANGE_BOUNDS_HISTOGRAM_ARG, RANGE_EMPTY_FRAC_ARG, RANGE_LENGTH_HISTOGRAM_ARG, RelationGetNamespace, RelationGetRelationName, RelationGetRelid, relname, and SearchSysCacheExistsAttName().

Referenced by import_fetched_statistics().

pg_clear_attribute_stats()

Datum pg_clear_attribute_stats

(

PG_FUNCTION_ARGS

)

Definition at line 616 of file attribute_stats.c.

{
    char       *nspname;
    char       *relname;
    Oid         reloid;
    char       *attname;
    AttrNumber  attnum;
    bool        inherited;
    Oid         locked_table = InvalidOid;
 
    stats_check_required_arg(fcinfo, cleararginfo, C_ATTRELSCHEMA_ARG);
    stats_check_required_arg(fcinfo, cleararginfo, C_ATTRELNAME_ARG);
    stats_check_required_arg(fcinfo, cleararginfo, C_ATTNAME_ARG);
    stats_check_required_arg(fcinfo, cleararginfo, C_INHERITED_ARG);
 
    nspname = TextDatumGetCString(PG_GETARG_DATUM(C_ATTRELSCHEMA_ARG));
    relname = TextDatumGetCString(PG_GETARG_DATUM(C_ATTRELNAME_ARG));
 
    if (RecoveryInProgress())
        ereport(ERROR,
                (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
                 errmsg("recovery is in progress"),
                 errhint("Statistics cannot be modified during recovery.")));
 
    reloid = RangeVarGetRelidExtended(makeRangeVar(nspname, relname, -1),
                                      ShareUpdateExclusiveLock, 0,
                                      RangeVarCallbackForStats, &locked_table);
 
    attname = TextDatumGetCString(PG_GETARG_DATUM(C_ATTNAME_ARG));
    attnum = get_attnum(reloid, attname);
 
    if (attnum < 0)
        ereport(ERROR,
                (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
                 errmsg("cannot clear statistics on system column \"%s\"",
                        attname)));
 
    if (attnum == InvalidAttrNumber)
        ereport(ERROR,
                (errcode(ERRCODE_UNDEFINED_COLUMN),
                 errmsg("column \"%s\" of relation \"%s\" does not exist",
                        attname, get_rel_name(reloid))));
 
    inherited = PG_GETARG_BOOL(C_INHERITED_ARG);
 
    delete_pg_statistic(reloid, attnum, inherited);
    PG_RETURN_VOID();
}

References attname, attnum, C_ATTNAME_ARG, C_ATTRELNAME_ARG, C_ATTRELSCHEMA_ARG, C_INHERITED_ARG, cleararginfo, delete_pg_statistic(), ereport, errcode(), errhint(), errmsg, ERROR, fb(), get_attnum(), get_rel_name(), InvalidAttrNumber, InvalidOid, makeRangeVar(), PG_GETARG_BOOL, PG_GETARG_DATUM, PG_RETURN_VOID, RangeVarCallbackForStats(), RangeVarGetRelidExtended(), RecoveryInProgress(), relname, ShareUpdateExclusiveLock, stats_check_required_arg(), and TextDatumGetCString.

pg_restore_attribute_stats()

Datum pg_restore_attribute_stats

(

PG_FUNCTION_ARGS

)

Definition at line 692 of file attribute_stats.c.

{
    LOCAL_FCINFO(positional_fcinfo, NUM_ATTRIBUTE_STATS_ARGS);
    bool        result = true;
 
    InitFunctionCallInfoData(*positional_fcinfo, NULL, NUM_ATTRIBUTE_STATS_ARGS,
                             InvalidOid, NULL, NULL);
 
    if (!stats_fill_fcinfo_from_arg_pairs(fcinfo, positional_fcinfo,
                                          attarginfo))
        result = false;
 
    if (!attribute_statistics_update(positional_fcinfo))
        result = false;
 
    PG_RETURN_BOOL(result);
}

References attarginfo, attribute_statistics_update(), fb(), InitFunctionCallInfoData, InvalidOid, LOCAL_FCINFO, NUM_ATTRIBUTE_STATS_ARGS, PG_RETURN_BOOL, result, and stats_fill_fcinfo_from_arg_pairs().

upsert_pg_statistic()

static void upsert_pg_statistic ( Relation  starel, HeapTuple  oldtup, const Datum *  values, const bool *  nulls, const bool *  replaces  )

static

Definition at line 560 of file attribute_stats.c.

{
    HeapTuple   newtup;
 
    if (HeapTupleIsValid(oldtup))
    {
        newtup = heap_modify_tuple(oldtup, RelationGetDescr(starel),
                                   values, nulls, replaces);
        CatalogTupleUpdate(starel, &newtup->t_self, newtup);
    }
    else
    {
        newtup = heap_form_tuple(RelationGetDescr(starel), values, nulls);
        CatalogTupleInsert(starel, newtup);
    }
 
    heap_freetuple(newtup);
 
    CommandCounterIncrement();
}

References CatalogTupleInsert(), CatalogTupleUpdate(), CommandCounterIncrement(), fb(), heap_form_tuple(), heap_freetuple(), heap_modify_tuple(), HeapTupleIsValid, RelationGetDescr, and values.

Referenced by attribute_statistics_update_internal().

Variable Documentation

attarginfo

struct StatsArgInfo attarginfo[]

static

Initial value:

=
{
    [ATTRELSCHEMA_ARG] = {"schemaname", TEXTOID},
    [ATTRELNAME_ARG] = {"relname", TEXTOID},
    [ATTNAME_ARG] = {"attname", TEXTOID},
    [ATTNUM_ARG] = {"attnum", INT2OID},
    [INHERITED_ARG] = {"inherited", BOOLOID},
    [NULL_FRAC_ARG] = {"null_frac", FLOAT4OID},
    [AVG_WIDTH_ARG] = {"avg_width", INT4OID},
    [N_DISTINCT_ARG] = {"n_distinct", FLOAT4OID},
    [MOST_COMMON_VALS_ARG] = {"most_common_vals", TEXTOID},
    [MOST_COMMON_FREQS_ARG] = {"most_common_freqs", FLOAT4ARRAYOID},
    [HISTOGRAM_BOUNDS_ARG] = {"histogram_bounds", TEXTOID},
    [CORRELATION_ARG] = {"correlation", FLOAT4OID},
    [MOST_COMMON_ELEMS_ARG] = {"most_common_elems", TEXTOID},
    [MOST_COMMON_ELEM_FREQS_ARG] = {"most_common_elem_freqs", FLOAT4ARRAYOID},
    [ELEM_COUNT_HISTOGRAM_ARG] = {"elem_count_histogram", FLOAT4ARRAYOID},
    [RANGE_LENGTH_HISTOGRAM_ARG] = {"range_length_histogram", TEXTOID},
    [RANGE_EMPTY_FRAC_ARG] = {"range_empty_frac", FLOAT4OID},
    [RANGE_BOUNDS_HISTOGRAM_ARG] = {"range_bounds_histogram", TEXTOID},
    [NUM_ATTRIBUTE_STATS_ARGS] = {0}
}

Definition at line 61 of file attribute_stats.c.

{
    [ATTRELSCHEMA_ARG] = {"schemaname", TEXTOID},
    [ATTRELNAME_ARG] = {"relname", TEXTOID},
    [ATTNAME_ARG] = {"attname", TEXTOID},
    [ATTNUM_ARG] = {"attnum", INT2OID},
    [INHERITED_ARG] = {"inherited", BOOLOID},
    [NULL_FRAC_ARG] = {"null_frac", FLOAT4OID},
    [AVG_WIDTH_ARG] = {"avg_width", INT4OID},
    [N_DISTINCT_ARG] = {"n_distinct", FLOAT4OID},
    [MOST_COMMON_VALS_ARG] = {"most_common_vals", TEXTOID},
    [MOST_COMMON_FREQS_ARG] = {"most_common_freqs", FLOAT4ARRAYOID},
    [HISTOGRAM_BOUNDS_ARG] = {"histogram_bounds", TEXTOID},
    [CORRELATION_ARG] = {"correlation", FLOAT4OID},
    [MOST_COMMON_ELEMS_ARG] = {"most_common_elems", TEXTOID},
    [MOST_COMMON_ELEM_FREQS_ARG] = {"most_common_elem_freqs", FLOAT4ARRAYOID},
    [ELEM_COUNT_HISTOGRAM_ARG] = {"elem_count_histogram", FLOAT4ARRAYOID},
    [RANGE_LENGTH_HISTOGRAM_ARG] = {"range_length_histogram", TEXTOID},
    [RANGE_EMPTY_FRAC_ARG] = {"range_empty_frac", FLOAT4OID},
    [RANGE_BOUNDS_HISTOGRAM_ARG] = {"range_bounds_histogram", TEXTOID},
    [NUM_ATTRIBUTE_STATS_ARGS] = {0}
};

Referenced by attribute_statistics_update(), attribute_statistics_update_internal(), and pg_restore_attribute_stats().

cleararginfo

struct StatsArgInfo cleararginfo[]

static

Initial value:

=
{
    [C_ATTRELSCHEMA_ARG] = {"schemaname", TEXTOID},
    [C_ATTRELNAME_ARG] = {"relname", TEXTOID},
    [C_ATTNAME_ARG] = {"attname", TEXTOID},
    [C_INHERITED_ARG] = {"inherited", BOOLOID},
    [C_NUM_ATTRIBUTE_STATS_ARGS] = {0}
}

Definition at line 98 of file attribute_stats.c.

{
    [C_ATTRELSCHEMA_ARG] = {"schemaname", TEXTOID},
    [C_ATTRELNAME_ARG] = {"relname", TEXTOID},
    [C_ATTNAME_ARG] = {"attname", TEXTOID},
    [C_INHERITED_ARG] = {"inherited", BOOLOID},
    [C_NUM_ATTRIBUTE_STATS_ARGS] = {0}
};

Referenced by pg_clear_attribute_stats().