pg_range.c File Reference

#include "postgres.h"
#include "access/genam.h"
#include "access/htup_details.h"
#include "access/table.h"
#include "catalog/dependency.h"
#include "catalog/indexing.h"
#include "catalog/pg_collation.h"
#include "catalog/pg_opclass.h"
#include "catalog/pg_proc.h"
#include "catalog/pg_range.h"
#include "catalog/pg_type.h"
#include "utils/fmgroids.h"
#include "utils/rel.h"

Include dependency graph for pg_range.c:

Go to the source code of this file.

Functions
void	RangeCreate (Oid rangeTypeOid, Oid rangeSubType, Oid rangeCollation, Oid rangeSubOpclass, RegProcedure rangeCanonical, RegProcedure rangeSubDiff, Oid multirangeTypeOid, RegProcedure rangeConstruct2, RegProcedure rangeConstruct3, RegProcedure mltrngConstruct0, RegProcedure mltrngConstruct1, RegProcedure mltrngConstruct2)
void	RangeDelete (Oid rangeTypeOid)

Function Documentation

RangeCreate()

void RangeCreate	(	Oid	rangeTypeOid,
		Oid	rangeSubType,
		Oid	rangeCollation,
		Oid	rangeSubOpclass,
		RegProcedure	rangeCanonical,
		RegProcedure	rangeSubDiff,
		Oid	multirangeTypeOid,
		RegProcedure	rangeConstruct2,
		RegProcedure	rangeConstruct3,
		RegProcedure	mltrngConstruct0,
		RegProcedure	mltrngConstruct1,
		RegProcedure	mltrngConstruct2
	)

Definition at line 36 of file pg_range.c.

{
    Relation    pg_range;
    Datum       values[Natts_pg_range];
    bool        nulls[Natts_pg_range];
    HeapTuple   tup;
    ObjectAddress myself;
    ObjectAddress referenced;
    ObjectAddress referencing;
    ObjectAddresses *addrs;
 
    pg_range = table_open(RangeRelationId, RowExclusiveLock);
 
    memset(nulls, 0, sizeof(nulls));
 
    values[Anum_pg_range_rngtypid - 1] = ObjectIdGetDatum(rangeTypeOid);
    values[Anum_pg_range_rngsubtype - 1] = ObjectIdGetDatum(rangeSubType);
    values[Anum_pg_range_rngcollation - 1] = ObjectIdGetDatum(rangeCollation);
    values[Anum_pg_range_rngsubopc - 1] = ObjectIdGetDatum(rangeSubOpclass);
    values[Anum_pg_range_rngcanonical - 1] = ObjectIdGetDatum(rangeCanonical);
    values[Anum_pg_range_rngsubdiff - 1] = ObjectIdGetDatum(rangeSubDiff);
    values[Anum_pg_range_rngmultitypid - 1] = ObjectIdGetDatum(multirangeTypeOid);
    values[Anum_pg_range_rngconstruct2 - 1] = ObjectIdGetDatum(rangeConstruct2);
    values[Anum_pg_range_rngconstruct3 - 1] = ObjectIdGetDatum(rangeConstruct3);
    values[Anum_pg_range_rngmltconstruct0 - 1] = ObjectIdGetDatum(mltrngConstruct0);
    values[Anum_pg_range_rngmltconstruct1 - 1] = ObjectIdGetDatum(mltrngConstruct1);
    values[Anum_pg_range_rngmltconstruct2 - 1] = ObjectIdGetDatum(mltrngConstruct2);
 
    tup = heap_form_tuple(RelationGetDescr(pg_range), values, nulls);
 
    CatalogTupleInsert(pg_range, tup);
    heap_freetuple(tup);
 
    /* record type's dependencies on range-related items */
    addrs = new_object_addresses();
 
    ObjectAddressSet(myself, TypeRelationId, rangeTypeOid);
 
    ObjectAddressSet(referenced, TypeRelationId, rangeSubType);
    add_exact_object_address(&referenced, addrs);
 
    ObjectAddressSet(referenced, OperatorClassRelationId, rangeSubOpclass);
    add_exact_object_address(&referenced, addrs);
 
    if (OidIsValid(rangeCollation))
    {
        ObjectAddressSet(referenced, CollationRelationId, rangeCollation);
        add_exact_object_address(&referenced, addrs);
    }
 
    if (OidIsValid(rangeCanonical))
    {
        ObjectAddressSet(referenced, ProcedureRelationId, rangeCanonical);
        add_exact_object_address(&referenced, addrs);
    }
 
    if (OidIsValid(rangeSubDiff))
    {
        ObjectAddressSet(referenced, ProcedureRelationId, rangeSubDiff);
        add_exact_object_address(&referenced, addrs);
    }
 
    record_object_address_dependencies(&myself, addrs, DEPENDENCY_NORMAL);
    free_object_addresses(addrs);
 
    /* record multirange type's dependency on the range type */
    referencing.classId = TypeRelationId;
    referencing.objectId = multirangeTypeOid;
    referencing.objectSubId = 0;
    recordDependencyOn(&referencing, &myself, DEPENDENCY_INTERNAL);
 
    table_close(pg_range, RowExclusiveLock);
}

References add_exact_object_address(), CatalogTupleInsert(), DEPENDENCY_INTERNAL, DEPENDENCY_NORMAL, fb(), free_object_addresses(), heap_form_tuple(), heap_freetuple(), new_object_addresses(), ObjectAddressSet, ObjectIdGetDatum(), OidIsValid, record_object_address_dependencies(), recordDependencyOn(), RelationGetDescr, RowExclusiveLock, table_close(), table_open(), and values.

Referenced by DefineRange().

RangeDelete()

void RangeDelete

(

Oid

rangeTypeOid

)

Definition at line 120 of file pg_range.c.

{
    Relation    pg_range;
    ScanKeyData key[1];
    SysScanDesc scan;
    HeapTuple   tup;
 
    pg_range = table_open(RangeRelationId, RowExclusiveLock);
 
    ScanKeyInit(&key[0],
                Anum_pg_range_rngtypid,
                BTEqualStrategyNumber, F_OIDEQ,
                ObjectIdGetDatum(rangeTypeOid));
 
    scan = systable_beginscan(pg_range, RangeTypidIndexId, true,
                              NULL, 1, key);
 
    while (HeapTupleIsValid(tup = systable_getnext(scan)))
    {
        CatalogTupleDelete(pg_range, &tup->t_self);
    }
 
    systable_endscan(scan);
 
    table_close(pg_range, RowExclusiveLock);
}

References BTEqualStrategyNumber, CatalogTupleDelete(), fb(), HeapTupleIsValid, ObjectIdGetDatum(), RowExclusiveLock, ScanKeyInit(), systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), and table_open().

Referenced by RemoveTypeById().