1998-08-22 14:38:39 +02:00
|
|
|
/**********************************************************************
|
|
|
|
* pl_handler.c - Handler for the PL/pgSQL
|
|
|
|
* procedural language
|
|
|
|
*
|
|
|
|
* IDENTIFICATION
|
2005-12-28 19:11:25 +01:00
|
|
|
* $PostgreSQL: pgsql/src/pl/plpgsql/src/pl_handler.c,v 1.27 2005/12/28 18:11:25 tgl Exp $
|
1998-08-22 14:38:39 +02:00
|
|
|
*
|
1998-09-01 06:40:42 +02:00
|
|
|
* This software is copyrighted by Jan Wieck - Hamburg.
|
1998-08-22 14:38:39 +02:00
|
|
|
*
|
1998-09-01 06:40:42 +02:00
|
|
|
* The author hereby grants permission to use, copy, modify,
|
|
|
|
* distribute, and license this software and its documentation
|
|
|
|
* for any purpose, provided that existing copyright notices are
|
|
|
|
* retained in all copies and that this notice is included
|
|
|
|
* verbatim in any distributions. No written agreement, license,
|
|
|
|
* or royalty fee is required for any of the authorized uses.
|
|
|
|
* Modifications to this software may be copyrighted by their
|
|
|
|
* author and need not follow the licensing terms described
|
|
|
|
* here, provided that the new terms are clearly indicated on
|
|
|
|
* the first page of each file where they apply.
|
1998-08-22 14:38:39 +02:00
|
|
|
*
|
1998-09-01 06:40:42 +02:00
|
|
|
* IN NO EVENT SHALL THE AUTHOR OR DISTRIBUTORS BE LIABLE TO ANY
|
|
|
|
* PARTY FOR DIRECT, INDIRECT, SPECIAL, INCIDENTAL, OR
|
|
|
|
* CONSEQUENTIAL DAMAGES ARISING OUT OF THE USE OF THIS
|
|
|
|
* SOFTWARE, ITS DOCUMENTATION, OR ANY DERIVATIVES THEREOF, EVEN
|
|
|
|
* IF THE AUTHOR HAVE BEEN ADVISED OF THE POSSIBILITY OF SUCH
|
|
|
|
* DAMAGE.
|
1998-08-22 14:38:39 +02:00
|
|
|
*
|
1998-09-01 06:40:42 +02:00
|
|
|
* THE AUTHOR AND DISTRIBUTORS SPECIFICALLY DISCLAIM ANY
|
|
|
|
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
|
|
|
|
* WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
|
|
|
|
* PURPOSE, AND NON-INFRINGEMENT. THIS SOFTWARE IS PROVIDED ON
|
|
|
|
* AN "AS IS" BASIS, AND THE AUTHOR AND DISTRIBUTORS HAVE NO
|
|
|
|
* OBLIGATION TO PROVIDE MAINTENANCE, SUPPORT, UPDATES,
|
|
|
|
* ENHANCEMENTS, OR MODIFICATIONS.
|
1998-08-22 14:38:39 +02:00
|
|
|
*
|
|
|
|
**********************************************************************/
|
|
|
|
|
|
|
|
#include "plpgsql.h"
|
|
|
|
#include "pl.tab.h"
|
|
|
|
|
|
|
|
#include "access/heapam.h"
|
|
|
|
#include "catalog/pg_proc.h"
|
|
|
|
#include "catalog/pg_type.h"
|
2005-12-28 19:11:25 +01:00
|
|
|
#include "funcapi.h"
|
2000-05-28 19:56:29 +02:00
|
|
|
#include "utils/builtins.h"
|
2004-03-19 19:58:07 +01:00
|
|
|
#include "utils/lsyscache.h"
|
2000-05-28 19:56:29 +02:00
|
|
|
#include "utils/syscache.h"
|
1998-08-22 14:38:39 +02:00
|
|
|
|
2004-03-22 04:15:33 +01:00
|
|
|
extern DLLIMPORT bool check_function_bodies;
|
2004-03-19 19:58:07 +01:00
|
|
|
|
2005-10-15 04:49:52 +02:00
|
|
|
static bool plpgsql_firstcall = true;
|
2003-07-31 20:36:46 +02:00
|
|
|
|
|
|
|
static void plpgsql_init_all(void);
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
* plpgsql_init() - postmaster-startup safe initialization
|
|
|
|
*
|
|
|
|
* DO NOT make this static --- it has to be callable by preload
|
|
|
|
*/
|
|
|
|
void
|
|
|
|
plpgsql_init(void)
|
|
|
|
{
|
|
|
|
/* Do initialization only once */
|
|
|
|
if (!plpgsql_firstcall)
|
|
|
|
return;
|
|
|
|
|
|
|
|
plpgsql_HashTableInit();
|
2004-08-01 19:32:22 +02:00
|
|
|
RegisterXactCallback(plpgsql_xact_cb, NULL);
|
This patch changes makes some significant changes to how compilation
and parsing work in PL/PgSQL:
- memory management is now done via palloc(). The compiled representation
of each function now has its own memory context. Therefore, the storage
consumed by a function can be reclaimed via MemoryContextDelete().
During compilation, the CurrentMemoryContext is the function's memory
context. This means that a palloc() is sufficient to allocate memory
that will have the same lifetime as the function itself. As a result,
code invoked during compilation should be careful to pfree() temporary
allocations to avoid leaking memory. Since a lot of the code in the
backend is not careful about releasing palloc'ed memory, that means
we should switch into a temporary memory context before invoking
backend functions. A temporary context appropriate for such allocations
is `compile_tmp_cxt'.
- The ability to use palloc() allows us to simply a lot of the code in
the parser. Rather than representing lists of elements via ad hoc
linked lists or arrays, we can use the List type. Rather than doing
malloc followed by memset(0), we can just use palloc0().
- We now check that the user has supplied the right number of parameters
to a RAISE statement. Supplying either too few or too many results in
an error (at runtime).
- PL/PgSQL's parser needs to accept arbitrary SQL statements. Since we
do not want to duplicate the SQL grammar in the PL/PgSQL grammar, this
means we need to be quite lax in what the PL/PgSQL grammar considers
a "SQL statement". This can lead to misleading behavior if there is a
syntax error in the function definition, since we assume a malformed
PL/PgSQL construct is a SQL statement. Furthermore, these errors were
only detected at runtime (when we tried to execute the alleged "SQL
statement" via SPI).
To rectify this, the patch changes the parser to invoke the main SQL
parser when it sees a string it believes to be a SQL expression. This
means that synctically-invalid SQL will be rejected during the
compilation of the PL/PgSQL function. This is only done when compiling
for "validation" purposes (i.e. at CREATE FUNCTION time), so it should
not impose a runtime overhead.
- Fixes for the various buffer overruns I've patched in stable branches
in the past few weeks. I've rewritten code where I thought it was
warranted (unlike the patches applied to older branches, which were
minimally invasive).
- Various other minor changes and cleanups.
- Updates to the regression tests.
2005-02-22 08:18:27 +01:00
|
|
|
plpgsql_firstcall = false;
|
2003-07-31 20:36:46 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
/*
|
|
|
|
* plpgsql_init_all() - Initialize all
|
|
|
|
*/
|
|
|
|
static void
|
|
|
|
plpgsql_init_all(void)
|
|
|
|
{
|
|
|
|
/* Execute any postmaster-startup safe initialization */
|
This patch changes makes some significant changes to how compilation
and parsing work in PL/PgSQL:
- memory management is now done via palloc(). The compiled representation
of each function now has its own memory context. Therefore, the storage
consumed by a function can be reclaimed via MemoryContextDelete().
During compilation, the CurrentMemoryContext is the function's memory
context. This means that a palloc() is sufficient to allocate memory
that will have the same lifetime as the function itself. As a result,
code invoked during compilation should be careful to pfree() temporary
allocations to avoid leaking memory. Since a lot of the code in the
backend is not careful about releasing palloc'ed memory, that means
we should switch into a temporary memory context before invoking
backend functions. A temporary context appropriate for such allocations
is `compile_tmp_cxt'.
- The ability to use palloc() allows us to simply a lot of the code in
the parser. Rather than representing lists of elements via ad hoc
linked lists or arrays, we can use the List type. Rather than doing
malloc followed by memset(0), we can just use palloc0().
- We now check that the user has supplied the right number of parameters
to a RAISE statement. Supplying either too few or too many results in
an error (at runtime).
- PL/PgSQL's parser needs to accept arbitrary SQL statements. Since we
do not want to duplicate the SQL grammar in the PL/PgSQL grammar, this
means we need to be quite lax in what the PL/PgSQL grammar considers
a "SQL statement". This can lead to misleading behavior if there is a
syntax error in the function definition, since we assume a malformed
PL/PgSQL construct is a SQL statement. Furthermore, these errors were
only detected at runtime (when we tried to execute the alleged "SQL
statement" via SPI).
To rectify this, the patch changes the parser to invoke the main SQL
parser when it sees a string it believes to be a SQL expression. This
means that synctically-invalid SQL will be rejected during the
compilation of the PL/PgSQL function. This is only done when compiling
for "validation" purposes (i.e. at CREATE FUNCTION time), so it should
not impose a runtime overhead.
- Fixes for the various buffer overruns I've patched in stable branches
in the past few weeks. I've rewritten code where I thought it was
warranted (unlike the patches applied to older branches, which were
minimally invasive).
- Various other minor changes and cleanups.
- Updates to the regression tests.
2005-02-22 08:18:27 +01:00
|
|
|
plpgsql_init();
|
2003-07-31 20:36:46 +02:00
|
|
|
|
|
|
|
/*
|
2003-08-04 02:43:34 +02:00
|
|
|
* Any other initialization that must be done each time a new backend
|
|
|
|
* starts -- currently none
|
2003-07-31 20:36:46 +02:00
|
|
|
*/
|
|
|
|
}
|
1998-08-22 14:38:39 +02:00
|
|
|
|
|
|
|
/* ----------
|
2000-05-28 19:56:29 +02:00
|
|
|
* plpgsql_call_handler
|
|
|
|
*
|
|
|
|
* The PostgreSQL function manager and trigger manager
|
|
|
|
* call this function for execution of PL/pgSQL procedures.
|
1998-08-22 14:38:39 +02:00
|
|
|
* ----------
|
|
|
|
*/
|
2000-11-20 21:36:57 +01:00
|
|
|
PG_FUNCTION_INFO_V1(plpgsql_call_handler);
|
|
|
|
|
1998-08-22 14:38:39 +02:00
|
|
|
Datum
|
2000-05-28 19:56:29 +02:00
|
|
|
plpgsql_call_handler(PG_FUNCTION_ARGS)
|
1998-08-22 14:38:39 +02:00
|
|
|
{
|
2000-05-28 19:56:29 +02:00
|
|
|
PLpgSQL_function *func;
|
1998-09-01 06:40:42 +02:00
|
|
|
Datum retval;
|
2004-07-31 22:55:45 +02:00
|
|
|
int rc;
|
1998-09-01 06:40:42 +02:00
|
|
|
|
2003-07-31 20:36:46 +02:00
|
|
|
/* perform initialization */
|
|
|
|
plpgsql_init_all();
|
|
|
|
|
2001-03-22 07:16:21 +01:00
|
|
|
/*
|
2000-05-28 19:56:29 +02:00
|
|
|
* Connect to SPI manager
|
1998-09-01 06:40:42 +02:00
|
|
|
*/
|
2004-07-31 22:55:45 +02:00
|
|
|
if ((rc = SPI_connect()) != SPI_OK_CONNECT)
|
|
|
|
elog(ERROR, "SPI_connect failed: %s", SPI_result_code_string(rc));
|
1998-09-01 06:40:42 +02:00
|
|
|
|
2003-07-01 23:47:09 +02:00
|
|
|
/* Find or compile the function */
|
2004-03-19 19:58:07 +01:00
|
|
|
func = plpgsql_compile(fcinfo, false);
|
1998-09-01 06:40:42 +02:00
|
|
|
|
2001-03-22 07:16:21 +01:00
|
|
|
/*
|
|
|
|
* Determine if called as function or trigger and call appropriate
|
|
|
|
* subhandler
|
1998-09-01 06:40:42 +02:00
|
|
|
*/
|
2003-07-01 23:47:09 +02:00
|
|
|
if (CALLED_AS_TRIGGER(fcinfo))
|
2000-05-29 03:59:17 +02:00
|
|
|
retval = PointerGetDatum(plpgsql_exec_trigger(func,
|
2005-10-15 04:49:52 +02:00
|
|
|
(TriggerData *) fcinfo->context));
|
2000-05-28 19:56:29 +02:00
|
|
|
else
|
|
|
|
retval = plpgsql_exec_function(func, fcinfo);
|
1998-09-01 06:40:42 +02:00
|
|
|
|
2001-03-22 07:16:21 +01:00
|
|
|
/*
|
2000-05-28 19:56:29 +02:00
|
|
|
* Disconnect from SPI manager
|
1998-09-01 06:40:42 +02:00
|
|
|
*/
|
2004-07-31 22:55:45 +02:00
|
|
|
if ((rc = SPI_finish()) != SPI_OK_FINISH)
|
|
|
|
elog(ERROR, "SPI_finish failed: %s", SPI_result_code_string(rc));
|
1998-09-01 06:40:42 +02:00
|
|
|
|
2000-05-28 19:56:29 +02:00
|
|
|
return retval;
|
1998-08-22 14:38:39 +02:00
|
|
|
}
|
2004-03-19 19:58:07 +01:00
|
|
|
|
|
|
|
/* ----------
|
|
|
|
* plpgsql_validator
|
|
|
|
*
|
|
|
|
* This function attempts to validate a PL/pgSQL function at
|
|
|
|
* CREATE FUNCTION time.
|
|
|
|
* ----------
|
|
|
|
*/
|
|
|
|
PG_FUNCTION_INFO_V1(plpgsql_validator);
|
|
|
|
|
|
|
|
Datum
|
|
|
|
plpgsql_validator(PG_FUNCTION_ARGS)
|
|
|
|
{
|
|
|
|
Oid funcoid = PG_GETARG_OID(0);
|
|
|
|
HeapTuple tuple;
|
|
|
|
Form_pg_proc proc;
|
|
|
|
char functyptype;
|
2005-12-28 19:11:25 +01:00
|
|
|
int numargs;
|
|
|
|
Oid *argtypes;
|
|
|
|
char **argnames;
|
|
|
|
char *argmodes;
|
2004-03-19 19:58:07 +01:00
|
|
|
bool istrigger = false;
|
|
|
|
int i;
|
|
|
|
|
|
|
|
/* perform initialization */
|
|
|
|
plpgsql_init_all();
|
|
|
|
|
|
|
|
/* Get the new function's pg_proc entry */
|
|
|
|
tuple = SearchSysCache(PROCOID,
|
|
|
|
ObjectIdGetDatum(funcoid),
|
|
|
|
0, 0, 0);
|
|
|
|
if (!HeapTupleIsValid(tuple))
|
|
|
|
elog(ERROR, "cache lookup failed for function %u", funcoid);
|
|
|
|
proc = (Form_pg_proc) GETSTRUCT(tuple);
|
|
|
|
|
|
|
|
functyptype = get_typtype(proc->prorettype);
|
|
|
|
|
|
|
|
/* Disallow pseudotype result */
|
|
|
|
/* except for TRIGGER, RECORD, VOID, ANYARRAY, or ANYELEMENT */
|
|
|
|
if (functyptype == 'p')
|
|
|
|
{
|
|
|
|
/* we assume OPAQUE with no arguments means a trigger */
|
|
|
|
if (proc->prorettype == TRIGGEROID ||
|
|
|
|
(proc->prorettype == OPAQUEOID && proc->pronargs == 0))
|
|
|
|
istrigger = true;
|
|
|
|
else if (proc->prorettype != RECORDOID &&
|
2005-12-28 19:11:25 +01:00
|
|
|
proc->prorettype != VOIDOID &&
|
|
|
|
proc->prorettype != ANYARRAYOID &&
|
|
|
|
proc->prorettype != ANYELEMENTOID)
|
2004-03-19 19:58:07 +01:00
|
|
|
ereport(ERROR,
|
|
|
|
(errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
|
|
|
|
errmsg("plpgsql functions cannot return type %s",
|
|
|
|
format_type_be(proc->prorettype))));
|
|
|
|
}
|
|
|
|
|
2005-12-28 19:11:25 +01:00
|
|
|
/* Disallow pseudotypes in arguments (either IN or OUT) */
|
2004-03-19 19:58:07 +01:00
|
|
|
/* except for ANYARRAY or ANYELEMENT */
|
2005-12-28 19:11:25 +01:00
|
|
|
numargs = get_func_arg_info(tuple,
|
|
|
|
&argtypes, &argnames, &argmodes);
|
|
|
|
for (i = 0; i < numargs; i++)
|
2004-03-19 19:58:07 +01:00
|
|
|
{
|
2005-12-28 19:11:25 +01:00
|
|
|
if (get_typtype(argtypes[i]) == 'p')
|
2004-03-19 19:58:07 +01:00
|
|
|
{
|
2005-12-28 19:11:25 +01:00
|
|
|
if (argtypes[i] != ANYARRAYOID &&
|
|
|
|
argtypes[i] != ANYELEMENTOID)
|
2004-03-19 19:58:07 +01:00
|
|
|
ereport(ERROR,
|
|
|
|
(errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
|
|
|
|
errmsg("plpgsql functions cannot take type %s",
|
2005-12-28 19:11:25 +01:00
|
|
|
format_type_be(argtypes[i]))));
|
2004-03-19 19:58:07 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Postpone body checks if !check_function_bodies */
|
|
|
|
if (check_function_bodies)
|
|
|
|
{
|
|
|
|
FunctionCallInfoData fake_fcinfo;
|
|
|
|
FmgrInfo flinfo;
|
|
|
|
TriggerData trigdata;
|
2004-07-31 22:55:45 +02:00
|
|
|
int rc;
|
2004-03-19 19:58:07 +01:00
|
|
|
|
|
|
|
/*
|
|
|
|
* Connect to SPI manager (is this needed for compilation?)
|
|
|
|
*/
|
2004-07-31 22:55:45 +02:00
|
|
|
if ((rc = SPI_connect()) != SPI_OK_CONNECT)
|
|
|
|
elog(ERROR, "SPI_connect failed: %s", SPI_result_code_string(rc));
|
2004-03-19 19:58:07 +01:00
|
|
|
|
|
|
|
/*
|
|
|
|
* Set up a fake fcinfo with just enough info to satisfy
|
|
|
|
* plpgsql_compile().
|
|
|
|
*/
|
|
|
|
MemSet(&fake_fcinfo, 0, sizeof(fake_fcinfo));
|
|
|
|
MemSet(&flinfo, 0, sizeof(flinfo));
|
|
|
|
fake_fcinfo.flinfo = &flinfo;
|
|
|
|
flinfo.fn_oid = funcoid;
|
|
|
|
flinfo.fn_mcxt = CurrentMemoryContext;
|
|
|
|
if (istrigger)
|
|
|
|
{
|
|
|
|
MemSet(&trigdata, 0, sizeof(trigdata));
|
|
|
|
trigdata.type = T_TriggerData;
|
|
|
|
fake_fcinfo.context = (Node *) &trigdata;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Test-compile the function */
|
|
|
|
plpgsql_compile(&fake_fcinfo, true);
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Disconnect from SPI manager
|
|
|
|
*/
|
2004-07-31 22:55:45 +02:00
|
|
|
if ((rc = SPI_finish()) != SPI_OK_FINISH)
|
|
|
|
elog(ERROR, "SPI_finish failed: %s", SPI_result_code_string(rc));
|
2004-03-19 19:58:07 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
ReleaseSysCache(tuple);
|
|
|
|
|
|
|
|
PG_RETURN_VOID();
|
|
|
|
}
|