pg_cast.c File Reference

#include "postgres.h"
#include "access/htup_details.h"
#include "access/table.h"
#include "catalog/catalog.h"
#include "catalog/dependency.h"
#include "catalog/indexing.h"
#include "catalog/objectaccess.h"
#include "catalog/pg_cast.h"
#include "catalog/pg_proc.h"
#include "catalog/pg_type.h"
#include "utils/builtins.h"
#include "utils/rel.h"
#include "utils/syscache.h"

Include dependency graph for pg_cast.c:

Go to the source code of this file.

Functions
ObjectAddress	CastCreate (Oid sourcetypeid, Oid targettypeid, Oid funcid, Oid incastid, Oid outcastid, char castcontext, char castmethod, DependencyType behavior)

Function Documentation

CastCreate()

ObjectAddress CastCreate	(	Oid	sourcetypeid,
		Oid	targettypeid,
		Oid	funcid,
		Oid	incastid,
		Oid	outcastid,
		char	castcontext,
		char	castmethod,
		DependencyType	behavior
	)

Definition at line 49 of file pg_cast.c.

{
    Relation    relation;
    HeapTuple   tuple;
    Oid         castid;
    Datum       values[Natts_pg_cast];
    bool        nulls[Natts_pg_cast] = {0};
    ObjectAddress myself,
                referenced;
    ObjectAddresses *addrs;
 
    relation = table_open(CastRelationId, RowExclusiveLock);
 
    /*
     * Check for duplicate.  This is just to give a friendly error message,
     * the unique index would catch it anyway (so no need to sweat about race
     * conditions).
     */
    tuple = SearchSysCache2(CASTSOURCETARGET,
                            ObjectIdGetDatum(sourcetypeid),
                            ObjectIdGetDatum(targettypeid));
    if (HeapTupleIsValid(tuple))
        ereport(ERROR,
                (errcode(ERRCODE_DUPLICATE_OBJECT),
                 errmsg("cast from type %s to type %s already exists",
                        format_type_be(sourcetypeid),
                        format_type_be(targettypeid))));
 
    /* ready to go */
    castid = GetNewOidWithIndex(relation, CastOidIndexId, Anum_pg_cast_oid);
    values[Anum_pg_cast_oid - 1] = ObjectIdGetDatum(castid);
    values[Anum_pg_cast_castsource - 1] = ObjectIdGetDatum(sourcetypeid);
    values[Anum_pg_cast_casttarget - 1] = ObjectIdGetDatum(targettypeid);
    values[Anum_pg_cast_castfunc - 1] = ObjectIdGetDatum(funcid);
    values[Anum_pg_cast_castcontext - 1] = CharGetDatum(castcontext);
    values[Anum_pg_cast_castmethod - 1] = CharGetDatum(castmethod);
 
    tuple = heap_form_tuple(RelationGetDescr(relation), values, nulls);
 
    CatalogTupleInsert(relation, tuple);
 
    addrs = new_object_addresses();
 
    /* make dependency entries */
    ObjectAddressSet(myself, CastRelationId, castid);
 
    /* dependency on source type */
    ObjectAddressSet(referenced, TypeRelationId, sourcetypeid);
    add_exact_object_address(&referenced, addrs);
 
    /* dependency on target type */
    ObjectAddressSet(referenced, TypeRelationId, targettypeid);
    add_exact_object_address(&referenced, addrs);
 
    /* dependency on function */
    if (OidIsValid(funcid))
    {
        ObjectAddressSet(referenced, ProcedureRelationId, funcid);
        add_exact_object_address(&referenced, addrs);
    }
 
    /* dependencies on casts required for function */
    if (OidIsValid(incastid))
    {
        ObjectAddressSet(referenced, CastRelationId, incastid);
        add_exact_object_address(&referenced, addrs);
    }
    if (OidIsValid(outcastid))
    {
        ObjectAddressSet(referenced, CastRelationId, outcastid);
        add_exact_object_address(&referenced, addrs);
    }
 
    record_object_address_dependencies(&myself, addrs, behavior);
    free_object_addresses(addrs);
 
    /* dependency on extension */
    recordDependencyOnCurrentExtension(&myself, false);
 
    /* Post creation hook for new cast */
    InvokeObjectPostCreateHook(CastRelationId, castid, 0);
 
    heap_freetuple(tuple);
 
    table_close(relation, RowExclusiveLock);
 
    return myself;
}

References add_exact_object_address(), CatalogTupleInsert(), CharGetDatum(), ereport, errcode(), ERRCODE_DUPLICATE_OBJECT, errmsg(), ERROR, format_type_be(), free_object_addresses(), GetNewOidWithIndex(), heap_form_tuple(), heap_freetuple(), HeapTupleIsValid, InvokeObjectPostCreateHook, new_object_addresses(), ObjectAddressSet, ObjectIdGetDatum(), OidIsValid, record_object_address_dependencies(), recordDependencyOnCurrentExtension(), RelationGetDescr, RowExclusiveLock, SearchSysCache2(), table_close(), table_open(), and values.

Referenced by CreateCast(), and DefineRange().