Line data Source code
1 : /*-------------------------------------------------------------------------
2 : *
3 : * execSRF.c
4 : * Routines implementing the API for set-returning functions
5 : *
6 : * This file serves nodeFunctionscan.c and nodeProjectSet.c, providing
7 : * common code for calling set-returning functions according to the
8 : * ReturnSetInfo API.
9 : *
10 : * Portions Copyright (c) 1996-2024, PostgreSQL Global Development Group
11 : * Portions Copyright (c) 1994, Regents of the University of California
12 : *
13 : *
14 : * IDENTIFICATION
15 : * src/backend/executor/execSRF.c
16 : *
17 : *-------------------------------------------------------------------------
18 : */
19 : #include "postgres.h"
20 :
21 : #include "access/htup_details.h"
22 : #include "catalog/objectaccess.h"
23 : #include "catalog/pg_proc.h"
24 : #include "funcapi.h"
25 : #include "miscadmin.h"
26 : #include "nodes/nodeFuncs.h"
27 : #include "parser/parse_coerce.h"
28 : #include "pgstat.h"
29 : #include "utils/acl.h"
30 : #include "utils/builtins.h"
31 : #include "utils/lsyscache.h"
32 : #include "utils/memutils.h"
33 : #include "utils/typcache.h"
34 :
35 :
36 : /* static function decls */
37 : static void init_sexpr(Oid foid, Oid input_collation, Expr *node,
38 : SetExprState *sexpr, PlanState *parent,
39 : MemoryContext sexprCxt, bool allowSRF, bool needDescForSRF);
40 : static void ShutdownSetExpr(Datum arg);
41 : static void ExecEvalFuncArgs(FunctionCallInfo fcinfo,
42 : List *argList, ExprContext *econtext);
43 : static void ExecPrepareTuplestoreResult(SetExprState *sexpr,
44 : ExprContext *econtext,
45 : Tuplestorestate *resultStore,
46 : TupleDesc resultDesc);
47 : static void tupledesc_match(TupleDesc dst_tupdesc, TupleDesc src_tupdesc);
48 :
49 :
50 : /*
51 : * Prepare function call in FROM (ROWS FROM) for execution.
52 : *
53 : * This is used by nodeFunctionscan.c.
54 : */
55 : SetExprState *
56 61550 : ExecInitTableFunctionResult(Expr *expr,
57 : ExprContext *econtext, PlanState *parent)
58 : {
59 61550 : SetExprState *state = makeNode(SetExprState);
60 :
61 61550 : state->funcReturnsSet = false;
62 61550 : state->expr = expr;
63 61550 : state->func.fn_oid = InvalidOid;
64 :
65 : /*
66 : * Normally the passed expression tree will be a FuncExpr, since the
67 : * grammar only allows a function call at the top level of a table
68 : * function reference. However, if the function doesn't return set then
69 : * the planner might have replaced the function call via constant-folding
70 : * or inlining. So if we see any other kind of expression node, execute
71 : * it via the general ExecEvalExpr() code. That code path will not
72 : * support set-returning functions buried in the expression, though.
73 : */
74 61550 : if (IsA(expr, FuncExpr))
75 : {
76 61436 : FuncExpr *func = (FuncExpr *) expr;
77 :
78 61436 : state->funcReturnsSet = func->funcretset;
79 61436 : state->args = ExecInitExprList(func->args, parent);
80 :
81 61436 : init_sexpr(func->funcid, func->inputcollid, expr, state, parent,
82 61436 : econtext->ecxt_per_query_memory, func->funcretset, false);
83 : }
84 : else
85 : {
86 114 : state->elidedFuncState = ExecInitExpr(expr, parent);
87 : }
88 :
89 61542 : return state;
90 : }
91 :
92 : /*
93 : * ExecMakeTableFunctionResult
94 : *
95 : * Evaluate a table function, producing a materialized result in a Tuplestore
96 : * object.
97 : *
98 : * This is used by nodeFunctionscan.c.
99 : */
100 : Tuplestorestate *
101 138486 : ExecMakeTableFunctionResult(SetExprState *setexpr,
102 : ExprContext *econtext,
103 : MemoryContext argContext,
104 : TupleDesc expectedDesc,
105 : bool randomAccess)
106 : {
107 138486 : Tuplestorestate *tupstore = NULL;
108 138486 : TupleDesc tupdesc = NULL;
109 : Oid funcrettype;
110 : bool returnsTuple;
111 138486 : bool returnsSet = false;
112 : FunctionCallInfo fcinfo;
113 : PgStat_FunctionCallUsage fcusage;
114 : ReturnSetInfo rsinfo;
115 : HeapTupleData tmptup;
116 : MemoryContext callerContext;
117 138486 : bool first_time = true;
118 :
119 : /*
120 : * Execute per-tablefunc actions in appropriate context.
121 : *
122 : * The FunctionCallInfo needs to live across all the calls to a
123 : * ValuePerCall function, so it can't be allocated in the per-tuple
124 : * context. Similarly, the function arguments need to be evaluated in a
125 : * context that is longer lived than the per-tuple context: The argument
126 : * values would otherwise disappear when we reset that context in the
127 : * inner loop. As the caller's CurrentMemoryContext is typically a
128 : * query-lifespan context, we don't want to leak memory there. We require
129 : * the caller to pass a separate memory context that can be used for this,
130 : * and can be reset each time through to avoid bloat.
131 : */
132 138486 : MemoryContextReset(argContext);
133 138486 : callerContext = MemoryContextSwitchTo(argContext);
134 :
135 138486 : funcrettype = exprType((Node *) setexpr->expr);
136 :
137 138486 : returnsTuple = type_is_rowtype(funcrettype);
138 :
139 : /*
140 : * Prepare a resultinfo node for communication. We always do this even if
141 : * not expecting a set result, so that we can pass expectedDesc. In the
142 : * generic-expression case, the expression doesn't actually get to see the
143 : * resultinfo, but set it up anyway because we use some of the fields as
144 : * our own state variables.
145 : */
146 138486 : rsinfo.type = T_ReturnSetInfo;
147 138486 : rsinfo.econtext = econtext;
148 138486 : rsinfo.expectedDesc = expectedDesc;
149 138486 : rsinfo.allowedModes = (int) (SFRM_ValuePerCall | SFRM_Materialize | SFRM_Materialize_Preferred);
150 138486 : if (randomAccess)
151 78 : rsinfo.allowedModes |= (int) SFRM_Materialize_Random;
152 138486 : rsinfo.returnMode = SFRM_ValuePerCall;
153 : /* isDone is filled below */
154 138486 : rsinfo.setResult = NULL;
155 138486 : rsinfo.setDesc = NULL;
156 :
157 138486 : fcinfo = palloc(SizeForFunctionCallInfo(list_length(setexpr->args)));
158 :
159 : /*
160 : * Normally the passed expression tree will be a SetExprState, since the
161 : * grammar only allows a function call at the top level of a table
162 : * function reference. However, if the function doesn't return set then
163 : * the planner might have replaced the function call via constant-folding
164 : * or inlining. So if we see any other kind of expression node, execute
165 : * it via the general ExecEvalExpr() code; the only difference is that we
166 : * don't get a chance to pass a special ReturnSetInfo to any functions
167 : * buried in the expression.
168 : */
169 138486 : if (!setexpr->elidedFuncState)
170 : {
171 : /*
172 : * This path is similar to ExecMakeFunctionResultSet.
173 : */
174 138372 : returnsSet = setexpr->funcReturnsSet;
175 138372 : InitFunctionCallInfoData(*fcinfo, &(setexpr->func),
176 : list_length(setexpr->args),
177 : setexpr->fcinfo->fncollation,
178 : NULL, (Node *) &rsinfo);
179 : /* evaluate the function's argument list */
180 : Assert(CurrentMemoryContext == argContext);
181 138372 : ExecEvalFuncArgs(fcinfo, setexpr->args, econtext);
182 :
183 : /*
184 : * If function is strict, and there are any NULL arguments, skip
185 : * calling the function and act like it returned NULL (or an empty
186 : * set, in the returns-set case).
187 : */
188 138356 : if (setexpr->func.fn_strict)
189 : {
190 : int i;
191 :
192 271106 : for (i = 0; i < fcinfo->nargs; i++)
193 : {
194 190776 : if (fcinfo->args[i].isnull)
195 41176 : goto no_function_result;
196 : }
197 : }
198 : }
199 : else
200 : {
201 : /* Treat setexpr as a generic expression */
202 114 : InitFunctionCallInfoData(*fcinfo, NULL, 0, InvalidOid, NULL, NULL);
203 : }
204 :
205 : /*
206 : * Switch to short-lived context for calling the function or expression.
207 : */
208 97294 : MemoryContextSwitchTo(econtext->ecxt_per_tuple_memory);
209 :
210 : /*
211 : * Loop to handle the ValuePerCall protocol (which is also the same
212 : * behavior needed in the generic ExecEvalExpr path).
213 : */
214 : for (;;)
215 17292844 : {
216 : Datum result;
217 :
218 17390138 : CHECK_FOR_INTERRUPTS();
219 :
220 : /*
221 : * Reset per-tuple memory context before each call of the function or
222 : * expression. This cleans up any local memory the function may leak
223 : * when called.
224 : */
225 17390136 : ResetExprContext(econtext);
226 :
227 : /* Call the function or expression one time */
228 17390136 : if (!setexpr->elidedFuncState)
229 : {
230 17390022 : pgstat_init_function_usage(fcinfo, &fcusage);
231 :
232 17390022 : fcinfo->isnull = false;
233 17390022 : rsinfo.isDone = ExprSingleResult;
234 17390022 : result = FunctionCallInvoke(fcinfo);
235 :
236 17384968 : pgstat_end_function_usage(&fcusage,
237 17384968 : rsinfo.isDone != ExprMultipleResult);
238 : }
239 : else
240 : {
241 114 : result =
242 114 : ExecEvalExpr(setexpr->elidedFuncState, econtext, &fcinfo->isnull);
243 114 : rsinfo.isDone = ExprSingleResult;
244 : }
245 :
246 : /* Which protocol does function want to use? */
247 17385082 : if (rsinfo.returnMode == SFRM_ValuePerCall)
248 : {
249 : /*
250 : * Check for end of result set.
251 : */
252 17367442 : if (rsinfo.isDone == ExprEndResult)
253 92238 : break;
254 :
255 : /*
256 : * If first time through, build tuplestore for result. For a
257 : * scalar function result type, also make a suitable tupdesc.
258 : */
259 17327828 : if (first_time)
260 : {
261 : MemoryContext oldcontext =
262 73506 : MemoryContextSwitchTo(econtext->ecxt_per_query_memory);
263 :
264 73506 : tupstore = tuplestore_begin_heap(randomAccess, false, work_mem);
265 73506 : rsinfo.setResult = tupstore;
266 73506 : if (!returnsTuple)
267 : {
268 43038 : tupdesc = CreateTemplateTupleDesc(1);
269 43038 : TupleDescInitEntry(tupdesc,
270 : (AttrNumber) 1,
271 : "column",
272 : funcrettype,
273 : -1,
274 : 0);
275 43038 : rsinfo.setDesc = tupdesc;
276 : }
277 73506 : MemoryContextSwitchTo(oldcontext);
278 : }
279 :
280 : /*
281 : * Store current resultset item.
282 : */
283 17327828 : if (returnsTuple)
284 : {
285 1610526 : if (!fcinfo->isnull)
286 : {
287 1610462 : HeapTupleHeader td = DatumGetHeapTupleHeader(result);
288 :
289 1610462 : if (tupdesc == NULL)
290 : {
291 : MemoryContext oldcontext =
292 30428 : MemoryContextSwitchTo(econtext->ecxt_per_query_memory);
293 :
294 : /*
295 : * This is the first non-NULL result from the
296 : * function. Use the type info embedded in the
297 : * rowtype Datum to look up the needed tupdesc. Make
298 : * a copy for the query.
299 : */
300 30428 : tupdesc = lookup_rowtype_tupdesc_copy(HeapTupleHeaderGetTypeId(td),
301 : HeapTupleHeaderGetTypMod(td));
302 30428 : rsinfo.setDesc = tupdesc;
303 30428 : MemoryContextSwitchTo(oldcontext);
304 : }
305 : else
306 : {
307 : /*
308 : * Verify all later returned rows have same subtype;
309 : * necessary in case the type is RECORD.
310 : */
311 1580034 : if (HeapTupleHeaderGetTypeId(td) != tupdesc->tdtypeid ||
312 1580034 : HeapTupleHeaderGetTypMod(td) != tupdesc->tdtypmod)
313 0 : ereport(ERROR,
314 : (errcode(ERRCODE_DATATYPE_MISMATCH),
315 : errmsg("rows returned by function are not all of the same row type")));
316 : }
317 :
318 : /*
319 : * tuplestore_puttuple needs a HeapTuple not a bare
320 : * HeapTupleHeader, but it doesn't need all the fields.
321 : */
322 1610462 : tmptup.t_len = HeapTupleHeaderGetDatumLength(td);
323 1610462 : tmptup.t_data = td;
324 :
325 1610462 : tuplestore_puttuple(tupstore, &tmptup);
326 : }
327 : else
328 : {
329 : /*
330 : * NULL result from a tuple-returning function; expand it
331 : * to a row of all nulls. We rely on the expectedDesc to
332 : * form such rows. (Note: this would be problematic if
333 : * tuplestore_putvalues saved the tdtypeid/tdtypmod from
334 : * the provided descriptor, since that might not match
335 : * what we get from the function itself. But it doesn't.)
336 : */
337 64 : int natts = expectedDesc->natts;
338 : bool *nullflags;
339 :
340 64 : nullflags = (bool *) palloc(natts * sizeof(bool));
341 64 : memset(nullflags, true, natts * sizeof(bool));
342 64 : tuplestore_putvalues(tupstore, expectedDesc, NULL, nullflags);
343 : }
344 : }
345 : else
346 : {
347 : /* Scalar-type case: just store the function result */
348 15717302 : tuplestore_putvalues(tupstore, tupdesc, &result, &fcinfo->isnull);
349 : }
350 :
351 : /*
352 : * Are we done?
353 : */
354 17327828 : if (rsinfo.isDone != ExprMultipleResult)
355 34984 : break;
356 :
357 : /*
358 : * Check that set-returning functions were properly declared.
359 : * (Note: for historical reasons, we don't complain if a non-SRF
360 : * returns ExprEndResult; that's treated as returning NULL.)
361 : */
362 17292844 : if (!returnsSet)
363 0 : ereport(ERROR,
364 : (errcode(ERRCODE_E_R_I_E_SRF_PROTOCOL_VIOLATED),
365 : errmsg("table-function protocol for value-per-call mode was not followed")));
366 : }
367 17640 : else if (rsinfo.returnMode == SFRM_Materialize)
368 : {
369 : /* check we're on the same page as the function author */
370 17640 : if (!first_time || rsinfo.isDone != ExprSingleResult || !returnsSet)
371 0 : ereport(ERROR,
372 : (errcode(ERRCODE_E_R_I_E_SRF_PROTOCOL_VIOLATED),
373 : errmsg("table-function protocol for materialize mode was not followed")));
374 : /* Done evaluating the set result */
375 17640 : break;
376 : }
377 : else
378 0 : ereport(ERROR,
379 : (errcode(ERRCODE_E_R_I_E_SRF_PROTOCOL_VIOLATED),
380 : errmsg("unrecognized table-function returnMode: %d",
381 : (int) rsinfo.returnMode)));
382 :
383 17292844 : first_time = false;
384 : }
385 :
386 133414 : no_function_result:
387 :
388 : /*
389 : * If we got nothing from the function (ie, an empty-set or NULL result),
390 : * we have to create the tuplestore to return, and if it's a
391 : * non-set-returning function then insert a single all-nulls row. As
392 : * above, we depend on the expectedDesc to manufacture the dummy row.
393 : */
394 133414 : if (rsinfo.setResult == NULL)
395 : {
396 : MemoryContext oldcontext =
397 42296 : MemoryContextSwitchTo(econtext->ecxt_per_query_memory);
398 :
399 42296 : tupstore = tuplestore_begin_heap(randomAccess, false, work_mem);
400 42296 : rsinfo.setResult = tupstore;
401 42296 : MemoryContextSwitchTo(oldcontext);
402 :
403 42296 : if (!returnsSet)
404 : {
405 14 : int natts = expectedDesc->natts;
406 : bool *nullflags;
407 :
408 14 : nullflags = (bool *) palloc(natts * sizeof(bool));
409 14 : memset(nullflags, true, natts * sizeof(bool));
410 14 : tuplestore_putvalues(tupstore, expectedDesc, NULL, nullflags);
411 : }
412 : }
413 :
414 : /*
415 : * If function provided a tupdesc, cross-check it. We only really need to
416 : * do this for functions returning RECORD, but might as well do it always.
417 : */
418 133414 : if (rsinfo.setDesc)
419 : {
420 91072 : tupledesc_match(expectedDesc, rsinfo.setDesc);
421 :
422 : /*
423 : * If it is a dynamically-allocated TupleDesc, free it: it is
424 : * typically allocated in a per-query context, so we must avoid
425 : * leaking it across multiple usages.
426 : */
427 90988 : if (rsinfo.setDesc->tdrefcount == -1)
428 90988 : FreeTupleDesc(rsinfo.setDesc);
429 : }
430 :
431 133330 : MemoryContextSwitchTo(callerContext);
432 :
433 : /* All done, pass back the tuplestore */
434 133330 : return rsinfo.setResult;
435 : }
436 :
437 :
438 : /*
439 : * Prepare targetlist SRF function call for execution.
440 : *
441 : * This is used by nodeProjectSet.c.
442 : */
443 : SetExprState *
444 9058 : ExecInitFunctionResultSet(Expr *expr,
445 : ExprContext *econtext, PlanState *parent)
446 : {
447 9058 : SetExprState *state = makeNode(SetExprState);
448 :
449 9058 : state->funcReturnsSet = true;
450 9058 : state->expr = expr;
451 9058 : state->func.fn_oid = InvalidOid;
452 :
453 : /*
454 : * Initialize metadata. The expression node could be either a FuncExpr or
455 : * an OpExpr.
456 : */
457 9058 : if (IsA(expr, FuncExpr))
458 : {
459 9052 : FuncExpr *func = (FuncExpr *) expr;
460 :
461 9052 : state->args = ExecInitExprList(func->args, parent);
462 9052 : init_sexpr(func->funcid, func->inputcollid, expr, state, parent,
463 : econtext->ecxt_per_query_memory, true, true);
464 : }
465 6 : else if (IsA(expr, OpExpr))
466 : {
467 6 : OpExpr *op = (OpExpr *) expr;
468 :
469 6 : state->args = ExecInitExprList(op->args, parent);
470 6 : init_sexpr(op->opfuncid, op->inputcollid, expr, state, parent,
471 : econtext->ecxt_per_query_memory, true, true);
472 : }
473 : else
474 0 : elog(ERROR, "unrecognized node type: %d",
475 : (int) nodeTag(expr));
476 :
477 : /* shouldn't get here unless the selected function returns set */
478 : Assert(state->func.fn_retset);
479 :
480 9056 : return state;
481 : }
482 :
483 : /*
484 : * ExecMakeFunctionResultSet
485 : *
486 : * Evaluate the arguments to a set-returning function and then call the
487 : * function itself. The argument expressions may not contain set-returning
488 : * functions (the planner is supposed to have separated evaluation for those).
489 : *
490 : * This should be called in a short-lived (per-tuple) context, argContext
491 : * needs to live until all rows have been returned (i.e. *isDone set to
492 : * ExprEndResult or ExprSingleResult).
493 : *
494 : * This is used by nodeProjectSet.c.
495 : */
496 : Datum
497 2127636 : ExecMakeFunctionResultSet(SetExprState *fcache,
498 : ExprContext *econtext,
499 : MemoryContext argContext,
500 : bool *isNull,
501 : ExprDoneCond *isDone)
502 : {
503 : List *arguments;
504 : Datum result;
505 : FunctionCallInfo fcinfo;
506 : PgStat_FunctionCallUsage fcusage;
507 : ReturnSetInfo rsinfo;
508 : bool callit;
509 : int i;
510 :
511 2127636 : restart:
512 :
513 : /* Guard against stack overflow due to overly complex expressions */
514 2127636 : check_stack_depth();
515 :
516 : /*
517 : * If a previous call of the function returned a set result in the form of
518 : * a tuplestore, continue reading rows from the tuplestore until it's
519 : * empty.
520 : */
521 2127636 : if (fcache->funcResultStore)
522 : {
523 76596 : TupleTableSlot *slot = fcache->funcResultSlot;
524 : MemoryContext oldContext;
525 : bool foundTup;
526 :
527 : /*
528 : * Have to make sure tuple in slot lives long enough, otherwise
529 : * clearing the slot could end up trying to free something already
530 : * freed.
531 : */
532 76596 : oldContext = MemoryContextSwitchTo(slot->tts_mcxt);
533 76596 : foundTup = tuplestore_gettupleslot(fcache->funcResultStore, true, false,
534 : fcache->funcResultSlot);
535 76596 : MemoryContextSwitchTo(oldContext);
536 :
537 76596 : if (foundTup)
538 : {
539 63486 : *isDone = ExprMultipleResult;
540 63486 : if (fcache->funcReturnsTuple)
541 : {
542 : /* We must return the whole tuple as a Datum. */
543 58918 : *isNull = false;
544 58918 : return ExecFetchSlotHeapTupleDatum(fcache->funcResultSlot);
545 : }
546 : else
547 : {
548 : /* Extract the first column and return it as a scalar. */
549 4568 : return slot_getattr(fcache->funcResultSlot, 1, isNull);
550 : }
551 : }
552 : /* Exhausted the tuplestore, so clean up */
553 13110 : tuplestore_end(fcache->funcResultStore);
554 13110 : fcache->funcResultStore = NULL;
555 13110 : *isDone = ExprEndResult;
556 13110 : *isNull = true;
557 13110 : return (Datum) 0;
558 : }
559 :
560 : /*
561 : * arguments is a list of expressions to evaluate before passing to the
562 : * function manager. We skip the evaluation if it was already done in the
563 : * previous call (ie, we are continuing the evaluation of a set-valued
564 : * function). Otherwise, collect the current argument values into fcinfo.
565 : *
566 : * The arguments have to live in a context that lives at least until all
567 : * rows from this SRF have been returned, otherwise ValuePerCall SRFs
568 : * would reference freed memory after the first returned row.
569 : */
570 2051040 : fcinfo = fcache->fcinfo;
571 2051040 : arguments = fcache->args;
572 2051040 : if (!fcache->setArgsValid)
573 : {
574 152376 : MemoryContext oldContext = MemoryContextSwitchTo(argContext);
575 :
576 152376 : ExecEvalFuncArgs(fcinfo, arguments, econtext);
577 152376 : MemoryContextSwitchTo(oldContext);
578 : }
579 : else
580 : {
581 : /* Reset flag (we may set it again below) */
582 1898664 : fcache->setArgsValid = false;
583 : }
584 :
585 : /*
586 : * Now call the function, passing the evaluated parameter values.
587 : */
588 :
589 : /* Prepare a resultinfo node for communication. */
590 2051040 : fcinfo->resultinfo = (Node *) &rsinfo;
591 2051040 : rsinfo.type = T_ReturnSetInfo;
592 2051040 : rsinfo.econtext = econtext;
593 2051040 : rsinfo.expectedDesc = fcache->funcResultDesc;
594 2051040 : rsinfo.allowedModes = (int) (SFRM_ValuePerCall | SFRM_Materialize);
595 : /* note we do not set SFRM_Materialize_Random or _Preferred */
596 2051040 : rsinfo.returnMode = SFRM_ValuePerCall;
597 : /* isDone is filled below */
598 2051040 : rsinfo.setResult = NULL;
599 2051040 : rsinfo.setDesc = NULL;
600 :
601 : /*
602 : * If function is strict, and there are any NULL arguments, skip calling
603 : * the function.
604 : */
605 2051040 : callit = true;
606 2051040 : if (fcache->func.fn_strict)
607 : {
608 5621226 : for (i = 0; i < fcinfo->nargs; i++)
609 : {
610 3629918 : if (fcinfo->args[i].isnull)
611 : {
612 55274 : callit = false;
613 55274 : break;
614 : }
615 : }
616 : }
617 :
618 2051040 : if (callit)
619 : {
620 1995766 : pgstat_init_function_usage(fcinfo, &fcusage);
621 :
622 1995766 : fcinfo->isnull = false;
623 1995766 : rsinfo.isDone = ExprSingleResult;
624 1995766 : result = FunctionCallInvoke(fcinfo);
625 1994264 : *isNull = fcinfo->isnull;
626 1994264 : *isDone = rsinfo.isDone;
627 :
628 1994264 : pgstat_end_function_usage(&fcusage,
629 1994264 : rsinfo.isDone != ExprMultipleResult);
630 : }
631 : else
632 : {
633 : /* for a strict SRF, result for NULL is an empty set */
634 55274 : result = (Datum) 0;
635 55274 : *isNull = true;
636 55274 : *isDone = ExprEndResult;
637 : }
638 :
639 : /* Which protocol does function want to use? */
640 2049538 : if (rsinfo.returnMode == SFRM_ValuePerCall)
641 : {
642 2036368 : if (*isDone != ExprEndResult)
643 : {
644 : /*
645 : * Save the current argument values to re-use on the next call.
646 : */
647 1898730 : if (*isDone == ExprMultipleResult)
648 : {
649 1898724 : fcache->setArgsValid = true;
650 : /* Register cleanup callback if we didn't already */
651 1898724 : if (!fcache->shutdown_reg)
652 : {
653 19114 : RegisterExprContextCallback(econtext,
654 : ShutdownSetExpr,
655 : PointerGetDatum(fcache));
656 19114 : fcache->shutdown_reg = true;
657 : }
658 : }
659 : }
660 : }
661 13170 : else if (rsinfo.returnMode == SFRM_Materialize)
662 : {
663 : /* check we're on the same page as the function author */
664 13170 : if (rsinfo.isDone != ExprSingleResult)
665 0 : ereport(ERROR,
666 : (errcode(ERRCODE_E_R_I_E_SRF_PROTOCOL_VIOLATED),
667 : errmsg("table-function protocol for materialize mode was not followed")));
668 13170 : if (rsinfo.setResult != NULL)
669 : {
670 : /* prepare to return values from the tuplestore */
671 13146 : ExecPrepareTuplestoreResult(fcache, econtext,
672 : rsinfo.setResult,
673 : rsinfo.setDesc);
674 : /* loop back to top to start returning from tuplestore */
675 13146 : goto restart;
676 : }
677 : /* if setResult was left null, treat it as empty set */
678 24 : *isDone = ExprEndResult;
679 24 : *isNull = true;
680 24 : result = (Datum) 0;
681 : }
682 : else
683 0 : ereport(ERROR,
684 : (errcode(ERRCODE_E_R_I_E_SRF_PROTOCOL_VIOLATED),
685 : errmsg("unrecognized table-function returnMode: %d",
686 : (int) rsinfo.returnMode)));
687 :
688 2036392 : return result;
689 : }
690 :
691 :
692 : /*
693 : * init_sexpr - initialize a SetExprState node during first use
694 : */
695 : static void
696 70494 : init_sexpr(Oid foid, Oid input_collation, Expr *node,
697 : SetExprState *sexpr, PlanState *parent,
698 : MemoryContext sexprCxt, bool allowSRF, bool needDescForSRF)
699 : {
700 : AclResult aclresult;
701 70494 : size_t numargs = list_length(sexpr->args);
702 :
703 : /* Check permission to call function */
704 70494 : aclresult = object_aclcheck(ProcedureRelationId, foid, GetUserId(), ACL_EXECUTE);
705 70494 : if (aclresult != ACLCHECK_OK)
706 10 : aclcheck_error(aclresult, OBJECT_FUNCTION, get_func_name(foid));
707 70484 : InvokeFunctionExecuteHook(foid);
708 :
709 : /*
710 : * Safety check on nargs. Under normal circumstances this should never
711 : * fail, as parser should check sooner. But possibly it might fail if
712 : * server has been compiled with FUNC_MAX_ARGS smaller than some functions
713 : * declared in pg_proc?
714 : */
715 70484 : if (list_length(sexpr->args) > FUNC_MAX_ARGS)
716 0 : ereport(ERROR,
717 : (errcode(ERRCODE_TOO_MANY_ARGUMENTS),
718 : errmsg_plural("cannot pass more than %d argument to a function",
719 : "cannot pass more than %d arguments to a function",
720 : FUNC_MAX_ARGS,
721 : FUNC_MAX_ARGS)));
722 :
723 : /* Set up the primary fmgr lookup information */
724 70484 : fmgr_info_cxt(foid, &(sexpr->func), sexprCxt);
725 70484 : fmgr_info_set_expr((Node *) sexpr->expr, &(sexpr->func));
726 :
727 : /* Initialize the function call parameter struct as well */
728 70484 : sexpr->fcinfo =
729 70484 : (FunctionCallInfo) palloc(SizeForFunctionCallInfo(numargs));
730 70484 : InitFunctionCallInfoData(*sexpr->fcinfo, &(sexpr->func),
731 : numargs,
732 : input_collation, NULL, NULL);
733 :
734 : /* If function returns set, check if that's allowed by caller */
735 70484 : if (sexpr->func.fn_retset && !allowSRF)
736 0 : ereport(ERROR,
737 : (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
738 : errmsg("set-valued function called in context that cannot accept a set"),
739 : parent ? executor_errposition(parent->state,
740 : exprLocation((Node *) node)) : 0));
741 :
742 : /* Otherwise, caller should have marked the sexpr correctly */
743 : Assert(sexpr->func.fn_retset == sexpr->funcReturnsSet);
744 :
745 : /* If function returns set, prepare expected tuple descriptor */
746 70484 : if (sexpr->func.fn_retset && needDescForSRF)
747 9056 : {
748 : TypeFuncClass functypclass;
749 : Oid funcrettype;
750 : TupleDesc tupdesc;
751 : MemoryContext oldcontext;
752 :
753 9056 : functypclass = get_expr_result_type(sexpr->func.fn_expr,
754 : &funcrettype,
755 : &tupdesc);
756 :
757 : /* Must save tupdesc in sexpr's context */
758 9056 : oldcontext = MemoryContextSwitchTo(sexprCxt);
759 :
760 9056 : if (functypclass == TYPEFUNC_COMPOSITE ||
761 : functypclass == TYPEFUNC_COMPOSITE_DOMAIN)
762 : {
763 : /* Composite data type, e.g. a table's row type */
764 : Assert(tupdesc);
765 : /* Must copy it out of typcache for safety */
766 780 : sexpr->funcResultDesc = CreateTupleDescCopy(tupdesc);
767 780 : sexpr->funcReturnsTuple = true;
768 : }
769 8276 : else if (functypclass == TYPEFUNC_SCALAR)
770 : {
771 : /* Base data type, i.e. scalar */
772 8192 : tupdesc = CreateTemplateTupleDesc(1);
773 8192 : TupleDescInitEntry(tupdesc,
774 : (AttrNumber) 1,
775 : NULL,
776 : funcrettype,
777 : -1,
778 : 0);
779 8192 : sexpr->funcResultDesc = tupdesc;
780 8192 : sexpr->funcReturnsTuple = false;
781 : }
782 84 : else if (functypclass == TYPEFUNC_RECORD)
783 : {
784 : /* This will work if function doesn't need an expectedDesc */
785 84 : sexpr->funcResultDesc = NULL;
786 84 : sexpr->funcReturnsTuple = true;
787 : }
788 : else
789 : {
790 : /* Else, we will fail if function needs an expectedDesc */
791 0 : sexpr->funcResultDesc = NULL;
792 : }
793 :
794 9056 : MemoryContextSwitchTo(oldcontext);
795 : }
796 : else
797 61428 : sexpr->funcResultDesc = NULL;
798 :
799 : /* Initialize additional state */
800 70484 : sexpr->funcResultStore = NULL;
801 70484 : sexpr->funcResultSlot = NULL;
802 70484 : sexpr->shutdown_reg = false;
803 70484 : }
804 :
805 : /*
806 : * callback function in case a SetExprState needs to be shut down before it
807 : * has been run to completion
808 : */
809 : static void
810 20096 : ShutdownSetExpr(Datum arg)
811 : {
812 20096 : SetExprState *sexpr = castNode(SetExprState, DatumGetPointer(arg));
813 :
814 : /* If we have a slot, make sure it's let go of any tuplestore pointer */
815 20096 : if (sexpr->funcResultSlot)
816 990 : ExecClearTuple(sexpr->funcResultSlot);
817 :
818 : /* Release any open tuplestore */
819 20096 : if (sexpr->funcResultStore)
820 36 : tuplestore_end(sexpr->funcResultStore);
821 20096 : sexpr->funcResultStore = NULL;
822 :
823 : /* Clear any active set-argument state */
824 20096 : sexpr->setArgsValid = false;
825 :
826 : /* execUtils will deregister the callback... */
827 20096 : sexpr->shutdown_reg = false;
828 20096 : }
829 :
830 : /*
831 : * Evaluate arguments for a function.
832 : */
833 : static void
834 290748 : ExecEvalFuncArgs(FunctionCallInfo fcinfo,
835 : List *argList,
836 : ExprContext *econtext)
837 : {
838 : int i;
839 : ListCell *arg;
840 :
841 290748 : i = 0;
842 701462 : foreach(arg, argList)
843 : {
844 410730 : ExprState *argstate = (ExprState *) lfirst(arg);
845 :
846 410730 : fcinfo->args[i].value = ExecEvalExpr(argstate,
847 : econtext,
848 : &fcinfo->args[i].isnull);
849 410714 : i++;
850 : }
851 :
852 : Assert(i == fcinfo->nargs);
853 290732 : }
854 :
855 : /*
856 : * ExecPrepareTuplestoreResult
857 : *
858 : * Subroutine for ExecMakeFunctionResultSet: prepare to extract rows from a
859 : * tuplestore function result. We must set up a funcResultSlot (unless
860 : * already done in a previous call cycle) and verify that the function
861 : * returned the expected tuple descriptor.
862 : */
863 : static void
864 13146 : ExecPrepareTuplestoreResult(SetExprState *sexpr,
865 : ExprContext *econtext,
866 : Tuplestorestate *resultStore,
867 : TupleDesc resultDesc)
868 : {
869 13146 : sexpr->funcResultStore = resultStore;
870 :
871 13146 : if (sexpr->funcResultSlot == NULL)
872 : {
873 : /* Create a slot so we can read data out of the tuplestore */
874 : TupleDesc slotDesc;
875 : MemoryContext oldcontext;
876 :
877 990 : oldcontext = MemoryContextSwitchTo(sexpr->func.fn_mcxt);
878 :
879 : /*
880 : * If we were not able to determine the result rowtype from context,
881 : * and the function didn't return a tupdesc, we have to fail.
882 : */
883 990 : if (sexpr->funcResultDesc)
884 948 : slotDesc = sexpr->funcResultDesc;
885 42 : else if (resultDesc)
886 : {
887 : /* don't assume resultDesc is long-lived */
888 42 : slotDesc = CreateTupleDescCopy(resultDesc);
889 : }
890 : else
891 : {
892 0 : ereport(ERROR,
893 : (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
894 : errmsg("function returning setof record called in "
895 : "context that cannot accept type record")));
896 : slotDesc = NULL; /* keep compiler quiet */
897 : }
898 :
899 990 : sexpr->funcResultSlot = MakeSingleTupleTableSlot(slotDesc,
900 : &TTSOpsMinimalTuple);
901 990 : MemoryContextSwitchTo(oldcontext);
902 : }
903 :
904 : /*
905 : * If function provided a tupdesc, cross-check it. We only really need to
906 : * do this for functions returning RECORD, but might as well do it always.
907 : */
908 13146 : if (resultDesc)
909 : {
910 13146 : if (sexpr->funcResultDesc)
911 13092 : tupledesc_match(sexpr->funcResultDesc, resultDesc);
912 :
913 : /*
914 : * If it is a dynamically-allocated TupleDesc, free it: it is
915 : * typically allocated in a per-query context, so we must avoid
916 : * leaking it across multiple usages.
917 : */
918 13146 : if (resultDesc->tdrefcount == -1)
919 13146 : FreeTupleDesc(resultDesc);
920 : }
921 :
922 : /* Register cleanup callback if we didn't already */
923 13146 : if (!sexpr->shutdown_reg)
924 : {
925 990 : RegisterExprContextCallback(econtext,
926 : ShutdownSetExpr,
927 : PointerGetDatum(sexpr));
928 990 : sexpr->shutdown_reg = true;
929 : }
930 13146 : }
931 :
932 : /*
933 : * Check that function result tuple type (src_tupdesc) matches or can
934 : * be considered to match what the query expects (dst_tupdesc). If
935 : * they don't match, ereport.
936 : *
937 : * We really only care about number of attributes and data type.
938 : * Also, we can ignore type mismatch on columns that are dropped in the
939 : * destination type, so long as the physical storage matches. This is
940 : * helpful in some cases involving out-of-date cached plans.
941 : */
942 : static void
943 104164 : tupledesc_match(TupleDesc dst_tupdesc, TupleDesc src_tupdesc)
944 : {
945 : int i;
946 :
947 104164 : if (dst_tupdesc->natts != src_tupdesc->natts)
948 48 : ereport(ERROR,
949 : (errcode(ERRCODE_DATATYPE_MISMATCH),
950 : errmsg("function return row and query-specified return row do not match"),
951 : errdetail_plural("Returned row contains %d attribute, but query expects %d.",
952 : "Returned row contains %d attributes, but query expects %d.",
953 : src_tupdesc->natts,
954 : src_tupdesc->natts, dst_tupdesc->natts)));
955 :
956 495492 : for (i = 0; i < dst_tupdesc->natts; i++)
957 : {
958 391412 : Form_pg_attribute dattr = TupleDescAttr(dst_tupdesc, i);
959 391412 : Form_pg_attribute sattr = TupleDescAttr(src_tupdesc, i);
960 :
961 391412 : if (IsBinaryCoercible(sattr->atttypid, dattr->atttypid))
962 391376 : continue; /* no worries */
963 36 : if (!dattr->attisdropped)
964 36 : ereport(ERROR,
965 : (errcode(ERRCODE_DATATYPE_MISMATCH),
966 : errmsg("function return row and query-specified return row do not match"),
967 : errdetail("Returned type %s at ordinal position %d, but query expects %s.",
968 : format_type_be(sattr->atttypid),
969 : i + 1,
970 : format_type_be(dattr->atttypid))));
971 :
972 0 : if (dattr->attlen != sattr->attlen ||
973 0 : dattr->attalign != sattr->attalign)
974 0 : ereport(ERROR,
975 : (errcode(ERRCODE_DATATYPE_MISMATCH),
976 : errmsg("function return row and query-specified return row do not match"),
977 : errdetail("Physical storage mismatch on dropped attribute at ordinal position %d.",
978 : i + 1)));
979 : }
980 104080 : }
|
