plpy_exec.c File Reference

#include "postgres.h"
#include "commands/event_trigger.h"
#include "commands/trigger.h"
#include "executor/spi.h"
#include "funcapi.h"
#include "plpy_elog.h"
#include "plpy_exec.h"
#include "plpy_main.h"
#include "plpy_subxactobject.h"
#include "plpy_util.h"
#include "utils/fmgrprotos.h"

Include dependency graph for plpy_exec.c:

Go to the source code of this file.

Functions
static void	ShutdownPLyFunction (Datum arg)
static PyObject *	PLy_function_build_args (FunctionCallInfo fcinfo, PLyProcedure *proc)
static PLySavedArgs *	PLy_function_save_args (PLyProcedure *proc)
static void	PLy_function_restore_args (PLyProcedure *proc, PLySavedArgs *savedargs)
static void	PLy_function_drop_args (PLySavedArgs *savedargs)
static void	PLy_global_args_push (PLyProcedure *proc)
static void	PLy_global_args_pop (PLyProcedure *proc)
static void	plpython_return_error_callback (void *arg)
static PyObject *	PLy_trigger_build_args (FunctionCallInfo fcinfo, PLyProcedure *proc, HeapTuple *rv)
static HeapTuple	PLy_modify_tuple (PLyProcedure *proc, PyObject *pltd, TriggerData *tdata, HeapTuple otup)
static void	plpython_trigger_error_callback (void *arg)
static PyObject *	PLy_procedure_call (PLyProcedure *proc, const char *kargs, PyObject *vargs)
static void	PLy_abort_open_subtransactions (int save_subxact_level)
Datum	PLy_exec_function (FunctionCallInfo fcinfo, PLyProcedureCache *pcache)
void	PLy_function_cleanup_srfstate (PLyProcedureCache *pcache)
HeapTuple	PLy_exec_trigger (FunctionCallInfo fcinfo, PLyProcedure *proc)
void	PLy_exec_event_trigger (FunctionCallInfo fcinfo, PLyProcedure *proc)

Function Documentation

plpython_return_error_callback()

static void plpython_return_error_callback ( void *  arg )

static

Definition at line 785 of file plpy_exec.c.

{
    PLyExecutionContext *exec_ctx = PLy_current_execution_context();
 
    if (exec_ctx->curr_proc &&
        !exec_ctx->curr_proc->is_procedure)
        errcontext("while creating return value");
}

References errcontext, fb(), and PLy_current_execution_context().

Referenced by PLy_exec_function().

plpython_trigger_error_callback()

static void plpython_trigger_error_callback ( void *  arg )

static

Definition at line 1142 of file plpy_exec.c.

{
    PLyExecutionContext *exec_ctx = PLy_current_execution_context();
 
    if (exec_ctx->curr_proc)
        errcontext("while modifying trigger row");
}

References errcontext, fb(), and PLy_current_execution_context().

Referenced by PLy_modify_tuple().

PLy_abort_open_subtransactions()

static void PLy_abort_open_subtransactions ( int  save_subxact_level )

static

Definition at line 1188 of file plpy_exec.c.

{
    Assert(save_subxact_level >= 0);
 
    while (list_length(explicit_subtransactions) > save_subxact_level)
    {
        PLySubtransactionData *subtransactiondata;
 
        Assert(explicit_subtransactions != NIL);
 
        ereport(WARNING,
                (errmsg("forcibly aborting a subtransaction that has not been exited")));
 
        RollbackAndReleaseCurrentSubTransaction();
 
        subtransactiondata = (PLySubtransactionData *) linitial(explicit_subtransactions);
        explicit_subtransactions = list_delete_first(explicit_subtransactions);
 
        MemoryContextSwitchTo(subtransactiondata->oldcontext);
        CurrentResourceOwner = subtransactiondata->oldowner;
        pfree(subtransactiondata);
    }
}

References Assert, CurrentResourceOwner, ereport, errmsg, explicit_subtransactions, fb(), linitial, list_delete_first(), list_length(), MemoryContextSwitchTo(), NIL, pfree(), RollbackAndReleaseCurrentSubTransaction(), and WARNING.

Referenced by PLy_procedure_call().

PLy_exec_event_trigger()

void PLy_exec_event_trigger	(	FunctionCallInfo	fcinfo,
		PLyProcedure *	proc
	)

Definition at line 504 of file plpy_exec.c.

{
    EventTriggerData *tdata;
    PyObject   *volatile pltdata = NULL;
 
    Assert(CALLED_AS_EVENT_TRIGGER(fcinfo));
    tdata = (EventTriggerData *) fcinfo->context;
 
    PG_TRY();
    {
        PyObject   *pltevent,
                   *plttag;
 
        pltdata = PyDict_New();
        if (!pltdata)
            PLy_elog(ERROR, NULL);
 
        pltevent = PLyUnicode_FromString(tdata->event);
        PyDict_SetItemString(pltdata, "event", pltevent);
        Py_DECREF(pltevent);
 
        plttag = PLyUnicode_FromString(GetCommandTagName(tdata->tag));
        PyDict_SetItemString(pltdata, "tag", plttag);
        Py_DECREF(plttag);
 
        PLy_procedure_call(proc, "TD", pltdata);
 
        if (SPI_finish() != SPI_OK_FINISH)
            elog(ERROR, "SPI_finish() failed");
    }
    PG_FINALLY();
    {
        Py_XDECREF(pltdata);
    }
    PG_END_TRY();
}

References Assert, CALLED_AS_EVENT_TRIGGER, FunctionCallInfoBaseData::context, elog, ERROR, fb(), GetCommandTagName(), PG_END_TRY, PG_FINALLY, PG_TRY, PLy_elog, PLy_procedure_call(), PLyUnicode_FromString(), SPI_finish(), and SPI_OK_FINISH.

Referenced by plpython3_call_handler().

PLy_exec_function()

Datum PLy_exec_function	(	FunctionCallInfo	fcinfo,
		PLyProcedureCache *	pcache
	)

Definition at line 41 of file plpy_exec.c.

{
    PLyProcedure *proc = pcache->proc;
    bool        is_setof = proc->is_setof;
    ReturnSetInfo *rsi = (ReturnSetInfo *) fcinfo->resultinfo;
    Datum       rv;
    PyObject   *volatile plargs = NULL;
    PyObject   *volatile plrv = NULL;
    PLySRFState *volatile srfstate = NULL;
    ErrorContextCallback plerrcontext;
 
    /*
     * If the function is called recursively, we must push outer-level
     * arguments into the stack.  This must be immediately before the PG_TRY
     * to ensure that the corresponding pop happens.
     */
    PLy_global_args_push(proc);
 
    PG_TRY();
    {
        if (is_setof)
        {
            /*
             * PL/Python returns sets in ValuePerCall mode, so the handler is
             * invoked once per result row.  Across those calls we keep the
             * iterator and saved arguments in the per-call-site cache
             * (pcache->srfstate); a NULL srfstate means this is the first
             * call of a new iteration, so we must set up that state now.
             */
            if (pcache->srfstate == NULL)
            {
                if (!rsi || !IsA(rsi, ReturnSetInfo) ||
                    (rsi->allowedModes & SFRM_ValuePerCall) == 0)
                {
                    ereport(ERROR,
                            (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
                             errmsg("unsupported set function return mode"),
                             errdetail("PL/Python set-returning functions only support returning one value per call.")));
                }
                rsi->returnMode = SFRM_ValuePerCall;
 
                pcache->srfstate = (PLySRFState *)
                    MemoryContextAllocZero(pcache->fcontext, sizeof(PLySRFState));
 
                /*
                 * Register a shutdown callback so that the iterator state is
                 * released if execution is abandoned before the iterator is
                 * exhausted.  We'll unregister it again on normal completion.
                 */
                RegisterExprContextCallback(rsi->econtext,
                                            ShutdownPLyFunction,
                                            PointerGetDatum(pcache));
                pcache->shutdown_reg = true;
            }
 
            srfstate = pcache->srfstate;
        }
 
        if (srfstate == NULL || srfstate->iter == NULL)
        {
            /*
             * Non-SETOF function or first time for SETOF function: build
             * args, then actually execute the function.
             */
            plargs = PLy_function_build_args(fcinfo, proc);
            plrv = PLy_procedure_call(proc, "args", plargs);
            Assert(plrv != NULL);
        }
        else
        {
            /*
             * Second or later call for a SETOF function: restore arguments in
             * globals dict to what they were when we left off.  We must do
             * this in case multiple evaluations of the same SETOF function
             * are interleaved.  It's a bit annoying, since the iterator may
             * not look at the arguments at all, but we have no way to know
             * that.  Fortunately this isn't terribly expensive.
             */
            if (srfstate->savedargs)
                PLy_function_restore_args(proc, srfstate->savedargs);
            srfstate->savedargs = NULL; /* deleted by restore_args */
        }
 
        /*
         * If it returns a set, call the iterator to get the next return item.
         * We stay in the SPI context while doing this, because PyIter_Next()
         * calls back into Python code which might contain SPI calls.
         */
        if (is_setof)
        {
            if (srfstate->iter == NULL)
            {
                /* First time -- make iterator out of returned object */
                srfstate->iter = PyObject_GetIter(plrv);
 
                Py_DECREF(plrv);
                plrv = NULL;
 
                if (srfstate->iter == NULL)
                    ereport(ERROR,
                            (errcode(ERRCODE_DATATYPE_MISMATCH),
                             errmsg("returned object cannot be iterated"),
                             errdetail("PL/Python set-returning functions must return an iterable object.")));
            }
 
            /* Fetch next from iterator */
            plrv = PyIter_Next(srfstate->iter);
            if (plrv == NULL)
            {
                /* Iterator is exhausted or error happened */
                bool        has_error = (PyErr_Occurred() != NULL);
 
                Py_DECREF(srfstate->iter);
                srfstate->iter = NULL;
 
                if (has_error)
                    PLy_elog(ERROR, "error fetching next item from iterator");
 
                /* Pass a null through the data-returning steps below */
                Py_INCREF(Py_None);
                plrv = Py_None;
            }
            else
            {
                /*
                 * This won't be last call, so save argument values.  We do
                 * this again each time in case the iterator is changing those
                 * values.
                 */
                srfstate->savedargs = PLy_function_save_args(proc);
            }
        }
 
        /*
         * Disconnect from SPI manager and then create the return values datum
         * (if the input function does a palloc for it this must not be
         * allocated in the SPI memory context because SPI_finish would free
         * it).
         */
        if (SPI_finish() != SPI_OK_FINISH)
            elog(ERROR, "SPI_finish failed");
 
        plerrcontext.callback = plpython_return_error_callback;
        plerrcontext.previous = error_context_stack;
        error_context_stack = &plerrcontext;
 
        /*
         * For a procedure or function declared to return void, the Python
         * return value must be None. For void-returning functions, we also
         * treat a None return value as a special "void datum" rather than
         * NULL (as is the case for non-void-returning functions).
         */
        if (proc->result.typoid == VOIDOID)
        {
            if (plrv != Py_None)
            {
                if (proc->is_procedure)
                    ereport(ERROR,
                            (errcode(ERRCODE_DATATYPE_MISMATCH),
                             errmsg("PL/Python procedure did not return None")));
                else
                    ereport(ERROR,
                            (errcode(ERRCODE_DATATYPE_MISMATCH),
                             errmsg("PL/Python function with return type \"void\" did not return None")));
            }
 
            fcinfo->isnull = false;
            rv = (Datum) 0;
        }
        else if (plrv == Py_None &&
                 srfstate && srfstate->iter == NULL)
        {
            /*
             * In a SETOF function, the iteration-ending null isn't a real
             * value; don't pass it through the input function, which might
             * complain.
             */
            fcinfo->isnull = true;
            rv = (Datum) 0;
        }
        else
        {
            /*
             * Normal conversion of result.  However, if the result is of type
             * RECORD, we have to set up for that each time through, since it
             * might be different from last time.
             */
            if (proc->result.typoid == RECORDOID)
            {
                TupleDesc   desc;
 
                if (get_call_result_type(fcinfo, NULL, &desc) != TYPEFUNC_COMPOSITE)
                    ereport(ERROR,
                            (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
                             errmsg("function returning record called in context "
                                    "that cannot accept type record")));
                PLy_output_setup_record(&proc->result, desc, proc);
            }
 
            rv = PLy_output_convert(&proc->result, plrv,
                                    &fcinfo->isnull);
        }
    }
    PG_CATCH();
    {
        /* Pop old arguments from the stack if they were pushed above */
        PLy_global_args_pop(proc);
 
        Py_XDECREF(plargs);
        Py_XDECREF(plrv);
 
        /*
         * If we are erroring out of a SRF, clean up its state immediately.
         * ShutdownPLyFunction will not be called on abort, and the
         * memory-context callback only fires when the FmgrInfo's context is
         * torn down.  Releasing the Python references promptly avoids leaking
         * them if teardown is delayed, and clearing pcache->srfstate ensures
         * that if we reuse the pcache we won't mistake this for an iteration
         * still in progress.
         */
        PLy_function_cleanup_srfstate(pcache);
 
        PG_RE_THROW();
    }
    PG_END_TRY();
 
    error_context_stack = plerrcontext.previous;
 
    /* Pop old arguments from the stack if they were pushed above */
    PLy_global_args_pop(proc);
 
    Py_XDECREF(plargs);
    Py_DECREF(plrv);
 
    if (srfstate)
    {
        /* We're in a SRF, signal done-or-not via rsi->isDone */
        if (srfstate->iter == NULL)
        {
            /*
             * Iterator exhausted.  Unregister the shutdown callback since
             * we're done normally, then clean up srfstate.  (srfstate->iter
             * is already NULL here, so the cleanup just frees the struct.)
             */
            if (pcache->shutdown_reg)
            {
                UnregisterExprContextCallback(rsi->econtext,
                                              ShutdownPLyFunction,
                                              PointerGetDatum(pcache));
                pcache->shutdown_reg = false;
            }
            PLy_function_cleanup_srfstate(pcache);
 
            rsi->isDone = ExprEndResult;
            fcinfo->isnull = true;
            return (Datum) 0;
        }
        else
        {
            rsi->isDone = ExprMultipleResult;
            return rv;
        }
    }
 
    /* Plain function, just return the Datum value (possibly null) */
    return rv;
}

References ReturnSetInfo::allowedModes, Assert, ReturnSetInfo::econtext, elog, ereport, errcode(), errdetail(), errmsg, ERROR, error_context_stack, ExprEndResult, ExprMultipleResult, fb(), get_call_result_type(), PLyProcedure::is_procedure, PLyProcedure::is_setof, IsA, ReturnSetInfo::isDone, FunctionCallInfoBaseData::isnull, PLySRFState::iter, MemoryContextAllocZero(), PG_CATCH, PG_END_TRY, PG_RE_THROW, PG_TRY, plpython_return_error_callback(), PLy_elog, PLy_function_build_args(), PLy_function_cleanup_srfstate(), PLy_function_restore_args(), PLy_function_save_args(), PLy_global_args_pop(), PLy_global_args_push(), PLy_output_convert(), PLy_output_setup_record(), PLy_procedure_call(), PointerGetDatum, ErrorContextCallback::previous, RegisterExprContextCallback(), PLyProcedure::result, FunctionCallInfoBaseData::resultinfo, ReturnSetInfo::returnMode, PLySRFState::savedargs, SFRM_ValuePerCall, ShutdownPLyFunction(), SPI_finish(), SPI_OK_FINISH, TYPEFUNC_COMPOSITE, PLyObToDatum::typoid, and UnregisterExprContextCallback().

Referenced by plpython3_call_handler(), and plpython3_inline_handler().

PLy_exec_trigger()

HeapTuple PLy_exec_trigger	(	FunctionCallInfo	fcinfo,
		PLyProcedure *	proc
	)

Definition at line 389 of file plpy_exec.c.

{
    HeapTuple   rv = NULL;
    PyObject   *volatile plargs = NULL;
    PyObject   *volatile plrv = NULL;
    TriggerData *tdata;
    TupleDesc   rel_descr;
 
    Assert(CALLED_AS_TRIGGER(fcinfo));
    tdata = (TriggerData *) fcinfo->context;
 
    /*
     * Input/output conversion for trigger tuples.  We use the result and
     * result_in fields to store the tuple conversion info.  We do this over
     * again on each call to cover the possibility that the relation's tupdesc
     * changed since the trigger was last called.  The PLy_xxx_setup_func
     * calls should only happen once, but PLy_input_setup_tuple and
     * PLy_output_setup_tuple are responsible for not doing repetitive work.
     */
    rel_descr = RelationGetDescr(tdata->tg_relation);
    if (proc->result.typoid != rel_descr->tdtypeid)
        PLy_output_setup_func(&proc->result, proc->mcxt,
                              rel_descr->tdtypeid,
                              rel_descr->tdtypmod,
                              proc);
    if (proc->result_in.typoid != rel_descr->tdtypeid)
        PLy_input_setup_func(&proc->result_in, proc->mcxt,
                             rel_descr->tdtypeid,
                             rel_descr->tdtypmod,
                             proc);
    PLy_output_setup_tuple(&proc->result, rel_descr, proc);
    PLy_input_setup_tuple(&proc->result_in, rel_descr, proc);
 
    /*
     * If the trigger is called recursively, we must push outer-level
     * arguments into the stack.  This must be immediately before the PG_TRY
     * to ensure that the corresponding pop happens.
     */
    PLy_global_args_push(proc);
 
    PG_TRY();
    {
        int         rc PG_USED_FOR_ASSERTS_ONLY;
 
        rc = SPI_register_trigger_data(tdata);
        Assert(rc >= 0);
 
        plargs = PLy_trigger_build_args(fcinfo, proc, &rv);
        plrv = PLy_procedure_call(proc, "TD", plargs);
 
        Assert(plrv != NULL);
 
        /*
         * Disconnect from SPI manager
         */
        if (SPI_finish() != SPI_OK_FINISH)
            elog(ERROR, "SPI_finish failed");
 
        /*
         * return of None means we're happy with the tuple
         */
        if (plrv != Py_None)
        {
            char       *srv;
 
            if (PyUnicode_Check(plrv))
                srv = PLyUnicode_AsString(plrv);
            else
            {
                ereport(ERROR,
                        (errcode(ERRCODE_DATA_EXCEPTION),
                         errmsg("unexpected return value from trigger procedure"),
                         errdetail("Expected None or a string.")));
                srv = NULL;     /* keep compiler quiet */
            }
 
            if (pg_strcasecmp(srv, "SKIP") == 0)
                rv = NULL;
            else if (pg_strcasecmp(srv, "MODIFY") == 0)
            {
                if (TRIGGER_FIRED_BY_INSERT(tdata->tg_event) ||
                    TRIGGER_FIRED_BY_UPDATE(tdata->tg_event))
                    rv = PLy_modify_tuple(proc, plargs, tdata, rv);
                else
                    ereport(WARNING,
                            (errmsg("PL/Python trigger function returned \"MODIFY\" in a DELETE trigger -- ignored")));
            }
            else if (pg_strcasecmp(srv, "OK") != 0)
            {
                /*
                 * accept "OK" as an alternative to None; otherwise, raise an
                 * error
                 */
                ereport(ERROR,
                        (errcode(ERRCODE_DATA_EXCEPTION),
                         errmsg("unexpected return value from trigger procedure"),
                         errdetail("Expected None, \"OK\", \"SKIP\", or \"MODIFY\".")));
            }
        }
    }
    PG_FINALLY();
    {
        PLy_global_args_pop(proc);
        Py_XDECREF(plargs);
        Py_XDECREF(plrv);
    }
    PG_END_TRY();
 
    return rv;
}

References Assert, CALLED_AS_TRIGGER, FunctionCallInfoBaseData::context, elog, ereport, errcode(), errdetail(), errmsg, ERROR, fb(), PLyProcedure::mcxt, PG_END_TRY, PG_FINALLY, pg_strcasecmp(), PG_TRY, PG_USED_FOR_ASSERTS_ONLY, PLy_global_args_pop(), PLy_global_args_push(), PLy_input_setup_func(), PLy_input_setup_tuple(), PLy_modify_tuple(), PLy_output_setup_func(), PLy_output_setup_tuple(), PLy_procedure_call(), PLy_trigger_build_args(), PLyUnicode_AsString(), RelationGetDescr, PLyProcedure::result, PLyProcedure::result_in, SPI_finish(), SPI_OK_FINISH, SPI_register_trigger_data(), TRIGGER_FIRED_BY_INSERT, TRIGGER_FIRED_BY_UPDATE, PLyDatumToOb::typoid, PLyObToDatum::typoid, and WARNING.

Referenced by plpython3_call_handler().

PLy_function_build_args()

static PyObject * PLy_function_build_args ( FunctionCallInfo  fcinfo, PLyProcedure *  proc  )

static

Definition at line 544 of file plpy_exec.c.

{
    PyObject   *volatile arg = NULL;
    PyObject   *args;
    int         i;
 
    /*
     * Make any Py*_New() calls before the PG_TRY block so that we can quickly
     * return NULL on failure.  We can't return within the PG_TRY block, else
     * we'd miss unwinding the exception stack.
     */
    args = PyList_New(proc->nargs);
    if (!args)
        return NULL;
 
    PG_TRY();
    {
        for (i = 0; i < proc->nargs; i++)
        {
            PLyDatumToOb *arginfo = &proc->args[i];
 
            if (fcinfo->args[i].isnull)
                arg = NULL;
            else
                arg = PLy_input_convert(arginfo, fcinfo->args[i].value);
 
            if (arg == NULL)
            {
                Py_INCREF(Py_None);
                arg = Py_None;
            }
 
            if (PyList_SetItem(args, i, arg) == -1)
                PLy_elog(ERROR, "PyList_SetItem() failed, while setting up arguments");
 
            if (proc->argnames && proc->argnames[i] &&
                PyDict_SetItemString(proc->globals, proc->argnames[i], arg) == -1)
                PLy_elog(ERROR, "PyDict_SetItemString() failed, while setting up arguments");
            arg = NULL;
        }
    }
    PG_CATCH();
    {
        Py_XDECREF(arg);
        Py_XDECREF(args);
 
        PG_RE_THROW();
    }
    PG_END_TRY();
 
    return args;
}

References arg, PLyProcedure::argnames, FunctionCallInfoBaseData::args, PLyProcedure::args, ERROR, fb(), PLyProcedure::globals, i, NullableDatum::isnull, PLyProcedure::nargs, PG_CATCH, PG_END_TRY, PG_RE_THROW, PG_TRY, PLy_elog, PLy_input_convert(), and NullableDatum::value.

Referenced by PLy_exec_function().

PLy_function_cleanup_srfstate()

void PLy_function_cleanup_srfstate

(

PLyProcedureCache *

pcache

)

Definition at line 357 of file plpy_exec.c.

{
    PLySRFState *srfstate = pcache->srfstate;
 
    if (srfstate != NULL)
    {
        /* Release refcount on the iter, if we still have one */
        Py_XDECREF(srfstate->iter);
        srfstate->iter = NULL;
 
        /* And drop any saved args; we won't need them */
        if (srfstate->savedargs)
            PLy_function_drop_args(srfstate->savedargs);
        srfstate->savedargs = NULL;
 
        pfree(srfstate);
        pcache->srfstate = NULL;
    }
}

References fb(), PLySRFState::iter, pfree(), PLy_function_drop_args(), and PLySRFState::savedargs.

Referenced by PLy_exec_function(), RemovePLyProcedureCache(), and ShutdownPLyFunction().

PLy_function_drop_args()

static void PLy_function_drop_args ( PLySavedArgs *  savedargs )

static

Definition at line 693 of file plpy_exec.c.

{
    int         i;
 
    /* Drop references for named args */
    for (i = 0; i < savedargs->nargs; i++)
    {
        Py_XDECREF(savedargs->namedargs[i]);
    }
 
    /* Drop refs to the "args" and "TD" objects, too */
    Py_XDECREF(savedargs->args);
    Py_XDECREF(savedargs->td);
 
    /* And free the PLySavedArgs struct */
    pfree(savedargs);
}

References PLySavedArgs::args, fb(), i, PLySavedArgs::namedargs, PLySavedArgs::nargs, pfree(), and PLySavedArgs::td.

Referenced by PLy_function_cleanup_srfstate().

PLy_function_restore_args()

static void PLy_function_restore_args ( PLyProcedure *  proc, PLySavedArgs *  savedargs  )

static

Definition at line 653 of file plpy_exec.c.

{
    /* Restore named arguments into their slots in the globals dict */
    if (proc->argnames)
    {
        int         i;
 
        for (i = 0; i < savedargs->nargs; i++)
        {
            if (proc->argnames[i] && savedargs->namedargs[i])
            {
                PyDict_SetItemString(proc->globals, proc->argnames[i],
                                     savedargs->namedargs[i]);
                Py_DECREF(savedargs->namedargs[i]);
            }
        }
    }
 
    /* Restore the "args" object, too */
    if (savedargs->args)
    {
        PyDict_SetItemString(proc->globals, "args", savedargs->args);
        Py_DECREF(savedargs->args);
    }
 
    /* Restore the "TD" object, too */
    if (savedargs->td)
    {
        PyDict_SetItemString(proc->globals, "TD", savedargs->td);
        Py_DECREF(savedargs->td);
    }
 
    /* And free the PLySavedArgs struct */
    pfree(savedargs);
}

References PLyProcedure::argnames, PLySavedArgs::args, fb(), PLyProcedure::globals, i, PLySavedArgs::namedargs, PLySavedArgs::nargs, pfree(), and PLySavedArgs::td.

Referenced by PLy_exec_function(), and PLy_global_args_pop().

PLy_function_save_args()

static PLySavedArgs * PLy_function_save_args ( PLyProcedure *  proc )

static

Definition at line 607 of file plpy_exec.c.

{
    PLySavedArgs *result;
 
    /* saved args are always allocated in procedure's context */
    result = (PLySavedArgs *)
        MemoryContextAllocZero(proc->mcxt,
                               offsetof(PLySavedArgs, namedargs) +
                               proc->nargs * sizeof(PyObject *));
    result->nargs = proc->nargs;
 
    /* Fetch the "args" list */
    result->args = PyDict_GetItemString(proc->globals, "args");
    Py_XINCREF(result->args);
 
    /* If it's a trigger, also save "TD" */
    if (proc->is_trigger == PLPY_TRIGGER)
    {
        result->td = PyDict_GetItemString(proc->globals, "TD");
        Py_XINCREF(result->td);
    }
 
    /* Fetch all the named arguments */
    if (proc->argnames)
    {
        int         i;
 
        for (i = 0; i < result->nargs; i++)
        {
            if (proc->argnames[i])
            {
                result->namedargs[i] = PyDict_GetItemString(proc->globals,
                                                            proc->argnames[i]);
                Py_XINCREF(result->namedargs[i]);
            }
        }
    }
 
    return result;
}

References PLyProcedure::argnames, fb(), PLyProcedure::globals, i, PLyProcedure::is_trigger, PLyProcedure::mcxt, MemoryContextAllocZero(), PLySavedArgs::nargs, PLyProcedure::nargs, PLPY_TRIGGER, and result.

Referenced by PLy_exec_function(), and PLy_global_args_push().

PLy_global_args_pop()

static void PLy_global_args_pop ( PLyProcedure *  proc )

static

Definition at line 752 of file plpy_exec.c.

{
    Assert(proc->calldepth > 0);
    /* We only need to pop if we were already inside some active call */
    if (proc->calldepth > 1)
    {
        PLySavedArgs *ptr = proc->argstack;
 
        /* Pop the callstack */
        Assert(ptr != NULL);
        proc->argstack = ptr->next;
        proc->calldepth--;
 
        /* Restore argument values, then free ptr */
        PLy_function_restore_args(proc, ptr);
    }
    else
    {
        /* Exiting call depth 1 */
        Assert(proc->argstack == NULL);
        proc->calldepth--;
 
        /*
         * We used to delete the named arguments (but not "args") from the
         * proc's globals dict when exiting the outermost call level for a
         * function.  This seems rather pointless though: nothing can see the
         * dict until the function is called again, at which time we'll
         * overwrite those dict entries.  So don't bother with that.
         */
    }
}

References PLyProcedure::argstack, Assert, PLyProcedure::calldepth, fb(), PLySavedArgs::next, and PLy_function_restore_args().

Referenced by PLy_exec_function(), and PLy_exec_trigger().

PLy_global_args_push()

static void PLy_global_args_push ( PLyProcedure *  proc )

static

Definition at line 722 of file plpy_exec.c.

{
    /* We only need to push if we are already inside some active call */
    if (proc->calldepth > 0)
    {
        PLySavedArgs *node;
 
        /* Build a struct containing current argument values */
        node = PLy_function_save_args(proc);
 
        /*
         * Push the saved argument values into the procedure's stack.  Once we
         * modify either proc->argstack or proc->calldepth, we had better
         * return without the possibility of error.
         */
        node->next = proc->argstack;
        proc->argstack = node;
    }
    proc->calldepth++;
}

References PLyProcedure::argstack, PLyProcedure::calldepth, PLySavedArgs::next, and PLy_function_save_args().

Referenced by PLy_exec_function(), and PLy_exec_trigger().

PLy_modify_tuple()

static HeapTuple PLy_modify_tuple ( PLyProcedure *  proc, PyObject *  pltd, TriggerData *  tdata, HeapTuple  otup  )

static

Definition at line 1012 of file plpy_exec.c.

{
    HeapTuple   rtup;
    PyObject   *volatile plntup;
    PyObject   *volatile plkeys;
    PyObject   *volatile plval;
    Datum      *volatile modvalues;
    bool       *volatile modnulls;
    bool       *volatile modrepls;
    ErrorContextCallback plerrcontext;
 
    plerrcontext.callback = plpython_trigger_error_callback;
    plerrcontext.previous = error_context_stack;
    error_context_stack = &plerrcontext;
 
    plntup = plkeys = plval = NULL;
    modvalues = NULL;
    modnulls = NULL;
    modrepls = NULL;
 
    PG_TRY();
    {
        TupleDesc   tupdesc;
        int         nkeys,
                    i;
 
        if ((plntup = PyDict_GetItemString(pltd, "new")) == NULL)
            ereport(ERROR,
                    (errcode(ERRCODE_UNDEFINED_OBJECT),
                     errmsg("TD[\"new\"] deleted, cannot modify row")));
        Py_INCREF(plntup);
        if (!PyDict_Check(plntup))
            ereport(ERROR,
                    (errcode(ERRCODE_DATATYPE_MISMATCH),
                     errmsg("TD[\"new\"] is not a dictionary")));
 
        plkeys = PyDict_Keys(plntup);
        nkeys = PyList_Size(plkeys);
 
        tupdesc = RelationGetDescr(tdata->tg_relation);
 
        modvalues = (Datum *) palloc0(tupdesc->natts * sizeof(Datum));
        modnulls = (bool *) palloc0(tupdesc->natts * sizeof(bool));
        modrepls = (bool *) palloc0(tupdesc->natts * sizeof(bool));
 
        for (i = 0; i < nkeys; i++)
        {
            PyObject   *platt;
            char       *plattstr;
            int         attn;
            PLyObToDatum *att;
 
            platt = PyList_GetItem(plkeys, i);
            if (PyUnicode_Check(platt))
                plattstr = PLyUnicode_AsString(platt);
            else
            {
                ereport(ERROR,
                        (errcode(ERRCODE_DATATYPE_MISMATCH),
                         errmsg("TD[\"new\"] dictionary key at ordinal position %d is not a string", i)));
                plattstr = NULL;    /* keep compiler quiet */
            }
            attn = SPI_fnumber(tupdesc, plattstr);
            if (attn == SPI_ERROR_NOATTRIBUTE)
                ereport(ERROR,
                        (errcode(ERRCODE_UNDEFINED_COLUMN),
                         errmsg("key \"%s\" found in TD[\"new\"] does not exist as a column in the triggering row",
                                plattstr)));
            if (attn <= 0)
                ereport(ERROR,
                        (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
                         errmsg("cannot set system attribute \"%s\"",
                                plattstr)));
            if (TupleDescAttr(tupdesc, attn - 1)->attgenerated)
                ereport(ERROR,
                        (errcode(ERRCODE_E_R_I_E_TRIGGER_PROTOCOL_VIOLATED),
                         errmsg("cannot set generated column \"%s\"",
                                plattstr)));
 
            plval = PyDict_GetItem(plntup, platt);
            if (plval == NULL)
                elog(FATAL, "Python interpreter is probably corrupted");
 
            Py_INCREF(plval);
 
            /* We assume proc->result is set up to convert tuples properly */
            att = &proc->result.tuple.atts[attn - 1];
 
            modvalues[attn - 1] = PLy_output_convert(att,
                                                     plval,
                                                     &modnulls[attn - 1]);
            modrepls[attn - 1] = true;
 
            Py_DECREF(plval);
            plval = NULL;
        }
 
        rtup = heap_modify_tuple(otup, tupdesc, modvalues, modnulls, modrepls);
    }
    PG_CATCH();
    {
        Py_XDECREF(plntup);
        Py_XDECREF(plkeys);
        Py_XDECREF(plval);
 
        if (modvalues)
            pfree(modvalues);
        if (modnulls)
            pfree(modnulls);
        if (modrepls)
            pfree(modrepls);
 
        PG_RE_THROW();
    }
    PG_END_TRY();
 
    Py_DECREF(plntup);
    Py_DECREF(plkeys);
 
    pfree(modvalues);
    pfree(modnulls);
    pfree(modrepls);
 
    error_context_stack = plerrcontext.previous;
 
    return rtup;
}

References PLyObToTuple::atts, ErrorContextCallback::callback, elog, ereport, errcode(), errmsg, ERROR, error_context_stack, FATAL, fb(), heap_modify_tuple(), i, TupleDescData::natts, palloc0(), pfree(), PG_CATCH, PG_END_TRY, PG_RE_THROW, PG_TRY, plpython_trigger_error_callback(), PLy_output_convert(), PLyUnicode_AsString(), ErrorContextCallback::previous, RelationGetDescr, PLyProcedure::result, SPI_ERROR_NOATTRIBUTE, SPI_fnumber(), PLyObToDatum::tuple, and TupleDescAttr().

Referenced by PLy_exec_trigger().

PLy_procedure_call()

static PyObject * PLy_procedure_call ( PLyProcedure *  proc, const char *  kargs, PyObject *  vargs  )

static

Definition at line 1152 of file plpy_exec.c.

{
    PyObject   *rv = NULL;
    int volatile save_subxact_level = list_length(explicit_subtransactions);
 
    PyDict_SetItemString(proc->globals, kargs, vargs);
 
    PG_TRY();
    {
        rv = PyEval_EvalCode(proc->code, proc->globals, proc->globals);
 
        /*
         * Since plpy will only let you close subtransactions that you
         * started, you cannot *unnest* subtransactions, only *nest* them
         * without closing.
         */
        Assert(list_length(explicit_subtransactions) >= save_subxact_level);
    }
    PG_FINALLY();
    {
        PLy_abort_open_subtransactions(save_subxact_level);
    }
    PG_END_TRY();
 
    /* If the Python code returned an error, propagate it */
    if (rv == NULL)
        PLy_elog(ERROR, NULL);
 
    return rv;
}

References Assert, PLyProcedure::code, ERROR, explicit_subtransactions, fb(), PLyProcedure::globals, list_length(), PG_END_TRY, PG_FINALLY, PG_TRY, PLy_abort_open_subtransactions(), and PLy_elog.

Referenced by PLy_exec_event_trigger(), PLy_exec_function(), and PLy_exec_trigger().

PLy_trigger_build_args()

static PyObject * PLy_trigger_build_args ( FunctionCallInfo  fcinfo, PLyProcedure *  proc, HeapTuple *  rv  )

static

Definition at line 795 of file plpy_exec.c.

{
    TriggerData *tdata = (TriggerData *) fcinfo->context;
    TupleDesc   rel_descr = RelationGetDescr(tdata->tg_relation);
    PyObject   *pltname,
               *pltevent,
               *pltwhen,
               *pltlevel,
               *pltrelid,
               *plttablename,
               *plttableschema,
               *pltargs,
               *pytnew,
               *pytold,
               *pltdata;
    char       *stroid;
 
    /*
     * Make any Py*_New() calls before the PG_TRY block so that we can quickly
     * return NULL on failure.  We can't return within the PG_TRY block, else
     * we'd miss unwinding the exception stack.
     */
    pltdata = PyDict_New();
    if (!pltdata)
        return NULL;
 
    if (tdata->tg_trigger->tgnargs)
    {
        pltargs = PyList_New(tdata->tg_trigger->tgnargs);
        if (!pltargs)
        {
            Py_DECREF(pltdata);
            return NULL;
        }
    }
    else
    {
        Py_INCREF(Py_None);
        pltargs = Py_None;
    }
 
    PG_TRY();
    {
        pltname = PLyUnicode_FromString(tdata->tg_trigger->tgname);
        PyDict_SetItemString(pltdata, "name", pltname);
        Py_DECREF(pltname);
 
        stroid = DatumGetCString(DirectFunctionCall1(oidout,
                                                     ObjectIdGetDatum(tdata->tg_relation->rd_id)));
        pltrelid = PLyUnicode_FromString(stroid);
        PyDict_SetItemString(pltdata, "relid", pltrelid);
        Py_DECREF(pltrelid);
        pfree(stroid);
 
        stroid = SPI_getrelname(tdata->tg_relation);
        plttablename = PLyUnicode_FromString(stroid);
        PyDict_SetItemString(pltdata, "table_name", plttablename);
        Py_DECREF(plttablename);
        pfree(stroid);
 
        stroid = SPI_getnspname(tdata->tg_relation);
        plttableschema = PLyUnicode_FromString(stroid);
        PyDict_SetItemString(pltdata, "table_schema", plttableschema);
        Py_DECREF(plttableschema);
        pfree(stroid);
 
        if (TRIGGER_FIRED_BEFORE(tdata->tg_event))
            pltwhen = PLyUnicode_FromString("BEFORE");
        else if (TRIGGER_FIRED_AFTER(tdata->tg_event))
            pltwhen = PLyUnicode_FromString("AFTER");
        else if (TRIGGER_FIRED_INSTEAD(tdata->tg_event))
            pltwhen = PLyUnicode_FromString("INSTEAD OF");
        else
        {
            elog(ERROR, "unrecognized WHEN tg_event: %u", tdata->tg_event);
            pltwhen = NULL;     /* keep compiler quiet */
        }
        PyDict_SetItemString(pltdata, "when", pltwhen);
        Py_DECREF(pltwhen);
 
        if (TRIGGER_FIRED_FOR_ROW(tdata->tg_event))
        {
            pltlevel = PLyUnicode_FromString("ROW");
            PyDict_SetItemString(pltdata, "level", pltlevel);
            Py_DECREF(pltlevel);
 
            /*
             * Note: In BEFORE trigger, stored generated columns are not
             * computed yet, so don't make them accessible in NEW row.
             */
 
            if (TRIGGER_FIRED_BY_INSERT(tdata->tg_event))
            {
                pltevent = PLyUnicode_FromString("INSERT");
 
                PyDict_SetItemString(pltdata, "old", Py_None);
                pytnew = PLy_input_from_tuple(&proc->result_in,
                                              tdata->tg_trigtuple,
                                              rel_descr,
                                              !TRIGGER_FIRED_BEFORE(tdata->tg_event));
                PyDict_SetItemString(pltdata, "new", pytnew);
                Py_DECREF(pytnew);
                *rv = tdata->tg_trigtuple;
            }
            else if (TRIGGER_FIRED_BY_DELETE(tdata->tg_event))
            {
                pltevent = PLyUnicode_FromString("DELETE");
 
                PyDict_SetItemString(pltdata, "new", Py_None);
                pytold = PLy_input_from_tuple(&proc->result_in,
                                              tdata->tg_trigtuple,
                                              rel_descr,
                                              true);
                PyDict_SetItemString(pltdata, "old", pytold);
                Py_DECREF(pytold);
                *rv = tdata->tg_trigtuple;
            }
            else if (TRIGGER_FIRED_BY_UPDATE(tdata->tg_event))
            {
                pltevent = PLyUnicode_FromString("UPDATE");
 
                pytnew = PLy_input_from_tuple(&proc->result_in,
                                              tdata->tg_newtuple,
                                              rel_descr,
                                              !TRIGGER_FIRED_BEFORE(tdata->tg_event));
                PyDict_SetItemString(pltdata, "new", pytnew);
                Py_DECREF(pytnew);
                pytold = PLy_input_from_tuple(&proc->result_in,
                                              tdata->tg_trigtuple,
                                              rel_descr,
                                              true);
                PyDict_SetItemString(pltdata, "old", pytold);
                Py_DECREF(pytold);
                *rv = tdata->tg_newtuple;
            }
            else
            {
                elog(ERROR, "unrecognized OP tg_event: %u", tdata->tg_event);
                pltevent = NULL;    /* keep compiler quiet */
            }
 
            PyDict_SetItemString(pltdata, "event", pltevent);
            Py_DECREF(pltevent);
        }
        else if (TRIGGER_FIRED_FOR_STATEMENT(tdata->tg_event))
        {
            pltlevel = PLyUnicode_FromString("STATEMENT");
            PyDict_SetItemString(pltdata, "level", pltlevel);
            Py_DECREF(pltlevel);
 
            PyDict_SetItemString(pltdata, "old", Py_None);
            PyDict_SetItemString(pltdata, "new", Py_None);
            *rv = NULL;
 
            if (TRIGGER_FIRED_BY_INSERT(tdata->tg_event))
                pltevent = PLyUnicode_FromString("INSERT");
            else if (TRIGGER_FIRED_BY_DELETE(tdata->tg_event))
                pltevent = PLyUnicode_FromString("DELETE");
            else if (TRIGGER_FIRED_BY_UPDATE(tdata->tg_event))
                pltevent = PLyUnicode_FromString("UPDATE");
            else if (TRIGGER_FIRED_BY_TRUNCATE(tdata->tg_event))
                pltevent = PLyUnicode_FromString("TRUNCATE");
            else
            {
                elog(ERROR, "unrecognized OP tg_event: %u", tdata->tg_event);
                pltevent = NULL;    /* keep compiler quiet */
            }
 
            PyDict_SetItemString(pltdata, "event", pltevent);
            Py_DECREF(pltevent);
        }
        else
            elog(ERROR, "unrecognized LEVEL tg_event: %u", tdata->tg_event);
 
        if (tdata->tg_trigger->tgnargs)
        {
            /*
             * all strings...
             */
            int         i;
            PyObject   *pltarg;
 
            /* pltargs should have been allocated before the PG_TRY block. */
            Assert(pltargs && pltargs != Py_None);
 
            for (i = 0; i < tdata->tg_trigger->tgnargs; i++)
            {
                pltarg = PLyUnicode_FromString(tdata->tg_trigger->tgargs[i]);
 
                /*
                 * stolen, don't Py_DECREF
                 */
                PyList_SetItem(pltargs, i, pltarg);
            }
        }
        else
        {
            Assert(pltargs == Py_None);
        }
        PyDict_SetItemString(pltdata, "args", pltargs);
        Py_DECREF(pltargs);
    }
    PG_CATCH();
    {
        Py_XDECREF(pltargs);
        Py_XDECREF(pltdata);
        PG_RE_THROW();
    }
    PG_END_TRY();
 
    return pltdata;
}

References Assert, FunctionCallInfoBaseData::context, DatumGetCString(), DirectFunctionCall1, elog, ERROR, fb(), i, ObjectIdGetDatum(), oidout(), pfree(), PG_CATCH, PG_END_TRY, PG_RE_THROW, PG_TRY, PLy_input_from_tuple(), PLyUnicode_FromString(), RelationGetDescr, PLyProcedure::result_in, SPI_getnspname(), SPI_getrelname(), TRIGGER_FIRED_AFTER, TRIGGER_FIRED_BEFORE, TRIGGER_FIRED_BY_DELETE, TRIGGER_FIRED_BY_INSERT, TRIGGER_FIRED_BY_TRUNCATE, TRIGGER_FIRED_BY_UPDATE, TRIGGER_FIRED_FOR_ROW, TRIGGER_FIRED_FOR_STATEMENT, and TRIGGER_FIRED_INSTEAD.

Referenced by PLy_exec_trigger().

ShutdownPLyFunction()

static void ShutdownPLyFunction ( Datum  arg )

static

Definition at line 319 of file plpy_exec.c.

{
    PLyProcedureCache *pcache = (PLyProcedureCache *) DatumGetPointer(arg);
 
    /* execUtils.c will deregister the callback after we return */
    pcache->shutdown_reg = false;
 
    PLy_function_cleanup_srfstate(pcache);
}

References arg, DatumGetPointer(), fb(), PLy_function_cleanup_srfstate(), and PLyProcedureCache::shutdown_reg.

Referenced by PLy_exec_function().