blob: 6ac45fc23bb71d67e0f4e2854b3dbebd869a987e [file] [log] [blame]
danielk1977c3f9bad2002-05-15 08:30:12 +00001/*
danielk1977633ed082002-05-17 00:05:58 +00002**
3** The author disclaims copyright to this source code. In place of
4** a legal notice, here is a blessing:
5**
6** May you do good and not evil.
7** May you find forgiveness for yourself and forgive others.
8** May you share freely, never taking more than you give.
9**
10*************************************************************************
11*
drh9adf9ac2002-05-15 11:44:13 +000012*/
danielk1977c3f9bad2002-05-15 08:30:12 +000013#include "sqliteInt.h"
drh9adf9ac2002-05-15 11:44:13 +000014
danielk1977c3f9bad2002-05-15 08:30:12 +000015/*
drh4b59ab52002-08-24 18:24:51 +000016** Delete a linked list of TriggerStep structures.
17*/
drhf0f258b2003-04-21 18:48:45 +000018void sqliteDeleteTriggerStep(TriggerStep *pTriggerStep){
drh4b59ab52002-08-24 18:24:51 +000019 while( pTriggerStep ){
20 TriggerStep * pTmp = pTriggerStep;
21 pTriggerStep = pTriggerStep->pNext;
22
drh8c74a8c2002-08-25 19:20:40 +000023 if( pTmp->target.dyn ) sqliteFree((char*)pTmp->target.z);
drh4b59ab52002-08-24 18:24:51 +000024 sqliteExprDelete(pTmp->pWhere);
25 sqliteExprListDelete(pTmp->pExprList);
26 sqliteSelectDelete(pTmp->pSelect);
27 sqliteIdListDelete(pTmp->pIdList);
28
29 sqliteFree(pTmp);
30 }
31}
32
33/*
drhf0f258b2003-04-21 18:48:45 +000034** This is called by the parser when it sees a CREATE TRIGGER statement
35** up to the point of the BEGIN before the trigger actions. A Trigger
36** structure is generated based on the information available and stored
37** in pParse->pNewTrigger. After the trigger actions have been parsed, the
38** sqliteFinishTrigger() function is called to complete the trigger
39** construction process.
drh9adf9ac2002-05-15 11:44:13 +000040*/
drhf0f258b2003-04-21 18:48:45 +000041void sqliteBeginTrigger(
drh9adf9ac2002-05-15 11:44:13 +000042 Parse *pParse, /* The parse context of the CREATE TRIGGER statement */
danielk1977633ed082002-05-17 00:05:58 +000043 Token *pName, /* The name of the trigger */
drh5cf590c2003-04-24 01:45:04 +000044 int tr_tm, /* One of TK_BEFORE, TK_AFTER, TK_INSTEAD */
drh9adf9ac2002-05-15 11:44:13 +000045 int op, /* One of TK_INSERT, TK_UPDATE, TK_DELETE */
danielk1977633ed082002-05-17 00:05:58 +000046 IdList *pColumns, /* column list if this is an UPDATE OF trigger */
drhd24cc422003-03-27 12:51:24 +000047 SrcList *pTableName,/* The name of the table/view the trigger applies to */
drh9adf9ac2002-05-15 11:44:13 +000048 int foreach, /* One of TK_ROW or TK_STATEMENT */
49 Expr *pWhen, /* WHEN clause */
drhf0f258b2003-04-21 18:48:45 +000050 int isTemp /* True if the TEMPORARY keyword is present */
drh9adf9ac2002-05-15 11:44:13 +000051){
52 Trigger *nt;
53 Table *tab;
drhf0f258b2003-04-21 18:48:45 +000054 char *zName = 0; /* Name of the trigger */
drhd24cc422003-03-27 12:51:24 +000055 sqlite *db = pParse->db;
drhf0f258b2003-04-21 18:48:45 +000056 int iDb; /* When database to store the trigger in */
drhed6c8672003-01-12 18:02:16 +000057
danielk1977c3f9bad2002-05-15 08:30:12 +000058 /* Check that:
drh9adf9ac2002-05-15 11:44:13 +000059 ** 1. the trigger name does not already exist.
drhf0f258b2003-04-21 18:48:45 +000060 ** 2. the table (or view) does exist in the same database as the trigger.
danielk1977d702fcc2002-05-26 23:24:40 +000061 ** 3. that we are not trying to create a trigger on the sqlite_master table
62 ** 4. That we are not trying to create an INSTEAD OF trigger on a table.
63 ** 5. That we are not trying to create a BEFORE or AFTER trigger on a view.
drh9adf9ac2002-05-15 11:44:13 +000064 */
drhd24cc422003-03-27 12:51:24 +000065 if( sqlite_malloc_failed ) goto trigger_cleanup;
66 assert( pTableName->nSrc==1 );
drh812d7a22003-03-27 13:50:00 +000067 tab = sqliteSrcListLookup(pParse, pTableName);
drhd24cc422003-03-27 12:51:24 +000068 if( !tab ){
69 goto trigger_cleanup;
70 }
drhf0f258b2003-04-21 18:48:45 +000071 iDb = isTemp ? 1 : tab->iDb;
72 if( iDb>=2 && !pParse->initFlag ){
drhda93d232003-03-31 02:12:46 +000073 sqliteErrorMsg(pParse, "triggers may not be added to auxiliary "
74 "database %s", db->aDb[tab->iDb].zName);
drhd24cc422003-03-27 12:51:24 +000075 goto trigger_cleanup;
76 }
77
drhe5f9c642003-01-13 23:27:31 +000078 zName = sqliteStrNDup(pName->z, pName->n);
drhf0f258b2003-04-21 18:48:45 +000079 if( sqliteHashFind(&(db->aDb[iDb].trigHash), zName,pName->n+1) ){
drhda93d232003-03-31 02:12:46 +000080 sqliteErrorMsg(pParse, "trigger %T already exists", pName);
drhe5f9c642003-01-13 23:27:31 +000081 goto trigger_cleanup;
danielk1977c3f9bad2002-05-15 08:30:12 +000082 }
drhd24cc422003-03-27 12:51:24 +000083 if( sqliteStrNICmp(tab->zName, "sqlite_", 7)==0 ){
drhda93d232003-03-31 02:12:46 +000084 sqliteErrorMsg(pParse, "cannot create trigger on system table");
drhd24cc422003-03-27 12:51:24 +000085 pParse->nErr++;
86 goto trigger_cleanup;
danielk1977d702fcc2002-05-26 23:24:40 +000087 }
drhd24cc422003-03-27 12:51:24 +000088 if( tab->pSelect && tr_tm != TK_INSTEAD ){
drhda93d232003-03-31 02:12:46 +000089 sqliteErrorMsg(pParse, "cannot create %s trigger on view: %S",
90 (tr_tm == TK_BEFORE)?"BEFORE":"AFTER", pTableName, 0);
drhd24cc422003-03-27 12:51:24 +000091 goto trigger_cleanup;
92 }
93 if( !tab->pSelect && tr_tm == TK_INSTEAD ){
drhda93d232003-03-31 02:12:46 +000094 sqliteErrorMsg(pParse, "cannot create INSTEAD OF"
95 " trigger on table: %S", pTableName, 0);
drhd24cc422003-03-27 12:51:24 +000096 goto trigger_cleanup;
97 }
98#ifndef SQLITE_OMIT_AUTHORIZATION
99 {
100 int code = SQLITE_CREATE_TRIGGER;
drhe22a3342003-04-22 20:30:37 +0000101 const char *zDb = db->aDb[tab->iDb].zName;
102 const char *zDbTrig = isTemp ? db->aDb[1].zName : zDb;
drhf0f258b2003-04-21 18:48:45 +0000103 if( tab->iDb==1 || isTemp ) code = SQLITE_CREATE_TEMP_TRIGGER;
drhe22a3342003-04-22 20:30:37 +0000104 if( sqliteAuthCheck(pParse, code, zName, tab->zName, zDbTrig) ){
drhd24cc422003-03-27 12:51:24 +0000105 goto trigger_cleanup;
106 }
drhe22a3342003-04-22 20:30:37 +0000107 if( sqliteAuthCheck(pParse, SQLITE_INSERT, SCHEMA_TABLE(tab->iDb), 0, zDb)){
drhd24cc422003-03-27 12:51:24 +0000108 goto trigger_cleanup;
109 }
110 }
111#endif
danielk1977d702fcc2002-05-26 23:24:40 +0000112
drh5cf590c2003-04-24 01:45:04 +0000113 /* INSTEAD OF triggers can only appear on views and BEGIN triggers
114 ** cannot appear on views. So we might as well translate every
115 ** INSTEAD OF trigger into a BEFORE trigger. It simplifies code
116 ** elsewhere.
117 */
danielk1977d702fcc2002-05-26 23:24:40 +0000118 if (tr_tm == TK_INSTEAD){
119 tr_tm = TK_BEFORE;
danielk1977c3f9bad2002-05-15 08:30:12 +0000120 }
121
122 /* Build the Trigger object */
drh9adf9ac2002-05-15 11:44:13 +0000123 nt = (Trigger*)sqliteMalloc(sizeof(Trigger));
drhe4697f52002-05-23 02:09:03 +0000124 if( nt==0 ) goto trigger_cleanup;
drhe5f9c642003-01-13 23:27:31 +0000125 nt->name = zName;
126 zName = 0;
drhd24cc422003-03-27 12:51:24 +0000127 nt->table = sqliteStrDup(pTableName->a[0].zName);
drhe4697f52002-05-23 02:09:03 +0000128 if( sqlite_malloc_failed ) goto trigger_cleanup;
drhf0f258b2003-04-21 18:48:45 +0000129 nt->iDb = iDb;
drh79a519c2003-05-17 19:04:03 +0000130 nt->iTabDb = tab->iDb;
danielk1977c3f9bad2002-05-15 08:30:12 +0000131 nt->op = op;
132 nt->tr_tm = tr_tm;
drh4b59ab52002-08-24 18:24:51 +0000133 nt->pWhen = sqliteExprDup(pWhen);
drh4b59ab52002-08-24 18:24:51 +0000134 nt->pColumns = sqliteIdListDup(pColumns);
danielk1977c3f9bad2002-05-15 08:30:12 +0000135 nt->foreach = foreach;
drhf0f258b2003-04-21 18:48:45 +0000136 assert( pParse->pNewTrigger==0 );
137 pParse->pNewTrigger = nt;
138
139trigger_cleanup:
140 sqliteFree(zName);
141 sqliteSrcListDelete(pTableName);
142 sqliteIdListDelete(pColumns);
143 sqliteExprDelete(pWhen);
144}
145
146/*
147** This routine is called after all of the trigger actions have been parsed
148** in order to complete the process of building the trigger.
149*/
150void sqliteFinishTrigger(
151 Parse *pParse, /* Parser context */
152 TriggerStep *pStepList, /* The triggered program */
153 Token *pAll /* Token that describes the complete CREATE TRIGGER */
154){
155 Trigger *nt; /* The trigger whose construction is finishing up */
156 sqlite *db = pParse->db; /* The database */
157
158 if( pParse->nErr || pParse->pNewTrigger==0 ) goto triggerfinish_cleanup;
159 nt = pParse->pNewTrigger;
160 pParse->pNewTrigger = 0;
danielk1977633ed082002-05-17 00:05:58 +0000161 nt->step_list = pStepList;
drha69d9162003-04-17 22:57:53 +0000162 while( pStepList ){
163 pStepList->pTrig = nt;
164 pStepList = pStepList->pNext;
165 }
danielk1977c3f9bad2002-05-15 08:30:12 +0000166
167 /* if we are not initializing, and this trigger is not on a TEMP table,
drh9adf9ac2002-05-15 11:44:13 +0000168 ** build the sqlite_master entry
169 */
drhe0bc4042002-06-25 01:09:11 +0000170 if( !pParse->initFlag ){
drhc977f7f2002-05-21 11:38:11 +0000171 static VdbeOp insertTrig[] = {
drhc977f7f2002-05-21 11:38:11 +0000172 { OP_NewRecno, 0, 0, 0 },
173 { OP_String, 0, 0, "trigger" },
drhe0bc4042002-06-25 01:09:11 +0000174 { OP_String, 0, 0, 0 }, /* 2: trigger name */
175 { OP_String, 0, 0, 0 }, /* 3: table name */
drhc977f7f2002-05-21 11:38:11 +0000176 { OP_Integer, 0, 0, 0 },
drhe0bc4042002-06-25 01:09:11 +0000177 { OP_String, 0, 0, 0 }, /* 5: SQL */
drhc977f7f2002-05-21 11:38:11 +0000178 { OP_MakeRecord, 5, 0, 0 },
179 { OP_PutIntKey, 0, 0, 0 },
drhc977f7f2002-05-21 11:38:11 +0000180 };
181 int addr;
182 Vdbe *v;
danielk1977c3f9bad2002-05-15 08:30:12 +0000183
184 /* Make an entry in the sqlite_master table */
drhc977f7f2002-05-21 11:38:11 +0000185 v = sqliteGetVdbe(pParse);
drhf0f258b2003-04-21 18:48:45 +0000186 if( v==0 ) goto triggerfinish_cleanup;
drhcabb0812002-09-14 13:47:32 +0000187 sqliteBeginWriteOperation(pParse, 0, 0);
drh79a519c2003-05-17 19:04:03 +0000188 sqliteOpenMasterTable(v, nt->iDb);
drhc977f7f2002-05-21 11:38:11 +0000189 addr = sqliteVdbeAddOpList(v, ArraySize(insertTrig), insertTrig);
drhe0bc4042002-06-25 01:09:11 +0000190 sqliteVdbeChangeP3(v, addr+2, nt->name, 0);
191 sqliteVdbeChangeP3(v, addr+3, nt->table, 0);
drh4b59ab52002-08-24 18:24:51 +0000192 sqliteVdbeChangeP3(v, addr+5, pAll->z, pAll->n);
drhf0f258b2003-04-21 18:48:45 +0000193 if( nt->iDb==0 ){
drhd24cc422003-03-27 12:51:24 +0000194 sqliteChangeCookie(db, v);
drhe0bc4042002-06-25 01:09:11 +0000195 }
196 sqliteVdbeAddOp(v, OP_Close, 0, 0);
danielk1977c3f9bad2002-05-15 08:30:12 +0000197 sqliteEndWriteOperation(pParse);
198 }
199
danielk1977633ed082002-05-17 00:05:58 +0000200 if( !pParse->explain ){
drhf0f258b2003-04-21 18:48:45 +0000201 Table *pTab;
202 sqliteHashInsert(&db->aDb[nt->iDb].trigHash,
203 nt->name, strlen(nt->name)+1, nt);
204 pTab = sqliteLocateTable(pParse, nt->table, 0);
205 assert( pTab!=0 );
206 nt->pNext = pTab->pTrigger;
207 pTab->pTrigger = nt;
danielk1977f29ce552002-05-19 23:43:12 +0000208 }else{
drhf0f258b2003-04-21 18:48:45 +0000209 sqliteDeleteTrigger(nt);
danielk1977c3f9bad2002-05-15 08:30:12 +0000210 }
211
drhf0f258b2003-04-21 18:48:45 +0000212triggerfinish_cleanup:
213 sqliteDeleteTrigger(pParse->pNewTrigger);
214 pParse->pNewTrigger = 0;
drh4b59ab52002-08-24 18:24:51 +0000215 sqliteDeleteTriggerStep(pStepList);
216}
danielk1977c3f9bad2002-05-15 08:30:12 +0000217
drh4b59ab52002-08-24 18:24:51 +0000218/*
219** Make a copy of all components of the given trigger step. This has
220** the effect of copying all Expr.token.z values into memory obtained
221** from sqliteMalloc(). As initially created, the Expr.token.z values
222** all point to the input string that was fed to the parser. But that
223** string is ephemeral - it will go away as soon as the sqlite_exec()
224** call that started the parser exits. This routine makes a persistent
225** copy of all the Expr.token.z strings so that the TriggerStep structure
226** will be valid even after the sqlite_exec() call returns.
227*/
228static void sqlitePersistTriggerStep(TriggerStep *p){
229 if( p->target.z ){
230 p->target.z = sqliteStrNDup(p->target.z, p->target.n);
231 p->target.dyn = 1;
232 }
233 if( p->pSelect ){
234 Select *pNew = sqliteSelectDup(p->pSelect);
235 sqliteSelectDelete(p->pSelect);
236 p->pSelect = pNew;
237 }
238 if( p->pWhere ){
239 Expr *pNew = sqliteExprDup(p->pWhere);
240 sqliteExprDelete(p->pWhere);
241 p->pWhere = pNew;
242 }
243 if( p->pExprList ){
244 ExprList *pNew = sqliteExprListDup(p->pExprList);
245 sqliteExprListDelete(p->pExprList);
246 p->pExprList = pNew;
247 }
248 if( p->pIdList ){
249 IdList *pNew = sqliteIdListDup(p->pIdList);
250 sqliteIdListDelete(p->pIdList);
251 p->pIdList = pNew;
danielk1977c3f9bad2002-05-15 08:30:12 +0000252 }
253}
254
drhc977f7f2002-05-21 11:38:11 +0000255/*
256** Turn a SELECT statement (that the pSelect parameter points to) into
257** a trigger step. Return a pointer to a TriggerStep structure.
258**
259** The parser calls this routine when it finds a SELECT statement in
260** body of a TRIGGER.
261*/
262TriggerStep *sqliteTriggerSelectStep(Select *pSelect){
danielk1977633ed082002-05-17 00:05:58 +0000263 TriggerStep *pTriggerStep = sqliteMalloc(sizeof(TriggerStep));
drhe4697f52002-05-23 02:09:03 +0000264 if( pTriggerStep==0 ) return 0;
danielk1977c3f9bad2002-05-15 08:30:12 +0000265
danielk1977633ed082002-05-17 00:05:58 +0000266 pTriggerStep->op = TK_SELECT;
267 pTriggerStep->pSelect = pSelect;
268 pTriggerStep->orconf = OE_Default;
drh4b59ab52002-08-24 18:24:51 +0000269 sqlitePersistTriggerStep(pTriggerStep);
danielk1977c3f9bad2002-05-15 08:30:12 +0000270
danielk1977633ed082002-05-17 00:05:58 +0000271 return pTriggerStep;
danielk1977c3f9bad2002-05-15 08:30:12 +0000272}
273
drhc977f7f2002-05-21 11:38:11 +0000274/*
275** Build a trigger step out of an INSERT statement. Return a pointer
276** to the new trigger step.
277**
278** The parser calls this routine when it sees an INSERT inside the
279** body of a trigger.
280*/
danielk1977633ed082002-05-17 00:05:58 +0000281TriggerStep *sqliteTriggerInsertStep(
drhc977f7f2002-05-21 11:38:11 +0000282 Token *pTableName, /* Name of the table into which we insert */
283 IdList *pColumn, /* List of columns in pTableName to insert into */
284 ExprList *pEList, /* The VALUE clause: a list of values to be inserted */
285 Select *pSelect, /* A SELECT statement that supplies values */
286 int orconf /* The conflict algorithm (OE_Abort, OE_Replace, etc.) */
danielk1977633ed082002-05-17 00:05:58 +0000287){
288 TriggerStep *pTriggerStep = sqliteMalloc(sizeof(TriggerStep));
drhe4697f52002-05-23 02:09:03 +0000289 if( pTriggerStep==0 ) return 0;
danielk1977c3f9bad2002-05-15 08:30:12 +0000290
danielk1977633ed082002-05-17 00:05:58 +0000291 assert(pEList == 0 || pSelect == 0);
292 assert(pEList != 0 || pSelect != 0);
danielk1977c3f9bad2002-05-15 08:30:12 +0000293
danielk1977633ed082002-05-17 00:05:58 +0000294 pTriggerStep->op = TK_INSERT;
295 pTriggerStep->pSelect = pSelect;
296 pTriggerStep->target = *pTableName;
297 pTriggerStep->pIdList = pColumn;
298 pTriggerStep->pExprList = pEList;
299 pTriggerStep->orconf = orconf;
drh4b59ab52002-08-24 18:24:51 +0000300 sqlitePersistTriggerStep(pTriggerStep);
danielk1977c3f9bad2002-05-15 08:30:12 +0000301
danielk1977633ed082002-05-17 00:05:58 +0000302 return pTriggerStep;
danielk1977c3f9bad2002-05-15 08:30:12 +0000303}
304
drhc977f7f2002-05-21 11:38:11 +0000305/*
306** Construct a trigger step that implements an UPDATE statement and return
307** a pointer to that trigger step. The parser calls this routine when it
308** sees an UPDATE statement inside the body of a CREATE TRIGGER.
309*/
danielk1977633ed082002-05-17 00:05:58 +0000310TriggerStep *sqliteTriggerUpdateStep(
drhc977f7f2002-05-21 11:38:11 +0000311 Token *pTableName, /* Name of the table to be updated */
312 ExprList *pEList, /* The SET clause: list of column and new values */
313 Expr *pWhere, /* The WHERE clause */
314 int orconf /* The conflict algorithm. (OE_Abort, OE_Ignore, etc) */
315){
danielk1977633ed082002-05-17 00:05:58 +0000316 TriggerStep *pTriggerStep = sqliteMalloc(sizeof(TriggerStep));
drhe4697f52002-05-23 02:09:03 +0000317 if( pTriggerStep==0 ) return 0;
danielk1977c3f9bad2002-05-15 08:30:12 +0000318
danielk1977633ed082002-05-17 00:05:58 +0000319 pTriggerStep->op = TK_UPDATE;
320 pTriggerStep->target = *pTableName;
321 pTriggerStep->pExprList = pEList;
322 pTriggerStep->pWhere = pWhere;
323 pTriggerStep->orconf = orconf;
drh4b59ab52002-08-24 18:24:51 +0000324 sqlitePersistTriggerStep(pTriggerStep);
danielk1977c3f9bad2002-05-15 08:30:12 +0000325
danielk1977633ed082002-05-17 00:05:58 +0000326 return pTriggerStep;
danielk1977c3f9bad2002-05-15 08:30:12 +0000327}
328
drhc977f7f2002-05-21 11:38:11 +0000329/*
330** Construct a trigger step that implements a DELETE statement and return
331** a pointer to that trigger step. The parser calls this routine when it
332** sees a DELETE statement inside the body of a CREATE TRIGGER.
333*/
334TriggerStep *sqliteTriggerDeleteStep(Token *pTableName, Expr *pWhere){
drhe4697f52002-05-23 02:09:03 +0000335 TriggerStep *pTriggerStep = sqliteMalloc(sizeof(TriggerStep));
336 if( pTriggerStep==0 ) return 0;
danielk1977c3f9bad2002-05-15 08:30:12 +0000337
danielk1977633ed082002-05-17 00:05:58 +0000338 pTriggerStep->op = TK_DELETE;
339 pTriggerStep->target = *pTableName;
340 pTriggerStep->pWhere = pWhere;
341 pTriggerStep->orconf = OE_Default;
drh4b59ab52002-08-24 18:24:51 +0000342 sqlitePersistTriggerStep(pTriggerStep);
danielk1977c3f9bad2002-05-15 08:30:12 +0000343
danielk1977633ed082002-05-17 00:05:58 +0000344 return pTriggerStep;
danielk1977c3f9bad2002-05-15 08:30:12 +0000345}
346
danielk1977633ed082002-05-17 00:05:58 +0000347/*
348** Recursively delete a Trigger structure
349*/
drh1d1f3052002-05-21 13:18:25 +0000350void sqliteDeleteTrigger(Trigger *pTrigger){
drhf0f258b2003-04-21 18:48:45 +0000351 if( pTrigger==0 ) return;
drh4b59ab52002-08-24 18:24:51 +0000352 sqliteDeleteTriggerStep(pTrigger->step_list);
danielk1977633ed082002-05-17 00:05:58 +0000353 sqliteFree(pTrigger->name);
354 sqliteFree(pTrigger->table);
355 sqliteExprDelete(pTrigger->pWhen);
356 sqliteIdListDelete(pTrigger->pColumns);
danielk1977633ed082002-05-17 00:05:58 +0000357 sqliteFree(pTrigger);
danielk1977c3f9bad2002-05-15 08:30:12 +0000358}
359
360/*
danielk1977633ed082002-05-17 00:05:58 +0000361 * This function is called to drop a trigger from the database schema.
362 *
drh79a519c2003-05-17 19:04:03 +0000363 * This may be called directly from the parser and therefore identifies
364 * the trigger by name. The sqliteDropTriggerPtr() routine does the
365 * same job as this routine except it take a spointer to the trigger
366 * instead of the trigger name.
danielk1977633ed082002-05-17 00:05:58 +0000367 *
368 * Note that this function does not delete the trigger entirely. Instead it
369 * removes it from the internal schema and places it in the trigDrop hash
370 * table. This is so that the trigger can be restored into the database schema
371 * if the transaction is rolled back.
danielk1977c3f9bad2002-05-15 08:30:12 +0000372 */
drh79a519c2003-05-17 19:04:03 +0000373void sqliteDropTrigger(Parse *pParse, SrcList *pName){
danielk1977633ed082002-05-17 00:05:58 +0000374 Trigger *pTrigger;
drhd24cc422003-03-27 12:51:24 +0000375 int i;
376 const char *zDb;
377 const char *zName;
378 int nName;
379 sqlite *db = pParse->db;
danielk1977c3f9bad2002-05-15 08:30:12 +0000380
drhd24cc422003-03-27 12:51:24 +0000381 if( sqlite_malloc_failed ) goto drop_trigger_cleanup;
382 assert( pName->nSrc==1 );
383 zDb = pName->a[0].zDatabase;
384 zName = pName->a[0].zName;
385 nName = strlen(zName);
386 for(i=0; i<db->nDb; i++){
drh812d7a22003-03-27 13:50:00 +0000387 int j = (i<2) ? i^1 : i; /* Search TEMP before MAIN */
388 if( zDb && sqliteStrICmp(db->aDb[j].zName, zDb) ) continue;
389 pTrigger = sqliteHashFind(&(db->aDb[j].trigHash), zName, nName+1);
drhd24cc422003-03-27 12:51:24 +0000390 if( pTrigger ) break;
danielk1977c3f9bad2002-05-15 08:30:12 +0000391 }
drhd24cc422003-03-27 12:51:24 +0000392 if( !pTrigger ){
drhda93d232003-03-31 02:12:46 +0000393 sqliteErrorMsg(pParse, "no such trigger: %S", pName, 0);
drhd24cc422003-03-27 12:51:24 +0000394 goto drop_trigger_cleanup;
395 }
drh79a519c2003-05-17 19:04:03 +0000396 sqliteDropTriggerPtr(pParse, pTrigger, 0);
397
398drop_trigger_cleanup:
399 sqliteSrcListDelete(pName);
400}
401
402/*
403** Drop a trigger given a pointer to that trigger. If nested is false,
404** then also generate code to remove the trigger from the SQLITE_MASTER
405** table.
406*/
407void sqliteDropTriggerPtr(Parse *pParse, Trigger *pTrigger, int nested){
408 Table *pTable;
409 Vdbe *v;
410 sqlite *db = pParse->db;
411
drhf0f258b2003-04-21 18:48:45 +0000412 assert( pTrigger->iDb<db->nDb );
drhd24cc422003-03-27 12:51:24 +0000413 if( pTrigger->iDb>=2 ){
drhda93d232003-03-31 02:12:46 +0000414 sqliteErrorMsg(pParse, "triggers may not be removed from "
415 "auxiliary database %s", db->aDb[pTrigger->iDb].zName);
drh79a519c2003-05-17 19:04:03 +0000416 return;
drhd24cc422003-03-27 12:51:24 +0000417 }
drh79a519c2003-05-17 19:04:03 +0000418 pTable = sqliteFindTable(db, pTrigger->table,db->aDb[pTrigger->iTabDb].zName);
drhed6c8672003-01-12 18:02:16 +0000419 assert(pTable);
drhf0f258b2003-04-21 18:48:45 +0000420 assert( pTable->iDb==pTrigger->iDb || pTrigger->iDb==1 );
drhe5f9c642003-01-13 23:27:31 +0000421#ifndef SQLITE_OMIT_AUTHORIZATION
422 {
423 int code = SQLITE_DROP_TRIGGER;
drhe22a3342003-04-22 20:30:37 +0000424 const char *zDb = db->aDb[pTrigger->iDb].zName;
425 const char *zTab = SCHEMA_TABLE(pTrigger->iDb);
drhf0f258b2003-04-21 18:48:45 +0000426 if( pTrigger->iDb ) code = SQLITE_DROP_TEMP_TRIGGER;
drhe22a3342003-04-22 20:30:37 +0000427 if( sqliteAuthCheck(pParse, code, pTrigger->name, pTable->zName, zDb) ||
428 sqliteAuthCheck(pParse, SQLITE_DELETE, zTab, 0, zDb) ){
drh79a519c2003-05-17 19:04:03 +0000429 return;
drhe5f9c642003-01-13 23:27:31 +0000430 }
drhed6c8672003-01-12 18:02:16 +0000431 }
drhe5f9c642003-01-13 23:27:31 +0000432#endif
danielk1977c3f9bad2002-05-15 08:30:12 +0000433
drhf0f258b2003-04-21 18:48:45 +0000434 /* Generate code to destroy the database record of the trigger.
435 */
436 if( pTable!=0 && !nested && (v = sqliteGetVdbe(pParse))!=0 ){
437 int base;
438 static VdbeOp dropTrigger[] = {
439 { OP_Rewind, 0, ADDR(8), 0},
440 { OP_String, 0, 0, 0}, /* 1 */
441 { OP_MemStore, 1, 1, 0},
442 { OP_MemLoad, 1, 0, 0}, /* 3 */
443 { OP_Column, 0, 1, 0},
444 { OP_Ne, 0, ADDR(7), 0},
445 { OP_Delete, 0, 0, 0},
446 { OP_Next, 0, ADDR(3), 0}, /* 7 */
447 };
448
449 sqliteBeginWriteOperation(pParse, 0, 0);
450 sqliteOpenMasterTable(v, pTrigger->iDb);
451 base = sqliteVdbeAddOpList(v, ArraySize(dropTrigger), dropTrigger);
drh79a519c2003-05-17 19:04:03 +0000452 sqliteVdbeChangeP3(v, base+1, pTrigger->name, 0);
drhf0f258b2003-04-21 18:48:45 +0000453 if( pTrigger->iDb==0 ){
454 sqliteChangeCookie(db, v);
455 }
456 sqliteVdbeAddOp(v, OP_Close, 0, 0);
457 sqliteEndWriteOperation(pParse);
458 }
459
danielk1977c3f9bad2002-05-15 08:30:12 +0000460 /*
drhe0bc4042002-06-25 01:09:11 +0000461 * If this is not an "explain", then delete the trigger structure.
danielk1977c3f9bad2002-05-15 08:30:12 +0000462 */
danielk1977633ed082002-05-17 00:05:58 +0000463 if( !pParse->explain ){
drh79a519c2003-05-17 19:04:03 +0000464 const char *zName = pTrigger->name;
465 int nName = strlen(zName);
danielk1977633ed082002-05-17 00:05:58 +0000466 if( pTable->pTrigger == pTrigger ){
467 pTable->pTrigger = pTrigger->pNext;
danielk1977f29ce552002-05-19 23:43:12 +0000468 }else{
danielk1977633ed082002-05-17 00:05:58 +0000469 Trigger *cc = pTable->pTrigger;
470 while( cc ){
471 if( cc->pNext == pTrigger ){
drh9adf9ac2002-05-15 11:44:13 +0000472 cc->pNext = cc->pNext->pNext;
473 break;
474 }
475 cc = cc->pNext;
danielk1977c3f9bad2002-05-15 08:30:12 +0000476 }
477 assert(cc);
478 }
drhd24cc422003-03-27 12:51:24 +0000479 sqliteHashInsert(&(db->aDb[pTrigger->iDb].trigHash), zName, nName+1, 0);
drhe0bc4042002-06-25 01:09:11 +0000480 sqliteDeleteTrigger(pTrigger);
danielk1977c3f9bad2002-05-15 08:30:12 +0000481 }
danielk1977c3f9bad2002-05-15 08:30:12 +0000482}
483
drhc977f7f2002-05-21 11:38:11 +0000484/*
485** pEList is the SET clause of an UPDATE statement. Each entry
486** in pEList is of the format <id>=<expr>. If any of the entries
487** in pEList have an <id> which matches an identifier in pIdList,
488** then return TRUE. If pIdList==NULL, then it is considered a
489** wildcard that matches anything. Likewise if pEList==NULL then
490** it matches anything so always return true. Return false only
491** if there is no match.
492*/
493static int checkColumnOverLap(IdList *pIdList, ExprList *pEList){
drhad2d8302002-05-24 20:31:36 +0000494 int e;
495 if( !pIdList || !pEList ) return 1;
496 for(e=0; e<pEList->nExpr; e++){
497 if( sqliteIdListIndex(pIdList, pEList->a[e].zName)>=0 ) return 1;
danielk1977f29ce552002-05-19 23:43:12 +0000498 }
danielk1977c3f9bad2002-05-15 08:30:12 +0000499 return 0;
500}
501
502/* A global variable that is TRUE if we should always set up temp tables for
503 * for triggers, even if there are no triggers to code. This is used to test
504 * how much overhead the triggers algorithm is causing.
505 *
506 * This flag can be set or cleared using the "trigger_overhead_test" pragma.
507 * The pragma is not documented since it is not really part of the interface
508 * to SQLite, just the test procedure.
509*/
510int always_code_trigger_setup = 0;
511
512/*
513 * Returns true if a trigger matching op, tr_tm and foreach that is NOT already
514 * on the Parse objects trigger-stack (to prevent recursive trigger firing) is
515 * found in the list specified as pTrigger.
516 */
517int sqliteTriggersExist(
drhc977f7f2002-05-21 11:38:11 +0000518 Parse *pParse, /* Used to check for recursive triggers */
519 Trigger *pTrigger, /* A list of triggers associated with a table */
danielk1977633ed082002-05-17 00:05:58 +0000520 int op, /* one of TK_DELETE, TK_INSERT, TK_UPDATE */
521 int tr_tm, /* one of TK_BEFORE, TK_AFTER */
522 int foreach, /* one of TK_ROW or TK_STATEMENT */
drhc977f7f2002-05-21 11:38:11 +0000523 ExprList *pChanges /* Columns that change in an UPDATE statement */
524){
danielk1977633ed082002-05-17 00:05:58 +0000525 Trigger * pTriggerCursor;
danielk1977c3f9bad2002-05-15 08:30:12 +0000526
danielk1977633ed082002-05-17 00:05:58 +0000527 if( always_code_trigger_setup ){
528 return 1;
529 }
danielk1977c3f9bad2002-05-15 08:30:12 +0000530
danielk1977633ed082002-05-17 00:05:58 +0000531 pTriggerCursor = pTrigger;
532 while( pTriggerCursor ){
533 if( pTriggerCursor->op == op &&
534 pTriggerCursor->tr_tm == tr_tm &&
535 pTriggerCursor->foreach == foreach &&
536 checkColumnOverLap(pTriggerCursor->pColumns, pChanges) ){
danielk1977c3f9bad2002-05-15 08:30:12 +0000537 TriggerStack * ss;
538 ss = pParse->trigStack;
danielk1977f29ce552002-05-19 23:43:12 +0000539 while( ss && ss->pTrigger != pTrigger ){
540 ss = ss->pNext;
541 }
542 if( !ss )return 1;
danielk1977c3f9bad2002-05-15 08:30:12 +0000543 }
danielk1977633ed082002-05-17 00:05:58 +0000544 pTriggerCursor = pTriggerCursor->pNext;
danielk1977c3f9bad2002-05-15 08:30:12 +0000545 }
546
547 return 0;
548}
549
drhc977f7f2002-05-21 11:38:11 +0000550/*
551** Generate VDBE code for zero or more statements inside the body of a
552** trigger.
553*/
danielk1977c3f9bad2002-05-15 08:30:12 +0000554static int codeTriggerProgram(
drhc977f7f2002-05-21 11:38:11 +0000555 Parse *pParse, /* The parser context */
556 TriggerStep *pStepList, /* List of statements inside the trigger body */
557 int orconfin /* Conflict algorithm. (OE_Abort, etc) */
danielk1977633ed082002-05-17 00:05:58 +0000558){
559 TriggerStep * pTriggerStep = pStepList;
560 int orconf;
danielk1977c3f9bad2002-05-15 08:30:12 +0000561
danielk1977633ed082002-05-17 00:05:58 +0000562 while( pTriggerStep ){
563 int saveNTab = pParse->nTab;
drha69d9162003-04-17 22:57:53 +0000564 int saveUseDb = pParse->useDb;
danielk1977633ed082002-05-17 00:05:58 +0000565 orconf = (orconfin == OE_Default)?pTriggerStep->orconf:orconfin;
566 pParse->trigStack->orconf = orconf;
drha69d9162003-04-17 22:57:53 +0000567 pParse->useDb = pTriggerStep->pTrig->iDb;
drhf0f258b2003-04-21 18:48:45 +0000568 if( pParse->useDb==1 ) pParse->useDb = -1;
danielk1977633ed082002-05-17 00:05:58 +0000569 switch( pTriggerStep->op ){
570 case TK_SELECT: {
danielk19776f349032002-06-11 02:25:40 +0000571 Select * ss = sqliteSelectDup(pTriggerStep->pSelect);
572 assert(ss);
573 assert(ss->pSrc);
574 sqliteSelect(pParse, ss, SRT_Discard, 0, 0, 0, 0);
575 sqliteSelectDelete(ss);
danielk1977633ed082002-05-17 00:05:58 +0000576 break;
577 }
578 case TK_UPDATE: {
drh113088e2003-03-20 01:16:58 +0000579 SrcList *pSrc;
580 pSrc = sqliteSrcListAppend(0, &pTriggerStep->target, 0);
drhbd5a4512002-05-23 22:07:02 +0000581 sqliteVdbeAddOp(pParse->pVdbe, OP_ListPush, 0, 0);
drh113088e2003-03-20 01:16:58 +0000582 sqliteUpdate(pParse, pSrc,
danielk19776f349032002-06-11 02:25:40 +0000583 sqliteExprListDup(pTriggerStep->pExprList),
584 sqliteExprDup(pTriggerStep->pWhere), orconf);
drhbd5a4512002-05-23 22:07:02 +0000585 sqliteVdbeAddOp(pParse->pVdbe, OP_ListPop, 0, 0);
danielk1977633ed082002-05-17 00:05:58 +0000586 break;
587 }
588 case TK_INSERT: {
drh113088e2003-03-20 01:16:58 +0000589 SrcList *pSrc;
590 pSrc = sqliteSrcListAppend(0, &pTriggerStep->target, 0);
591 sqliteInsert(pParse, pSrc,
592 sqliteExprListDup(pTriggerStep->pExprList),
593 sqliteSelectDup(pTriggerStep->pSelect),
594 sqliteIdListDup(pTriggerStep->pIdList), orconf);
danielk1977633ed082002-05-17 00:05:58 +0000595 break;
596 }
597 case TK_DELETE: {
drh113088e2003-03-20 01:16:58 +0000598 SrcList *pSrc;
drhbd5a4512002-05-23 22:07:02 +0000599 sqliteVdbeAddOp(pParse->pVdbe, OP_ListPush, 0, 0);
drh113088e2003-03-20 01:16:58 +0000600 pSrc = sqliteSrcListAppend(0, &pTriggerStep->target, 0);
601 sqliteDeleteFrom(pParse, pSrc, sqliteExprDup(pTriggerStep->pWhere));
drhbd5a4512002-05-23 22:07:02 +0000602 sqliteVdbeAddOp(pParse->pVdbe, OP_ListPop, 0, 0);
danielk1977633ed082002-05-17 00:05:58 +0000603 break;
604 }
605 default:
606 assert(0);
607 }
608 pParse->nTab = saveNTab;
drha69d9162003-04-17 22:57:53 +0000609 pParse->useDb = saveUseDb;
danielk1977633ed082002-05-17 00:05:58 +0000610 pTriggerStep = pTriggerStep->pNext;
611 }
danielk1977c3f9bad2002-05-15 08:30:12 +0000612
danielk1977633ed082002-05-17 00:05:58 +0000613 return 0;
danielk1977c3f9bad2002-05-15 08:30:12 +0000614}
615
danielk1977633ed082002-05-17 00:05:58 +0000616/*
617** This is called to code FOR EACH ROW triggers.
618**
619** When the code that this function generates is executed, the following
620** must be true:
drhc977f7f2002-05-21 11:38:11 +0000621**
622** 1. No cursors may be open in the main database. (But newIdx and oldIdx
623** can be indices of cursors in temporary tables. See below.)
624**
danielk1977633ed082002-05-17 00:05:58 +0000625** 2. If the triggers being coded are ON INSERT or ON UPDATE triggers, then
626** a temporary vdbe cursor (index newIdx) must be open and pointing at
627** a row containing values to be substituted for new.* expressions in the
628** trigger program(s).
drhc977f7f2002-05-21 11:38:11 +0000629**
danielk1977633ed082002-05-17 00:05:58 +0000630** 3. If the triggers being coded are ON DELETE or ON UPDATE triggers, then
631** a temporary vdbe cursor (index oldIdx) must be open and pointing at
632** a row containing values to be substituted for old.* expressions in the
633** trigger program(s).
634**
635*/
danielk1977c3f9bad2002-05-15 08:30:12 +0000636int sqliteCodeRowTrigger(
danielk1977633ed082002-05-17 00:05:58 +0000637 Parse *pParse, /* Parse context */
638 int op, /* One of TK_UPDATE, TK_INSERT, TK_DELETE */
639 ExprList *pChanges, /* Changes list for any UPDATE OF triggers */
640 int tr_tm, /* One of TK_BEFORE, TK_AFTER */
641 Table *pTab, /* The table to code triggers from */
642 int newIdx, /* The indice of the "new" row to access */
643 int oldIdx, /* The indice of the "old" row to access */
danielk19776f349032002-06-11 02:25:40 +0000644 int orconf, /* ON CONFLICT policy */
645 int ignoreJump /* Instruction to jump to for RAISE(IGNORE) */
drhc977f7f2002-05-21 11:38:11 +0000646){
danielk1977c3f9bad2002-05-15 08:30:12 +0000647 Trigger * pTrigger;
648 TriggerStack * pTriggerStack;
649
danielk1977c3f9bad2002-05-15 08:30:12 +0000650 assert(op == TK_UPDATE || op == TK_INSERT || op == TK_DELETE);
drh5cf590c2003-04-24 01:45:04 +0000651 assert(tr_tm == TK_BEFORE || tr_tm == TK_AFTER );
danielk1977c3f9bad2002-05-15 08:30:12 +0000652
danielk1977633ed082002-05-17 00:05:58 +0000653 assert(newIdx != -1 || oldIdx != -1);
danielk1977c3f9bad2002-05-15 08:30:12 +0000654
danielk1977633ed082002-05-17 00:05:58 +0000655 pTrigger = pTab->pTrigger;
danielk1977f29ce552002-05-19 23:43:12 +0000656 while( pTrigger ){
danielk1977c3f9bad2002-05-15 08:30:12 +0000657 int fire_this = 0;
658
659 /* determine whether we should code this trigger */
danielk1977f29ce552002-05-19 23:43:12 +0000660 if( pTrigger->op == op && pTrigger->tr_tm == tr_tm &&
661 pTrigger->foreach == TK_ROW ){
danielk1977c3f9bad2002-05-15 08:30:12 +0000662 fire_this = 1;
663 pTriggerStack = pParse->trigStack;
danielk1977f29ce552002-05-19 23:43:12 +0000664 while( pTriggerStack ){
665 if( pTriggerStack->pTrigger == pTrigger ){
666 fire_this = 0;
667 }
drh9adf9ac2002-05-15 11:44:13 +0000668 pTriggerStack = pTriggerStack->pNext;
danielk1977c3f9bad2002-05-15 08:30:12 +0000669 }
danielk1977f29ce552002-05-19 23:43:12 +0000670 if( op == TK_UPDATE && pTrigger->pColumns &&
671 !checkColumnOverLap(pTrigger->pColumns, pChanges) ){
drh9adf9ac2002-05-15 11:44:13 +0000672 fire_this = 0;
danielk1977f29ce552002-05-19 23:43:12 +0000673 }
danielk1977c3f9bad2002-05-15 08:30:12 +0000674 }
675
drhe4697f52002-05-23 02:09:03 +0000676 if( fire_this && (pTriggerStack = sqliteMalloc(sizeof(TriggerStack)))!=0 ){
danielk1977c3f9bad2002-05-15 08:30:12 +0000677 int endTrigger;
drhad3cab52002-05-24 02:04:32 +0000678 SrcList dummyTablist;
danielk1977c3f9bad2002-05-15 08:30:12 +0000679 Expr * whenExpr;
drh85e20962003-04-25 17:52:11 +0000680 AuthContext sContext;
danielk1977c3f9bad2002-05-15 08:30:12 +0000681
drhad3cab52002-05-24 02:04:32 +0000682 dummyTablist.nSrc = 0;
danielk1977c3f9bad2002-05-15 08:30:12 +0000683
684 /* Push an entry on to the trigger stack */
danielk1977c3f9bad2002-05-15 08:30:12 +0000685 pTriggerStack->pTrigger = pTrigger;
danielk1977633ed082002-05-17 00:05:58 +0000686 pTriggerStack->newIdx = newIdx;
687 pTriggerStack->oldIdx = oldIdx;
688 pTriggerStack->pTab = pTab;
danielk1977c3f9bad2002-05-15 08:30:12 +0000689 pTriggerStack->pNext = pParse->trigStack;
danielk19776f349032002-06-11 02:25:40 +0000690 pTriggerStack->ignoreJump = ignoreJump;
danielk1977c3f9bad2002-05-15 08:30:12 +0000691 pParse->trigStack = pTriggerStack;
drh85e20962003-04-25 17:52:11 +0000692 sqliteAuthContextPush(pParse, &sContext, pTrigger->name);
danielk1977c3f9bad2002-05-15 08:30:12 +0000693
694 /* code the WHEN clause */
695 endTrigger = sqliteVdbeMakeLabel(pParse->pVdbe);
696 whenExpr = sqliteExprDup(pTrigger->pWhen);
drh6a3ea0e2003-05-02 14:32:12 +0000697 if( sqliteExprResolveIds(pParse, &dummyTablist, 0, whenExpr) ){
drh9adf9ac2002-05-15 11:44:13 +0000698 pParse->trigStack = pParse->trigStack->pNext;
699 sqliteFree(pTriggerStack);
700 sqliteExprDelete(whenExpr);
701 return 1;
danielk1977c3f9bad2002-05-15 08:30:12 +0000702 }
drhf5905aa2002-05-26 20:54:33 +0000703 sqliteExprIfFalse(pParse, whenExpr, endTrigger, 1);
danielk1977c3f9bad2002-05-15 08:30:12 +0000704 sqliteExprDelete(whenExpr);
705
danielk1977633ed082002-05-17 00:05:58 +0000706 codeTriggerProgram(pParse, pTrigger->step_list, orconf);
danielk1977c3f9bad2002-05-15 08:30:12 +0000707
708 /* Pop the entry off the trigger stack */
709 pParse->trigStack = pParse->trigStack->pNext;
drh85e20962003-04-25 17:52:11 +0000710 sqliteAuthContextPop(&sContext);
danielk1977c3f9bad2002-05-15 08:30:12 +0000711 sqliteFree(pTriggerStack);
712
713 sqliteVdbeResolveLabel(pParse->pVdbe, endTrigger);
714 }
715 pTrigger = pTrigger->pNext;
716 }
717
718 return 0;
719}