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*6a67fe8eSdanielk1977 ** $Id: expr.c,v 1.191 2005/02/04 04:07:17 danielk1977 Exp $ 16cce7d176Sdrh */ 17cce7d176Sdrh #include "sqliteInt.h" 1804738cb9Sdrh #include <ctype.h> 19a2e00042Sdrh 20e014a838Sdanielk1977 /* 21e014a838Sdanielk1977 ** Return the 'affinity' of the expression pExpr if any. 22e014a838Sdanielk1977 ** 23e014a838Sdanielk1977 ** If pExpr is a column, a reference to a column via an 'AS' alias, 24e014a838Sdanielk1977 ** or a sub-select with a column as the return value, then the 25e014a838Sdanielk1977 ** affinity of that column is returned. Otherwise, 0x00 is returned, 26e014a838Sdanielk1977 ** indicating no affinity for the expression. 27e014a838Sdanielk1977 ** 28e014a838Sdanielk1977 ** i.e. the WHERE clause expresssions in the following statements all 29e014a838Sdanielk1977 ** have an affinity: 30e014a838Sdanielk1977 ** 31e014a838Sdanielk1977 ** CREATE TABLE t1(a); 32e014a838Sdanielk1977 ** SELECT * FROM t1 WHERE a; 33e014a838Sdanielk1977 ** SELECT a AS b FROM t1 WHERE b; 34e014a838Sdanielk1977 ** SELECT * FROM t1 WHERE (select a from t1); 35e014a838Sdanielk1977 */ 36bf3b721fSdanielk1977 char sqlite3ExprAffinity(Expr *pExpr){ 37a37cdde0Sdanielk1977 if( pExpr->op==TK_AS ){ 38bf3b721fSdanielk1977 return sqlite3ExprAffinity(pExpr->pLeft); 39a37cdde0Sdanielk1977 } 40a37cdde0Sdanielk1977 if( pExpr->op==TK_SELECT ){ 41bf3b721fSdanielk1977 return sqlite3ExprAffinity(pExpr->pSelect->pEList->a[0].pExpr); 42a37cdde0Sdanielk1977 } 43a37cdde0Sdanielk1977 return pExpr->affinity; 44a37cdde0Sdanielk1977 } 45a37cdde0Sdanielk1977 4653db1458Sdrh /* 470202b29eSdanielk1977 ** Return the default collation sequence for the expression pExpr. If 480202b29eSdanielk1977 ** there is no default collation type, return 0. 490202b29eSdanielk1977 */ 507cedc8d4Sdanielk1977 CollSeq *sqlite3ExprCollSeq(Parse *pParse, Expr *pExpr){ 517cedc8d4Sdanielk1977 CollSeq *pColl = 0; 520202b29eSdanielk1977 if( pExpr ){ 537cedc8d4Sdanielk1977 pColl = pExpr->pColl; 547cedc8d4Sdanielk1977 if( pExpr->op==TK_AS && !pColl ){ 557cedc8d4Sdanielk1977 return sqlite3ExprCollSeq(pParse, pExpr->pLeft); 560202b29eSdanielk1977 } 570202b29eSdanielk1977 } 587cedc8d4Sdanielk1977 if( sqlite3CheckCollSeq(pParse, pColl) ){ 597cedc8d4Sdanielk1977 pColl = 0; 607cedc8d4Sdanielk1977 } 617cedc8d4Sdanielk1977 return pColl; 620202b29eSdanielk1977 } 630202b29eSdanielk1977 640202b29eSdanielk1977 /* 65626a879aSdrh ** pExpr is an operand of a comparison operator. aff2 is the 66626a879aSdrh ** type affinity of the other operand. This routine returns the 6753db1458Sdrh ** type affinity that should be used for the comparison operator. 6853db1458Sdrh */ 69e014a838Sdanielk1977 char sqlite3CompareAffinity(Expr *pExpr, char aff2){ 70bf3b721fSdanielk1977 char aff1 = sqlite3ExprAffinity(pExpr); 71e014a838Sdanielk1977 if( aff1 && aff2 ){ 72e014a838Sdanielk1977 /* Both sides of the comparison are columns. If one has numeric or 73e014a838Sdanielk1977 ** integer affinity, use that. Otherwise use no affinity. 74e014a838Sdanielk1977 */ 75e014a838Sdanielk1977 if( aff1==SQLITE_AFF_INTEGER || aff2==SQLITE_AFF_INTEGER ){ 76e014a838Sdanielk1977 return SQLITE_AFF_INTEGER; 77e014a838Sdanielk1977 }else if( aff1==SQLITE_AFF_NUMERIC || aff2==SQLITE_AFF_NUMERIC ){ 78e014a838Sdanielk1977 return SQLITE_AFF_NUMERIC; 79e014a838Sdanielk1977 }else{ 80e014a838Sdanielk1977 return SQLITE_AFF_NONE; 81e014a838Sdanielk1977 } 82e014a838Sdanielk1977 }else if( !aff1 && !aff2 ){ 835f6a87b3Sdrh /* Neither side of the comparison is a column. Compare the 845f6a87b3Sdrh ** results directly. 85e014a838Sdanielk1977 */ 865f6a87b3Sdrh /* return SQLITE_AFF_NUMERIC; // Ticket #805 */ 875f6a87b3Sdrh return SQLITE_AFF_NONE; 88e014a838Sdanielk1977 }else{ 89e014a838Sdanielk1977 /* One side is a column, the other is not. Use the columns affinity. */ 90e014a838Sdanielk1977 return (aff1 + aff2); 91e014a838Sdanielk1977 } 92e014a838Sdanielk1977 } 93e014a838Sdanielk1977 9453db1458Sdrh /* 9553db1458Sdrh ** pExpr is a comparison operator. Return the type affinity that should 9653db1458Sdrh ** be applied to both operands prior to doing the comparison. 9753db1458Sdrh */ 98e014a838Sdanielk1977 static char comparisonAffinity(Expr *pExpr){ 99e014a838Sdanielk1977 char aff; 100e014a838Sdanielk1977 assert( pExpr->op==TK_EQ || pExpr->op==TK_IN || pExpr->op==TK_LT || 101e014a838Sdanielk1977 pExpr->op==TK_GT || pExpr->op==TK_GE || pExpr->op==TK_LE || 102e014a838Sdanielk1977 pExpr->op==TK_NE ); 103e014a838Sdanielk1977 assert( pExpr->pLeft ); 104bf3b721fSdanielk1977 aff = sqlite3ExprAffinity(pExpr->pLeft); 105e014a838Sdanielk1977 if( pExpr->pRight ){ 106e014a838Sdanielk1977 aff = sqlite3CompareAffinity(pExpr->pRight, aff); 107e014a838Sdanielk1977 } 108e014a838Sdanielk1977 else if( pExpr->pSelect ){ 109e014a838Sdanielk1977 aff = sqlite3CompareAffinity(pExpr->pSelect->pEList->a[0].pExpr, aff); 110e014a838Sdanielk1977 } 111e014a838Sdanielk1977 else if( !aff ){ 112e014a838Sdanielk1977 aff = SQLITE_AFF_NUMERIC; 113e014a838Sdanielk1977 } 114e014a838Sdanielk1977 return aff; 115e014a838Sdanielk1977 } 116e014a838Sdanielk1977 117e014a838Sdanielk1977 /* 118e014a838Sdanielk1977 ** pExpr is a comparison expression, eg. '=', '<', IN(...) etc. 119e014a838Sdanielk1977 ** idx_affinity is the affinity of an indexed column. Return true 120e014a838Sdanielk1977 ** if the index with affinity idx_affinity may be used to implement 121e014a838Sdanielk1977 ** the comparison in pExpr. 122e014a838Sdanielk1977 */ 123e014a838Sdanielk1977 int sqlite3IndexAffinityOk(Expr *pExpr, char idx_affinity){ 124e014a838Sdanielk1977 char aff = comparisonAffinity(pExpr); 125e014a838Sdanielk1977 return 126e014a838Sdanielk1977 (aff==SQLITE_AFF_NONE) || 127e014a838Sdanielk1977 (aff==SQLITE_AFF_NUMERIC && idx_affinity==SQLITE_AFF_INTEGER) || 128e014a838Sdanielk1977 (aff==SQLITE_AFF_INTEGER && idx_affinity==SQLITE_AFF_NUMERIC) || 129e014a838Sdanielk1977 (aff==idx_affinity); 130e014a838Sdanielk1977 } 131e014a838Sdanielk1977 132a37cdde0Sdanielk1977 /* 133a37cdde0Sdanielk1977 ** Return the P1 value that should be used for a binary comparison 134a37cdde0Sdanielk1977 ** opcode (OP_Eq, OP_Ge etc.) used to compare pExpr1 and pExpr2. 135a37cdde0Sdanielk1977 ** If jumpIfNull is true, then set the low byte of the returned 136a37cdde0Sdanielk1977 ** P1 value to tell the opcode to jump if either expression 137a37cdde0Sdanielk1977 ** evaluates to NULL. 138a37cdde0Sdanielk1977 */ 139e014a838Sdanielk1977 static int binaryCompareP1(Expr *pExpr1, Expr *pExpr2, int jumpIfNull){ 140bf3b721fSdanielk1977 char aff = sqlite3ExprAffinity(pExpr2); 141e014a838Sdanielk1977 return (((int)sqlite3CompareAffinity(pExpr1, aff))<<8)+(jumpIfNull?1:0); 142a37cdde0Sdanielk1977 } 143a37cdde0Sdanielk1977 144a2e00042Sdrh /* 1450202b29eSdanielk1977 ** Return a pointer to the collation sequence that should be used by 1460202b29eSdanielk1977 ** a binary comparison operator comparing pLeft and pRight. 1470202b29eSdanielk1977 ** 1480202b29eSdanielk1977 ** If the left hand expression has a collating sequence type, then it is 1490202b29eSdanielk1977 ** used. Otherwise the collation sequence for the right hand expression 1500202b29eSdanielk1977 ** is used, or the default (BINARY) if neither expression has a collating 1510202b29eSdanielk1977 ** type. 1520202b29eSdanielk1977 */ 1537cedc8d4Sdanielk1977 static CollSeq* binaryCompareCollSeq(Parse *pParse, Expr *pLeft, Expr *pRight){ 1547cedc8d4Sdanielk1977 CollSeq *pColl = sqlite3ExprCollSeq(pParse, pLeft); 1550202b29eSdanielk1977 if( !pColl ){ 1567cedc8d4Sdanielk1977 pColl = sqlite3ExprCollSeq(pParse, pRight); 1570202b29eSdanielk1977 } 1580202b29eSdanielk1977 return pColl; 1590202b29eSdanielk1977 } 1600202b29eSdanielk1977 1610202b29eSdanielk1977 /* 162be5c89acSdrh ** Generate code for a comparison operator. 163be5c89acSdrh */ 164be5c89acSdrh static int codeCompare( 165be5c89acSdrh Parse *pParse, /* The parsing (and code generating) context */ 166be5c89acSdrh Expr *pLeft, /* The left operand */ 167be5c89acSdrh Expr *pRight, /* The right operand */ 168be5c89acSdrh int opcode, /* The comparison opcode */ 169be5c89acSdrh int dest, /* Jump here if true. */ 170be5c89acSdrh int jumpIfNull /* If true, jump if either operand is NULL */ 171be5c89acSdrh ){ 172be5c89acSdrh int p1 = binaryCompareP1(pLeft, pRight, jumpIfNull); 173be5c89acSdrh CollSeq *p3 = binaryCompareCollSeq(pParse, pLeft, pRight); 174be5c89acSdrh return sqlite3VdbeOp3(pParse->pVdbe, opcode, p1, dest, (void*)p3, P3_COLLSEQ); 175be5c89acSdrh } 176be5c89acSdrh 177be5c89acSdrh /* 178a76b5dfcSdrh ** Construct a new expression node and return a pointer to it. Memory 179a76b5dfcSdrh ** for this node is obtained from sqliteMalloc(). The calling function 180a76b5dfcSdrh ** is responsible for making sure the node eventually gets freed. 181a76b5dfcSdrh */ 182e4e72072Sdrh Expr *sqlite3Expr(int op, Expr *pLeft, Expr *pRight, const Token *pToken){ 183a76b5dfcSdrh Expr *pNew; 184a76b5dfcSdrh pNew = sqliteMalloc( sizeof(Expr) ); 185a76b5dfcSdrh if( pNew==0 ){ 1864efc4754Sdrh /* When malloc fails, we leak memory from pLeft and pRight */ 187a76b5dfcSdrh return 0; 188a76b5dfcSdrh } 189a76b5dfcSdrh pNew->op = op; 190a76b5dfcSdrh pNew->pLeft = pLeft; 191a76b5dfcSdrh pNew->pRight = pRight; 192a76b5dfcSdrh if( pToken ){ 1934b59ab5eSdrh assert( pToken->dyn==0 ); 194145716b3Sdrh pNew->span = pNew->token = *pToken; 195145716b3Sdrh }else if( pLeft && pRight ){ 1964adee20fSdanielk1977 sqlite3ExprSpan(pNew, &pLeft->span, &pRight->span); 197a76b5dfcSdrh } 198a76b5dfcSdrh return pNew; 199a76b5dfcSdrh } 200a76b5dfcSdrh 201a76b5dfcSdrh /* 2024e0cff60Sdrh ** When doing a nested parse, you can include terms in an expression 2034e0cff60Sdrh ** that look like this: #0 #1 #2 ... These terms refer to elements 2044e0cff60Sdrh ** on the stack. "#0" (or just "#") means the top of the stack. 2052958a4e6Sdrh ** "#1" means the next down on the stack. And so forth. #-1 means 2062958a4e6Sdrh ** memory location 0. #-2 means memory location 1. And so forth. 2074e0cff60Sdrh ** 2084e0cff60Sdrh ** This routine is called by the parser to deal with on of those terms. 2094e0cff60Sdrh ** It immediately generates code to store the value in a memory location. 2104e0cff60Sdrh ** The returns an expression that will code to extract the value from 2114e0cff60Sdrh ** that memory location as needed. 2124e0cff60Sdrh */ 2134e0cff60Sdrh Expr *sqlite3RegisterExpr(Parse *pParse, Token *pToken){ 2144e0cff60Sdrh Vdbe *v = pParse->pVdbe; 2154e0cff60Sdrh Expr *p; 2164e0cff60Sdrh int depth; 2174e0cff60Sdrh if( v==0 ) return 0; 2184e0cff60Sdrh if( pParse->nested==0 ){ 2194e0cff60Sdrh sqlite3ErrorMsg(pParse, "near \"%T\": syntax error", pToken); 2204e0cff60Sdrh return 0; 2214e0cff60Sdrh } 2224e0cff60Sdrh p = sqlite3Expr(TK_REGISTER, 0, 0, pToken); 22373c42a13Sdrh if( p==0 ){ 22473c42a13Sdrh return 0; /* Malloc failed */ 22573c42a13Sdrh } 2264e0cff60Sdrh depth = atoi(&pToken->z[1]); 2272958a4e6Sdrh if( depth>=0 ){ 2284e0cff60Sdrh p->iTable = pParse->nMem++; 2294e0cff60Sdrh sqlite3VdbeAddOp(v, OP_Dup, depth, 0); 2304e0cff60Sdrh sqlite3VdbeAddOp(v, OP_MemStore, p->iTable, 1); 2312958a4e6Sdrh }else{ 2322958a4e6Sdrh p->iTable = -1-depth; 2332958a4e6Sdrh } 2344e0cff60Sdrh return p; 2354e0cff60Sdrh } 2364e0cff60Sdrh 2374e0cff60Sdrh /* 23891bb0eedSdrh ** Join two expressions using an AND operator. If either expression is 23991bb0eedSdrh ** NULL, then just return the other expression. 24091bb0eedSdrh */ 24191bb0eedSdrh Expr *sqlite3ExprAnd(Expr *pLeft, Expr *pRight){ 24291bb0eedSdrh if( pLeft==0 ){ 24391bb0eedSdrh return pRight; 24491bb0eedSdrh }else if( pRight==0 ){ 24591bb0eedSdrh return pLeft; 24691bb0eedSdrh }else{ 24791bb0eedSdrh return sqlite3Expr(TK_AND, pLeft, pRight, 0); 24891bb0eedSdrh } 24991bb0eedSdrh } 25091bb0eedSdrh 25191bb0eedSdrh /* 2526977fea8Sdrh ** Set the Expr.span field of the given expression to span all 253a76b5dfcSdrh ** text between the two given tokens. 254a76b5dfcSdrh */ 2554adee20fSdanielk1977 void sqlite3ExprSpan(Expr *pExpr, Token *pLeft, Token *pRight){ 2564efc4754Sdrh assert( pRight!=0 ); 2574efc4754Sdrh assert( pLeft!=0 ); 25871c697efSdrh if( !sqlite3_malloc_failed && pRight->z && pLeft->z ){ 259ad6d9460Sdrh assert( pLeft->dyn==0 || pLeft->z[pLeft->n]==0 ); 260145716b3Sdrh if( pLeft->dyn==0 && pRight->dyn==0 ){ 2616977fea8Sdrh pExpr->span.z = pLeft->z; 2626977fea8Sdrh pExpr->span.n = pRight->n + Addr(pRight->z) - Addr(pLeft->z); 2634b59ab5eSdrh }else{ 2646977fea8Sdrh pExpr->span.z = 0; 2654b59ab5eSdrh } 266a76b5dfcSdrh } 267a76b5dfcSdrh } 268a76b5dfcSdrh 269a76b5dfcSdrh /* 270a76b5dfcSdrh ** Construct a new expression node for a function with multiple 271a76b5dfcSdrh ** arguments. 272a76b5dfcSdrh */ 2734adee20fSdanielk1977 Expr *sqlite3ExprFunction(ExprList *pList, Token *pToken){ 274a76b5dfcSdrh Expr *pNew; 275a76b5dfcSdrh pNew = sqliteMalloc( sizeof(Expr) ); 276a76b5dfcSdrh if( pNew==0 ){ 2774adee20fSdanielk1977 /* sqlite3ExprListDelete(pList); // Leak pList when malloc fails */ 278a76b5dfcSdrh return 0; 279a76b5dfcSdrh } 280a76b5dfcSdrh pNew->op = TK_FUNCTION; 281a76b5dfcSdrh pNew->pList = pList; 282a76b5dfcSdrh if( pToken ){ 2834b59ab5eSdrh assert( pToken->dyn==0 ); 284a76b5dfcSdrh pNew->token = *pToken; 285a76b5dfcSdrh }else{ 286a76b5dfcSdrh pNew->token.z = 0; 287a76b5dfcSdrh } 2886977fea8Sdrh pNew->span = pNew->token; 289a76b5dfcSdrh return pNew; 290a76b5dfcSdrh } 291a76b5dfcSdrh 292a76b5dfcSdrh /* 293fa6bc000Sdrh ** Assign a variable number to an expression that encodes a wildcard 294fa6bc000Sdrh ** in the original SQL statement. 295fa6bc000Sdrh ** 296fa6bc000Sdrh ** Wildcards consisting of a single "?" are assigned the next sequential 297fa6bc000Sdrh ** variable number. 298fa6bc000Sdrh ** 299fa6bc000Sdrh ** Wildcards of the form "?nnn" are assigned the number "nnn". We make 300fa6bc000Sdrh ** sure "nnn" is not too be to avoid a denial of service attack when 301fa6bc000Sdrh ** the SQL statement comes from an external source. 302fa6bc000Sdrh ** 303fa6bc000Sdrh ** Wildcards of the form ":aaa" or "$aaa" are assigned the same number 304fa6bc000Sdrh ** as the previous instance of the same wildcard. Or if this is the first 305fa6bc000Sdrh ** instance of the wildcard, the next sequenial variable number is 306fa6bc000Sdrh ** assigned. 307fa6bc000Sdrh */ 308fa6bc000Sdrh void sqlite3ExprAssignVarNumber(Parse *pParse, Expr *pExpr){ 309fa6bc000Sdrh Token *pToken; 310fa6bc000Sdrh if( pExpr==0 ) return; 311fa6bc000Sdrh pToken = &pExpr->token; 312fa6bc000Sdrh assert( pToken->n>=1 ); 313fa6bc000Sdrh assert( pToken->z!=0 ); 314fa6bc000Sdrh assert( pToken->z[0]!=0 ); 315fa6bc000Sdrh if( pToken->n==1 ){ 316fa6bc000Sdrh /* Wildcard of the form "?". Assign the next variable number */ 317fa6bc000Sdrh pExpr->iTable = ++pParse->nVar; 318fa6bc000Sdrh }else if( pToken->z[0]=='?' ){ 319fa6bc000Sdrh /* Wildcard of the form "?nnn". Convert "nnn" to an integer and 320fa6bc000Sdrh ** use it as the variable number */ 321fa6bc000Sdrh int i; 322fa6bc000Sdrh pExpr->iTable = i = atoi(&pToken->z[1]); 323fa6bc000Sdrh if( i<1 || i>SQLITE_MAX_VARIABLE_NUMBER ){ 324fa6bc000Sdrh sqlite3ErrorMsg(pParse, "variable number must be between ?1 and ?%d", 325fa6bc000Sdrh SQLITE_MAX_VARIABLE_NUMBER); 326fa6bc000Sdrh } 327fa6bc000Sdrh if( i>pParse->nVar ){ 328fa6bc000Sdrh pParse->nVar = i; 329fa6bc000Sdrh } 330fa6bc000Sdrh }else{ 331fa6bc000Sdrh /* Wildcards of the form ":aaa" or "$aaa". Reuse the same variable 332fa6bc000Sdrh ** number as the prior appearance of the same name, or if the name 333fa6bc000Sdrh ** has never appeared before, reuse the same variable number 334fa6bc000Sdrh */ 335fa6bc000Sdrh int i, n; 336fa6bc000Sdrh n = pToken->n; 337fa6bc000Sdrh for(i=0; i<pParse->nVarExpr; i++){ 338fa6bc000Sdrh Expr *pE; 339fa6bc000Sdrh if( (pE = pParse->apVarExpr[i])!=0 340fa6bc000Sdrh && pE->token.n==n 341fa6bc000Sdrh && memcmp(pE->token.z, pToken->z, n)==0 ){ 342fa6bc000Sdrh pExpr->iTable = pE->iTable; 343fa6bc000Sdrh break; 344fa6bc000Sdrh } 345fa6bc000Sdrh } 346fa6bc000Sdrh if( i>=pParse->nVarExpr ){ 347fa6bc000Sdrh pExpr->iTable = ++pParse->nVar; 348fa6bc000Sdrh if( pParse->nVarExpr>=pParse->nVarExprAlloc-1 ){ 349fa6bc000Sdrh pParse->nVarExprAlloc += pParse->nVarExprAlloc + 10; 350fa6bc000Sdrh pParse->apVarExpr = sqliteRealloc(pParse->apVarExpr, 351fa6bc000Sdrh pParse->nVarExprAlloc*sizeof(pParse->apVarExpr[0]) ); 352fa6bc000Sdrh } 353fa6bc000Sdrh if( !sqlite3_malloc_failed ){ 354fa6bc000Sdrh assert( pParse->apVarExpr!=0 ); 355fa6bc000Sdrh pParse->apVarExpr[pParse->nVarExpr++] = pExpr; 356fa6bc000Sdrh } 357fa6bc000Sdrh } 358fa6bc000Sdrh } 359fa6bc000Sdrh } 360fa6bc000Sdrh 361fa6bc000Sdrh /* 362a2e00042Sdrh ** Recursively delete an expression tree. 363a2e00042Sdrh */ 3644adee20fSdanielk1977 void sqlite3ExprDelete(Expr *p){ 365a2e00042Sdrh if( p==0 ) return; 3664efc4754Sdrh if( p->span.dyn ) sqliteFree((char*)p->span.z); 3674efc4754Sdrh if( p->token.dyn ) sqliteFree((char*)p->token.z); 3684adee20fSdanielk1977 sqlite3ExprDelete(p->pLeft); 3694adee20fSdanielk1977 sqlite3ExprDelete(p->pRight); 3704adee20fSdanielk1977 sqlite3ExprListDelete(p->pList); 3714adee20fSdanielk1977 sqlite3SelectDelete(p->pSelect); 372a2e00042Sdrh sqliteFree(p); 373a2e00042Sdrh } 374a2e00042Sdrh 375a76b5dfcSdrh 376a76b5dfcSdrh /* 377ff78bd2fSdrh ** The following group of routines make deep copies of expressions, 378ff78bd2fSdrh ** expression lists, ID lists, and select statements. The copies can 379ff78bd2fSdrh ** be deleted (by being passed to their respective ...Delete() routines) 380ff78bd2fSdrh ** without effecting the originals. 381ff78bd2fSdrh ** 3824adee20fSdanielk1977 ** The expression list, ID, and source lists return by sqlite3ExprListDup(), 3834adee20fSdanielk1977 ** sqlite3IdListDup(), and sqlite3SrcListDup() can not be further expanded 384ad3cab52Sdrh ** by subsequent calls to sqlite*ListAppend() routines. 385ff78bd2fSdrh ** 386ad3cab52Sdrh ** Any tables that the SrcList might point to are not duplicated. 387ff78bd2fSdrh */ 3884adee20fSdanielk1977 Expr *sqlite3ExprDup(Expr *p){ 389ff78bd2fSdrh Expr *pNew; 390ff78bd2fSdrh if( p==0 ) return 0; 391fcb78a49Sdrh pNew = sqliteMallocRaw( sizeof(*p) ); 392ff78bd2fSdrh if( pNew==0 ) return 0; 3933b167c75Sdrh memcpy(pNew, p, sizeof(*pNew)); 3946977fea8Sdrh if( p->token.z!=0 ){ 395b9ecf6faSdrh pNew->token.z = sqliteStrNDup(p->token.z, p->token.n); 3964b59ab5eSdrh pNew->token.dyn = 1; 3974b59ab5eSdrh }else{ 3984efc4754Sdrh assert( pNew->token.z==0 ); 3994b59ab5eSdrh } 4006977fea8Sdrh pNew->span.z = 0; 4014adee20fSdanielk1977 pNew->pLeft = sqlite3ExprDup(p->pLeft); 4024adee20fSdanielk1977 pNew->pRight = sqlite3ExprDup(p->pRight); 4034adee20fSdanielk1977 pNew->pList = sqlite3ExprListDup(p->pList); 4044adee20fSdanielk1977 pNew->pSelect = sqlite3SelectDup(p->pSelect); 405ff78bd2fSdrh return pNew; 406ff78bd2fSdrh } 4074adee20fSdanielk1977 void sqlite3TokenCopy(Token *pTo, Token *pFrom){ 4084b59ab5eSdrh if( pTo->dyn ) sqliteFree((char*)pTo->z); 4094b59ab5eSdrh if( pFrom->z ){ 4104b59ab5eSdrh pTo->n = pFrom->n; 4114b59ab5eSdrh pTo->z = sqliteStrNDup(pFrom->z, pFrom->n); 4124b59ab5eSdrh pTo->dyn = 1; 4134b59ab5eSdrh }else{ 4144b59ab5eSdrh pTo->z = 0; 4154b59ab5eSdrh } 4164b59ab5eSdrh } 4174adee20fSdanielk1977 ExprList *sqlite3ExprListDup(ExprList *p){ 418ff78bd2fSdrh ExprList *pNew; 419145716b3Sdrh struct ExprList_item *pItem, *pOldItem; 420ff78bd2fSdrh int i; 421ff78bd2fSdrh if( p==0 ) return 0; 422ff78bd2fSdrh pNew = sqliteMalloc( sizeof(*pNew) ); 423ff78bd2fSdrh if( pNew==0 ) return 0; 4244305d103Sdrh pNew->nExpr = pNew->nAlloc = p->nExpr; 4253e7bc9caSdrh pNew->a = pItem = sqliteMalloc( p->nExpr*sizeof(p->a[0]) ); 426e0048400Sdanielk1977 if( pItem==0 ){ 427e0048400Sdanielk1977 sqliteFree(pNew); 428e0048400Sdanielk1977 return 0; 429e0048400Sdanielk1977 } 430145716b3Sdrh pOldItem = p->a; 431145716b3Sdrh for(i=0; i<p->nExpr; i++, pItem++, pOldItem++){ 4324b59ab5eSdrh Expr *pNewExpr, *pOldExpr; 433145716b3Sdrh pItem->pExpr = pNewExpr = sqlite3ExprDup(pOldExpr = pOldItem->pExpr); 4346977fea8Sdrh if( pOldExpr->span.z!=0 && pNewExpr ){ 4356977fea8Sdrh /* Always make a copy of the span for top-level expressions in the 4364b59ab5eSdrh ** expression list. The logic in SELECT processing that determines 4374b59ab5eSdrh ** the names of columns in the result set needs this information */ 4384adee20fSdanielk1977 sqlite3TokenCopy(&pNewExpr->span, &pOldExpr->span); 4394b59ab5eSdrh } 4401f3e905cSdrh assert( pNewExpr==0 || pNewExpr->span.z!=0 44124b03fd0Sdanielk1977 || pOldExpr->span.z==0 || sqlite3_malloc_failed ); 442145716b3Sdrh pItem->zName = sqliteStrDup(pOldItem->zName); 443145716b3Sdrh pItem->sortOrder = pOldItem->sortOrder; 444145716b3Sdrh pItem->isAgg = pOldItem->isAgg; 4453e7bc9caSdrh pItem->done = 0; 446ff78bd2fSdrh } 447ff78bd2fSdrh return pNew; 448ff78bd2fSdrh } 44993758c8dSdanielk1977 45093758c8dSdanielk1977 /* 45193758c8dSdanielk1977 ** If cursors, triggers, views and subqueries are all omitted from 45293758c8dSdanielk1977 ** the build, then none of the following routines, except for 45393758c8dSdanielk1977 ** sqlite3SelectDup(), can be called. sqlite3SelectDup() is sometimes 45493758c8dSdanielk1977 ** called with a NULL argument. 45593758c8dSdanielk1977 */ 456*6a67fe8eSdanielk1977 #if !defined(SQLITE_OMIT_VIEW) || !defined(SQLITE_OMIT_TRIGGER) \ 457*6a67fe8eSdanielk1977 || !defined(SQLITE_OMIT_SUBQUERY) 4584adee20fSdanielk1977 SrcList *sqlite3SrcListDup(SrcList *p){ 459ad3cab52Sdrh SrcList *pNew; 460ad3cab52Sdrh int i; 461113088ecSdrh int nByte; 462ad3cab52Sdrh if( p==0 ) return 0; 463113088ecSdrh nByte = sizeof(*p) + (p->nSrc>0 ? sizeof(p->a[0]) * (p->nSrc-1) : 0); 4644efc4754Sdrh pNew = sqliteMallocRaw( nByte ); 465ad3cab52Sdrh if( pNew==0 ) return 0; 4664305d103Sdrh pNew->nSrc = pNew->nAlloc = p->nSrc; 467ad3cab52Sdrh for(i=0; i<p->nSrc; i++){ 4684efc4754Sdrh struct SrcList_item *pNewItem = &pNew->a[i]; 4694efc4754Sdrh struct SrcList_item *pOldItem = &p->a[i]; 4704efc4754Sdrh pNewItem->zDatabase = sqliteStrDup(pOldItem->zDatabase); 4714efc4754Sdrh pNewItem->zName = sqliteStrDup(pOldItem->zName); 4724efc4754Sdrh pNewItem->zAlias = sqliteStrDup(pOldItem->zAlias); 4734efc4754Sdrh pNewItem->jointype = pOldItem->jointype; 4744efc4754Sdrh pNewItem->iCursor = pOldItem->iCursor; 4754efc4754Sdrh pNewItem->pTab = 0; 4764adee20fSdanielk1977 pNewItem->pSelect = sqlite3SelectDup(pOldItem->pSelect); 4774adee20fSdanielk1977 pNewItem->pOn = sqlite3ExprDup(pOldItem->pOn); 4784adee20fSdanielk1977 pNewItem->pUsing = sqlite3IdListDup(pOldItem->pUsing); 4796c18b6e0Sdanielk1977 pNewItem->colUsed = pOldItem->colUsed; 480ad3cab52Sdrh } 481ad3cab52Sdrh return pNew; 482ad3cab52Sdrh } 4834adee20fSdanielk1977 IdList *sqlite3IdListDup(IdList *p){ 484ff78bd2fSdrh IdList *pNew; 485ff78bd2fSdrh int i; 486ff78bd2fSdrh if( p==0 ) return 0; 4874efc4754Sdrh pNew = sqliteMallocRaw( sizeof(*pNew) ); 488ff78bd2fSdrh if( pNew==0 ) return 0; 4894305d103Sdrh pNew->nId = pNew->nAlloc = p->nId; 4904efc4754Sdrh pNew->a = sqliteMallocRaw( p->nId*sizeof(p->a[0]) ); 491e4697f5eSdrh if( pNew->a==0 ) return 0; 492ff78bd2fSdrh for(i=0; i<p->nId; i++){ 4934efc4754Sdrh struct IdList_item *pNewItem = &pNew->a[i]; 4944efc4754Sdrh struct IdList_item *pOldItem = &p->a[i]; 4954efc4754Sdrh pNewItem->zName = sqliteStrDup(pOldItem->zName); 4964efc4754Sdrh pNewItem->idx = pOldItem->idx; 497ff78bd2fSdrh } 498ff78bd2fSdrh return pNew; 499ff78bd2fSdrh } 5004adee20fSdanielk1977 Select *sqlite3SelectDup(Select *p){ 501ff78bd2fSdrh Select *pNew; 502ff78bd2fSdrh if( p==0 ) return 0; 5034efc4754Sdrh pNew = sqliteMallocRaw( sizeof(*p) ); 504ff78bd2fSdrh if( pNew==0 ) return 0; 505ff78bd2fSdrh pNew->isDistinct = p->isDistinct; 5064adee20fSdanielk1977 pNew->pEList = sqlite3ExprListDup(p->pEList); 5074adee20fSdanielk1977 pNew->pSrc = sqlite3SrcListDup(p->pSrc); 5084adee20fSdanielk1977 pNew->pWhere = sqlite3ExprDup(p->pWhere); 5094adee20fSdanielk1977 pNew->pGroupBy = sqlite3ExprListDup(p->pGroupBy); 5104adee20fSdanielk1977 pNew->pHaving = sqlite3ExprDup(p->pHaving); 5114adee20fSdanielk1977 pNew->pOrderBy = sqlite3ExprListDup(p->pOrderBy); 512ff78bd2fSdrh pNew->op = p->op; 5134adee20fSdanielk1977 pNew->pPrior = sqlite3SelectDup(p->pPrior); 514ff78bd2fSdrh pNew->nLimit = p->nLimit; 515ff78bd2fSdrh pNew->nOffset = p->nOffset; 5167b58daeaSdrh pNew->iLimit = -1; 5177b58daeaSdrh pNew->iOffset = -1; 518dc1bdc4fSdanielk1977 pNew->ppOpenTemp = 0; 519b6c29897Sdrh pNew->pFetch = 0; 520b3bce662Sdanielk1977 pNew->isResolved = 0; 521b3bce662Sdanielk1977 pNew->isAgg = 0; 522ff78bd2fSdrh return pNew; 523ff78bd2fSdrh } 52493758c8dSdanielk1977 #else 52593758c8dSdanielk1977 Select *sqlite3SelectDup(Select *p){ 52693758c8dSdanielk1977 assert( p==0 ); 52793758c8dSdanielk1977 return 0; 52893758c8dSdanielk1977 } 52993758c8dSdanielk1977 #endif 530ff78bd2fSdrh 531ff78bd2fSdrh 532ff78bd2fSdrh /* 533a76b5dfcSdrh ** Add a new element to the end of an expression list. If pList is 534a76b5dfcSdrh ** initially NULL, then create a new expression list. 535a76b5dfcSdrh */ 5364adee20fSdanielk1977 ExprList *sqlite3ExprListAppend(ExprList *pList, Expr *pExpr, Token *pName){ 537a76b5dfcSdrh if( pList==0 ){ 538a76b5dfcSdrh pList = sqliteMalloc( sizeof(ExprList) ); 539a76b5dfcSdrh if( pList==0 ){ 5404adee20fSdanielk1977 /* sqlite3ExprDelete(pExpr); // Leak memory if malloc fails */ 541a76b5dfcSdrh return 0; 542a76b5dfcSdrh } 5434efc4754Sdrh assert( pList->nAlloc==0 ); 544a76b5dfcSdrh } 5454305d103Sdrh if( pList->nAlloc<=pList->nExpr ){ 5464305d103Sdrh pList->nAlloc = pList->nAlloc*2 + 4; 5474efc4754Sdrh pList->a = sqliteRealloc(pList->a, pList->nAlloc*sizeof(pList->a[0])); 5484efc4754Sdrh if( pList->a==0 ){ 5494adee20fSdanielk1977 /* sqlite3ExprDelete(pExpr); // Leak memory if malloc fails */ 5504efc4754Sdrh pList->nExpr = pList->nAlloc = 0; 551a76b5dfcSdrh return pList; 552a76b5dfcSdrh } 553a76b5dfcSdrh } 5544efc4754Sdrh assert( pList->a!=0 ); 5554efc4754Sdrh if( pExpr || pName ){ 5564efc4754Sdrh struct ExprList_item *pItem = &pList->a[pList->nExpr++]; 5574efc4754Sdrh memset(pItem, 0, sizeof(*pItem)); 5584efc4754Sdrh pItem->pExpr = pExpr; 559a99db3b6Sdrh pItem->zName = sqlite3NameFromToken(pName); 560a76b5dfcSdrh } 561a76b5dfcSdrh return pList; 562a76b5dfcSdrh } 563a76b5dfcSdrh 564a76b5dfcSdrh /* 565a76b5dfcSdrh ** Delete an entire expression list. 566a76b5dfcSdrh */ 5674adee20fSdanielk1977 void sqlite3ExprListDelete(ExprList *pList){ 568a76b5dfcSdrh int i; 569be5c89acSdrh struct ExprList_item *pItem; 570a76b5dfcSdrh if( pList==0 ) return; 5711bdd9b57Sdrh assert( pList->a!=0 || (pList->nExpr==0 && pList->nAlloc==0) ); 5721bdd9b57Sdrh assert( pList->nExpr<=pList->nAlloc ); 573be5c89acSdrh for(pItem=pList->a, i=0; i<pList->nExpr; i++, pItem++){ 574be5c89acSdrh sqlite3ExprDelete(pItem->pExpr); 575be5c89acSdrh sqliteFree(pItem->zName); 576a76b5dfcSdrh } 577a76b5dfcSdrh sqliteFree(pList->a); 578a76b5dfcSdrh sqliteFree(pList); 579a76b5dfcSdrh } 580a76b5dfcSdrh 581a76b5dfcSdrh /* 582626a879aSdrh ** Walk an expression tree. Call xFunc for each node visited. 58373b211abSdrh ** 584626a879aSdrh ** The return value from xFunc determines whether the tree walk continues. 585626a879aSdrh ** 0 means continue walking the tree. 1 means do not walk children 586626a879aSdrh ** of the current node but continue with siblings. 2 means abandon 587626a879aSdrh ** the tree walk completely. 588626a879aSdrh ** 589626a879aSdrh ** The return value from this routine is 1 to abandon the tree walk 590626a879aSdrh ** and 0 to continue. 591626a879aSdrh */ 592626a879aSdrh static int walkExprTree(Expr *pExpr, int (*xFunc)(void*,Expr*), void *pArg){ 593626a879aSdrh ExprList *pList; 594626a879aSdrh int rc; 595626a879aSdrh if( pExpr==0 ) return 0; 596626a879aSdrh rc = (*xFunc)(pArg, pExpr); 597626a879aSdrh if( rc==0 ){ 598626a879aSdrh if( walkExprTree(pExpr->pLeft, xFunc, pArg) ) return 1; 599626a879aSdrh if( walkExprTree(pExpr->pRight, xFunc, pArg) ) return 1; 600626a879aSdrh pList = pExpr->pList; 601626a879aSdrh if( pList ){ 602626a879aSdrh int i; 603626a879aSdrh struct ExprList_item *pItem; 604626a879aSdrh for(i=pList->nExpr, pItem=pList->a; i>0; i--, pItem++){ 605626a879aSdrh if( walkExprTree(pItem->pExpr, xFunc, pArg) ) return 1; 606626a879aSdrh } 607626a879aSdrh } 608626a879aSdrh } 609626a879aSdrh return rc>1; 610626a879aSdrh } 611626a879aSdrh 612626a879aSdrh /* 613626a879aSdrh ** This routine is designed as an xFunc for walkExprTree(). 614626a879aSdrh ** 615626a879aSdrh ** pArg is really a pointer to an integer. If we can tell by looking 61673b211abSdrh ** at pExpr that the expression that contains pExpr is not a constant 61773b211abSdrh ** expression, then set *pArg to 0 and return 2 to abandon the tree walk. 61873b211abSdrh ** If pExpr does does not disqualify the expression from being a constant 61973b211abSdrh ** then do nothing. 62073b211abSdrh ** 62173b211abSdrh ** After walking the whole tree, if no nodes are found that disqualify 62273b211abSdrh ** the expression as constant, then we assume the whole expression 62373b211abSdrh ** is constant. See sqlite3ExprIsConstant() for additional information. 624626a879aSdrh */ 625626a879aSdrh static int exprNodeIsConstant(void *pArg, Expr *pExpr){ 626626a879aSdrh switch( pExpr->op ){ 627626a879aSdrh case TK_ID: 628626a879aSdrh case TK_COLUMN: 629626a879aSdrh case TK_DOT: 630626a879aSdrh case TK_AGG_FUNCTION: 631626a879aSdrh case TK_FUNCTION: 632fe2093d7Sdrh #ifndef SQLITE_OMIT_SUBQUERY 633fe2093d7Sdrh case TK_SELECT: 634fe2093d7Sdrh case TK_EXISTS: 635fe2093d7Sdrh #endif 636626a879aSdrh *((int*)pArg) = 0; 637626a879aSdrh return 2; 638626a879aSdrh default: 639626a879aSdrh return 0; 640626a879aSdrh } 641626a879aSdrh } 642626a879aSdrh 643626a879aSdrh /* 644fef5208cSdrh ** Walk an expression tree. Return 1 if the expression is constant 645fef5208cSdrh ** and 0 if it involves variables. 6462398937bSdrh ** 6472398937bSdrh ** For the purposes of this function, a double-quoted string (ex: "abc") 6482398937bSdrh ** is considered a variable but a single-quoted string (ex: 'abc') is 6492398937bSdrh ** a constant. 650fef5208cSdrh */ 6514adee20fSdanielk1977 int sqlite3ExprIsConstant(Expr *p){ 652626a879aSdrh int isConst = 1; 653626a879aSdrh walkExprTree(p, exprNodeIsConstant, &isConst); 654626a879aSdrh return isConst; 655fef5208cSdrh } 656fef5208cSdrh 657fef5208cSdrh /* 65873b211abSdrh ** If the expression p codes a constant integer that is small enough 659202b2df7Sdrh ** to fit in a 32-bit integer, return 1 and put the value of the integer 660202b2df7Sdrh ** in *pValue. If the expression is not an integer or if it is too big 661202b2df7Sdrh ** to fit in a signed 32-bit integer, return 0 and leave *pValue unchanged. 662e4de1febSdrh */ 6634adee20fSdanielk1977 int sqlite3ExprIsInteger(Expr *p, int *pValue){ 664e4de1febSdrh switch( p->op ){ 665e4de1febSdrh case TK_INTEGER: { 666fec19aadSdrh if( sqlite3GetInt32(p->token.z, pValue) ){ 667e4de1febSdrh return 1; 668e4de1febSdrh } 669202b2df7Sdrh break; 670202b2df7Sdrh } 6714b59ab5eSdrh case TK_UPLUS: { 6724adee20fSdanielk1977 return sqlite3ExprIsInteger(p->pLeft, pValue); 6734b59ab5eSdrh } 674e4de1febSdrh case TK_UMINUS: { 675e4de1febSdrh int v; 6764adee20fSdanielk1977 if( sqlite3ExprIsInteger(p->pLeft, &v) ){ 677e4de1febSdrh *pValue = -v; 678e4de1febSdrh return 1; 679e4de1febSdrh } 680e4de1febSdrh break; 681e4de1febSdrh } 682e4de1febSdrh default: break; 683e4de1febSdrh } 684e4de1febSdrh return 0; 685e4de1febSdrh } 686e4de1febSdrh 687e4de1febSdrh /* 688c4a3c779Sdrh ** Return TRUE if the given string is a row-id column name. 689c4a3c779Sdrh */ 6904adee20fSdanielk1977 int sqlite3IsRowid(const char *z){ 6914adee20fSdanielk1977 if( sqlite3StrICmp(z, "_ROWID_")==0 ) return 1; 6924adee20fSdanielk1977 if( sqlite3StrICmp(z, "ROWID")==0 ) return 1; 6934adee20fSdanielk1977 if( sqlite3StrICmp(z, "OID")==0 ) return 1; 694c4a3c779Sdrh return 0; 695c4a3c779Sdrh } 696c4a3c779Sdrh 697c4a3c779Sdrh /* 6988141f61eSdrh ** Given the name of a column of the form X.Y.Z or Y.Z or just Z, look up 6998141f61eSdrh ** that name in the set of source tables in pSrcList and make the pExpr 7008141f61eSdrh ** expression node refer back to that source column. The following changes 7018141f61eSdrh ** are made to pExpr: 7028141f61eSdrh ** 7038141f61eSdrh ** pExpr->iDb Set the index in db->aDb[] of the database holding 7048141f61eSdrh ** the table. 7058141f61eSdrh ** pExpr->iTable Set to the cursor number for the table obtained 7068141f61eSdrh ** from pSrcList. 7078141f61eSdrh ** pExpr->iColumn Set to the column number within the table. 7088141f61eSdrh ** pExpr->op Set to TK_COLUMN. 7098141f61eSdrh ** pExpr->pLeft Any expression this points to is deleted 7108141f61eSdrh ** pExpr->pRight Any expression this points to is deleted. 7118141f61eSdrh ** 7128141f61eSdrh ** The pDbToken is the name of the database (the "X"). This value may be 7138141f61eSdrh ** NULL meaning that name is of the form Y.Z or Z. Any available database 7148141f61eSdrh ** can be used. The pTableToken is the name of the table (the "Y"). This 7158141f61eSdrh ** value can be NULL if pDbToken is also NULL. If pTableToken is NULL it 7168141f61eSdrh ** means that the form of the name is Z and that columns from any table 7178141f61eSdrh ** can be used. 7188141f61eSdrh ** 7198141f61eSdrh ** If the name cannot be resolved unambiguously, leave an error message 7208141f61eSdrh ** in pParse and return non-zero. Return zero on success. 7218141f61eSdrh */ 7228141f61eSdrh static int lookupName( 7238141f61eSdrh Parse *pParse, /* The parsing context */ 7248141f61eSdrh Token *pDbToken, /* Name of the database containing table, or NULL */ 7258141f61eSdrh Token *pTableToken, /* Name of table containing column, or NULL */ 7268141f61eSdrh Token *pColumnToken, /* Name of the column. */ 727626a879aSdrh NameContext *pNC, /* The name context used to resolve the name */ 7288141f61eSdrh Expr *pExpr /* Make this EXPR node point to the selected column */ 7298141f61eSdrh ){ 7308141f61eSdrh char *zDb = 0; /* Name of the database. The "X" in X.Y.Z */ 7318141f61eSdrh char *zTab = 0; /* Name of the table. The "Y" in X.Y.Z or Y.Z */ 7328141f61eSdrh char *zCol = 0; /* Name of the column. The "Z" */ 7338141f61eSdrh int i, j; /* Loop counters */ 7348141f61eSdrh int cnt = 0; /* Number of matching column names */ 7358141f61eSdrh int cntTab = 0; /* Number of matching table names */ 7369bb575fdSdrh sqlite3 *db = pParse->db; /* The database */ 73751669863Sdrh struct SrcList_item *pItem; /* Use for looping over pSrcList items */ 73851669863Sdrh struct SrcList_item *pMatch = 0; /* The matching pSrcList item */ 73973b211abSdrh NameContext *pTopNC = pNC; /* First namecontext in the list */ 7408141f61eSdrh 7418141f61eSdrh assert( pColumnToken && pColumnToken->z ); /* The Z in X.Y.Z cannot be NULL */ 742a99db3b6Sdrh zDb = sqlite3NameFromToken(pDbToken); 743a99db3b6Sdrh zTab = sqlite3NameFromToken(pTableToken); 744a99db3b6Sdrh zCol = sqlite3NameFromToken(pColumnToken); 74524b03fd0Sdanielk1977 if( sqlite3_malloc_failed ){ 7468141f61eSdrh return 1; /* Leak memory (zDb and zTab) if malloc fails */ 7478141f61eSdrh } 7488141f61eSdrh 7498141f61eSdrh pExpr->iTable = -1; 750626a879aSdrh while( pNC && cnt==0 ){ 751626a879aSdrh SrcList *pSrcList = pNC->pSrcList; 752626a879aSdrh ExprList *pEList = pNC->pEList; 753626a879aSdrh 754626a879aSdrh pNC->nRef++; 755626a879aSdrh /* assert( zTab==0 || pEList==0 ); */ 756b3bce662Sdanielk1977 if( pSrcList ){ 75751669863Sdrh for(i=0, pItem=pSrcList->a; i<pSrcList->nSrc; i++, pItem++){ 7588141f61eSdrh Table *pTab = pItem->pTab; 7598141f61eSdrh Column *pCol; 7608141f61eSdrh 7618141f61eSdrh if( pTab==0 ) continue; 7628141f61eSdrh assert( pTab->nCol>0 ); 7638141f61eSdrh if( zTab ){ 7648141f61eSdrh if( pItem->zAlias ){ 7658141f61eSdrh char *zTabName = pItem->zAlias; 7664adee20fSdanielk1977 if( sqlite3StrICmp(zTabName, zTab)!=0 ) continue; 7678141f61eSdrh }else{ 7688141f61eSdrh char *zTabName = pTab->zName; 7694adee20fSdanielk1977 if( zTabName==0 || sqlite3StrICmp(zTabName, zTab)!=0 ) continue; 7704adee20fSdanielk1977 if( zDb!=0 && sqlite3StrICmp(db->aDb[pTab->iDb].zName, zDb)!=0 ){ 7718141f61eSdrh continue; 7728141f61eSdrh } 7738141f61eSdrh } 7748141f61eSdrh } 7758141f61eSdrh if( 0==(cntTab++) ){ 7768141f61eSdrh pExpr->iTable = pItem->iCursor; 7778141f61eSdrh pExpr->iDb = pTab->iDb; 77851669863Sdrh pMatch = pItem; 7798141f61eSdrh } 7808141f61eSdrh for(j=0, pCol=pTab->aCol; j<pTab->nCol; j++, pCol++){ 7814adee20fSdanielk1977 if( sqlite3StrICmp(pCol->zName, zCol)==0 ){ 7828141f61eSdrh cnt++; 7838141f61eSdrh pExpr->iTable = pItem->iCursor; 78451669863Sdrh pMatch = pItem; 7858141f61eSdrh pExpr->iDb = pTab->iDb; 7868141f61eSdrh /* Substitute the rowid (column -1) for the INTEGER PRIMARY KEY */ 7878141f61eSdrh pExpr->iColumn = j==pTab->iPKey ? -1 : j; 788a37cdde0Sdanielk1977 pExpr->affinity = pTab->aCol[j].affinity; 7890202b29eSdanielk1977 pExpr->pColl = pTab->aCol[j].pColl; 7908141f61eSdrh break; 7918141f61eSdrh } 7928141f61eSdrh } 7938141f61eSdrh } 794b3bce662Sdanielk1977 } 7958141f61eSdrh 796b7f9164eSdrh #ifndef SQLITE_OMIT_TRIGGER 7978141f61eSdrh /* If we have not already resolved the name, then maybe 7988141f61eSdrh ** it is a new.* or old.* trigger argument reference 7998141f61eSdrh */ 8008141f61eSdrh if( zDb==0 && zTab!=0 && cnt==0 && pParse->trigStack!=0 ){ 8018141f61eSdrh TriggerStack *pTriggerStack = pParse->trigStack; 8028141f61eSdrh Table *pTab = 0; 8034adee20fSdanielk1977 if( pTriggerStack->newIdx != -1 && sqlite3StrICmp("new", zTab) == 0 ){ 8048141f61eSdrh pExpr->iTable = pTriggerStack->newIdx; 8058141f61eSdrh assert( pTriggerStack->pTab ); 8068141f61eSdrh pTab = pTriggerStack->pTab; 8074adee20fSdanielk1977 }else if( pTriggerStack->oldIdx != -1 && sqlite3StrICmp("old", zTab)==0 ){ 8088141f61eSdrh pExpr->iTable = pTriggerStack->oldIdx; 8098141f61eSdrh assert( pTriggerStack->pTab ); 8108141f61eSdrh pTab = pTriggerStack->pTab; 8118141f61eSdrh } 8128141f61eSdrh 8138141f61eSdrh if( pTab ){ 8148141f61eSdrh int j; 8158141f61eSdrh Column *pCol = pTab->aCol; 8168141f61eSdrh 8178141f61eSdrh pExpr->iDb = pTab->iDb; 8188141f61eSdrh cntTab++; 8198141f61eSdrh for(j=0; j < pTab->nCol; j++, pCol++) { 8204adee20fSdanielk1977 if( sqlite3StrICmp(pCol->zName, zCol)==0 ){ 8218141f61eSdrh cnt++; 8228141f61eSdrh pExpr->iColumn = j==pTab->iPKey ? -1 : j; 823a37cdde0Sdanielk1977 pExpr->affinity = pTab->aCol[j].affinity; 8240202b29eSdanielk1977 pExpr->pColl = pTab->aCol[j].pColl; 8258141f61eSdrh break; 8268141f61eSdrh } 8278141f61eSdrh } 8288141f61eSdrh } 8298141f61eSdrh } 830b7f9164eSdrh #endif /* !defined(SQLITE_OMIT_TRIGGER) */ 8318141f61eSdrh 8328141f61eSdrh /* 8338141f61eSdrh ** Perhaps the name is a reference to the ROWID 8348141f61eSdrh */ 8354adee20fSdanielk1977 if( cnt==0 && cntTab==1 && sqlite3IsRowid(zCol) ){ 8368141f61eSdrh cnt = 1; 8378141f61eSdrh pExpr->iColumn = -1; 838a37cdde0Sdanielk1977 pExpr->affinity = SQLITE_AFF_INTEGER; 8398141f61eSdrh } 8408141f61eSdrh 8418141f61eSdrh /* 8428141f61eSdrh ** If the input is of the form Z (not Y.Z or X.Y.Z) then the name Z 8438141f61eSdrh ** might refer to an result-set alias. This happens, for example, when 8448141f61eSdrh ** we are resolving names in the WHERE clause of the following command: 8458141f61eSdrh ** 8468141f61eSdrh ** SELECT a+b AS x FROM table WHERE x<10; 8478141f61eSdrh ** 8488141f61eSdrh ** In cases like this, replace pExpr with a copy of the expression that 8498141f61eSdrh ** forms the result set entry ("a+b" in the example) and return immediately. 8508141f61eSdrh ** Note that the expression in the result set should have already been 8518141f61eSdrh ** resolved by the time the WHERE clause is resolved. 8528141f61eSdrh */ 85379d5f63fSdrh if( cnt==0 && pEList!=0 && zTab==0 ){ 8548141f61eSdrh for(j=0; j<pEList->nExpr; j++){ 8558141f61eSdrh char *zAs = pEList->a[j].zName; 8564adee20fSdanielk1977 if( zAs!=0 && sqlite3StrICmp(zAs, zCol)==0 ){ 8578141f61eSdrh assert( pExpr->pLeft==0 && pExpr->pRight==0 ); 8588141f61eSdrh pExpr->op = TK_AS; 8598141f61eSdrh pExpr->iColumn = j; 8604adee20fSdanielk1977 pExpr->pLeft = sqlite3ExprDup(pEList->a[j].pExpr); 8618141f61eSdrh sqliteFree(zCol); 8628141f61eSdrh assert( zTab==0 && zDb==0 ); 8638141f61eSdrh return 0; 8648141f61eSdrh } 8658141f61eSdrh } 8668141f61eSdrh } 8678141f61eSdrh 868626a879aSdrh /* Advance to the next name context. The loop will exit when either 869626a879aSdrh ** we have a match (cnt>0) or when we run out of name contexts. 870626a879aSdrh */ 871626a879aSdrh if( cnt==0 ){ 872626a879aSdrh pNC = pNC->pNext; 873626a879aSdrh } 874626a879aSdrh } 875626a879aSdrh 8768141f61eSdrh /* 8778141f61eSdrh ** If X and Y are NULL (in other words if only the column name Z is 8788141f61eSdrh ** supplied) and the value of Z is enclosed in double-quotes, then 8798141f61eSdrh ** Z is a string literal if it doesn't match any column names. In that 8808141f61eSdrh ** case, we need to return right away and not make any changes to 8818141f61eSdrh ** pExpr. 8828141f61eSdrh */ 8838141f61eSdrh if( cnt==0 && zTab==0 && pColumnToken->z[0]=='"' ){ 8848141f61eSdrh sqliteFree(zCol); 8858141f61eSdrh return 0; 8868141f61eSdrh } 8878141f61eSdrh 8888141f61eSdrh /* 8898141f61eSdrh ** cnt==0 means there was not match. cnt>1 means there were two or 8908141f61eSdrh ** more matches. Either way, we have an error. 8918141f61eSdrh */ 8928141f61eSdrh if( cnt!=1 ){ 8938141f61eSdrh char *z = 0; 8948141f61eSdrh char *zErr; 8958141f61eSdrh zErr = cnt==0 ? "no such column: %s" : "ambiguous column name: %s"; 8968141f61eSdrh if( zDb ){ 8974adee20fSdanielk1977 sqlite3SetString(&z, zDb, ".", zTab, ".", zCol, 0); 8988141f61eSdrh }else if( zTab ){ 8994adee20fSdanielk1977 sqlite3SetString(&z, zTab, ".", zCol, 0); 9008141f61eSdrh }else{ 9018141f61eSdrh z = sqliteStrDup(zCol); 9028141f61eSdrh } 9034adee20fSdanielk1977 sqlite3ErrorMsg(pParse, zErr, z); 9048141f61eSdrh sqliteFree(z); 90573b211abSdrh pTopNC->nErr++; 9068141f61eSdrh } 9078141f61eSdrh 90851669863Sdrh /* If a column from a table in pSrcList is referenced, then record 90951669863Sdrh ** this fact in the pSrcList.a[].colUsed bitmask. Column 0 causes 91051669863Sdrh ** bit 0 to be set. Column 1 sets bit 1. And so forth. If the 91151669863Sdrh ** column number is greater than the number of bits in the bitmask 91251669863Sdrh ** then set the high-order bit of the bitmask. 91351669863Sdrh */ 91451669863Sdrh if( pExpr->iColumn>=0 && pMatch!=0 ){ 91551669863Sdrh int n = pExpr->iColumn; 91651669863Sdrh if( n>=sizeof(Bitmask)*8 ){ 91751669863Sdrh n = sizeof(Bitmask)*8-1; 91851669863Sdrh } 91951669863Sdrh assert( pMatch->iCursor==pExpr->iTable ); 92051669863Sdrh pMatch->colUsed |= 1<<n; 92151669863Sdrh } 92251669863Sdrh 9238141f61eSdrh /* Clean up and return 9248141f61eSdrh */ 9258141f61eSdrh sqliteFree(zDb); 9268141f61eSdrh sqliteFree(zTab); 9278141f61eSdrh sqliteFree(zCol); 9284adee20fSdanielk1977 sqlite3ExprDelete(pExpr->pLeft); 9298141f61eSdrh pExpr->pLeft = 0; 9304adee20fSdanielk1977 sqlite3ExprDelete(pExpr->pRight); 9318141f61eSdrh pExpr->pRight = 0; 9328141f61eSdrh pExpr->op = TK_COLUMN; 933626a879aSdrh if( cnt==1 ){ 934b3bce662Sdanielk1977 assert( pNC!=0 ); 935626a879aSdrh sqlite3AuthRead(pParse, pExpr, pNC->pSrcList); 936626a879aSdrh } 9378141f61eSdrh return cnt!=1; 9388141f61eSdrh } 9398141f61eSdrh 9408141f61eSdrh /* 941626a879aSdrh ** pExpr is a node that defines a function of some kind. It might 942626a879aSdrh ** be a syntactic function like "count(x)" or it might be a function 943626a879aSdrh ** that implements an operator, like "a LIKE b". 944626a879aSdrh ** 945626a879aSdrh ** This routine makes *pzName point to the name of the function and 946626a879aSdrh ** *pnName hold the number of characters in the function name. 947626a879aSdrh */ 948626a879aSdrh static void getFunctionName(Expr *pExpr, const char **pzName, int *pnName){ 949626a879aSdrh switch( pExpr->op ){ 950626a879aSdrh case TK_FUNCTION: { 951626a879aSdrh *pzName = pExpr->token.z; 952626a879aSdrh *pnName = pExpr->token.n; 953626a879aSdrh break; 954626a879aSdrh } 955626a879aSdrh case TK_LIKE: { 956626a879aSdrh *pzName = "like"; 957626a879aSdrh *pnName = 4; 958626a879aSdrh break; 959626a879aSdrh } 960626a879aSdrh case TK_GLOB: { 961626a879aSdrh *pzName = "glob"; 962626a879aSdrh *pnName = 4; 963626a879aSdrh break; 964626a879aSdrh } 965626a879aSdrh case TK_CTIME: { 966626a879aSdrh *pzName = "current_time"; 967626a879aSdrh *pnName = 12; 968626a879aSdrh break; 969626a879aSdrh } 970626a879aSdrh case TK_CDATE: { 971626a879aSdrh *pzName = "current_date"; 972626a879aSdrh *pnName = 12; 973626a879aSdrh break; 974626a879aSdrh } 975626a879aSdrh case TK_CTIMESTAMP: { 976626a879aSdrh *pzName = "current_timestamp"; 977626a879aSdrh *pnName = 17; 978626a879aSdrh break; 979626a879aSdrh } 980626a879aSdrh } 981626a879aSdrh } 982626a879aSdrh 983626a879aSdrh /* 984626a879aSdrh ** This routine is designed as an xFunc for walkExprTree(). 985626a879aSdrh ** 98673b211abSdrh ** Resolve symbolic names into TK_COLUMN operators for the current 987626a879aSdrh ** node in the expression tree. Return 0 to continue the search down 98873b211abSdrh ** the tree or 2 to abort the tree walk. 98973b211abSdrh ** 99073b211abSdrh ** This routine also does error checking and name resolution for 99173b211abSdrh ** function names. The operator for aggregate functions is changed 99273b211abSdrh ** to TK_AGG_FUNCTION. 993626a879aSdrh */ 994626a879aSdrh static int nameResolverStep(void *pArg, Expr *pExpr){ 995626a879aSdrh NameContext *pNC = (NameContext*)pArg; 996626a879aSdrh SrcList *pSrcList; 997626a879aSdrh Parse *pParse; 998626a879aSdrh 999b3bce662Sdanielk1977 if( pExpr==0 ) return 1; 1000626a879aSdrh assert( pNC!=0 ); 1001626a879aSdrh pSrcList = pNC->pSrcList; 1002626a879aSdrh pParse = pNC->pParse; 1003b3bce662Sdanielk1977 1004626a879aSdrh if( ExprHasAnyProperty(pExpr, EP_Resolved) ) return 1; 1005626a879aSdrh ExprSetProperty(pExpr, EP_Resolved); 1006626a879aSdrh #ifndef NDEBUG 1007626a879aSdrh if( pSrcList ){ 1008940fac9dSdanielk1977 int i; 1009626a879aSdrh for(i=0; i<pSrcList->nSrc; i++){ 1010626a879aSdrh assert( pSrcList->a[i].iCursor>=0 && pSrcList->a[i].iCursor<pParse->nTab); 1011626a879aSdrh } 1012626a879aSdrh } 1013626a879aSdrh #endif 1014626a879aSdrh switch( pExpr->op ){ 1015626a879aSdrh /* Double-quoted strings (ex: "abc") are used as identifiers if 1016626a879aSdrh ** possible. Otherwise they remain as strings. Single-quoted 1017626a879aSdrh ** strings (ex: 'abc') are always string literals. 1018626a879aSdrh */ 1019626a879aSdrh case TK_STRING: { 1020626a879aSdrh if( pExpr->token.z[0]=='\'' ) break; 1021626a879aSdrh /* Fall thru into the TK_ID case if this is a double-quoted string */ 1022626a879aSdrh } 1023626a879aSdrh /* A lone identifier is the name of a column. 1024626a879aSdrh */ 1025626a879aSdrh case TK_ID: { 1026626a879aSdrh lookupName(pParse, 0, 0, &pExpr->token, pNC, pExpr); 1027626a879aSdrh return 1; 1028626a879aSdrh } 1029626a879aSdrh 1030626a879aSdrh /* A table name and column name: ID.ID 1031626a879aSdrh ** Or a database, table and column: ID.ID.ID 1032626a879aSdrh */ 1033626a879aSdrh case TK_DOT: { 1034626a879aSdrh Token *pColumn; 1035626a879aSdrh Token *pTable; 1036626a879aSdrh Token *pDb; 1037626a879aSdrh Expr *pRight; 1038626a879aSdrh 1039b3bce662Sdanielk1977 /* if( pSrcList==0 ) break; */ 1040626a879aSdrh pRight = pExpr->pRight; 1041626a879aSdrh if( pRight->op==TK_ID ){ 1042626a879aSdrh pDb = 0; 1043626a879aSdrh pTable = &pExpr->pLeft->token; 1044626a879aSdrh pColumn = &pRight->token; 1045626a879aSdrh }else{ 1046626a879aSdrh assert( pRight->op==TK_DOT ); 1047626a879aSdrh pDb = &pExpr->pLeft->token; 1048626a879aSdrh pTable = &pRight->pLeft->token; 1049626a879aSdrh pColumn = &pRight->pRight->token; 1050626a879aSdrh } 1051626a879aSdrh lookupName(pParse, pDb, pTable, pColumn, pNC, pExpr); 1052626a879aSdrh return 1; 1053626a879aSdrh } 1054626a879aSdrh 1055626a879aSdrh /* Resolve function names 1056626a879aSdrh */ 1057626a879aSdrh case TK_CTIME: 1058626a879aSdrh case TK_CTIMESTAMP: 1059626a879aSdrh case TK_CDATE: 1060626a879aSdrh case TK_GLOB: 1061626a879aSdrh case TK_LIKE: 1062626a879aSdrh case TK_FUNCTION: { 1063626a879aSdrh ExprList *pList = pExpr->pList; /* The argument list */ 1064626a879aSdrh int n = pList ? pList->nExpr : 0; /* Number of arguments */ 1065626a879aSdrh int no_such_func = 0; /* True if no such function exists */ 1066626a879aSdrh int wrong_num_args = 0; /* True if wrong number of arguments */ 1067626a879aSdrh int is_agg = 0; /* True if is an aggregate function */ 1068626a879aSdrh int i; 1069626a879aSdrh int nId; /* Number of characters in function name */ 1070626a879aSdrh const char *zId; /* The function name. */ 107173b211abSdrh FuncDef *pDef; /* Information about the function */ 107273b211abSdrh int enc = pParse->db->enc; /* The database encoding */ 1073626a879aSdrh 1074626a879aSdrh getFunctionName(pExpr, &zId, &nId); 1075626a879aSdrh pDef = sqlite3FindFunction(pParse->db, zId, nId, n, enc, 0); 1076626a879aSdrh if( pDef==0 ){ 1077626a879aSdrh pDef = sqlite3FindFunction(pParse->db, zId, nId, -1, enc, 0); 1078626a879aSdrh if( pDef==0 ){ 1079626a879aSdrh no_such_func = 1; 1080626a879aSdrh }else{ 1081626a879aSdrh wrong_num_args = 1; 1082626a879aSdrh } 1083626a879aSdrh }else{ 1084626a879aSdrh is_agg = pDef->xFunc==0; 1085626a879aSdrh } 1086626a879aSdrh if( is_agg && !pNC->allowAgg ){ 1087626a879aSdrh sqlite3ErrorMsg(pParse, "misuse of aggregate function %.*s()", nId,zId); 1088626a879aSdrh pNC->nErr++; 1089626a879aSdrh is_agg = 0; 1090626a879aSdrh }else if( no_such_func ){ 1091626a879aSdrh sqlite3ErrorMsg(pParse, "no such function: %.*s", nId, zId); 1092626a879aSdrh pNC->nErr++; 1093626a879aSdrh }else if( wrong_num_args ){ 1094626a879aSdrh sqlite3ErrorMsg(pParse,"wrong number of arguments to function %.*s()", 1095626a879aSdrh nId, zId); 1096626a879aSdrh pNC->nErr++; 1097626a879aSdrh } 1098626a879aSdrh if( is_agg ){ 1099626a879aSdrh pExpr->op = TK_AGG_FUNCTION; 1100626a879aSdrh pNC->hasAgg = 1; 1101626a879aSdrh } 110273b211abSdrh if( is_agg ) pNC->allowAgg = 0; 1103626a879aSdrh for(i=0; pNC->nErr==0 && i<n; i++){ 110473b211abSdrh walkExprTree(pList->a[i].pExpr, nameResolverStep, pNC); 1105626a879aSdrh } 110673b211abSdrh if( is_agg ) pNC->allowAgg = 1; 1107626a879aSdrh /* FIX ME: Compute pExpr->affinity based on the expected return 1108626a879aSdrh ** type of the function 1109626a879aSdrh */ 1110626a879aSdrh return is_agg; 1111626a879aSdrh } 1112b3bce662Sdanielk1977 #ifndef SQLITE_OMIT_SUBQUERY 1113b3bce662Sdanielk1977 case TK_SELECT: 1114b3bce662Sdanielk1977 case TK_EXISTS: 1115b3bce662Sdanielk1977 #endif 1116b3bce662Sdanielk1977 case TK_IN: { 1117b3bce662Sdanielk1977 if( pExpr->pSelect ){ 1118b3bce662Sdanielk1977 int nRef = pNC->nRef; 1119b3bce662Sdanielk1977 sqlite3SelectResolve(pParse, pExpr->pSelect, pNC); 1120b3bce662Sdanielk1977 assert( pNC->nRef>=nRef ); 1121b3bce662Sdanielk1977 if( nRef!=pNC->nRef ){ 1122b3bce662Sdanielk1977 ExprSetProperty(pExpr, EP_VarSelect); 1123b3bce662Sdanielk1977 } 1124b3bce662Sdanielk1977 } 1125b3bce662Sdanielk1977 } 1126626a879aSdrh } 1127626a879aSdrh return 0; 1128626a879aSdrh } 1129626a879aSdrh 1130626a879aSdrh /* 1131cce7d176Sdrh ** This routine walks an expression tree and resolves references to 1132967e8b73Sdrh ** table columns. Nodes of the form ID.ID or ID resolve into an 1133aacc543eSdrh ** index to the table in the table list and a column offset. The 1134aacc543eSdrh ** Expr.opcode for such nodes is changed to TK_COLUMN. The Expr.iTable 1135aacc543eSdrh ** value is changed to the index of the referenced table in pTabList 1136832508b7Sdrh ** plus the "base" value. The base value will ultimately become the 1137aacc543eSdrh ** VDBE cursor number for a cursor that is pointing into the referenced 1138aacc543eSdrh ** table. The Expr.iColumn value is changed to the index of the column 1139aacc543eSdrh ** of the referenced table. The Expr.iColumn value for the special 1140aacc543eSdrh ** ROWID column is -1. Any INTEGER PRIMARY KEY column is tried as an 1141aacc543eSdrh ** alias for ROWID. 114219a775c2Sdrh ** 1143626a879aSdrh ** Also resolve function names and check the functions for proper 1144626a879aSdrh ** usage. Make sure all function names are recognized and all functions 1145626a879aSdrh ** have the correct number of arguments. Leave an error message 1146626a879aSdrh ** in pParse->zErrMsg if anything is amiss. Return the number of errors. 1147626a879aSdrh ** 114873b211abSdrh ** If the expression contains aggregate functions then set the EP_Agg 114973b211abSdrh ** property on the expression. 1150626a879aSdrh */ 1151626a879aSdrh int sqlite3ExprResolveNames( 1152b3bce662Sdanielk1977 NameContext *pNC, /* Namespace to resolve expressions in. */ 1153b3bce662Sdanielk1977 Expr *pExpr /* The expression to be analyzed. */ 1154626a879aSdrh ){ 115573b211abSdrh if( pExpr==0 ) return 0; 1156b3bce662Sdanielk1977 walkExprTree(pExpr, nameResolverStep, pNC); 1157b3bce662Sdanielk1977 if( pNC->nErr>0 ){ 115873b211abSdrh ExprSetProperty(pExpr, EP_Error); 115973b211abSdrh } 116073b211abSdrh return ExprHasProperty(pExpr, EP_Error); 1161626a879aSdrh } 1162626a879aSdrh 11631398ad36Sdrh /* 11641398ad36Sdrh ** A pointer instance of this structure is used to pass information 11651398ad36Sdrh ** through walkExprTree into codeSubqueryStep(). 11661398ad36Sdrh */ 11671398ad36Sdrh typedef struct QueryCoder QueryCoder; 11681398ad36Sdrh struct QueryCoder { 11691398ad36Sdrh Parse *pParse; /* The parsing context */ 11701398ad36Sdrh NameContext *pNC; /* Namespace of first enclosing query */ 11711398ad36Sdrh }; 11721398ad36Sdrh 1173626a879aSdrh 1174626a879aSdrh /* 1175626a879aSdrh ** Generate code for subqueries and IN operators. 1176626a879aSdrh ** 117773b211abSdrh ** IN operators comes in two forms: 1178fef5208cSdrh ** 1179fef5208cSdrh ** expr IN (exprlist) 1180fef5208cSdrh ** and 1181fef5208cSdrh ** expr IN (SELECT ...) 1182fef5208cSdrh ** 1183fef5208cSdrh ** The first form is handled by creating a set holding the list 1184fef5208cSdrh ** of allowed values. The second form causes the SELECT to generate 1185fef5208cSdrh ** a temporary table. 1186cce7d176Sdrh */ 118751522cd3Sdrh #ifndef SQLITE_OMIT_SUBQUERY 1188b3bce662Sdanielk1977 void sqlite3CodeSubselect(Parse *pParse, Expr *pExpr){ 1189b3bce662Sdanielk1977 int label = 0; /* Address after sub-select code */ 1190b3bce662Sdanielk1977 Vdbe *v = sqlite3GetVdbe(pParse); 1191b3bce662Sdanielk1977 if( v==0 ) return; 1192b3bce662Sdanielk1977 1193b3bce662Sdanielk1977 /* If this is not a variable (correlated) select, then execute 1194b3bce662Sdanielk1977 ** it only once. Unless this is part of a trigger program. In 1195b3bce662Sdanielk1977 ** that case re-execute every time (this could be optimized). 1196b3bce662Sdanielk1977 */ 1197b3bce662Sdanielk1977 if( !ExprHasAnyProperty(pExpr, EP_VarSelect) && !pParse->trigStack ){ 1198b3bce662Sdanielk1977 int mem = pParse->nMem++; 1199b3bce662Sdanielk1977 sqlite3VdbeAddOp(v, OP_MemLoad, mem, 0); 1200b3bce662Sdanielk1977 label = sqlite3VdbeMakeLabel(v); 1201b3bce662Sdanielk1977 sqlite3VdbeAddOp(v, OP_If, 0, label); 1202b3bce662Sdanielk1977 sqlite3VdbeAddOp(v, OP_Integer, 1, 0); 1203b3bce662Sdanielk1977 sqlite3VdbeAddOp(v, OP_MemStore, mem, 1); 1204b3bce662Sdanielk1977 } 1205b3bce662Sdanielk1977 1206b3bce662Sdanielk1977 if( pExpr->pSelect ){ 1207b3bce662Sdanielk1977 sqlite3VdbeAddOp(v, OP_AggContextPush, 0, 0); 1208b3bce662Sdanielk1977 } 12096a3ea0e6Sdrh 1210cce7d176Sdrh switch( pExpr->op ){ 1211fef5208cSdrh case TK_IN: { 1212e014a838Sdanielk1977 char affinity; 1213d3d39e93Sdrh KeyInfo keyInfo; 12140202b29eSdanielk1977 int addr; /* Address of OP_OpenTemp instruction */ 1215d3d39e93Sdrh 1216bf3b721fSdanielk1977 affinity = sqlite3ExprAffinity(pExpr->pLeft); 1217e014a838Sdanielk1977 1218e014a838Sdanielk1977 /* Whether this is an 'x IN(SELECT...)' or an 'x IN(<exprlist>)' 1219e014a838Sdanielk1977 ** expression it is handled the same way. A temporary table is 1220e014a838Sdanielk1977 ** filled with single-field index keys representing the results 1221e014a838Sdanielk1977 ** from the SELECT or the <exprlist>. 1222fef5208cSdrh ** 1223e014a838Sdanielk1977 ** If the 'x' expression is a column value, or the SELECT... 1224e014a838Sdanielk1977 ** statement returns a column value, then the affinity of that 1225e014a838Sdanielk1977 ** column is used to build the index keys. If both 'x' and the 1226e014a838Sdanielk1977 ** SELECT... statement are columns, then numeric affinity is used 1227e014a838Sdanielk1977 ** if either column has NUMERIC or INTEGER affinity. If neither 1228e014a838Sdanielk1977 ** 'x' nor the SELECT... statement are columns, then numeric affinity 1229e014a838Sdanielk1977 ** is used. 1230fef5208cSdrh */ 1231832508b7Sdrh pExpr->iTable = pParse->nTab++; 12320202b29eSdanielk1977 addr = sqlite3VdbeAddOp(v, OP_OpenTemp, pExpr->iTable, 0); 1233d3d39e93Sdrh memset(&keyInfo, 0, sizeof(keyInfo)); 1234d3d39e93Sdrh keyInfo.nField = 1; 1235f3218feaSdrh sqlite3VdbeAddOp(v, OP_SetNumColumns, pExpr->iTable, 1); 1236e014a838Sdanielk1977 1237e014a838Sdanielk1977 if( pExpr->pSelect ){ 1238e014a838Sdanielk1977 /* Case 1: expr IN (SELECT ...) 1239e014a838Sdanielk1977 ** 1240e014a838Sdanielk1977 ** Generate code to write the results of the select into the temporary 1241e014a838Sdanielk1977 ** table allocated and opened above. 1242e014a838Sdanielk1977 */ 1243e014a838Sdanielk1977 int iParm = pExpr->iTable + (((int)affinity)<<16); 1244be5c89acSdrh ExprList *pEList; 1245e014a838Sdanielk1977 assert( (pExpr->iTable&0x0000FFFF)==pExpr->iTable ); 1246b3bce662Sdanielk1977 sqlite3Select(pParse, pExpr->pSelect, SRT_Set, iParm, 0, 0, 0, 0); 1247be5c89acSdrh pEList = pExpr->pSelect->pEList; 1248be5c89acSdrh if( pEList && pEList->nExpr>0 ){ 12497cedc8d4Sdanielk1977 keyInfo.aColl[0] = binaryCompareCollSeq(pParse, pExpr->pLeft, 1250be5c89acSdrh pEList->a[0].pExpr); 12510202b29eSdanielk1977 } 1252fef5208cSdrh }else if( pExpr->pList ){ 1253fef5208cSdrh /* Case 2: expr IN (exprlist) 1254fef5208cSdrh ** 1255e014a838Sdanielk1977 ** For each expression, build an index key from the evaluation and 1256e014a838Sdanielk1977 ** store it in the temporary table. If <expr> is a column, then use 1257e014a838Sdanielk1977 ** that columns affinity when building index keys. If <expr> is not 1258e014a838Sdanielk1977 ** a column, use numeric affinity. 1259fef5208cSdrh */ 1260e014a838Sdanielk1977 int i; 1261e014a838Sdanielk1977 if( !affinity ){ 1262e014a838Sdanielk1977 affinity = SQLITE_AFF_NUMERIC; 1263e014a838Sdanielk1977 } 12640202b29eSdanielk1977 keyInfo.aColl[0] = pExpr->pLeft->pColl; 1265e014a838Sdanielk1977 1266e014a838Sdanielk1977 /* Loop through each expression in <exprlist>. */ 1267fef5208cSdrh for(i=0; i<pExpr->pList->nExpr; i++){ 1268fef5208cSdrh Expr *pE2 = pExpr->pList->a[i].pExpr; 1269e014a838Sdanielk1977 1270e014a838Sdanielk1977 /* Check that the expression is constant and valid. */ 12714adee20fSdanielk1977 if( !sqlite3ExprIsConstant(pE2) ){ 12724adee20fSdanielk1977 sqlite3ErrorMsg(pParse, 1273da93d238Sdrh "right-hand side of IN operator must be constant"); 1274b3bce662Sdanielk1977 return; 12754794b980Sdrh } 1276e014a838Sdanielk1977 1277e014a838Sdanielk1977 /* Evaluate the expression and insert it into the temp table */ 12784adee20fSdanielk1977 sqlite3ExprCode(pParse, pE2); 127994a11211Sdrh sqlite3VdbeOp3(v, OP_MakeRecord, 1, 0, &affinity, 1); 12800f69c1e3Sdanielk1977 sqlite3VdbeAddOp(v, OP_String8, 0, 0); 1281e014a838Sdanielk1977 sqlite3VdbeAddOp(v, OP_PutStrKey, pExpr->iTable, 0); 1282fef5208cSdrh } 1283fef5208cSdrh } 12840202b29eSdanielk1977 sqlite3VdbeChangeP3(v, addr, (void *)&keyInfo, P3_KEYINFO); 1285b3bce662Sdanielk1977 break; 1286fef5208cSdrh } 1287fef5208cSdrh 128851522cd3Sdrh case TK_EXISTS: 128919a775c2Sdrh case TK_SELECT: { 1290fef5208cSdrh /* This has to be a scalar SELECT. Generate code to put the 1291fef5208cSdrh ** value of this select in a memory cell and record the number 1292967e8b73Sdrh ** of the memory cell in iColumn. 1293fef5208cSdrh */ 129451522cd3Sdrh int sop; 129551522cd3Sdrh Select *pSel; 12961398ad36Sdrh 1297967e8b73Sdrh pExpr->iColumn = pParse->nMem++; 129851522cd3Sdrh pSel = pExpr->pSelect; 129951522cd3Sdrh if( pExpr->op==TK_SELECT ){ 130051522cd3Sdrh sop = SRT_Mem; 130151522cd3Sdrh }else{ 130251522cd3Sdrh static const Token one = { "1", 0, 1 }; 130351522cd3Sdrh sop = SRT_Exists; 130451522cd3Sdrh sqlite3ExprListDelete(pSel->pEList); 130551522cd3Sdrh pSel->pEList = sqlite3ExprListAppend(0, 130651522cd3Sdrh sqlite3Expr(TK_INTEGER, 0, 0, &one), 0); 130751522cd3Sdrh } 1308b3bce662Sdanielk1977 sqlite3Select(pParse, pSel, sop, pExpr->iColumn, 0, 0, 0, 0); 1309b3bce662Sdanielk1977 break; 131019a775c2Sdrh } 1311cce7d176Sdrh } 1312b3bce662Sdanielk1977 1313b3bce662Sdanielk1977 if( pExpr->pSelect ){ 1314b3bce662Sdanielk1977 sqlite3VdbeAddOp(v, OP_AggContextPop, 0, 0); 1315b3bce662Sdanielk1977 } 1316b3bce662Sdanielk1977 if( label<0 ){ 1317b3bce662Sdanielk1977 sqlite3VdbeResolveLabel(v, label); 1318b3bce662Sdanielk1977 } 1319b3bce662Sdanielk1977 return; 1320cce7d176Sdrh } 132151522cd3Sdrh #endif /* SQLITE_OMIT_SUBQUERY */ 1322cce7d176Sdrh 1323cce7d176Sdrh /* 1324fec19aadSdrh ** Generate an instruction that will put the integer describe by 1325fec19aadSdrh ** text z[0..n-1] on the stack. 1326fec19aadSdrh */ 1327fec19aadSdrh static void codeInteger(Vdbe *v, const char *z, int n){ 1328fec19aadSdrh int i; 13296fec0762Sdrh if( sqlite3GetInt32(z, &i) ){ 13306fec0762Sdrh sqlite3VdbeAddOp(v, OP_Integer, i, 0); 13316fec0762Sdrh }else if( sqlite3FitsIn64Bits(z) ){ 13326fec0762Sdrh sqlite3VdbeOp3(v, OP_Integer, 0, 0, z, n); 1333fec19aadSdrh }else{ 1334fec19aadSdrh sqlite3VdbeOp3(v, OP_Real, 0, 0, z, n); 1335fec19aadSdrh } 1336fec19aadSdrh } 1337fec19aadSdrh 1338fec19aadSdrh /* 1339cce7d176Sdrh ** Generate code into the current Vdbe to evaluate the given 13401ccde15dSdrh ** expression and leave the result on the top of stack. 1341f2bc013cSdrh ** 1342f2bc013cSdrh ** This code depends on the fact that certain token values (ex: TK_EQ) 1343f2bc013cSdrh ** are the same as opcode values (ex: OP_Eq) that implement the corresponding 1344f2bc013cSdrh ** operation. Special comments in vdbe.c and the mkopcodeh.awk script in 1345f2bc013cSdrh ** the make process cause these values to align. Assert()s in the code 1346f2bc013cSdrh ** below verify that the numbers are aligned correctly. 1347cce7d176Sdrh */ 13484adee20fSdanielk1977 void sqlite3ExprCode(Parse *pParse, Expr *pExpr){ 1349cce7d176Sdrh Vdbe *v = pParse->pVdbe; 1350cce7d176Sdrh int op; 13517977a17fSdanielk1977 if( v==0 ) return; 13527977a17fSdanielk1977 if( pExpr==0 ){ 13537977a17fSdanielk1977 sqlite3VdbeAddOp(v, OP_String8, 0, 0); /* Empty expression evals to NULL */ 13547977a17fSdanielk1977 return; 13557977a17fSdanielk1977 } 1356f2bc013cSdrh op = pExpr->op; 1357f2bc013cSdrh switch( op ){ 1358967e8b73Sdrh case TK_COLUMN: { 13592282792aSdrh if( pParse->useAgg ){ 13604adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_AggGet, 0, pExpr->iAgg); 1361c4a3c779Sdrh }else if( pExpr->iColumn>=0 ){ 13624adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Column, pExpr->iTable, pExpr->iColumn); 1363145716b3Sdrh #ifndef NDEBUG 1364145716b3Sdrh if( pExpr->span.z && pExpr->span.n>0 && pExpr->span.n<100 ){ 1365ad6d9460Sdrh VdbeComment((v, "# %T", &pExpr->span)); 1366145716b3Sdrh } 1367145716b3Sdrh #endif 1368c4a3c779Sdrh }else{ 13694adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Recno, pExpr->iTable, 0); 13702282792aSdrh } 1371cce7d176Sdrh break; 1372cce7d176Sdrh } 1373cce7d176Sdrh case TK_INTEGER: { 1374fec19aadSdrh codeInteger(v, pExpr->token.z, pExpr->token.n); 1375fec19aadSdrh break; 137651e9a445Sdrh } 1377fec19aadSdrh case TK_FLOAT: 1378fec19aadSdrh case TK_STRING: { 1379f2bc013cSdrh assert( TK_FLOAT==OP_Real ); 1380f2bc013cSdrh assert( TK_STRING==OP_String8 ); 1381fec19aadSdrh sqlite3VdbeOp3(v, op, 0, 0, pExpr->token.z, pExpr->token.n); 13824adee20fSdanielk1977 sqlite3VdbeDequoteP3(v, -1); 1383cce7d176Sdrh break; 1384cce7d176Sdrh } 13855338a5f7Sdanielk1977 #ifndef SQLITE_OMIT_BLOB_LITERAL 1386c572ef7fSdanielk1977 case TK_BLOB: { 1387f2bc013cSdrh assert( TK_BLOB==OP_HexBlob ); 1388c572ef7fSdanielk1977 sqlite3VdbeOp3(v, op, 0, 0, pExpr->token.z+1, pExpr->token.n-1); 1389c572ef7fSdanielk1977 sqlite3VdbeDequoteP3(v, -1); 1390c572ef7fSdanielk1977 break; 1391c572ef7fSdanielk1977 } 13925338a5f7Sdanielk1977 #endif 1393cce7d176Sdrh case TK_NULL: { 13940f69c1e3Sdanielk1977 sqlite3VdbeAddOp(v, OP_String8, 0, 0); 1395cce7d176Sdrh break; 1396cce7d176Sdrh } 139750457896Sdrh case TK_VARIABLE: { 13984adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Variable, pExpr->iTable, 0); 1399895d7472Sdrh if( pExpr->token.n>1 ){ 1400895d7472Sdrh sqlite3VdbeChangeP3(v, -1, pExpr->token.z, pExpr->token.n); 1401895d7472Sdrh } 140250457896Sdrh break; 140350457896Sdrh } 14044e0cff60Sdrh case TK_REGISTER: { 14054e0cff60Sdrh sqlite3VdbeAddOp(v, OP_MemLoad, pExpr->iTable, 0); 14064e0cff60Sdrh break; 14074e0cff60Sdrh } 1408c9b84a1fSdrh case TK_LT: 1409c9b84a1fSdrh case TK_LE: 1410c9b84a1fSdrh case TK_GT: 1411c9b84a1fSdrh case TK_GE: 1412c9b84a1fSdrh case TK_NE: 1413c9b84a1fSdrh case TK_EQ: { 1414f2bc013cSdrh assert( TK_LT==OP_Lt ); 1415f2bc013cSdrh assert( TK_LE==OP_Le ); 1416f2bc013cSdrh assert( TK_GT==OP_Gt ); 1417f2bc013cSdrh assert( TK_GE==OP_Ge ); 1418f2bc013cSdrh assert( TK_EQ==OP_Eq ); 1419f2bc013cSdrh assert( TK_NE==OP_Ne ); 1420a37cdde0Sdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 1421a37cdde0Sdanielk1977 sqlite3ExprCode(pParse, pExpr->pRight); 1422be5c89acSdrh codeCompare(pParse, pExpr->pLeft, pExpr->pRight, op, 0, 0); 1423a37cdde0Sdanielk1977 break; 1424c9b84a1fSdrh } 1425cce7d176Sdrh case TK_AND: 1426cce7d176Sdrh case TK_OR: 1427cce7d176Sdrh case TK_PLUS: 1428cce7d176Sdrh case TK_STAR: 1429cce7d176Sdrh case TK_MINUS: 1430bf4133cbSdrh case TK_REM: 1431bf4133cbSdrh case TK_BITAND: 1432bf4133cbSdrh case TK_BITOR: 143317c40294Sdrh case TK_SLASH: 1434bf4133cbSdrh case TK_LSHIFT: 1435855eb1cfSdrh case TK_RSHIFT: 14360040077dSdrh case TK_CONCAT: { 1437f2bc013cSdrh assert( TK_AND==OP_And ); 1438f2bc013cSdrh assert( TK_OR==OP_Or ); 1439f2bc013cSdrh assert( TK_PLUS==OP_Add ); 1440f2bc013cSdrh assert( TK_MINUS==OP_Subtract ); 1441f2bc013cSdrh assert( TK_REM==OP_Remainder ); 1442f2bc013cSdrh assert( TK_BITAND==OP_BitAnd ); 1443f2bc013cSdrh assert( TK_BITOR==OP_BitOr ); 1444f2bc013cSdrh assert( TK_SLASH==OP_Divide ); 1445f2bc013cSdrh assert( TK_LSHIFT==OP_ShiftLeft ); 1446f2bc013cSdrh assert( TK_RSHIFT==OP_ShiftRight ); 1447f2bc013cSdrh assert( TK_CONCAT==OP_Concat ); 14484adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 14494adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pRight); 1450855eb1cfSdrh sqlite3VdbeAddOp(v, op, 0, 0); 14510040077dSdrh break; 14520040077dSdrh } 1453cce7d176Sdrh case TK_UMINUS: { 1454fec19aadSdrh Expr *pLeft = pExpr->pLeft; 1455fec19aadSdrh assert( pLeft ); 1456fec19aadSdrh if( pLeft->op==TK_FLOAT || pLeft->op==TK_INTEGER ){ 1457fec19aadSdrh Token *p = &pLeft->token; 14586e142f54Sdrh char *z = sqliteMalloc( p->n + 2 ); 14596e142f54Sdrh sprintf(z, "-%.*s", p->n, p->z); 1460fec19aadSdrh if( pLeft->op==TK_FLOAT ){ 1461fec19aadSdrh sqlite3VdbeOp3(v, OP_Real, 0, 0, z, p->n+1); 1462e6840900Sdrh }else{ 1463fec19aadSdrh codeInteger(v, z, p->n+1); 1464e6840900Sdrh } 14656e142f54Sdrh sqliteFree(z); 14666e142f54Sdrh break; 14676e142f54Sdrh } 14681ccde15dSdrh /* Fall through into TK_NOT */ 14696e142f54Sdrh } 1470bf4133cbSdrh case TK_BITNOT: 14716e142f54Sdrh case TK_NOT: { 1472f2bc013cSdrh assert( TK_BITNOT==OP_BitNot ); 1473f2bc013cSdrh assert( TK_NOT==OP_Not ); 14744adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 14754adee20fSdanielk1977 sqlite3VdbeAddOp(v, op, 0, 0); 1476cce7d176Sdrh break; 1477cce7d176Sdrh } 1478cce7d176Sdrh case TK_ISNULL: 1479cce7d176Sdrh case TK_NOTNULL: { 1480cce7d176Sdrh int dest; 1481f2bc013cSdrh assert( TK_ISNULL==OP_IsNull ); 1482f2bc013cSdrh assert( TK_NOTNULL==OP_NotNull ); 14834adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Integer, 1, 0); 14844adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 14854adee20fSdanielk1977 dest = sqlite3VdbeCurrentAddr(v) + 2; 14864adee20fSdanielk1977 sqlite3VdbeAddOp(v, op, 1, dest); 14874adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_AddImm, -1, 0); 1488a37cdde0Sdanielk1977 break; 1489f2bc013cSdrh } 14902282792aSdrh case TK_AGG_FUNCTION: { 14914adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_AggGet, 0, pExpr->iAgg); 14922282792aSdrh break; 14932282792aSdrh } 14947977a17fSdanielk1977 case TK_CDATE: 14957977a17fSdanielk1977 case TK_CTIME: 14967977a17fSdanielk1977 case TK_CTIMESTAMP: 14974b59ab5eSdrh case TK_GLOB: 14984b59ab5eSdrh case TK_LIKE: 1499cce7d176Sdrh case TK_FUNCTION: { 1500cce7d176Sdrh ExprList *pList = pExpr->pList; 150189425d5eSdrh int nExpr = pList ? pList->nExpr : 0; 15020bce8354Sdrh FuncDef *pDef; 15034b59ab5eSdrh int nId; 15044b59ab5eSdrh const char *zId; 1505682f68b0Sdanielk1977 int p2 = 0; 1506682f68b0Sdanielk1977 int i; 1507d8123366Sdanielk1977 u8 enc = pParse->db->enc; 1508dc1bdc4fSdanielk1977 CollSeq *pColl = 0; 15094b59ab5eSdrh getFunctionName(pExpr, &zId, &nId); 1510d8123366Sdanielk1977 pDef = sqlite3FindFunction(pParse->db, zId, nId, nExpr, enc, 0); 15110bce8354Sdrh assert( pDef!=0 ); 1512f9b596ebSdrh nExpr = sqlite3ExprCodeExprList(pParse, pList); 1513682f68b0Sdanielk1977 for(i=0; i<nExpr && i<32; i++){ 1514d02eb1fdSdanielk1977 if( sqlite3ExprIsConstant(pList->a[i].pExpr) ){ 1515d02eb1fdSdanielk1977 p2 |= (1<<i); 1516d02eb1fdSdanielk1977 } 1517dc1bdc4fSdanielk1977 if( pDef->needCollSeq && !pColl ){ 1518dc1bdc4fSdanielk1977 pColl = sqlite3ExprCollSeq(pParse, pList->a[i].pExpr); 1519dc1bdc4fSdanielk1977 } 1520dc1bdc4fSdanielk1977 } 1521dc1bdc4fSdanielk1977 if( pDef->needCollSeq ){ 1522dc1bdc4fSdanielk1977 if( !pColl ) pColl = pParse->db->pDfltColl; 1523d8123366Sdanielk1977 sqlite3VdbeOp3(v, OP_CollSeq, 0, 0, (char *)pColl, P3_COLLSEQ); 1524682f68b0Sdanielk1977 } 1525682f68b0Sdanielk1977 sqlite3VdbeOp3(v, OP_Function, nExpr, p2, (char*)pDef, P3_FUNCDEF); 15266ec2733bSdrh break; 15276ec2733bSdrh } 1528fe2093d7Sdrh #ifndef SQLITE_OMIT_SUBQUERY 1529fe2093d7Sdrh case TK_EXISTS: 153019a775c2Sdrh case TK_SELECT: { 1531b3bce662Sdanielk1977 sqlite3CodeSubselect(pParse, pExpr); 15324adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_MemLoad, pExpr->iColumn, 0); 1533ad6d9460Sdrh VdbeComment((v, "# load subquery result")); 153419a775c2Sdrh break; 153519a775c2Sdrh } 1536fef5208cSdrh case TK_IN: { 1537fef5208cSdrh int addr; 153894a11211Sdrh char affinity; 1539b3bce662Sdanielk1977 sqlite3CodeSubselect(pParse, pExpr); 1540e014a838Sdanielk1977 1541e014a838Sdanielk1977 /* Figure out the affinity to use to create a key from the results 1542e014a838Sdanielk1977 ** of the expression. affinityStr stores a static string suitable for 1543ededfd5eSdanielk1977 ** P3 of OP_MakeRecord. 1544e014a838Sdanielk1977 */ 154594a11211Sdrh affinity = comparisonAffinity(pExpr); 1546e014a838Sdanielk1977 15474adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Integer, 1, 0); 1548e014a838Sdanielk1977 1549e014a838Sdanielk1977 /* Code the <expr> from "<expr> IN (...)". The temporary table 1550e014a838Sdanielk1977 ** pExpr->iTable contains the values that make up the (...) set. 1551e014a838Sdanielk1977 */ 15524adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 15534adee20fSdanielk1977 addr = sqlite3VdbeCurrentAddr(v); 1554e014a838Sdanielk1977 sqlite3VdbeAddOp(v, OP_NotNull, -1, addr+4); /* addr + 0 */ 15554adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Pop, 2, 0); 15560f69c1e3Sdanielk1977 sqlite3VdbeAddOp(v, OP_String8, 0, 0); 1557e014a838Sdanielk1977 sqlite3VdbeAddOp(v, OP_Goto, 0, addr+7); 155894a11211Sdrh sqlite3VdbeOp3(v, OP_MakeRecord, 1, 0, &affinity, 1); /* addr + 4 */ 1559e014a838Sdanielk1977 sqlite3VdbeAddOp(v, OP_Found, pExpr->iTable, addr+7); 1560e014a838Sdanielk1977 sqlite3VdbeAddOp(v, OP_AddImm, -1, 0); /* addr + 6 */ 1561e014a838Sdanielk1977 1562fef5208cSdrh break; 1563fef5208cSdrh } 156493758c8dSdanielk1977 #endif 1565fef5208cSdrh case TK_BETWEEN: { 1566be5c89acSdrh Expr *pLeft = pExpr->pLeft; 1567be5c89acSdrh struct ExprList_item *pLItem = pExpr->pList->a; 1568be5c89acSdrh Expr *pRight = pLItem->pExpr; 1569be5c89acSdrh sqlite3ExprCode(pParse, pLeft); 15704adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Dup, 0, 0); 1571be5c89acSdrh sqlite3ExprCode(pParse, pRight); 1572be5c89acSdrh codeCompare(pParse, pLeft, pRight, OP_Ge, 0, 0); 15734adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Pull, 1, 0); 1574be5c89acSdrh pLItem++; 1575be5c89acSdrh pRight = pLItem->pExpr; 1576be5c89acSdrh sqlite3ExprCode(pParse, pRight); 1577be5c89acSdrh codeCompare(pParse, pLeft, pRight, OP_Le, 0, 0); 15784adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_And, 0, 0); 1579fef5208cSdrh break; 1580fef5208cSdrh } 158151e9a445Sdrh case TK_UPLUS: 1582a2e00042Sdrh case TK_AS: { 15834adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 1584a2e00042Sdrh break; 1585a2e00042Sdrh } 158617a7f8ddSdrh case TK_CASE: { 158717a7f8ddSdrh int expr_end_label; 1588f5905aa7Sdrh int jumpInst; 1589f5905aa7Sdrh int addr; 1590f5905aa7Sdrh int nExpr; 159117a7f8ddSdrh int i; 1592be5c89acSdrh ExprList *pEList; 1593be5c89acSdrh struct ExprList_item *aListelem; 159417a7f8ddSdrh 159517a7f8ddSdrh assert(pExpr->pList); 159617a7f8ddSdrh assert((pExpr->pList->nExpr % 2) == 0); 159717a7f8ddSdrh assert(pExpr->pList->nExpr > 0); 1598be5c89acSdrh pEList = pExpr->pList; 1599be5c89acSdrh aListelem = pEList->a; 1600be5c89acSdrh nExpr = pEList->nExpr; 16014adee20fSdanielk1977 expr_end_label = sqlite3VdbeMakeLabel(v); 160217a7f8ddSdrh if( pExpr->pLeft ){ 16034adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 1604cce7d176Sdrh } 1605f5905aa7Sdrh for(i=0; i<nExpr; i=i+2){ 1606be5c89acSdrh sqlite3ExprCode(pParse, aListelem[i].pExpr); 160717a7f8ddSdrh if( pExpr->pLeft ){ 16084adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Dup, 1, 1); 1609be5c89acSdrh jumpInst = codeCompare(pParse, pExpr->pLeft, aListelem[i].pExpr, 1610be5c89acSdrh OP_Ne, 0, 1); 16114adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Pop, 1, 0); 1612f5905aa7Sdrh }else{ 16134adee20fSdanielk1977 jumpInst = sqlite3VdbeAddOp(v, OP_IfNot, 1, 0); 161417a7f8ddSdrh } 1615be5c89acSdrh sqlite3ExprCode(pParse, aListelem[i+1].pExpr); 16164adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Goto, 0, expr_end_label); 16174adee20fSdanielk1977 addr = sqlite3VdbeCurrentAddr(v); 16184adee20fSdanielk1977 sqlite3VdbeChangeP2(v, jumpInst, addr); 161917a7f8ddSdrh } 1620f570f011Sdrh if( pExpr->pLeft ){ 16214adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Pop, 1, 0); 1622f570f011Sdrh } 162317a7f8ddSdrh if( pExpr->pRight ){ 16244adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pRight); 162517a7f8ddSdrh }else{ 16260f69c1e3Sdanielk1977 sqlite3VdbeAddOp(v, OP_String8, 0, 0); 162717a7f8ddSdrh } 16284adee20fSdanielk1977 sqlite3VdbeResolveLabel(v, expr_end_label); 16296f34903eSdanielk1977 break; 16306f34903eSdanielk1977 } 16315338a5f7Sdanielk1977 #ifndef SQLITE_OMIT_TRIGGER 16326f34903eSdanielk1977 case TK_RAISE: { 16336f34903eSdanielk1977 if( !pParse->trigStack ){ 16344adee20fSdanielk1977 sqlite3ErrorMsg(pParse, 1635da93d238Sdrh "RAISE() may only be used within a trigger-program"); 16366f34903eSdanielk1977 return; 16376f34903eSdanielk1977 } 1638ad6d9460Sdrh if( pExpr->iColumn!=OE_Ignore ){ 1639ad6d9460Sdrh assert( pExpr->iColumn==OE_Rollback || 16406f34903eSdanielk1977 pExpr->iColumn == OE_Abort || 1641ad6d9460Sdrh pExpr->iColumn == OE_Fail ); 16424adee20fSdanielk1977 sqlite3VdbeOp3(v, OP_Halt, SQLITE_CONSTRAINT, pExpr->iColumn, 1643701a0aebSdrh pExpr->token.z, pExpr->token.n); 16444adee20fSdanielk1977 sqlite3VdbeDequoteP3(v, -1); 16456f34903eSdanielk1977 } else { 16466f34903eSdanielk1977 assert( pExpr->iColumn == OE_Ignore ); 1647344737f6Sdrh sqlite3VdbeAddOp(v, OP_ContextPop, 0, 0); 1648ad6d9460Sdrh sqlite3VdbeAddOp(v, OP_Goto, 0, pParse->trigStack->ignoreJump); 1649ad6d9460Sdrh VdbeComment((v, "# raise(IGNORE)")); 16506f34903eSdanielk1977 } 165117a7f8ddSdrh } 16525338a5f7Sdanielk1977 #endif 165317a7f8ddSdrh break; 165417a7f8ddSdrh } 1655cce7d176Sdrh } 1656cce7d176Sdrh 165793758c8dSdanielk1977 #ifndef SQLITE_OMIT_TRIGGER 1658cce7d176Sdrh /* 165925303780Sdrh ** Generate code that evalutes the given expression and leaves the result 166025303780Sdrh ** on the stack. See also sqlite3ExprCode(). 166125303780Sdrh ** 166225303780Sdrh ** This routine might also cache the result and modify the pExpr tree 166325303780Sdrh ** so that it will make use of the cached result on subsequent evaluations 166425303780Sdrh ** rather than evaluate the whole expression again. Trivial expressions are 166525303780Sdrh ** not cached. If the expression is cached, its result is stored in a 166625303780Sdrh ** memory location. 166725303780Sdrh */ 166825303780Sdrh void sqlite3ExprCodeAndCache(Parse *pParse, Expr *pExpr){ 166925303780Sdrh Vdbe *v = pParse->pVdbe; 167025303780Sdrh int iMem; 167125303780Sdrh int addr1, addr2; 167225303780Sdrh if( v==0 ) return; 167325303780Sdrh addr1 = sqlite3VdbeCurrentAddr(v); 167425303780Sdrh sqlite3ExprCode(pParse, pExpr); 167525303780Sdrh addr2 = sqlite3VdbeCurrentAddr(v); 167625303780Sdrh if( addr2>addr1+1 || sqlite3VdbeGetOp(v, addr1)->opcode==OP_Function ){ 167725303780Sdrh iMem = pExpr->iTable = pParse->nMem++; 167825303780Sdrh sqlite3VdbeAddOp(v, OP_MemStore, iMem, 0); 167925303780Sdrh pExpr->op = TK_REGISTER; 168025303780Sdrh } 168125303780Sdrh } 168293758c8dSdanielk1977 #endif 168325303780Sdrh 168425303780Sdrh /* 1685268380caSdrh ** Generate code that pushes the value of every element of the given 1686f9b596ebSdrh ** expression list onto the stack. 1687268380caSdrh ** 1688268380caSdrh ** Return the number of elements pushed onto the stack. 1689268380caSdrh */ 16904adee20fSdanielk1977 int sqlite3ExprCodeExprList( 1691268380caSdrh Parse *pParse, /* Parsing context */ 1692f9b596ebSdrh ExprList *pList /* The expression list to be coded */ 1693268380caSdrh ){ 1694268380caSdrh struct ExprList_item *pItem; 1695268380caSdrh int i, n; 1696268380caSdrh Vdbe *v; 1697268380caSdrh if( pList==0 ) return 0; 16984adee20fSdanielk1977 v = sqlite3GetVdbe(pParse); 1699268380caSdrh n = pList->nExpr; 1700268380caSdrh for(pItem=pList->a, i=0; i<n; i++, pItem++){ 17014adee20fSdanielk1977 sqlite3ExprCode(pParse, pItem->pExpr); 1702268380caSdrh } 1703f9b596ebSdrh return n; 1704268380caSdrh } 1705268380caSdrh 1706268380caSdrh /* 1707cce7d176Sdrh ** Generate code for a boolean expression such that a jump is made 1708cce7d176Sdrh ** to the label "dest" if the expression is true but execution 1709cce7d176Sdrh ** continues straight thru if the expression is false. 1710f5905aa7Sdrh ** 1711f5905aa7Sdrh ** If the expression evaluates to NULL (neither true nor false), then 1712f5905aa7Sdrh ** take the jump if the jumpIfNull flag is true. 1713f2bc013cSdrh ** 1714f2bc013cSdrh ** This code depends on the fact that certain token values (ex: TK_EQ) 1715f2bc013cSdrh ** are the same as opcode values (ex: OP_Eq) that implement the corresponding 1716f2bc013cSdrh ** operation. Special comments in vdbe.c and the mkopcodeh.awk script in 1717f2bc013cSdrh ** the make process cause these values to align. Assert()s in the code 1718f2bc013cSdrh ** below verify that the numbers are aligned correctly. 1719cce7d176Sdrh */ 17204adee20fSdanielk1977 void sqlite3ExprIfTrue(Parse *pParse, Expr *pExpr, int dest, int jumpIfNull){ 1721cce7d176Sdrh Vdbe *v = pParse->pVdbe; 1722cce7d176Sdrh int op = 0; 1723daffd0e5Sdrh if( v==0 || pExpr==0 ) return; 1724f2bc013cSdrh op = pExpr->op; 1725f2bc013cSdrh switch( op ){ 1726cce7d176Sdrh case TK_AND: { 17274adee20fSdanielk1977 int d2 = sqlite3VdbeMakeLabel(v); 17284adee20fSdanielk1977 sqlite3ExprIfFalse(pParse, pExpr->pLeft, d2, !jumpIfNull); 17294adee20fSdanielk1977 sqlite3ExprIfTrue(pParse, pExpr->pRight, dest, jumpIfNull); 17304adee20fSdanielk1977 sqlite3VdbeResolveLabel(v, d2); 1731cce7d176Sdrh break; 1732cce7d176Sdrh } 1733cce7d176Sdrh case TK_OR: { 17344adee20fSdanielk1977 sqlite3ExprIfTrue(pParse, pExpr->pLeft, dest, jumpIfNull); 17354adee20fSdanielk1977 sqlite3ExprIfTrue(pParse, pExpr->pRight, dest, jumpIfNull); 1736cce7d176Sdrh break; 1737cce7d176Sdrh } 1738cce7d176Sdrh case TK_NOT: { 17394adee20fSdanielk1977 sqlite3ExprIfFalse(pParse, pExpr->pLeft, dest, jumpIfNull); 1740cce7d176Sdrh break; 1741cce7d176Sdrh } 1742cce7d176Sdrh case TK_LT: 1743cce7d176Sdrh case TK_LE: 1744cce7d176Sdrh case TK_GT: 1745cce7d176Sdrh case TK_GE: 1746cce7d176Sdrh case TK_NE: 17470ac65892Sdrh case TK_EQ: { 1748f2bc013cSdrh assert( TK_LT==OP_Lt ); 1749f2bc013cSdrh assert( TK_LE==OP_Le ); 1750f2bc013cSdrh assert( TK_GT==OP_Gt ); 1751f2bc013cSdrh assert( TK_GE==OP_Ge ); 1752f2bc013cSdrh assert( TK_EQ==OP_Eq ); 1753f2bc013cSdrh assert( TK_NE==OP_Ne ); 17544adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 17554adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pRight); 1756be5c89acSdrh codeCompare(pParse, pExpr->pLeft, pExpr->pRight, op, dest, jumpIfNull); 1757cce7d176Sdrh break; 1758cce7d176Sdrh } 1759cce7d176Sdrh case TK_ISNULL: 1760cce7d176Sdrh case TK_NOTNULL: { 1761f2bc013cSdrh assert( TK_ISNULL==OP_IsNull ); 1762f2bc013cSdrh assert( TK_NOTNULL==OP_NotNull ); 17634adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 17644adee20fSdanielk1977 sqlite3VdbeAddOp(v, op, 1, dest); 1765cce7d176Sdrh break; 1766cce7d176Sdrh } 1767fef5208cSdrh case TK_BETWEEN: { 17680202b29eSdanielk1977 /* The expression "x BETWEEN y AND z" is implemented as: 17690202b29eSdanielk1977 ** 17700202b29eSdanielk1977 ** 1 IF (x < y) GOTO 3 17710202b29eSdanielk1977 ** 2 IF (x <= z) GOTO <dest> 17720202b29eSdanielk1977 ** 3 ... 17730202b29eSdanielk1977 */ 1774f5905aa7Sdrh int addr; 1775be5c89acSdrh Expr *pLeft = pExpr->pLeft; 1776be5c89acSdrh Expr *pRight = pExpr->pList->a[0].pExpr; 1777be5c89acSdrh sqlite3ExprCode(pParse, pLeft); 17784adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Dup, 0, 0); 1779be5c89acSdrh sqlite3ExprCode(pParse, pRight); 1780be5c89acSdrh addr = codeCompare(pParse, pLeft, pRight, OP_Lt, 0, !jumpIfNull); 17810202b29eSdanielk1977 1782be5c89acSdrh pRight = pExpr->pList->a[1].pExpr; 1783be5c89acSdrh sqlite3ExprCode(pParse, pRight); 1784be5c89acSdrh codeCompare(pParse, pLeft, pRight, OP_Le, dest, jumpIfNull); 17850202b29eSdanielk1977 17864adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Integer, 0, 0); 17874adee20fSdanielk1977 sqlite3VdbeChangeP2(v, addr, sqlite3VdbeCurrentAddr(v)); 17884adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Pop, 1, 0); 1789fef5208cSdrh break; 1790fef5208cSdrh } 1791cce7d176Sdrh default: { 17924adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr); 17934adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_If, jumpIfNull, dest); 1794cce7d176Sdrh break; 1795cce7d176Sdrh } 1796cce7d176Sdrh } 1797cce7d176Sdrh } 1798cce7d176Sdrh 1799cce7d176Sdrh /* 180066b89c8fSdrh ** Generate code for a boolean expression such that a jump is made 1801cce7d176Sdrh ** to the label "dest" if the expression is false but execution 1802cce7d176Sdrh ** continues straight thru if the expression is true. 1803f5905aa7Sdrh ** 1804f5905aa7Sdrh ** If the expression evaluates to NULL (neither true nor false) then 1805f5905aa7Sdrh ** jump if jumpIfNull is true or fall through if jumpIfNull is false. 1806cce7d176Sdrh */ 18074adee20fSdanielk1977 void sqlite3ExprIfFalse(Parse *pParse, Expr *pExpr, int dest, int jumpIfNull){ 1808cce7d176Sdrh Vdbe *v = pParse->pVdbe; 1809cce7d176Sdrh int op = 0; 1810daffd0e5Sdrh if( v==0 || pExpr==0 ) return; 1811f2bc013cSdrh 1812f2bc013cSdrh /* The value of pExpr->op and op are related as follows: 1813f2bc013cSdrh ** 1814f2bc013cSdrh ** pExpr->op op 1815f2bc013cSdrh ** --------- ---------- 1816f2bc013cSdrh ** TK_ISNULL OP_NotNull 1817f2bc013cSdrh ** TK_NOTNULL OP_IsNull 1818f2bc013cSdrh ** TK_NE OP_Eq 1819f2bc013cSdrh ** TK_EQ OP_Ne 1820f2bc013cSdrh ** TK_GT OP_Le 1821f2bc013cSdrh ** TK_LE OP_Gt 1822f2bc013cSdrh ** TK_GE OP_Lt 1823f2bc013cSdrh ** TK_LT OP_Ge 1824f2bc013cSdrh ** 1825f2bc013cSdrh ** For other values of pExpr->op, op is undefined and unused. 1826f2bc013cSdrh ** The value of TK_ and OP_ constants are arranged such that we 1827f2bc013cSdrh ** can compute the mapping above using the following expression. 1828f2bc013cSdrh ** Assert()s verify that the computation is correct. 1829f2bc013cSdrh */ 1830f2bc013cSdrh op = ((pExpr->op+(TK_ISNULL&1))^1)-(TK_ISNULL&1); 1831f2bc013cSdrh 1832f2bc013cSdrh /* Verify correct alignment of TK_ and OP_ constants 1833f2bc013cSdrh */ 1834f2bc013cSdrh assert( pExpr->op!=TK_ISNULL || op==OP_NotNull ); 1835f2bc013cSdrh assert( pExpr->op!=TK_NOTNULL || op==OP_IsNull ); 1836f2bc013cSdrh assert( pExpr->op!=TK_NE || op==OP_Eq ); 1837f2bc013cSdrh assert( pExpr->op!=TK_EQ || op==OP_Ne ); 1838f2bc013cSdrh assert( pExpr->op!=TK_LT || op==OP_Ge ); 1839f2bc013cSdrh assert( pExpr->op!=TK_LE || op==OP_Gt ); 1840f2bc013cSdrh assert( pExpr->op!=TK_GT || op==OP_Le ); 1841f2bc013cSdrh assert( pExpr->op!=TK_GE || op==OP_Lt ); 1842f2bc013cSdrh 1843cce7d176Sdrh switch( pExpr->op ){ 1844cce7d176Sdrh case TK_AND: { 18454adee20fSdanielk1977 sqlite3ExprIfFalse(pParse, pExpr->pLeft, dest, jumpIfNull); 18464adee20fSdanielk1977 sqlite3ExprIfFalse(pParse, pExpr->pRight, dest, jumpIfNull); 1847cce7d176Sdrh break; 1848cce7d176Sdrh } 1849cce7d176Sdrh case TK_OR: { 18504adee20fSdanielk1977 int d2 = sqlite3VdbeMakeLabel(v); 18514adee20fSdanielk1977 sqlite3ExprIfTrue(pParse, pExpr->pLeft, d2, !jumpIfNull); 18524adee20fSdanielk1977 sqlite3ExprIfFalse(pParse, pExpr->pRight, dest, jumpIfNull); 18534adee20fSdanielk1977 sqlite3VdbeResolveLabel(v, d2); 1854cce7d176Sdrh break; 1855cce7d176Sdrh } 1856cce7d176Sdrh case TK_NOT: { 18574adee20fSdanielk1977 sqlite3ExprIfTrue(pParse, pExpr->pLeft, dest, jumpIfNull); 1858cce7d176Sdrh break; 1859cce7d176Sdrh } 1860cce7d176Sdrh case TK_LT: 1861cce7d176Sdrh case TK_LE: 1862cce7d176Sdrh case TK_GT: 1863cce7d176Sdrh case TK_GE: 1864cce7d176Sdrh case TK_NE: 1865cce7d176Sdrh case TK_EQ: { 18664adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 18674adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pRight); 1868be5c89acSdrh codeCompare(pParse, pExpr->pLeft, pExpr->pRight, op, dest, jumpIfNull); 1869cce7d176Sdrh break; 1870cce7d176Sdrh } 1871cce7d176Sdrh case TK_ISNULL: 1872cce7d176Sdrh case TK_NOTNULL: { 18734adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 18744adee20fSdanielk1977 sqlite3VdbeAddOp(v, op, 1, dest); 1875cce7d176Sdrh break; 1876cce7d176Sdrh } 1877fef5208cSdrh case TK_BETWEEN: { 18780202b29eSdanielk1977 /* The expression is "x BETWEEN y AND z". It is implemented as: 18790202b29eSdanielk1977 ** 18800202b29eSdanielk1977 ** 1 IF (x >= y) GOTO 3 18810202b29eSdanielk1977 ** 2 GOTO <dest> 18820202b29eSdanielk1977 ** 3 IF (x > z) GOTO <dest> 18830202b29eSdanielk1977 */ 1884fef5208cSdrh int addr; 1885be5c89acSdrh Expr *pLeft = pExpr->pLeft; 1886be5c89acSdrh Expr *pRight = pExpr->pList->a[0].pExpr; 1887be5c89acSdrh sqlite3ExprCode(pParse, pLeft); 18884adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Dup, 0, 0); 1889be5c89acSdrh sqlite3ExprCode(pParse, pRight); 18904adee20fSdanielk1977 addr = sqlite3VdbeCurrentAddr(v); 1891be5c89acSdrh codeCompare(pParse, pLeft, pRight, OP_Ge, addr+3, !jumpIfNull); 1892be5c89acSdrh 18934adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Pop, 1, 0); 18944adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Goto, 0, dest); 1895be5c89acSdrh pRight = pExpr->pList->a[1].pExpr; 1896be5c89acSdrh sqlite3ExprCode(pParse, pRight); 1897be5c89acSdrh codeCompare(pParse, pLeft, pRight, OP_Gt, dest, jumpIfNull); 1898fef5208cSdrh break; 1899fef5208cSdrh } 1900cce7d176Sdrh default: { 19014adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr); 19024adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_IfNot, jumpIfNull, dest); 1903cce7d176Sdrh break; 1904cce7d176Sdrh } 1905cce7d176Sdrh } 1906cce7d176Sdrh } 19072282792aSdrh 19082282792aSdrh /* 19092282792aSdrh ** Do a deep comparison of two expression trees. Return TRUE (non-zero) 19102282792aSdrh ** if they are identical and return FALSE if they differ in any way. 19112282792aSdrh */ 19124adee20fSdanielk1977 int sqlite3ExprCompare(Expr *pA, Expr *pB){ 19132282792aSdrh int i; 19142282792aSdrh if( pA==0 ){ 19152282792aSdrh return pB==0; 19162282792aSdrh }else if( pB==0 ){ 19172282792aSdrh return 0; 19182282792aSdrh } 19192282792aSdrh if( pA->op!=pB->op ) return 0; 19204adee20fSdanielk1977 if( !sqlite3ExprCompare(pA->pLeft, pB->pLeft) ) return 0; 19214adee20fSdanielk1977 if( !sqlite3ExprCompare(pA->pRight, pB->pRight) ) return 0; 19222282792aSdrh if( pA->pList ){ 19232282792aSdrh if( pB->pList==0 ) return 0; 19242282792aSdrh if( pA->pList->nExpr!=pB->pList->nExpr ) return 0; 19252282792aSdrh for(i=0; i<pA->pList->nExpr; i++){ 19264adee20fSdanielk1977 if( !sqlite3ExprCompare(pA->pList->a[i].pExpr, pB->pList->a[i].pExpr) ){ 19272282792aSdrh return 0; 19282282792aSdrh } 19292282792aSdrh } 19302282792aSdrh }else if( pB->pList ){ 19312282792aSdrh return 0; 19322282792aSdrh } 19332282792aSdrh if( pA->pSelect || pB->pSelect ) return 0; 19342f2c01e5Sdrh if( pA->iTable!=pB->iTable || pA->iColumn!=pB->iColumn ) return 0; 19352282792aSdrh if( pA->token.z ){ 19362282792aSdrh if( pB->token.z==0 ) return 0; 19376977fea8Sdrh if( pB->token.n!=pA->token.n ) return 0; 19384adee20fSdanielk1977 if( sqlite3StrNICmp(pA->token.z, pB->token.z, pB->token.n)!=0 ) return 0; 19392282792aSdrh } 19402282792aSdrh return 1; 19412282792aSdrh } 19422282792aSdrh 19432282792aSdrh /* 19442282792aSdrh ** Add a new element to the pParse->aAgg[] array and return its index. 194573b211abSdrh ** The new element is initialized to zero. The calling function is 194673b211abSdrh ** expected to fill it in. 19472282792aSdrh */ 19482282792aSdrh static int appendAggInfo(Parse *pParse){ 19492282792aSdrh if( (pParse->nAgg & 0x7)==0 ){ 19502282792aSdrh int amt = pParse->nAgg + 8; 19516d4abfbeSdrh AggExpr *aAgg = sqliteRealloc(pParse->aAgg, amt*sizeof(pParse->aAgg[0])); 19526d4abfbeSdrh if( aAgg==0 ){ 19532282792aSdrh return -1; 19542282792aSdrh } 19556d4abfbeSdrh pParse->aAgg = aAgg; 19562282792aSdrh } 19572282792aSdrh memset(&pParse->aAgg[pParse->nAgg], 0, sizeof(pParse->aAgg[0])); 19582282792aSdrh return pParse->nAgg++; 19592282792aSdrh } 19602282792aSdrh 19612282792aSdrh /* 1962626a879aSdrh ** This is an xFunc for walkExprTree() used to implement 1963626a879aSdrh ** sqlite3ExprAnalyzeAggregates(). See sqlite3ExprAnalyzeAggregates 1964626a879aSdrh ** for additional information. 19652282792aSdrh ** 1966626a879aSdrh ** This routine analyzes the aggregate function at pExpr. 19672282792aSdrh */ 1968626a879aSdrh static int analyzeAggregate(void *pArg, Expr *pExpr){ 19692282792aSdrh int i; 19702282792aSdrh AggExpr *aAgg; 1971626a879aSdrh Parse *pParse = (Parse*)pArg; 19722282792aSdrh 19732282792aSdrh switch( pExpr->op ){ 1974967e8b73Sdrh case TK_COLUMN: { 19752282792aSdrh aAgg = pParse->aAgg; 19762282792aSdrh for(i=0; i<pParse->nAgg; i++){ 19772282792aSdrh if( aAgg[i].isAgg ) continue; 19782282792aSdrh if( aAgg[i].pExpr->iTable==pExpr->iTable 1979967e8b73Sdrh && aAgg[i].pExpr->iColumn==pExpr->iColumn ){ 19802282792aSdrh break; 19812282792aSdrh } 19822282792aSdrh } 19832282792aSdrh if( i>=pParse->nAgg ){ 19842282792aSdrh i = appendAggInfo(pParse); 19852282792aSdrh if( i<0 ) return 1; 19862282792aSdrh pParse->aAgg[i].isAgg = 0; 19872282792aSdrh pParse->aAgg[i].pExpr = pExpr; 19882282792aSdrh } 1989aaf88729Sdrh pExpr->iAgg = i; 1990626a879aSdrh return 1; 19912282792aSdrh } 19922282792aSdrh case TK_AGG_FUNCTION: { 19932282792aSdrh aAgg = pParse->aAgg; 19942282792aSdrh for(i=0; i<pParse->nAgg; i++){ 19952282792aSdrh if( !aAgg[i].isAgg ) continue; 19964adee20fSdanielk1977 if( sqlite3ExprCompare(aAgg[i].pExpr, pExpr) ){ 19972282792aSdrh break; 19982282792aSdrh } 19992282792aSdrh } 20002282792aSdrh if( i>=pParse->nAgg ){ 2001d8123366Sdanielk1977 u8 enc = pParse->db->enc; 20022282792aSdrh i = appendAggInfo(pParse); 20032282792aSdrh if( i<0 ) return 1; 20042282792aSdrh pParse->aAgg[i].isAgg = 1; 20052282792aSdrh pParse->aAgg[i].pExpr = pExpr; 20064adee20fSdanielk1977 pParse->aAgg[i].pFunc = sqlite3FindFunction(pParse->db, 20076977fea8Sdrh pExpr->token.z, pExpr->token.n, 2008d8123366Sdanielk1977 pExpr->pList ? pExpr->pList->nExpr : 0, enc, 0); 20092282792aSdrh } 20102282792aSdrh pExpr->iAgg = i; 2011626a879aSdrh return 1; 20122282792aSdrh } 20132282792aSdrh } 2014626a879aSdrh return 0; 20152282792aSdrh } 2016626a879aSdrh 2017626a879aSdrh /* 2018626a879aSdrh ** Analyze the given expression looking for aggregate functions and 2019626a879aSdrh ** for variables that need to be added to the pParse->aAgg[] array. 2020626a879aSdrh ** Make additional entries to the pParse->aAgg[] array as necessary. 2021626a879aSdrh ** 2022626a879aSdrh ** This routine should only be called after the expression has been 2023626a879aSdrh ** analyzed by sqlite3ExprResolveNames(). 2024626a879aSdrh ** 2025626a879aSdrh ** If errors are seen, leave an error message in zErrMsg and return 2026626a879aSdrh ** the number of errors. 2027626a879aSdrh */ 2028626a879aSdrh int sqlite3ExprAnalyzeAggregates(Parse *pParse, Expr *pExpr){ 2029626a879aSdrh int nErr = pParse->nErr; 2030626a879aSdrh walkExprTree(pExpr, analyzeAggregate, pParse); 2031626a879aSdrh return pParse->nErr - nErr; 20322282792aSdrh } 20338e0a2f90Sdrh 20348e0a2f90Sdrh /* 2035d02eb1fdSdanielk1977 ** Locate a user function given a name, a number of arguments and a flag 2036d02eb1fdSdanielk1977 ** indicating whether the function prefers UTF-16 over UTF-8. Return a 2037d02eb1fdSdanielk1977 ** pointer to the FuncDef structure that defines that function, or return 2038d02eb1fdSdanielk1977 ** NULL if the function does not exist. 20398e0a2f90Sdrh ** 20400bce8354Sdrh ** If the createFlag argument is true, then a new (blank) FuncDef 20418e0a2f90Sdrh ** structure is created and liked into the "db" structure if a 20428e0a2f90Sdrh ** no matching function previously existed. When createFlag is true 20438e0a2f90Sdrh ** and the nArg parameter is -1, then only a function that accepts 20448e0a2f90Sdrh ** any number of arguments will be returned. 20458e0a2f90Sdrh ** 20468e0a2f90Sdrh ** If createFlag is false and nArg is -1, then the first valid 20478e0a2f90Sdrh ** function found is returned. A function is valid if either xFunc 20488e0a2f90Sdrh ** or xStep is non-zero. 2049d02eb1fdSdanielk1977 ** 2050d02eb1fdSdanielk1977 ** If createFlag is false, then a function with the required name and 2051d02eb1fdSdanielk1977 ** number of arguments may be returned even if the eTextRep flag does not 2052d02eb1fdSdanielk1977 ** match that requested. 20538e0a2f90Sdrh */ 20544adee20fSdanielk1977 FuncDef *sqlite3FindFunction( 20559bb575fdSdrh sqlite3 *db, /* An open database */ 20568e0a2f90Sdrh const char *zName, /* Name of the function. Not null-terminated */ 20578e0a2f90Sdrh int nName, /* Number of characters in the name */ 20588e0a2f90Sdrh int nArg, /* Number of arguments. -1 means any number */ 2059d8123366Sdanielk1977 u8 enc, /* Preferred text encoding */ 20608e0a2f90Sdrh int createFlag /* Create new entry if true and does not otherwise exist */ 20618e0a2f90Sdrh ){ 2062d02eb1fdSdanielk1977 FuncDef *p; /* Iterator variable */ 2063d02eb1fdSdanielk1977 FuncDef *pFirst; /* First function with this name */ 2064d02eb1fdSdanielk1977 FuncDef *pBest = 0; /* Best match found so far */ 2065d8123366Sdanielk1977 int bestmatch = 0; 2066d02eb1fdSdanielk1977 2067d8123366Sdanielk1977 2068d8123366Sdanielk1977 assert( enc==SQLITE_UTF8 || enc==SQLITE_UTF16LE || enc==SQLITE_UTF16BE ); 2069d02eb1fdSdanielk1977 if( nArg<-1 ) nArg = -1; 2070d02eb1fdSdanielk1977 2071d02eb1fdSdanielk1977 pFirst = (FuncDef*)sqlite3HashFind(&db->aFunc, zName, nName); 2072d02eb1fdSdanielk1977 for(p=pFirst; p; p=p->pNext){ 2073d8123366Sdanielk1977 /* During the search for the best function definition, bestmatch is set 2074d8123366Sdanielk1977 ** as follows to indicate the quality of the match with the definition 2075d8123366Sdanielk1977 ** pointed to by pBest: 2076d8123366Sdanielk1977 ** 2077d8123366Sdanielk1977 ** 0: pBest is NULL. No match has been found. 2078d8123366Sdanielk1977 ** 1: A variable arguments function that prefers UTF-8 when a UTF-16 2079d8123366Sdanielk1977 ** encoding is requested, or vice versa. 2080d8123366Sdanielk1977 ** 2: A variable arguments function that uses UTF-16BE when UTF-16LE is 2081d8123366Sdanielk1977 ** requested, or vice versa. 2082d8123366Sdanielk1977 ** 3: A variable arguments function using the same text encoding. 2083d8123366Sdanielk1977 ** 4: A function with the exact number of arguments requested that 2084d8123366Sdanielk1977 ** prefers UTF-8 when a UTF-16 encoding is requested, or vice versa. 2085d8123366Sdanielk1977 ** 5: A function with the exact number of arguments requested that 2086d8123366Sdanielk1977 ** prefers UTF-16LE when UTF-16BE is requested, or vice versa. 2087d8123366Sdanielk1977 ** 6: An exact match. 2088d8123366Sdanielk1977 ** 2089d8123366Sdanielk1977 ** A larger value of 'matchqual' indicates a more desirable match. 2090d8123366Sdanielk1977 */ 2091e12c17baSdanielk1977 if( p->nArg==-1 || p->nArg==nArg || nArg==-1 ){ 2092d8123366Sdanielk1977 int match = 1; /* Quality of this match */ 2093d8123366Sdanielk1977 if( p->nArg==nArg || nArg==-1 ){ 2094d8123366Sdanielk1977 match = 4; 20958e0a2f90Sdrh } 2096d8123366Sdanielk1977 if( enc==p->iPrefEnc ){ 2097d8123366Sdanielk1977 match += 2; 20988e0a2f90Sdrh } 2099d8123366Sdanielk1977 else if( (enc==SQLITE_UTF16LE && p->iPrefEnc==SQLITE_UTF16BE) || 2100d8123366Sdanielk1977 (enc==SQLITE_UTF16BE && p->iPrefEnc==SQLITE_UTF16LE) ){ 2101d8123366Sdanielk1977 match += 1; 2102d02eb1fdSdanielk1977 } 2103d8123366Sdanielk1977 2104d8123366Sdanielk1977 if( match>bestmatch ){ 2105d02eb1fdSdanielk1977 pBest = p; 2106d8123366Sdanielk1977 bestmatch = match; 2107d02eb1fdSdanielk1977 } 2108d02eb1fdSdanielk1977 } 2109d02eb1fdSdanielk1977 } 2110d02eb1fdSdanielk1977 2111d8123366Sdanielk1977 /* If the createFlag parameter is true, and the seach did not reveal an 2112d8123366Sdanielk1977 ** exact match for the name, number of arguments and encoding, then add a 2113d8123366Sdanielk1977 ** new entry to the hash table and return it. 2114d8123366Sdanielk1977 */ 2115d8123366Sdanielk1977 if( createFlag && bestmatch<6 && 2116d02eb1fdSdanielk1977 (pBest = sqliteMalloc(sizeof(*pBest)+nName+1)) ){ 2117d02eb1fdSdanielk1977 pBest->nArg = nArg; 2118d02eb1fdSdanielk1977 pBest->pNext = pFirst; 2119d02eb1fdSdanielk1977 pBest->zName = (char*)&pBest[1]; 2120d8123366Sdanielk1977 pBest->iPrefEnc = enc; 2121d02eb1fdSdanielk1977 memcpy(pBest->zName, zName, nName); 2122d02eb1fdSdanielk1977 pBest->zName[nName] = 0; 21232c336549Sdanielk1977 if( pBest==sqlite3HashInsert(&db->aFunc,pBest->zName,nName,(void*)pBest) ){ 21242c336549Sdanielk1977 sqliteFree(pBest); 21252c336549Sdanielk1977 return 0; 21262c336549Sdanielk1977 } 2127d02eb1fdSdanielk1977 } 2128d02eb1fdSdanielk1977 2129d02eb1fdSdanielk1977 if( pBest && (pBest->xStep || pBest->xFunc || createFlag) ){ 2130d02eb1fdSdanielk1977 return pBest; 2131d02eb1fdSdanielk1977 } 21328e0a2f90Sdrh return 0; 21338e0a2f90Sdrh } 2134