trigger.c.svn-base
上传用户:sunhongbo
上传日期:2022-01-25
资源大小:3010k
文件大小:28k
源码类别:

数据库系统

开发平台:

C/C++

  1. /*
  2. **
  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. *
  12. */
  13. #include "sqliteInt.h"
  14. #ifndef SQLITE_OMIT_TRIGGER
  15. /*
  16. ** Delete a linked list of TriggerStep structures.
  17. */
  18. void sqlite3DeleteTriggerStep(TriggerStep *pTriggerStep){
  19.   while( pTriggerStep ){
  20.     TriggerStep * pTmp = pTriggerStep;
  21.     pTriggerStep = pTriggerStep->pNext;
  22.     if( pTmp->target.dyn ) sqlite3_free((char*)pTmp->target.z);
  23.     sqlite3ExprDelete(pTmp->pWhere);
  24.     sqlite3ExprListDelete(pTmp->pExprList);
  25.     sqlite3SelectDelete(pTmp->pSelect);
  26.     sqlite3IdListDelete(pTmp->pIdList);
  27.     sqlite3_free(pTmp);
  28.   }
  29. }
  30. /*
  31. ** This is called by the parser when it sees a CREATE TRIGGER statement
  32. ** up to the point of the BEGIN before the trigger actions.  A Trigger
  33. ** structure is generated based on the information available and stored
  34. ** in pParse->pNewTrigger.  After the trigger actions have been parsed, the
  35. ** sqlite3FinishTrigger() function is called to complete the trigger
  36. ** construction process.
  37. */
  38. void sqlite3BeginTrigger(
  39.   Parse *pParse,      /* The parse context of the CREATE TRIGGER statement */
  40.   Token *pName1,      /* The name of the trigger */
  41.   Token *pName2,      /* The name of the trigger */
  42.   int tr_tm,          /* One of TK_BEFORE, TK_AFTER, TK_INSTEAD */
  43.   int op,             /* One of TK_INSERT, TK_UPDATE, TK_DELETE */
  44.   IdList *pColumns,   /* column list if this is an UPDATE OF trigger */
  45.   SrcList *pTableName,/* The name of the table/view the trigger applies to */
  46.   Expr *pWhen,        /* WHEN clause */
  47.   int isTemp,         /* True if the TEMPORARY keyword is present */
  48.   int noErr           /* Suppress errors if the trigger already exists */
  49. ){
  50.   Trigger *pTrigger = 0;
  51.   Table *pTab;
  52.   char *zName = 0;        /* Name of the trigger */
  53.   sqlite3 *db = pParse->db;
  54.   int iDb;                /* The database to store the trigger in */
  55.   Token *pName;           /* The unqualified db name */
  56.   DbFixer sFix;
  57.   int iTabDb;
  58.   assert( pName1!=0 );   /* pName1->z might be NULL, but not pName1 itself */
  59.   assert( pName2!=0 );
  60.   if( isTemp ){
  61.     /* If TEMP was specified, then the trigger name may not be qualified. */
  62.     if( pName2->n>0 ){
  63.       sqlite3ErrorMsg(pParse, "temporary trigger may not have qualified name");
  64.       goto trigger_cleanup;
  65.     }
  66.     iDb = 1;
  67.     pName = pName1;
  68.   }else{
  69.     /* Figure out the db that the the trigger will be created in */
  70.     iDb = sqlite3TwoPartName(pParse, pName1, pName2, &pName);
  71.     if( iDb<0 ){
  72.       goto trigger_cleanup;
  73.     }
  74.   }
  75.   /* If the trigger name was unqualified, and the table is a temp table,
  76.   ** then set iDb to 1 to create the trigger in the temporary database.
  77.   ** If sqlite3SrcListLookup() returns 0, indicating the table does not
  78.   ** exist, the error is caught by the block below.
  79.   */
  80.   if( !pTableName || db->mallocFailed ){
  81.     goto trigger_cleanup;
  82.   }
  83.   pTab = sqlite3SrcListLookup(pParse, pTableName);
  84.   if( pName2->n==0 && pTab && pTab->pSchema==db->aDb[1].pSchema ){
  85.     iDb = 1;
  86.   }
  87.   /* Ensure the table name matches database name and that the table exists */
  88.   if( db->mallocFailed ) goto trigger_cleanup;
  89.   assert( pTableName->nSrc==1 );
  90.   if( sqlite3FixInit(&sFix, pParse, iDb, "trigger", pName) && 
  91.       sqlite3FixSrcList(&sFix, pTableName) ){
  92.     goto trigger_cleanup;
  93.   }
  94.   pTab = sqlite3SrcListLookup(pParse, pTableName);
  95.   if( !pTab ){
  96.     /* The table does not exist. */
  97.     goto trigger_cleanup;
  98.   }
  99.   if( IsVirtual(pTab) ){
  100.     sqlite3ErrorMsg(pParse, "cannot create triggers on virtual tables");
  101.     goto trigger_cleanup;
  102.   }
  103.   /* Check that the trigger name is not reserved and that no trigger of the
  104.   ** specified name exists */
  105.   zName = sqlite3NameFromToken(db, pName);
  106.   if( !zName || SQLITE_OK!=sqlite3CheckObjectName(pParse, zName) ){
  107.     goto trigger_cleanup;
  108.   }
  109.   if( sqlite3HashFind(&(db->aDb[iDb].pSchema->trigHash), zName,strlen(zName)) ){
  110.     if( !noErr ){
  111.       sqlite3ErrorMsg(pParse, "trigger %T already exists", pName);
  112.     }
  113.     goto trigger_cleanup;
  114.   }
  115.   /* Do not create a trigger on a system table */
  116.   if( sqlite3StrNICmp(pTab->zName, "sqlite_", 7)==0 ){
  117.     sqlite3ErrorMsg(pParse, "cannot create trigger on system table");
  118.     pParse->nErr++;
  119.     goto trigger_cleanup;
  120.   }
  121.   /* INSTEAD of triggers are only for views and views only support INSTEAD
  122.   ** of triggers.
  123.   */
  124.   if( pTab->pSelect && tr_tm!=TK_INSTEAD ){
  125.     sqlite3ErrorMsg(pParse, "cannot create %s trigger on view: %S", 
  126.         (tr_tm == TK_BEFORE)?"BEFORE":"AFTER", pTableName, 0);
  127.     goto trigger_cleanup;
  128.   }
  129.   if( !pTab->pSelect && tr_tm==TK_INSTEAD ){
  130.     sqlite3ErrorMsg(pParse, "cannot create INSTEAD OF"
  131.         " trigger on table: %S", pTableName, 0);
  132.     goto trigger_cleanup;
  133.   }
  134.   iTabDb = sqlite3SchemaToIndex(db, pTab->pSchema);
  135. #ifndef SQLITE_OMIT_AUTHORIZATION
  136.   {
  137.     int code = SQLITE_CREATE_TRIGGER;
  138.     const char *zDb = db->aDb[iTabDb].zName;
  139.     const char *zDbTrig = isTemp ? db->aDb[1].zName : zDb;
  140.     if( iTabDb==1 || isTemp ) code = SQLITE_CREATE_TEMP_TRIGGER;
  141.     if( sqlite3AuthCheck(pParse, code, zName, pTab->zName, zDbTrig) ){
  142.       goto trigger_cleanup;
  143.     }
  144.     if( sqlite3AuthCheck(pParse, SQLITE_INSERT, SCHEMA_TABLE(iTabDb),0,zDb)){
  145.       goto trigger_cleanup;
  146.     }
  147.   }
  148. #endif
  149.   /* INSTEAD OF triggers can only appear on views and BEFORE triggers
  150.   ** cannot appear on views.  So we might as well translate every
  151.   ** INSTEAD OF trigger into a BEFORE trigger.  It simplifies code
  152.   ** elsewhere.
  153.   */
  154.   if (tr_tm == TK_INSTEAD){
  155.     tr_tm = TK_BEFORE;
  156.   }
  157.   /* Build the Trigger object */
  158.   pTrigger = (Trigger*)sqlite3DbMallocZero(db, sizeof(Trigger));
  159.   if( pTrigger==0 ) goto trigger_cleanup;
  160.   pTrigger->name = zName;
  161.   zName = 0;
  162.   pTrigger->table = sqlite3DbStrDup(db, pTableName->a[0].zName);
  163.   pTrigger->pSchema = db->aDb[iDb].pSchema;
  164.   pTrigger->pTabSchema = pTab->pSchema;
  165.   pTrigger->op = op;
  166.   pTrigger->tr_tm = tr_tm==TK_BEFORE ? TRIGGER_BEFORE : TRIGGER_AFTER;
  167.   pTrigger->pWhen = sqlite3ExprDup(db, pWhen);
  168.   pTrigger->pColumns = sqlite3IdListDup(db, pColumns);
  169.   sqlite3TokenCopy(db, &pTrigger->nameToken,pName);
  170.   assert( pParse->pNewTrigger==0 );
  171.   pParse->pNewTrigger = pTrigger;
  172. trigger_cleanup:
  173.   sqlite3_free(zName);
  174.   sqlite3SrcListDelete(pTableName);
  175.   sqlite3IdListDelete(pColumns);
  176.   sqlite3ExprDelete(pWhen);
  177.   if( !pParse->pNewTrigger ){
  178.     sqlite3DeleteTrigger(pTrigger);
  179.   }else{
  180.     assert( pParse->pNewTrigger==pTrigger );
  181.   }
  182. }
  183. /*
  184. ** This routine is called after all of the trigger actions have been parsed
  185. ** in order to complete the process of building the trigger.
  186. */
  187. void sqlite3FinishTrigger(
  188.   Parse *pParse,          /* Parser context */
  189.   TriggerStep *pStepList, /* The triggered program */
  190.   Token *pAll             /* Token that describes the complete CREATE TRIGGER */
  191. ){
  192.   Trigger *pTrig = 0;     /* The trigger whose construction is finishing up */
  193.   sqlite3 *db = pParse->db;  /* The database */
  194.   DbFixer sFix;
  195.   int iDb;                   /* Database containing the trigger */
  196.   pTrig = pParse->pNewTrigger;
  197.   pParse->pNewTrigger = 0;
  198.   if( pParse->nErr || !pTrig ) goto triggerfinish_cleanup;
  199.   iDb = sqlite3SchemaToIndex(pParse->db, pTrig->pSchema);
  200.   pTrig->step_list = pStepList;
  201.   while( pStepList ){
  202.     pStepList->pTrig = pTrig;
  203.     pStepList = pStepList->pNext;
  204.   }
  205.   if( sqlite3FixInit(&sFix, pParse, iDb, "trigger", &pTrig->nameToken) 
  206.           && sqlite3FixTriggerStep(&sFix, pTrig->step_list) ){
  207.     goto triggerfinish_cleanup;
  208.   }
  209.   /* if we are not initializing, and this trigger is not on a TEMP table, 
  210.   ** build the sqlite_master entry
  211.   */
  212.   if( !db->init.busy ){
  213.     Vdbe *v;
  214.     char *z;
  215.     /* Make an entry in the sqlite_master table */
  216.     v = sqlite3GetVdbe(pParse);
  217.     if( v==0 ) goto triggerfinish_cleanup;
  218.     sqlite3BeginWriteOperation(pParse, 0, iDb);
  219.     z = sqlite3DbStrNDup(db, (char*)pAll->z, pAll->n);
  220.     sqlite3NestedParse(pParse,
  221.        "INSERT INTO %Q.%s VALUES('trigger',%Q,%Q,0,'CREATE TRIGGER %q')",
  222.        db->aDb[iDb].zName, SCHEMA_TABLE(iDb), pTrig->name,
  223.        pTrig->table, z);
  224.     sqlite3_free(z);
  225.     sqlite3ChangeCookie(pParse, iDb);
  226.     sqlite3VdbeAddOp4(v, OP_ParseSchema, iDb, 0, 0, sqlite3MPrintf(
  227.         db, "type='trigger' AND name='%q'", pTrig->name), P4_DYNAMIC
  228.     );
  229.   }
  230.   if( db->init.busy ){
  231.     int n;
  232.     Table *pTab;
  233.     Trigger *pDel;
  234.     pDel = sqlite3HashInsert(&db->aDb[iDb].pSchema->trigHash, 
  235.                      pTrig->name, strlen(pTrig->name), pTrig);
  236.     if( pDel ){
  237.       assert( pDel==pTrig );
  238.       db->mallocFailed = 1;
  239.       goto triggerfinish_cleanup;
  240.     }
  241.     n = strlen(pTrig->table) + 1;
  242.     pTab = sqlite3HashFind(&pTrig->pTabSchema->tblHash, pTrig->table, n);
  243.     assert( pTab!=0 );
  244.     pTrig->pNext = pTab->pTrigger;
  245.     pTab->pTrigger = pTrig;
  246.     pTrig = 0;
  247.   }
  248. triggerfinish_cleanup:
  249.   sqlite3DeleteTrigger(pTrig);
  250.   assert( !pParse->pNewTrigger );
  251.   sqlite3DeleteTriggerStep(pStepList);
  252. }
  253. /*
  254. ** Make a copy of all components of the given trigger step.  This has
  255. ** the effect of copying all Expr.token.z values into memory obtained
  256. ** from sqlite3_malloc().  As initially created, the Expr.token.z values
  257. ** all point to the input string that was fed to the parser.  But that
  258. ** string is ephemeral - it will go away as soon as the sqlite3_exec()
  259. ** call that started the parser exits.  This routine makes a persistent
  260. ** copy of all the Expr.token.z strings so that the TriggerStep structure
  261. ** will be valid even after the sqlite3_exec() call returns.
  262. */
  263. static void sqlitePersistTriggerStep(sqlite3 *db, TriggerStep *p){
  264.   if( p->target.z ){
  265.     p->target.z = (u8*)sqlite3DbStrNDup(db, (char*)p->target.z, p->target.n);
  266.     p->target.dyn = 1;
  267.   }
  268.   if( p->pSelect ){
  269.     Select *pNew = sqlite3SelectDup(db, p->pSelect);
  270.     sqlite3SelectDelete(p->pSelect);
  271.     p->pSelect = pNew;
  272.   }
  273.   if( p->pWhere ){
  274.     Expr *pNew = sqlite3ExprDup(db, p->pWhere);
  275.     sqlite3ExprDelete(p->pWhere);
  276.     p->pWhere = pNew;
  277.   }
  278.   if( p->pExprList ){
  279.     ExprList *pNew = sqlite3ExprListDup(db, p->pExprList);
  280.     sqlite3ExprListDelete(p->pExprList);
  281.     p->pExprList = pNew;
  282.   }
  283.   if( p->pIdList ){
  284.     IdList *pNew = sqlite3IdListDup(db, p->pIdList);
  285.     sqlite3IdListDelete(p->pIdList);
  286.     p->pIdList = pNew;
  287.   }
  288. }
  289. /*
  290. ** Turn a SELECT statement (that the pSelect parameter points to) into
  291. ** a trigger step.  Return a pointer to a TriggerStep structure.
  292. **
  293. ** The parser calls this routine when it finds a SELECT statement in
  294. ** body of a TRIGGER.  
  295. */
  296. TriggerStep *sqlite3TriggerSelectStep(sqlite3 *db, Select *pSelect){
  297.   TriggerStep *pTriggerStep = sqlite3DbMallocZero(db, sizeof(TriggerStep));
  298.   if( pTriggerStep==0 ) {
  299.     sqlite3SelectDelete(pSelect);
  300.     return 0;
  301.   }
  302.   pTriggerStep->op = TK_SELECT;
  303.   pTriggerStep->pSelect = pSelect;
  304.   pTriggerStep->orconf = OE_Default;
  305.   sqlitePersistTriggerStep(db, pTriggerStep);
  306.   return pTriggerStep;
  307. }
  308. /*
  309. ** Build a trigger step out of an INSERT statement.  Return a pointer
  310. ** to the new trigger step.
  311. **
  312. ** The parser calls this routine when it sees an INSERT inside the
  313. ** body of a trigger.
  314. */
  315. TriggerStep *sqlite3TriggerInsertStep(
  316.   sqlite3 *db,        /* The database connection */
  317.   Token *pTableName,  /* Name of the table into which we insert */
  318.   IdList *pColumn,    /* List of columns in pTableName to insert into */
  319.   ExprList *pEList,   /* The VALUE clause: a list of values to be inserted */
  320.   Select *pSelect,    /* A SELECT statement that supplies values */
  321.   int orconf          /* The conflict algorithm (OE_Abort, OE_Replace, etc.) */
  322. ){
  323.   TriggerStep *pTriggerStep;
  324.   assert(pEList == 0 || pSelect == 0);
  325.   assert(pEList != 0 || pSelect != 0 || db->mallocFailed);
  326.   pTriggerStep = sqlite3DbMallocZero(db, sizeof(TriggerStep));
  327.   if( pTriggerStep ){
  328.     pTriggerStep->op = TK_INSERT;
  329.     pTriggerStep->pSelect = pSelect;
  330.     pTriggerStep->target  = *pTableName;
  331.     pTriggerStep->pIdList = pColumn;
  332.     pTriggerStep->pExprList = pEList;
  333.     pTriggerStep->orconf = orconf;
  334.     sqlitePersistTriggerStep(db, pTriggerStep);
  335.   }else{
  336.     sqlite3IdListDelete(pColumn);
  337.     sqlite3ExprListDelete(pEList);
  338.     sqlite3SelectDelete(pSelect);
  339.   }
  340.   return pTriggerStep;
  341. }
  342. /*
  343. ** Construct a trigger step that implements an UPDATE statement and return
  344. ** a pointer to that trigger step.  The parser calls this routine when it
  345. ** sees an UPDATE statement inside the body of a CREATE TRIGGER.
  346. */
  347. TriggerStep *sqlite3TriggerUpdateStep(
  348.   sqlite3 *db,         /* The database connection */
  349.   Token *pTableName,   /* Name of the table to be updated */
  350.   ExprList *pEList,    /* The SET clause: list of column and new values */
  351.   Expr *pWhere,        /* The WHERE clause */
  352.   int orconf           /* The conflict algorithm. (OE_Abort, OE_Ignore, etc) */
  353. ){
  354.   TriggerStep *pTriggerStep = sqlite3DbMallocZero(db, sizeof(TriggerStep));
  355.   if( pTriggerStep==0 ){
  356.      sqlite3ExprListDelete(pEList);
  357.      sqlite3ExprDelete(pWhere);
  358.      return 0;
  359.   }
  360.   pTriggerStep->op = TK_UPDATE;
  361.   pTriggerStep->target  = *pTableName;
  362.   pTriggerStep->pExprList = pEList;
  363.   pTriggerStep->pWhere = pWhere;
  364.   pTriggerStep->orconf = orconf;
  365.   sqlitePersistTriggerStep(db, pTriggerStep);
  366.   return pTriggerStep;
  367. }
  368. /*
  369. ** Construct a trigger step that implements a DELETE statement and return
  370. ** a pointer to that trigger step.  The parser calls this routine when it
  371. ** sees a DELETE statement inside the body of a CREATE TRIGGER.
  372. */
  373. TriggerStep *sqlite3TriggerDeleteStep(
  374.   sqlite3 *db,            /* Database connection */
  375.   Token *pTableName,      /* The table from which rows are deleted */
  376.   Expr *pWhere            /* The WHERE clause */
  377. ){
  378.   TriggerStep *pTriggerStep = sqlite3DbMallocZero(db, sizeof(TriggerStep));
  379.   if( pTriggerStep==0 ){
  380.     sqlite3ExprDelete(pWhere);
  381.     return 0;
  382.   }
  383.   pTriggerStep->op = TK_DELETE;
  384.   pTriggerStep->target  = *pTableName;
  385.   pTriggerStep->pWhere = pWhere;
  386.   pTriggerStep->orconf = OE_Default;
  387.   sqlitePersistTriggerStep(db, pTriggerStep);
  388.   return pTriggerStep;
  389. }
  390. /* 
  391. ** Recursively delete a Trigger structure
  392. */
  393. void sqlite3DeleteTrigger(Trigger *pTrigger){
  394.   if( pTrigger==0 ) return;
  395.   sqlite3DeleteTriggerStep(pTrigger->step_list);
  396.   sqlite3_free(pTrigger->name);
  397.   sqlite3_free(pTrigger->table);
  398.   sqlite3ExprDelete(pTrigger->pWhen);
  399.   sqlite3IdListDelete(pTrigger->pColumns);
  400.   if( pTrigger->nameToken.dyn ) sqlite3_free((char*)pTrigger->nameToken.z);
  401.   sqlite3_free(pTrigger);
  402. }
  403. /*
  404. ** This function is called to drop a trigger from the database schema. 
  405. **
  406. ** This may be called directly from the parser and therefore identifies
  407. ** the trigger by name.  The sqlite3DropTriggerPtr() routine does the
  408. ** same job as this routine except it takes a pointer to the trigger
  409. ** instead of the trigger name.
  410. **/
  411. void sqlite3DropTrigger(Parse *pParse, SrcList *pName, int noErr){
  412.   Trigger *pTrigger = 0;
  413.   int i;
  414.   const char *zDb;
  415.   const char *zName;
  416.   int nName;
  417.   sqlite3 *db = pParse->db;
  418.   if( db->mallocFailed ) goto drop_trigger_cleanup;
  419.   if( SQLITE_OK!=sqlite3ReadSchema(pParse) ){
  420.     goto drop_trigger_cleanup;
  421.   }
  422.   assert( pName->nSrc==1 );
  423.   zDb = pName->a[0].zDatabase;
  424.   zName = pName->a[0].zName;
  425.   nName = strlen(zName);
  426.   for(i=OMIT_TEMPDB; i<db->nDb; i++){
  427.     int j = (i<2) ? i^1 : i;  /* Search TEMP before MAIN */
  428.     if( zDb && sqlite3StrICmp(db->aDb[j].zName, zDb) ) continue;
  429.     pTrigger = sqlite3HashFind(&(db->aDb[j].pSchema->trigHash), zName, nName);
  430.     if( pTrigger ) break;
  431.   }
  432.   if( !pTrigger ){
  433.     if( !noErr ){
  434.       sqlite3ErrorMsg(pParse, "no such trigger: %S", pName, 0);
  435.     }
  436.     goto drop_trigger_cleanup;
  437.   }
  438.   sqlite3DropTriggerPtr(pParse, pTrigger);
  439. drop_trigger_cleanup:
  440.   sqlite3SrcListDelete(pName);
  441. }
  442. /*
  443. ** Return a pointer to the Table structure for the table that a trigger
  444. ** is set on.
  445. */
  446. static Table *tableOfTrigger(Trigger *pTrigger){
  447.   int n = strlen(pTrigger->table) + 1;
  448.   return sqlite3HashFind(&pTrigger->pTabSchema->tblHash, pTrigger->table, n);
  449. }
  450. /*
  451. ** Drop a trigger given a pointer to that trigger. 
  452. */
  453. void sqlite3DropTriggerPtr(Parse *pParse, Trigger *pTrigger){
  454.   Table   *pTable;
  455.   Vdbe *v;
  456.   sqlite3 *db = pParse->db;
  457.   int iDb;
  458.   iDb = sqlite3SchemaToIndex(pParse->db, pTrigger->pSchema);
  459.   assert( iDb>=0 && iDb<db->nDb );
  460.   pTable = tableOfTrigger(pTrigger);
  461.   assert( pTable );
  462.   assert( pTable->pSchema==pTrigger->pSchema || iDb==1 );
  463. #ifndef SQLITE_OMIT_AUTHORIZATION
  464.   {
  465.     int code = SQLITE_DROP_TRIGGER;
  466.     const char *zDb = db->aDb[iDb].zName;
  467.     const char *zTab = SCHEMA_TABLE(iDb);
  468.     if( iDb==1 ) code = SQLITE_DROP_TEMP_TRIGGER;
  469.     if( sqlite3AuthCheck(pParse, code, pTrigger->name, pTable->zName, zDb) ||
  470.       sqlite3AuthCheck(pParse, SQLITE_DELETE, zTab, 0, zDb) ){
  471.       return;
  472.     }
  473.   }
  474. #endif
  475.   /* Generate code to destroy the database record of the trigger.
  476.   */
  477.   assert( pTable!=0 );
  478.   if( (v = sqlite3GetVdbe(pParse))!=0 ){
  479.     int base;
  480.     static const VdbeOpList dropTrigger[] = {
  481.       { OP_Rewind,     0, ADDR(9),  0},
  482.       { OP_String8,    0, 1,        0}, /* 1 */
  483.       { OP_Column,     0, 1,        2},
  484.       { OP_Ne,         2, ADDR(8),  1},
  485.       { OP_String8,    0, 1,        0}, /* 4: "trigger" */
  486.       { OP_Column,     0, 0,        2},
  487.       { OP_Ne,         2, ADDR(8),  1},
  488.       { OP_Delete,     0, 0,        0},
  489.       { OP_Next,       0, ADDR(1),  0}, /* 8 */
  490.     };
  491.     sqlite3BeginWriteOperation(pParse, 0, iDb);
  492.     sqlite3OpenMasterTable(pParse, iDb);
  493.     base = sqlite3VdbeAddOpList(v,  ArraySize(dropTrigger), dropTrigger);
  494.     sqlite3VdbeChangeP4(v, base+1, pTrigger->name, 0);
  495.     sqlite3VdbeChangeP4(v, base+4, "trigger", P4_STATIC);
  496.     sqlite3ChangeCookie(pParse, iDb);
  497.     sqlite3VdbeAddOp2(v, OP_Close, 0, 0);
  498.     sqlite3VdbeAddOp4(v, OP_DropTrigger, iDb, 0, 0, pTrigger->name, 0);
  499.   }
  500. }
  501. /*
  502. ** Remove a trigger from the hash tables of the sqlite* pointer.
  503. */
  504. void sqlite3UnlinkAndDeleteTrigger(sqlite3 *db, int iDb, const char *zName){
  505.   Trigger *pTrigger;
  506.   int nName = strlen(zName);
  507.   pTrigger = sqlite3HashInsert(&(db->aDb[iDb].pSchema->trigHash),
  508.                                zName, nName, 0);
  509.   if( pTrigger ){
  510.     Table *pTable = tableOfTrigger(pTrigger);
  511.     assert( pTable!=0 );
  512.     if( pTable->pTrigger == pTrigger ){
  513.       pTable->pTrigger = pTrigger->pNext;
  514.     }else{
  515.       Trigger *cc = pTable->pTrigger;
  516.       while( cc ){ 
  517.         if( cc->pNext == pTrigger ){
  518.           cc->pNext = cc->pNext->pNext;
  519.           break;
  520.         }
  521.         cc = cc->pNext;
  522.       }
  523.       assert(cc);
  524.     }
  525.     sqlite3DeleteTrigger(pTrigger);
  526.     db->flags |= SQLITE_InternChanges;
  527.   }
  528. }
  529. /*
  530. ** pEList is the SET clause of an UPDATE statement.  Each entry
  531. ** in pEList is of the format <id>=<expr>.  If any of the entries
  532. ** in pEList have an <id> which matches an identifier in pIdList,
  533. ** then return TRUE.  If pIdList==NULL, then it is considered a
  534. ** wildcard that matches anything.  Likewise if pEList==NULL then
  535. ** it matches anything so always return true.  Return false only
  536. ** if there is no match.
  537. */
  538. static int checkColumnOverLap(IdList *pIdList, ExprList *pEList){
  539.   int e;
  540.   if( !pIdList || !pEList ) return 1;
  541.   for(e=0; e<pEList->nExpr; e++){
  542.     if( sqlite3IdListIndex(pIdList, pEList->a[e].zName)>=0 ) return 1;
  543.   }
  544.   return 0; 
  545. }
  546. /*
  547. ** Return a bit vector to indicate what kind of triggers exist for operation
  548. ** "op" on table pTab.  If pChanges is not NULL then it is a list of columns
  549. ** that are being updated.  Triggers only match if the ON clause of the
  550. ** trigger definition overlaps the set of columns being updated.
  551. **
  552. ** The returned bit vector is some combination of TRIGGER_BEFORE and
  553. ** TRIGGER_AFTER.
  554. */
  555. int sqlite3TriggersExist(
  556.   Parse *pParse,          /* Used to check for recursive triggers */
  557.   Table *pTab,            /* The table the contains the triggers */
  558.   int op,                 /* one of TK_DELETE, TK_INSERT, TK_UPDATE */
  559.   ExprList *pChanges      /* Columns that change in an UPDATE statement */
  560. ){
  561.   Trigger *pTrigger;
  562.   int mask = 0;
  563.   pTrigger = IsVirtual(pTab) ? 0 : pTab->pTrigger;
  564.   while( pTrigger ){
  565.     if( pTrigger->op==op && checkColumnOverLap(pTrigger->pColumns, pChanges) ){
  566.       mask |= pTrigger->tr_tm;
  567.     }
  568.     pTrigger = pTrigger->pNext;
  569.   }
  570.   return mask;
  571. }
  572. /*
  573. ** Convert the pStep->target token into a SrcList and return a pointer
  574. ** to that SrcList.
  575. **
  576. ** This routine adds a specific database name, if needed, to the target when
  577. ** forming the SrcList.  This prevents a trigger in one database from
  578. ** referring to a target in another database.  An exception is when the
  579. ** trigger is in TEMP in which case it can refer to any other database it
  580. ** wants.
  581. */
  582. static SrcList *targetSrcList(
  583.   Parse *pParse,       /* The parsing context */
  584.   TriggerStep *pStep   /* The trigger containing the target token */
  585. ){
  586.   Token sDb;           /* Dummy database name token */
  587.   int iDb;             /* Index of the database to use */
  588.   SrcList *pSrc;       /* SrcList to be returned */
  589.   iDb = sqlite3SchemaToIndex(pParse->db, pStep->pTrig->pSchema);
  590.   if( iDb==0 || iDb>=2 ){
  591.     assert( iDb<pParse->db->nDb );
  592.     sDb.z = (u8*)pParse->db->aDb[iDb].zName;
  593.     sDb.n = strlen((char*)sDb.z);
  594.     pSrc = sqlite3SrcListAppend(pParse->db, 0, &sDb, &pStep->target);
  595.   } else {
  596.     pSrc = sqlite3SrcListAppend(pParse->db, 0, &pStep->target, 0);
  597.   }
  598.   return pSrc;
  599. }
  600. /*
  601. ** Generate VDBE code for zero or more statements inside the body of a
  602. ** trigger.  
  603. */
  604. static int codeTriggerProgram(
  605.   Parse *pParse,            /* The parser context */
  606.   TriggerStep *pStepList,   /* List of statements inside the trigger body */
  607.   int orconfin              /* Conflict algorithm. (OE_Abort, etc) */  
  608. ){
  609.   TriggerStep * pTriggerStep = pStepList;
  610.   int orconf;
  611.   Vdbe *v = pParse->pVdbe;
  612.   sqlite3 *db = pParse->db;
  613.   assert( pTriggerStep!=0 );
  614.   assert( v!=0 );
  615.   sqlite3VdbeAddOp2(v, OP_ContextPush, 0, 0);
  616.   VdbeComment((v, "begin trigger %s", pStepList->pTrig->name));
  617.   while( pTriggerStep ){
  618.     orconf = (orconfin == OE_Default)?pTriggerStep->orconf:orconfin;
  619.     pParse->trigStack->orconf = orconf;
  620.     switch( pTriggerStep->op ){
  621.       case TK_SELECT: {
  622.         Select *ss = sqlite3SelectDup(db, pTriggerStep->pSelect);
  623.         if( ss ){
  624.           SelectDest dest;
  625.           sqlite3SelectDestInit(&dest, SRT_Discard, 0);
  626.           sqlite3SelectResolve(pParse, ss, 0);
  627.           sqlite3Select(pParse, ss, &dest, 0, 0, 0, 0);
  628.           sqlite3SelectDelete(ss);
  629.         }
  630.         break;
  631.       }
  632.       case TK_UPDATE: {
  633.         SrcList *pSrc;
  634.         pSrc = targetSrcList(pParse, pTriggerStep);
  635.         sqlite3VdbeAddOp2(v, OP_ResetCount, 0, 0);
  636.         sqlite3Update(pParse, pSrc,
  637.                 sqlite3ExprListDup(db, pTriggerStep->pExprList), 
  638.                 sqlite3ExprDup(db, pTriggerStep->pWhere), orconf);
  639.         sqlite3VdbeAddOp2(v, OP_ResetCount, 1, 0);
  640.         break;
  641.       }
  642.       case TK_INSERT: {
  643.         SrcList *pSrc;
  644.         pSrc = targetSrcList(pParse, pTriggerStep);
  645.         sqlite3VdbeAddOp2(v, OP_ResetCount, 0, 0);
  646.         sqlite3Insert(pParse, pSrc,
  647.           sqlite3ExprListDup(db, pTriggerStep->pExprList), 
  648.           sqlite3SelectDup(db, pTriggerStep->pSelect), 
  649.           sqlite3IdListDup(db, pTriggerStep->pIdList), orconf);
  650.         sqlite3VdbeAddOp2(v, OP_ResetCount, 1, 0);
  651.         break;
  652.       }
  653.       case TK_DELETE: {
  654.         SrcList *pSrc;
  655.         sqlite3VdbeAddOp2(v, OP_ResetCount, 0, 0);
  656.         pSrc = targetSrcList(pParse, pTriggerStep);
  657.         sqlite3DeleteFrom(pParse, pSrc, 
  658.                           sqlite3ExprDup(db, pTriggerStep->pWhere));
  659.         sqlite3VdbeAddOp2(v, OP_ResetCount, 1, 0);
  660.         break;
  661.       }
  662.       default:
  663.         assert(0);
  664.     } 
  665.     pTriggerStep = pTriggerStep->pNext;
  666.   }
  667.   sqlite3VdbeAddOp2(v, OP_ContextPop, 0, 0);
  668.   VdbeComment((v, "end trigger %s", pStepList->pTrig->name));
  669.   return 0;
  670. }
  671. /*
  672. ** This is called to code FOR EACH ROW triggers.
  673. **
  674. ** When the code that this function generates is executed, the following 
  675. ** must be true:
  676. **
  677. ** 1. No cursors may be open in the main database.  (But newIdx and oldIdx
  678. **    can be indices of cursors in temporary tables.  See below.)
  679. **
  680. ** 2. If the triggers being coded are ON INSERT or ON UPDATE triggers, then
  681. **    a temporary vdbe cursor (index newIdx) must be open and pointing at
  682. **    a row containing values to be substituted for new.* expressions in the
  683. **    trigger program(s).
  684. **
  685. ** 3. If the triggers being coded are ON DELETE or ON UPDATE triggers, then
  686. **    a temporary vdbe cursor (index oldIdx) must be open and pointing at
  687. **    a row containing values to be substituted for old.* expressions in the
  688. **    trigger program(s).
  689. **
  690. ** If they are not NULL, the piOldColMask and piNewColMask output variables
  691. ** are set to values that describe the columns used by the trigger program
  692. ** in the OLD.* and NEW.* tables respectively. If column N of the 
  693. ** pseudo-table is read at least once, the corresponding bit of the output
  694. ** mask is set. If a column with an index greater than 32 is read, the
  695. ** output mask is set to the special value 0xffffffff.
  696. **
  697. */
  698. int sqlite3CodeRowTrigger(
  699.   Parse *pParse,       /* Parse context */
  700.   int op,              /* One of TK_UPDATE, TK_INSERT, TK_DELETE */
  701.   ExprList *pChanges,  /* Changes list for any UPDATE OF triggers */
  702.   int tr_tm,           /* One of TRIGGER_BEFORE, TRIGGER_AFTER */
  703.   Table *pTab,         /* The table to code triggers from */
  704.   int newIdx,          /* The indice of the "new" row to access */
  705.   int oldIdx,          /* The indice of the "old" row to access */
  706.   int orconf,          /* ON CONFLICT policy */
  707.   int ignoreJump,      /* Instruction to jump to for RAISE(IGNORE) */
  708.   u32 *piOldColMask,   /* OUT: Mask of columns used from the OLD.* table */
  709.   u32 *piNewColMask    /* OUT: Mask of columns used from the NEW.* table */
  710. ){
  711.   Trigger *p;
  712.   sqlite3 *db = pParse->db;
  713.   TriggerStack trigStackEntry;
  714.   trigStackEntry.oldColMask = 0;
  715.   trigStackEntry.newColMask = 0;
  716.   assert(op == TK_UPDATE || op == TK_INSERT || op == TK_DELETE);
  717.   assert(tr_tm == TRIGGER_BEFORE || tr_tm == TRIGGER_AFTER );
  718.   assert(newIdx != -1 || oldIdx != -1);
  719.   for(p=pTab->pTrigger; p; p=p->pNext){
  720.     int fire_this = 0;
  721.     /* Determine whether we should code this trigger */
  722.     if( 
  723.       p->op==op && 
  724.       p->tr_tm==tr_tm && 
  725.       (p->pSchema==p->pTabSchema || p->pSchema==db->aDb[1].pSchema) &&
  726.       (op!=TK_UPDATE||!p->pColumns||checkColumnOverLap(p->pColumns,pChanges))
  727.     ){
  728.       TriggerStack *pS;      /* Pointer to trigger-stack entry */
  729.       for(pS=pParse->trigStack; pS && p!=pS->pTrigger; pS=pS->pNext){}
  730.       if( !pS ){
  731.         fire_this = 1;
  732.       }
  733. #if 0    /* Give no warning for recursive triggers.  Just do not do them */
  734.       else{
  735.         sqlite3ErrorMsg(pParse, "recursive triggers not supported (%s)",
  736.             p->name);
  737.         return SQLITE_ERROR;
  738.       }
  739. #endif
  740.     }
  741.  
  742.     if( fire_this ){
  743.       int endTrigger;
  744.       Expr * whenExpr;
  745.       AuthContext sContext;
  746.       NameContext sNC;
  747. #ifndef SQLITE_OMIT_TRACE
  748.       sqlite3VdbeAddOp4(pParse->pVdbe, OP_Trace, 0, 0, 0,
  749.                         sqlite3MPrintf(db, "-- TRIGGER %s", p->name),
  750.                         P4_DYNAMIC);
  751. #endif
  752.       memset(&sNC, 0, sizeof(sNC));
  753.       sNC.pParse = pParse;
  754.       /* Push an entry on to the trigger stack */
  755.       trigStackEntry.pTrigger = p;
  756.       trigStackEntry.newIdx = newIdx;
  757.       trigStackEntry.oldIdx = oldIdx;
  758.       trigStackEntry.pTab = pTab;
  759.       trigStackEntry.pNext = pParse->trigStack;
  760.       trigStackEntry.ignoreJump = ignoreJump;
  761.       pParse->trigStack = &trigStackEntry;
  762.       sqlite3AuthContextPush(pParse, &sContext, p->name);
  763.       /* code the WHEN clause */
  764.       endTrigger = sqlite3VdbeMakeLabel(pParse->pVdbe);
  765.       whenExpr = sqlite3ExprDup(db, p->pWhen);
  766.       if( db->mallocFailed || sqlite3ExprResolveNames(&sNC, whenExpr) ){
  767.         pParse->trigStack = trigStackEntry.pNext;
  768.         sqlite3ExprDelete(whenExpr);
  769.         return 1;
  770.       }
  771.       sqlite3ExprIfFalse(pParse, whenExpr, endTrigger, SQLITE_JUMPIFNULL);
  772.       sqlite3ExprDelete(whenExpr);
  773.       codeTriggerProgram(pParse, p->step_list, orconf); 
  774.       /* Pop the entry off the trigger stack */
  775.       pParse->trigStack = trigStackEntry.pNext;
  776.       sqlite3AuthContextPop(&sContext);
  777.       sqlite3VdbeResolveLabel(pParse->pVdbe, endTrigger);
  778.     }
  779.   }
  780.   if( piOldColMask ) *piOldColMask |= trigStackEntry.oldColMask;
  781.   if( piNewColMask ) *piNewColMask |= trigStackEntry.newColMask;
  782.   return 0;
  783. }
  784. #endif /* !defined(SQLITE_OMIT_TRIGGER) */