PostgreSQL Source Code git master
Functions
pg_collation.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_collation.h"
#include "catalog/pg_namespace.h"
#include "mb/pg_wchar.h"
#include "utils/builtins.h"
#include "utils/rel.h"
#include "utils/syscache.h"
Include dependency graph for pg_collation.c:

Go to the source code of this file.

Functions

Oid CollationCreate (const char *collname, Oid collnamespace, Oid collowner, char collprovider, bool collisdeterministic, int32 collencoding, const char *collcollate, const char *collctype, const char *colllocale, const char *collicurules, const char *collversion, bool if_not_exists, bool quiet)
 

Function Documentation

◆ CollationCreate()

Oid CollationCreate ( const char *  collname,
Oid  collnamespace,
Oid  collowner,
char  collprovider,
bool  collisdeterministic,
int32  collencoding,
const char *  collcollate,
const char *  collctype,
const char *  colllocale,
const char *  collicurules,
const char *  collversion,
bool  if_not_exists,
bool  quiet 
)

Definition at line 42 of file pg_collation.c.

53{
54 Relation rel;
55 TupleDesc tupDesc;
56 HeapTuple tup;
57 Datum values[Natts_pg_collation];
58 bool nulls[Natts_pg_collation];
59 NameData name_name;
60 Oid oid;
61 ObjectAddress myself,
62 referenced;
63
64 Assert(collname);
65 Assert(collnamespace);
66 Assert(collowner);
67 Assert((collprovider == COLLPROVIDER_LIBC &&
68 collcollate && collctype && !colllocale) ||
69 (collprovider != COLLPROVIDER_LIBC &&
70 !collcollate && !collctype && colllocale));
71
72 /*
73 * Make sure there is no existing collation of same name & encoding.
74 *
75 * This would be caught by the unique index anyway; we're just giving a
76 * friendlier error message. The unique index provides a backstop against
77 * race conditions.
78 */
79 oid = GetSysCacheOid3(COLLNAMEENCNSP,
80 Anum_pg_collation_oid,
81 PointerGetDatum(collname),
82 Int32GetDatum(collencoding),
83 ObjectIdGetDatum(collnamespace));
84 if (OidIsValid(oid))
85 {
86 if (quiet)
87 return InvalidOid;
88 else if (if_not_exists)
89 {
90 /*
91 * If we are in an extension script, insist that the pre-existing
92 * object be a member of the extension, to avoid security risks.
93 */
94 ObjectAddressSet(myself, CollationRelationId, oid);
95 checkMembershipInCurrentExtension(&myself);
96
97 /* OK to skip */
98 ereport(NOTICE,
99 (errcode(ERRCODE_DUPLICATE_OBJECT),
100 collencoding == -1
101 ? errmsg("collation \"%s\" already exists, skipping",
102 collname)
103 : errmsg("collation \"%s\" for encoding \"%s\" already exists, skipping",
104 collname, pg_encoding_to_char(collencoding))));
105 return InvalidOid;
106 }
107 else
108 ereport(ERROR,
109 (errcode(ERRCODE_DUPLICATE_OBJECT),
110 collencoding == -1
111 ? errmsg("collation \"%s\" already exists",
112 collname)
113 : errmsg("collation \"%s\" for encoding \"%s\" already exists",
114 collname, pg_encoding_to_char(collencoding))));
115 }
116
117 /* open pg_collation; see below about the lock level */
118 rel = table_open(CollationRelationId, ShareRowExclusiveLock);
119
120 /*
121 * Also forbid a specific-encoding collation shadowing an any-encoding
122 * collation, or an any-encoding collation being shadowed (see
123 * get_collation_name()). This test is not backed up by the unique index,
124 * so we take a ShareRowExclusiveLock earlier, to protect against
125 * concurrent changes fooling this check.
126 */
127 if (collencoding == -1)
128 oid = GetSysCacheOid3(COLLNAMEENCNSP,
129 Anum_pg_collation_oid,
130 PointerGetDatum(collname),
131 Int32GetDatum(GetDatabaseEncoding()),
132 ObjectIdGetDatum(collnamespace));
133 else
134 oid = GetSysCacheOid3(COLLNAMEENCNSP,
135 Anum_pg_collation_oid,
136 PointerGetDatum(collname),
137 Int32GetDatum(-1),
138 ObjectIdGetDatum(collnamespace));
139 if (OidIsValid(oid))
140 {
141 if (quiet)
142 {
143 table_close(rel, NoLock);
144 return InvalidOid;
145 }
146 else if (if_not_exists)
147 {
148 /*
149 * If we are in an extension script, insist that the pre-existing
150 * object be a member of the extension, to avoid security risks.
151 */
152 ObjectAddressSet(myself, CollationRelationId, oid);
153 checkMembershipInCurrentExtension(&myself);
154
155 /* OK to skip */
156 table_close(rel, NoLock);
157 ereport(NOTICE,
158 (errcode(ERRCODE_DUPLICATE_OBJECT),
159 errmsg("collation \"%s\" already exists, skipping",
160 collname)));
161 return InvalidOid;
162 }
163 else
164 ereport(ERROR,
165 (errcode(ERRCODE_DUPLICATE_OBJECT),
166 errmsg("collation \"%s\" already exists",
167 collname)));
168 }
169
170 tupDesc = RelationGetDescr(rel);
171
172 /* form a tuple */
173 memset(nulls, 0, sizeof(nulls));
174
175 namestrcpy(&name_name, collname);
176 oid = GetNewOidWithIndex(rel, CollationOidIndexId,
177 Anum_pg_collation_oid);
178 values[Anum_pg_collation_oid - 1] = ObjectIdGetDatum(oid);
179 values[Anum_pg_collation_collname - 1] = NameGetDatum(&name_name);
180 values[Anum_pg_collation_collnamespace - 1] = ObjectIdGetDatum(collnamespace);
181 values[Anum_pg_collation_collowner - 1] = ObjectIdGetDatum(collowner);
182 values[Anum_pg_collation_collprovider - 1] = CharGetDatum(collprovider);
183 values[Anum_pg_collation_collisdeterministic - 1] = BoolGetDatum(collisdeterministic);
184 values[Anum_pg_collation_collencoding - 1] = Int32GetDatum(collencoding);
185 if (collcollate)
186 values[Anum_pg_collation_collcollate - 1] = CStringGetTextDatum(collcollate);
187 else
188 nulls[Anum_pg_collation_collcollate - 1] = true;
189 if (collctype)
190 values[Anum_pg_collation_collctype - 1] = CStringGetTextDatum(collctype);
191 else
192 nulls[Anum_pg_collation_collctype - 1] = true;
193 if (colllocale)
194 values[Anum_pg_collation_colllocale - 1] = CStringGetTextDatum(colllocale);
195 else
196 nulls[Anum_pg_collation_colllocale - 1] = true;
197 if (collicurules)
198 values[Anum_pg_collation_collicurules - 1] = CStringGetTextDatum(collicurules);
199 else
200 nulls[Anum_pg_collation_collicurules - 1] = true;
201 if (collversion)
202 values[Anum_pg_collation_collversion - 1] = CStringGetTextDatum(collversion);
203 else
204 nulls[Anum_pg_collation_collversion - 1] = true;
205
206 tup = heap_form_tuple(tupDesc, values, nulls);
207
208 /* insert a new tuple */
209 CatalogTupleInsert(rel, tup);
210 Assert(OidIsValid(oid));
211
212 /* set up dependencies for the new collation */
213 myself.classId = CollationRelationId;
214 myself.objectId = oid;
215 myself.objectSubId = 0;
216
217 /* create dependency on namespace */
218 referenced.classId = NamespaceRelationId;
219 referenced.objectId = collnamespace;
220 referenced.objectSubId = 0;
221 recordDependencyOn(&myself, &referenced, DEPENDENCY_NORMAL);
222
223 /* create dependency on owner */
224 recordDependencyOnOwner(CollationRelationId, oid, collowner);
225
226 /* dependency on extension */
227 recordDependencyOnCurrentExtension(&myself, false);
228
229 /* Post creation hook for new collation */
230 InvokeObjectPostCreateHook(CollationRelationId, oid, 0);
231
232 heap_freetuple(tup);
233 table_close(rel, NoLock);
234
235 return oid;
236}
values
static Datum values[MAXATTR]
Definition: bootstrap.c:153
CStringGetTextDatum
#define CStringGetTextDatum(s)
Definition: builtins.h:97
OidIsValid
#define OidIsValid(objectId)
Definition: c.h:777
GetNewOidWithIndex
Oid GetNewOidWithIndex(Relation relation, Oid indexId, AttrNumber oidcolumn)
Definition: catalog.c:448
DEPENDENCY_NORMAL
@ DEPENDENCY_NORMAL
Definition: dependency.h:33
errcode
int errcode(int sqlerrcode)
Definition: elog.c:863
errmsg
int errmsg(const char *fmt,...)
Definition: elog.c:1080
ERROR
#define ERROR
Definition: elog.h:39
NOTICE
#define NOTICE
Definition: elog.h:35
ereport
#define ereport(elevel,...)
Definition: elog.h:150
Assert
Assert(PointerIsAligned(start, uint64))
heap_form_tuple
HeapTuple heap_form_tuple(TupleDesc tupleDescriptor, const Datum *values, const bool *isnull)
Definition: heaptuple.c:1117
heap_freetuple
void heap_freetuple(HeapTuple htup)
Definition: heaptuple.c:1435
CatalogTupleInsert
void CatalogTupleInsert(Relation heapRel, HeapTuple tup)
Definition: indexing.c:233
NoLock
#define NoLock
Definition: lockdefs.h:34
ShareRowExclusiveLock
#define ShareRowExclusiveLock
Definition: lockdefs.h:41
GetDatabaseEncoding
int GetDatabaseEncoding(void)
Definition: mbutils.c:1262
namestrcpy
void namestrcpy(Name name, const char *str)
Definition: name.c:233
InvokeObjectPostCreateHook
#define InvokeObjectPostCreateHook(classId, objectId, subId)
Definition: objectaccess.h:173
ObjectAddressSet
#define ObjectAddressSet(addr, class_id, object_id)
Definition: objectaddress.h:40
checkMembershipInCurrentExtension
void checkMembershipInCurrentExtension(const ObjectAddress *object)
Definition: pg_depend.c:258
recordDependencyOn
void recordDependencyOn(const ObjectAddress *depender, const ObjectAddress *referenced, DependencyType behavior)
Definition: pg_depend.c:45
recordDependencyOnCurrentExtension
void recordDependencyOnCurrentExtension(const ObjectAddress *object, bool isReplace)
Definition: pg_depend.c:193
recordDependencyOnOwner
void recordDependencyOnOwner(Oid classId, Oid objectId, Oid owner)
Definition: pg_shdepend.c:168
pg_encoding_to_char
#define pg_encoding_to_char
Definition: pg_wchar.h:630
PointerGetDatum
static Datum PointerGetDatum(const void *X)
Definition: postgres.h:332
BoolGetDatum
static Datum BoolGetDatum(bool X)
Definition: postgres.h:112
ObjectIdGetDatum
static Datum ObjectIdGetDatum(Oid X)
Definition: postgres.h:262
NameGetDatum
static Datum NameGetDatum(const NameData *X)
Definition: postgres.h:383
Datum
uint64_t Datum
Definition: postgres.h:70
Int32GetDatum
static Datum Int32GetDatum(int32 X)
Definition: postgres.h:222
CharGetDatum
static Datum CharGetDatum(char X)
Definition: postgres.h:132
InvalidOid
#define InvalidOid
Definition: postgres_ext.h:37
Oid
unsigned int Oid
Definition: postgres_ext.h:32
RelationGetDescr
#define RelationGetDescr(relation)
Definition: rel.h:541
ERRCODE_DUPLICATE_OBJECT
#define ERRCODE_DUPLICATE_OBJECT
Definition: streamutil.c:30
nameData
Definition: c.h:749
GetSysCacheOid3
#define GetSysCacheOid3(cacheId, oidcol, key1, key2, key3)
Definition: syscache.h:113
table_close
void table_close(Relation relation, LOCKMODE lockmode)
Definition: table.c:126
table_open
Relation table_open(Oid relationId, LOCKMODE lockmode)
Definition: table.c:40

References Assert(), BoolGetDatum(), CatalogTupleInsert(), CharGetDatum(), checkMembershipInCurrentExtension(), ObjectAddress::classId, CStringGetTextDatum, DEPENDENCY_NORMAL, ereport, errcode(), ERRCODE_DUPLICATE_OBJECT, errmsg(), ERROR, GetDatabaseEncoding(), GetNewOidWithIndex(), GetSysCacheOid3, heap_form_tuple(), heap_freetuple(), Int32GetDatum(), InvalidOid, InvokeObjectPostCreateHook, NameGetDatum(), namestrcpy(), NoLock, NOTICE, ObjectAddressSet, ObjectAddress::objectId, ObjectIdGetDatum(), ObjectAddress::objectSubId, OidIsValid, pg_encoding_to_char, PointerGetDatum(), recordDependencyOn(), recordDependencyOnCurrentExtension(), recordDependencyOnOwner(), RelationGetDescr, ShareRowExclusiveLock, table_close(), table_open(), and values.

Referenced by DefineCollation(), and pg_import_system_collations().