#include "catalog/genbki.h"
#include "catalog/objectaddress.h"
#include "catalog/pg_conversion_d.h"

Include dependency graph for pg_conversion.h:

This graph shows which files directly or indirectly include this file:

Functions
BEGIN_CATALOG_STRUCT	CATALOG (pg_conversion, 2607, ConversionRelationId)

	DECLARE_UNIQUE_INDEX (pg_conversion_default_index, 2668, ConversionDefaultIndexId, pg_conversion, btree(connamespace oid_ops, conforencoding int4_ops, contoencoding int4_ops, oid oid_ops))

	DECLARE_UNIQUE_INDEX (pg_conversion_name_nsp_index, 2669, ConversionNameNspIndexId, pg_conversion, btree(conname name_ops, connamespace oid_ops))

	DECLARE_UNIQUE_INDEX_PKEY (pg_conversion_oid_index, 2670, ConversionOidIndexId, pg_conversion, btree(oid oid_ops))

	MAKE_SYSCACHE (CONDEFAULT, pg_conversion_default_index, 8)

	MAKE_SYSCACHE (CONNAMENSP, pg_conversion_name_nsp_index, 8)

	MAKE_SYSCACHE (CONVOID, pg_conversion_oid_index, 8)

ObjectAddress	ConversionCreate (const char *conname, Oid connamespace, Oid conowner, int32 conforencoding, int32 contoencoding, Oid conproc, bool def)

Oid	FindDefaultConversion (Oid name_space, int32 for_encoding, int32 to_encoding)

Variables
END_CATALOG_STRUCT typedef FormData_pg_conversion *	Form_pg_conversion

	FormData_pg_conversion

Function Documentation

◆ CATALOG()

BEGIN_CATALOG_STRUCT CATALOG	(	pg_conversion	,
		2607	,
		ConversionRelationId
	)

Definition at line 31 of file pg_conversion.h.

{
    /* oid */
    Oid         oid;
 
    /* name of the conversion */
    NameData    conname;
 
    /* namespace that the conversion belongs to */
    Oid         connamespace BKI_DEFAULT(pg_catalog) BKI_LOOKUP(pg_namespace);
 
    /* owner of the conversion */
    Oid         conowner BKI_DEFAULT(POSTGRES) BKI_LOOKUP(pg_authid);
 
    /* FOR encoding id */
    int32       conforencoding BKI_LOOKUP(encoding);
 
    /* TO encoding id */
    int32       contoencoding BKI_LOOKUP(encoding);
 
    /* OID of the conversion proc */
    regproc     conproc BKI_LOOKUP(pg_proc);
 
    /* true if this is a default conversion */
    bool        condefault BKI_DEFAULT(t);
} FormData_pg_conversion;

References BKI_DEFAULT, BKI_LOOKUP, encoding, and fb().

◆ ConversionCreate()

ObjectAddress ConversionCreate	(	const char *	conname,
		Oid	connamespace,
		Oid	conowner,
		int32	conforencoding,
		int32	contoencoding,
		Oid	conproc,
		bool	def
	)

extern

Definition at line 38 of file pg_conversion.c.

{
    int         i;
    Relation    rel;
    TupleDesc   tupDesc;
    HeapTuple   tup;
    Oid         oid;
    bool        nulls[Natts_pg_conversion];
    Datum       values[Natts_pg_conversion];
    NameData    cname;
    ObjectAddress myself,
                referenced;
 
    /* sanity checks */
    if (!conname)
        elog(ERROR, "no conversion name supplied");
 
    /* make sure there is no existing conversion of same name */
    if (SearchSysCacheExists2(CONNAMENSP,
                              PointerGetDatum(conname),
                              ObjectIdGetDatum(connamespace)))
        ereport(ERROR,
                (errcode(ERRCODE_DUPLICATE_OBJECT),
                 errmsg("conversion \"%s\" already exists", conname)));
 
    if (def)
    {
        /*
         * make sure there is no existing default <for encoding><to encoding>
         * pair in this name space
         */
        if (FindDefaultConversion(connamespace,
                                  conforencoding,
                                  contoencoding))
            ereport(ERROR,
                    (errcode(ERRCODE_DUPLICATE_OBJECT),
                     errmsg("default conversion for %s to %s already exists",
                            pg_encoding_to_char(conforencoding),
                            pg_encoding_to_char(contoencoding))));
    }
 
    /* open pg_conversion */
    rel = table_open(ConversionRelationId, RowExclusiveLock);
    tupDesc = rel->rd_att;
 
    /* initialize nulls and values */
    for (i = 0; i < Natts_pg_conversion; i++)
    {
        nulls[i] = false;
        values[i] = (Datum) 0;
    }
 
    /* form a tuple */
    namestrcpy(&cname, conname);
    oid = GetNewOidWithIndex(rel, ConversionOidIndexId,
                             Anum_pg_conversion_oid);
    values[Anum_pg_conversion_oid - 1] = ObjectIdGetDatum(oid);
    values[Anum_pg_conversion_conname - 1] = NameGetDatum(&cname);
    values[Anum_pg_conversion_connamespace - 1] = ObjectIdGetDatum(connamespace);
    values[Anum_pg_conversion_conowner - 1] = ObjectIdGetDatum(conowner);
    values[Anum_pg_conversion_conforencoding - 1] = Int32GetDatum(conforencoding);
    values[Anum_pg_conversion_contoencoding - 1] = Int32GetDatum(contoencoding);
    values[Anum_pg_conversion_conproc - 1] = ObjectIdGetDatum(conproc);
    values[Anum_pg_conversion_condefault - 1] = BoolGetDatum(def);
 
    tup = heap_form_tuple(tupDesc, values, nulls);
 
    /* insert a new tuple */
    CatalogTupleInsert(rel, tup);
 
    myself.classId = ConversionRelationId;
    myself.objectId = oid;
    myself.objectSubId = 0;
 
    /* create dependency on conversion procedure */
    referenced.classId = ProcedureRelationId;
    referenced.objectId = conproc;
    referenced.objectSubId = 0;
    recordDependencyOn(&myself, &referenced, DEPENDENCY_NORMAL);
 
    /* create dependency on namespace */
    referenced.classId = NamespaceRelationId;
    referenced.objectId = connamespace;
    referenced.objectSubId = 0;
    recordDependencyOn(&myself, &referenced, DEPENDENCY_NORMAL);
 
    /* create dependency on owner */
    recordDependencyOnOwner(ConversionRelationId, oid, conowner);
 
    /* dependency on extension */
    recordDependencyOnCurrentExtension(&myself, false);
 
    /* Post creation hook for new conversion */
    InvokeObjectPostCreateHook(ConversionRelationId, oid, 0);
 
    heap_freetuple(tup);
    table_close(rel, RowExclusiveLock);
 
    return myself;
}

References BoolGetDatum(), CatalogTupleInsert(), DEPENDENCY_NORMAL, elog, ereport, errcode(), ERRCODE_DUPLICATE_OBJECT, errmsg(), ERROR, fb(), FindDefaultConversion(), GetNewOidWithIndex(), heap_form_tuple(), heap_freetuple(), i, Int32GetDatum(), InvokeObjectPostCreateHook, NameGetDatum(), namestrcpy(), ObjectIdGetDatum(), pg_encoding_to_char, PointerGetDatum(), RelationData::rd_att, recordDependencyOn(), recordDependencyOnCurrentExtension(), recordDependencyOnOwner(), RowExclusiveLock, SearchSysCacheExists2, table_close(), table_open(), and values.

Referenced by CreateConversionCommand().

◆ DECLARE_UNIQUE_INDEX() [1/2]

DECLARE_UNIQUE_INDEX	(	pg_conversion_default_index	,
		2668	,
		ConversionDefaultIndexId	,
		pg_conversion	,
		btree(connamespace oid_ops, conforencoding int4_ops, contoencoding int4_ops, oid oid_ops)
	)

◆ DECLARE_UNIQUE_INDEX() [2/2]

DECLARE_UNIQUE_INDEX	(	pg_conversion_name_nsp_index	,
		2669	,
		ConversionNameNspIndexId	,
		pg_conversion	,
		btree(conname name_ops, connamespace oid_ops)
	)

◆ DECLARE_UNIQUE_INDEX_PKEY()

DECLARE_UNIQUE_INDEX_PKEY	(	pg_conversion_oid_index	,
		2670	,
		ConversionOidIndexId	,
		pg_conversion	,
		btree(oid oid_ops)
	)

◆ FindDefaultConversion()

Oid FindDefaultConversion	(	Oid	name_space,
		int32	for_encoding,
		int32	to_encoding
	)

extern

Definition at line 152 of file pg_conversion.c.

{
    CatCList   *catlist;
    HeapTuple   tuple;
    Form_pg_conversion body;
    Oid         proc = InvalidOid;
    int         i;
 
    catlist = SearchSysCacheList3(CONDEFAULT,
                                  ObjectIdGetDatum(name_space),
                                  Int32GetDatum(for_encoding),
                                  Int32GetDatum(to_encoding));
 
    for (i = 0; i < catlist->n_members; i++)
    {
        tuple = &catlist->members[i]->tuple;
        body = (Form_pg_conversion) GETSTRUCT(tuple);
        if (body->condefault)
        {
            proc = body->conproc;
            break;
        }
    }
    ReleaseSysCacheList(catlist);
    return proc;
}

References fb(), Form_pg_conversion, GETSTRUCT(), i, Int32GetDatum(), InvalidOid, ObjectIdGetDatum(), ReleaseSysCacheList, and SearchSysCacheList3.

Referenced by ConversionCreate(), and FindDefaultConversionProc().

◆ MAKE_SYSCACHE() [1/3]

MAKE_SYSCACHE	(	CONDEFAULT	,
		pg_conversion_default_index	,
		8
	)

◆ MAKE_SYSCACHE() [2/3]

MAKE_SYSCACHE	(	CONNAMENSP	,
		pg_conversion_name_nsp_index	,
		8
	)

◆ MAKE_SYSCACHE() [3/3]

MAKE_SYSCACHE	(	CONVOID	,
		pg_conversion_oid_index	,
		8
	)

Variable Documentation

◆ Form_pg_conversion

END_CATALOG_STRUCT typedef FormData_pg_conversion* Form_pg_conversion

Definition at line 65 of file pg_conversion.h.

Referenced by ConversionIsVisibleExt(), FindDefaultConversion(), getObjectDescription(), and getObjectIdentityParts().

◆ FormData_pg_conversion

FormData_pg_conversion

Definition at line 56 of file pg_conversion.h.

Functions

Variables