/*

**

** The author disclaims copyright to this source code.  In place of

** a legal notice, here is a blessing:

**

**    May you do good and not evil.

**    May you find forgiveness for yourself and forgive others.

**    May you share freely, never taking more than you give.

**

*************************************************************************

**

**

** $Id: trigger.c,v 1.128 2008/07/28 19:34:54 drh Exp $

*/

#include "sqliteInt.h"

#ifndef SQLITE_OMIT_TRIGGER

/*

** Delete a linked list of TriggerStep structures.

*/

void sqlite3DeleteTriggerStep(sqlite3 *db, TriggerStep *pTriggerStep){

  while( pTriggerStep ){

    TriggerStep * pTmp = pTriggerStep;

    pTriggerStep = pTriggerStep->pNext;

    if( pTmp->target.dyn ) sqlite3DbFree(db, (char*)pTmp->target.z);

    sqlite3ExprDelete(db, pTmp->pWhere);

    sqlite3ExprListDelete(db, pTmp->pExprList);

    sqlite3SelectDelete(db, pTmp->pSelect);

    sqlite3IdListDelete(db, pTmp->pIdList);

    sqlite3DbFree(db, pTmp);

  }

}

/*

** This is called by the parser when it sees a CREATE TRIGGER statement

** up to the point of the BEGIN before the trigger actions.  A Trigger

** structure is generated based on the information available and stored

** in pParse->pNewTrigger.  After the trigger actions have been parsed, the

** sqlite3FinishTrigger() function is called to complete the trigger

** construction process.

*/

void sqlite3BeginTrigger(

  Parse *pParse,      /* The parse context of the CREATE TRIGGER statement */

  Token *pName1,      /* The name of the trigger */

  Token *pName2,      /* The name of the trigger */

  int tr_tm,          /* One of TK_BEFORE, TK_AFTER, TK_INSTEAD */

  int op,             /* One of TK_INSERT, TK_UPDATE, TK_DELETE */

  IdList *pColumns,   /* column list if this is an UPDATE OF trigger */

  SrcList *pTableName,/* The name of the table/view the trigger applies to */

  Expr *pWhen,        /* WHEN clause */

  int isTemp,         /* True if the TEMPORARY keyword is present */

  int noErr           /* Suppress errors if the trigger already exists */

){

  Trigger *pTrigger = 0;

  Table *pTab;

  char *zName = 0;        /* Name of the trigger */

  sqlite3 *db = pParse->db;

  int iDb;                /* The database to store the trigger in */

  Token *pName;           /* The unqualified db name */

  DbFixer sFix;

  int iTabDb;

  assert( pName1!=0 );   /* pName1->z might be NULL, but not pName1 itself */

  assert( pName2!=0 );

  if( isTemp ){

    /* If TEMP was specified, then the trigger name may not be qualified. */

    if( pName2->n>0 ){

      sqlite3ErrorMsg(pParse, "temporary trigger may not have qualified name");

      goto trigger_cleanup;

    }

    iDb = 1;

    pName = pName1;

  }else{

    /* Figure out the db that the the trigger will be created in */

    iDb = sqlite3TwoPartName(pParse, pName1, pName2, &pName);

    if( iDb<0 ){

      goto trigger_cleanup;

    }

  }

  /* If the trigger name was unqualified, and the table is a temp table,

  ** then set iDb to 1 to create the trigger in the temporary database.

  ** If sqlite3SrcListLookup() returns 0, indicating the table does not

  ** exist, the error is caught by the block below.

  */

  if( !pTableName || db->mallocFailed ){

    goto trigger_cleanup;

  }

  pTab = sqlite3SrcListLookup(pParse, pTableName);

  if( pName2->n==0 && pTab && pTab->pSchema==db->aDb[1].pSchema ){

    iDb = 1;

  }

  /* Ensure the table name matches database name and that the table exists */

  if( db->mallocFailed ) goto trigger_cleanup;

  assert( pTableName->nSrc==1 );

  if( sqlite3FixInit(&sFix, pParse, iDb, "trigger", pName) && 

      sqlite3FixSrcList(&sFix, pTableName) ){

    goto trigger_cleanup;

  }

  pTab = sqlite3SrcListLookup(pParse, pTableName);

  if( !pTab ){

    /* The table does not exist. */

    goto trigger_cleanup;

  }

  if( IsVirtual(pTab) ){

    sqlite3ErrorMsg(pParse, "cannot create triggers on virtual tables");

    goto trigger_cleanup;

  }

  /* Check that the trigger name is not reserved and that no trigger of the

  ** specified name exists */

  zName = sqlite3NameFromToken(db, pName);

  if( !zName || SQLITE_OK!=sqlite3CheckObjectName(pParse, zName) ){

    goto trigger_cleanup;

  }

  if( sqlite3HashFind(&(db->aDb[iDb].pSchema->trigHash), zName,strlen(zName)) ){

    if( !noErr ){

      sqlite3ErrorMsg(pParse, "trigger %T already exists", pName);

    }

    goto trigger_cleanup;

  }

  /* Do not create a trigger on a system table */

  if( sqlite3StrNICmp(pTab->zName, "sqlite_", 7)==0 ){

    sqlite3ErrorMsg(pParse, "cannot create trigger on system table");

    pParse->nErr++;

    goto trigger_cleanup;

  }

  /* INSTEAD of triggers are only for views and views only support INSTEAD

  ** of triggers.

  */

  if( pTab->pSelect && tr_tm!=TK_INSTEAD ){

    sqlite3ErrorMsg(pParse, "cannot create %s trigger on view: %S", 

        (tr_tm == TK_BEFORE)?"BEFORE":"AFTER", pTableName, 0);

    goto trigger_cleanup;

  }

  if( !pTab->pSelect && tr_tm==TK_INSTEAD ){

    sqlite3ErrorMsg(pParse, "cannot create INSTEAD OF"

        " trigger on table: %S", pTableName, 0);

    goto trigger_cleanup;

  }

  iTabDb = sqlite3SchemaToIndex(db, pTab->pSchema);

#ifndef SQLITE_OMIT_AUTHORIZATION

  {

    int code = SQLITE_CREATE_TRIGGER;

    const char *zDb = db->aDb[iTabDb].zName;

    const char *zDbTrig = isTemp ? db->aDb[1].zName : zDb;

    if( iTabDb==1 || isTemp ) code = SQLITE_CREATE_TEMP_TRIGGER;

    if( sqlite3AuthCheck(pParse, code, zName, pTab->zName, zDbTrig) ){

      goto trigger_cleanup;

    }

    if( sqlite3AuthCheck(pParse, SQLITE_INSERT, SCHEMA_TABLE(iTabDb),0,zDb)){

      goto trigger_cleanup;

    }

  }

#endif

  /* INSTEAD OF triggers can only appear on views and BEFORE triggers

  ** cannot appear on views.  So we might as well translate every

  ** INSTEAD OF trigger into a BEFORE trigger.  It simplifies code

  ** elsewhere.

  */

  if (tr_tm == TK_INSTEAD){

    tr_tm = TK_BEFORE;

  }

  /* Build the Trigger object */

  pTrigger = (Trigger*)sqlite3DbMallocZero(db, sizeof(Trigger));

  if( pTrigger==0 ) goto trigger_cleanup;

  pTrigger->name = zName;

  zName = 0;

  pTrigger->table = sqlite3DbStrDup(db, pTableName->a[0].zName);

  pTrigger->pSchema = db->aDb[iDb].pSchema;

  pTrigger->pTabSchema = pTab->pSchema;

  pTrigger->op = op;

  pTrigger->tr_tm = tr_tm==TK_BEFORE ? TRIGGER_BEFORE : TRIGGER_AFTER;

  pTrigger->pWhen = sqlite3ExprDup(db, pWhen);

  pTrigger->pColumns = sqlite3IdListDup(db, pColumns);

  sqlite3TokenCopy(db, &pTrigger->nameToken,pName);

  assert( pParse->pNewTrigger==0 );

  pParse->pNewTrigger = pTrigger;

trigger_cleanup:

  sqlite3DbFree(db, zName);

  sqlite3SrcListDelete(db, pTableName);

  sqlite3IdListDelete(db, pColumns);

  sqlite3ExprDelete(db, pWhen);

  if( !pParse->pNewTrigger ){

    sqlite3DeleteTrigger(db, pTrigger);

  }else{

    assert( pParse->pNewTrigger==pTrigger );

  }

}

/*

** This routine is called after all of the trigger actions have been parsed

** in order to complete the process of building the trigger.

*/

void sqlite3FinishTrigger(

  Parse *pParse,          /* Parser context */

  TriggerStep *pStepList, /* The triggered program */

  Token *pAll             /* Token that describes the complete CREATE TRIGGER */

){

  Trigger *pTrig = 0;     /* The trigger whose construction is finishing up */

  sqlite3 *db = pParse->db;  /* The database */

  DbFixer sFix;

  int iDb;                   /* Database containing the trigger */

  pTrig = pParse->pNewTrigger;

  pParse->pNewTrigger = 0;

  if( pParse->nErr || !pTrig ) goto triggerfinish_cleanup;

  iDb = sqlite3SchemaToIndex(pParse->db, pTrig->pSchema);

  pTrig->step_list = pStepList;

  while( pStepList ){

    pStepList->pTrig = pTrig;

    pStepList = pStepList->pNext;

  }

  if( sqlite3FixInit(&sFix, pParse, iDb, "trigger", &pTrig->nameToken) 

          && sqlite3FixTriggerStep(&sFix, pTrig->step_list) ){

    goto triggerfinish_cleanup;

  }

  /* if we are not initializing, and this trigger is not on a TEMP table, 

  ** build the sqlite_master entry

  */

  if( !db->init.busy ){

    Vdbe *v;

    char *z;

    /* Make an entry in the sqlite_master table */

    v = sqlite3GetVdbe(pParse);

    if( v==0 ) goto triggerfinish_cleanup;

    sqlite3BeginWriteOperation(pParse, 0, iDb);

    z = sqlite3DbStrNDup(db, (char*)pAll->z, pAll->n);

    sqlite3NestedParse(pParse,

       "INSERT INTO %Q.%s VALUES('trigger',%Q,%Q,0,'CREATE TRIGGER %q')",

       db->aDb[iDb].zName, SCHEMA_TABLE(iDb), pTrig->name,

       pTrig->table, z);

    sqlite3DbFree(db, z);

    sqlite3ChangeCookie(pParse, iDb);

    sqlite3VdbeAddOp4(v, OP_ParseSchema, iDb, 0, 0, sqlite3MPrintf(

        db, "type='trigger' AND name='%q'", pTrig->name), P4_DYNAMIC

    );

  }

  if( db->init.busy ){

    int n;

    Table *pTab;

    Trigger *pDel;

    pDel = sqlite3HashInsert(&db->aDb[iDb].pSchema->trigHash, 

                     pTrig->name, strlen(pTrig->name), pTrig);

    if( pDel ){

      assert( pDel==pTrig );

      db->mallocFailed = 1;

      goto triggerfinish_cleanup;

    }

    n = strlen(pTrig->table) + 1;

    pTab = sqlite3HashFind(&pTrig->pTabSchema->tblHash, pTrig->table, n);

    assert( pTab!=0 );

    pTrig->pNext = pTab->pTrigger;

    pTab->pTrigger = pTrig;

    pTrig = 0;

  }

triggerfinish_cleanup:

  sqlite3DeleteTrigger(db, pTrig);

  assert( !pParse->pNewTrigger );

  sqlite3DeleteTriggerStep(db, pStepList);

}

/*

** Make a copy of all components of the given trigger step.  This has

** the effect of copying all Expr.token.z values into memory obtained

** from sqlite3_malloc().  As initially created, the Expr.token.z values

** all point to the input string that was fed to the parser.  But that

** string is ephemeral - it will go away as soon as the sqlite3_exec()

** call that started the parser exits.  This routine makes a persistent

** copy of all the Expr.token.z strings so that the TriggerStep structure

** will be valid even after the sqlite3_exec() call returns.

*/

static void sqlitePersistTriggerStep(sqlite3 *db, TriggerStep *p){

  if( p->target.z ){

    p->target.z = (u8*)sqlite3DbStrNDup(db, (char*)p->target.z, p->target.n);

    p->target.dyn = 1;

  }

  if( p->pSelect ){

    Select *pNew = sqlite3SelectDup(db, p->pSelect);

    sqlite3SelectDelete(db, p->pSelect);

    p->pSelect = pNew;

  }

  if( p->pWhere ){

    Expr *pNew = sqlite3ExprDup(db, p->pWhere);

    sqlite3ExprDelete(db, p->pWhere);

    p->pWhere = pNew;

  }

  if( p->pExprList ){

    ExprList *pNew = sqlite3ExprListDup(db, p->pExprList);

    sqlite3ExprListDelete(db, p->pExprList);

    p->pExprList = pNew;

  }

  if( p->pIdList ){

    IdList *pNew = sqlite3IdListDup(db, p->pIdList);

    sqlite3IdListDelete(db, p->pIdList);

    p->pIdList = pNew;

  }

}

/*

** Turn a SELECT statement (that the pSelect parameter points to) into

** a trigger step.  Return a pointer to a TriggerStep structure.

**

** The parser calls this routine when it finds a SELECT statement in

** body of a TRIGGER.  

*/

TriggerStep *sqlite3TriggerSelectStep(sqlite3 *db, Select *pSelect){

  TriggerStep *pTriggerStep = sqlite3DbMallocZero(db, sizeof(TriggerStep));

  if( pTriggerStep==0 ) {

    sqlite3SelectDelete(db, pSelect);

    return 0;

  }

  pTriggerStep->op = TK_SELECT;

  pTriggerStep->pSelect = pSelect;

  pTriggerStep->orconf = OE_Default;

  sqlitePersistTriggerStep(db, pTriggerStep);

  return pTriggerStep;

}

/*

** Build a trigger step out of an INSERT statement.  Return a pointer

** to the new trigger step.

**

** The parser calls this routine when it sees an INSERT inside the

** body of a trigger.

*/

TriggerStep *sqlite3TriggerInsertStep(

  sqlite3 *db,        /* The database connection */

  Token *pTableName,  /* Name of the table into which we insert */

  IdList *pColumn,    /* List of columns in pTableName to insert into */

  ExprList *pEList,   /* The VALUE clause: a list of values to be inserted */

  Select *pSelect,    /* A SELECT statement that supplies values */

  int orconf          /* The conflict algorithm (OE_Abort, OE_Replace, etc.) */

){

  TriggerStep *pTriggerStep;

  assert(pEList == 0 || pSelect == 0);

  assert(pEList != 0 || pSelect != 0 || db->mallocFailed);

  pTriggerStep = sqlite3DbMallocZero(db, sizeof(TriggerStep));

  if( pTriggerStep ){

    pTriggerStep->op = TK_INSERT;

    pTriggerStep->pSelect = pSelect;

    pTriggerStep->target  = *pTableName;

    pTriggerStep->pIdList = pColumn;

    pTriggerStep->pExprList = pEList;

    pTriggerStep->orconf = orconf;

    sqlitePersistTriggerStep(db, pTriggerStep);

  }else{

    sqlite3IdListDelete(db, pColumn);

    sqlite3ExprListDelete(db, pEList);

    sqlite3SelectDelete(db, pSelect);

  }

  return pTriggerStep;

}

/*

** Construct a trigger step that implements an UPDATE statement and return

** a pointer to that trigger step.  The parser calls this routine when it

** sees an UPDATE statement inside the body of a CREATE TRIGGER.

*/

TriggerStep *sqlite3TriggerUpdateStep(

  sqlite3 *db,         /* The database connection */

  Token *pTableName,   /* Name of the table to be updated */

  ExprList *pEList,    /* The SET clause: list of column and new values */

  Expr *pWhere,        /* The WHERE clause */

  int orconf           /* The conflict algorithm. (OE_Abort, OE_Ignore, etc) */

){

  TriggerStep *pTriggerStep = sqlite3DbMallocZero(db, sizeof(TriggerStep));

  if( pTriggerStep==0 ){

     sqlite3ExprListDelete(db, pEList);

     sqlite3ExprDelete(db, pWhere);

     return 0;

  }

  pTriggerStep->op = TK_UPDATE;

  pTriggerStep->target  = *pTableName;

  pTriggerStep->pExprList = pEList;

  pTriggerStep->pWhere = pWhere;

  pTriggerStep->orconf = orconf;

  sqlitePersistTriggerStep(db, pTriggerStep);

  return pTriggerStep;

}

/*

** Construct a trigger step that implements a DELETE statement and return

** a pointer to that trigger step.  The parser calls this routine when it

** sees a DELETE statement inside the body of a CREATE TRIGGER.

*/

TriggerStep *sqlite3TriggerDeleteStep(

  sqlite3 *db,            /* Database connection */

  Token *pTableName,      /* The table from which rows are deleted */

  Expr *pWhere            /* The WHERE clause */

){

  TriggerStep *pTriggerStep = sqlite3DbMallocZero(db, sizeof(TriggerStep));

  if( pTriggerStep==0 ){

    sqlite3ExprDelete(db, pWhere);

    return 0;

  }

  pTriggerStep->op = TK_DELETE;

  pTriggerStep->target  = *pTableName;

  pTriggerStep->pWhere = pWhere;

  pTriggerStep->orconf = OE_Default;

  sqlitePersistTriggerStep(db, pTriggerStep);

  return pTriggerStep;

}

/* 

** Recursively delete a Trigger structure

*/

void sqlite3DeleteTrigger(sqlite3 *db, Trigger *pTrigger){

  if( pTrigger==0 ) return;

  sqlite3DeleteTriggerStep(db, pTrigger->step_list);

  sqlite3DbFree(db, pTrigger->name);

  sqlite3DbFree(db, pTrigger->table);

  sqlite3ExprDelete(db, pTrigger->pWhen);

  sqlite3IdListDelete(db, pTrigger->pColumns);

  if( pTrigger->nameToken.dyn ) sqlite3DbFree(db, (char*)pTrigger->nameToken.z);

  sqlite3DbFree(db, pTrigger);

}

/*

** This function is called to drop a trigger from the database schema. 

**

** This may be called directly from the parser and therefore identifies

** the trigger by name.  The sqlite3DropTriggerPtr() routine does the

** same job as this routine except it takes a pointer to the trigger

** instead of the trigger name.

**/

void sqlite3DropTrigger(Parse *pParse, SrcList *pName, int noErr){

  Trigger *pTrigger = 0;

  int i;

  const char *zDb;

  const char *zName;

  int nName;

  sqlite3 *db = pParse->db;

  if( db->mallocFailed ) goto drop_trigger_cleanup;

  if( SQLITE_OK!=sqlite3ReadSchema(pParse) ){

    goto drop_trigger_cleanup;

  }

  assert( pName->nSrc==1 );

  zDb = pName->a[0].zDatabase;

  zName = pName->a[0].zName;

  nName = strlen(zName);

  for(i=OMIT_TEMPDB; i<db->nDb; i++){

    int j = (i<2) ? i^1 : i;  /* Search TEMP before MAIN */

    if( zDb && sqlite3StrICmp(db->aDb[j].zName, zDb) ) continue;

    pTrigger = sqlite3HashFind(&(db->aDb[j].pSchema->trigHash), zName, nName);

    if( pTrigger ) break;

  }

  if( !pTrigger ){

    if( !noErr ){

      sqlite3ErrorMsg(pParse, "no such trigger: %S", pName, 0);

    }

    goto drop_trigger_cleanup;

  }

  sqlite3DropTriggerPtr(pParse, pTrigger);

drop_trigger_cleanup:

  sqlite3SrcListDelete(db, pName);

}

/*

** Return a pointer to the Table structure for the table that a trigger

** is set on.

*/

static Table *tableOfTrigger(Trigger *pTrigger){

  int n = strlen(pTrigger->table) + 1;

  return sqlite3HashFind(&pTrigger->pTabSchema->tblHash, pTrigger->table, n);

}

/*

** Drop a trigger given a pointer to that trigger. 

*/

void sqlite3DropTriggerPtr(Parse *pParse, Trigger *pTrigger){

  Table   *pTable;

  Vdbe *v;

  sqlite3 *db = pParse->db;

  int iDb;

  iDb = sqlite3SchemaToIndex(pParse->db, pTrigger->pSchema);

  assert( iDb>=0 && iDb<db->nDb );

  pTable = tableOfTrigger(pTrigger);

  assert( pTable );

  assert( pTable->pSchema==pTrigger->pSchema || iDb==1 );

#ifndef SQLITE_OMIT_AUTHORIZATION

  {

    int code = SQLITE_DROP_TRIGGER;

    const char *zDb = db->aDb[iDb].zName;

    const char *zTab = SCHEMA_TABLE(iDb);

    if( iDb==1 ) code = SQLITE_DROP_TEMP_TRIGGER;

    if( sqlite3AuthCheck(pParse, code, pTrigger->name, pTable->zName, zDb) ||

      sqlite3AuthCheck(pParse, SQLITE_DELETE, zTab, 0, zDb) ){

      return;

    }

  }

#endif

  /* Generate code to destroy the database record of the trigger.

  */

  assert( pTable!=0 );

  if( (v = sqlite3GetVdbe(pParse))!=0 ){

    int base;

    static const VdbeOpList dropTrigger[] = {

      { OP_Rewind,     0, ADDR(9),  0},

      { OP_String8,    0, 1,        0}, /* 1 */