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*3119bc42Sdrh ** $Id: expr.c,v 1.183 2005/01/20 01:51:26 drh 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 } 4494adee20fSdanielk1977 SrcList *sqlite3SrcListDup(SrcList *p){ 450ad3cab52Sdrh SrcList *pNew; 451ad3cab52Sdrh int i; 452113088ecSdrh int nByte; 453ad3cab52Sdrh if( p==0 ) return 0; 454113088ecSdrh nByte = sizeof(*p) + (p->nSrc>0 ? sizeof(p->a[0]) * (p->nSrc-1) : 0); 4554efc4754Sdrh pNew = sqliteMallocRaw( nByte ); 456ad3cab52Sdrh if( pNew==0 ) return 0; 4574305d103Sdrh pNew->nSrc = pNew->nAlloc = p->nSrc; 458ad3cab52Sdrh for(i=0; i<p->nSrc; i++){ 4594efc4754Sdrh struct SrcList_item *pNewItem = &pNew->a[i]; 4604efc4754Sdrh struct SrcList_item *pOldItem = &p->a[i]; 4614efc4754Sdrh pNewItem->zDatabase = sqliteStrDup(pOldItem->zDatabase); 4624efc4754Sdrh pNewItem->zName = sqliteStrDup(pOldItem->zName); 4634efc4754Sdrh pNewItem->zAlias = sqliteStrDup(pOldItem->zAlias); 4644efc4754Sdrh pNewItem->jointype = pOldItem->jointype; 4654efc4754Sdrh pNewItem->iCursor = pOldItem->iCursor; 4664efc4754Sdrh pNewItem->pTab = 0; 4674adee20fSdanielk1977 pNewItem->pSelect = sqlite3SelectDup(pOldItem->pSelect); 4684adee20fSdanielk1977 pNewItem->pOn = sqlite3ExprDup(pOldItem->pOn); 4694adee20fSdanielk1977 pNewItem->pUsing = sqlite3IdListDup(pOldItem->pUsing); 470ad3cab52Sdrh } 471ad3cab52Sdrh return pNew; 472ad3cab52Sdrh } 4734adee20fSdanielk1977 IdList *sqlite3IdListDup(IdList *p){ 474ff78bd2fSdrh IdList *pNew; 475ff78bd2fSdrh int i; 476ff78bd2fSdrh if( p==0 ) return 0; 4774efc4754Sdrh pNew = sqliteMallocRaw( sizeof(*pNew) ); 478ff78bd2fSdrh if( pNew==0 ) return 0; 4794305d103Sdrh pNew->nId = pNew->nAlloc = p->nId; 4804efc4754Sdrh pNew->a = sqliteMallocRaw( p->nId*sizeof(p->a[0]) ); 481e4697f5eSdrh if( pNew->a==0 ) return 0; 482ff78bd2fSdrh for(i=0; i<p->nId; i++){ 4834efc4754Sdrh struct IdList_item *pNewItem = &pNew->a[i]; 4844efc4754Sdrh struct IdList_item *pOldItem = &p->a[i]; 4854efc4754Sdrh pNewItem->zName = sqliteStrDup(pOldItem->zName); 4864efc4754Sdrh pNewItem->idx = pOldItem->idx; 487ff78bd2fSdrh } 488ff78bd2fSdrh return pNew; 489ff78bd2fSdrh } 4904adee20fSdanielk1977 Select *sqlite3SelectDup(Select *p){ 491ff78bd2fSdrh Select *pNew; 492ff78bd2fSdrh if( p==0 ) return 0; 4934efc4754Sdrh pNew = sqliteMallocRaw( sizeof(*p) ); 494ff78bd2fSdrh if( pNew==0 ) return 0; 495ff78bd2fSdrh pNew->isDistinct = p->isDistinct; 4964adee20fSdanielk1977 pNew->pEList = sqlite3ExprListDup(p->pEList); 4974adee20fSdanielk1977 pNew->pSrc = sqlite3SrcListDup(p->pSrc); 4984adee20fSdanielk1977 pNew->pWhere = sqlite3ExprDup(p->pWhere); 4994adee20fSdanielk1977 pNew->pGroupBy = sqlite3ExprListDup(p->pGroupBy); 5004adee20fSdanielk1977 pNew->pHaving = sqlite3ExprDup(p->pHaving); 5014adee20fSdanielk1977 pNew->pOrderBy = sqlite3ExprListDup(p->pOrderBy); 502ff78bd2fSdrh pNew->op = p->op; 5034adee20fSdanielk1977 pNew->pPrior = sqlite3SelectDup(p->pPrior); 504ff78bd2fSdrh pNew->nLimit = p->nLimit; 505ff78bd2fSdrh pNew->nOffset = p->nOffset; 5067b58daeaSdrh pNew->iLimit = -1; 5077b58daeaSdrh pNew->iOffset = -1; 508dc1bdc4fSdanielk1977 pNew->ppOpenTemp = 0; 509b6c29897Sdrh pNew->pFetch = 0; 510ff78bd2fSdrh return pNew; 511ff78bd2fSdrh } 512ff78bd2fSdrh 513ff78bd2fSdrh 514ff78bd2fSdrh /* 515a76b5dfcSdrh ** Add a new element to the end of an expression list. If pList is 516a76b5dfcSdrh ** initially NULL, then create a new expression list. 517a76b5dfcSdrh */ 5184adee20fSdanielk1977 ExprList *sqlite3ExprListAppend(ExprList *pList, Expr *pExpr, Token *pName){ 519a76b5dfcSdrh if( pList==0 ){ 520a76b5dfcSdrh pList = sqliteMalloc( sizeof(ExprList) ); 521a76b5dfcSdrh if( pList==0 ){ 5224adee20fSdanielk1977 /* sqlite3ExprDelete(pExpr); // Leak memory if malloc fails */ 523a76b5dfcSdrh return 0; 524a76b5dfcSdrh } 5254efc4754Sdrh assert( pList->nAlloc==0 ); 526a76b5dfcSdrh } 5274305d103Sdrh if( pList->nAlloc<=pList->nExpr ){ 5284305d103Sdrh pList->nAlloc = pList->nAlloc*2 + 4; 5294efc4754Sdrh pList->a = sqliteRealloc(pList->a, pList->nAlloc*sizeof(pList->a[0])); 5304efc4754Sdrh if( pList->a==0 ){ 5314adee20fSdanielk1977 /* sqlite3ExprDelete(pExpr); // Leak memory if malloc fails */ 5324efc4754Sdrh pList->nExpr = pList->nAlloc = 0; 533a76b5dfcSdrh return pList; 534a76b5dfcSdrh } 535a76b5dfcSdrh } 5364efc4754Sdrh assert( pList->a!=0 ); 5374efc4754Sdrh if( pExpr || pName ){ 5384efc4754Sdrh struct ExprList_item *pItem = &pList->a[pList->nExpr++]; 5394efc4754Sdrh memset(pItem, 0, sizeof(*pItem)); 5404efc4754Sdrh pItem->pExpr = pExpr; 541a99db3b6Sdrh pItem->zName = sqlite3NameFromToken(pName); 542a76b5dfcSdrh } 543a76b5dfcSdrh return pList; 544a76b5dfcSdrh } 545a76b5dfcSdrh 546a76b5dfcSdrh /* 547a76b5dfcSdrh ** Delete an entire expression list. 548a76b5dfcSdrh */ 5494adee20fSdanielk1977 void sqlite3ExprListDelete(ExprList *pList){ 550a76b5dfcSdrh int i; 551be5c89acSdrh struct ExprList_item *pItem; 552a76b5dfcSdrh if( pList==0 ) return; 5531bdd9b57Sdrh assert( pList->a!=0 || (pList->nExpr==0 && pList->nAlloc==0) ); 5541bdd9b57Sdrh assert( pList->nExpr<=pList->nAlloc ); 555be5c89acSdrh for(pItem=pList->a, i=0; i<pList->nExpr; i++, pItem++){ 556be5c89acSdrh sqlite3ExprDelete(pItem->pExpr); 557be5c89acSdrh sqliteFree(pItem->zName); 558a76b5dfcSdrh } 559a76b5dfcSdrh sqliteFree(pList->a); 560a76b5dfcSdrh sqliteFree(pList); 561a76b5dfcSdrh } 562a76b5dfcSdrh 563a76b5dfcSdrh /* 564626a879aSdrh ** Walk an expression tree. Call xFunc for each node visited. 56573b211abSdrh ** 566626a879aSdrh ** The return value from xFunc determines whether the tree walk continues. 567626a879aSdrh ** 0 means continue walking the tree. 1 means do not walk children 568626a879aSdrh ** of the current node but continue with siblings. 2 means abandon 569626a879aSdrh ** the tree walk completely. 570626a879aSdrh ** 571626a879aSdrh ** The return value from this routine is 1 to abandon the tree walk 572626a879aSdrh ** and 0 to continue. 573626a879aSdrh */ 574626a879aSdrh static int walkExprTree(Expr *pExpr, int (*xFunc)(void*,Expr*), void *pArg){ 575626a879aSdrh ExprList *pList; 576626a879aSdrh int rc; 577626a879aSdrh if( pExpr==0 ) return 0; 578626a879aSdrh rc = (*xFunc)(pArg, pExpr); 579626a879aSdrh if( rc==0 ){ 580626a879aSdrh if( walkExprTree(pExpr->pLeft, xFunc, pArg) ) return 1; 581626a879aSdrh if( walkExprTree(pExpr->pRight, xFunc, pArg) ) return 1; 582626a879aSdrh pList = pExpr->pList; 583626a879aSdrh if( pList ){ 584626a879aSdrh int i; 585626a879aSdrh struct ExprList_item *pItem; 586626a879aSdrh for(i=pList->nExpr, pItem=pList->a; i>0; i--, pItem++){ 587626a879aSdrh if( walkExprTree(pItem->pExpr, xFunc, pArg) ) return 1; 588626a879aSdrh } 589626a879aSdrh } 590626a879aSdrh } 591626a879aSdrh return rc>1; 592626a879aSdrh } 593626a879aSdrh 594626a879aSdrh /* 595626a879aSdrh ** This routine is designed as an xFunc for walkExprTree(). 596626a879aSdrh ** 597626a879aSdrh ** pArg is really a pointer to an integer. If we can tell by looking 59873b211abSdrh ** at pExpr that the expression that contains pExpr is not a constant 59973b211abSdrh ** expression, then set *pArg to 0 and return 2 to abandon the tree walk. 60073b211abSdrh ** If pExpr does does not disqualify the expression from being a constant 60173b211abSdrh ** then do nothing. 60273b211abSdrh ** 60373b211abSdrh ** After walking the whole tree, if no nodes are found that disqualify 60473b211abSdrh ** the expression as constant, then we assume the whole expression 60573b211abSdrh ** is constant. See sqlite3ExprIsConstant() for additional information. 606626a879aSdrh */ 607626a879aSdrh static int exprNodeIsConstant(void *pArg, Expr *pExpr){ 608626a879aSdrh switch( pExpr->op ){ 609626a879aSdrh case TK_ID: 610626a879aSdrh case TK_COLUMN: 611626a879aSdrh case TK_DOT: 612626a879aSdrh case TK_AGG_FUNCTION: 613626a879aSdrh case TK_FUNCTION: 614626a879aSdrh *((int*)pArg) = 0; 615626a879aSdrh return 2; 616626a879aSdrh default: 617626a879aSdrh return 0; 618626a879aSdrh } 619626a879aSdrh } 620626a879aSdrh 621626a879aSdrh /* 622fef5208cSdrh ** Walk an expression tree. Return 1 if the expression is constant 623fef5208cSdrh ** and 0 if it involves variables. 6242398937bSdrh ** 6252398937bSdrh ** For the purposes of this function, a double-quoted string (ex: "abc") 6262398937bSdrh ** is considered a variable but a single-quoted string (ex: 'abc') is 6272398937bSdrh ** a constant. 628fef5208cSdrh */ 6294adee20fSdanielk1977 int sqlite3ExprIsConstant(Expr *p){ 630626a879aSdrh int isConst = 1; 631626a879aSdrh walkExprTree(p, exprNodeIsConstant, &isConst); 632626a879aSdrh return isConst; 633fef5208cSdrh } 634fef5208cSdrh 635fef5208cSdrh /* 63673b211abSdrh ** If the expression p codes a constant integer that is small enough 637202b2df7Sdrh ** to fit in a 32-bit integer, return 1 and put the value of the integer 638202b2df7Sdrh ** in *pValue. If the expression is not an integer or if it is too big 639202b2df7Sdrh ** to fit in a signed 32-bit integer, return 0 and leave *pValue unchanged. 640e4de1febSdrh */ 6414adee20fSdanielk1977 int sqlite3ExprIsInteger(Expr *p, int *pValue){ 642e4de1febSdrh switch( p->op ){ 643e4de1febSdrh case TK_INTEGER: { 644fec19aadSdrh if( sqlite3GetInt32(p->token.z, pValue) ){ 645e4de1febSdrh return 1; 646e4de1febSdrh } 647202b2df7Sdrh break; 648202b2df7Sdrh } 6494b59ab5eSdrh case TK_UPLUS: { 6504adee20fSdanielk1977 return sqlite3ExprIsInteger(p->pLeft, pValue); 6514b59ab5eSdrh } 652e4de1febSdrh case TK_UMINUS: { 653e4de1febSdrh int v; 6544adee20fSdanielk1977 if( sqlite3ExprIsInteger(p->pLeft, &v) ){ 655e4de1febSdrh *pValue = -v; 656e4de1febSdrh return 1; 657e4de1febSdrh } 658e4de1febSdrh break; 659e4de1febSdrh } 660e4de1febSdrh default: break; 661e4de1febSdrh } 662e4de1febSdrh return 0; 663e4de1febSdrh } 664e4de1febSdrh 665e4de1febSdrh /* 666c4a3c779Sdrh ** Return TRUE if the given string is a row-id column name. 667c4a3c779Sdrh */ 6684adee20fSdanielk1977 int sqlite3IsRowid(const char *z){ 6694adee20fSdanielk1977 if( sqlite3StrICmp(z, "_ROWID_")==0 ) return 1; 6704adee20fSdanielk1977 if( sqlite3StrICmp(z, "ROWID")==0 ) return 1; 6714adee20fSdanielk1977 if( sqlite3StrICmp(z, "OID")==0 ) return 1; 672c4a3c779Sdrh return 0; 673c4a3c779Sdrh } 674c4a3c779Sdrh 675c4a3c779Sdrh /* 6768141f61eSdrh ** Given the name of a column of the form X.Y.Z or Y.Z or just Z, look up 6778141f61eSdrh ** that name in the set of source tables in pSrcList and make the pExpr 6788141f61eSdrh ** expression node refer back to that source column. The following changes 6798141f61eSdrh ** are made to pExpr: 6808141f61eSdrh ** 6818141f61eSdrh ** pExpr->iDb Set the index in db->aDb[] of the database holding 6828141f61eSdrh ** the table. 6838141f61eSdrh ** pExpr->iTable Set to the cursor number for the table obtained 6848141f61eSdrh ** from pSrcList. 6858141f61eSdrh ** pExpr->iColumn Set to the column number within the table. 6868141f61eSdrh ** pExpr->op Set to TK_COLUMN. 6878141f61eSdrh ** pExpr->pLeft Any expression this points to is deleted 6888141f61eSdrh ** pExpr->pRight Any expression this points to is deleted. 6898141f61eSdrh ** 6908141f61eSdrh ** The pDbToken is the name of the database (the "X"). This value may be 6918141f61eSdrh ** NULL meaning that name is of the form Y.Z or Z. Any available database 6928141f61eSdrh ** can be used. The pTableToken is the name of the table (the "Y"). This 6938141f61eSdrh ** value can be NULL if pDbToken is also NULL. If pTableToken is NULL it 6948141f61eSdrh ** means that the form of the name is Z and that columns from any table 6958141f61eSdrh ** can be used. 6968141f61eSdrh ** 6978141f61eSdrh ** If the name cannot be resolved unambiguously, leave an error message 6988141f61eSdrh ** in pParse and return non-zero. Return zero on success. 6998141f61eSdrh */ 7008141f61eSdrh static int lookupName( 7018141f61eSdrh Parse *pParse, /* The parsing context */ 7028141f61eSdrh Token *pDbToken, /* Name of the database containing table, or NULL */ 7038141f61eSdrh Token *pTableToken, /* Name of table containing column, or NULL */ 7048141f61eSdrh Token *pColumnToken, /* Name of the column. */ 705626a879aSdrh NameContext *pNC, /* The name context used to resolve the name */ 7068141f61eSdrh Expr *pExpr /* Make this EXPR node point to the selected column */ 7078141f61eSdrh ){ 7088141f61eSdrh char *zDb = 0; /* Name of the database. The "X" in X.Y.Z */ 7098141f61eSdrh char *zTab = 0; /* Name of the table. The "Y" in X.Y.Z or Y.Z */ 7108141f61eSdrh char *zCol = 0; /* Name of the column. The "Z" */ 7118141f61eSdrh int i, j; /* Loop counters */ 7128141f61eSdrh int cnt = 0; /* Number of matching column names */ 7138141f61eSdrh int cntTab = 0; /* Number of matching table names */ 7149bb575fdSdrh sqlite3 *db = pParse->db; /* The database */ 71551669863Sdrh struct SrcList_item *pItem; /* Use for looping over pSrcList items */ 71651669863Sdrh struct SrcList_item *pMatch = 0; /* The matching pSrcList item */ 71773b211abSdrh NameContext *pTopNC = pNC; /* First namecontext in the list */ 7188141f61eSdrh 7198141f61eSdrh assert( pColumnToken && pColumnToken->z ); /* The Z in X.Y.Z cannot be NULL */ 720a99db3b6Sdrh zDb = sqlite3NameFromToken(pDbToken); 721a99db3b6Sdrh zTab = sqlite3NameFromToken(pTableToken); 722a99db3b6Sdrh zCol = sqlite3NameFromToken(pColumnToken); 72324b03fd0Sdanielk1977 if( sqlite3_malloc_failed ){ 7248141f61eSdrh return 1; /* Leak memory (zDb and zTab) if malloc fails */ 7258141f61eSdrh } 7268141f61eSdrh 7278141f61eSdrh pExpr->iTable = -1; 728626a879aSdrh while( pNC && cnt==0 ){ 729626a879aSdrh SrcList *pSrcList = pNC->pSrcList; 730626a879aSdrh ExprList *pEList = pNC->pEList; 731626a879aSdrh 732626a879aSdrh pNC->nRef++; 733626a879aSdrh /* assert( zTab==0 || pEList==0 ); */ 73451669863Sdrh for(i=0, pItem=pSrcList->a; i<pSrcList->nSrc; i++, pItem++){ 7358141f61eSdrh Table *pTab = pItem->pTab; 7368141f61eSdrh Column *pCol; 7378141f61eSdrh 7388141f61eSdrh if( pTab==0 ) continue; 7398141f61eSdrh assert( pTab->nCol>0 ); 7408141f61eSdrh if( zTab ){ 7418141f61eSdrh if( pItem->zAlias ){ 7428141f61eSdrh char *zTabName = pItem->zAlias; 7434adee20fSdanielk1977 if( sqlite3StrICmp(zTabName, zTab)!=0 ) continue; 7448141f61eSdrh }else{ 7458141f61eSdrh char *zTabName = pTab->zName; 7464adee20fSdanielk1977 if( zTabName==0 || sqlite3StrICmp(zTabName, zTab)!=0 ) continue; 7474adee20fSdanielk1977 if( zDb!=0 && sqlite3StrICmp(db->aDb[pTab->iDb].zName, zDb)!=0 ){ 7488141f61eSdrh continue; 7498141f61eSdrh } 7508141f61eSdrh } 7518141f61eSdrh } 7528141f61eSdrh if( 0==(cntTab++) ){ 7538141f61eSdrh pExpr->iTable = pItem->iCursor; 7548141f61eSdrh pExpr->iDb = pTab->iDb; 75551669863Sdrh pMatch = pItem; 7568141f61eSdrh } 7578141f61eSdrh for(j=0, pCol=pTab->aCol; j<pTab->nCol; j++, pCol++){ 7584adee20fSdanielk1977 if( sqlite3StrICmp(pCol->zName, zCol)==0 ){ 7598141f61eSdrh cnt++; 7608141f61eSdrh pExpr->iTable = pItem->iCursor; 76151669863Sdrh pMatch = pItem; 7628141f61eSdrh pExpr->iDb = pTab->iDb; 7638141f61eSdrh /* Substitute the rowid (column -1) for the INTEGER PRIMARY KEY */ 7648141f61eSdrh pExpr->iColumn = j==pTab->iPKey ? -1 : j; 765a37cdde0Sdanielk1977 pExpr->affinity = pTab->aCol[j].affinity; 7660202b29eSdanielk1977 pExpr->pColl = pTab->aCol[j].pColl; 7678141f61eSdrh break; 7688141f61eSdrh } 7698141f61eSdrh } 7708141f61eSdrh } 7718141f61eSdrh 772b7f9164eSdrh #ifndef SQLITE_OMIT_TRIGGER 7738141f61eSdrh /* If we have not already resolved the name, then maybe 7748141f61eSdrh ** it is a new.* or old.* trigger argument reference 7758141f61eSdrh */ 7768141f61eSdrh if( zDb==0 && zTab!=0 && cnt==0 && pParse->trigStack!=0 ){ 7778141f61eSdrh TriggerStack *pTriggerStack = pParse->trigStack; 7788141f61eSdrh Table *pTab = 0; 7794adee20fSdanielk1977 if( pTriggerStack->newIdx != -1 && sqlite3StrICmp("new", zTab) == 0 ){ 7808141f61eSdrh pExpr->iTable = pTriggerStack->newIdx; 7818141f61eSdrh assert( pTriggerStack->pTab ); 7828141f61eSdrh pTab = pTriggerStack->pTab; 7834adee20fSdanielk1977 }else if( pTriggerStack->oldIdx != -1 && sqlite3StrICmp("old", zTab)==0 ){ 7848141f61eSdrh pExpr->iTable = pTriggerStack->oldIdx; 7858141f61eSdrh assert( pTriggerStack->pTab ); 7868141f61eSdrh pTab = pTriggerStack->pTab; 7878141f61eSdrh } 7888141f61eSdrh 7898141f61eSdrh if( pTab ){ 7908141f61eSdrh int j; 7918141f61eSdrh Column *pCol = pTab->aCol; 7928141f61eSdrh 7938141f61eSdrh pExpr->iDb = pTab->iDb; 7948141f61eSdrh cntTab++; 7958141f61eSdrh for(j=0; j < pTab->nCol; j++, pCol++) { 7964adee20fSdanielk1977 if( sqlite3StrICmp(pCol->zName, zCol)==0 ){ 7978141f61eSdrh cnt++; 7988141f61eSdrh pExpr->iColumn = j==pTab->iPKey ? -1 : j; 799a37cdde0Sdanielk1977 pExpr->affinity = pTab->aCol[j].affinity; 8000202b29eSdanielk1977 pExpr->pColl = pTab->aCol[j].pColl; 8018141f61eSdrh break; 8028141f61eSdrh } 8038141f61eSdrh } 8048141f61eSdrh } 8058141f61eSdrh } 806b7f9164eSdrh #endif /* !defined(SQLITE_OMIT_TRIGGER) */ 8078141f61eSdrh 8088141f61eSdrh /* 8098141f61eSdrh ** Perhaps the name is a reference to the ROWID 8108141f61eSdrh */ 8114adee20fSdanielk1977 if( cnt==0 && cntTab==1 && sqlite3IsRowid(zCol) ){ 8128141f61eSdrh cnt = 1; 8138141f61eSdrh pExpr->iColumn = -1; 814a37cdde0Sdanielk1977 pExpr->affinity = SQLITE_AFF_INTEGER; 8158141f61eSdrh } 8168141f61eSdrh 8178141f61eSdrh /* 8188141f61eSdrh ** If the input is of the form Z (not Y.Z or X.Y.Z) then the name Z 8198141f61eSdrh ** might refer to an result-set alias. This happens, for example, when 8208141f61eSdrh ** we are resolving names in the WHERE clause of the following command: 8218141f61eSdrh ** 8228141f61eSdrh ** SELECT a+b AS x FROM table WHERE x<10; 8238141f61eSdrh ** 8248141f61eSdrh ** In cases like this, replace pExpr with a copy of the expression that 8258141f61eSdrh ** forms the result set entry ("a+b" in the example) and return immediately. 8268141f61eSdrh ** Note that the expression in the result set should have already been 8278141f61eSdrh ** resolved by the time the WHERE clause is resolved. 8288141f61eSdrh */ 82979d5f63fSdrh if( cnt==0 && pEList!=0 && zTab==0 ){ 8308141f61eSdrh for(j=0; j<pEList->nExpr; j++){ 8318141f61eSdrh char *zAs = pEList->a[j].zName; 8324adee20fSdanielk1977 if( zAs!=0 && sqlite3StrICmp(zAs, zCol)==0 ){ 8338141f61eSdrh assert( pExpr->pLeft==0 && pExpr->pRight==0 ); 8348141f61eSdrh pExpr->op = TK_AS; 8358141f61eSdrh pExpr->iColumn = j; 8364adee20fSdanielk1977 pExpr->pLeft = sqlite3ExprDup(pEList->a[j].pExpr); 8378141f61eSdrh sqliteFree(zCol); 8388141f61eSdrh assert( zTab==0 && zDb==0 ); 8398141f61eSdrh return 0; 8408141f61eSdrh } 8418141f61eSdrh } 8428141f61eSdrh } 8438141f61eSdrh 844626a879aSdrh /* Advance to the next name context. The loop will exit when either 845626a879aSdrh ** we have a match (cnt>0) or when we run out of name contexts. 846626a879aSdrh */ 847626a879aSdrh if( cnt==0 ){ 848626a879aSdrh pNC = pNC->pNext; 849626a879aSdrh } 850626a879aSdrh } 851626a879aSdrh 8528141f61eSdrh /* 8538141f61eSdrh ** If X and Y are NULL (in other words if only the column name Z is 8548141f61eSdrh ** supplied) and the value of Z is enclosed in double-quotes, then 8558141f61eSdrh ** Z is a string literal if it doesn't match any column names. In that 8568141f61eSdrh ** case, we need to return right away and not make any changes to 8578141f61eSdrh ** pExpr. 8588141f61eSdrh */ 8598141f61eSdrh if( cnt==0 && zTab==0 && pColumnToken->z[0]=='"' ){ 8608141f61eSdrh sqliteFree(zCol); 8618141f61eSdrh return 0; 8628141f61eSdrh } 8638141f61eSdrh 8648141f61eSdrh /* 8658141f61eSdrh ** cnt==0 means there was not match. cnt>1 means there were two or 8668141f61eSdrh ** more matches. Either way, we have an error. 8678141f61eSdrh */ 8688141f61eSdrh if( cnt!=1 ){ 8698141f61eSdrh char *z = 0; 8708141f61eSdrh char *zErr; 8718141f61eSdrh zErr = cnt==0 ? "no such column: %s" : "ambiguous column name: %s"; 8728141f61eSdrh if( zDb ){ 8734adee20fSdanielk1977 sqlite3SetString(&z, zDb, ".", zTab, ".", zCol, 0); 8748141f61eSdrh }else if( zTab ){ 8754adee20fSdanielk1977 sqlite3SetString(&z, zTab, ".", zCol, 0); 8768141f61eSdrh }else{ 8778141f61eSdrh z = sqliteStrDup(zCol); 8788141f61eSdrh } 8794adee20fSdanielk1977 sqlite3ErrorMsg(pParse, zErr, z); 8808141f61eSdrh sqliteFree(z); 88173b211abSdrh pTopNC->nErr++; 8828141f61eSdrh } 8838141f61eSdrh 88451669863Sdrh /* If a column from a table in pSrcList is referenced, then record 88551669863Sdrh ** this fact in the pSrcList.a[].colUsed bitmask. Column 0 causes 88651669863Sdrh ** bit 0 to be set. Column 1 sets bit 1. And so forth. If the 88751669863Sdrh ** column number is greater than the number of bits in the bitmask 88851669863Sdrh ** then set the high-order bit of the bitmask. 88951669863Sdrh */ 89051669863Sdrh if( pExpr->iColumn>=0 && pMatch!=0 ){ 89151669863Sdrh int n = pExpr->iColumn; 89251669863Sdrh if( n>=sizeof(Bitmask)*8 ){ 89351669863Sdrh n = sizeof(Bitmask)*8-1; 89451669863Sdrh } 89551669863Sdrh assert( pMatch->iCursor==pExpr->iTable ); 89651669863Sdrh pMatch->colUsed |= 1<<n; 89751669863Sdrh } 89851669863Sdrh 8998141f61eSdrh /* Clean up and return 9008141f61eSdrh */ 9018141f61eSdrh sqliteFree(zDb); 9028141f61eSdrh sqliteFree(zTab); 9038141f61eSdrh sqliteFree(zCol); 9044adee20fSdanielk1977 sqlite3ExprDelete(pExpr->pLeft); 9058141f61eSdrh pExpr->pLeft = 0; 9064adee20fSdanielk1977 sqlite3ExprDelete(pExpr->pRight); 9078141f61eSdrh pExpr->pRight = 0; 9088141f61eSdrh pExpr->op = TK_COLUMN; 909626a879aSdrh if( cnt==1 ){ 910626a879aSdrh assert( pNC!=0 && pNC->pSrcList!=0 ); 911626a879aSdrh sqlite3AuthRead(pParse, pExpr, pNC->pSrcList); 912626a879aSdrh } 9138141f61eSdrh return cnt!=1; 9148141f61eSdrh } 9158141f61eSdrh 9168141f61eSdrh /* 917626a879aSdrh ** pExpr is a node that defines a function of some kind. It might 918626a879aSdrh ** be a syntactic function like "count(x)" or it might be a function 919626a879aSdrh ** that implements an operator, like "a LIKE b". 920626a879aSdrh ** 921626a879aSdrh ** This routine makes *pzName point to the name of the function and 922626a879aSdrh ** *pnName hold the number of characters in the function name. 923626a879aSdrh */ 924626a879aSdrh static void getFunctionName(Expr *pExpr, const char **pzName, int *pnName){ 925626a879aSdrh switch( pExpr->op ){ 926626a879aSdrh case TK_FUNCTION: { 927626a879aSdrh *pzName = pExpr->token.z; 928626a879aSdrh *pnName = pExpr->token.n; 929626a879aSdrh break; 930626a879aSdrh } 931626a879aSdrh case TK_LIKE: { 932626a879aSdrh *pzName = "like"; 933626a879aSdrh *pnName = 4; 934626a879aSdrh break; 935626a879aSdrh } 936626a879aSdrh case TK_GLOB: { 937626a879aSdrh *pzName = "glob"; 938626a879aSdrh *pnName = 4; 939626a879aSdrh break; 940626a879aSdrh } 941626a879aSdrh case TK_CTIME: { 942626a879aSdrh *pzName = "current_time"; 943626a879aSdrh *pnName = 12; 944626a879aSdrh break; 945626a879aSdrh } 946626a879aSdrh case TK_CDATE: { 947626a879aSdrh *pzName = "current_date"; 948626a879aSdrh *pnName = 12; 949626a879aSdrh break; 950626a879aSdrh } 951626a879aSdrh case TK_CTIMESTAMP: { 952626a879aSdrh *pzName = "current_timestamp"; 953626a879aSdrh *pnName = 17; 954626a879aSdrh break; 955626a879aSdrh } 956626a879aSdrh default: { 957626a879aSdrh *pzName = "can't happen"; 958626a879aSdrh *pnName = 12; 959626a879aSdrh break; 960626a879aSdrh } 961626a879aSdrh } 962626a879aSdrh } 963626a879aSdrh 964626a879aSdrh /* 965626a879aSdrh ** This routine is designed as an xFunc for walkExprTree(). 966626a879aSdrh ** 96773b211abSdrh ** Resolve symbolic names into TK_COLUMN operators for the current 968626a879aSdrh ** node in the expression tree. Return 0 to continue the search down 96973b211abSdrh ** the tree or 2 to abort the tree walk. 97073b211abSdrh ** 97173b211abSdrh ** This routine also does error checking and name resolution for 97273b211abSdrh ** function names. The operator for aggregate functions is changed 97373b211abSdrh ** to TK_AGG_FUNCTION. 974626a879aSdrh */ 975626a879aSdrh static int nameResolverStep(void *pArg, Expr *pExpr){ 976626a879aSdrh NameContext *pNC = (NameContext*)pArg; 977626a879aSdrh SrcList *pSrcList; 978626a879aSdrh Parse *pParse; 979626a879aSdrh int i; 980626a879aSdrh 981626a879aSdrh assert( pNC!=0 ); 982626a879aSdrh pSrcList = pNC->pSrcList; 983626a879aSdrh pParse = pNC->pParse; 984626a879aSdrh if( pExpr==0 ) return 1; 985626a879aSdrh if( ExprHasAnyProperty(pExpr, EP_Resolved) ) return 1; 986626a879aSdrh ExprSetProperty(pExpr, EP_Resolved); 987626a879aSdrh #ifndef NDEBUG 988626a879aSdrh if( pSrcList ){ 989626a879aSdrh for(i=0; i<pSrcList->nSrc; i++){ 990626a879aSdrh assert( pSrcList->a[i].iCursor>=0 && pSrcList->a[i].iCursor<pParse->nTab); 991626a879aSdrh } 992626a879aSdrh } 993626a879aSdrh #endif 994626a879aSdrh switch( pExpr->op ){ 995626a879aSdrh /* Double-quoted strings (ex: "abc") are used as identifiers if 996626a879aSdrh ** possible. Otherwise they remain as strings. Single-quoted 997626a879aSdrh ** strings (ex: 'abc') are always string literals. 998626a879aSdrh */ 999626a879aSdrh case TK_STRING: { 1000626a879aSdrh if( pExpr->token.z[0]=='\'' ) break; 1001626a879aSdrh /* Fall thru into the TK_ID case if this is a double-quoted string */ 1002626a879aSdrh } 1003626a879aSdrh /* A lone identifier is the name of a column. 1004626a879aSdrh */ 1005626a879aSdrh case TK_ID: { 1006626a879aSdrh if( pSrcList==0 ) break; 1007626a879aSdrh lookupName(pParse, 0, 0, &pExpr->token, pNC, pExpr); 1008626a879aSdrh return 1; 1009626a879aSdrh } 1010626a879aSdrh 1011626a879aSdrh /* A table name and column name: ID.ID 1012626a879aSdrh ** Or a database, table and column: ID.ID.ID 1013626a879aSdrh */ 1014626a879aSdrh case TK_DOT: { 1015626a879aSdrh Token *pColumn; 1016626a879aSdrh Token *pTable; 1017626a879aSdrh Token *pDb; 1018626a879aSdrh Expr *pRight; 1019626a879aSdrh 1020626a879aSdrh if( pSrcList==0 ) break; 1021626a879aSdrh pRight = pExpr->pRight; 1022626a879aSdrh if( pRight->op==TK_ID ){ 1023626a879aSdrh pDb = 0; 1024626a879aSdrh pTable = &pExpr->pLeft->token; 1025626a879aSdrh pColumn = &pRight->token; 1026626a879aSdrh }else{ 1027626a879aSdrh assert( pRight->op==TK_DOT ); 1028626a879aSdrh pDb = &pExpr->pLeft->token; 1029626a879aSdrh pTable = &pRight->pLeft->token; 1030626a879aSdrh pColumn = &pRight->pRight->token; 1031626a879aSdrh } 1032626a879aSdrh lookupName(pParse, pDb, pTable, pColumn, pNC, pExpr); 1033626a879aSdrh return 1; 1034626a879aSdrh } 1035626a879aSdrh 1036626a879aSdrh /* Resolve function names 1037626a879aSdrh */ 1038626a879aSdrh case TK_CTIME: 1039626a879aSdrh case TK_CTIMESTAMP: 1040626a879aSdrh case TK_CDATE: 1041626a879aSdrh /* Note: The above three were a seperate case in sqlmoto. Reason? */ 1042626a879aSdrh case TK_GLOB: 1043626a879aSdrh case TK_LIKE: 1044626a879aSdrh case TK_FUNCTION: { 1045626a879aSdrh ExprList *pList = pExpr->pList; /* The argument list */ 1046626a879aSdrh int n = pList ? pList->nExpr : 0; /* Number of arguments */ 1047626a879aSdrh int no_such_func = 0; /* True if no such function exists */ 1048626a879aSdrh int wrong_num_args = 0; /* True if wrong number of arguments */ 1049626a879aSdrh int is_agg = 0; /* True if is an aggregate function */ 1050626a879aSdrh int i; 1051626a879aSdrh int nId; /* Number of characters in function name */ 1052626a879aSdrh const char *zId; /* The function name. */ 105373b211abSdrh FuncDef *pDef; /* Information about the function */ 105473b211abSdrh int enc = pParse->db->enc; /* The database encoding */ 1055626a879aSdrh 1056626a879aSdrh getFunctionName(pExpr, &zId, &nId); 1057626a879aSdrh pDef = sqlite3FindFunction(pParse->db, zId, nId, n, enc, 0); 1058626a879aSdrh if( pDef==0 ){ 1059626a879aSdrh pDef = sqlite3FindFunction(pParse->db, zId, nId, -1, enc, 0); 1060626a879aSdrh if( pDef==0 ){ 1061626a879aSdrh no_such_func = 1; 1062626a879aSdrh }else{ 1063626a879aSdrh wrong_num_args = 1; 1064626a879aSdrh } 1065626a879aSdrh }else{ 1066626a879aSdrh is_agg = pDef->xFunc==0; 1067626a879aSdrh } 1068626a879aSdrh if( is_agg && !pNC->allowAgg ){ 1069626a879aSdrh sqlite3ErrorMsg(pParse, "misuse of aggregate function %.*s()", nId,zId); 1070626a879aSdrh pNC->nErr++; 1071626a879aSdrh is_agg = 0; 1072626a879aSdrh }else if( no_such_func ){ 1073626a879aSdrh sqlite3ErrorMsg(pParse, "no such function: %.*s", nId, zId); 1074626a879aSdrh pNC->nErr++; 1075626a879aSdrh }else if( wrong_num_args ){ 1076626a879aSdrh sqlite3ErrorMsg(pParse,"wrong number of arguments to function %.*s()", 1077626a879aSdrh nId, zId); 1078626a879aSdrh pNC->nErr++; 1079626a879aSdrh } 1080626a879aSdrh if( is_agg ){ 1081626a879aSdrh pExpr->op = TK_AGG_FUNCTION; 1082626a879aSdrh pNC->hasAgg = 1; 1083626a879aSdrh } 108473b211abSdrh if( is_agg ) pNC->allowAgg = 0; 1085626a879aSdrh for(i=0; pNC->nErr==0 && i<n; i++){ 108673b211abSdrh walkExprTree(pList->a[i].pExpr, nameResolverStep, pNC); 1087626a879aSdrh } 108873b211abSdrh if( is_agg ) pNC->allowAgg = 1; 1089626a879aSdrh /* FIX ME: Compute pExpr->affinity based on the expected return 1090626a879aSdrh ** type of the function 1091626a879aSdrh */ 1092626a879aSdrh return is_agg; 1093626a879aSdrh } 1094626a879aSdrh } 1095626a879aSdrh return 0; 1096626a879aSdrh } 1097626a879aSdrh 10981398ad36Sdrh /* Forward declaration */ 10991398ad36Sdrh static int sqlite3ExprCodeSubquery(Parse*, NameContext*, Expr*); 11001398ad36Sdrh 1101626a879aSdrh /* 1102cce7d176Sdrh ** This routine walks an expression tree and resolves references to 1103967e8b73Sdrh ** table columns. Nodes of the form ID.ID or ID resolve into an 1104aacc543eSdrh ** index to the table in the table list and a column offset. The 1105aacc543eSdrh ** Expr.opcode for such nodes is changed to TK_COLUMN. The Expr.iTable 1106aacc543eSdrh ** value is changed to the index of the referenced table in pTabList 1107832508b7Sdrh ** plus the "base" value. The base value will ultimately become the 1108aacc543eSdrh ** VDBE cursor number for a cursor that is pointing into the referenced 1109aacc543eSdrh ** table. The Expr.iColumn value is changed to the index of the column 1110aacc543eSdrh ** of the referenced table. The Expr.iColumn value for the special 1111aacc543eSdrh ** ROWID column is -1. Any INTEGER PRIMARY KEY column is tried as an 1112aacc543eSdrh ** alias for ROWID. 111319a775c2Sdrh ** 1114626a879aSdrh ** Also resolve function names and check the functions for proper 1115626a879aSdrh ** usage. Make sure all function names are recognized and all functions 1116626a879aSdrh ** have the correct number of arguments. Leave an error message 1117626a879aSdrh ** in pParse->zErrMsg if anything is amiss. Return the number of errors. 1118626a879aSdrh ** 111973b211abSdrh ** If the expression contains aggregate functions then set the EP_Agg 112073b211abSdrh ** property on the expression. 1121626a879aSdrh */ 1122626a879aSdrh int sqlite3ExprResolveNames( 1123626a879aSdrh Parse *pParse, /* The parser context */ 1124626a879aSdrh SrcList *pSrcList, /* List of tables used to resolve column names */ 1125626a879aSdrh ExprList *pEList, /* List of expressions used to resolve "AS" */ 11261398ad36Sdrh NameContext *pNC, /* Namespace of enclosing statement */ 1127626a879aSdrh Expr *pExpr, /* The expression to be analyzed. */ 1128626a879aSdrh int allowAgg, /* True to allow aggregate expressions */ 1129626a879aSdrh int codeSubquery /* If true, then generate code for subqueries too */ 1130626a879aSdrh ){ 1131626a879aSdrh NameContext sNC; 1132626a879aSdrh 113373b211abSdrh if( pExpr==0 ) return 0; 1134626a879aSdrh memset(&sNC, 0, sizeof(sNC)); 1135626a879aSdrh sNC.pSrcList = pSrcList; 1136626a879aSdrh sNC.pParse = pParse; 1137626a879aSdrh sNC.pEList = pEList; 1138626a879aSdrh sNC.allowAgg = allowAgg; 11391398ad36Sdrh sNC.pNext = pNC; 1140626a879aSdrh walkExprTree(pExpr, nameResolverStep, &sNC); 114173b211abSdrh if( sNC.hasAgg ){ 114273b211abSdrh ExprSetProperty(pExpr, EP_Agg); 1143626a879aSdrh } 114473b211abSdrh if( sNC.nErr>0 ){ 114573b211abSdrh ExprSetProperty(pExpr, EP_Error); 11461398ad36Sdrh }else if( codeSubquery && sqlite3ExprCodeSubquery(pParse, &sNC, pExpr) ){ 114773b211abSdrh return 1; 114873b211abSdrh } 114973b211abSdrh return ExprHasProperty(pExpr, EP_Error); 1150626a879aSdrh } 1151626a879aSdrh 11521398ad36Sdrh /* 11531398ad36Sdrh ** A pointer instance of this structure is used to pass information 11541398ad36Sdrh ** through walkExprTree into codeSubqueryStep(). 11551398ad36Sdrh */ 11561398ad36Sdrh typedef struct QueryCoder QueryCoder; 11571398ad36Sdrh struct QueryCoder { 11581398ad36Sdrh Parse *pParse; /* The parsing context */ 11591398ad36Sdrh NameContext *pNC; /* Namespace of first enclosing query */ 11601398ad36Sdrh }; 11611398ad36Sdrh 1162626a879aSdrh 1163626a879aSdrh /* 1164626a879aSdrh ** Generate code for subqueries and IN operators. 1165626a879aSdrh ** 116673b211abSdrh ** IN operators comes in two forms: 1167fef5208cSdrh ** 1168fef5208cSdrh ** expr IN (exprlist) 1169fef5208cSdrh ** and 1170fef5208cSdrh ** expr IN (SELECT ...) 1171fef5208cSdrh ** 1172fef5208cSdrh ** The first form is handled by creating a set holding the list 1173fef5208cSdrh ** of allowed values. The second form causes the SELECT to generate 1174fef5208cSdrh ** a temporary table. 1175fef5208cSdrh ** 1176fef5208cSdrh ** This routine also looks for scalar SELECTs that are part of an expression. 117719a775c2Sdrh ** If it finds any, it generates code to write the value of that select 117819a775c2Sdrh ** into a memory cell. 117973b211abSdrh ** 118073b211abSdrh ** This routine is a callback for wallExprTree() used to implement 118173b211abSdrh ** sqlite3ExprCodeSubquery(). See comments on those routines for 118273b211abSdrh ** additional information. 1183cce7d176Sdrh */ 1184626a879aSdrh static int codeSubqueryStep(void *pArg, Expr *pExpr){ 11851398ad36Sdrh QueryCoder *pCoder = (QueryCoder*)pArg; 11861398ad36Sdrh Parse *pParse = pCoder->pParse; 11876a3ea0e6Sdrh 1188cce7d176Sdrh switch( pExpr->op ){ 1189fef5208cSdrh case TK_IN: { 1190e014a838Sdanielk1977 char affinity; 11914adee20fSdanielk1977 Vdbe *v = sqlite3GetVdbe(pParse); 1192d3d39e93Sdrh KeyInfo keyInfo; 11930202b29eSdanielk1977 int addr; /* Address of OP_OpenTemp instruction */ 1194d3d39e93Sdrh 1195626a879aSdrh if( v==0 ) return 2; 1196bf3b721fSdanielk1977 affinity = sqlite3ExprAffinity(pExpr->pLeft); 1197e014a838Sdanielk1977 1198e014a838Sdanielk1977 /* Whether this is an 'x IN(SELECT...)' or an 'x IN(<exprlist>)' 1199e014a838Sdanielk1977 ** expression it is handled the same way. A temporary table is 1200e014a838Sdanielk1977 ** filled with single-field index keys representing the results 1201e014a838Sdanielk1977 ** from the SELECT or the <exprlist>. 1202fef5208cSdrh ** 1203e014a838Sdanielk1977 ** If the 'x' expression is a column value, or the SELECT... 1204e014a838Sdanielk1977 ** statement returns a column value, then the affinity of that 1205e014a838Sdanielk1977 ** column is used to build the index keys. If both 'x' and the 1206e014a838Sdanielk1977 ** SELECT... statement are columns, then numeric affinity is used 1207e014a838Sdanielk1977 ** if either column has NUMERIC or INTEGER affinity. If neither 1208e014a838Sdanielk1977 ** 'x' nor the SELECT... statement are columns, then numeric affinity 1209e014a838Sdanielk1977 ** is used. 1210fef5208cSdrh */ 1211832508b7Sdrh pExpr->iTable = pParse->nTab++; 12120202b29eSdanielk1977 addr = sqlite3VdbeAddOp(v, OP_OpenTemp, pExpr->iTable, 0); 1213d3d39e93Sdrh memset(&keyInfo, 0, sizeof(keyInfo)); 1214d3d39e93Sdrh keyInfo.nField = 1; 1215f3218feaSdrh sqlite3VdbeAddOp(v, OP_SetNumColumns, pExpr->iTable, 1); 1216e014a838Sdanielk1977 1217e014a838Sdanielk1977 if( pExpr->pSelect ){ 1218e014a838Sdanielk1977 /* Case 1: expr IN (SELECT ...) 1219e014a838Sdanielk1977 ** 1220e014a838Sdanielk1977 ** Generate code to write the results of the select into the temporary 1221e014a838Sdanielk1977 ** table allocated and opened above. 1222e014a838Sdanielk1977 */ 1223e014a838Sdanielk1977 int iParm = pExpr->iTable + (((int)affinity)<<16); 1224be5c89acSdrh ExprList *pEList; 1225e014a838Sdanielk1977 assert( (pExpr->iTable&0x0000FFFF)==pExpr->iTable ); 12261398ad36Sdrh sqlite3Select(pParse, pExpr->pSelect, SRT_Set, iParm, 0, 0, 0, 0, 0); 1227be5c89acSdrh pEList = pExpr->pSelect->pEList; 1228be5c89acSdrh if( pEList && pEList->nExpr>0 ){ 12297cedc8d4Sdanielk1977 keyInfo.aColl[0] = binaryCompareCollSeq(pParse, pExpr->pLeft, 1230be5c89acSdrh pEList->a[0].pExpr); 12310202b29eSdanielk1977 } 1232fef5208cSdrh }else if( pExpr->pList ){ 1233fef5208cSdrh /* Case 2: expr IN (exprlist) 1234fef5208cSdrh ** 1235e014a838Sdanielk1977 ** For each expression, build an index key from the evaluation and 1236e014a838Sdanielk1977 ** store it in the temporary table. If <expr> is a column, then use 1237e014a838Sdanielk1977 ** that columns affinity when building index keys. If <expr> is not 1238e014a838Sdanielk1977 ** a column, use numeric affinity. 1239fef5208cSdrh */ 1240e014a838Sdanielk1977 int i; 1241e014a838Sdanielk1977 if( !affinity ){ 1242e014a838Sdanielk1977 affinity = SQLITE_AFF_NUMERIC; 1243e014a838Sdanielk1977 } 12440202b29eSdanielk1977 keyInfo.aColl[0] = pExpr->pLeft->pColl; 1245e014a838Sdanielk1977 1246e014a838Sdanielk1977 /* Loop through each expression in <exprlist>. */ 1247fef5208cSdrh for(i=0; i<pExpr->pList->nExpr; i++){ 1248fef5208cSdrh Expr *pE2 = pExpr->pList->a[i].pExpr; 1249e014a838Sdanielk1977 1250e014a838Sdanielk1977 /* Check that the expression is constant and valid. */ 12514adee20fSdanielk1977 if( !sqlite3ExprIsConstant(pE2) ){ 12524adee20fSdanielk1977 sqlite3ErrorMsg(pParse, 1253da93d238Sdrh "right-hand side of IN operator must be constant"); 1254626a879aSdrh return 2; 1255fef5208cSdrh } 12561398ad36Sdrh if( sqlite3ExprResolveNames(pParse, 0, 0, 0, pE2, 0, 0) ){ 1257626a879aSdrh return 2; 12584794b980Sdrh } 1259e014a838Sdanielk1977 1260e014a838Sdanielk1977 /* Evaluate the expression and insert it into the temp table */ 12614adee20fSdanielk1977 sqlite3ExprCode(pParse, pE2); 126294a11211Sdrh sqlite3VdbeOp3(v, OP_MakeRecord, 1, 0, &affinity, 1); 12630f69c1e3Sdanielk1977 sqlite3VdbeAddOp(v, OP_String8, 0, 0); 1264e014a838Sdanielk1977 sqlite3VdbeAddOp(v, OP_PutStrKey, pExpr->iTable, 0); 1265fef5208cSdrh } 1266fef5208cSdrh } 12670202b29eSdanielk1977 sqlite3VdbeChangeP3(v, addr, (void *)&keyInfo, P3_KEYINFO); 1268626a879aSdrh return 1; 1269fef5208cSdrh } 1270fef5208cSdrh 127119a775c2Sdrh case TK_SELECT: { 1272fef5208cSdrh /* This has to be a scalar SELECT. Generate code to put the 1273fef5208cSdrh ** value of this select in a memory cell and record the number 1274967e8b73Sdrh ** of the memory cell in iColumn. 1275fef5208cSdrh */ 12761398ad36Sdrh NameContext *pNC; 12771398ad36Sdrh int nRef; 12781398ad36Sdrh Vdbe *v; 12791398ad36Sdrh int addr; 12801398ad36Sdrh 12811398ad36Sdrh pNC = pCoder->pNC; 12821398ad36Sdrh if( pNC ) nRef = pNC->nRef; 1283*3119bc42Sdrh sqlite3CodeVerifySchema(pParse, -1); /* Insert the cookie verifier Goto */ 12841398ad36Sdrh v = sqlite3GetVdbe(pParse); 12851398ad36Sdrh addr = sqlite3VdbeAddOp(v, OP_Goto, 0, 0); 1286967e8b73Sdrh pExpr->iColumn = pParse->nMem++; 12871398ad36Sdrh sqlite3Select(pParse, pExpr->pSelect, SRT_Mem,pExpr->iColumn,0,0,0,0,pNC); 12881398ad36Sdrh if( pNC && pNC->nRef>nRef ){ 12891398ad36Sdrh /* Subquery value changes. Evaluate at each use */ 12901398ad36Sdrh pExpr->iTable = addr+1; 12911398ad36Sdrh sqlite3VdbeAddOp(v, OP_Return, 0, 0); 12921398ad36Sdrh sqlite3VdbeChangeP2(v, addr, sqlite3VdbeCurrentAddr(v)); 12931398ad36Sdrh }else{ 12941398ad36Sdrh /* Subquery value is constant. evaluate only once. */ 12951398ad36Sdrh pExpr->iTable = -1; 12961398ad36Sdrh sqlite3VdbeChangeP2(v, addr, addr+1); 12971398ad36Sdrh } 129819a775c2Sdrh return 1; 129919a775c2Sdrh } 1300cce7d176Sdrh } 1301cce7d176Sdrh return 0; 1302cce7d176Sdrh } 1303cce7d176Sdrh 1304cce7d176Sdrh /* 130573b211abSdrh ** Generate code to evaluate subqueries and IN operators contained 130673b211abSdrh ** in expression pExpr. 13074b59ab5eSdrh */ 13081398ad36Sdrh static int sqlite3ExprCodeSubquery( 13091398ad36Sdrh Parse *pParse, /* Parser */ 13101398ad36Sdrh NameContext *pNC, /* First enclosing namespace. Often NULL */ 13111398ad36Sdrh Expr *pExpr /* Subquery to be coded */ 13121398ad36Sdrh ){ 13131398ad36Sdrh QueryCoder sCoder; 13141398ad36Sdrh sCoder.pParse = pParse; 13151398ad36Sdrh sCoder.pNC = pNC; 13161398ad36Sdrh walkExprTree(pExpr, codeSubqueryStep, &sCoder); 1317626a879aSdrh return 0; 1318290c1948Sdrh } 1319290c1948Sdrh 1320290c1948Sdrh /* 1321fec19aadSdrh ** Generate an instruction that will put the integer describe by 1322fec19aadSdrh ** text z[0..n-1] on the stack. 1323fec19aadSdrh */ 1324fec19aadSdrh static void codeInteger(Vdbe *v, const char *z, int n){ 1325fec19aadSdrh int i; 13266fec0762Sdrh if( sqlite3GetInt32(z, &i) ){ 13276fec0762Sdrh sqlite3VdbeAddOp(v, OP_Integer, i, 0); 13286fec0762Sdrh }else if( sqlite3FitsIn64Bits(z) ){ 13296fec0762Sdrh sqlite3VdbeOp3(v, OP_Integer, 0, 0, z, n); 1330fec19aadSdrh }else{ 1331fec19aadSdrh sqlite3VdbeOp3(v, OP_Real, 0, 0, z, n); 1332fec19aadSdrh } 1333fec19aadSdrh } 1334fec19aadSdrh 1335fec19aadSdrh /* 1336cce7d176Sdrh ** Generate code into the current Vdbe to evaluate the given 13371ccde15dSdrh ** expression and leave the result on the top of stack. 1338f2bc013cSdrh ** 1339f2bc013cSdrh ** This code depends on the fact that certain token values (ex: TK_EQ) 1340f2bc013cSdrh ** are the same as opcode values (ex: OP_Eq) that implement the corresponding 1341f2bc013cSdrh ** operation. Special comments in vdbe.c and the mkopcodeh.awk script in 1342f2bc013cSdrh ** the make process cause these values to align. Assert()s in the code 1343f2bc013cSdrh ** below verify that the numbers are aligned correctly. 1344cce7d176Sdrh */ 13454adee20fSdanielk1977 void sqlite3ExprCode(Parse *pParse, Expr *pExpr){ 1346cce7d176Sdrh Vdbe *v = pParse->pVdbe; 1347cce7d176Sdrh int op; 13487977a17fSdanielk1977 if( v==0 ) return; 13497977a17fSdanielk1977 if( pExpr==0 ){ 13507977a17fSdanielk1977 sqlite3VdbeAddOp(v, OP_String8, 0, 0); /* Empty expression evals to NULL */ 13517977a17fSdanielk1977 return; 13527977a17fSdanielk1977 } 1353f2bc013cSdrh op = pExpr->op; 1354f2bc013cSdrh switch( op ){ 1355967e8b73Sdrh case TK_COLUMN: { 13562282792aSdrh if( pParse->useAgg ){ 13574adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_AggGet, 0, pExpr->iAgg); 1358c4a3c779Sdrh }else if( pExpr->iColumn>=0 ){ 13594adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Column, pExpr->iTable, pExpr->iColumn); 1360145716b3Sdrh #ifndef NDEBUG 1361145716b3Sdrh if( pExpr->span.z && pExpr->span.n>0 && pExpr->span.n<100 ){ 1362ad6d9460Sdrh VdbeComment((v, "# %T", &pExpr->span)); 1363145716b3Sdrh } 1364145716b3Sdrh #endif 1365c4a3c779Sdrh }else{ 13664adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Recno, pExpr->iTable, 0); 13672282792aSdrh } 1368cce7d176Sdrh break; 1369cce7d176Sdrh } 1370cce7d176Sdrh case TK_INTEGER: { 1371fec19aadSdrh codeInteger(v, pExpr->token.z, pExpr->token.n); 1372fec19aadSdrh break; 137351e9a445Sdrh } 1374fec19aadSdrh case TK_FLOAT: 1375fec19aadSdrh case TK_STRING: { 1376f2bc013cSdrh assert( TK_FLOAT==OP_Real ); 1377f2bc013cSdrh assert( TK_STRING==OP_String8 ); 1378fec19aadSdrh sqlite3VdbeOp3(v, op, 0, 0, pExpr->token.z, pExpr->token.n); 13794adee20fSdanielk1977 sqlite3VdbeDequoteP3(v, -1); 1380cce7d176Sdrh break; 1381cce7d176Sdrh } 1382c572ef7fSdanielk1977 case TK_BLOB: { 1383f2bc013cSdrh assert( TK_BLOB==OP_HexBlob ); 1384c572ef7fSdanielk1977 sqlite3VdbeOp3(v, op, 0, 0, pExpr->token.z+1, pExpr->token.n-1); 1385c572ef7fSdanielk1977 sqlite3VdbeDequoteP3(v, -1); 1386c572ef7fSdanielk1977 break; 1387c572ef7fSdanielk1977 } 1388cce7d176Sdrh case TK_NULL: { 13890f69c1e3Sdanielk1977 sqlite3VdbeAddOp(v, OP_String8, 0, 0); 1390cce7d176Sdrh break; 1391cce7d176Sdrh } 139250457896Sdrh case TK_VARIABLE: { 13934adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Variable, pExpr->iTable, 0); 1394895d7472Sdrh if( pExpr->token.n>1 ){ 1395895d7472Sdrh sqlite3VdbeChangeP3(v, -1, pExpr->token.z, pExpr->token.n); 1396895d7472Sdrh } 139750457896Sdrh break; 139850457896Sdrh } 13994e0cff60Sdrh case TK_REGISTER: { 14004e0cff60Sdrh sqlite3VdbeAddOp(v, OP_MemLoad, pExpr->iTable, 0); 14014e0cff60Sdrh break; 14024e0cff60Sdrh } 1403c9b84a1fSdrh case TK_LT: 1404c9b84a1fSdrh case TK_LE: 1405c9b84a1fSdrh case TK_GT: 1406c9b84a1fSdrh case TK_GE: 1407c9b84a1fSdrh case TK_NE: 1408c9b84a1fSdrh case TK_EQ: { 1409f2bc013cSdrh assert( TK_LT==OP_Lt ); 1410f2bc013cSdrh assert( TK_LE==OP_Le ); 1411f2bc013cSdrh assert( TK_GT==OP_Gt ); 1412f2bc013cSdrh assert( TK_GE==OP_Ge ); 1413f2bc013cSdrh assert( TK_EQ==OP_Eq ); 1414f2bc013cSdrh assert( TK_NE==OP_Ne ); 1415a37cdde0Sdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 1416a37cdde0Sdanielk1977 sqlite3ExprCode(pParse, pExpr->pRight); 1417be5c89acSdrh codeCompare(pParse, pExpr->pLeft, pExpr->pRight, op, 0, 0); 1418a37cdde0Sdanielk1977 break; 1419c9b84a1fSdrh } 1420cce7d176Sdrh case TK_AND: 1421cce7d176Sdrh case TK_OR: 1422cce7d176Sdrh case TK_PLUS: 1423cce7d176Sdrh case TK_STAR: 1424cce7d176Sdrh case TK_MINUS: 1425bf4133cbSdrh case TK_REM: 1426bf4133cbSdrh case TK_BITAND: 1427bf4133cbSdrh case TK_BITOR: 142817c40294Sdrh case TK_SLASH: 1429bf4133cbSdrh case TK_LSHIFT: 1430855eb1cfSdrh case TK_RSHIFT: 14310040077dSdrh case TK_CONCAT: { 1432f2bc013cSdrh assert( TK_AND==OP_And ); 1433f2bc013cSdrh assert( TK_OR==OP_Or ); 1434f2bc013cSdrh assert( TK_PLUS==OP_Add ); 1435f2bc013cSdrh assert( TK_MINUS==OP_Subtract ); 1436f2bc013cSdrh assert( TK_REM==OP_Remainder ); 1437f2bc013cSdrh assert( TK_BITAND==OP_BitAnd ); 1438f2bc013cSdrh assert( TK_BITOR==OP_BitOr ); 1439f2bc013cSdrh assert( TK_SLASH==OP_Divide ); 1440f2bc013cSdrh assert( TK_LSHIFT==OP_ShiftLeft ); 1441f2bc013cSdrh assert( TK_RSHIFT==OP_ShiftRight ); 1442f2bc013cSdrh assert( TK_CONCAT==OP_Concat ); 14434adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 14444adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pRight); 1445855eb1cfSdrh sqlite3VdbeAddOp(v, op, 0, 0); 14460040077dSdrh break; 14470040077dSdrh } 1448cce7d176Sdrh case TK_UMINUS: { 1449fec19aadSdrh Expr *pLeft = pExpr->pLeft; 1450fec19aadSdrh assert( pLeft ); 1451fec19aadSdrh if( pLeft->op==TK_FLOAT || pLeft->op==TK_INTEGER ){ 1452fec19aadSdrh Token *p = &pLeft->token; 14536e142f54Sdrh char *z = sqliteMalloc( p->n + 2 ); 14546e142f54Sdrh sprintf(z, "-%.*s", p->n, p->z); 1455fec19aadSdrh if( pLeft->op==TK_FLOAT ){ 1456fec19aadSdrh sqlite3VdbeOp3(v, OP_Real, 0, 0, z, p->n+1); 1457e6840900Sdrh }else{ 1458fec19aadSdrh codeInteger(v, z, p->n+1); 1459e6840900Sdrh } 14606e142f54Sdrh sqliteFree(z); 14616e142f54Sdrh break; 14626e142f54Sdrh } 14631ccde15dSdrh /* Fall through into TK_NOT */ 14646e142f54Sdrh } 1465bf4133cbSdrh case TK_BITNOT: 14666e142f54Sdrh case TK_NOT: { 1467f2bc013cSdrh assert( TK_BITNOT==OP_BitNot ); 1468f2bc013cSdrh assert( TK_NOT==OP_Not ); 14694adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 14704adee20fSdanielk1977 sqlite3VdbeAddOp(v, op, 0, 0); 1471cce7d176Sdrh break; 1472cce7d176Sdrh } 1473cce7d176Sdrh case TK_ISNULL: 1474cce7d176Sdrh case TK_NOTNULL: { 1475cce7d176Sdrh int dest; 1476f2bc013cSdrh assert( TK_ISNULL==OP_IsNull ); 1477f2bc013cSdrh assert( TK_NOTNULL==OP_NotNull ); 14784adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Integer, 1, 0); 14794adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 14804adee20fSdanielk1977 dest = sqlite3VdbeCurrentAddr(v) + 2; 14814adee20fSdanielk1977 sqlite3VdbeAddOp(v, op, 1, dest); 14824adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_AddImm, -1, 0); 1483a37cdde0Sdanielk1977 break; 1484f2bc013cSdrh } 14852282792aSdrh case TK_AGG_FUNCTION: { 14864adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_AggGet, 0, pExpr->iAgg); 14872282792aSdrh break; 14882282792aSdrh } 14897977a17fSdanielk1977 case TK_CDATE: 14907977a17fSdanielk1977 case TK_CTIME: 14917977a17fSdanielk1977 case TK_CTIMESTAMP: 14924b59ab5eSdrh case TK_GLOB: 14934b59ab5eSdrh case TK_LIKE: 1494cce7d176Sdrh case TK_FUNCTION: { 1495cce7d176Sdrh ExprList *pList = pExpr->pList; 149689425d5eSdrh int nExpr = pList ? pList->nExpr : 0; 14970bce8354Sdrh FuncDef *pDef; 14984b59ab5eSdrh int nId; 14994b59ab5eSdrh const char *zId; 1500682f68b0Sdanielk1977 int p2 = 0; 1501682f68b0Sdanielk1977 int i; 1502d8123366Sdanielk1977 u8 enc = pParse->db->enc; 1503dc1bdc4fSdanielk1977 CollSeq *pColl = 0; 15044b59ab5eSdrh getFunctionName(pExpr, &zId, &nId); 1505d8123366Sdanielk1977 pDef = sqlite3FindFunction(pParse->db, zId, nId, nExpr, enc, 0); 15060bce8354Sdrh assert( pDef!=0 ); 1507f9b596ebSdrh nExpr = sqlite3ExprCodeExprList(pParse, pList); 1508682f68b0Sdanielk1977 for(i=0; i<nExpr && i<32; i++){ 1509d02eb1fdSdanielk1977 if( sqlite3ExprIsConstant(pList->a[i].pExpr) ){ 1510d02eb1fdSdanielk1977 p2 |= (1<<i); 1511d02eb1fdSdanielk1977 } 1512dc1bdc4fSdanielk1977 if( pDef->needCollSeq && !pColl ){ 1513dc1bdc4fSdanielk1977 pColl = sqlite3ExprCollSeq(pParse, pList->a[i].pExpr); 1514dc1bdc4fSdanielk1977 } 1515dc1bdc4fSdanielk1977 } 1516dc1bdc4fSdanielk1977 if( pDef->needCollSeq ){ 1517dc1bdc4fSdanielk1977 if( !pColl ) pColl = pParse->db->pDfltColl; 1518d8123366Sdanielk1977 sqlite3VdbeOp3(v, OP_CollSeq, 0, 0, (char *)pColl, P3_COLLSEQ); 1519682f68b0Sdanielk1977 } 1520682f68b0Sdanielk1977 sqlite3VdbeOp3(v, OP_Function, nExpr, p2, (char*)pDef, P3_FUNCDEF); 15216ec2733bSdrh break; 15226ec2733bSdrh } 152319a775c2Sdrh case TK_SELECT: { 15241398ad36Sdrh if( pExpr->iTable>=0 ){ 15251398ad36Sdrh sqlite3VdbeAddOp(v, OP_Gosub, 0, pExpr->iTable); 15261398ad36Sdrh VdbeComment((v, "# run subquery")); 15271398ad36Sdrh } 15284adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_MemLoad, pExpr->iColumn, 0); 1529ad6d9460Sdrh VdbeComment((v, "# load subquery result")); 153019a775c2Sdrh break; 153119a775c2Sdrh } 1532fef5208cSdrh case TK_IN: { 1533fef5208cSdrh int addr; 153494a11211Sdrh char affinity; 1535e014a838Sdanielk1977 1536e014a838Sdanielk1977 /* Figure out the affinity to use to create a key from the results 1537e014a838Sdanielk1977 ** of the expression. affinityStr stores a static string suitable for 1538ededfd5eSdanielk1977 ** P3 of OP_MakeRecord. 1539e014a838Sdanielk1977 */ 154094a11211Sdrh affinity = comparisonAffinity(pExpr); 1541e014a838Sdanielk1977 15424adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Integer, 1, 0); 1543e014a838Sdanielk1977 1544e014a838Sdanielk1977 /* Code the <expr> from "<expr> IN (...)". The temporary table 1545e014a838Sdanielk1977 ** pExpr->iTable contains the values that make up the (...) set. 1546e014a838Sdanielk1977 */ 15474adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 15484adee20fSdanielk1977 addr = sqlite3VdbeCurrentAddr(v); 1549e014a838Sdanielk1977 sqlite3VdbeAddOp(v, OP_NotNull, -1, addr+4); /* addr + 0 */ 15504adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Pop, 2, 0); 15510f69c1e3Sdanielk1977 sqlite3VdbeAddOp(v, OP_String8, 0, 0); 1552e014a838Sdanielk1977 sqlite3VdbeAddOp(v, OP_Goto, 0, addr+7); 155394a11211Sdrh sqlite3VdbeOp3(v, OP_MakeRecord, 1, 0, &affinity, 1); /* addr + 4 */ 1554e014a838Sdanielk1977 sqlite3VdbeAddOp(v, OP_Found, pExpr->iTable, addr+7); 1555e014a838Sdanielk1977 sqlite3VdbeAddOp(v, OP_AddImm, -1, 0); /* addr + 6 */ 1556e014a838Sdanielk1977 1557fef5208cSdrh break; 1558fef5208cSdrh } 1559fef5208cSdrh case TK_BETWEEN: { 1560be5c89acSdrh Expr *pLeft = pExpr->pLeft; 1561be5c89acSdrh struct ExprList_item *pLItem = pExpr->pList->a; 1562be5c89acSdrh Expr *pRight = pLItem->pExpr; 1563be5c89acSdrh sqlite3ExprCode(pParse, pLeft); 15644adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Dup, 0, 0); 1565be5c89acSdrh sqlite3ExprCode(pParse, pRight); 1566be5c89acSdrh codeCompare(pParse, pLeft, pRight, OP_Ge, 0, 0); 15674adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Pull, 1, 0); 1568be5c89acSdrh pLItem++; 1569be5c89acSdrh pRight = pLItem->pExpr; 1570be5c89acSdrh sqlite3ExprCode(pParse, pRight); 1571be5c89acSdrh codeCompare(pParse, pLeft, pRight, OP_Le, 0, 0); 15724adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_And, 0, 0); 1573fef5208cSdrh break; 1574fef5208cSdrh } 157551e9a445Sdrh case TK_UPLUS: 1576a2e00042Sdrh case TK_AS: { 15774adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 1578a2e00042Sdrh break; 1579a2e00042Sdrh } 158017a7f8ddSdrh case TK_CASE: { 158117a7f8ddSdrh int expr_end_label; 1582f5905aa7Sdrh int jumpInst; 1583f5905aa7Sdrh int addr; 1584f5905aa7Sdrh int nExpr; 158517a7f8ddSdrh int i; 1586be5c89acSdrh ExprList *pEList; 1587be5c89acSdrh struct ExprList_item *aListelem; 158817a7f8ddSdrh 158917a7f8ddSdrh assert(pExpr->pList); 159017a7f8ddSdrh assert((pExpr->pList->nExpr % 2) == 0); 159117a7f8ddSdrh assert(pExpr->pList->nExpr > 0); 1592be5c89acSdrh pEList = pExpr->pList; 1593be5c89acSdrh aListelem = pEList->a; 1594be5c89acSdrh nExpr = pEList->nExpr; 15954adee20fSdanielk1977 expr_end_label = sqlite3VdbeMakeLabel(v); 159617a7f8ddSdrh if( pExpr->pLeft ){ 15974adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 1598cce7d176Sdrh } 1599f5905aa7Sdrh for(i=0; i<nExpr; i=i+2){ 1600be5c89acSdrh sqlite3ExprCode(pParse, aListelem[i].pExpr); 160117a7f8ddSdrh if( pExpr->pLeft ){ 16024adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Dup, 1, 1); 1603be5c89acSdrh jumpInst = codeCompare(pParse, pExpr->pLeft, aListelem[i].pExpr, 1604be5c89acSdrh OP_Ne, 0, 1); 16054adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Pop, 1, 0); 1606f5905aa7Sdrh }else{ 16074adee20fSdanielk1977 jumpInst = sqlite3VdbeAddOp(v, OP_IfNot, 1, 0); 160817a7f8ddSdrh } 1609be5c89acSdrh sqlite3ExprCode(pParse, aListelem[i+1].pExpr); 16104adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Goto, 0, expr_end_label); 16114adee20fSdanielk1977 addr = sqlite3VdbeCurrentAddr(v); 16124adee20fSdanielk1977 sqlite3VdbeChangeP2(v, jumpInst, addr); 161317a7f8ddSdrh } 1614f570f011Sdrh if( pExpr->pLeft ){ 16154adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Pop, 1, 0); 1616f570f011Sdrh } 161717a7f8ddSdrh if( pExpr->pRight ){ 16184adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pRight); 161917a7f8ddSdrh }else{ 16200f69c1e3Sdanielk1977 sqlite3VdbeAddOp(v, OP_String8, 0, 0); 162117a7f8ddSdrh } 16224adee20fSdanielk1977 sqlite3VdbeResolveLabel(v, expr_end_label); 16236f34903eSdanielk1977 break; 16246f34903eSdanielk1977 } 16256f34903eSdanielk1977 case TK_RAISE: { 16266f34903eSdanielk1977 if( !pParse->trigStack ){ 16274adee20fSdanielk1977 sqlite3ErrorMsg(pParse, 1628da93d238Sdrh "RAISE() may only be used within a trigger-program"); 16296f34903eSdanielk1977 return; 16306f34903eSdanielk1977 } 1631ad6d9460Sdrh if( pExpr->iColumn!=OE_Ignore ){ 1632ad6d9460Sdrh assert( pExpr->iColumn==OE_Rollback || 16336f34903eSdanielk1977 pExpr->iColumn == OE_Abort || 1634ad6d9460Sdrh pExpr->iColumn == OE_Fail ); 16354adee20fSdanielk1977 sqlite3VdbeOp3(v, OP_Halt, SQLITE_CONSTRAINT, pExpr->iColumn, 1636701a0aebSdrh pExpr->token.z, pExpr->token.n); 16374adee20fSdanielk1977 sqlite3VdbeDequoteP3(v, -1); 16386f34903eSdanielk1977 } else { 16396f34903eSdanielk1977 assert( pExpr->iColumn == OE_Ignore ); 1640344737f6Sdrh sqlite3VdbeAddOp(v, OP_ContextPop, 0, 0); 1641ad6d9460Sdrh sqlite3VdbeAddOp(v, OP_Goto, 0, pParse->trigStack->ignoreJump); 1642ad6d9460Sdrh VdbeComment((v, "# raise(IGNORE)")); 16436f34903eSdanielk1977 } 164417a7f8ddSdrh } 164517a7f8ddSdrh break; 164617a7f8ddSdrh } 1647cce7d176Sdrh } 1648cce7d176Sdrh 1649cce7d176Sdrh /* 165025303780Sdrh ** Generate code that evalutes the given expression and leaves the result 165125303780Sdrh ** on the stack. See also sqlite3ExprCode(). 165225303780Sdrh ** 165325303780Sdrh ** This routine might also cache the result and modify the pExpr tree 165425303780Sdrh ** so that it will make use of the cached result on subsequent evaluations 165525303780Sdrh ** rather than evaluate the whole expression again. Trivial expressions are 165625303780Sdrh ** not cached. If the expression is cached, its result is stored in a 165725303780Sdrh ** memory location. 165825303780Sdrh */ 165925303780Sdrh void sqlite3ExprCodeAndCache(Parse *pParse, Expr *pExpr){ 166025303780Sdrh Vdbe *v = pParse->pVdbe; 166125303780Sdrh int iMem; 166225303780Sdrh int addr1, addr2; 166325303780Sdrh if( v==0 ) return; 166425303780Sdrh addr1 = sqlite3VdbeCurrentAddr(v); 166525303780Sdrh sqlite3ExprCode(pParse, pExpr); 166625303780Sdrh addr2 = sqlite3VdbeCurrentAddr(v); 166725303780Sdrh if( addr2>addr1+1 || sqlite3VdbeGetOp(v, addr1)->opcode==OP_Function ){ 166825303780Sdrh iMem = pExpr->iTable = pParse->nMem++; 166925303780Sdrh sqlite3VdbeAddOp(v, OP_MemStore, iMem, 0); 167025303780Sdrh pExpr->op = TK_REGISTER; 167125303780Sdrh } 167225303780Sdrh } 167325303780Sdrh 167425303780Sdrh /* 1675268380caSdrh ** Generate code that pushes the value of every element of the given 1676f9b596ebSdrh ** expression list onto the stack. 1677268380caSdrh ** 1678268380caSdrh ** Return the number of elements pushed onto the stack. 1679268380caSdrh */ 16804adee20fSdanielk1977 int sqlite3ExprCodeExprList( 1681268380caSdrh Parse *pParse, /* Parsing context */ 1682f9b596ebSdrh ExprList *pList /* The expression list to be coded */ 1683268380caSdrh ){ 1684268380caSdrh struct ExprList_item *pItem; 1685268380caSdrh int i, n; 1686268380caSdrh Vdbe *v; 1687268380caSdrh if( pList==0 ) return 0; 16884adee20fSdanielk1977 v = sqlite3GetVdbe(pParse); 1689268380caSdrh n = pList->nExpr; 1690268380caSdrh for(pItem=pList->a, i=0; i<n; i++, pItem++){ 16914adee20fSdanielk1977 sqlite3ExprCode(pParse, pItem->pExpr); 1692268380caSdrh } 1693f9b596ebSdrh return n; 1694268380caSdrh } 1695268380caSdrh 1696268380caSdrh /* 1697cce7d176Sdrh ** Generate code for a boolean expression such that a jump is made 1698cce7d176Sdrh ** to the label "dest" if the expression is true but execution 1699cce7d176Sdrh ** continues straight thru if the expression is false. 1700f5905aa7Sdrh ** 1701f5905aa7Sdrh ** If the expression evaluates to NULL (neither true nor false), then 1702f5905aa7Sdrh ** take the jump if the jumpIfNull flag is true. 1703f2bc013cSdrh ** 1704f2bc013cSdrh ** This code depends on the fact that certain token values (ex: TK_EQ) 1705f2bc013cSdrh ** are the same as opcode values (ex: OP_Eq) that implement the corresponding 1706f2bc013cSdrh ** operation. Special comments in vdbe.c and the mkopcodeh.awk script in 1707f2bc013cSdrh ** the make process cause these values to align. Assert()s in the code 1708f2bc013cSdrh ** below verify that the numbers are aligned correctly. 1709cce7d176Sdrh */ 17104adee20fSdanielk1977 void sqlite3ExprIfTrue(Parse *pParse, Expr *pExpr, int dest, int jumpIfNull){ 1711cce7d176Sdrh Vdbe *v = pParse->pVdbe; 1712cce7d176Sdrh int op = 0; 1713daffd0e5Sdrh if( v==0 || pExpr==0 ) return; 1714f2bc013cSdrh op = pExpr->op; 1715f2bc013cSdrh switch( op ){ 1716cce7d176Sdrh case TK_AND: { 17174adee20fSdanielk1977 int d2 = sqlite3VdbeMakeLabel(v); 17184adee20fSdanielk1977 sqlite3ExprIfFalse(pParse, pExpr->pLeft, d2, !jumpIfNull); 17194adee20fSdanielk1977 sqlite3ExprIfTrue(pParse, pExpr->pRight, dest, jumpIfNull); 17204adee20fSdanielk1977 sqlite3VdbeResolveLabel(v, d2); 1721cce7d176Sdrh break; 1722cce7d176Sdrh } 1723cce7d176Sdrh case TK_OR: { 17244adee20fSdanielk1977 sqlite3ExprIfTrue(pParse, pExpr->pLeft, dest, jumpIfNull); 17254adee20fSdanielk1977 sqlite3ExprIfTrue(pParse, pExpr->pRight, dest, jumpIfNull); 1726cce7d176Sdrh break; 1727cce7d176Sdrh } 1728cce7d176Sdrh case TK_NOT: { 17294adee20fSdanielk1977 sqlite3ExprIfFalse(pParse, pExpr->pLeft, dest, jumpIfNull); 1730cce7d176Sdrh break; 1731cce7d176Sdrh } 1732cce7d176Sdrh case TK_LT: 1733cce7d176Sdrh case TK_LE: 1734cce7d176Sdrh case TK_GT: 1735cce7d176Sdrh case TK_GE: 1736cce7d176Sdrh case TK_NE: 17370ac65892Sdrh case TK_EQ: { 1738f2bc013cSdrh assert( TK_LT==OP_Lt ); 1739f2bc013cSdrh assert( TK_LE==OP_Le ); 1740f2bc013cSdrh assert( TK_GT==OP_Gt ); 1741f2bc013cSdrh assert( TK_GE==OP_Ge ); 1742f2bc013cSdrh assert( TK_EQ==OP_Eq ); 1743f2bc013cSdrh assert( TK_NE==OP_Ne ); 17444adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 17454adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pRight); 1746be5c89acSdrh codeCompare(pParse, pExpr->pLeft, pExpr->pRight, op, dest, jumpIfNull); 1747cce7d176Sdrh break; 1748cce7d176Sdrh } 1749cce7d176Sdrh case TK_ISNULL: 1750cce7d176Sdrh case TK_NOTNULL: { 1751f2bc013cSdrh assert( TK_ISNULL==OP_IsNull ); 1752f2bc013cSdrh assert( TK_NOTNULL==OP_NotNull ); 17534adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 17544adee20fSdanielk1977 sqlite3VdbeAddOp(v, op, 1, dest); 1755cce7d176Sdrh break; 1756cce7d176Sdrh } 1757fef5208cSdrh case TK_BETWEEN: { 17580202b29eSdanielk1977 /* The expression "x BETWEEN y AND z" is implemented as: 17590202b29eSdanielk1977 ** 17600202b29eSdanielk1977 ** 1 IF (x < y) GOTO 3 17610202b29eSdanielk1977 ** 2 IF (x <= z) GOTO <dest> 17620202b29eSdanielk1977 ** 3 ... 17630202b29eSdanielk1977 */ 1764f5905aa7Sdrh int addr; 1765be5c89acSdrh Expr *pLeft = pExpr->pLeft; 1766be5c89acSdrh Expr *pRight = pExpr->pList->a[0].pExpr; 1767be5c89acSdrh sqlite3ExprCode(pParse, pLeft); 17684adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Dup, 0, 0); 1769be5c89acSdrh sqlite3ExprCode(pParse, pRight); 1770be5c89acSdrh addr = codeCompare(pParse, pLeft, pRight, OP_Lt, 0, !jumpIfNull); 17710202b29eSdanielk1977 1772be5c89acSdrh pRight = pExpr->pList->a[1].pExpr; 1773be5c89acSdrh sqlite3ExprCode(pParse, pRight); 1774be5c89acSdrh codeCompare(pParse, pLeft, pRight, OP_Le, dest, jumpIfNull); 17750202b29eSdanielk1977 17764adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Integer, 0, 0); 17774adee20fSdanielk1977 sqlite3VdbeChangeP2(v, addr, sqlite3VdbeCurrentAddr(v)); 17784adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Pop, 1, 0); 1779fef5208cSdrh break; 1780fef5208cSdrh } 1781cce7d176Sdrh default: { 17824adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr); 17834adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_If, jumpIfNull, dest); 1784cce7d176Sdrh break; 1785cce7d176Sdrh } 1786cce7d176Sdrh } 1787cce7d176Sdrh } 1788cce7d176Sdrh 1789cce7d176Sdrh /* 179066b89c8fSdrh ** Generate code for a boolean expression such that a jump is made 1791cce7d176Sdrh ** to the label "dest" if the expression is false but execution 1792cce7d176Sdrh ** continues straight thru if the expression is true. 1793f5905aa7Sdrh ** 1794f5905aa7Sdrh ** If the expression evaluates to NULL (neither true nor false) then 1795f5905aa7Sdrh ** jump if jumpIfNull is true or fall through if jumpIfNull is false. 1796cce7d176Sdrh */ 17974adee20fSdanielk1977 void sqlite3ExprIfFalse(Parse *pParse, Expr *pExpr, int dest, int jumpIfNull){ 1798cce7d176Sdrh Vdbe *v = pParse->pVdbe; 1799cce7d176Sdrh int op = 0; 1800daffd0e5Sdrh if( v==0 || pExpr==0 ) return; 1801f2bc013cSdrh 1802f2bc013cSdrh /* The value of pExpr->op and op are related as follows: 1803f2bc013cSdrh ** 1804f2bc013cSdrh ** pExpr->op op 1805f2bc013cSdrh ** --------- ---------- 1806f2bc013cSdrh ** TK_ISNULL OP_NotNull 1807f2bc013cSdrh ** TK_NOTNULL OP_IsNull 1808f2bc013cSdrh ** TK_NE OP_Eq 1809f2bc013cSdrh ** TK_EQ OP_Ne 1810f2bc013cSdrh ** TK_GT OP_Le 1811f2bc013cSdrh ** TK_LE OP_Gt 1812f2bc013cSdrh ** TK_GE OP_Lt 1813f2bc013cSdrh ** TK_LT OP_Ge 1814f2bc013cSdrh ** 1815f2bc013cSdrh ** For other values of pExpr->op, op is undefined and unused. 1816f2bc013cSdrh ** The value of TK_ and OP_ constants are arranged such that we 1817f2bc013cSdrh ** can compute the mapping above using the following expression. 1818f2bc013cSdrh ** Assert()s verify that the computation is correct. 1819f2bc013cSdrh */ 1820f2bc013cSdrh op = ((pExpr->op+(TK_ISNULL&1))^1)-(TK_ISNULL&1); 1821f2bc013cSdrh 1822f2bc013cSdrh /* Verify correct alignment of TK_ and OP_ constants 1823f2bc013cSdrh */ 1824f2bc013cSdrh assert( pExpr->op!=TK_ISNULL || op==OP_NotNull ); 1825f2bc013cSdrh assert( pExpr->op!=TK_NOTNULL || op==OP_IsNull ); 1826f2bc013cSdrh assert( pExpr->op!=TK_NE || op==OP_Eq ); 1827f2bc013cSdrh assert( pExpr->op!=TK_EQ || op==OP_Ne ); 1828f2bc013cSdrh assert( pExpr->op!=TK_LT || op==OP_Ge ); 1829f2bc013cSdrh assert( pExpr->op!=TK_LE || op==OP_Gt ); 1830f2bc013cSdrh assert( pExpr->op!=TK_GT || op==OP_Le ); 1831f2bc013cSdrh assert( pExpr->op!=TK_GE || op==OP_Lt ); 1832f2bc013cSdrh 1833cce7d176Sdrh switch( pExpr->op ){ 1834cce7d176Sdrh case TK_AND: { 18354adee20fSdanielk1977 sqlite3ExprIfFalse(pParse, pExpr->pLeft, dest, jumpIfNull); 18364adee20fSdanielk1977 sqlite3ExprIfFalse(pParse, pExpr->pRight, dest, jumpIfNull); 1837cce7d176Sdrh break; 1838cce7d176Sdrh } 1839cce7d176Sdrh case TK_OR: { 18404adee20fSdanielk1977 int d2 = sqlite3VdbeMakeLabel(v); 18414adee20fSdanielk1977 sqlite3ExprIfTrue(pParse, pExpr->pLeft, d2, !jumpIfNull); 18424adee20fSdanielk1977 sqlite3ExprIfFalse(pParse, pExpr->pRight, dest, jumpIfNull); 18434adee20fSdanielk1977 sqlite3VdbeResolveLabel(v, d2); 1844cce7d176Sdrh break; 1845cce7d176Sdrh } 1846cce7d176Sdrh case TK_NOT: { 18474adee20fSdanielk1977 sqlite3ExprIfTrue(pParse, pExpr->pLeft, dest, jumpIfNull); 1848cce7d176Sdrh break; 1849cce7d176Sdrh } 1850cce7d176Sdrh case TK_LT: 1851cce7d176Sdrh case TK_LE: 1852cce7d176Sdrh case TK_GT: 1853cce7d176Sdrh case TK_GE: 1854cce7d176Sdrh case TK_NE: 1855cce7d176Sdrh case TK_EQ: { 18564adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 18574adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pRight); 1858be5c89acSdrh codeCompare(pParse, pExpr->pLeft, pExpr->pRight, op, dest, jumpIfNull); 1859cce7d176Sdrh break; 1860cce7d176Sdrh } 1861cce7d176Sdrh case TK_ISNULL: 1862cce7d176Sdrh case TK_NOTNULL: { 18634adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr->pLeft); 18644adee20fSdanielk1977 sqlite3VdbeAddOp(v, op, 1, dest); 1865cce7d176Sdrh break; 1866cce7d176Sdrh } 1867fef5208cSdrh case TK_BETWEEN: { 18680202b29eSdanielk1977 /* The expression is "x BETWEEN y AND z". It is implemented as: 18690202b29eSdanielk1977 ** 18700202b29eSdanielk1977 ** 1 IF (x >= y) GOTO 3 18710202b29eSdanielk1977 ** 2 GOTO <dest> 18720202b29eSdanielk1977 ** 3 IF (x > z) GOTO <dest> 18730202b29eSdanielk1977 */ 1874fef5208cSdrh int addr; 1875be5c89acSdrh Expr *pLeft = pExpr->pLeft; 1876be5c89acSdrh Expr *pRight = pExpr->pList->a[0].pExpr; 1877be5c89acSdrh sqlite3ExprCode(pParse, pLeft); 18784adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Dup, 0, 0); 1879be5c89acSdrh sqlite3ExprCode(pParse, pRight); 18804adee20fSdanielk1977 addr = sqlite3VdbeCurrentAddr(v); 1881be5c89acSdrh codeCompare(pParse, pLeft, pRight, OP_Ge, addr+3, !jumpIfNull); 1882be5c89acSdrh 18834adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Pop, 1, 0); 18844adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_Goto, 0, dest); 1885be5c89acSdrh pRight = pExpr->pList->a[1].pExpr; 1886be5c89acSdrh sqlite3ExprCode(pParse, pRight); 1887be5c89acSdrh codeCompare(pParse, pLeft, pRight, OP_Gt, dest, jumpIfNull); 1888fef5208cSdrh break; 1889fef5208cSdrh } 1890cce7d176Sdrh default: { 18914adee20fSdanielk1977 sqlite3ExprCode(pParse, pExpr); 18924adee20fSdanielk1977 sqlite3VdbeAddOp(v, OP_IfNot, jumpIfNull, dest); 1893cce7d176Sdrh break; 1894cce7d176Sdrh } 1895cce7d176Sdrh } 1896cce7d176Sdrh } 18972282792aSdrh 18982282792aSdrh /* 18992282792aSdrh ** Do a deep comparison of two expression trees. Return TRUE (non-zero) 19002282792aSdrh ** if they are identical and return FALSE if they differ in any way. 19012282792aSdrh */ 19024adee20fSdanielk1977 int sqlite3ExprCompare(Expr *pA, Expr *pB){ 19032282792aSdrh int i; 19042282792aSdrh if( pA==0 ){ 19052282792aSdrh return pB==0; 19062282792aSdrh }else if( pB==0 ){ 19072282792aSdrh return 0; 19082282792aSdrh } 19092282792aSdrh if( pA->op!=pB->op ) return 0; 19104adee20fSdanielk1977 if( !sqlite3ExprCompare(pA->pLeft, pB->pLeft) ) return 0; 19114adee20fSdanielk1977 if( !sqlite3ExprCompare(pA->pRight, pB->pRight) ) return 0; 19122282792aSdrh if( pA->pList ){ 19132282792aSdrh if( pB->pList==0 ) return 0; 19142282792aSdrh if( pA->pList->nExpr!=pB->pList->nExpr ) return 0; 19152282792aSdrh for(i=0; i<pA->pList->nExpr; i++){ 19164adee20fSdanielk1977 if( !sqlite3ExprCompare(pA->pList->a[i].pExpr, pB->pList->a[i].pExpr) ){ 19172282792aSdrh return 0; 19182282792aSdrh } 19192282792aSdrh } 19202282792aSdrh }else if( pB->pList ){ 19212282792aSdrh return 0; 19222282792aSdrh } 19232282792aSdrh if( pA->pSelect || pB->pSelect ) return 0; 19242f2c01e5Sdrh if( pA->iTable!=pB->iTable || pA->iColumn!=pB->iColumn ) return 0; 19252282792aSdrh if( pA->token.z ){ 19262282792aSdrh if( pB->token.z==0 ) return 0; 19276977fea8Sdrh if( pB->token.n!=pA->token.n ) return 0; 19284adee20fSdanielk1977 if( sqlite3StrNICmp(pA->token.z, pB->token.z, pB->token.n)!=0 ) return 0; 19292282792aSdrh } 19302282792aSdrh return 1; 19312282792aSdrh } 19322282792aSdrh 19332282792aSdrh /* 19342282792aSdrh ** Add a new element to the pParse->aAgg[] array and return its index. 193573b211abSdrh ** The new element is initialized to zero. The calling function is 193673b211abSdrh ** expected to fill it in. 19372282792aSdrh */ 19382282792aSdrh static int appendAggInfo(Parse *pParse){ 19392282792aSdrh if( (pParse->nAgg & 0x7)==0 ){ 19402282792aSdrh int amt = pParse->nAgg + 8; 19416d4abfbeSdrh AggExpr *aAgg = sqliteRealloc(pParse->aAgg, amt*sizeof(pParse->aAgg[0])); 19426d4abfbeSdrh if( aAgg==0 ){ 19432282792aSdrh return -1; 19442282792aSdrh } 19456d4abfbeSdrh pParse->aAgg = aAgg; 19462282792aSdrh } 19472282792aSdrh memset(&pParse->aAgg[pParse->nAgg], 0, sizeof(pParse->aAgg[0])); 19482282792aSdrh return pParse->nAgg++; 19492282792aSdrh } 19502282792aSdrh 19512282792aSdrh /* 1952626a879aSdrh ** This is an xFunc for walkExprTree() used to implement 1953626a879aSdrh ** sqlite3ExprAnalyzeAggregates(). See sqlite3ExprAnalyzeAggregates 1954626a879aSdrh ** for additional information. 19552282792aSdrh ** 1956626a879aSdrh ** This routine analyzes the aggregate function at pExpr. 19572282792aSdrh */ 1958626a879aSdrh static int analyzeAggregate(void *pArg, Expr *pExpr){ 19592282792aSdrh int i; 19602282792aSdrh AggExpr *aAgg; 1961626a879aSdrh Parse *pParse = (Parse*)pArg; 19622282792aSdrh 19632282792aSdrh switch( pExpr->op ){ 1964967e8b73Sdrh case TK_COLUMN: { 19652282792aSdrh aAgg = pParse->aAgg; 19662282792aSdrh for(i=0; i<pParse->nAgg; i++){ 19672282792aSdrh if( aAgg[i].isAgg ) continue; 19682282792aSdrh if( aAgg[i].pExpr->iTable==pExpr->iTable 1969967e8b73Sdrh && aAgg[i].pExpr->iColumn==pExpr->iColumn ){ 19702282792aSdrh break; 19712282792aSdrh } 19722282792aSdrh } 19732282792aSdrh if( i>=pParse->nAgg ){ 19742282792aSdrh i = appendAggInfo(pParse); 19752282792aSdrh if( i<0 ) return 1; 19762282792aSdrh pParse->aAgg[i].isAgg = 0; 19772282792aSdrh pParse->aAgg[i].pExpr = pExpr; 19782282792aSdrh } 1979aaf88729Sdrh pExpr->iAgg = i; 1980626a879aSdrh return 1; 19812282792aSdrh } 19822282792aSdrh case TK_AGG_FUNCTION: { 19832282792aSdrh aAgg = pParse->aAgg; 19842282792aSdrh for(i=0; i<pParse->nAgg; i++){ 19852282792aSdrh if( !aAgg[i].isAgg ) continue; 19864adee20fSdanielk1977 if( sqlite3ExprCompare(aAgg[i].pExpr, pExpr) ){ 19872282792aSdrh break; 19882282792aSdrh } 19892282792aSdrh } 19902282792aSdrh if( i>=pParse->nAgg ){ 1991d8123366Sdanielk1977 u8 enc = pParse->db->enc; 19922282792aSdrh i = appendAggInfo(pParse); 19932282792aSdrh if( i<0 ) return 1; 19942282792aSdrh pParse->aAgg[i].isAgg = 1; 19952282792aSdrh pParse->aAgg[i].pExpr = pExpr; 19964adee20fSdanielk1977 pParse->aAgg[i].pFunc = sqlite3FindFunction(pParse->db, 19976977fea8Sdrh pExpr->token.z, pExpr->token.n, 1998d8123366Sdanielk1977 pExpr->pList ? pExpr->pList->nExpr : 0, enc, 0); 19992282792aSdrh } 20002282792aSdrh pExpr->iAgg = i; 2001626a879aSdrh return 1; 20022282792aSdrh } 20032282792aSdrh } 2004626a879aSdrh return 0; 20052282792aSdrh } 2006626a879aSdrh 2007626a879aSdrh /* 2008626a879aSdrh ** Analyze the given expression looking for aggregate functions and 2009626a879aSdrh ** for variables that need to be added to the pParse->aAgg[] array. 2010626a879aSdrh ** Make additional entries to the pParse->aAgg[] array as necessary. 2011626a879aSdrh ** 2012626a879aSdrh ** This routine should only be called after the expression has been 2013626a879aSdrh ** analyzed by sqlite3ExprResolveNames(). 2014626a879aSdrh ** 2015626a879aSdrh ** If errors are seen, leave an error message in zErrMsg and return 2016626a879aSdrh ** the number of errors. 2017626a879aSdrh */ 2018626a879aSdrh int sqlite3ExprAnalyzeAggregates(Parse *pParse, Expr *pExpr){ 2019626a879aSdrh int nErr = pParse->nErr; 2020626a879aSdrh walkExprTree(pExpr, analyzeAggregate, pParse); 2021626a879aSdrh return pParse->nErr - nErr; 20222282792aSdrh } 20238e0a2f90Sdrh 20248e0a2f90Sdrh /* 2025d02eb1fdSdanielk1977 ** Locate a user function given a name, a number of arguments and a flag 2026d02eb1fdSdanielk1977 ** indicating whether the function prefers UTF-16 over UTF-8. Return a 2027d02eb1fdSdanielk1977 ** pointer to the FuncDef structure that defines that function, or return 2028d02eb1fdSdanielk1977 ** NULL if the function does not exist. 20298e0a2f90Sdrh ** 20300bce8354Sdrh ** If the createFlag argument is true, then a new (blank) FuncDef 20318e0a2f90Sdrh ** structure is created and liked into the "db" structure if a 20328e0a2f90Sdrh ** no matching function previously existed. When createFlag is true 20338e0a2f90Sdrh ** and the nArg parameter is -1, then only a function that accepts 20348e0a2f90Sdrh ** any number of arguments will be returned. 20358e0a2f90Sdrh ** 20368e0a2f90Sdrh ** If createFlag is false and nArg is -1, then the first valid 20378e0a2f90Sdrh ** function found is returned. A function is valid if either xFunc 20388e0a2f90Sdrh ** or xStep is non-zero. 2039d02eb1fdSdanielk1977 ** 2040d02eb1fdSdanielk1977 ** If createFlag is false, then a function with the required name and 2041d02eb1fdSdanielk1977 ** number of arguments may be returned even if the eTextRep flag does not 2042d02eb1fdSdanielk1977 ** match that requested. 20438e0a2f90Sdrh */ 20444adee20fSdanielk1977 FuncDef *sqlite3FindFunction( 20459bb575fdSdrh sqlite3 *db, /* An open database */ 20468e0a2f90Sdrh const char *zName, /* Name of the function. Not null-terminated */ 20478e0a2f90Sdrh int nName, /* Number of characters in the name */ 20488e0a2f90Sdrh int nArg, /* Number of arguments. -1 means any number */ 2049d8123366Sdanielk1977 u8 enc, /* Preferred text encoding */ 20508e0a2f90Sdrh int createFlag /* Create new entry if true and does not otherwise exist */ 20518e0a2f90Sdrh ){ 2052d02eb1fdSdanielk1977 FuncDef *p; /* Iterator variable */ 2053d02eb1fdSdanielk1977 FuncDef *pFirst; /* First function with this name */ 2054d02eb1fdSdanielk1977 FuncDef *pBest = 0; /* Best match found so far */ 2055d8123366Sdanielk1977 int bestmatch = 0; 2056d02eb1fdSdanielk1977 2057d8123366Sdanielk1977 2058d8123366Sdanielk1977 assert( enc==SQLITE_UTF8 || enc==SQLITE_UTF16LE || enc==SQLITE_UTF16BE ); 2059d02eb1fdSdanielk1977 if( nArg<-1 ) nArg = -1; 2060d02eb1fdSdanielk1977 2061d02eb1fdSdanielk1977 pFirst = (FuncDef*)sqlite3HashFind(&db->aFunc, zName, nName); 2062d02eb1fdSdanielk1977 for(p=pFirst; p; p=p->pNext){ 2063d8123366Sdanielk1977 /* During the search for the best function definition, bestmatch is set 2064d8123366Sdanielk1977 ** as follows to indicate the quality of the match with the definition 2065d8123366Sdanielk1977 ** pointed to by pBest: 2066d8123366Sdanielk1977 ** 2067d8123366Sdanielk1977 ** 0: pBest is NULL. No match has been found. 2068d8123366Sdanielk1977 ** 1: A variable arguments function that prefers UTF-8 when a UTF-16 2069d8123366Sdanielk1977 ** encoding is requested, or vice versa. 2070d8123366Sdanielk1977 ** 2: A variable arguments function that uses UTF-16BE when UTF-16LE is 2071d8123366Sdanielk1977 ** requested, or vice versa. 2072d8123366Sdanielk1977 ** 3: A variable arguments function using the same text encoding. 2073d8123366Sdanielk1977 ** 4: A function with the exact number of arguments requested that 2074d8123366Sdanielk1977 ** prefers UTF-8 when a UTF-16 encoding is requested, or vice versa. 2075d8123366Sdanielk1977 ** 5: A function with the exact number of arguments requested that 2076d8123366Sdanielk1977 ** prefers UTF-16LE when UTF-16BE is requested, or vice versa. 2077d8123366Sdanielk1977 ** 6: An exact match. 2078d8123366Sdanielk1977 ** 2079d8123366Sdanielk1977 ** A larger value of 'matchqual' indicates a more desirable match. 2080d8123366Sdanielk1977 */ 2081e12c17baSdanielk1977 if( p->nArg==-1 || p->nArg==nArg || nArg==-1 ){ 2082d8123366Sdanielk1977 int match = 1; /* Quality of this match */ 2083d8123366Sdanielk1977 if( p->nArg==nArg || nArg==-1 ){ 2084d8123366Sdanielk1977 match = 4; 20858e0a2f90Sdrh } 2086d8123366Sdanielk1977 if( enc==p->iPrefEnc ){ 2087d8123366Sdanielk1977 match += 2; 20888e0a2f90Sdrh } 2089d8123366Sdanielk1977 else if( (enc==SQLITE_UTF16LE && p->iPrefEnc==SQLITE_UTF16BE) || 2090d8123366Sdanielk1977 (enc==SQLITE_UTF16BE && p->iPrefEnc==SQLITE_UTF16LE) ){ 2091d8123366Sdanielk1977 match += 1; 2092d02eb1fdSdanielk1977 } 2093d8123366Sdanielk1977 2094d8123366Sdanielk1977 if( match>bestmatch ){ 2095d02eb1fdSdanielk1977 pBest = p; 2096d8123366Sdanielk1977 bestmatch = match; 2097d02eb1fdSdanielk1977 } 2098d02eb1fdSdanielk1977 } 2099d02eb1fdSdanielk1977 } 2100d02eb1fdSdanielk1977 2101d8123366Sdanielk1977 /* If the createFlag parameter is true, and the seach did not reveal an 2102d8123366Sdanielk1977 ** exact match for the name, number of arguments and encoding, then add a 2103d8123366Sdanielk1977 ** new entry to the hash table and return it. 2104d8123366Sdanielk1977 */ 2105d8123366Sdanielk1977 if( createFlag && bestmatch<6 && 2106d02eb1fdSdanielk1977 (pBest = sqliteMalloc(sizeof(*pBest)+nName+1)) ){ 2107d02eb1fdSdanielk1977 pBest->nArg = nArg; 2108d02eb1fdSdanielk1977 pBest->pNext = pFirst; 2109d02eb1fdSdanielk1977 pBest->zName = (char*)&pBest[1]; 2110d8123366Sdanielk1977 pBest->iPrefEnc = enc; 2111d02eb1fdSdanielk1977 memcpy(pBest->zName, zName, nName); 2112d02eb1fdSdanielk1977 pBest->zName[nName] = 0; 21132c336549Sdanielk1977 if( pBest==sqlite3HashInsert(&db->aFunc,pBest->zName,nName,(void*)pBest) ){ 21142c336549Sdanielk1977 sqliteFree(pBest); 21152c336549Sdanielk1977 return 0; 21162c336549Sdanielk1977 } 2117d02eb1fdSdanielk1977 } 2118d02eb1fdSdanielk1977 2119d02eb1fdSdanielk1977 if( pBest && (pBest->xStep || pBest->xFunc || createFlag) ){ 2120d02eb1fdSdanielk1977 return pBest; 2121d02eb1fdSdanielk1977 } 21228e0a2f90Sdrh return 0; 21238e0a2f90Sdrh } 2124