#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:

Typedefs
typedef FormData_pg_conversion *	Form_pg_conversion

Functions
	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
	FormData_pg_conversion

Typedef Documentation

◆ Form_pg_conversion

typedef FormData_pg_conversion* Form_pg_conversion

Definition at line 61 of file pg_conversion.h.

Function Documentation

◆ CATALOG()

CATALOG	(	pg_conversion	,
		2607	,
		ConversionRelationId
	)

Definition at line 29 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, and encoding.

◆ ConversionCreate()

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

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) NULL;
     }
  
     /* 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(), ObjectAddress::classId, DEPENDENCY_NORMAL, elog, ereport, errcode(), ERRCODE_DUPLICATE_OBJECT, errmsg(), ERROR, FindDefaultConversion(), GetNewOidWithIndex(), heap_form_tuple(), heap_freetuple(), i, Int32GetDatum(), InvokeObjectPostCreateHook, NameGetDatum(), namestrcpy(), ObjectAddress::objectId, ObjectIdGetDatum(), ObjectAddress::objectSubId, 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
	)

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 GETSTRUCT, i, Int32GetDatum(), InvalidOid, catclist::members, catclist::n_members, ObjectIdGetDatum(), ReleaseSysCacheList, SearchSysCacheList3, and catctup::tuple.

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

◆ FormData_pg_conversion

FormData_pg_conversion

Definition at line 54 of file pg_conversion.h.

Typedefs

Functions

Variables