89 Oid *prorettype_p,
bool *returnsSet_p)
101 if (languageOid == SQLlanguageId)
103 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
104 errmsg(
"SQL function cannot return shell type %s",
108 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
109 errmsg(
"return type %s is only a shell",
128 if (languageOid != INTERNALlanguageId &&
129 languageOid != ClanguageId)
131 (
errcode(ERRCODE_UNDEFINED_OBJECT),
132 errmsg(
"type \"%s\" does not exist", typnam)));
137 (
errcode(ERRCODE_SYNTAX_ERROR),
138 errmsg(
"type modifier cannot be specified for shell type \"%s\"",
143 (
errcode(ERRCODE_UNDEFINED_OBJECT),
144 errmsg(
"type \"%s\" is not yet defined", typnam),
145 errdetail(
"Creating a shell type definition.")));
162 *prorettype_p = rettype;
163 *returnsSet_p = returnType->
setof;
188 List **parameterTypes_list,
192 List **inParameterNames_list,
193 List **parameterDefaults,
194 Oid *variadicArgType,
195 Oid *requiredResultType)
205 bool have_names =
false;
206 bool have_defaults =
false;
217 *parameterDefaults =
NIL;
221 foreach(
x, parameters)
226 bool isinput =
false;
241 if (languageOid == SQLlanguageId)
243 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
244 errmsg(
"SQL function cannot accept shell type %s",
249 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
250 errmsg(
"aggregate cannot accept shell type %s",
254 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
255 errmsg(
"argument type %s is only a shell",
264 (
errcode(ERRCODE_UNDEFINED_OBJECT),
265 errmsg(
"type %s does not exist",
278 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
279 errmsg(
"aggregates cannot accept set arguments")));
282 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
283 errmsg(
"procedures cannot accept set arguments")));
286 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
287 errmsg(
"functions cannot accept set arguments")));
296 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
297 errmsg(
"VARIADIC parameter must be the last input parameter")));
298 inTypes[inCount++] = toid;
300 if (parameterTypes_list)
301 *parameterTypes_list =
lappend_oid(*parameterTypes_list, toid);
316 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
317 errmsg(
"VARIADIC parameter must be the last parameter")));
319 *requiredResultType = RECORDOID;
321 else if (outCount == 0)
322 *requiredResultType = toid;
328 *variadicArgType = toid;
334 case ANYCOMPATIBLEARRAYOID:
341 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
342 errmsg(
"VARIADIC parameter must be an array")));
361 foreach(
px, parameters)
369 prevfpmode = prevfp->
mode;
383 if (prevfp->
name && prevfp->
name[0] &&
384 strcmp(prevfp->
name, fp->
name) == 0)
386 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
387 errmsg(
"parameter name \"%s\" used more than once",
395 if (inParameterNames_list)
404 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
405 errmsg(
"only input parameters can have default values")));
419 (
errcode(ERRCODE_INVALID_COLUMN_REFERENCE),
420 errmsg(
"cannot use table references in parameter default value")));
436 *parameterDefaults =
lappend(*parameterDefaults, def);
437 have_defaults =
true;
441 if (isinput && have_defaults)
443 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
444 errmsg(
"input parameters after one with a default value must also have defaults")));
453 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
454 errmsg(
"procedure OUT parameters cannot appear after one with a default value")));
463 if (outCount > 0 || varCount > 0)
468 *requiredResultType = RECORDOID;
473 *allParameterTypes = NULL;
474 *parameterModes = NULL;
479 for (
i = 0;
i < parameterCount;
i++)
487 *parameterNames = NULL;
513 if (strcmp(defel->
defname,
"volatility") == 0)
516 goto procedure_error;
517 if (*volatility_item)
520 *volatility_item = defel;
522 else if (strcmp(defel->
defname,
"strict") == 0)
525 goto procedure_error;
529 *strict_item = defel;
531 else if (strcmp(defel->
defname,
"security") == 0)
536 *security_item = defel;
538 else if (strcmp(defel->
defname,
"leakproof") == 0)
541 goto procedure_error;
545 *leakproof_item = defel;
547 else if (strcmp(defel->
defname,
"set") == 0)
551 else if (strcmp(defel->
defname,
"cost") == 0)
554 goto procedure_error;
560 else if (strcmp(defel->
defname,
"rows") == 0)
563 goto procedure_error;
569 else if (strcmp(defel->
defname,
"support") == 0)
572 goto procedure_error;
576 *support_item = defel;
578 else if (strcmp(defel->
defname,
"parallel") == 0)
581 goto procedure_error;
585 *parallel_item = defel;
595 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
596 errmsg(
"invalid attribute in procedure definition"),
606 if (strcmp(
str,
"immutable") == 0)
607 return PROVOLATILE_IMMUTABLE;
608 else if (strcmp(
str,
"stable") == 0)
609 return PROVOLATILE_STABLE;
610 else if (strcmp(
str,
"volatile") == 0)
611 return PROVOLATILE_VOLATILE;
624 if (strcmp(
str,
"safe") == 0)
625 return PROPARALLEL_SAFE;
626 else if (strcmp(
str,
"unsafe") == 0)
627 return PROPARALLEL_UNSAFE;
628 else if (strcmp(
str,
"restricted") == 0)
629 return PROPARALLEL_RESTRICTED;
633 (
errcode(ERRCODE_SYNTAX_ERROR),
634 errmsg(
"parameter \"parallel\" must be SAFE, RESTRICTED, or UNSAFE")));
635 return PROPARALLEL_UNSAFE;
649 foreach(l, set_items)
680 argList[0] = INTERNALOID;
685 (
errcode(ERRCODE_UNDEFINED_FUNCTION),
686 errmsg(
"function %s does not exist",
691 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
692 errmsg(
"support function %s must return type %s",
702 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
703 errmsg(
"must be superuser to specify a support function")));
723 bool *security_definer,
734 DefElem *transform_item = NULL;
735 DefElem *windowfunc_item = NULL;
736 DefElem *volatility_item = NULL;
739 DefElem *leakproof_item = NULL;
750 if (strcmp(defel->
defname,
"as") == 0)
756 else if (strcmp(defel->
defname,
"language") == 0)
760 language_item = defel;
762 else if (strcmp(defel->
defname,
"transform") == 0)
766 transform_item = defel;
768 else if (strcmp(defel->
defname,
"window") == 0)
774 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
775 errmsg(
"invalid attribute in procedure definition"),
777 windowfunc_item = defel;
796 elog(
ERROR,
"option \"%s\" not recognized",
805 *transform = transform_item->
arg;
807 *windowfunc_p =
boolVal(windowfunc_item->
arg);
813 *security_definer =
boolVal(security_item->
arg);
823 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
824 errmsg(
"COST must be positive")));
831 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
832 errmsg(
"ROWS must be positive")));
853 List *parameterTypes,
List *inParameterNames,
854 char **prosrc_str_p,
char **probin_str_p,
856 const char *queryString)
858 if (!sql_body_in && !as)
860 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
861 errmsg(
"no function body specified")));
863 if (sql_body_in && as)
865 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
866 errmsg(
"duplicate function body specified")));
868 if (sql_body_in && languageOid != SQLlanguageId)
870 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
871 errmsg(
"inline SQL function body only valid for language SQL")));
873 *sql_body_out = NULL;
875 if (languageOid == ClanguageId)
891 if (strcmp(*prosrc_str_p,
"-") == 0)
895 else if (sql_body_in)
910 if (IsPolymorphicType(pinfo->
argtypes[
i]))
912 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
913 errmsg(
"SQL function with unquoted function body cannot have polymorphic arguments")));
938 errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
939 errmsg(
"%s is not yet supported in unquoted SQL function body",
941 transformed_stmts =
lappend(transformed_stmts, q);
957 errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
958 errmsg(
"%s is not yet supported in unquoted SQL function body",
962 *sql_body_out = (
Node *) q;
975 *probin_str_p = NULL;
981 *probin_str_p = NULL;
985 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
986 errmsg(
"only one AS item needed for language \"%s\"",
989 if (languageOid == INTERNALlanguageId)
999 if (strlen(*prosrc_str_p) == 0)
1020 Oid languageValidator;
1021 Node *transformDefElem = NULL;
1026 List *parameterTypes_list =
NIL;
1030 List *inParameterNames_list =
NIL;
1031 List *parameterDefaults;
1032 Oid variadicArgType;
1035 Oid requiredResultType;
1063 isWindowFunc =
false;
1066 isLeakProof =
false;
1067 volatility = PROVOLATILE_VOLATILE;
1072 parallel = PROPARALLEL_UNSAFE;
1078 &as_clause, &language, &transformDefElem,
1079 &isWindowFunc, &volatility,
1080 &isStrict, &security, &isLeakProof,
1081 &proconfig, &procost, &prorows,
1082 &prosupport, ¶llel);
1090 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
1091 errmsg(
"no language specified")));
1098 (
errcode(ERRCODE_UNDEFINED_OBJECT),
1099 errmsg(
"language \"%s\" does not exist", language),
1101 errhint(
"Use CREATE EXTENSION to load the language into the database.") : 0)));
1104 languageOid = languageStruct->oid;
1106 if (languageStruct->lanpltrusted)
1112 NameStr(languageStruct->lanname));
1119 NameStr(languageStruct->lanname));
1122 languageValidator = languageStruct->lanvalidator;
1133 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
1134 errmsg(
"only superuser can define a leakproof function")));
1136 if (transformDefElem)
1146 typeid = elt ? elt :
typeid;
1149 trftypes_list =
lappend_oid(trftypes_list,
typeid);
1162 ¶meterTypes_list,
1166 &inParameterNames_list,
1169 &requiredResultType);
1171 if (
stmt->is_procedure)
1174 prorettype = requiredResultType ? requiredResultType : VOIDOID;
1177 else if (
stmt->returnType)
1181 &prorettype, &returnsSet);
1182 if (
OidIsValid(requiredResultType) && prorettype != requiredResultType)
1184 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
1185 errmsg(
"function result type must be %s because of OUT parameters",
1191 prorettype = requiredResultType;
1197 (
errcode(ERRCODE_INVALID_FUNCTION_DEFINITION),
1198 errmsg(
"function result type must be specified")));
1200 prorettype = VOIDOID;
1204 if (trftypes_list !=
NIL)
1212 foreach(lc, trftypes_list)
1223 parameterTypes_list, inParameterNames_list,
1224 &prosrc_str, &probin_str, &prosqlbody,
1235 if (languageOid == INTERNALlanguageId ||
1236 languageOid == ClanguageId)
1248 else if (!returnsSet)
1250 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1251 errmsg(
"ROWS is not applicable when function does not return a set")));
1268 stmt->is_procedure ? PROKIND_PROCEDURE : (isWindowFunc ? PROKIND_WINDOW : PROKIND_FUNCTION),
1306 elog(
ERROR,
"cache lookup failed for function %u", funcOid);
1321 if (prokind == PROKIND_AGGREGATE)
1327 elog(
ERROR,
"cache lookup failed for pg_aggregate tuple for function %u", funcOid);
1351 DefElem *volatility_item = NULL;
1353 DefElem *security_def_item = NULL;
1354 DefElem *leakproof_item = NULL;
1359 DefElem *parallel_item = NULL;
1370 elog(
ERROR,
"cache lookup failed for function %u", funcOid);
1379 if (procForm->prokind == PROKIND_AGGREGATE)
1381 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1382 errmsg(
"\"%s\" is an aggregate function",
1385 is_procedure = (procForm->prokind == PROKIND_PROCEDURE);
1388 foreach(l,
stmt->actions)
1403 ¶llel_item) ==
false)
1407 if (volatility_item)
1410 procForm->proisstrict =
boolVal(strict_item->
arg);
1411 if (security_def_item)
1412 procForm->prosecdef =
boolVal(security_def_item->
arg);
1415 procForm->proleakproof =
boolVal(leakproof_item->
arg);
1416 if (procForm->proleakproof && !
superuser())
1418 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
1419 errmsg(
"only superuser can define a leakproof function")));
1424 if (procForm->procost <= 0)
1426 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1427 errmsg(
"COST must be positive")));
1432 if (procForm->prorows <= 0)
1434 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1435 errmsg(
"ROWS must be positive")));
1436 if (!procForm->proretset)
1438 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1439 errmsg(
"ROWS is not applicable when function does not return a set")));
1450 ProcedureRelationId, procForm->prosupport,
1452 elog(
ERROR,
"could not change support dependency for function %s",
1459 referenced.
classId = ProcedureRelationId;
1465 procForm->prosupport = newsupport;
1474 Datum repl_val[Natts_pg_proc];
1475 bool repl_null[Natts_pg_proc];
1476 bool repl_repl[Natts_pg_proc];
1479 datum =
SysCacheGetAttr(PROCOID, tup, Anum_pg_proc_proconfig, &isnull);
1486 memset(repl_repl,
false,
sizeof(repl_repl));
1487 repl_repl[Anum_pg_proc_proconfig - 1] =
true;
1491 repl_val[Anum_pg_proc_proconfig - 1] = (
Datum) 0;
1492 repl_null[Anum_pg_proc_proconfig - 1] =
true;
1497 repl_null[Anum_pg_proc_proconfig - 1] =
false;
1501 repl_val, repl_null, repl_repl);
1543 if (sourcetyptype == TYPTYPE_PSEUDO)
1545 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1546 errmsg(
"source data type %s is a pseudo-type",
1549 if (targettyptype == TYPTYPE_PSEUDO)
1551 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1552 errmsg(
"target data type %s is a pseudo-type",
1559 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
1560 errmsg(
"must be owner of type %s or type %s",
1573 if (sourcetyptype == TYPTYPE_DOMAIN)
1575 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1576 errmsg(
"cast will be ignored because the source data type is a domain")));
1578 else if (targettyptype == TYPTYPE_DOMAIN)
1580 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1581 errmsg(
"cast will be ignored because the target data type is a domain")));
1584 if (
stmt->func != NULL)
1585 castmethod = COERCION_METHOD_FUNCTION;
1586 else if (
stmt->inout)
1587 castmethod = COERCION_METHOD_INOUT;
1589 castmethod = COERCION_METHOD_BINARY;
1591 if (castmethod == COERCION_METHOD_FUNCTION)
1599 elog(
ERROR,
"cache lookup failed for function %u", funcid);
1602 nargs = procstruct->pronargs;
1603 if (nargs < 1 || nargs > 3)
1605 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1606 errmsg(
"cast function must take one to three arguments")));
1608 procstruct->proargtypes.values[0],
1611 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1612 errmsg(
"argument of cast function must match or be binary-coercible from source data type")));
1613 if (nargs > 1 && procstruct->proargtypes.values[1] != INT4OID)
1615 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1616 errmsg(
"second argument of cast function must be type %s",
1618 if (nargs > 2 && procstruct->proargtypes.values[2] != BOOLOID)
1620 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1621 errmsg(
"third argument of cast function must be type %s",
1627 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1628 errmsg(
"return data type of cast function must match or be binary-coercible to target data type")));
1636 if (procstruct->provolatile == PROVOLATILE_VOLATILE)
1638 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1639 errmsg(
"cast function must not be volatile")));
1641 if (procstruct->prokind != PROKIND_FUNCTION)
1643 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1644 errmsg(
"cast function must be a normal function")));
1645 if (procstruct->proretset)
1647 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1648 errmsg(
"cast function must not return a set")));
1658 if (castmethod == COERCION_METHOD_BINARY)
1673 (
errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
1674 errmsg(
"must be superuser to create a cast WITHOUT FUNCTION")));
1684 if (typ1len != typ2len ||
1685 typ1byval != typ2byval ||
1686 typ1align != typ2align)
1688 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1689 errmsg(
"source and target data types are not physically compatible")));
1705 if (sourcetyptype == TYPTYPE_COMPOSITE ||
1706 targettyptype == TYPTYPE_COMPOSITE)
1708 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1709 errmsg(
"composite data types are not binary-compatible")));
1714 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1715 errmsg(
"array data types are not binary-compatible")));
1717 if (sourcetyptype == TYPTYPE_RANGE ||
1718 targettyptype == TYPTYPE_RANGE ||
1719 sourcetyptype == TYPTYPE_MULTIRANGE ||
1720 targettyptype == TYPTYPE_MULTIRANGE)
1722 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1723 errmsg(
"range data types are not binary-compatible")));
1725 if (sourcetyptype == TYPTYPE_ENUM ||
1726 targettyptype == TYPTYPE_ENUM)
1728 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1729 errmsg(
"enum data types are not binary-compatible")));
1742 if (sourcetyptype == TYPTYPE_DOMAIN ||
1743 targettyptype == TYPTYPE_DOMAIN)
1745 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1746 errmsg(
"domain data types must not be marked binary-compatible")));
1753 if (sourcetypeid == targettypeid && nargs < 2)
1755 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1756 errmsg(
"source data type and target data type are the same")));
1759 switch (
stmt->context)
1762 castcontext = COERCION_CODE_IMPLICIT;
1765 castcontext = COERCION_CODE_ASSIGNMENT;
1769 castcontext = COERCION_CODE_EXPLICIT;
1772 elog(
ERROR,
"unrecognized CoercionContext: %d",
stmt->context);
1777 myself =
CastCreate(sourcetypeid, targettypeid, funcid, incastid, outcastid,
1786 if (procstruct->provolatile == PROVOLATILE_VOLATILE)
1788 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1789 errmsg(
"transform function must not be volatile")));
1790 if (procstruct->prokind != PROKIND_FUNCTION)
1792 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1793 errmsg(
"transform function must be a normal function")));
1794 if (procstruct->proretset)
1796 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1797 errmsg(
"transform function must not return a set")));
1798 if (procstruct->pronargs != 1)
1800 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1801 errmsg(
"transform function must take one argument")));
1802 if (procstruct->proargtypes.values[0] != INTERNALOID)
1804 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1805 errmsg(
"first argument of transform function must be type %s",
1824 bool nulls[Natts_pg_transform] = {0};
1825 bool replaces[Natts_pg_transform] = {0};
1841 if (typtype == TYPTYPE_PSEUDO)
1843 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1844 errmsg(
"data type %s is a pseudo-type",
1847 if (typtype == TYPTYPE_DOMAIN)
1849 (
errcode(ERRCODE_WRONG_OBJECT_TYPE),
1850 errmsg(
"data type %s is a domain",
1885 elog(
ERROR,
"cache lookup failed for function %u", fromsqlfuncid);
1887 if (procstruct->prorettype != INTERNALOID)
1889 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1890 errmsg(
"return data type of FROM SQL function must be %s",
1911 elog(
ERROR,
"cache lookup failed for function %u", tosqlfuncid);
1913 if (procstruct->prorettype !=
typeid)
1915 (
errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1916 errmsg(
"return data type of TO SQL function must be the transform data type")));
1943 errmsg(
"transform for type %s language \"%s\" already exists",
1947 replaces[Anum_pg_transform_trffromsql - 1] =
true;
1948 replaces[Anum_pg_transform_trftosql - 1] =
true;
1953 transformid = form->oid;
1960 Anum_pg_transform_oid);
2028 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2029 errmsg(
"transform for type %s language \"%s\" does not exist",
2052 (
errcode(ERRCODE_DUPLICATE_FUNCTION),
2053 errmsg(
"function %s already exists in schema \"%s\"",
2071 DefElem *language_item = NULL;
2082 if (strcmp(defel->
defname,
"as") == 0)
2088 else if (strcmp(defel->
defname,
"language") == 0)
2092 language_item = defel;
2095 elog(
ERROR,
"option \"%s\" not recognized",
2103 (
errcode(ERRCODE_SYNTAX_ERROR),
2104 errmsg(
"no inline code specified")));
2110 language =
"plpgsql";
2116 (
errcode(ERRCODE_UNDEFINED_OBJECT),
2117 errmsg(
"language \"%s\" does not exist", language),
2119 errhint(
"Use CREATE EXTENSION to load the language into the database.") : 0)));
2122 codeblock->
langOid = languageStruct->oid;
2124 codeblock->
atomic = atomic;
2126 if (languageStruct->lanpltrusted)
2135 NameStr(languageStruct->lanname));
2142 NameStr(languageStruct->lanname));
2146 laninline = languageStruct->laninline;
2149 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
2150 errmsg(
"language \"%s\" does not support inline code execution",
2151 NameStr(languageStruct->lanname))));
2204 fexpr =
stmt->funcexpr;
2214 callcontext->
atomic = atomic;
2227 callcontext->
atomic =
true;
2236 callcontext->
atomic =
true;
2244 (
errcode(ERRCODE_TOO_MANY_ARGUMENTS),
2245 errmsg_plural(
"cannot pass more than %d argument to a procedure",
2246 "cannot pass more than %d arguments to a procedure",
2255 (
Node *) callcontext, NULL);
2276 foreach(lc, fexpr->
args)
2286 fcinfo->args[
i].value =
val;
2287 fcinfo->args[
i].isnull = isnull;
2302 if (fexpr->funcresulttype == VOIDOID)
2306 else if (fexpr->funcresulttype == RECORDOID)
2318 elog(
ERROR,
"procedure returned null record");
2355 elog(
ERROR,
"unexpected result type for procedure: %u",
2356 fexpr->funcresulttype);
2371 fexpr =
stmt->funcexpr;
2394 for (
int i = 0;
i < tupdesc->
natts;
i++)
void aclcheck_error(AclResult aclerr, ObjectType objtype, const char *objectname)
AclResult object_aclcheck(Oid classid, Oid objectid, Oid roleid, AclMode mode)
bool object_ownercheck(Oid classid, Oid objectid, Oid roleid)
void aclcheck_error_type(AclResult aclerr, Oid typeOid)
#define DatumGetArrayTypeP(X)
ArrayType * construct_array_builtin(Datum *elems, int nelems, Oid elmtype)
static Datum values[MAXATTR]
#define CStringGetTextDatum(s)
#define Assert(condition)
#define OidIsValid(objectId)
Oid GetNewOidWithIndex(Relation relation, Oid indexId, AttrNumber oidcolumn)
const char * GetCommandTagName(CommandTag commandTag)
List * defGetQualifiedName(DefElem *def)
void errorConflictingDefElem(DefElem *defel, ParseState *pstate)
double defGetNumeric(DefElem *def)
void record_object_address_dependencies(const ObjectAddress *depender, ObjectAddresses *referenced, DependencyType behavior)
ObjectAddresses * new_object_addresses(void)
void add_exact_object_address(const ObjectAddress *object, ObjectAddresses *addrs)
void free_object_addresses(ObjectAddresses *addrs)
int errmsg_plural(const char *fmt_singular, const char *fmt_plural, unsigned long n,...)
int errdetail(const char *fmt,...)
int errhint(const char *fmt,...)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
ExprState * ExecPrepareExpr(Expr *node, EState *estate)
void end_tup_output(TupOutputState *tstate)
TupleTableSlot * ExecStoreHeapTuple(HeapTuple tuple, TupleTableSlot *slot, bool shouldFree)
const TupleTableSlotOps TTSOpsHeapTuple
TupOutputState * begin_tup_output_tupdesc(DestReceiver *dest, TupleDesc tupdesc, const TupleTableSlotOps *tts_ops)
EState * CreateExecutorState(void)
ExprContext * CreateExprContext(EState *estate)
void FreeExecutorState(EState *estate)
static Datum ExecEvalExprSwitchContext(ExprState *state, ExprContext *econtext, bool *isNull)
bool extension_file_exists(const char *extensionName)
void fmgr_info(Oid functionId, FmgrInfo *finfo)
#define OidFunctionCall1(functionId, arg1)
#define DatumGetHeapTupleHeader(X)
#define InitFunctionCallInfoData(Fcinfo, Flinfo, Nargs, Collation, Context, Resultinfo)
#define LOCAL_FCINFO(name, nargs)
#define FunctionCallInvoke(fcinfo)
#define fmgr_info_set_expr(expr, finfo)
TupleDesc build_function_result_tupdesc_t(HeapTuple procTuple)
void ExecuteCallStmt(CallStmt *stmt, ParamListInfo params, bool atomic, DestReceiver *dest)
ObjectAddress CreateCast(CreateCastStmt *stmt)
static ArrayType * update_proconfig_value(ArrayType *a, List *set_items)
static void compute_return_type(TypeName *returnType, Oid languageOid, Oid *prorettype_p, bool *returnsSet_p)
static Oid interpret_func_support(DefElem *defel)
static void compute_function_attributes(ParseState *pstate, bool is_procedure, List *options, List **as, char **language, Node **transform, bool *windowfunc_p, char *volatility_p, bool *strict_p, bool *security_definer, bool *leakproof_p, ArrayType **proconfig, float4 *procost, float4 *prorows, Oid *prosupport, char *parallel_p)
void interpret_function_parameter_list(ParseState *pstate, List *parameters, Oid languageOid, ObjectType objtype, oidvector **parameterTypes, List **parameterTypes_list, ArrayType **allParameterTypes, ArrayType **parameterModes, ArrayType **parameterNames, List **inParameterNames_list, List **parameterDefaults, Oid *variadicArgType, Oid *requiredResultType)
static bool compute_common_attribute(ParseState *pstate, bool is_procedure, DefElem *defel, DefElem **volatility_item, DefElem **strict_item, DefElem **security_item, DefElem **leakproof_item, List **set_items, DefElem **cost_item, DefElem **rows_item, DefElem **support_item, DefElem **parallel_item)
static char interpret_func_volatility(DefElem *defel)
ObjectAddress CreateFunction(ParseState *pstate, CreateFunctionStmt *stmt)
void IsThereFunctionInNamespace(const char *proname, int pronargs, oidvector *proargtypes, Oid nspOid)
ObjectAddress AlterFunction(ParseState *pstate, AlterFunctionStmt *stmt)
TupleDesc CallStmtResultDesc(CallStmt *stmt)
static void interpret_AS_clause(Oid languageOid, const char *languageName, char *funcname, List *as, Node *sql_body_in, List *parameterTypes, List *inParameterNames, char **prosrc_str_p, char **probin_str_p, Node **sql_body_out, const char *queryString)
Oid get_transform_oid(Oid type_id, Oid lang_id, bool missing_ok)
void ExecuteDoStmt(ParseState *pstate, DoStmt *stmt, bool atomic)
static void check_transform_function(Form_pg_proc procstruct)
ObjectAddress CreateTransform(CreateTransformStmt *stmt)
void RemoveFunctionById(Oid funcOid)
static char interpret_func_parallel(DefElem *defel)
void sql_fn_parser_setup(struct ParseState *pstate, SQLFunctionParseInfoPtr pinfo)
SQLFunctionParseInfo * SQLFunctionParseInfoPtr
void px(PlannerInfo *root, Gene *tour1, Gene *tour2, Gene *offspring, int num_gene, City *city_table)
ArrayType * GUCArrayAdd(ArrayType *array, const char *name, const char *value)
ArrayType * GUCArrayDelete(ArrayType *array, const char *name)
char * ExtractSetVariableArgs(VariableSetStmt *stmt)
HeapTuple heap_modify_tuple(HeapTuple tuple, TupleDesc tupleDesc, const Datum *replValues, const bool *replIsnull, const bool *doReplace)
HeapTuple heap_form_tuple(TupleDesc tupleDescriptor, const Datum *values, const bool *isnull)
bool heap_attisnull(HeapTuple tup, int attnum, TupleDesc tupleDesc)
void heap_freetuple(HeapTuple htup)
#define HeapTupleIsValid(tuple)
#define HeapTupleHeaderGetTypMod(tup)
#define HeapTupleHeaderGetTypeId(tup)
#define HeapTupleHeaderGetDatumLength(tup)
void CatalogTupleUpdate(Relation heapRel, ItemPointer otid, HeapTuple tup)
void CatalogTupleInsert(Relation heapRel, HeapTuple tup)
void CatalogTupleDelete(Relation heapRel, ItemPointer tid)
if(TABLE==NULL||TABLE_index==NULL)
static void ItemPointerSetInvalid(ItemPointerData *pointer)
List * lappend(List *list, void *datum)
List * lappend_oid(List *list, Oid datum)
char * get_language_name(Oid langoid, bool missing_ok)
Oid get_element_type(Oid typid)
char * get_namespace_name(Oid nspid)
void get_typlenbyvalalign(Oid typid, int16 *typlen, bool *typbyval, char *typalign)
char * get_func_name(Oid funcid)
char get_typtype(Oid typid)
Oid get_base_element_type(Oid typid)
Oid get_func_rettype(Oid funcid)
char * pstrdup(const char *in)
void * palloc0(Size size)
Oid QualifiedNameGetCreationNamespace(const List *names, char **objname_p)
char * NameListToString(const List *names)
Oid exprType(const Node *expr)
#define IsA(nodeptr, _type_)
#define castNode(_type_, nodeptr)
#define InvokeObjectPostCreateHook(classId, objectId, subId)
#define InvokeObjectPostAlterHook(classId, objectId, subId)
#define InvokeFunctionExecuteHook(objectId)
#define ObjectAddressSet(addr, class_id, object_id)
oidvector * buildoidvector(const Oid *oids, int n)
Node * coerce_to_specific_type(ParseState *pstate, Node *node, Oid targetTypeId, const char *constructName)
bool IsBinaryCoercibleWithCast(Oid srctype, Oid targettype, Oid *castoid)
void assign_expr_collations(ParseState *pstate, Node *expr)
Node * transformExpr(ParseState *pstate, Node *expr, ParseExprKind exprKind)
const char * func_signature_string(List *funcname, int nargs, List *argnames, const Oid *argtypes)
Oid LookupFuncWithArgs(ObjectType objtype, ObjectWithArgs *func, bool missing_ok)
const char * funcname_signature_string(const char *funcname, int nargs, List *argnames, const Oid *argtypes)
Oid LookupFuncName(List *funcname, int nargs, const Oid *argtypes, bool missing_ok)
void free_parsestate(ParseState *pstate)
int parser_errposition(ParseState *pstate, int location)
ParseState * make_parsestate(ParseState *parentParseState)
@ EXPR_KIND_FUNCTION_DEFAULT
Type LookupTypeName(ParseState *pstate, const TypeName *typeName, int32 *typmod_p, bool missing_ok)
char * TypeNameToString(const TypeName *typeName)
Oid typenameTypeId(ParseState *pstate, const TypeName *typeName)
Query * transformStmt(ParseState *pstate, Node *parseTree)
FormData_pg_attribute * Form_pg_attribute
ObjectAddress CastCreate(Oid sourcetypeid, Oid targettypeid, Oid funcid, Oid incastid, Oid outcastid, char castcontext, char castmethod, DependencyType behavior)
void recordDependencyOn(const ObjectAddress *depender, const ObjectAddress *referenced, DependencyType behavior)
long changeDependencyFor(Oid classId, Oid objectId, Oid refClassId, Oid oldRefObjectId, Oid newRefObjectId)
long deleteDependencyRecordsFor(Oid classId, Oid objectId, bool skipExtensionDeps)
void recordDependencyOnCurrentExtension(const ObjectAddress *object, bool isReplace)
FormData_pg_language * Form_pg_language
#define lfirst_node(type, lc)
static int list_length(const List *l)
#define linitial_node(type, l)
static Oid list_nth_oid(const List *list, int n)
static void * list_nth(const List *list, int n)
ObjectAddress ProcedureCreate(const char *procedureName, Oid procNamespace, bool replace, bool returnsSet, Oid returnType, Oid proowner, Oid languageObjectId, Oid languageValidator, const char *prosrc, const char *probin, Node *prosqlbody, char prokind, bool security_definer, bool isLeakProof, bool isStrict, char volatility, char parallel, oidvector *parameterTypes, Datum allParameterTypes, Datum parameterModes, Datum parameterNames, List *parameterDefaults, Datum trftypes, Datum proconfig, Oid prosupport, float4 procost, float4 prorows)
FormData_pg_proc * Form_pg_proc
ObjectAddress TypeShellMake(const char *typeName, Oid typeNamespace, Oid ownerId)
FormData_pg_type * Form_pg_type
void pgstat_drop_function(Oid proid)
void pgstat_init_function_usage(FunctionCallInfo fcinfo, PgStat_FunctionCallUsage *fcu)
void pgstat_end_function_usage(PgStat_FunctionCallUsage *fcu, bool finalize)
static Datum PointerGetDatum(const void *X)
static Datum ObjectIdGetDatum(Oid X)
static Datum CStringGetDatum(const char *X)
static Datum CharGetDatum(char X)
void EnsurePortalSnapshotExists(void)
Oid get_language_oid(const char *langname, bool missing_ok)
#define RelationGetDescr(relation)
Snapshot GetTransactionSnapshot(void)
void PushActiveSnapshot(Snapshot snapshot)
void PopActiveSnapshot(void)
#define ERRCODE_DUPLICATE_OBJECT
ParamListInfo es_param_list_info
FunctionParameterMode mode
const char * p_sourcetext
bool(* receiveSlot)(TupleTableSlot *slot, DestReceiver *self)
Oid values[FLEXIBLE_ARRAY_MEMBER]
void ReleaseSysCache(HeapTuple tuple)
HeapTuple SearchSysCache1(int cacheId, Datum key1)
Datum SysCacheGetAttr(int cacheId, HeapTuple tup, AttrNumber attributeNumber, bool *isNull)
HeapTuple SearchSysCache2(int cacheId, Datum key1, Datum key2)
#define SearchSysCacheCopy1(cacheId, key1)
#define SearchSysCacheExists3(cacheId, key1, key2, key3)
#define GetSysCacheOid2(cacheId, oidcol, key1, key2)
void table_close(Relation relation, LOCKMODE lockmode)
Relation table_open(Oid relationId, LOCKMODE lockmode)
void TupleDescInitEntry(TupleDesc desc, AttrNumber attributeNumber, const char *attributeName, Oid oidtypeid, int32 typmod, int attdim)
#define ReleaseTupleDesc(tupdesc)
#define TupleDescAttr(tupdesc, i)
TupleDesc lookup_rowtype_tupdesc(Oid type_id, int32 typmod)
CommandTag CreateCommandTag(Node *parsetree)
String * makeString(char *str)
bool contain_var_clause(Node *node)