PostgreSQL Source Code git master
Loading...
Searching...
No Matches
Functions
conversioncmds.h File Reference
#include "catalog/objectaddress.h"
#include "nodes/parsenodes.h"
Include dependency graph for conversioncmds.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions

ObjectAddress CreateConversionCommand (CreateConversionStmt *stmt)
 

Function Documentation

◆ CreateConversionCommand()

ObjectAddress CreateConversionCommand ( CreateConversionStmt *  stmt)
extern

Definition at line 33 of file conversioncmds.c.

34{
35 Oid namespaceId;
36 char *conversion_name;
37 AclResult aclresult;
38 int from_encoding;
39 int to_encoding;
40 Oid funcoid;
41 const char *from_encoding_name = stmt->for_encoding_name;
42 const char *to_encoding_name = stmt->to_encoding_name;
43 List *func_name = stmt->func_name;
44 static const Oid funcargs[] = {INT4OID, INT4OID, CSTRINGOID, INTERNALOID, INT4OID, BOOLOID};
45 char result[1];
46 Datum funcresult;
47
48 /* Convert list of names to a name and namespace */
49 namespaceId = QualifiedNameGetCreationNamespace(stmt->conversion_name,
50 &conversion_name);
51
52 /* Check we have creation rights in target namespace */
53 aclresult = object_aclcheck(NamespaceRelationId, namespaceId, GetUserId(), ACL_CREATE);
54 if (aclresult != ACLCHECK_OK)
55 aclcheck_error(aclresult, OBJECT_SCHEMA,
56 get_namespace_name(namespaceId));
57
58 /* Check the encoding names */
59 from_encoding = pg_char_to_encoding(from_encoding_name);
60 if (from_encoding < 0)
61 ereport(ERROR,
62 (errcode(ERRCODE_UNDEFINED_OBJECT),
63 errmsg("source encoding \"%s\" does not exist",
64 from_encoding_name)));
65
66 to_encoding = pg_char_to_encoding(to_encoding_name);
67 if (to_encoding < 0)
68 ereport(ERROR,
69 (errcode(ERRCODE_UNDEFINED_OBJECT),
70 errmsg("destination encoding \"%s\" does not exist",
71 to_encoding_name)));
72
73 /*
74 * We consider conversions to or from SQL_ASCII to be meaningless. (If
75 * you wish to change this, note that pg_do_encoding_conversion() and its
76 * sister functions have hard-wired fast paths for any conversion in which
77 * the source or target encoding is SQL_ASCII, so that an encoding
78 * conversion function declared for such a case will never be used.)
79 */
80 if (from_encoding == PG_SQL_ASCII || to_encoding == PG_SQL_ASCII)
81 ereport(ERROR,
82 (errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
83 errmsg("encoding conversion to or from \"SQL_ASCII\" is not supported")));
84
85 /*
86 * Check the existence of the conversion function. Function name could be
87 * a qualified name.
88 */
89 funcoid = LookupFuncName(func_name, sizeof(funcargs) / sizeof(Oid),
90 funcargs, false);
91
92 /* Check it returns int4, else it's probably the wrong function */
93 if (get_func_rettype(funcoid) != INT4OID)
94 ereport(ERROR,
95 (errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
96 errmsg("encoding conversion function %s must return type %s",
97 NameListToString(func_name), "integer")));
98
99 /* Check we have EXECUTE rights for the function */
100 aclresult = object_aclcheck(ProcedureRelationId, funcoid, GetUserId(), ACL_EXECUTE);
101 if (aclresult != ACLCHECK_OK)
102 aclcheck_error(aclresult, OBJECT_FUNCTION,
103 NameListToString(func_name));
104
105 /*
106 * Check that the conversion function is suitable for the requested source
107 * and target encodings. We do that by calling the function with an empty
108 * string; the conversion function should throw an error if it can't
109 * perform the requested conversion.
110 */
111 funcresult = OidFunctionCall6(funcoid,
112 Int32GetDatum(from_encoding),
113 Int32GetDatum(to_encoding),
114 CStringGetDatum(""),
115 CStringGetDatum(result),
116 Int32GetDatum(0),
117 BoolGetDatum(false));
118
119 /*
120 * The function should return 0 for empty input. Might as well check that,
121 * too.
122 */
123 if (DatumGetInt32(funcresult) != 0)
124 ereport(ERROR,
125 (errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
126 errmsg("encoding conversion function %s returned incorrect result for empty input",
127 NameListToString(func_name))));
128
129 /*
130 * All seem ok, go ahead (possible failure would be a duplicate conversion
131 * name)
132 */
133 return ConversionCreate(conversion_name, namespaceId, GetUserId(),
134 from_encoding, to_encoding, funcoid, stmt->def);
135}
AclResult
AclResult
Definition acl.h:183
ACLCHECK_OK
@ ACLCHECK_OK
Definition acl.h:184
aclcheck_error
void aclcheck_error(AclResult aclerr, ObjectType objtype, const char *objectname)
Definition aclchk.c:2672
object_aclcheck
AclResult object_aclcheck(Oid classid, Oid objectid, Oid roleid, AclMode mode)
Definition aclchk.c:3879
result
uint32 result
Definition checksum_block_internal.h:18
errcode
int errcode(int sqlerrcode)
Definition elog.c:874
ERROR
#define ERROR
Definition elog.h:40
ereport
#define ereport(elevel,...)
Definition elog.h:152
OidFunctionCall6
#define OidFunctionCall6(functionId, arg1, arg2, arg3, arg4, arg5, arg6)
Definition fmgr.h:732
stmt
#define stmt
Definition indent_codes.h:59
get_namespace_name
char * get_namespace_name(Oid nspid)
Definition lsyscache.c:3588
get_func_rettype
Oid get_func_rettype(Oid funcid)
Definition lsyscache.c:1875
GetUserId
Oid GetUserId(void)
Definition miscinit.c:470
NameListToString
char * NameListToString(const List *names)
Definition namespace.c:3666
QualifiedNameGetCreationNamespace
Oid QualifiedNameGetCreationNamespace(const List *names, char **objname_p)
Definition namespace.c:3559
errmsg
static char * errmsg
Definition oauth_hook_client.c:61
LookupFuncName
Oid LookupFuncName(List *funcname, int nargs, const Oid *argtypes, bool missing_ok)
Definition parse_func.c:2269
OBJECT_SCHEMA
@ OBJECT_SCHEMA
Definition parsenodes.h:2468
OBJECT_FUNCTION
@ OBJECT_FUNCTION
Definition parsenodes.h:2450
ACL_EXECUTE
#define ACL_EXECUTE
Definition parsenodes.h:83
ACL_CREATE
#define ACL_CREATE
Definition parsenodes.h:85
ConversionCreate
ObjectAddress ConversionCreate(const char *conname, Oid connamespace, Oid conowner, int32 conforencoding, int32 contoencoding, Oid conproc, bool def)
Definition pg_conversion.c:38
PG_SQL_ASCII
@ PG_SQL_ASCII
Definition pg_wchar.h:76
pg_char_to_encoding
#define pg_char_to_encoding
Definition pg_wchar.h:482
BoolGetDatum
static Datum BoolGetDatum(bool X)
Definition postgres.h:112
Datum
uint64_t Datum
Definition postgres.h:70
CStringGetDatum
static Datum CStringGetDatum(const char *X)
Definition postgres.h:370
Int32GetDatum
static Datum Int32GetDatum(int32 X)
Definition postgres.h:212
DatumGetInt32
static int32 DatumGetInt32(Datum X)
Definition postgres.h:202
Oid
unsigned int Oid
Definition postgres_ext.h:32
fb
static int fb(int x)
Definition preproc-init.c:92
List
Definition pg_list.h:54

References ACL_CREATE, ACL_EXECUTE, aclcheck_error(), ACLCHECK_OK, BoolGetDatum(), ConversionCreate(), CStringGetDatum(), DatumGetInt32(), ereport, errcode(), errmsg, ERROR, fb(), get_func_rettype(), get_namespace_name(), GetUserId(), Int32GetDatum(), LookupFuncName(), NameListToString(), object_aclcheck(), OBJECT_FUNCTION, OBJECT_SCHEMA, OidFunctionCall6, pg_char_to_encoding, PG_SQL_ASCII, QualifiedNameGetCreationNamespace(), result, and stmt.

Referenced by ProcessUtilitySlow().