1cce7d176Sdrh /* 2b19a2bc6Sdrh ** 2001 September 15 3cce7d176Sdrh ** 4b19a2bc6Sdrh ** The author disclaims copyright to this source code. In place of 5b19a2bc6Sdrh ** a legal notice, here is a blessing: 6cce7d176Sdrh ** 7b19a2bc6Sdrh ** May you do good and not evil. 8b19a2bc6Sdrh ** May you find forgiveness for yourself and forgive others. 9b19a2bc6Sdrh ** May you share freely, never taking more than you give. 10cce7d176Sdrh ** 11cce7d176Sdrh ************************************************************************* 121ccde15dSdrh ** This file contains routines used for analyzing expressions and 13b19a2bc6Sdrh ** for generating VDBE code that evaluates expressions in SQLite. 14cce7d176Sdrh ** 15*a2e00042Sdrh ** $Id: expr.c,v 1.38 2002/01/22 03:13:42 drh Exp $ 16cce7d176Sdrh */ 17cce7d176Sdrh #include "sqliteInt.h" 18cce7d176Sdrh 19*a2e00042Sdrh 20*a2e00042Sdrh /* 21*a2e00042Sdrh ** Recursively delete an expression tree. 22*a2e00042Sdrh */ 23*a2e00042Sdrh void sqliteExprDelete(Expr *p){ 24*a2e00042Sdrh if( p==0 ) return; 25*a2e00042Sdrh if( p->op!=TK_AS ){ 26*a2e00042Sdrh if( p->pLeft ) sqliteExprDelete(p->pLeft); 27*a2e00042Sdrh if( p->pRight ) sqliteExprDelete(p->pRight); 28*a2e00042Sdrh } 29*a2e00042Sdrh if( p->pList ) sqliteExprListDelete(p->pList); 30*a2e00042Sdrh if( p->pSelect ) sqliteSelectDelete(p->pSelect); 31*a2e00042Sdrh sqliteFree(p); 32*a2e00042Sdrh } 33*a2e00042Sdrh 34cce7d176Sdrh /* 35fef5208cSdrh ** Walk an expression tree. Return 1 if the expression is constant 36fef5208cSdrh ** and 0 if it involves variables. 37fef5208cSdrh */ 38fef5208cSdrh static int isConstant(Expr *p){ 39fef5208cSdrh switch( p->op ){ 40fef5208cSdrh case TK_ID: 41967e8b73Sdrh case TK_COLUMN: 42fef5208cSdrh case TK_DOT: 43fef5208cSdrh return 0; 44fef5208cSdrh default: { 45fef5208cSdrh if( p->pLeft && !isConstant(p->pLeft) ) return 0; 46fef5208cSdrh if( p->pRight && !isConstant(p->pRight) ) return 0; 47fef5208cSdrh if( p->pList ){ 48fef5208cSdrh int i; 49fef5208cSdrh for(i=0; i<p->pList->nExpr; i++){ 50fef5208cSdrh if( !isConstant(p->pList->a[i].pExpr) ) return 0; 51fef5208cSdrh } 52fef5208cSdrh } 53fef5208cSdrh break; 54fef5208cSdrh } 55fef5208cSdrh } 56fef5208cSdrh return 1; 57fef5208cSdrh } 58fef5208cSdrh 59fef5208cSdrh /* 604794b980Sdrh ** Walk the expression tree and process operators of the form: 614794b980Sdrh ** 624794b980Sdrh ** expr IN (SELECT ...) 634794b980Sdrh ** 64967e8b73Sdrh ** These operators have to be processed before column names are 654794b980Sdrh ** resolved because each such operator increments pParse->nTab 661ccde15dSdrh ** to reserve cursor numbers for its own use. But pParse->nTab 67aacc543eSdrh ** needs to be constant once we begin resolving column names. For 68aacc543eSdrh ** that reason, this procedure needs to be called on every expression 69aacc543eSdrh ** before sqliteExprResolveIds() is called on any expression. 704794b980Sdrh ** 714794b980Sdrh ** Actually, the processing of IN-SELECT is only started by this 724794b980Sdrh ** routine. This routine allocates a cursor number to the IN-SELECT 734794b980Sdrh ** and then moves on. The code generation is done by 744794b980Sdrh ** sqliteExprResolveIds() which must be called afterwards. 754794b980Sdrh */ 764794b980Sdrh void sqliteExprResolveInSelect(Parse *pParse, Expr *pExpr){ 774794b980Sdrh if( pExpr==0 ) return; 784794b980Sdrh if( pExpr->op==TK_IN && pExpr->pSelect!=0 ){ 794794b980Sdrh pExpr->iTable = pParse->nTab++; 804794b980Sdrh }else{ 814794b980Sdrh if( pExpr->pLeft ) sqliteExprResolveInSelect(pParse, pExpr->pLeft); 824794b980Sdrh if( pExpr->pRight ) sqliteExprResolveInSelect(pParse, pExpr->pRight); 834794b980Sdrh if( pExpr->pList ){ 844794b980Sdrh int i; 854794b980Sdrh ExprList *pList = pExpr->pList; 864794b980Sdrh for(i=0; i<pList->nExpr; i++){ 874794b980Sdrh sqliteExprResolveInSelect(pParse, pList->a[i].pExpr); 884794b980Sdrh } 894794b980Sdrh } 904794b980Sdrh } 914794b980Sdrh } 924794b980Sdrh 934794b980Sdrh /* 94c4a3c779Sdrh ** Return TRUE if the given string is a row-id column name. 95c4a3c779Sdrh */ 96c4a3c779Sdrh static int sqliteIsRowid(const char *z){ 97c4a3c779Sdrh if( sqliteStrICmp(z, "_ROWID_")==0 ) return 1; 98c4a3c779Sdrh if( sqliteStrICmp(z, "ROWID")==0 ) return 1; 99c4a3c779Sdrh if( sqliteStrICmp(z, "OID")==0 ) return 1; 100c4a3c779Sdrh return 0; 101c4a3c779Sdrh } 102c4a3c779Sdrh 103c4a3c779Sdrh /* 104cce7d176Sdrh ** This routine walks an expression tree and resolves references to 105967e8b73Sdrh ** table columns. Nodes of the form ID.ID or ID resolve into an 106aacc543eSdrh ** index to the table in the table list and a column offset. The 107aacc543eSdrh ** Expr.opcode for such nodes is changed to TK_COLUMN. The Expr.iTable 108aacc543eSdrh ** value is changed to the index of the referenced table in pTabList 109aacc543eSdrh ** plus the pParse->nTab value. This value will ultimately become the 110aacc543eSdrh ** VDBE cursor number for a cursor that is pointing into the referenced 111aacc543eSdrh ** table. The Expr.iColumn value is changed to the index of the column 112aacc543eSdrh ** of the referenced table. The Expr.iColumn value for the special 113aacc543eSdrh ** ROWID column is -1. Any INTEGER PRIMARY KEY column is tried as an 114aacc543eSdrh ** alias for ROWID. 11519a775c2Sdrh ** 116fef5208cSdrh ** We also check for instances of the IN operator. IN comes in two 117fef5208cSdrh ** forms: 118fef5208cSdrh ** 119fef5208cSdrh ** expr IN (exprlist) 120fef5208cSdrh ** and 121fef5208cSdrh ** expr IN (SELECT ...) 122fef5208cSdrh ** 123fef5208cSdrh ** The first form is handled by creating a set holding the list 124fef5208cSdrh ** of allowed values. The second form causes the SELECT to generate 125fef5208cSdrh ** a temporary table. 126fef5208cSdrh ** 127fef5208cSdrh ** This routine also looks for scalar SELECTs that are part of an expression. 12819a775c2Sdrh ** If it finds any, it generates code to write the value of that select 12919a775c2Sdrh ** into a memory cell. 130cce7d176Sdrh ** 131967e8b73Sdrh ** Unknown columns or tables provoke an error. The function returns 132cce7d176Sdrh ** the number of errors seen and leaves an error message on pParse->zErrMsg. 133cce7d176Sdrh */ 134*a2e00042Sdrh int sqliteExprResolveIds( 135*a2e00042Sdrh Parse *pParse, /* The parser context */ 136*a2e00042Sdrh IdList *pTabList, /* List of tables used to resolve column names */ 137*a2e00042Sdrh ExprList *pEList, /* List of expressions used to resolve "AS" */ 138*a2e00042Sdrh Expr *pExpr /* The expression to be analyzed. */ 139*a2e00042Sdrh ){ 140daffd0e5Sdrh if( pExpr==0 || pTabList==0 ) return 0; 141cce7d176Sdrh switch( pExpr->op ){ 142*a2e00042Sdrh /* A lone identifier. Try and match it as follows: 143*a2e00042Sdrh ** 144*a2e00042Sdrh ** 1. To the name of a column of one of the tables in pTabList 145*a2e00042Sdrh ** 146*a2e00042Sdrh ** 2. To the right side of an AS keyword in the column list of 147*a2e00042Sdrh ** a SELECT statement. (For example, match against 'x' in 148*a2e00042Sdrh ** "SELECT a+b AS 'x' FROM t1".) 149*a2e00042Sdrh ** 150*a2e00042Sdrh ** 3. One of the special names "ROWID", "OID", or "_ROWID_". 151*a2e00042Sdrh */ 152cce7d176Sdrh case TK_ID: { 153cce7d176Sdrh int cnt = 0; /* Number of matches */ 154cce7d176Sdrh int i; /* Loop counter */ 1556e142f54Sdrh char *z = sqliteStrNDup(pExpr->token.z, pExpr->token.n); 156daffd0e5Sdrh if( z==0 ) return 1; 157cce7d176Sdrh for(i=0; i<pTabList->nId; i++){ 158cce7d176Sdrh int j; 159cce7d176Sdrh Table *pTab = pTabList->a[i].pTab; 160cce7d176Sdrh if( pTab==0 ) continue; 161cce7d176Sdrh for(j=0; j<pTab->nCol; j++){ 1627020f651Sdrh if( sqliteStrICmp(pTab->aCol[j].zName, z)==0 ){ 163cce7d176Sdrh cnt++; 16419a775c2Sdrh pExpr->iTable = i + pParse->nTab; 1654a32431cSdrh if( j==pTab->iPKey ){ 1664a32431cSdrh /* Substitute the record number for the INTEGER PRIMARY KEY */ 1674a32431cSdrh pExpr->iColumn = -1; 1684a32431cSdrh }else{ 169967e8b73Sdrh pExpr->iColumn = j; 170cce7d176Sdrh } 171*a2e00042Sdrh pExpr->op = TK_COLUMN; 172*a2e00042Sdrh } 173*a2e00042Sdrh } 174*a2e00042Sdrh } 175*a2e00042Sdrh if( cnt==0 && pEList!=0 ){ 176*a2e00042Sdrh int j; 177*a2e00042Sdrh for(j=0; j<pEList->nExpr; j++){ 178*a2e00042Sdrh char *zAs = pEList->a[j].zName; 179*a2e00042Sdrh if( zAs!=0 && sqliteStrICmp(zAs, z)==0 ){ 180*a2e00042Sdrh cnt++; 181*a2e00042Sdrh assert( pExpr->pLeft==0 && pExpr->pRight==0 ); 182*a2e00042Sdrh pExpr->op = TK_AS; 183*a2e00042Sdrh pExpr->iColumn = j; 184*a2e00042Sdrh pExpr->pLeft = pEList->a[j].pExpr; 185cce7d176Sdrh } 186cce7d176Sdrh } 1874a32431cSdrh } 188c4a3c779Sdrh if( cnt==0 && sqliteIsRowid(z) ){ 189c4a3c779Sdrh pExpr->iColumn = -1; 190c4a3c779Sdrh pExpr->iTable = pParse->nTab; 191c4a3c779Sdrh cnt = 1 + (pTabList->nId>1); 192*a2e00042Sdrh pExpr->op = TK_COLUMN; 193c4a3c779Sdrh } 194cce7d176Sdrh sqliteFree(z); 195cce7d176Sdrh if( cnt==0 ){ 196967e8b73Sdrh sqliteSetNString(&pParse->zErrMsg, "no such column: ", -1, 197cce7d176Sdrh pExpr->token.z, pExpr->token.n, 0); 198cce7d176Sdrh pParse->nErr++; 199cce7d176Sdrh return 1; 200cce7d176Sdrh }else if( cnt>1 ){ 201967e8b73Sdrh sqliteSetNString(&pParse->zErrMsg, "ambiguous column name: ", -1, 202cce7d176Sdrh pExpr->token.z, pExpr->token.n, 0); 203cce7d176Sdrh pParse->nErr++; 204cce7d176Sdrh return 1; 205cce7d176Sdrh } 206cce7d176Sdrh break; 207cce7d176Sdrh } 208cce7d176Sdrh 209967e8b73Sdrh /* A table name and column name: ID.ID */ 210cce7d176Sdrh case TK_DOT: { 211cce7d176Sdrh int cnt = 0; /* Number of matches */ 212c4a3c779Sdrh int cntTab = 0; /* Number of matching tables */ 213cce7d176Sdrh int i; /* Loop counter */ 214cce7d176Sdrh Expr *pLeft, *pRight; /* Left and right subbranches of the expr */ 215cce7d176Sdrh char *zLeft, *zRight; /* Text of an identifier */ 216cce7d176Sdrh 217cce7d176Sdrh pLeft = pExpr->pLeft; 218cce7d176Sdrh pRight = pExpr->pRight; 219cce7d176Sdrh assert( pLeft && pLeft->op==TK_ID ); 220cce7d176Sdrh assert( pRight && pRight->op==TK_ID ); 2216e142f54Sdrh zLeft = sqliteStrNDup(pLeft->token.z, pLeft->token.n); 2226e142f54Sdrh zRight = sqliteStrNDup(pRight->token.z, pRight->token.n); 223daffd0e5Sdrh if( zLeft==0 || zRight==0 ){ 224daffd0e5Sdrh sqliteFree(zLeft); 225daffd0e5Sdrh sqliteFree(zRight); 226daffd0e5Sdrh return 1; 227daffd0e5Sdrh } 22887c40e88Sdrh sqliteDequote(zLeft); 22987c40e88Sdrh sqliteDequote(zRight); 230c4a3c779Sdrh pExpr->iTable = -1; 231cce7d176Sdrh for(i=0; i<pTabList->nId; i++){ 232cce7d176Sdrh int j; 233cce7d176Sdrh char *zTab; 234cce7d176Sdrh Table *pTab = pTabList->a[i].pTab; 235cce7d176Sdrh if( pTab==0 ) continue; 236cce7d176Sdrh if( pTabList->a[i].zAlias ){ 237cce7d176Sdrh zTab = pTabList->a[i].zAlias; 238cce7d176Sdrh }else{ 239cce7d176Sdrh zTab = pTab->zName; 240cce7d176Sdrh } 241cce7d176Sdrh if( sqliteStrICmp(zTab, zLeft)!=0 ) continue; 242c4a3c779Sdrh if( 0==(cntTab++) ) pExpr->iTable = i + pParse->nTab; 243cce7d176Sdrh for(j=0; j<pTab->nCol; j++){ 2447020f651Sdrh if( sqliteStrICmp(pTab->aCol[j].zName, zRight)==0 ){ 245cce7d176Sdrh cnt++; 24619a775c2Sdrh pExpr->iTable = i + pParse->nTab; 2474a32431cSdrh if( j==pTab->iPKey ){ 2484a32431cSdrh /* Substitute the record number for the INTEGER PRIMARY KEY */ 2494a32431cSdrh pExpr->iColumn = -1; 2504a32431cSdrh }else{ 251967e8b73Sdrh pExpr->iColumn = j; 252cce7d176Sdrh } 253cce7d176Sdrh } 254cce7d176Sdrh } 2554a32431cSdrh } 256c4a3c779Sdrh if( cnt==0 && cntTab==1 && sqliteIsRowid(zRight) ){ 257c4a3c779Sdrh cnt = 1; 258c4a3c779Sdrh pExpr->iColumn = -1; 259c4a3c779Sdrh } 260cce7d176Sdrh sqliteFree(zLeft); 261cce7d176Sdrh sqliteFree(zRight); 262cce7d176Sdrh if( cnt==0 ){ 263967e8b73Sdrh sqliteSetNString(&pParse->zErrMsg, "no such column: ", -1, 264cce7d176Sdrh pLeft->token.z, pLeft->token.n, ".", 1, 265cce7d176Sdrh pRight->token.z, pRight->token.n, 0); 266cce7d176Sdrh pParse->nErr++; 267cce7d176Sdrh return 1; 268cce7d176Sdrh }else if( cnt>1 ){ 269967e8b73Sdrh sqliteSetNString(&pParse->zErrMsg, "ambiguous column name: ", -1, 270cce7d176Sdrh pLeft->token.z, pLeft->token.n, ".", 1, 271cce7d176Sdrh pRight->token.z, pRight->token.n, 0); 272cce7d176Sdrh pParse->nErr++; 273cce7d176Sdrh return 1; 274cce7d176Sdrh } 275cce7d176Sdrh sqliteExprDelete(pLeft); 276cce7d176Sdrh pExpr->pLeft = 0; 277cce7d176Sdrh sqliteExprDelete(pRight); 278cce7d176Sdrh pExpr->pRight = 0; 279967e8b73Sdrh pExpr->op = TK_COLUMN; 280cce7d176Sdrh break; 281cce7d176Sdrh } 282cce7d176Sdrh 283fef5208cSdrh case TK_IN: { 284d8bc7086Sdrh Vdbe *v = sqliteGetVdbe(pParse); 285fef5208cSdrh if( v==0 ) return 1; 286*a2e00042Sdrh if( sqliteExprResolveIds(pParse, pTabList, pEList, pExpr->pLeft) ){ 287cfab11bcSdrh return 1; 288cfab11bcSdrh } 289fef5208cSdrh if( pExpr->pSelect ){ 290fef5208cSdrh /* Case 1: expr IN (SELECT ...) 291fef5208cSdrh ** 292fef5208cSdrh ** Generate code to write the results of the select into a temporary 2934794b980Sdrh ** table. The cursor number of the temporary table has already 2944794b980Sdrh ** been put in iTable by sqliteExprResolveInSelect(). 295fef5208cSdrh */ 296c6b52df3Sdrh sqliteVdbeAddOp(v, OP_OpenTemp, pExpr->iTable, 1); 297fef5208cSdrh if( sqliteSelect(pParse, pExpr->pSelect, SRT_Set, pExpr->iTable) ); 298fef5208cSdrh }else if( pExpr->pList ){ 299fef5208cSdrh /* Case 2: expr IN (exprlist) 300fef5208cSdrh ** 301fef5208cSdrh ** Create a set to put the exprlist values in. The Set id is stored 302fef5208cSdrh ** in iTable. 303fef5208cSdrh */ 304fef5208cSdrh int i, iSet; 305fef5208cSdrh for(i=0; i<pExpr->pList->nExpr; i++){ 306fef5208cSdrh Expr *pE2 = pExpr->pList->a[i].pExpr; 307fef5208cSdrh if( !isConstant(pE2) ){ 308fef5208cSdrh sqliteSetString(&pParse->zErrMsg, 309fef5208cSdrh "right-hand side of IN operator must be constant", 0); 310fef5208cSdrh pParse->nErr++; 311fef5208cSdrh return 1; 312fef5208cSdrh } 3134794b980Sdrh if( sqliteExprCheck(pParse, pE2, 0, 0) ){ 3144794b980Sdrh return 1; 3154794b980Sdrh } 316fef5208cSdrh } 317fef5208cSdrh iSet = pExpr->iTable = pParse->nSet++; 318fef5208cSdrh for(i=0; i<pExpr->pList->nExpr; i++){ 319fef5208cSdrh Expr *pE2 = pExpr->pList->a[i].pExpr; 320fef5208cSdrh switch( pE2->op ){ 321fef5208cSdrh case TK_FLOAT: 322fef5208cSdrh case TK_INTEGER: 323fef5208cSdrh case TK_STRING: { 32499fcd718Sdrh int addr = sqliteVdbeAddOp(v, OP_SetInsert, iSet, 0); 325fef5208cSdrh sqliteVdbeChangeP3(v, addr, pE2->token.z, pE2->token.n); 326fef5208cSdrh sqliteVdbeDequoteP3(v, addr); 327fef5208cSdrh break; 328fef5208cSdrh } 329fef5208cSdrh default: { 330fef5208cSdrh sqliteExprCode(pParse, pE2); 33199fcd718Sdrh sqliteVdbeAddOp(v, OP_SetInsert, iSet, 0); 332fef5208cSdrh break; 333fef5208cSdrh } 334fef5208cSdrh } 335fef5208cSdrh } 336fef5208cSdrh } 337cfab11bcSdrh break; 338fef5208cSdrh } 339fef5208cSdrh 34019a775c2Sdrh case TK_SELECT: { 341fef5208cSdrh /* This has to be a scalar SELECT. Generate code to put the 342fef5208cSdrh ** value of this select in a memory cell and record the number 343967e8b73Sdrh ** of the memory cell in iColumn. 344fef5208cSdrh */ 345967e8b73Sdrh pExpr->iColumn = pParse->nMem++; 346967e8b73Sdrh if( sqliteSelect(pParse, pExpr->pSelect, SRT_Mem, pExpr->iColumn) ){ 34719a775c2Sdrh return 1; 34819a775c2Sdrh } 34919a775c2Sdrh break; 35019a775c2Sdrh } 35119a775c2Sdrh 352cce7d176Sdrh /* For all else, just recursively walk the tree */ 353cce7d176Sdrh default: { 354cce7d176Sdrh if( pExpr->pLeft 355*a2e00042Sdrh && sqliteExprResolveIds(pParse, pTabList, pEList, pExpr->pLeft) ){ 356cce7d176Sdrh return 1; 357cce7d176Sdrh } 358cce7d176Sdrh if( pExpr->pRight 359*a2e00042Sdrh && sqliteExprResolveIds(pParse, pTabList, pEList, pExpr->pRight) ){ 360cce7d176Sdrh return 1; 361cce7d176Sdrh } 362cce7d176Sdrh if( pExpr->pList ){ 363cce7d176Sdrh int i; 364cce7d176Sdrh ExprList *pList = pExpr->pList; 365cce7d176Sdrh for(i=0; i<pList->nExpr; i++){ 366*a2e00042Sdrh if( sqliteExprResolveIds(pParse,pTabList,pEList,pList->a[i].pExpr) ){ 367cce7d176Sdrh return 1; 368cce7d176Sdrh } 369cce7d176Sdrh } 370cce7d176Sdrh } 371cce7d176Sdrh } 372cce7d176Sdrh } 373cce7d176Sdrh return 0; 374cce7d176Sdrh } 375cce7d176Sdrh 376cce7d176Sdrh #if 0 /* NOT USED */ 377cce7d176Sdrh /* 378cce7d176Sdrh ** Compare a token against a string. Return TRUE if they match. 379cce7d176Sdrh */ 380cce7d176Sdrh static int sqliteTokenCmp(Token *pToken, const char *zStr){ 381cce7d176Sdrh int n = strlen(zStr); 382cce7d176Sdrh if( n!=pToken->n ) return 0; 383cce7d176Sdrh return sqliteStrNICmp(pToken->z, zStr, n)==0; 384cce7d176Sdrh } 385cce7d176Sdrh #endif 386cce7d176Sdrh 387cce7d176Sdrh /* 388cce7d176Sdrh ** Convert a function name into its integer identifier. Return the 389cce7d176Sdrh ** identifier. Return FN_Unknown if the function name is unknown. 390cce7d176Sdrh */ 391cce7d176Sdrh int sqliteFuncId(Token *pToken){ 392cce7d176Sdrh static const struct { 393cce7d176Sdrh char *zName; 394cce7d176Sdrh int len; 395cce7d176Sdrh int id; 396cce7d176Sdrh } aFunc[] = { 397cce7d176Sdrh { "count", 5, FN_Count }, 398cce7d176Sdrh { "min", 3, FN_Min }, 399cce7d176Sdrh { "max", 3, FN_Max }, 400cce7d176Sdrh { "sum", 3, FN_Sum }, 4012282792aSdrh { "avg", 3, FN_Avg }, 4026ec2733bSdrh { "length", 6, FN_Length }, 4036ec2733bSdrh { "substr", 6, FN_Substr }, 404bf4133cbSdrh { "abs", 3, FN_Abs }, 405bf4133cbSdrh { "round", 5, FN_Round }, 406cce7d176Sdrh }; 407cce7d176Sdrh int i; 408cce7d176Sdrh for(i=0; i<ArraySize(aFunc); i++){ 409cce7d176Sdrh if( aFunc[i].len==pToken->n 410cce7d176Sdrh && sqliteStrNICmp(pToken->z, aFunc[i].zName, aFunc[i].len)==0 ){ 411cce7d176Sdrh return aFunc[i].id; 412cce7d176Sdrh } 413cce7d176Sdrh } 414cce7d176Sdrh return FN_Unknown; 415cce7d176Sdrh } 416cce7d176Sdrh 417cce7d176Sdrh /* 418cce7d176Sdrh ** Error check the functions in an expression. Make sure all 419cce7d176Sdrh ** function names are recognized and all functions have the correct 420cce7d176Sdrh ** number of arguments. Leave an error message in pParse->zErrMsg 421cce7d176Sdrh ** if anything is amiss. Return the number of errors. 422cce7d176Sdrh ** 423cce7d176Sdrh ** if pIsAgg is not null and this expression is an aggregate function 424cce7d176Sdrh ** (like count(*) or max(value)) then write a 1 into *pIsAgg. 425cce7d176Sdrh */ 426cce7d176Sdrh int sqliteExprCheck(Parse *pParse, Expr *pExpr, int allowAgg, int *pIsAgg){ 427cce7d176Sdrh int nErr = 0; 428cce7d176Sdrh if( pExpr==0 ) return 0; 429cce7d176Sdrh switch( pExpr->op ){ 430cce7d176Sdrh case TK_FUNCTION: { 431cce7d176Sdrh int id = sqliteFuncId(&pExpr->token); 432cce7d176Sdrh int n = pExpr->pList ? pExpr->pList->nExpr : 0; 433cce7d176Sdrh int no_such_func = 0; 434cce7d176Sdrh int too_many_args = 0; 435cce7d176Sdrh int too_few_args = 0; 436cce7d176Sdrh int is_agg = 0; 437cce7d176Sdrh int i; 438967e8b73Sdrh pExpr->iColumn = id; 439cce7d176Sdrh switch( id ){ 440cce7d176Sdrh case FN_Unknown: { 441cce7d176Sdrh no_such_func = 1; 442cce7d176Sdrh break; 443cce7d176Sdrh } 444cce7d176Sdrh case FN_Count: { 445cce7d176Sdrh no_such_func = !allowAgg; 446cce7d176Sdrh too_many_args = n>1; 447cce7d176Sdrh is_agg = 1; 448cce7d176Sdrh break; 449cce7d176Sdrh } 450cce7d176Sdrh case FN_Max: 451cce7d176Sdrh case FN_Min: { 452cce7d176Sdrh too_few_args = allowAgg ? n<1 : n<2; 453cce7d176Sdrh is_agg = n==1; 454cce7d176Sdrh break; 455cce7d176Sdrh } 4562282792aSdrh case FN_Avg: 457cce7d176Sdrh case FN_Sum: { 458cce7d176Sdrh no_such_func = !allowAgg; 459cce7d176Sdrh too_many_args = n>1; 460cce7d176Sdrh too_few_args = n<1; 461cce7d176Sdrh is_agg = 1; 462cce7d176Sdrh break; 463cce7d176Sdrh } 464bf4133cbSdrh case FN_Abs: 4656ec2733bSdrh case FN_Length: { 4666ec2733bSdrh too_few_args = n<1; 4676ec2733bSdrh too_many_args = n>1; 4686ec2733bSdrh break; 4696ec2733bSdrh } 470bf4133cbSdrh case FN_Round: { 471bf4133cbSdrh too_few_args = n<1; 472bf4133cbSdrh too_many_args = n>2; 473bf4133cbSdrh break; 474bf4133cbSdrh } 4756ec2733bSdrh case FN_Substr: { 4766ec2733bSdrh too_few_args = n<3; 4776ec2733bSdrh too_many_args = n>3; 4786ec2733bSdrh break; 4796ec2733bSdrh } 480cce7d176Sdrh default: break; 481cce7d176Sdrh } 482cce7d176Sdrh if( no_such_func ){ 483cce7d176Sdrh sqliteSetNString(&pParse->zErrMsg, "no such function: ", -1, 484cce7d176Sdrh pExpr->token.z, pExpr->token.n, 0); 485cce7d176Sdrh pParse->nErr++; 486cce7d176Sdrh nErr++; 487cce7d176Sdrh }else if( too_many_args ){ 488cce7d176Sdrh sqliteSetNString(&pParse->zErrMsg, "too many arguments to function ",-1, 489cce7d176Sdrh pExpr->token.z, pExpr->token.n, "()", 2, 0); 490cce7d176Sdrh pParse->nErr++; 491cce7d176Sdrh nErr++; 492cce7d176Sdrh }else if( too_few_args ){ 493cce7d176Sdrh sqliteSetNString(&pParse->zErrMsg, "too few arguments to function ",-1, 494cce7d176Sdrh pExpr->token.z, pExpr->token.n, "()", 2, 0); 495cce7d176Sdrh pParse->nErr++; 496cce7d176Sdrh nErr++; 497cce7d176Sdrh } 4982282792aSdrh if( is_agg ) pExpr->op = TK_AGG_FUNCTION; 499cce7d176Sdrh if( is_agg && pIsAgg ) *pIsAgg = 1; 500cce7d176Sdrh for(i=0; nErr==0 && i<n; i++){ 5014cfa7934Sdrh nErr = sqliteExprCheck(pParse, pExpr->pList->a[i].pExpr, 5024cfa7934Sdrh allowAgg && !is_agg, pIsAgg); 503cce7d176Sdrh } 504cce7d176Sdrh } 505cce7d176Sdrh default: { 506cce7d176Sdrh if( pExpr->pLeft ){ 5072282792aSdrh nErr = sqliteExprCheck(pParse, pExpr->pLeft, allowAgg, pIsAgg); 508cce7d176Sdrh } 509cce7d176Sdrh if( nErr==0 && pExpr->pRight ){ 5102282792aSdrh nErr = sqliteExprCheck(pParse, pExpr->pRight, allowAgg, pIsAgg); 511cce7d176Sdrh } 512fef5208cSdrh if( nErr==0 && pExpr->pList ){ 513fef5208cSdrh int n = pExpr->pList->nExpr; 514fef5208cSdrh int i; 515fef5208cSdrh for(i=0; nErr==0 && i<n; i++){ 5162282792aSdrh Expr *pE2 = pExpr->pList->a[i].pExpr; 5172282792aSdrh nErr = sqliteExprCheck(pParse, pE2, allowAgg, pIsAgg); 518fef5208cSdrh } 519fef5208cSdrh } 520cce7d176Sdrh break; 521cce7d176Sdrh } 522cce7d176Sdrh } 523cce7d176Sdrh return nErr; 524cce7d176Sdrh } 525cce7d176Sdrh 526cce7d176Sdrh /* 527cce7d176Sdrh ** Generate code into the current Vdbe to evaluate the given 5281ccde15dSdrh ** expression and leave the result on the top of stack. 529cce7d176Sdrh */ 530cce7d176Sdrh void sqliteExprCode(Parse *pParse, Expr *pExpr){ 531cce7d176Sdrh Vdbe *v = pParse->pVdbe; 532cce7d176Sdrh int op; 533daffd0e5Sdrh if( v==0 || pExpr==0 ) return; 534cce7d176Sdrh switch( pExpr->op ){ 535cce7d176Sdrh case TK_PLUS: op = OP_Add; break; 536cce7d176Sdrh case TK_MINUS: op = OP_Subtract; break; 537cce7d176Sdrh case TK_STAR: op = OP_Multiply; break; 538cce7d176Sdrh case TK_SLASH: op = OP_Divide; break; 539cce7d176Sdrh case TK_AND: op = OP_And; break; 540cce7d176Sdrh case TK_OR: op = OP_Or; break; 541cce7d176Sdrh case TK_LT: op = OP_Lt; break; 542cce7d176Sdrh case TK_LE: op = OP_Le; break; 543cce7d176Sdrh case TK_GT: op = OP_Gt; break; 544cce7d176Sdrh case TK_GE: op = OP_Ge; break; 545cce7d176Sdrh case TK_NE: op = OP_Ne; break; 546cce7d176Sdrh case TK_EQ: op = OP_Eq; break; 547cce7d176Sdrh case TK_LIKE: op = OP_Like; break; 548cce7d176Sdrh case TK_GLOB: op = OP_Glob; break; 549cce7d176Sdrh case TK_ISNULL: op = OP_IsNull; break; 550cce7d176Sdrh case TK_NOTNULL: op = OP_NotNull; break; 551cce7d176Sdrh case TK_NOT: op = OP_Not; break; 552cce7d176Sdrh case TK_UMINUS: op = OP_Negative; break; 553bf4133cbSdrh case TK_BITAND: op = OP_BitAnd; break; 554bf4133cbSdrh case TK_BITOR: op = OP_BitOr; break; 555bf4133cbSdrh case TK_BITNOT: op = OP_BitNot; break; 556bf4133cbSdrh case TK_LSHIFT: op = OP_ShiftLeft; break; 557bf4133cbSdrh case TK_RSHIFT: op = OP_ShiftRight; break; 558bf4133cbSdrh case TK_REM: op = OP_Remainder; break; 559cce7d176Sdrh default: break; 560cce7d176Sdrh } 561cce7d176Sdrh switch( pExpr->op ){ 562967e8b73Sdrh case TK_COLUMN: { 5632282792aSdrh if( pParse->useAgg ){ 56499fcd718Sdrh sqliteVdbeAddOp(v, OP_AggGet, 0, pExpr->iAgg); 565c4a3c779Sdrh }else if( pExpr->iColumn>=0 ){ 56699fcd718Sdrh sqliteVdbeAddOp(v, OP_Column, pExpr->iTable, pExpr->iColumn); 567c4a3c779Sdrh }else{ 56899fcd718Sdrh sqliteVdbeAddOp(v, OP_Recno, pExpr->iTable, 0); 5692282792aSdrh } 570cce7d176Sdrh break; 571cce7d176Sdrh } 572cce7d176Sdrh case TK_INTEGER: { 5737a7c7390Sdrh sqliteVdbeAddOp(v, OP_String, 0, 0); 5747a7c7390Sdrh sqliteVdbeChangeP3(v, -1, pExpr->token.z, pExpr->token.n); 575cce7d176Sdrh break; 576cce7d176Sdrh } 577cce7d176Sdrh case TK_FLOAT: { 57899fcd718Sdrh int addr = sqliteVdbeAddOp(v, OP_String, 0, 0); 579cce7d176Sdrh sqliteVdbeChangeP3(v, addr, pExpr->token.z, pExpr->token.n); 580cce7d176Sdrh break; 581cce7d176Sdrh } 582cce7d176Sdrh case TK_STRING: { 58399fcd718Sdrh int addr = sqliteVdbeAddOp(v, OP_String, 0, 0); 584cce7d176Sdrh sqliteVdbeChangeP3(v, addr, pExpr->token.z, pExpr->token.n); 585cce7d176Sdrh sqliteVdbeDequoteP3(v, addr); 586cce7d176Sdrh break; 587cce7d176Sdrh } 588cce7d176Sdrh case TK_NULL: { 58999fcd718Sdrh sqliteVdbeAddOp(v, OP_String, 0, 0); 590cce7d176Sdrh break; 591cce7d176Sdrh } 592cce7d176Sdrh case TK_AND: 593cce7d176Sdrh case TK_OR: 594cce7d176Sdrh case TK_PLUS: 595cce7d176Sdrh case TK_STAR: 596cce7d176Sdrh case TK_MINUS: 597bf4133cbSdrh case TK_REM: 598bf4133cbSdrh case TK_BITAND: 599bf4133cbSdrh case TK_BITOR: 600cce7d176Sdrh case TK_SLASH: { 601cce7d176Sdrh sqliteExprCode(pParse, pExpr->pLeft); 602cce7d176Sdrh sqliteExprCode(pParse, pExpr->pRight); 60399fcd718Sdrh sqliteVdbeAddOp(v, op, 0, 0); 604cce7d176Sdrh break; 605cce7d176Sdrh } 606bf4133cbSdrh case TK_LSHIFT: 607bf4133cbSdrh case TK_RSHIFT: { 608bf4133cbSdrh sqliteExprCode(pParse, pExpr->pRight); 609bf4133cbSdrh sqliteExprCode(pParse, pExpr->pLeft); 610bf4133cbSdrh sqliteVdbeAddOp(v, op, 0, 0); 611bf4133cbSdrh break; 612bf4133cbSdrh } 6130040077dSdrh case TK_CONCAT: { 6140040077dSdrh sqliteExprCode(pParse, pExpr->pLeft); 6150040077dSdrh sqliteExprCode(pParse, pExpr->pRight); 61699fcd718Sdrh sqliteVdbeAddOp(v, OP_Concat, 2, 0); 6170040077dSdrh break; 6180040077dSdrh } 619cce7d176Sdrh case TK_LT: 620cce7d176Sdrh case TK_LE: 621cce7d176Sdrh case TK_GT: 622cce7d176Sdrh case TK_GE: 623cce7d176Sdrh case TK_NE: 624cce7d176Sdrh case TK_EQ: 625cce7d176Sdrh case TK_LIKE: 626cce7d176Sdrh case TK_GLOB: { 627cce7d176Sdrh int dest; 62899fcd718Sdrh sqliteVdbeAddOp(v, OP_Integer, 1, 0); 629cce7d176Sdrh sqliteExprCode(pParse, pExpr->pLeft); 630cce7d176Sdrh sqliteExprCode(pParse, pExpr->pRight); 631cce7d176Sdrh dest = sqliteVdbeCurrentAddr(v) + 2; 63299fcd718Sdrh sqliteVdbeAddOp(v, op, 0, dest); 63399fcd718Sdrh sqliteVdbeAddOp(v, OP_AddImm, -1, 0); 634cce7d176Sdrh break; 635cce7d176Sdrh } 636cce7d176Sdrh case TK_UMINUS: { 6376e142f54Sdrh assert( pExpr->pLeft ); 6387a7c7390Sdrh if( pExpr->pLeft->op==TK_FLOAT || pExpr->pLeft->op==TK_INTEGER ){ 6396e142f54Sdrh Token *p = &pExpr->pLeft->token; 6406e142f54Sdrh char *z = sqliteMalloc( p->n + 2 ); 6416e142f54Sdrh sprintf(z, "-%.*s", p->n, p->z); 64299fcd718Sdrh sqliteVdbeAddOp(v, OP_String, 0, 0); 64399fcd718Sdrh sqliteVdbeChangeP3(v, -1, z, p->n+1); 6446e142f54Sdrh sqliteFree(z); 6456e142f54Sdrh break; 6466e142f54Sdrh } 6471ccde15dSdrh /* Fall through into TK_NOT */ 6486e142f54Sdrh } 649bf4133cbSdrh case TK_BITNOT: 6506e142f54Sdrh case TK_NOT: { 651cce7d176Sdrh sqliteExprCode(pParse, pExpr->pLeft); 65299fcd718Sdrh sqliteVdbeAddOp(v, op, 0, 0); 653cce7d176Sdrh break; 654cce7d176Sdrh } 655cce7d176Sdrh case TK_ISNULL: 656cce7d176Sdrh case TK_NOTNULL: { 657cce7d176Sdrh int dest; 65899fcd718Sdrh sqliteVdbeAddOp(v, OP_Integer, 1, 0); 659cce7d176Sdrh sqliteExprCode(pParse, pExpr->pLeft); 660cce7d176Sdrh dest = sqliteVdbeCurrentAddr(v) + 2; 66199fcd718Sdrh sqliteVdbeAddOp(v, op, 0, dest); 66299fcd718Sdrh sqliteVdbeAddOp(v, OP_AddImm, -1, 0); 663cce7d176Sdrh break; 664cce7d176Sdrh } 6652282792aSdrh case TK_AGG_FUNCTION: { 66699fcd718Sdrh sqliteVdbeAddOp(v, OP_AggGet, 0, pExpr->iAgg); 667967e8b73Sdrh if( pExpr->iColumn==FN_Avg ){ 6682282792aSdrh assert( pParse->iAggCount>=0 && pParse->iAggCount<pParse->nAgg ); 66999fcd718Sdrh sqliteVdbeAddOp(v, OP_AggGet, 0, pParse->iAggCount); 67099fcd718Sdrh sqliteVdbeAddOp(v, OP_Divide, 0, 0); 6712282792aSdrh } 6722282792aSdrh break; 6732282792aSdrh } 674cce7d176Sdrh case TK_FUNCTION: { 675967e8b73Sdrh int id = pExpr->iColumn; 676cce7d176Sdrh int op; 677cce7d176Sdrh int i; 678cce7d176Sdrh ExprList *pList = pExpr->pList; 6796ec2733bSdrh switch( id ){ 6806ec2733bSdrh case FN_Min: 6816ec2733bSdrh case FN_Max: { 682cce7d176Sdrh op = id==FN_Min ? OP_Min : OP_Max; 683cce7d176Sdrh for(i=0; i<pList->nExpr; i++){ 684cce7d176Sdrh sqliteExprCode(pParse, pList->a[i].pExpr); 685cce7d176Sdrh if( i>0 ){ 68699fcd718Sdrh sqliteVdbeAddOp(v, op, 0, 0); 687cce7d176Sdrh } 688cce7d176Sdrh } 689cce7d176Sdrh break; 690cce7d176Sdrh } 691bf4133cbSdrh case FN_Abs: { 692bf4133cbSdrh sqliteExprCode(pParse, pList->a[0].pExpr); 693bf4133cbSdrh sqliteVdbeAddOp(v, OP_AbsValue, 0, 0); 694bf4133cbSdrh break; 695bf4133cbSdrh } 696bf4133cbSdrh case FN_Round: { 697bf4133cbSdrh if( pList->nExpr==2 ){ 698bf4133cbSdrh sqliteExprCode(pParse, pList->a[1].pExpr); 699bf4133cbSdrh }else{ 700bf4133cbSdrh sqliteVdbeAddOp(v, OP_Integer, 0, 0); 701bf4133cbSdrh } 702bf4133cbSdrh sqliteExprCode(pParse, pList->a[0].pExpr); 703bf4133cbSdrh sqliteVdbeAddOp(v, OP_Precision, 0, 0); 704bf4133cbSdrh break; 705bf4133cbSdrh } 7066ec2733bSdrh case FN_Length: { 7076ec2733bSdrh sqliteExprCode(pParse, pList->a[0].pExpr); 70899fcd718Sdrh sqliteVdbeAddOp(v, OP_Strlen, 0, 0); 7096ec2733bSdrh break; 7106ec2733bSdrh } 7116ec2733bSdrh case FN_Substr: { 7126ec2733bSdrh for(i=0; i<pList->nExpr; i++){ 7136ec2733bSdrh sqliteExprCode(pParse, pList->a[i].pExpr); 7146ec2733bSdrh } 71599fcd718Sdrh sqliteVdbeAddOp(v, OP_Substr, 0, 0); 7166ec2733bSdrh break; 7176ec2733bSdrh } 7186ec2733bSdrh default: { 7196ec2733bSdrh /* Can't happen! */ 7206ec2733bSdrh break; 7216ec2733bSdrh } 7226ec2733bSdrh } 7236ec2733bSdrh break; 7246ec2733bSdrh } 72519a775c2Sdrh case TK_SELECT: { 72699fcd718Sdrh sqliteVdbeAddOp(v, OP_MemLoad, pExpr->iColumn, 0); 72719a775c2Sdrh break; 72819a775c2Sdrh } 729fef5208cSdrh case TK_IN: { 730fef5208cSdrh int addr; 73199fcd718Sdrh sqliteVdbeAddOp(v, OP_Integer, 1, 0); 732fef5208cSdrh sqliteExprCode(pParse, pExpr->pLeft); 733fef5208cSdrh addr = sqliteVdbeCurrentAddr(v); 734fef5208cSdrh if( pExpr->pSelect ){ 73599fcd718Sdrh sqliteVdbeAddOp(v, OP_Found, pExpr->iTable, addr+2); 736fef5208cSdrh }else{ 73799fcd718Sdrh sqliteVdbeAddOp(v, OP_SetFound, pExpr->iTable, addr+2); 738fef5208cSdrh } 73999fcd718Sdrh sqliteVdbeAddOp(v, OP_AddImm, -1, 0); 740fef5208cSdrh break; 741fef5208cSdrh } 742fef5208cSdrh case TK_BETWEEN: { 743fef5208cSdrh int lbl = sqliteVdbeMakeLabel(v); 74499fcd718Sdrh sqliteVdbeAddOp(v, OP_Integer, 0, 0); 745fef5208cSdrh sqliteExprIfFalse(pParse, pExpr, lbl); 74699fcd718Sdrh sqliteVdbeAddOp(v, OP_AddImm, 1, 0); 747fef5208cSdrh sqliteVdbeResolveLabel(v, lbl); 748fef5208cSdrh break; 749fef5208cSdrh } 750*a2e00042Sdrh case TK_AS: { 751*a2e00042Sdrh sqliteExprCode(pParse, pExpr->pLeft); 752*a2e00042Sdrh break; 753*a2e00042Sdrh } 754cce7d176Sdrh } 755cce7d176Sdrh return; 756cce7d176Sdrh } 757cce7d176Sdrh 758cce7d176Sdrh /* 759cce7d176Sdrh ** Generate code for a boolean expression such that a jump is made 760cce7d176Sdrh ** to the label "dest" if the expression is true but execution 761cce7d176Sdrh ** continues straight thru if the expression is false. 762cce7d176Sdrh */ 763cce7d176Sdrh void sqliteExprIfTrue(Parse *pParse, Expr *pExpr, int dest){ 764cce7d176Sdrh Vdbe *v = pParse->pVdbe; 765cce7d176Sdrh int op = 0; 766daffd0e5Sdrh if( v==0 || pExpr==0 ) return; 767cce7d176Sdrh switch( pExpr->op ){ 768cce7d176Sdrh case TK_LT: op = OP_Lt; break; 769cce7d176Sdrh case TK_LE: op = OP_Le; break; 770cce7d176Sdrh case TK_GT: op = OP_Gt; break; 771cce7d176Sdrh case TK_GE: op = OP_Ge; break; 772cce7d176Sdrh case TK_NE: op = OP_Ne; break; 773cce7d176Sdrh case TK_EQ: op = OP_Eq; break; 774cce7d176Sdrh case TK_LIKE: op = OP_Like; break; 775cce7d176Sdrh case TK_GLOB: op = OP_Glob; break; 776cce7d176Sdrh case TK_ISNULL: op = OP_IsNull; break; 777cce7d176Sdrh case TK_NOTNULL: op = OP_NotNull; break; 778cce7d176Sdrh default: break; 779cce7d176Sdrh } 780cce7d176Sdrh switch( pExpr->op ){ 781cce7d176Sdrh case TK_AND: { 782cce7d176Sdrh int d2 = sqliteVdbeMakeLabel(v); 783cce7d176Sdrh sqliteExprIfFalse(pParse, pExpr->pLeft, d2); 784cce7d176Sdrh sqliteExprIfTrue(pParse, pExpr->pRight, dest); 785cce7d176Sdrh sqliteVdbeResolveLabel(v, d2); 786cce7d176Sdrh break; 787cce7d176Sdrh } 788cce7d176Sdrh case TK_OR: { 789cce7d176Sdrh sqliteExprIfTrue(pParse, pExpr->pLeft, dest); 790cce7d176Sdrh sqliteExprIfTrue(pParse, pExpr->pRight, dest); 791cce7d176Sdrh break; 792cce7d176Sdrh } 793cce7d176Sdrh case TK_NOT: { 794cce7d176Sdrh sqliteExprIfFalse(pParse, pExpr->pLeft, dest); 795cce7d176Sdrh break; 796cce7d176Sdrh } 797cce7d176Sdrh case TK_LT: 798cce7d176Sdrh case TK_LE: 799cce7d176Sdrh case TK_GT: 800cce7d176Sdrh case TK_GE: 801cce7d176Sdrh case TK_NE: 802cce7d176Sdrh case TK_EQ: 803cce7d176Sdrh case TK_LIKE: 804cce7d176Sdrh case TK_GLOB: { 805cce7d176Sdrh sqliteExprCode(pParse, pExpr->pLeft); 806cce7d176Sdrh sqliteExprCode(pParse, pExpr->pRight); 80799fcd718Sdrh sqliteVdbeAddOp(v, op, 0, dest); 808cce7d176Sdrh break; 809cce7d176Sdrh } 810cce7d176Sdrh case TK_ISNULL: 811cce7d176Sdrh case TK_NOTNULL: { 812cce7d176Sdrh sqliteExprCode(pParse, pExpr->pLeft); 81399fcd718Sdrh sqliteVdbeAddOp(v, op, 0, dest); 814cce7d176Sdrh break; 815cce7d176Sdrh } 816fef5208cSdrh case TK_IN: { 817cfab11bcSdrh sqliteExprCode(pParse, pExpr->pLeft); 818fef5208cSdrh if( pExpr->pSelect ){ 81999fcd718Sdrh sqliteVdbeAddOp(v, OP_Found, pExpr->iTable, dest); 820fef5208cSdrh }else{ 82199fcd718Sdrh sqliteVdbeAddOp(v, OP_SetFound, pExpr->iTable, dest); 822fef5208cSdrh } 823fef5208cSdrh break; 824fef5208cSdrh } 825fef5208cSdrh case TK_BETWEEN: { 826fef5208cSdrh int lbl = sqliteVdbeMakeLabel(v); 827fef5208cSdrh sqliteExprCode(pParse, pExpr->pLeft); 82899fcd718Sdrh sqliteVdbeAddOp(v, OP_Dup, 0, 0); 829fef5208cSdrh sqliteExprCode(pParse, pExpr->pList->a[0].pExpr); 83099fcd718Sdrh sqliteVdbeAddOp(v, OP_Lt, 0, lbl); 831fef5208cSdrh sqliteExprCode(pParse, pExpr->pList->a[1].pExpr); 83299fcd718Sdrh sqliteVdbeAddOp(v, OP_Le, 0, dest); 83399fcd718Sdrh sqliteVdbeAddOp(v, OP_Integer, 0, 0); 83499fcd718Sdrh sqliteVdbeResolveLabel(v, lbl); 83599fcd718Sdrh sqliteVdbeAddOp(v, OP_Pop, 1, 0); 836fef5208cSdrh break; 837fef5208cSdrh } 838cce7d176Sdrh default: { 839cce7d176Sdrh sqliteExprCode(pParse, pExpr); 84099fcd718Sdrh sqliteVdbeAddOp(v, OP_If, 0, dest); 841cce7d176Sdrh break; 842cce7d176Sdrh } 843cce7d176Sdrh } 844cce7d176Sdrh } 845cce7d176Sdrh 846cce7d176Sdrh /* 84766b89c8fSdrh ** Generate code for a boolean expression such that a jump is made 848cce7d176Sdrh ** to the label "dest" if the expression is false but execution 849cce7d176Sdrh ** continues straight thru if the expression is true. 850cce7d176Sdrh */ 851cce7d176Sdrh void sqliteExprIfFalse(Parse *pParse, Expr *pExpr, int dest){ 852cce7d176Sdrh Vdbe *v = pParse->pVdbe; 853cce7d176Sdrh int op = 0; 854daffd0e5Sdrh if( v==0 || pExpr==0 ) return; 855cce7d176Sdrh switch( pExpr->op ){ 856cce7d176Sdrh case TK_LT: op = OP_Ge; break; 857cce7d176Sdrh case TK_LE: op = OP_Gt; break; 858cce7d176Sdrh case TK_GT: op = OP_Le; break; 859cce7d176Sdrh case TK_GE: op = OP_Lt; break; 860cce7d176Sdrh case TK_NE: op = OP_Eq; break; 861cce7d176Sdrh case TK_EQ: op = OP_Ne; break; 862cce7d176Sdrh case TK_LIKE: op = OP_Like; break; 863cce7d176Sdrh case TK_GLOB: op = OP_Glob; break; 864cce7d176Sdrh case TK_ISNULL: op = OP_NotNull; break; 865cce7d176Sdrh case TK_NOTNULL: op = OP_IsNull; break; 866cce7d176Sdrh default: break; 867cce7d176Sdrh } 868cce7d176Sdrh switch( pExpr->op ){ 869cce7d176Sdrh case TK_AND: { 870cce7d176Sdrh sqliteExprIfFalse(pParse, pExpr->pLeft, dest); 871cce7d176Sdrh sqliteExprIfFalse(pParse, pExpr->pRight, dest); 872cce7d176Sdrh break; 873cce7d176Sdrh } 874cce7d176Sdrh case TK_OR: { 875cce7d176Sdrh int d2 = sqliteVdbeMakeLabel(v); 876cce7d176Sdrh sqliteExprIfTrue(pParse, pExpr->pLeft, d2); 877cce7d176Sdrh sqliteExprIfFalse(pParse, pExpr->pRight, dest); 878cce7d176Sdrh sqliteVdbeResolveLabel(v, d2); 879cce7d176Sdrh break; 880cce7d176Sdrh } 881cce7d176Sdrh case TK_NOT: { 882cce7d176Sdrh sqliteExprIfTrue(pParse, pExpr->pLeft, dest); 883cce7d176Sdrh break; 884cce7d176Sdrh } 885cce7d176Sdrh case TK_LT: 886cce7d176Sdrh case TK_LE: 887cce7d176Sdrh case TK_GT: 888cce7d176Sdrh case TK_GE: 889cce7d176Sdrh case TK_NE: 890cce7d176Sdrh case TK_EQ: { 891cce7d176Sdrh sqliteExprCode(pParse, pExpr->pLeft); 892cce7d176Sdrh sqliteExprCode(pParse, pExpr->pRight); 89399fcd718Sdrh sqliteVdbeAddOp(v, op, 0, dest); 894cce7d176Sdrh break; 895cce7d176Sdrh } 896cce7d176Sdrh case TK_LIKE: 897cce7d176Sdrh case TK_GLOB: { 898cce7d176Sdrh sqliteExprCode(pParse, pExpr->pLeft); 899cce7d176Sdrh sqliteExprCode(pParse, pExpr->pRight); 90099fcd718Sdrh sqliteVdbeAddOp(v, op, 1, dest); 901cce7d176Sdrh break; 902cce7d176Sdrh } 903cce7d176Sdrh case TK_ISNULL: 904cce7d176Sdrh case TK_NOTNULL: { 905cce7d176Sdrh sqliteExprCode(pParse, pExpr->pLeft); 90699fcd718Sdrh sqliteVdbeAddOp(v, op, 0, dest); 907cce7d176Sdrh break; 908cce7d176Sdrh } 909fef5208cSdrh case TK_IN: { 910cfab11bcSdrh sqliteExprCode(pParse, pExpr->pLeft); 911fef5208cSdrh if( pExpr->pSelect ){ 91299fcd718Sdrh sqliteVdbeAddOp(v, OP_NotFound, pExpr->iTable, dest); 913fef5208cSdrh }else{ 91499fcd718Sdrh sqliteVdbeAddOp(v, OP_SetNotFound, pExpr->iTable, dest); 915fef5208cSdrh } 916fef5208cSdrh break; 917fef5208cSdrh } 918fef5208cSdrh case TK_BETWEEN: { 919fef5208cSdrh int addr; 920fef5208cSdrh sqliteExprCode(pParse, pExpr->pLeft); 92199fcd718Sdrh sqliteVdbeAddOp(v, OP_Dup, 0, 0); 922fef5208cSdrh sqliteExprCode(pParse, pExpr->pList->a[0].pExpr); 923fef5208cSdrh addr = sqliteVdbeCurrentAddr(v); 92499fcd718Sdrh sqliteVdbeAddOp(v, OP_Ge, 0, addr+3); 92599fcd718Sdrh sqliteVdbeAddOp(v, OP_Pop, 1, 0); 92699fcd718Sdrh sqliteVdbeAddOp(v, OP_Goto, 0, dest); 927fef5208cSdrh sqliteExprCode(pParse, pExpr->pList->a[1].pExpr); 92899fcd718Sdrh sqliteVdbeAddOp(v, OP_Gt, 0, dest); 929fef5208cSdrh break; 930fef5208cSdrh } 931cce7d176Sdrh default: { 932cce7d176Sdrh sqliteExprCode(pParse, pExpr); 93399fcd718Sdrh sqliteVdbeAddOp(v, OP_Not, 0, 0); 93499fcd718Sdrh sqliteVdbeAddOp(v, OP_If, 0, dest); 935cce7d176Sdrh break; 936cce7d176Sdrh } 937cce7d176Sdrh } 938cce7d176Sdrh } 9392282792aSdrh 9402282792aSdrh /* 9412282792aSdrh ** Do a deep comparison of two expression trees. Return TRUE (non-zero) 9422282792aSdrh ** if they are identical and return FALSE if they differ in any way. 9432282792aSdrh */ 944d8bc7086Sdrh int sqliteExprCompare(Expr *pA, Expr *pB){ 9452282792aSdrh int i; 9462282792aSdrh if( pA==0 ){ 9472282792aSdrh return pB==0; 9482282792aSdrh }else if( pB==0 ){ 9492282792aSdrh return 0; 9502282792aSdrh } 9512282792aSdrh if( pA->op!=pB->op ) return 0; 952d8bc7086Sdrh if( !sqliteExprCompare(pA->pLeft, pB->pLeft) ) return 0; 953d8bc7086Sdrh if( !sqliteExprCompare(pA->pRight, pB->pRight) ) return 0; 9542282792aSdrh if( pA->pList ){ 9552282792aSdrh if( pB->pList==0 ) return 0; 9562282792aSdrh if( pA->pList->nExpr!=pB->pList->nExpr ) return 0; 9572282792aSdrh for(i=0; i<pA->pList->nExpr; i++){ 958d8bc7086Sdrh if( !sqliteExprCompare(pA->pList->a[i].pExpr, pB->pList->a[i].pExpr) ){ 9592282792aSdrh return 0; 9602282792aSdrh } 9612282792aSdrh } 9622282792aSdrh }else if( pB->pList ){ 9632282792aSdrh return 0; 9642282792aSdrh } 9652282792aSdrh if( pA->pSelect || pB->pSelect ) return 0; 9662282792aSdrh if( pA->token.z ){ 9672282792aSdrh if( pB->token.z==0 ) return 0; 9682282792aSdrh if( pB->token.n!=pA->token.n ) return 0; 9692282792aSdrh if( sqliteStrNICmp(pA->token.z, pB->token.z, pA->token.n)!=0 ) return 0; 9702282792aSdrh } 9712282792aSdrh return 1; 9722282792aSdrh } 9732282792aSdrh 9742282792aSdrh /* 9752282792aSdrh ** Add a new element to the pParse->aAgg[] array and return its index. 9762282792aSdrh */ 9772282792aSdrh static int appendAggInfo(Parse *pParse){ 9782282792aSdrh if( (pParse->nAgg & 0x7)==0 ){ 9792282792aSdrh int amt = pParse->nAgg + 8; 9806d4abfbeSdrh AggExpr *aAgg = sqliteRealloc(pParse->aAgg, amt*sizeof(pParse->aAgg[0])); 9816d4abfbeSdrh if( aAgg==0 ){ 9822282792aSdrh return -1; 9832282792aSdrh } 9846d4abfbeSdrh pParse->aAgg = aAgg; 9852282792aSdrh } 9862282792aSdrh memset(&pParse->aAgg[pParse->nAgg], 0, sizeof(pParse->aAgg[0])); 9872282792aSdrh return pParse->nAgg++; 9882282792aSdrh } 9892282792aSdrh 9902282792aSdrh /* 9912282792aSdrh ** Analyze the given expression looking for aggregate functions and 9922282792aSdrh ** for variables that need to be added to the pParse->aAgg[] array. 9932282792aSdrh ** Make additional entries to the pParse->aAgg[] array as necessary. 9942282792aSdrh ** 9952282792aSdrh ** This routine should only be called after the expression has been 9962282792aSdrh ** analyzed by sqliteExprResolveIds() and sqliteExprCheck(). 9972282792aSdrh ** 9982282792aSdrh ** If errors are seen, leave an error message in zErrMsg and return 9992282792aSdrh ** the number of errors. 10002282792aSdrh */ 10012282792aSdrh int sqliteExprAnalyzeAggregates(Parse *pParse, Expr *pExpr){ 10022282792aSdrh int i; 10032282792aSdrh AggExpr *aAgg; 10042282792aSdrh int nErr = 0; 10052282792aSdrh 10062282792aSdrh if( pExpr==0 ) return 0; 10072282792aSdrh switch( pExpr->op ){ 1008967e8b73Sdrh case TK_COLUMN: { 10092282792aSdrh aAgg = pParse->aAgg; 10102282792aSdrh for(i=0; i<pParse->nAgg; i++){ 10112282792aSdrh if( aAgg[i].isAgg ) continue; 10122282792aSdrh if( aAgg[i].pExpr->iTable==pExpr->iTable 1013967e8b73Sdrh && aAgg[i].pExpr->iColumn==pExpr->iColumn ){ 10142282792aSdrh break; 10152282792aSdrh } 10162282792aSdrh } 10172282792aSdrh if( i>=pParse->nAgg ){ 10182282792aSdrh i = appendAggInfo(pParse); 10192282792aSdrh if( i<0 ) return 1; 10202282792aSdrh pParse->aAgg[i].isAgg = 0; 10212282792aSdrh pParse->aAgg[i].pExpr = pExpr; 10222282792aSdrh } 1023aaf88729Sdrh pExpr->iAgg = i; 10242282792aSdrh break; 10252282792aSdrh } 10262282792aSdrh case TK_AGG_FUNCTION: { 1027967e8b73Sdrh if( pExpr->iColumn==FN_Count || pExpr->iColumn==FN_Avg ){ 10282282792aSdrh if( pParse->iAggCount>=0 ){ 10292282792aSdrh i = pParse->iAggCount; 10302282792aSdrh }else{ 10312282792aSdrh i = appendAggInfo(pParse); 10322282792aSdrh if( i<0 ) return 1; 10332282792aSdrh pParse->aAgg[i].isAgg = 1; 10342282792aSdrh pParse->aAgg[i].pExpr = 0; 10352282792aSdrh pParse->iAggCount = i; 10362282792aSdrh } 1037967e8b73Sdrh if( pExpr->iColumn==FN_Count ){ 10382282792aSdrh pExpr->iAgg = i; 10392282792aSdrh break; 10402282792aSdrh } 10412282792aSdrh } 10422282792aSdrh aAgg = pParse->aAgg; 10432282792aSdrh for(i=0; i<pParse->nAgg; i++){ 10442282792aSdrh if( !aAgg[i].isAgg ) continue; 1045d8bc7086Sdrh if( sqliteExprCompare(aAgg[i].pExpr, pExpr) ){ 10462282792aSdrh break; 10472282792aSdrh } 10482282792aSdrh } 10492282792aSdrh if( i>=pParse->nAgg ){ 10502282792aSdrh i = appendAggInfo(pParse); 10512282792aSdrh if( i<0 ) return 1; 10522282792aSdrh pParse->aAgg[i].isAgg = 1; 10532282792aSdrh pParse->aAgg[i].pExpr = pExpr; 10542282792aSdrh } 10552282792aSdrh pExpr->iAgg = i; 10562282792aSdrh break; 10572282792aSdrh } 10582282792aSdrh default: { 10592282792aSdrh if( pExpr->pLeft ){ 10602282792aSdrh nErr = sqliteExprAnalyzeAggregates(pParse, pExpr->pLeft); 10612282792aSdrh } 10622282792aSdrh if( nErr==0 && pExpr->pRight ){ 10632282792aSdrh nErr = sqliteExprAnalyzeAggregates(pParse, pExpr->pRight); 10642282792aSdrh } 10652282792aSdrh if( nErr==0 && pExpr->pList ){ 10662282792aSdrh int n = pExpr->pList->nExpr; 10672282792aSdrh int i; 10682282792aSdrh for(i=0; nErr==0 && i<n; i++){ 10692282792aSdrh nErr = sqliteExprAnalyzeAggregates(pParse, pExpr->pList->a[i].pExpr); 10702282792aSdrh } 10712282792aSdrh } 10722282792aSdrh break; 10732282792aSdrh } 10742282792aSdrh } 10752282792aSdrh return nErr; 10762282792aSdrh } 1077