45 #define HAVE_TCL_VERSION(maj,min) \
46 ((TCL_MAJOR_VERSION > maj) || \
47 (TCL_MAJOR_VERSION == maj && TCL_MINOR_VERSION >= min))
50 #if !HAVE_TCL_VERSION(8,4)
51 #error PostgreSQL only supports Tcl 8.4 or later.
61 #define TEXTDOMAIN PG_TEXTDOMAIN("pltcl")
88 const char *_pltcl_utf_src = NULL; \
89 char *_pltcl_utf_dst = NULL
92 if (_pltcl_utf_src != (const char *) _pltcl_utf_dst) \
93 pfree(_pltcl_utf_dst); \
97 (_pltcl_utf_dst = utf_u2e(_pltcl_utf_src = (x)))
100 (_pltcl_utf_dst = utf_e2u(_pltcl_utf_src = (x)))
257 #include "pltclerrcodes.h"
266 Oid prolang,
bool pltrusted);
283 bool is_event_trigger,
286 static int pltcl_elog(ClientData cdata, Tcl_Interp *interp,
287 int objc, Tcl_Obj *
const objv[]);
290 static int pltcl_quote(ClientData cdata, Tcl_Interp *interp,
291 int objc, Tcl_Obj *
const objv[]);
293 int objc, Tcl_Obj *
const objv[]);
295 int objc, Tcl_Obj *
const objv[]);
297 int objc, Tcl_Obj *
const objv[]);
299 int objc, Tcl_Obj *
const objv[]);
301 const char *arrayname,
307 int objc, Tcl_Obj *
const objv[]);
309 int objc, Tcl_Obj *
const objv[]);
311 int objc, Tcl_Obj *
const objv[]);
312 static int pltcl_commit(ClientData cdata, Tcl_Interp *interp,
313 int objc, Tcl_Obj *
const objv[]);
315 int objc, Tcl_Obj *
const objv[]);
329 Tcl_Obj **kvObjv,
int kvObjc,
348 static int fakeThreadKey;
350 return (ClientData) &(fakeThreadKey);
370 Tcl_FileProc *proc, ClientData clientData)
402 Tcl_NotifierProcs notifier;
413 Tcl_FindExecutable(
"");
427 Tcl_SetNotifier(¬ifier);
434 elog(
ERROR,
"could not create dummy Tcl interpreter");
436 elog(
ERROR,
"could not initialize dummy Tcl interpreter");
462 gettext_noop(
"PL/Tcl function to call once when pltcl is first used."),
469 gettext_noop(
"PL/TclU function to call once when pltclu is first used."),
496 snprintf(interpname,
sizeof(interpname),
"subsidiary_%u", interp_desc->
user_id);
498 pltrusted ? 1 : 0)) == NULL)
499 elog(
ERROR,
"could not create subsidiary Tcl interpreter");
504 Tcl_InitHashTable(&interp_desc->
query_hash, TCL_STRING_KEYS);
509 Tcl_CreateObjCommand(interp,
"elog",
511 Tcl_CreateObjCommand(interp,
"quote",
513 Tcl_CreateObjCommand(interp,
"argisnull",
515 Tcl_CreateObjCommand(interp,
"return_null",
517 Tcl_CreateObjCommand(interp,
"return_next",
519 Tcl_CreateObjCommand(interp,
"spi_exec",
521 Tcl_CreateObjCommand(interp,
"spi_prepare",
523 Tcl_CreateObjCommand(interp,
"spi_execp",
525 Tcl_CreateObjCommand(interp,
"subtransaction",
527 Tcl_CreateObjCommand(interp,
"commit",
529 Tcl_CreateObjCommand(interp,
"rollback",
541 interp_desc->
interp = interp;
546 interp_desc->
interp = NULL;
547 Tcl_DeleteInterp(interp);
575 interp_desc->
interp = NULL;
605 gucname = pltrusted ?
"pltcl.start_proc" :
"pltclu.start_proc";
608 if (start_proc == NULL || start_proc[0] ==
'\0')
629 elog(
ERROR,
"cache lookup failed for function %u", procOid);
633 if (procStruct->prolang != prolang)
635 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
636 errmsg(
"function \"%s\" is in the wrong language",
644 if (procStruct->prosecdef)
646 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
647 errmsg(
"function \"%s\" must not be SECURITY DEFINER",
678 const char *gucname = (
const char *)
arg;
681 errcontext(
"processing %s parameter", gucname);
734 memset(¤t_call_state, 0,
sizeof(current_call_state));
764 current_call_state.
fcinfo = fcinfo;
776 if (current_call_state.
prodesc != NULL)
798 Tcl_Interp *
volatile interp;
804 nonatomic = fcinfo->context &&
810 elog(
ERROR,
"could not connect to SPI manager");
833 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
834 errmsg(
"set-valued function called in context that cannot accept a set")));
838 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
839 errmsg(
"materialize mode required, but it is not allowed in this context")));
841 call_state->
rsi = rsi;
850 tcl_cmd = Tcl_NewObj();
851 Tcl_ListObjAppendElement(NULL, tcl_cmd,
855 Tcl_IncrRefCount(tcl_cmd);
862 for (
i = 0;
i < prodesc->
nargs;
i++)
869 if (fcinfo->args[
i].isnull)
870 Tcl_ListObjAppendElement(NULL, tcl_cmd, Tcl_NewObj());
890 Tcl_ListObjAppendElement(NULL, tcl_cmd, list_tmp);
901 if (fcinfo->args[
i].isnull)
902 Tcl_ListObjAppendElement(NULL, tcl_cmd, Tcl_NewObj());
908 fcinfo->args[
i].value);
910 Tcl_ListObjAppendElement(NULL, tcl_cmd,
911 Tcl_NewStringObj(
UTF_E2U(tmp), -1));
921 Tcl_DecrRefCount(tcl_cmd);
931 tcl_rc = Tcl_EvalObjEx(interp, tcl_cmd, (TCL_EVAL_DIRECT | TCL_EVAL_GLOBAL));
934 Tcl_DecrRefCount(tcl_cmd);
939 if (tcl_rc != TCL_OK)
975 fcinfo->isnull =
true;
977 else if (fcinfo->isnull)
989 Tcl_Obj **resultObjv;
1011 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1012 errmsg(
"function returning record called in context "
1013 "that cannot accept type record")));
1017 elog(
ERROR,
"return type must be a row type");
1027 resultObj = Tcl_GetObjResult(interp);
1028 if (Tcl_ListObjGetElements(interp, resultObj, &resultObjc, &resultObjv) == TCL_ERROR)
1037 utf_u2e(Tcl_GetStringResult(interp)),
1053 Tcl_Interp *
volatile interp;
1059 Tcl_Obj *tcl_trigtup;
1064 Tcl_Obj **result_Objv;
1071 elog(
ERROR,
"could not connect to SPI manager");
1083 call_state->
prodesc = prodesc;
1094 tcl_cmd = Tcl_NewObj();
1095 Tcl_IncrRefCount(tcl_cmd);
1100 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1104 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1111 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1112 Tcl_NewStringObj(stroid, -1));
1117 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1118 Tcl_NewStringObj(
utf_e2u(stroid), -1));
1123 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1124 Tcl_NewStringObj(
utf_e2u(stroid), -1));
1128 tcl_trigtup = Tcl_NewObj();
1129 Tcl_ListObjAppendElement(NULL, tcl_trigtup, Tcl_NewObj());
1130 for (
i = 0;
i < tupdesc->natts;
i++)
1134 if (att->attisdropped)
1135 Tcl_ListObjAppendElement(NULL, tcl_trigtup, Tcl_NewObj());
1137 Tcl_ListObjAppendElement(NULL, tcl_trigtup,
1140 Tcl_ListObjAppendElement(NULL, tcl_cmd, tcl_trigtup);
1144 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1145 Tcl_NewStringObj(
"BEFORE", -1));
1147 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1148 Tcl_NewStringObj(
"AFTER", -1));
1150 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1151 Tcl_NewStringObj(
"INSTEAD OF", -1));
1158 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1159 Tcl_NewStringObj(
"ROW", -1));
1170 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1171 Tcl_NewStringObj(
"INSERT", -1));
1173 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1177 Tcl_ListObjAppendElement(NULL, tcl_cmd, Tcl_NewObj());
1183 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1184 Tcl_NewStringObj(
"DELETE", -1));
1186 Tcl_ListObjAppendElement(NULL, tcl_cmd, Tcl_NewObj());
1187 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1196 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1197 Tcl_NewStringObj(
"UPDATE", -1));
1199 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1203 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1215 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1216 Tcl_NewStringObj(
"STATEMENT", -1));
1219 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1220 Tcl_NewStringObj(
"INSERT", -1));
1222 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1223 Tcl_NewStringObj(
"DELETE", -1));
1225 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1226 Tcl_NewStringObj(
"UPDATE", -1));
1228 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1229 Tcl_NewStringObj(
"TRUNCATE", -1));
1233 Tcl_ListObjAppendElement(NULL, tcl_cmd, Tcl_NewObj());
1234 Tcl_ListObjAppendElement(NULL, tcl_cmd, Tcl_NewObj());
1243 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1248 Tcl_DecrRefCount(tcl_cmd);
1258 tcl_rc = Tcl_EvalObjEx(interp, tcl_cmd, (TCL_EVAL_DIRECT | TCL_EVAL_GLOBAL));
1261 Tcl_DecrRefCount(tcl_cmd);
1266 if (tcl_rc != TCL_OK)
1280 result = Tcl_GetStringResult(interp);
1282 if (strcmp(result,
"OK") == 0)
1284 if (strcmp(result,
"SKIP") == 0)
1291 if (Tcl_ListObjGetElements(interp, Tcl_GetObjResult(interp),
1292 &result_Objc, &result_Objv) != TCL_OK)
1294 (
errcode(ERRCODE_E_R_I_E_TRIGGER_PROTOCOL_VIOLATED),
1295 errmsg(
"could not split return value from trigger: %s",
1296 utf_u2e(Tcl_GetStringResult(interp)))));
1313 Tcl_Interp *
volatile interp;
1320 elog(
ERROR,
"could not connect to SPI manager");
1326 call_state->
prodesc = prodesc;
1332 tcl_cmd = Tcl_NewObj();
1333 Tcl_IncrRefCount(tcl_cmd);
1334 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1336 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1338 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1342 tcl_rc = Tcl_EvalObjEx(interp, tcl_cmd, (TCL_EVAL_DIRECT | TCL_EVAL_GLOBAL));
1345 Tcl_DecrRefCount(tcl_cmd);
1348 if (tcl_rc != TCL_OK)
1373 econtext =
utf_u2e(Tcl_GetVar(interp,
"errorInfo", TCL_GLOBAL_ONLY));
1375 (
errcode(ERRCODE_EXTERNAL_ROUTINE_EXCEPTION),
1390 bool is_event_trigger,
bool pltrusted)
1400 Tcl_DString proc_internal_def;
1401 Tcl_DString proc_internal_body;
1406 elog(
ERROR,
"cache lookup failed for function %u", fn_oid);
1430 if (prodesc != NULL &&
1447 Tcl_DStringInit(&proc_internal_def);
1448 Tcl_DStringInit(&proc_internal_body);
1452 char internal_proname[128];
1469 if (is_event_trigger)
1470 snprintf(internal_proname,
sizeof(internal_proname),
1471 "__PLTcl_proc_%u_evttrigger", fn_oid);
1472 else if (is_trigger)
1473 snprintf(internal_proname,
sizeof(internal_proname),
1474 "__PLTcl_proc_%u_trigger", fn_oid);
1476 snprintf(internal_proname,
sizeof(internal_proname),
1477 "__PLTcl_proc_%u", fn_oid);
1495 prodesc->
fn_cxt = proc_cxt;
1499 prodesc->
nargs = procStruct->pronargs;
1506 (procStruct->provolatile != PROVOLATILE_VOLATILE);
1521 if (!is_trigger && !is_event_trigger)
1523 Oid rettype = procStruct->prorettype;
1527 elog(
ERROR,
"cache lookup failed for type %u", rettype);
1531 if (typeStruct->typtype == TYPTYPE_PSEUDO)
1533 if (rettype == VOIDOID ||
1534 rettype == RECORDOID)
1536 else if (rettype == TRIGGEROID ||
1537 rettype == EVENT_TRIGGEROID)
1539 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1540 errmsg(
"trigger functions can only be called as triggers")));
1543 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1544 errmsg(
"PL/Tcl functions cannot return type %s",
1556 prodesc->
fn_retisdomain = (typeStruct->typtype == TYPTYPE_DOMAIN);
1566 if (!is_trigger && !is_event_trigger)
1568 proc_internal_args[0] =
'\0';
1569 for (
i = 0;
i < prodesc->
nargs;
i++)
1571 Oid argtype = procStruct->proargtypes.values[
i];
1575 elog(
ERROR,
"cache lookup failed for type %u", argtype);
1579 if (typeStruct->typtype == TYPTYPE_PSEUDO &&
1580 argtype != RECORDOID)
1582 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1583 errmsg(
"PL/Tcl functions cannot accept type %s",
1601 strcat(proc_internal_args,
" ");
1602 strcat(proc_internal_args,
buf);
1607 else if (is_trigger)
1610 strcpy(proc_internal_args,
1611 "TG_name TG_relid TG_table_name TG_table_schema TG_relatts TG_when TG_level TG_op __PLTcl_Tup_NEW __PLTcl_Tup_OLD args");
1613 else if (is_event_trigger)
1616 strcpy(proc_internal_args,
"TG_event TG_tag");
1627 Tcl_DStringAppendElement(&proc_internal_def,
"proc");
1628 Tcl_DStringAppendElement(&proc_internal_def, internal_proname);
1629 Tcl_DStringAppendElement(&proc_internal_def, proc_internal_args);
1636 Tcl_DStringAppend(&proc_internal_body,
"upvar #0 ", -1);
1637 Tcl_DStringAppend(&proc_internal_body, internal_proname, -1);
1638 Tcl_DStringAppend(&proc_internal_body,
" GD\n", -1);
1641 Tcl_DStringAppend(&proc_internal_body,
1642 "array set NEW $__PLTcl_Tup_NEW\n", -1);
1643 Tcl_DStringAppend(&proc_internal_body,
1644 "array set OLD $__PLTcl_Tup_OLD\n", -1);
1645 Tcl_DStringAppend(&proc_internal_body,
1648 "foreach v $args {\n"
1652 "unset i v\n\n", -1);
1654 else if (is_event_trigger)
1660 for (
i = 0;
i < prodesc->
nargs;
i++)
1665 "array set %d $__PLTcl_Tup_%d\n",
1667 Tcl_DStringAppend(&proc_internal_body,
buf, -1);
1676 Anum_pg_proc_prosrc);
1679 Tcl_DStringAppend(&proc_internal_body,
UTF_E2U(proc_source), -1);
1682 Tcl_DStringAppendElement(&proc_internal_def,
1683 Tcl_DStringValue(&proc_internal_body));
1688 tcl_rc = Tcl_EvalEx(interp,
1689 Tcl_DStringValue(&proc_internal_def),
1690 Tcl_DStringLength(&proc_internal_def),
1692 if (tcl_rc != TCL_OK)
1694 (
errcode(ERRCODE_EXTERNAL_ROUTINE_EXCEPTION),
1695 errmsg(
"could not create internal procedure \"%s\": %s",
1697 utf_u2e(Tcl_GetStringResult(interp)))));
1707 Tcl_DStringFree(&proc_internal_def);
1708 Tcl_DStringFree(&proc_internal_body);
1728 if (old_prodesc != NULL)
1735 Tcl_DStringFree(&proc_internal_def);
1736 Tcl_DStringFree(&proc_internal_body);
1749 int objc, Tcl_Obj *
const objv[])
1755 static const char *logpriorities[] = {
1756 "DEBUG",
"LOG",
"INFO",
"NOTICE",
1757 "WARNING",
"ERROR",
"FATAL", (
const char *) NULL
1760 static const int loglevels[] = {
1767 Tcl_WrongNumArgs(interp, 1, objv,
"level msg");
1771 if (Tcl_GetIndexFromObj(interp, objv[1], logpriorities,
"priority",
1772 TCL_EXACT, &priIndex) != TCL_OK)
1775 level = loglevels[priIndex];
1784 Tcl_SetObjResult(interp, objv[2]);
1802 (
errcode(ERRCODE_EXTERNAL_ROUTINE_EXCEPTION),
1818 Tcl_SetObjResult(interp, Tcl_NewStringObj(
UTF_E2U(edata->
message), -1));
1837 Tcl_Obj *obj = Tcl_NewObj();
1839 Tcl_ListObjAppendElement(interp, obj,
1840 Tcl_NewStringObj(
"POSTGRES", -1));
1841 Tcl_ListObjAppendElement(interp, obj,
1842 Tcl_NewStringObj(PG_VERSION, -1));
1843 Tcl_ListObjAppendElement(interp, obj,
1844 Tcl_NewStringObj(
"SQLSTATE", -1));
1845 Tcl_ListObjAppendElement(interp, obj,
1847 Tcl_ListObjAppendElement(interp, obj,
1848 Tcl_NewStringObj(
"condition", -1));
1849 Tcl_ListObjAppendElement(interp, obj,
1851 Tcl_ListObjAppendElement(interp, obj,
1852 Tcl_NewStringObj(
"message", -1));
1854 Tcl_ListObjAppendElement(interp, obj,
1859 Tcl_ListObjAppendElement(interp, obj,
1860 Tcl_NewStringObj(
"detail", -1));
1862 Tcl_ListObjAppendElement(interp, obj,
1868 Tcl_ListObjAppendElement(interp, obj,
1869 Tcl_NewStringObj(
"hint", -1));
1871 Tcl_ListObjAppendElement(interp, obj,
1877 Tcl_ListObjAppendElement(interp, obj,
1878 Tcl_NewStringObj(
"context", -1));
1880 Tcl_ListObjAppendElement(interp, obj,
1886 Tcl_ListObjAppendElement(interp, obj,
1887 Tcl_NewStringObj(
"schema", -1));
1889 Tcl_ListObjAppendElement(interp, obj,
1895 Tcl_ListObjAppendElement(interp, obj,
1896 Tcl_NewStringObj(
"table", -1));
1898 Tcl_ListObjAppendElement(interp, obj,
1904 Tcl_ListObjAppendElement(interp, obj,
1905 Tcl_NewStringObj(
"column", -1));
1907 Tcl_ListObjAppendElement(interp, obj,
1913 Tcl_ListObjAppendElement(interp, obj,
1914 Tcl_NewStringObj(
"datatype", -1));
1916 Tcl_ListObjAppendElement(interp, obj,
1922 Tcl_ListObjAppendElement(interp, obj,
1923 Tcl_NewStringObj(
"constraint", -1));
1925 Tcl_ListObjAppendElement(interp, obj,
1932 Tcl_ListObjAppendElement(interp, obj,
1933 Tcl_NewStringObj(
"statement", -1));
1935 Tcl_ListObjAppendElement(interp, obj,
1941 Tcl_ListObjAppendElement(interp, obj,
1942 Tcl_NewStringObj(
"cursor_position", -1));
1943 Tcl_ListObjAppendElement(interp, obj,
1948 Tcl_ListObjAppendElement(interp, obj,
1949 Tcl_NewStringObj(
"filename", -1));
1951 Tcl_ListObjAppendElement(interp, obj,
1957 Tcl_ListObjAppendElement(interp, obj,
1958 Tcl_NewStringObj(
"lineno", -1));
1959 Tcl_ListObjAppendElement(interp, obj,
1960 Tcl_NewIntObj(edata->
lineno));
1964 Tcl_ListObjAppendElement(interp, obj,
1965 Tcl_NewStringObj(
"funcname", -1));
1967 Tcl_ListObjAppendElement(interp, obj,
1972 Tcl_SetObjErrorCode(interp, obj);
1989 return "unrecognized_sqlstate";
1999 int objc, Tcl_Obj *
const objv[])
2011 Tcl_WrongNumArgs(interp, 1, objv,
"string");
2019 cp1 = Tcl_GetStringFromObj(objv[1], &length);
2020 tmp =
palloc(length * 2 + 1);
2042 Tcl_SetObjResult(interp, Tcl_NewStringObj(tmp, -1));
2053 int objc, Tcl_Obj *
const objv[])
2063 Tcl_WrongNumArgs(interp, 1, objv,
"argno");
2072 Tcl_SetObjResult(interp,
2073 Tcl_NewStringObj(
"argisnull cannot be used in triggers", -1));
2080 if (Tcl_GetIntFromObj(interp, objv[1], &argno) != TCL_OK)
2087 if (argno < 0 || argno >= fcinfo->
nargs)
2089 Tcl_SetObjResult(interp,
2090 Tcl_NewStringObj(
"argno out of range", -1));
2097 Tcl_SetObjResult(interp, Tcl_NewBooleanObj(
PG_ARGISNULL(argno)));
2107 int objc, Tcl_Obj *
const objv[])
2116 Tcl_WrongNumArgs(interp, 1, objv,
"");
2125 Tcl_SetObjResult(interp,
2126 Tcl_NewStringObj(
"return_null cannot be used in triggers", -1));
2145 int objc, Tcl_Obj *
const objv[])
2152 volatile int result = TCL_OK;
2159 Tcl_SetObjResult(interp,
2160 Tcl_NewStringObj(
"return_next cannot be used in triggers", -1));
2166 Tcl_SetObjResult(interp,
2167 Tcl_NewStringObj(
"return_next cannot be used in non-set-returning functions", -1));
2176 Tcl_WrongNumArgs(interp, 1, objv,
"result");
2201 if (Tcl_ListObjGetElements(interp, objv[1], &rowObjc, &rowObjv) == TCL_ERROR)
2215 bool isNull =
false;
2219 elog(
ERROR,
"wrong result type supplied in return_next");
2222 utf_u2e((
char *) Tcl_GetString(objv[1])),
2303 Tcl_SetObjResult(interp, Tcl_NewStringObj(
UTF_E2U(edata->
message), -1));
2315 int objc, Tcl_Obj *
const objv[])
2323 const char *
volatile arrayname = NULL;
2324 Tcl_Obj *
volatile loop_body = NULL;
2330 OPT_ARRAY, OPT_COUNT
2333 static const char *
options[] = {
2334 "-array",
"-count", (
const char *) NULL
2342 Tcl_WrongNumArgs(interp, 1, objv,
2343 "?-count n? ?-array name? query ?loop body?");
2350 if (Tcl_GetIndexFromObj(NULL, objv[
i],
options, NULL,
2351 TCL_EXACT, &optIndex) != TCL_OK)
2356 Tcl_SetObjResult(interp,
2357 Tcl_NewStringObj(
"missing argument to -count or -array", -1));
2361 switch ((
enum options) optIndex)
2364 arrayname = Tcl_GetString(objv[
i++]);
2368 if (Tcl_GetIntFromObj(interp, objv[
i++], &count) != TCL_OK)
2375 if (query_idx >= objc || query_idx + 2 < objc)
2377 Tcl_WrongNumArgs(interp, query_idx - 1, objv,
"query ?loop body?");
2381 if (query_idx + 1 < objc)
2382 loop_body = objv[query_idx + 1];
2424 const char *arrayname,
2442 Tcl_SetObjResult(interp, Tcl_NewWideIntObj(ntuples));
2447 if (tuptable == NULL)
2449 Tcl_SetObjResult(interp, Tcl_NewIntObj(0));
2463 tuples = tuptable->
vals;
2466 if (loop_body == NULL)
2474 tuples[0], tupdesc);
2484 for (
i = 0;
i < ntuples;
i++)
2487 tuples[
i], tupdesc);
2489 loop_rc = Tcl_EvalObjEx(interp, loop_body, 0);
2491 if (loop_rc == TCL_OK)
2493 if (loop_rc == TCL_CONTINUE)
2495 if (loop_rc == TCL_RETURN)
2500 if (loop_rc == TCL_BREAK)
2507 if (my_rc == TCL_OK)
2509 Tcl_SetObjResult(interp, Tcl_NewWideIntObj(ntuples));
2514 Tcl_AppendResult(interp,
"pltcl: SPI_execute failed: ",
2536 int objc, Tcl_Obj *
const objv[])
2543 Tcl_HashEntry *hashent;
2545 Tcl_HashTable *query_hash;
2554 Tcl_WrongNumArgs(interp, 1, objv,
"query argtypes");
2561 if (Tcl_ListObjGetElements(interp, objv[2], &nargs, &argsObj) != TCL_OK)
2572 "PL/Tcl spi_prepare query",
2577 qdesc->
nargs = nargs;
2597 for (
i = 0;
i < nargs;
i++)
2605 &typId, &typmod, NULL);
2622 if (qdesc->
plan == NULL)
2650 hashent = Tcl_CreateHashEntry(query_hash, qdesc->
qname, &hashnew);
2651 Tcl_SetHashValue(hashent, (ClientData) qdesc);
2654 Tcl_SetObjResult(interp, Tcl_NewStringObj(qdesc->
qname, -1));
2664 int objc, Tcl_Obj *
const objv[])
2671 Tcl_HashEntry *hashent;
2673 const char *nulls = NULL;
2674 const char *arrayname = NULL;
2675 Tcl_Obj *loop_body = NULL;
2678 Tcl_Obj **callObjv = NULL;
2682 Tcl_HashTable *query_hash;
2686 OPT_ARRAY, OPT_COUNT, OPT_NULLS
2689 static const char *
options[] = {
2690 "-array",
"-count",
"-nulls", (
const char *) NULL
2699 if (Tcl_GetIndexFromObj(NULL, objv[
i],
options, NULL,
2700 TCL_EXACT, &optIndex) != TCL_OK)
2705 Tcl_SetObjResult(interp,
2706 Tcl_NewStringObj(
"missing argument to -array, -count or -nulls", -1));
2710 switch ((
enum options) optIndex)
2713 arrayname = Tcl_GetString(objv[
i++]);
2717 if (Tcl_GetIntFromObj(interp, objv[
i++], &count) != TCL_OK)
2722 nulls = Tcl_GetString(objv[
i++]);
2732 Tcl_SetObjResult(interp,
2733 Tcl_NewStringObj(
"missing argument to -count or -array", -1));
2739 hashent = Tcl_FindHashEntry(query_hash, Tcl_GetString(objv[
i]));
2740 if (hashent == NULL)
2742 Tcl_AppendResult(interp,
"invalid queryid '", Tcl_GetString(objv[
i]),
"'", NULL);
2753 if (strlen(nulls) != qdesc->
nargs)
2755 Tcl_SetObjResult(interp,
2756 Tcl_NewStringObj(
"length of nulls string doesn't match number of arguments",
2766 if (qdesc->
nargs > 0)
2770 Tcl_SetObjResult(interp,
2771 Tcl_NewStringObj(
"argument list length doesn't match number of arguments for query",
2779 if (Tcl_ListObjGetElements(interp, objv[
i++], &callObjc, &callObjv) != TCL_OK)
2785 if (callObjc != qdesc->
nargs)
2787 Tcl_SetObjResult(interp,
2788 Tcl_NewStringObj(
"argument list length doesn't match number of arguments for query",
2800 loop_body = objv[
i++];
2804 Tcl_WrongNumArgs(interp, 1, objv,
2805 "?-count n? ?-array name? ?-nulls string? "
2806 "query ?args? ?loop body?");
2825 for (
j = 0;
j < callObjc;
j++)
2827 if (nulls && nulls[
j] ==
'n')
2838 UTF_U2E(Tcl_GetString(callObjv[
j])),
2880 int objc, Tcl_Obj *
const objv[])
2888 Tcl_WrongNumArgs(interp, 1, objv,
"command");
2900 retcode = Tcl_EvalObjEx(interp, objv[1], 0);
2902 if (retcode == TCL_ERROR)
2928 int objc, Tcl_Obj *
const objv[])
2948 Tcl_SetObjResult(interp, Tcl_NewStringObj(
UTF_E2U(edata->
message), -1));
2967 int objc, Tcl_Obj *
const objv[])
2987 Tcl_SetObjResult(interp, Tcl_NewStringObj(
UTF_E2U(edata->
message), -1));
3016 const char **arrptr;
3017 const char **nameptr;
3018 const char *nullname = NULL;
3023 if (arrayname == NULL)
3026 nameptr = &nullname;
3030 arrptr = &arrayname;
3038 Tcl_SetVar2Ex(interp, arrayname,
".tupno", Tcl_NewWideIntObj(tupno), 0);
3041 for (
i = 0;
i < tupdesc->
natts;
i++)
3046 if (att->attisdropped)
3074 Tcl_SetVar2Ex(interp, *arrptr, *nameptr,
3075 Tcl_NewStringObj(
UTF_E2U(outputstr), -1), 0);
3080 Tcl_UnsetVar2(interp, *arrptr, *nameptr, 0);
3094 Tcl_Obj *retobj = Tcl_NewObj();
3103 for (
i = 0;
i < tupdesc->
natts;
i++)
3108 if (att->attisdropped)
3111 if (att->attgenerated)
3114 if (!include_generated)
3139 &typoutput, &typisvarlena);
3142 Tcl_ListObjAppendElement(NULL, retobj,
3146 Tcl_ListObjAppendElement(NULL, retobj,
3147 Tcl_NewStringObj(
UTF_E2U(outputstr), -1));
3189 elog(
ERROR,
"PL/Tcl function does not return a tuple");
3196 if (kvObjc % 2 != 0)
3198 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
3199 errmsg(
"column name/value list must have even number of elements")));
3201 for (
i = 0;
i < kvObjc;
i += 2)
3203 char *fieldName =
utf_u2e(Tcl_GetString(kvObjv[
i]));
3213 if (strcmp(fieldName,
".tupno") == 0)
3216 (
errcode(ERRCODE_UNDEFINED_COLUMN),
3217 errmsg(
"column name/value list contains nonexistent column name \"%s\"",
3223 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3224 errmsg(
"cannot set system attribute \"%s\"",
3229 (
errcode(ERRCODE_E_R_I_E_TRIGGER_PROTOCOL_VIOLATED),
3230 errmsg(
"cannot set generated column \"%s\"",
void aclcheck_error(AclResult aclerr, ObjectType objtype, const char *objectname)
AclResult object_aclcheck(Oid classid, Oid objectid, Oid roleid, AclMode mode)
static Datum values[MAXATTR]
#define TextDatumGetCString(d)
#define unconstify(underlying_type, expr)
#define PG_USED_FOR_ASSERTS_ONLY
#define OidIsValid(objectId)
const char * GetCommandTagName(CommandTag commandTag)
elog(ERROR, "%s: %s", p2, msg)
void domain_check(Datum value, bool isnull, Oid domainType, void **extra, MemoryContext mcxt)
void * hash_search(HTAB *hashp, const void *keyPtr, HASHACTION action, bool *foundPtr)
HTAB * hash_create(const char *tabname, long nelem, const HASHCTL *info, int flags)
void FreeErrorData(ErrorData *edata)
ErrorContextCallback * error_context_stack
void FlushErrorState(void)
char * unpack_sql_state(int sql_state)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
ErrorData * CopyErrorData(void)
#define ereport(elevel,...)
#define CALLED_AS_EVENT_TRIGGER(fcinfo)
HeapTuple BuildTupleFromCStrings(AttInMetadata *attinmeta, char **values)
AttInMetadata * TupleDescGetAttInMetadata(TupleDesc tupdesc)
@ SFRM_Materialize_Random
Datum InputFunctionCall(FmgrInfo *flinfo, char *str, Oid typioparam, int32 typmod)
void fmgr_info(Oid functionId, FmgrInfo *finfo)
void fmgr_info_cxt(Oid functionId, FmgrInfo *finfo, MemoryContext mcxt)
char * OidOutputFunctionCall(Oid functionId, Datum val)
char * OutputFunctionCall(FmgrInfo *flinfo, Datum val)
#define DatumGetHeapTupleHeader(X)
#define InitFunctionCallInfoData(Fcinfo, Flinfo, Nargs, Collation, Context, Resultinfo)
#define DirectFunctionCall1(func, arg1)
#define LOCAL_FCINFO(name, nargs)
#define FunctionCallInvoke(fcinfo)
TypeFuncClass get_call_result_type(FunctionCallInfo fcinfo, Oid *resultTypeId, TupleDesc *resultTupleDesc)
@ TYPEFUNC_COMPOSITE_DOMAIN
static Datum HeapTupleGetDatum(const HeapTupleData *tuple)
void DefineCustomStringVariable(const char *name, const char *short_desc, const char *long_desc, char **valueAddr, const char *bootValue, GucContext context, int flags, GucStringCheckHook check_hook, GucStringAssignHook assign_hook, GucShowHook show_hook)
void MarkGUCPrefixReserved(const char *className)
HeapTupleData * HeapTuple
#define HeapTupleIsValid(tuple)
static Datum heap_getattr(HeapTuple tup, int attnum, TupleDesc tupleDesc, bool *isnull)
#define HeapTupleHeaderGetTypMod(tup)
#define HeapTupleHeaderGetTypeId(tup)
#define HeapTupleHeaderGetDatumLength(tup)
#define HeapTupleHeaderGetRawXmin(tup)
if(TABLE==NULL||TABLE_index==NULL)
bool ItemPointerEquals(ItemPointer pointer1, ItemPointer pointer2)
Assert(fmt[strlen(fmt) - 1] !='\n')
bool type_is_rowtype(Oid typid)
void getTypeOutputInfo(Oid type, Oid *typOutput, bool *typIsVarlena)
void getTypeInputInfo(Oid type, Oid *typInput, Oid *typIOParam)
Oid getTypeIOParam(HeapTuple typeTuple)
char * pg_any_to_server(const char *s, int len, int encoding)
char * pg_server_to_any(const char *s, int len, int encoding)
char * pstrdup(const char *in)
void pfree(void *pointer)
MemoryContext TopMemoryContext
void * palloc0(Size size)
MemoryContext CurrentMemoryContext
void MemoryContextDelete(MemoryContext context)
void MemoryContextSetIdentifier(MemoryContext context, const char *id)
#define AllocSetContextCreate
#define ALLOCSET_SMALL_SIZES
void pg_bindtextdomain(const char *domain)
#define IsA(nodeptr, _type_)
#define castNode(_type_, nodeptr)
#define InvokeFunctionExecuteHook(objectId)
Datum oidout(PG_FUNCTION_ARGS)
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
Oid LookupFuncName(List *funcname, int nargs, const Oid *argtypes, bool missing_ok)
bool parseTypeString(const char *str, Oid *typeid_p, int32 *typmod_p, Node *escontext)
FormData_pg_attribute * Form_pg_attribute
static PgChecksumMode mode
FormData_pg_proc * Form_pg_proc
FormData_pg_type * Form_pg_type
void pgstat_init_function_usage(FunctionCallInfo fcinfo, PgStat_FunctionCallUsage *fcu)
void pgstat_end_function_usage(PgStat_FunctionCallUsage *fcu, bool finalize)
static HeapTuple pltcl_trigger_handler(PG_FUNCTION_ARGS, pltcl_call_state *call_state, bool pltrusted)
PG_FUNCTION_INFO_V1(pltcl_call_handler)
static void pltcl_ServiceModeHook(int mode)
static const char * pltcl_get_condition_name(int sqlstate)
static HTAB * pltcl_proc_htab
static void pltcl_AlertNotifier(ClientData clientData)
static int pltcl_WaitForEvent(CONST86 Tcl_Time *timePtr)
static void pltcl_init_tuple_store(pltcl_call_state *call_state)
static Tcl_Obj * pltcl_build_tuple_argument(HeapTuple tuple, TupleDesc tupdesc, bool include_generated)
static pltcl_proc_desc * compile_pltcl_function(Oid fn_oid, Oid tgreloid, bool is_event_trigger, bool pltrusted)
static void call_pltcl_start_proc(Oid prolang, bool pltrusted)
static int pltcl_returnnext(ClientData cdata, Tcl_Interp *interp, int objc, Tcl_Obj *const objv[])
static void pltcl_SetTimer(CONST86 Tcl_Time *timePtr)
static int pltcl_SPI_execute(ClientData cdata, Tcl_Interp *interp, int objc, Tcl_Obj *const objv[])
static int pltcl_process_SPI_result(Tcl_Interp *interp, const char *arrayname, Tcl_Obj *loop_body, int spi_rc, SPITupleTable *tuptable, uint64 ntuples)
static int pltcl_elog(ClientData cdata, Tcl_Interp *interp, int objc, Tcl_Obj *const objv[])
static void pltcl_subtrans_abort(Tcl_Interp *interp, MemoryContext oldcontext, ResourceOwner oldowner)
static void pltcl_DeleteFileHandler(int fd)
static char * utf_e2u(const char *src)
static int pltcl_quote(ClientData cdata, Tcl_Interp *interp, int objc, Tcl_Obj *const objv[])
struct pltcl_proc_desc pltcl_proc_desc
static void pltcl_FinalizeNotifier(ClientData clientData)
static void throw_tcl_error(Tcl_Interp *interp, const char *proname)
static void pltcl_CreateFileHandler(int fd, int mask, Tcl_FileProc *proc, ClientData clientData)
static int pltcl_SPI_prepare(ClientData cdata, Tcl_Interp *interp, int objc, Tcl_Obj *const objv[])
static char * pltcl_start_proc
static Datum pltcl_handler(PG_FUNCTION_ARGS, bool pltrusted)
static HTAB * pltcl_interp_htab
struct pltcl_proc_key pltcl_proc_key
static pltcl_interp_desc * pltcl_fetch_interp(Oid prolang, bool pltrusted)
struct pltcl_interp_desc pltcl_interp_desc
static pltcl_call_state * pltcl_current_call_state
static void pltcl_init_interp(pltcl_interp_desc *interp_desc, Oid prolang, bool pltrusted)
static void pltcl_construct_errorCode(Tcl_Interp *interp, ErrorData *edata)
static char * pltclu_start_proc
static void pltcl_event_trigger_handler(PG_FUNCTION_ARGS, pltcl_call_state *call_state, bool pltrusted)
static ClientData pltcl_InitNotifier(void)
struct pltcl_query_desc pltcl_query_desc
static const TclExceptionNameMap exception_name_map[]
static int pltcl_rollback(ClientData cdata, Tcl_Interp *interp, int objc, Tcl_Obj *const objv[])
static void pltcl_set_tuple_values(Tcl_Interp *interp, const char *arrayname, uint64 tupno, HeapTuple tuple, TupleDesc tupdesc)
Datum pltclu_call_handler(PG_FUNCTION_ARGS)
static void start_proc_error_callback(void *arg)
static int pltcl_argisnull(ClientData cdata, Tcl_Interp *interp, int objc, Tcl_Obj *const objv[])
static int pltcl_returnnull(ClientData cdata, Tcl_Interp *interp, int objc, Tcl_Obj *const objv[])
static void pltcl_subtrans_begin(MemoryContext oldcontext, ResourceOwner oldowner)
static Datum pltcl_func_handler(PG_FUNCTION_ARGS, pltcl_call_state *call_state, bool pltrusted)
static Tcl_Interp * pltcl_hold_interp
static int pltcl_SPI_execute_plan(ClientData cdata, Tcl_Interp *interp, int objc, Tcl_Obj *const objv[])
struct pltcl_call_state pltcl_call_state
static void pltcl_subtrans_commit(MemoryContext oldcontext, ResourceOwner oldowner)
static HeapTuple pltcl_build_tuple_result(Tcl_Interp *interp, Tcl_Obj **kvObjv, int kvObjc, pltcl_call_state *call_state)
static char * utf_u2e(const char *src)
Datum pltcl_call_handler(PG_FUNCTION_ARGS)
static bool pltcl_pm_init_done
static int pltcl_subtransaction(ClientData cdata, Tcl_Interp *interp, int objc, Tcl_Obj *const objv[])
struct pltcl_proc_ptr pltcl_proc_ptr
static int pltcl_commit(ClientData cdata, Tcl_Interp *interp, int objc, Tcl_Obj *const objv[])
static Datum PointerGetDatum(const void *X)
static char * DatumGetCString(Datum X)
static Datum ObjectIdGetDatum(Oid X)
static int fd(const char *x, int i)
List * stringToQualifiedNameList(const char *string, Node *escontext)
#define RelationGetRelid(relation)
#define RelationGetDescr(relation)
ResourceOwner CurrentResourceOwner
char * SPI_getrelname(Relation rel)
int SPI_fnumber(TupleDesc tupdesc, const char *fname)
SPITupleTable * SPI_tuptable
const char * SPI_result_code_string(int code)
int SPI_execute_plan(SPIPlanPtr plan, Datum *Values, const char *Nulls, bool read_only, long tcount)
int SPI_register_trigger_data(TriggerData *tdata)
void SPI_freetuptable(SPITupleTable *tuptable)
SPIPlanPtr SPI_prepare(const char *src, int nargs, Oid *argtypes)
int SPI_keepplan(SPIPlanPtr plan)
char * SPI_getnspname(Relation rel)
int SPI_connect_ext(int options)
int SPI_execute(const char *src, bool read_only, long tcount)
#define SPI_OPT_NONATOMIC
#define SPI_OK_UPDATE_RETURNING
#define SPI_ERROR_NOATTRIBUTE
#define SPI_OK_INSERT_RETURNING
#define SPI_OK_DELETE_RETURNING
struct ErrorContextCallback * previous
void(* callback)(void *arg)
MemoryContext ecxt_per_query_memory
SetFunctionReturnMode returnMode
Tuplestorestate * setResult
pltcl_proc_desc * prodesc
MemoryContext tuple_store_cxt
Tuplestorestate * tuple_store
ResourceOwner tuple_store_owner
AttInMetadata * attinmeta
pltcl_interp_desc * interp_desc
unsigned long fn_refcount
pltcl_proc_desc * proc_ptr
void ReleaseSysCache(HeapTuple tuple)
HeapTuple SearchSysCache1(int cacheId, Datum key1)
Datum SysCacheGetAttrNotNull(int cacheId, HeapTuple tup, AttrNumber attributeNumber)
#define TRIGGER_FIRED_FOR_STATEMENT(event)
#define TRIGGER_FIRED_BY_DELETE(event)
#define TRIGGER_FIRED_BEFORE(event)
#define CALLED_AS_TRIGGER(fcinfo)
#define TRIGGER_FIRED_FOR_ROW(event)
#define TRIGGER_FIRED_AFTER(event)
#define TRIGGER_FIRED_BY_TRUNCATE(event)
#define TRIGGER_FIRED_BY_INSERT(event)
#define TRIGGER_FIRED_BY_UPDATE(event)
#define TRIGGER_FIRED_INSTEAD(event)
TupleDesc CreateTupleDescCopy(TupleDesc tupdesc)
#define ReleaseTupleDesc(tupdesc)
#define TupleDescAttr(tupdesc, i)
void tuplestore_putvalues(Tuplestorestate *state, TupleDesc tdesc, Datum *values, bool *isnull)
Tuplestorestate * tuplestore_begin_heap(bool randomAccess, bool interXact, int maxKBytes)
void tuplestore_puttuple(Tuplestorestate *state, HeapTuple tuple)
TupleDesc lookup_rowtype_tupdesc(Oid type_id, int32 typmod)
void BeginInternalSubTransaction(const char *name)
void RollbackAndReleaseCurrentSubTransaction(void)
void ReleaseCurrentSubTransaction(void)