mirror of
https://git.postgresql.org/git/postgresql.git
synced 2024-07-16 09:31:09 +02:00
caaf2e8469
Various places were testing TRIGGER_FIRED_BEFORE() where what they really meant was !TRIGGER_FIRED_AFTER(), or vice versa. This needs to be cleaned up because there are about to be more than two possible states. We might want to note this in the 9.1 release notes as something for trigger authors to double-check. For consistency's sake I also changed some places that assumed that TRIGGER_FIRED_FOR_ROW and TRIGGER_FIRED_FOR_STATEMENT are necessarily mutually exclusive; that's not in immediate danger of breaking, but it's still sloppier than it should be. Extracted from Dean Rasheed's patch for triggers on views. I'm committing this separately since it's an identifiable separate issue, and is the only reason for the patch to touch most of these particular files.
126 lines
3.2 KiB
C
126 lines
3.2 KiB
C
/*
|
|
* contrib/spi/autoinc.c
|
|
*/
|
|
#include "postgres.h"
|
|
|
|
#include "catalog/pg_type.h"
|
|
#include "commands/sequence.h"
|
|
#include "commands/trigger.h"
|
|
#include "executor/spi.h"
|
|
#include "utils/builtins.h"
|
|
|
|
PG_MODULE_MAGIC;
|
|
|
|
extern Datum autoinc(PG_FUNCTION_ARGS);
|
|
|
|
PG_FUNCTION_INFO_V1(autoinc);
|
|
|
|
Datum
|
|
autoinc(PG_FUNCTION_ARGS)
|
|
{
|
|
TriggerData *trigdata = (TriggerData *) fcinfo->context;
|
|
Trigger *trigger; /* to get trigger name */
|
|
int nargs; /* # of arguments */
|
|
int *chattrs; /* attnums of attributes to change */
|
|
int chnattrs = 0; /* # of above */
|
|
Datum *newvals; /* vals of above */
|
|
char **args; /* arguments */
|
|
char *relname; /* triggered relation name */
|
|
Relation rel; /* triggered relation */
|
|
HeapTuple rettuple = NULL;
|
|
TupleDesc tupdesc; /* tuple description */
|
|
bool isnull;
|
|
int i;
|
|
|
|
if (!CALLED_AS_TRIGGER(fcinfo))
|
|
/* internal error */
|
|
elog(ERROR, "not fired by trigger manager");
|
|
if (!TRIGGER_FIRED_FOR_ROW(trigdata->tg_event))
|
|
/* internal error */
|
|
elog(ERROR, "must be fired for row");
|
|
if (!TRIGGER_FIRED_BEFORE(trigdata->tg_event))
|
|
/* internal error */
|
|
elog(ERROR, "must be fired before event");
|
|
|
|
if (TRIGGER_FIRED_BY_INSERT(trigdata->tg_event))
|
|
rettuple = trigdata->tg_trigtuple;
|
|
else if (TRIGGER_FIRED_BY_UPDATE(trigdata->tg_event))
|
|
rettuple = trigdata->tg_newtuple;
|
|
else
|
|
/* internal error */
|
|
elog(ERROR, "cannot process DELETE events");
|
|
|
|
rel = trigdata->tg_relation;
|
|
relname = SPI_getrelname(rel);
|
|
|
|
trigger = trigdata->tg_trigger;
|
|
|
|
nargs = trigger->tgnargs;
|
|
if (nargs <= 0 || nargs % 2 != 0)
|
|
/* internal error */
|
|
elog(ERROR, "autoinc (%s): even number gt 0 of arguments was expected", relname);
|
|
|
|
args = trigger->tgargs;
|
|
tupdesc = rel->rd_att;
|
|
|
|
chattrs = (int *) palloc(nargs / 2 * sizeof(int));
|
|
newvals = (Datum *) palloc(nargs / 2 * sizeof(Datum));
|
|
|
|
for (i = 0; i < nargs;)
|
|
{
|
|
int attnum = SPI_fnumber(tupdesc, args[i]);
|
|
int32 val;
|
|
Datum seqname;
|
|
|
|
if (attnum < 0)
|
|
ereport(ERROR,
|
|
(errcode(ERRCODE_TRIGGERED_ACTION_EXCEPTION),
|
|
errmsg("\"%s\" has no attribute \"%s\"",
|
|
relname, args[i])));
|
|
|
|
if (SPI_gettypeid(tupdesc, attnum) != INT4OID)
|
|
ereport(ERROR,
|
|
(errcode(ERRCODE_TRIGGERED_ACTION_EXCEPTION),
|
|
errmsg("attribute \"%s\" of \"%s\" must be type INT4",
|
|
args[i], relname)));
|
|
|
|
val = DatumGetInt32(SPI_getbinval(rettuple, tupdesc, attnum, &isnull));
|
|
|
|
if (!isnull && val != 0)
|
|
{
|
|
i += 2;
|
|
continue;
|
|
}
|
|
|
|
i++;
|
|
chattrs[chnattrs] = attnum;
|
|
seqname = CStringGetTextDatum(args[i]);
|
|
newvals[chnattrs] = DirectFunctionCall1(nextval, seqname);
|
|
/* nextval now returns int64; coerce down to int32 */
|
|
newvals[chnattrs] = Int32GetDatum((int32) DatumGetInt64(newvals[chnattrs]));
|
|
if (DatumGetInt32(newvals[chnattrs]) == 0)
|
|
{
|
|
newvals[chnattrs] = DirectFunctionCall1(nextval, seqname);
|
|
newvals[chnattrs] = Int32GetDatum((int32) DatumGetInt64(newvals[chnattrs]));
|
|
}
|
|
pfree(DatumGetTextP(seqname));
|
|
chnattrs++;
|
|
i++;
|
|
}
|
|
|
|
if (chnattrs > 0)
|
|
{
|
|
rettuple = SPI_modifytuple(rel, rettuple, chnattrs, chattrs, newvals, NULL);
|
|
if (rettuple == NULL)
|
|
/* internal error */
|
|
elog(ERROR, "autoinc (%s): %d returned by SPI_modifytuple",
|
|
relname, SPI_result);
|
|
}
|
|
|
|
pfree(relname);
|
|
pfree(chattrs);
|
|
pfree(newvals);
|
|
|
|
return PointerGetDatum(rettuple);
|
|
}
|