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"
267 Oid prolang,
bool pltrusted);
284 bool is_event_trigger,
287 static int pltcl_elog(ClientData cdata, Tcl_Interp *interp,
288 int objc, Tcl_Obj *
const objv[]);
291 static int pltcl_quote(ClientData cdata, Tcl_Interp *interp,
292 int objc, Tcl_Obj *
const objv[]);
294 int objc, Tcl_Obj *
const objv[]);
296 int objc, Tcl_Obj *
const objv[]);
298 int objc, Tcl_Obj *
const objv[]);
300 int objc, Tcl_Obj *
const objv[]);
302 const char *arrayname,
308 int objc, Tcl_Obj *
const objv[]);
310 int objc, Tcl_Obj *
const objv[]);
312 int objc, Tcl_Obj *
const objv[]);
313 static int pltcl_commit(ClientData cdata, Tcl_Interp *interp,
314 int objc, Tcl_Obj *
const objv[]);
316 int objc, Tcl_Obj *
const objv[]);
330 Tcl_Obj **kvObjv,
int kvObjc,
349 static int fakeThreadKey;
351 return (ClientData) &(fakeThreadKey);
371 Tcl_FileProc *proc, ClientData clientData)
403 Tcl_NotifierProcs notifier;
414 Tcl_FindExecutable(
"");
428 Tcl_SetNotifier(¬ifier);
435 elog(
ERROR,
"could not create dummy Tcl interpreter");
437 elog(
ERROR,
"could not initialize dummy Tcl interpreter");
463 gettext_noop(
"PL/Tcl function to call once when pltcl is first used."),
470 gettext_noop(
"PL/TclU function to call once when pltclu is first used."),
497 snprintf(interpname,
sizeof(interpname),
"subsidiary_%u", interp_desc->
user_id);
499 pltrusted ? 1 : 0)) == NULL)
500 elog(
ERROR,
"could not create subsidiary Tcl interpreter");
505 Tcl_InitHashTable(&interp_desc->
query_hash, TCL_STRING_KEYS);
510 Tcl_CreateObjCommand(interp,
"elog",
512 Tcl_CreateObjCommand(interp,
"quote",
514 Tcl_CreateObjCommand(interp,
"argisnull",
516 Tcl_CreateObjCommand(interp,
"return_null",
518 Tcl_CreateObjCommand(interp,
"return_next",
520 Tcl_CreateObjCommand(interp,
"spi_exec",
522 Tcl_CreateObjCommand(interp,
"spi_prepare",
524 Tcl_CreateObjCommand(interp,
"spi_execp",
526 Tcl_CreateObjCommand(interp,
"subtransaction",
528 Tcl_CreateObjCommand(interp,
"commit",
530 Tcl_CreateObjCommand(interp,
"rollback",
542 interp_desc->
interp = interp;
547 interp_desc->
interp = NULL;
548 Tcl_DeleteInterp(interp);
576 interp_desc->
interp = NULL;
606 gucname = pltrusted ?
"pltcl.start_proc" :
"pltclu.start_proc";
609 if (start_proc == NULL || start_proc[0] ==
'\0')
630 elog(
ERROR,
"cache lookup failed for function %u", procOid);
634 if (procStruct->prolang != prolang)
636 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
637 errmsg(
"function \"%s\" is in the wrong language",
645 if (procStruct->prosecdef)
647 (
errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
648 errmsg(
"function \"%s\" must not be SECURITY DEFINER",
679 const char *gucname = (
const char *)
arg;
682 errcontext(
"processing %s parameter", gucname);
735 memset(¤t_call_state, 0,
sizeof(current_call_state));
765 current_call_state.
fcinfo = fcinfo;
777 if (current_call_state.
prodesc != NULL)
799 Tcl_Interp *
volatile interp;
805 nonatomic = fcinfo->context &&
811 elog(
ERROR,
"could not connect to SPI manager");
834 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
835 errmsg(
"set-valued function called in context that cannot accept a set")));
839 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
840 errmsg(
"materialize mode required, but it is not allowed in this context")));
842 call_state->
rsi = rsi;
851 tcl_cmd = Tcl_NewObj();
852 Tcl_ListObjAppendElement(NULL, tcl_cmd,
856 Tcl_IncrRefCount(tcl_cmd);
863 for (
i = 0;
i < prodesc->
nargs;
i++)
870 if (fcinfo->args[
i].isnull)
871 Tcl_ListObjAppendElement(NULL, tcl_cmd, Tcl_NewObj());
891 Tcl_ListObjAppendElement(NULL, tcl_cmd, list_tmp);
902 if (fcinfo->args[
i].isnull)
903 Tcl_ListObjAppendElement(NULL, tcl_cmd, Tcl_NewObj());
909 fcinfo->args[
i].value);
911 Tcl_ListObjAppendElement(NULL, tcl_cmd,
912 Tcl_NewStringObj(
UTF_E2U(tmp), -1));
922 Tcl_DecrRefCount(tcl_cmd);
932 tcl_rc = Tcl_EvalObjEx(interp, tcl_cmd, (TCL_EVAL_DIRECT | TCL_EVAL_GLOBAL));
935 Tcl_DecrRefCount(tcl_cmd);
940 if (tcl_rc != TCL_OK)
976 fcinfo->isnull =
true;
978 else if (fcinfo->isnull)
990 Tcl_Obj **resultObjv;
1012 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1013 errmsg(
"function returning record called in context "
1014 "that cannot accept type record")));
1018 elog(
ERROR,
"return type must be a row type");
1028 resultObj = Tcl_GetObjResult(interp);
1029 if (Tcl_ListObjGetElements(interp, resultObj, &resultObjc, &resultObjv) == TCL_ERROR)
1038 utf_u2e(Tcl_GetStringResult(interp)),
1054 Tcl_Interp *
volatile interp;
1060 Tcl_Obj *tcl_trigtup;
1065 Tcl_Obj **result_Objv;
1072 elog(
ERROR,
"could not connect to SPI manager");
1084 call_state->
prodesc = prodesc;
1095 tcl_cmd = Tcl_NewObj();
1096 Tcl_IncrRefCount(tcl_cmd);
1101 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1105 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1112 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1113 Tcl_NewStringObj(stroid, -1));
1118 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1119 Tcl_NewStringObj(
utf_e2u(stroid), -1));
1124 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1125 Tcl_NewStringObj(
utf_e2u(stroid), -1));
1129 tcl_trigtup = Tcl_NewObj();
1130 Tcl_ListObjAppendElement(NULL, tcl_trigtup, Tcl_NewObj());
1131 for (
i = 0;
i < tupdesc->natts;
i++)
1135 if (att->attisdropped)
1136 Tcl_ListObjAppendElement(NULL, tcl_trigtup, Tcl_NewObj());
1138 Tcl_ListObjAppendElement(NULL, tcl_trigtup,
1141 Tcl_ListObjAppendElement(NULL, tcl_cmd, tcl_trigtup);
1145 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1146 Tcl_NewStringObj(
"BEFORE", -1));
1148 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1149 Tcl_NewStringObj(
"AFTER", -1));
1151 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1152 Tcl_NewStringObj(
"INSTEAD OF", -1));
1159 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1160 Tcl_NewStringObj(
"ROW", -1));
1171 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1172 Tcl_NewStringObj(
"INSERT", -1));
1174 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1178 Tcl_ListObjAppendElement(NULL, tcl_cmd, Tcl_NewObj());
1184 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1185 Tcl_NewStringObj(
"DELETE", -1));
1187 Tcl_ListObjAppendElement(NULL, tcl_cmd, Tcl_NewObj());
1188 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1197 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1198 Tcl_NewStringObj(
"UPDATE", -1));
1200 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1204 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1216 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1217 Tcl_NewStringObj(
"STATEMENT", -1));
1220 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1221 Tcl_NewStringObj(
"INSERT", -1));
1223 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1224 Tcl_NewStringObj(
"DELETE", -1));
1226 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1227 Tcl_NewStringObj(
"UPDATE", -1));
1229 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1230 Tcl_NewStringObj(
"TRUNCATE", -1));
1234 Tcl_ListObjAppendElement(NULL, tcl_cmd, Tcl_NewObj());
1235 Tcl_ListObjAppendElement(NULL, tcl_cmd, Tcl_NewObj());
1244 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1249 Tcl_DecrRefCount(tcl_cmd);
1259 tcl_rc = Tcl_EvalObjEx(interp, tcl_cmd, (TCL_EVAL_DIRECT | TCL_EVAL_GLOBAL));
1262 Tcl_DecrRefCount(tcl_cmd);
1267 if (tcl_rc != TCL_OK)
1281 result = Tcl_GetStringResult(interp);
1283 if (strcmp(result,
"OK") == 0)
1285 if (strcmp(result,
"SKIP") == 0)
1292 if (Tcl_ListObjGetElements(interp, Tcl_GetObjResult(interp),
1293 &result_Objc, &result_Objv) != TCL_OK)
1295 (
errcode(ERRCODE_E_R_I_E_TRIGGER_PROTOCOL_VIOLATED),
1296 errmsg(
"could not split return value from trigger: %s",
1297 utf_u2e(Tcl_GetStringResult(interp)))));
1314 Tcl_Interp *
volatile interp;
1321 elog(
ERROR,
"could not connect to SPI manager");
1327 call_state->
prodesc = prodesc;
1333 tcl_cmd = Tcl_NewObj();
1334 Tcl_IncrRefCount(tcl_cmd);
1335 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1337 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1339 Tcl_ListObjAppendElement(NULL, tcl_cmd,
1343 tcl_rc = Tcl_EvalObjEx(interp, tcl_cmd, (TCL_EVAL_DIRECT | TCL_EVAL_GLOBAL));
1346 Tcl_DecrRefCount(tcl_cmd);
1349 if (tcl_rc != TCL_OK)
1374 econtext =
utf_u2e(Tcl_GetVar(interp,
"errorInfo", TCL_GLOBAL_ONLY));
1376 (
errcode(ERRCODE_EXTERNAL_ROUTINE_EXCEPTION),
1391 bool is_event_trigger,
bool pltrusted)
1401 Tcl_DString proc_internal_def;
1402 Tcl_DString proc_internal_body;
1407 elog(
ERROR,
"cache lookup failed for function %u", fn_oid);
1431 if (prodesc != NULL &&
1448 Tcl_DStringInit(&proc_internal_def);
1449 Tcl_DStringInit(&proc_internal_body);
1453 char internal_proname[128];
1471 if (is_event_trigger)
1472 snprintf(internal_proname,
sizeof(internal_proname),
1473 "__PLTcl_proc_%u_evttrigger", fn_oid);
1474 else if (is_trigger)
1475 snprintf(internal_proname,
sizeof(internal_proname),
1476 "__PLTcl_proc_%u_trigger", fn_oid);
1478 snprintf(internal_proname,
sizeof(internal_proname),
1479 "__PLTcl_proc_%u", fn_oid);
1497 prodesc->
fn_cxt = proc_cxt;
1501 prodesc->
nargs = procStruct->pronargs;
1508 (procStruct->provolatile != PROVOLATILE_VOLATILE);
1523 if (!is_trigger && !is_event_trigger)
1525 Oid rettype = procStruct->prorettype;
1529 elog(
ERROR,
"cache lookup failed for type %u", rettype);
1533 if (typeStruct->typtype == TYPTYPE_PSEUDO)
1535 if (rettype == VOIDOID ||
1536 rettype == RECORDOID)
1538 else if (rettype == TRIGGEROID ||
1539 rettype == EVENT_TRIGGEROID)
1541 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1542 errmsg(
"trigger functions can only be called as triggers")));
1545 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1546 errmsg(
"PL/Tcl functions cannot return type %s",
1558 prodesc->
fn_retisdomain = (typeStruct->typtype == TYPTYPE_DOMAIN);
1568 if (!is_trigger && !is_event_trigger)
1570 proc_internal_args[0] =
'\0';
1571 for (
i = 0;
i < prodesc->
nargs;
i++)
1573 Oid argtype = procStruct->proargtypes.values[
i];
1577 elog(
ERROR,
"cache lookup failed for type %u", argtype);
1581 if (typeStruct->typtype == TYPTYPE_PSEUDO &&
1582 argtype != RECORDOID)
1584 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
1585 errmsg(
"PL/Tcl functions cannot accept type %s",
1603 strcat(proc_internal_args,
" ");
1604 strcat(proc_internal_args,
buf);
1609 else if (is_trigger)
1612 strcpy(proc_internal_args,
1613 "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");
1615 else if (is_event_trigger)
1618 strcpy(proc_internal_args,
"TG_event TG_tag");
1629 Tcl_DStringAppendElement(&proc_internal_def,
"proc");
1630 Tcl_DStringAppendElement(&proc_internal_def, internal_proname);
1631 Tcl_DStringAppendElement(&proc_internal_def, proc_internal_args);
1638 Tcl_DStringAppend(&proc_internal_body,
"upvar #0 ", -1);
1639 Tcl_DStringAppend(&proc_internal_body, internal_proname, -1);
1640 Tcl_DStringAppend(&proc_internal_body,
" GD\n", -1);
1643 Tcl_DStringAppend(&proc_internal_body,
1644 "array set NEW $__PLTcl_Tup_NEW\n", -1);
1645 Tcl_DStringAppend(&proc_internal_body,
1646 "array set OLD $__PLTcl_Tup_OLD\n", -1);
1647 Tcl_DStringAppend(&proc_internal_body,
1650 "foreach v $args {\n"
1654 "unset i v\n\n", -1);
1656 else if (is_event_trigger)
1662 for (
i = 0;
i < prodesc->
nargs;
i++)
1667 "array set %d $__PLTcl_Tup_%d\n",
1669 Tcl_DStringAppend(&proc_internal_body,
buf, -1);
1678 Anum_pg_proc_prosrc, &isnull);
1683 Tcl_DStringAppend(&proc_internal_body,
UTF_E2U(proc_source), -1);
1686 Tcl_DStringAppendElement(&proc_internal_def,
1687 Tcl_DStringValue(&proc_internal_body));
1692 tcl_rc = Tcl_EvalEx(interp,
1693 Tcl_DStringValue(&proc_internal_def),
1694 Tcl_DStringLength(&proc_internal_def),
1696 if (tcl_rc != TCL_OK)
1698 (
errcode(ERRCODE_EXTERNAL_ROUTINE_EXCEPTION),
1699 errmsg(
"could not create internal procedure \"%s\": %s",
1701 utf_u2e(Tcl_GetStringResult(interp)))));
1711 Tcl_DStringFree(&proc_internal_def);
1712 Tcl_DStringFree(&proc_internal_body);
1732 if (old_prodesc != NULL)
1739 Tcl_DStringFree(&proc_internal_def);
1740 Tcl_DStringFree(&proc_internal_body);
1753 int objc, Tcl_Obj *
const objv[])
1759 static const char *logpriorities[] = {
1760 "DEBUG",
"LOG",
"INFO",
"NOTICE",
1761 "WARNING",
"ERROR",
"FATAL", (
const char *) NULL
1764 static const int loglevels[] = {
1771 Tcl_WrongNumArgs(interp, 1, objv,
"level msg");
1775 if (Tcl_GetIndexFromObj(interp, objv[1], logpriorities,
"priority",
1776 TCL_EXACT, &priIndex) != TCL_OK)
1779 level = loglevels[priIndex];
1788 Tcl_SetObjResult(interp, objv[2]);
1806 (
errcode(ERRCODE_EXTERNAL_ROUTINE_EXCEPTION),
1822 Tcl_SetObjResult(interp, Tcl_NewStringObj(
UTF_E2U(edata->
message), -1));
1841 Tcl_Obj *obj = Tcl_NewObj();
1843 Tcl_ListObjAppendElement(interp, obj,
1844 Tcl_NewStringObj(
"POSTGRES", -1));
1845 Tcl_ListObjAppendElement(interp, obj,
1846 Tcl_NewStringObj(PG_VERSION, -1));
1847 Tcl_ListObjAppendElement(interp, obj,
1848 Tcl_NewStringObj(
"SQLSTATE", -1));
1849 Tcl_ListObjAppendElement(interp, obj,
1851 Tcl_ListObjAppendElement(interp, obj,
1852 Tcl_NewStringObj(
"condition", -1));
1853 Tcl_ListObjAppendElement(interp, obj,
1855 Tcl_ListObjAppendElement(interp, obj,
1856 Tcl_NewStringObj(
"message", -1));
1858 Tcl_ListObjAppendElement(interp, obj,
1863 Tcl_ListObjAppendElement(interp, obj,
1864 Tcl_NewStringObj(
"detail", -1));
1866 Tcl_ListObjAppendElement(interp, obj,
1872 Tcl_ListObjAppendElement(interp, obj,
1873 Tcl_NewStringObj(
"hint", -1));
1875 Tcl_ListObjAppendElement(interp, obj,
1881 Tcl_ListObjAppendElement(interp, obj,
1882 Tcl_NewStringObj(
"context", -1));
1884 Tcl_ListObjAppendElement(interp, obj,
1890 Tcl_ListObjAppendElement(interp, obj,
1891 Tcl_NewStringObj(
"schema", -1));
1893 Tcl_ListObjAppendElement(interp, obj,
1899 Tcl_ListObjAppendElement(interp, obj,
1900 Tcl_NewStringObj(
"table", -1));
1902 Tcl_ListObjAppendElement(interp, obj,
1908 Tcl_ListObjAppendElement(interp, obj,
1909 Tcl_NewStringObj(
"column", -1));
1911 Tcl_ListObjAppendElement(interp, obj,
1917 Tcl_ListObjAppendElement(interp, obj,
1918 Tcl_NewStringObj(
"datatype", -1));
1920 Tcl_ListObjAppendElement(interp, obj,
1926 Tcl_ListObjAppendElement(interp, obj,
1927 Tcl_NewStringObj(
"constraint", -1));
1929 Tcl_ListObjAppendElement(interp, obj,
1936 Tcl_ListObjAppendElement(interp, obj,
1937 Tcl_NewStringObj(
"statement", -1));
1939 Tcl_ListObjAppendElement(interp, obj,
1945 Tcl_ListObjAppendElement(interp, obj,
1946 Tcl_NewStringObj(
"cursor_position", -1));
1947 Tcl_ListObjAppendElement(interp, obj,
1952 Tcl_ListObjAppendElement(interp, obj,
1953 Tcl_NewStringObj(
"filename", -1));
1955 Tcl_ListObjAppendElement(interp, obj,
1961 Tcl_ListObjAppendElement(interp, obj,
1962 Tcl_NewStringObj(
"lineno", -1));
1963 Tcl_ListObjAppendElement(interp, obj,
1964 Tcl_NewIntObj(edata->
lineno));
1968 Tcl_ListObjAppendElement(interp, obj,
1969 Tcl_NewStringObj(
"funcname", -1));
1971 Tcl_ListObjAppendElement(interp, obj,
1976 Tcl_SetObjErrorCode(interp, obj);
1993 return "unrecognized_sqlstate";
2003 int objc, Tcl_Obj *
const objv[])
2015 Tcl_WrongNumArgs(interp, 1, objv,
"string");
2023 cp1 = Tcl_GetStringFromObj(objv[1], &length);
2024 tmp =
palloc(length * 2 + 1);
2046 Tcl_SetObjResult(interp, Tcl_NewStringObj(tmp, -1));
2057 int objc, Tcl_Obj *
const objv[])
2067 Tcl_WrongNumArgs(interp, 1, objv,
"argno");
2076 Tcl_SetObjResult(interp,
2077 Tcl_NewStringObj(
"argisnull cannot be used in triggers", -1));
2084 if (Tcl_GetIntFromObj(interp, objv[1], &argno) != TCL_OK)
2091 if (argno < 0 || argno >= fcinfo->
nargs)
2093 Tcl_SetObjResult(interp,
2094 Tcl_NewStringObj(
"argno out of range", -1));
2101 Tcl_SetObjResult(interp, Tcl_NewBooleanObj(
PG_ARGISNULL(argno)));
2111 int objc, Tcl_Obj *
const objv[])
2120 Tcl_WrongNumArgs(interp, 1, objv,
"");
2129 Tcl_SetObjResult(interp,
2130 Tcl_NewStringObj(
"return_null cannot be used in triggers", -1));
2149 int objc, Tcl_Obj *
const objv[])
2156 volatile int result = TCL_OK;
2163 Tcl_SetObjResult(interp,
2164 Tcl_NewStringObj(
"return_next cannot be used in triggers", -1));
2170 Tcl_SetObjResult(interp,
2171 Tcl_NewStringObj(
"return_next cannot be used in non-set-returning functions", -1));
2180 Tcl_WrongNumArgs(interp, 1, objv,
"result");
2205 if (Tcl_ListObjGetElements(interp, objv[1], &rowObjc, &rowObjv) == TCL_ERROR)
2219 bool isNull =
false;
2223 elog(
ERROR,
"wrong result type supplied in return_next");
2226 utf_u2e((
char *) Tcl_GetString(objv[1])),
2307 Tcl_SetObjResult(interp, Tcl_NewStringObj(
UTF_E2U(edata->
message), -1));
2319 int objc, Tcl_Obj *
const objv[])
2327 const char *
volatile arrayname = NULL;
2328 Tcl_Obj *
volatile loop_body = NULL;
2334 OPT_ARRAY, OPT_COUNT
2337 static const char *
options[] = {
2338 "-array",
"-count", (
const char *) NULL
2346 Tcl_WrongNumArgs(interp, 1, objv,
2347 "?-count n? ?-array name? query ?loop body?");
2354 if (Tcl_GetIndexFromObj(NULL, objv[
i],
options, NULL,
2355 TCL_EXACT, &optIndex) != TCL_OK)
2360 Tcl_SetObjResult(interp,
2361 Tcl_NewStringObj(
"missing argument to -count or -array", -1));
2365 switch ((
enum options) optIndex)
2368 arrayname = Tcl_GetString(objv[
i++]);
2372 if (Tcl_GetIntFromObj(interp, objv[
i++], &count) != TCL_OK)
2379 if (query_idx >= objc || query_idx + 2 < objc)
2381 Tcl_WrongNumArgs(interp, query_idx - 1, objv,
"query ?loop body?");
2385 if (query_idx + 1 < objc)
2386 loop_body = objv[query_idx + 1];
2428 const char *arrayname,
2445 Tcl_SetObjResult(interp, Tcl_NewWideIntObj(ntuples));
2450 if (tuptable == NULL)
2452 Tcl_SetObjResult(interp, Tcl_NewIntObj(0));
2466 tuples = tuptable->
vals;
2469 if (loop_body == NULL)
2477 tuples[0], tupdesc);
2487 for (
i = 0;
i < ntuples;
i++)
2490 tuples[
i], tupdesc);
2492 loop_rc = Tcl_EvalObjEx(interp, loop_body, 0);
2494 if (loop_rc == TCL_OK)
2496 if (loop_rc == TCL_CONTINUE)
2498 if (loop_rc == TCL_RETURN)
2503 if (loop_rc == TCL_BREAK)
2510 if (my_rc == TCL_OK)
2512 Tcl_SetObjResult(interp, Tcl_NewWideIntObj(ntuples));
2517 Tcl_AppendResult(interp,
"pltcl: SPI_execute failed: ",
2539 int objc, Tcl_Obj *
const objv[])
2546 Tcl_HashEntry *hashent;
2548 Tcl_HashTable *query_hash;
2557 Tcl_WrongNumArgs(interp, 1, objv,
"query argtypes");
2564 if (Tcl_ListObjGetElements(interp, objv[2], &nargs, &argsObj) != TCL_OK)
2575 "PL/Tcl spi_prepare query",
2580 qdesc->
nargs = nargs;
2600 for (
i = 0;
i < nargs;
i++)
2624 if (qdesc->
plan == NULL)
2652 hashent = Tcl_CreateHashEntry(query_hash, qdesc->
qname, &hashnew);
2653 Tcl_SetHashValue(hashent, (ClientData) qdesc);
2656 Tcl_SetObjResult(interp, Tcl_NewStringObj(qdesc->
qname, -1));
2666 int objc, Tcl_Obj *
const objv[])
2673 Tcl_HashEntry *hashent;
2675 const char *nulls = NULL;
2676 const char *arrayname = NULL;
2677 Tcl_Obj *loop_body = NULL;
2680 Tcl_Obj **callObjv = NULL;
2684 Tcl_HashTable *query_hash;
2688 OPT_ARRAY, OPT_COUNT, OPT_NULLS
2691 static const char *
options[] = {
2692 "-array",
"-count",
"-nulls", (
const char *) NULL
2701 if (Tcl_GetIndexFromObj(NULL, objv[
i],
options, NULL,
2702 TCL_EXACT, &optIndex) != TCL_OK)
2707 Tcl_SetObjResult(interp,
2708 Tcl_NewStringObj(
"missing argument to -array, -count or -nulls", -1));
2712 switch ((
enum options) optIndex)
2715 arrayname = Tcl_GetString(objv[
i++]);
2719 if (Tcl_GetIntFromObj(interp, objv[
i++], &count) != TCL_OK)
2724 nulls = Tcl_GetString(objv[
i++]);
2734 Tcl_SetObjResult(interp,
2735 Tcl_NewStringObj(
"missing argument to -count or -array", -1));
2741 hashent = Tcl_FindHashEntry(query_hash, Tcl_GetString(objv[
i]));
2742 if (hashent == NULL)
2744 Tcl_AppendResult(interp,
"invalid queryid '", Tcl_GetString(objv[
i]),
"'", NULL);
2755 if (strlen(nulls) != qdesc->
nargs)
2757 Tcl_SetObjResult(interp,
2758 Tcl_NewStringObj(
"length of nulls string doesn't match number of arguments",
2768 if (qdesc->
nargs > 0)
2772 Tcl_SetObjResult(interp,
2773 Tcl_NewStringObj(
"argument list length doesn't match number of arguments for query",
2781 if (Tcl_ListObjGetElements(interp, objv[
i++], &callObjc, &callObjv) != TCL_OK)
2787 if (callObjc != qdesc->
nargs)
2789 Tcl_SetObjResult(interp,
2790 Tcl_NewStringObj(
"argument list length doesn't match number of arguments for query",
2802 loop_body = objv[
i++];
2806 Tcl_WrongNumArgs(interp, 1, objv,
2807 "?-count n? ?-array name? ?-nulls string? "
2808 "query ?args? ?loop body?");
2827 for (
j = 0;
j < callObjc;
j++)
2829 if (nulls && nulls[
j] ==
'n')
2840 UTF_U2E(Tcl_GetString(callObjv[
j])),
2882 int objc, Tcl_Obj *
const objv[])
2890 Tcl_WrongNumArgs(interp, 1, objv,
"command");
2902 retcode = Tcl_EvalObjEx(interp, objv[1], 0);
2904 if (retcode == TCL_ERROR)
2930 int objc, Tcl_Obj *
const objv[])
2950 Tcl_SetObjResult(interp, Tcl_NewStringObj(
UTF_E2U(edata->
message), -1));
2969 int objc, Tcl_Obj *
const objv[])
2989 Tcl_SetObjResult(interp, Tcl_NewStringObj(
UTF_E2U(edata->
message), -1));
3018 const char **arrptr;
3019 const char **nameptr;
3020 const char *nullname = NULL;
3025 if (arrayname == NULL)
3028 nameptr = &nullname;
3032 arrptr = &arrayname;
3040 Tcl_SetVar2Ex(interp, arrayname,
".tupno", Tcl_NewWideIntObj(tupno), 0);
3043 for (
i = 0;
i < tupdesc->
natts;
i++)
3048 if (att->attisdropped)
3076 Tcl_SetVar2Ex(interp, *arrptr, *nameptr,
3077 Tcl_NewStringObj(
UTF_E2U(outputstr), -1), 0);
3082 Tcl_UnsetVar2(interp, *arrptr, *nameptr, 0);
3096 Tcl_Obj *retobj = Tcl_NewObj();
3105 for (
i = 0;
i < tupdesc->
natts;
i++)
3110 if (att->attisdropped)
3113 if (att->attgenerated)
3116 if (!include_generated)
3141 &typoutput, &typisvarlena);
3144 Tcl_ListObjAppendElement(NULL, retobj,
3148 Tcl_ListObjAppendElement(NULL, retobj,
3149 Tcl_NewStringObj(
UTF_E2U(outputstr), -1));
3191 elog(
ERROR,
"PL/Tcl function does not return a tuple");
3198 if (kvObjc % 2 != 0)
3200 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
3201 errmsg(
"column name/value list must have even number of elements")));
3203 for (
i = 0;
i < kvObjc;
i += 2)
3205 char *fieldName =
utf_u2e(Tcl_GetString(kvObjv[
i]));
3215 if (strcmp(fieldName,
".tupno") == 0)
3218 (
errcode(ERRCODE_UNDEFINED_COLUMN),
3219 errmsg(
"column name/value list contains nonexistent column name \"%s\"",
3225 (
errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
3226 errmsg(
"cannot set system attribute \"%s\"",
3231 (
errcode(ERRCODE_E_R_I_E_TRIGGER_PROTOCOL_VIOLATED),
3232 errmsg(
"cannot set generated column \"%s\"",
void aclcheck_error(AclResult aclerr, ObjectType objtype, const char *objectname)
AclResult pg_proc_aclcheck(Oid proc_oid, 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)
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
#define HeapTupleGetDatum(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)
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)
void parseTypeString(const char *str, Oid *typeid_p, int32 *typmod_p, bool missing_ok)
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[])
#define ObjectIdGetDatum(X)
#define DatumGetCString(X)
#define PointerGetDatum(X)
static int fd(const char *x, int i)
List * stringToQualifiedNameList(const char *string)
#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 SysCacheGetAttr(int cacheId, HeapTuple tup, AttrNumber attributeNumber, bool *isNull)
#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)