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*e4697f5eSdrh ** $Id: expr.c,v 1.62 2002/05/23 02:09:04 drh Exp $ 16cce7d176Sdrh */ 17cce7d176Sdrh #include "sqliteInt.h" 18cce7d176Sdrh 19a2e00042Sdrh 20a2e00042Sdrh /* 21a76b5dfcSdrh ** Construct a new expression node and return a pointer to it. Memory 22a76b5dfcSdrh ** for this node is obtained from sqliteMalloc(). The calling function 23a76b5dfcSdrh ** is responsible for making sure the node eventually gets freed. 24a76b5dfcSdrh */ 25a76b5dfcSdrh Expr *sqliteExpr(int op, Expr *pLeft, Expr *pRight, Token *pToken){ 26a76b5dfcSdrh Expr *pNew; 27a76b5dfcSdrh pNew = sqliteMalloc( sizeof(Expr) ); 28a76b5dfcSdrh if( pNew==0 ){ 29a76b5dfcSdrh sqliteExprDelete(pLeft); 30a76b5dfcSdrh sqliteExprDelete(pRight); 31a76b5dfcSdrh return 0; 32a76b5dfcSdrh } 33a76b5dfcSdrh pNew->op = op; 34a76b5dfcSdrh pNew->pLeft = pLeft; 35a76b5dfcSdrh pNew->pRight = pRight; 36a76b5dfcSdrh if( pToken ){ 37a76b5dfcSdrh pNew->token = *pToken; 38a76b5dfcSdrh }else{ 39a76b5dfcSdrh pNew->token.z = 0; 40a76b5dfcSdrh pNew->token.n = 0; 41a76b5dfcSdrh } 42a76b5dfcSdrh if( pLeft && pRight ){ 43a76b5dfcSdrh sqliteExprSpan(pNew, &pLeft->span, &pRight->span); 44a76b5dfcSdrh }else{ 45a76b5dfcSdrh pNew->span = pNew->token; 46a76b5dfcSdrh } 47a76b5dfcSdrh return pNew; 48a76b5dfcSdrh } 49a76b5dfcSdrh 50a76b5dfcSdrh /* 51a76b5dfcSdrh ** Set the Expr.token field of the given expression to span all 52a76b5dfcSdrh ** text between the two given tokens. 53a76b5dfcSdrh */ 54a76b5dfcSdrh void sqliteExprSpan(Expr *pExpr, Token *pLeft, Token *pRight){ 55a76b5dfcSdrh if( pExpr ){ 56a76b5dfcSdrh pExpr->span.z = pLeft->z; 57a76b5dfcSdrh pExpr->span.n = pRight->n + Addr(pRight->z) - Addr(pLeft->z); 58a76b5dfcSdrh } 59a76b5dfcSdrh } 60a76b5dfcSdrh 61a76b5dfcSdrh /* 62a76b5dfcSdrh ** Construct a new expression node for a function with multiple 63a76b5dfcSdrh ** arguments. 64a76b5dfcSdrh */ 65a76b5dfcSdrh Expr *sqliteExprFunction(ExprList *pList, Token *pToken){ 66a76b5dfcSdrh Expr *pNew; 67a76b5dfcSdrh pNew = sqliteMalloc( sizeof(Expr) ); 68a76b5dfcSdrh if( pNew==0 ){ 69a76b5dfcSdrh sqliteExprListDelete(pList); 70a76b5dfcSdrh return 0; 71a76b5dfcSdrh } 72a76b5dfcSdrh pNew->op = TK_FUNCTION; 73a76b5dfcSdrh pNew->pList = pList; 74a76b5dfcSdrh if( pToken ){ 75a76b5dfcSdrh pNew->token = *pToken; 76a76b5dfcSdrh }else{ 77a76b5dfcSdrh pNew->token.z = 0; 78a76b5dfcSdrh pNew->token.n = 0; 79a76b5dfcSdrh } 80a76b5dfcSdrh return pNew; 81a76b5dfcSdrh } 82a76b5dfcSdrh 83a76b5dfcSdrh /* 84a2e00042Sdrh ** Recursively delete an expression tree. 85a2e00042Sdrh */ 86a2e00042Sdrh void sqliteExprDelete(Expr *p){ 87a2e00042Sdrh if( p==0 ) return; 88a2e00042Sdrh if( p->pLeft ) sqliteExprDelete(p->pLeft); 89a2e00042Sdrh if( p->pRight ) sqliteExprDelete(p->pRight); 90a2e00042Sdrh if( p->pList ) sqliteExprListDelete(p->pList); 91a2e00042Sdrh if( p->pSelect ) sqliteSelectDelete(p->pSelect); 92a2e00042Sdrh sqliteFree(p); 93a2e00042Sdrh } 94a2e00042Sdrh 95cce7d176Sdrh /* 96a76b5dfcSdrh ** The following group of functions are used to translate the string 97a76b5dfcSdrh ** pointers of tokens in expression from one buffer to another. 98a76b5dfcSdrh ** 99a76b5dfcSdrh ** Normally, the Expr.token.z and Expr.span.z fields point into the 100a76b5dfcSdrh ** original input buffer of an SQL statement. This is usually OK 101a76b5dfcSdrh ** since the SQL statement is executed and the expression is deleted 102a76b5dfcSdrh ** before the input buffer is freed. Making the tokens point to the 103a76b5dfcSdrh ** original input buffer saves many calls to malloc() and thus helps 104a76b5dfcSdrh ** the library to run faster. 105a76b5dfcSdrh ** 106a76b5dfcSdrh ** But sometimes we need an expression to persist past the time when 107a76b5dfcSdrh ** the input buffer is freed. (Example: The SELECT clause of a 108a76b5dfcSdrh ** CREATE VIEW statement contains expressions that must persist for 109a76b5dfcSdrh ** the life of the view.) When that happens we have to make a 110a76b5dfcSdrh ** persistent copy of the input buffer and translate the Expr.token.z 111a76b5dfcSdrh ** and Expr.span.z fields to point to the copy rather than the 112a2ed5601Sdrh ** original input buffer. The following group of routines handle that 113a76b5dfcSdrh ** translation. 114a76b5dfcSdrh ** 115a76b5dfcSdrh ** The "offset" parameter is the distance from the original input buffer 116a76b5dfcSdrh ** to the persistent copy. These routines recursively walk the entire 117a76b5dfcSdrh ** expression tree and shift all tokens by "offset" amount. 118a76b5dfcSdrh ** 119a76b5dfcSdrh ** The work of figuring out the appropriate "offset" and making the 120a76b5dfcSdrh ** presistent copy of the input buffer is done by the calling routine. 121a76b5dfcSdrh */ 122a76b5dfcSdrh void sqliteExprMoveStrings(Expr *p, int offset){ 123a76b5dfcSdrh if( p==0 ) return; 124a76b5dfcSdrh if( p->token.z ) p->token.z += offset; 125a76b5dfcSdrh if( p->span.z ) p->span.z += offset; 126a76b5dfcSdrh if( p->pLeft ) sqliteExprMoveStrings(p->pLeft, offset); 127a76b5dfcSdrh if( p->pRight ) sqliteExprMoveStrings(p->pRight, offset); 128a76b5dfcSdrh if( p->pList ) sqliteExprListMoveStrings(p->pList, offset); 129a76b5dfcSdrh if( p->pSelect ) sqliteSelectMoveStrings(p->pSelect, offset); 130a76b5dfcSdrh } 131a76b5dfcSdrh void sqliteExprListMoveStrings(ExprList *pList, int offset){ 132a76b5dfcSdrh int i; 133a76b5dfcSdrh if( pList==0 ) return; 134a76b5dfcSdrh for(i=0; i<pList->nExpr; i++){ 135a76b5dfcSdrh sqliteExprMoveStrings(pList->a[i].pExpr, offset); 136a76b5dfcSdrh } 137a76b5dfcSdrh } 138a76b5dfcSdrh void sqliteSelectMoveStrings(Select *pSelect, int offset){ 139a76b5dfcSdrh if( pSelect==0 ) return; 140a76b5dfcSdrh sqliteExprListMoveStrings(pSelect->pEList, offset); 141a76b5dfcSdrh sqliteExprMoveStrings(pSelect->pWhere, offset); 142a76b5dfcSdrh sqliteExprListMoveStrings(pSelect->pGroupBy, offset); 143a76b5dfcSdrh sqliteExprMoveStrings(pSelect->pHaving, offset); 144a76b5dfcSdrh sqliteExprListMoveStrings(pSelect->pOrderBy, offset); 145a76b5dfcSdrh sqliteSelectMoveStrings(pSelect->pPrior, offset); 146a76b5dfcSdrh } 147a76b5dfcSdrh 148a76b5dfcSdrh /* 149ff78bd2fSdrh ** The following group of routines make deep copies of expressions, 150ff78bd2fSdrh ** expression lists, ID lists, and select statements. The copies can 151ff78bd2fSdrh ** be deleted (by being passed to their respective ...Delete() routines) 152ff78bd2fSdrh ** without effecting the originals. 153ff78bd2fSdrh ** 154ff78bd2fSdrh ** Note, however, that the Expr.token.z and Expr.span.z fields point to 155ff78bd2fSdrh ** string space that is allocated separately from the expression tree 156ff78bd2fSdrh ** itself. These routines do NOT duplicate that string space. 157ff78bd2fSdrh ** 158ff78bd2fSdrh ** The expression list and ID list return by sqliteExprListDup() and 159ff78bd2fSdrh ** sqliteIdListDup() can not be further expanded by subsequent calls 160ff78bd2fSdrh ** to sqliteExprListAppend() or sqliteIdListAppend(). 161ff78bd2fSdrh ** 162ff78bd2fSdrh ** Any tables that the ID list might point to are not duplicated. 163ff78bd2fSdrh */ 164ff78bd2fSdrh Expr *sqliteExprDup(Expr *p){ 165ff78bd2fSdrh Expr *pNew; 166ff78bd2fSdrh if( p==0 ) return 0; 167ff78bd2fSdrh pNew = sqliteMalloc( sizeof(*p) ); 168ff78bd2fSdrh if( pNew==0 ) return 0; 169ff78bd2fSdrh pNew->op = p->op; 170ff78bd2fSdrh pNew->pLeft = sqliteExprDup(p->pLeft); 171ff78bd2fSdrh pNew->pRight = sqliteExprDup(p->pRight); 172ff78bd2fSdrh pNew->pList = sqliteExprListDup(p->pList); 173832508b7Sdrh pNew->iTable = p->iTable; 174832508b7Sdrh pNew->iColumn = p->iColumn; 175832508b7Sdrh pNew->iAgg = p->iAgg; 176ff78bd2fSdrh pNew->token = p->token; 177ff78bd2fSdrh pNew->span = p->span; 178ff78bd2fSdrh pNew->pSelect = sqliteSelectDup(p->pSelect); 179ff78bd2fSdrh return pNew; 180ff78bd2fSdrh } 181ff78bd2fSdrh ExprList *sqliteExprListDup(ExprList *p){ 182ff78bd2fSdrh ExprList *pNew; 183ff78bd2fSdrh int i; 184ff78bd2fSdrh if( p==0 ) return 0; 185ff78bd2fSdrh pNew = sqliteMalloc( sizeof(*pNew) ); 186ff78bd2fSdrh if( pNew==0 ) return 0; 187ff78bd2fSdrh pNew->nExpr = p->nExpr; 188ff78bd2fSdrh pNew->a = sqliteMalloc( p->nExpr*sizeof(p->a[0]) ); 189*e4697f5eSdrh if( pNew->a==0 ) return 0; 190ff78bd2fSdrh for(i=0; i<p->nExpr; i++){ 191ff78bd2fSdrh pNew->a[i].pExpr = sqliteExprDup(p->a[i].pExpr); 192ff78bd2fSdrh pNew->a[i].zName = sqliteStrDup(p->a[i].zName); 193ff78bd2fSdrh pNew->a[i].sortOrder = p->a[i].sortOrder; 194ff78bd2fSdrh pNew->a[i].isAgg = p->a[i].isAgg; 195ff78bd2fSdrh pNew->a[i].done = 0; 196ff78bd2fSdrh } 197ff78bd2fSdrh return pNew; 198ff78bd2fSdrh } 199ff78bd2fSdrh IdList *sqliteIdListDup(IdList *p){ 200ff78bd2fSdrh IdList *pNew; 201ff78bd2fSdrh int i; 202ff78bd2fSdrh if( p==0 ) return 0; 203ff78bd2fSdrh pNew = sqliteMalloc( sizeof(*pNew) ); 204ff78bd2fSdrh if( pNew==0 ) return 0; 205ff78bd2fSdrh pNew->nId = p->nId; 206ff78bd2fSdrh pNew->a = sqliteMalloc( p->nId*sizeof(p->a[0]) ); 207*e4697f5eSdrh if( pNew->a==0 ) return 0; 208ff78bd2fSdrh for(i=0; i<p->nId; i++){ 209ff78bd2fSdrh pNew->a[i].zName = sqliteStrDup(p->a[i].zName); 210ff78bd2fSdrh pNew->a[i].zAlias = sqliteStrDup(p->a[i].zAlias); 211ff78bd2fSdrh pNew->a[i].idx = p->a[i].idx; 212ff78bd2fSdrh pNew->a[i].pTab = 0; 213ff78bd2fSdrh pNew->a[i].pSelect = sqliteSelectDup(p->a[i].pSelect); 214ff78bd2fSdrh } 215ff78bd2fSdrh return pNew; 216ff78bd2fSdrh } 217ff78bd2fSdrh Select *sqliteSelectDup(Select *p){ 218ff78bd2fSdrh Select *pNew; 219ff78bd2fSdrh if( p==0 ) return 0; 220ff78bd2fSdrh pNew = sqliteMalloc( sizeof(*p) ); 221ff78bd2fSdrh if( pNew==0 ) return 0; 222ff78bd2fSdrh pNew->isDistinct = p->isDistinct; 223ff78bd2fSdrh pNew->pEList = sqliteExprListDup(p->pEList); 224ff78bd2fSdrh pNew->pSrc = sqliteIdListDup(p->pSrc); 225ff78bd2fSdrh pNew->pWhere = sqliteExprDup(p->pWhere); 226ff78bd2fSdrh pNew->pGroupBy = sqliteExprListDup(p->pGroupBy); 227ff78bd2fSdrh pNew->pHaving = sqliteExprDup(p->pHaving); 228ff78bd2fSdrh pNew->pOrderBy = sqliteExprListDup(p->pOrderBy); 229ff78bd2fSdrh pNew->op = p->op; 230ff78bd2fSdrh pNew->pPrior = sqliteSelectDup(p->pPrior); 231ff78bd2fSdrh pNew->nLimit = p->nLimit; 232ff78bd2fSdrh pNew->nOffset = p->nOffset; 233ff78bd2fSdrh pNew->zSelect = 0; 234ff78bd2fSdrh return pNew; 235ff78bd2fSdrh } 236ff78bd2fSdrh 237ff78bd2fSdrh 238ff78bd2fSdrh /* 239a76b5dfcSdrh ** Add a new element to the end of an expression list. If pList is 240a76b5dfcSdrh ** initially NULL, then create a new expression list. 241a76b5dfcSdrh */ 242a76b5dfcSdrh ExprList *sqliteExprListAppend(ExprList *pList, Expr *pExpr, Token *pName){ 243a76b5dfcSdrh int i; 244a76b5dfcSdrh if( pList==0 ){ 245a76b5dfcSdrh pList = sqliteMalloc( sizeof(ExprList) ); 246a76b5dfcSdrh if( pList==0 ){ 247a76b5dfcSdrh sqliteExprDelete(pExpr); 248a76b5dfcSdrh return 0; 249a76b5dfcSdrh } 250a76b5dfcSdrh } 251a76b5dfcSdrh if( (pList->nExpr & 7)==0 ){ 252a76b5dfcSdrh int n = pList->nExpr + 8; 253a76b5dfcSdrh struct ExprList_item *a; 254a76b5dfcSdrh a = sqliteRealloc(pList->a, n*sizeof(pList->a[0])); 255a76b5dfcSdrh if( a==0 ){ 256a76b5dfcSdrh sqliteExprDelete(pExpr); 257a76b5dfcSdrh return pList; 258a76b5dfcSdrh } 259a76b5dfcSdrh pList->a = a; 260a76b5dfcSdrh } 261a76b5dfcSdrh if( pExpr || pName ){ 262a76b5dfcSdrh i = pList->nExpr++; 263a76b5dfcSdrh pList->a[i].pExpr = pExpr; 264a76b5dfcSdrh pList->a[i].zName = 0; 265a76b5dfcSdrh if( pName ){ 266a76b5dfcSdrh sqliteSetNString(&pList->a[i].zName, pName->z, pName->n, 0); 267a76b5dfcSdrh sqliteDequote(pList->a[i].zName); 268a76b5dfcSdrh } 269a76b5dfcSdrh } 270a76b5dfcSdrh return pList; 271a76b5dfcSdrh } 272a76b5dfcSdrh 273a76b5dfcSdrh /* 274a76b5dfcSdrh ** Delete an entire expression list. 275a76b5dfcSdrh */ 276a76b5dfcSdrh void sqliteExprListDelete(ExprList *pList){ 277a76b5dfcSdrh int i; 278a76b5dfcSdrh if( pList==0 ) return; 279a76b5dfcSdrh for(i=0; i<pList->nExpr; i++){ 280a76b5dfcSdrh sqliteExprDelete(pList->a[i].pExpr); 281a76b5dfcSdrh sqliteFree(pList->a[i].zName); 282a76b5dfcSdrh } 283a76b5dfcSdrh sqliteFree(pList->a); 284a76b5dfcSdrh sqliteFree(pList); 285a76b5dfcSdrh } 286a76b5dfcSdrh 287a76b5dfcSdrh /* 288fef5208cSdrh ** Walk an expression tree. Return 1 if the expression is constant 289fef5208cSdrh ** and 0 if it involves variables. 2902398937bSdrh ** 2912398937bSdrh ** For the purposes of this function, a double-quoted string (ex: "abc") 2922398937bSdrh ** is considered a variable but a single-quoted string (ex: 'abc') is 2932398937bSdrh ** a constant. 294fef5208cSdrh */ 2959208643dSdrh int sqliteExprIsConstant(Expr *p){ 296fef5208cSdrh switch( p->op ){ 297fef5208cSdrh case TK_ID: 298967e8b73Sdrh case TK_COLUMN: 299fef5208cSdrh case TK_DOT: 300fef5208cSdrh return 0; 3012398937bSdrh case TK_STRING: 3022398937bSdrh return p->token.z[0]=='\''; 3039208643dSdrh case TK_INTEGER: 3049208643dSdrh case TK_FLOAT: 3059208643dSdrh return 1; 306fef5208cSdrh default: { 3079208643dSdrh if( p->pLeft && !sqliteExprIsConstant(p->pLeft) ) return 0; 3089208643dSdrh if( p->pRight && !sqliteExprIsConstant(p->pRight) ) return 0; 309fef5208cSdrh if( p->pList ){ 310fef5208cSdrh int i; 311fef5208cSdrh for(i=0; i<p->pList->nExpr; i++){ 3129208643dSdrh if( !sqliteExprIsConstant(p->pList->a[i].pExpr) ) return 0; 313fef5208cSdrh } 314fef5208cSdrh } 3159208643dSdrh return p->pLeft!=0 || p->pRight!=0 || (p->pList && p->pList->nExpr>0); 316fef5208cSdrh } 317fef5208cSdrh } 3189208643dSdrh return 0; 319fef5208cSdrh } 320fef5208cSdrh 321fef5208cSdrh /* 322c4a3c779Sdrh ** Return TRUE if the given string is a row-id column name. 323c4a3c779Sdrh */ 324c4a3c779Sdrh static int sqliteIsRowid(const char *z){ 325c4a3c779Sdrh if( sqliteStrICmp(z, "_ROWID_")==0 ) return 1; 326c4a3c779Sdrh if( sqliteStrICmp(z, "ROWID")==0 ) return 1; 327c4a3c779Sdrh if( sqliteStrICmp(z, "OID")==0 ) return 1; 328c4a3c779Sdrh return 0; 329c4a3c779Sdrh } 330c4a3c779Sdrh 331c4a3c779Sdrh /* 332cce7d176Sdrh ** This routine walks an expression tree and resolves references to 333967e8b73Sdrh ** table columns. Nodes of the form ID.ID or ID resolve into an 334aacc543eSdrh ** index to the table in the table list and a column offset. The 335aacc543eSdrh ** Expr.opcode for such nodes is changed to TK_COLUMN. The Expr.iTable 336aacc543eSdrh ** value is changed to the index of the referenced table in pTabList 337832508b7Sdrh ** plus the "base" value. The base value will ultimately become the 338aacc543eSdrh ** VDBE cursor number for a cursor that is pointing into the referenced 339aacc543eSdrh ** table. The Expr.iColumn value is changed to the index of the column 340aacc543eSdrh ** of the referenced table. The Expr.iColumn value for the special 341aacc543eSdrh ** ROWID column is -1. Any INTEGER PRIMARY KEY column is tried as an 342aacc543eSdrh ** alias for ROWID. 34319a775c2Sdrh ** 344fef5208cSdrh ** We also check for instances of the IN operator. IN comes in two 345fef5208cSdrh ** forms: 346fef5208cSdrh ** 347fef5208cSdrh ** expr IN (exprlist) 348fef5208cSdrh ** and 349fef5208cSdrh ** expr IN (SELECT ...) 350fef5208cSdrh ** 351fef5208cSdrh ** The first form is handled by creating a set holding the list 352fef5208cSdrh ** of allowed values. The second form causes the SELECT to generate 353fef5208cSdrh ** a temporary table. 354fef5208cSdrh ** 355fef5208cSdrh ** This routine also looks for scalar SELECTs that are part of an expression. 35619a775c2Sdrh ** If it finds any, it generates code to write the value of that select 35719a775c2Sdrh ** into a memory cell. 358cce7d176Sdrh ** 359967e8b73Sdrh ** Unknown columns or tables provoke an error. The function returns 360cce7d176Sdrh ** the number of errors seen and leaves an error message on pParse->zErrMsg. 361cce7d176Sdrh */ 362a2e00042Sdrh int sqliteExprResolveIds( 363a2e00042Sdrh Parse *pParse, /* The parser context */ 364832508b7Sdrh int base, /* VDBE cursor number for first entry in pTabList */ 365a2e00042Sdrh IdList *pTabList, /* List of tables used to resolve column names */ 366a2e00042Sdrh ExprList *pEList, /* List of expressions used to resolve "AS" */ 367a2e00042Sdrh Expr *pExpr /* The expression to be analyzed. */ 368a2e00042Sdrh ){ 369daffd0e5Sdrh if( pExpr==0 || pTabList==0 ) return 0; 370832508b7Sdrh assert( base+pTabList->nId<=pParse->nTab ); 371cce7d176Sdrh switch( pExpr->op ){ 3722398937bSdrh /* Double-quoted strings (ex: "abc") are used as identifiers if 3732398937bSdrh ** possible. Otherwise they remain as strings. Single-quoted 3742398937bSdrh ** strings (ex: 'abc') are always string literals. 3752398937bSdrh */ 3762398937bSdrh case TK_STRING: { 3772398937bSdrh if( pExpr->token.z[0]=='\'' ) break; 3782398937bSdrh /* Fall thru into the TK_ID case if this is a double-quoted string */ 3792398937bSdrh } 380a2e00042Sdrh /* A lone identifier. Try and match it as follows: 381a2e00042Sdrh ** 382a2e00042Sdrh ** 1. To the name of a column of one of the tables in pTabList 383a2e00042Sdrh ** 384a2e00042Sdrh ** 2. To the right side of an AS keyword in the column list of 385a2e00042Sdrh ** a SELECT statement. (For example, match against 'x' in 386a2e00042Sdrh ** "SELECT a+b AS 'x' FROM t1".) 387a2e00042Sdrh ** 388a2e00042Sdrh ** 3. One of the special names "ROWID", "OID", or "_ROWID_". 389a2e00042Sdrh */ 390cce7d176Sdrh case TK_ID: { 391cce7d176Sdrh int cnt = 0; /* Number of matches */ 392cce7d176Sdrh int i; /* Loop counter */ 393a76b5dfcSdrh char *z; 394a76b5dfcSdrh assert( pExpr->token.z ); 395a76b5dfcSdrh z = sqliteStrNDup(pExpr->token.z, pExpr->token.n); 3962f4392ffSdrh sqliteDequote(z); 397daffd0e5Sdrh if( z==0 ) return 1; 398cce7d176Sdrh for(i=0; i<pTabList->nId; i++){ 399cce7d176Sdrh int j; 400cce7d176Sdrh Table *pTab = pTabList->a[i].pTab; 401cce7d176Sdrh if( pTab==0 ) continue; 402417be79cSdrh assert( pTab->nCol>0 ); 403cce7d176Sdrh for(j=0; j<pTab->nCol; j++){ 4047020f651Sdrh if( sqliteStrICmp(pTab->aCol[j].zName, z)==0 ){ 405cce7d176Sdrh cnt++; 406832508b7Sdrh pExpr->iTable = i + base; 4074a32431cSdrh if( j==pTab->iPKey ){ 4084a32431cSdrh /* Substitute the record number for the INTEGER PRIMARY KEY */ 4094a32431cSdrh pExpr->iColumn = -1; 4104a32431cSdrh }else{ 411967e8b73Sdrh pExpr->iColumn = j; 412cce7d176Sdrh } 413a2e00042Sdrh pExpr->op = TK_COLUMN; 414a2e00042Sdrh } 415a2e00042Sdrh } 416a2e00042Sdrh } 417a2e00042Sdrh if( cnt==0 && pEList!=0 ){ 418a2e00042Sdrh int j; 419a2e00042Sdrh for(j=0; j<pEList->nExpr; j++){ 420a2e00042Sdrh char *zAs = pEList->a[j].zName; 421a2e00042Sdrh if( zAs!=0 && sqliteStrICmp(zAs, z)==0 ){ 422a2e00042Sdrh cnt++; 423a2e00042Sdrh assert( pExpr->pLeft==0 && pExpr->pRight==0 ); 424a2e00042Sdrh pExpr->op = TK_AS; 425a2e00042Sdrh pExpr->iColumn = j; 42675148a27Sdrh pExpr->pLeft = sqliteExprDup(pEList->a[j].pExpr); 427cce7d176Sdrh } 428cce7d176Sdrh } 4294a32431cSdrh } 430c4a3c779Sdrh if( cnt==0 && sqliteIsRowid(z) ){ 431c4a3c779Sdrh pExpr->iColumn = -1; 432832508b7Sdrh pExpr->iTable = base; 433c4a3c779Sdrh cnt = 1 + (pTabList->nId>1); 434a2e00042Sdrh pExpr->op = TK_COLUMN; 435c4a3c779Sdrh } 436cce7d176Sdrh sqliteFree(z); 4372398937bSdrh if( cnt==0 && pExpr->token.z[0]!='"' ){ 438967e8b73Sdrh sqliteSetNString(&pParse->zErrMsg, "no such column: ", -1, 439cce7d176Sdrh pExpr->token.z, pExpr->token.n, 0); 440cce7d176Sdrh pParse->nErr++; 441cce7d176Sdrh return 1; 442cce7d176Sdrh }else if( cnt>1 ){ 443967e8b73Sdrh sqliteSetNString(&pParse->zErrMsg, "ambiguous column name: ", -1, 444cce7d176Sdrh pExpr->token.z, pExpr->token.n, 0); 445cce7d176Sdrh pParse->nErr++; 446cce7d176Sdrh return 1; 447cce7d176Sdrh } 448cce7d176Sdrh break; 449cce7d176Sdrh } 450cce7d176Sdrh 451967e8b73Sdrh /* A table name and column name: ID.ID */ 452cce7d176Sdrh case TK_DOT: { 453cce7d176Sdrh int cnt = 0; /* Number of matches */ 454c4a3c779Sdrh int cntTab = 0; /* Number of matching tables */ 455cce7d176Sdrh int i; /* Loop counter */ 456cce7d176Sdrh Expr *pLeft, *pRight; /* Left and right subbranches of the expr */ 457cce7d176Sdrh char *zLeft, *zRight; /* Text of an identifier */ 458cce7d176Sdrh 459cce7d176Sdrh pLeft = pExpr->pLeft; 460cce7d176Sdrh pRight = pExpr->pRight; 461a76b5dfcSdrh assert( pLeft && pLeft->op==TK_ID && pLeft->token.z ); 462a76b5dfcSdrh assert( pRight && pRight->op==TK_ID && pRight->token.z ); 4636e142f54Sdrh zLeft = sqliteStrNDup(pLeft->token.z, pLeft->token.n); 4646e142f54Sdrh zRight = sqliteStrNDup(pRight->token.z, pRight->token.n); 465daffd0e5Sdrh if( zLeft==0 || zRight==0 ){ 466daffd0e5Sdrh sqliteFree(zLeft); 467daffd0e5Sdrh sqliteFree(zRight); 468daffd0e5Sdrh return 1; 469daffd0e5Sdrh } 47087c40e88Sdrh sqliteDequote(zLeft); 47187c40e88Sdrh sqliteDequote(zRight); 472c4a3c779Sdrh pExpr->iTable = -1; 473cce7d176Sdrh for(i=0; i<pTabList->nId; i++){ 474cce7d176Sdrh int j; 475cce7d176Sdrh char *zTab; 476cce7d176Sdrh Table *pTab = pTabList->a[i].pTab; 477cce7d176Sdrh if( pTab==0 ) continue; 478417be79cSdrh assert( pTab->nCol>0 ); 479cce7d176Sdrh if( pTabList->a[i].zAlias ){ 480cce7d176Sdrh zTab = pTabList->a[i].zAlias; 481cce7d176Sdrh }else{ 482cce7d176Sdrh zTab = pTab->zName; 483cce7d176Sdrh } 484094b2bbfSdrh if( zTab==0 || sqliteStrICmp(zTab, zLeft)!=0 ) continue; 485832508b7Sdrh if( 0==(cntTab++) ) pExpr->iTable = i + base; 486cce7d176Sdrh for(j=0; j<pTab->nCol; j++){ 4877020f651Sdrh if( sqliteStrICmp(pTab->aCol[j].zName, zRight)==0 ){ 488cce7d176Sdrh cnt++; 489832508b7Sdrh pExpr->iTable = i + base; 4904a32431cSdrh if( j==pTab->iPKey ){ 4914a32431cSdrh /* Substitute the record number for the INTEGER PRIMARY KEY */ 4924a32431cSdrh pExpr->iColumn = -1; 4934a32431cSdrh }else{ 494967e8b73Sdrh pExpr->iColumn = j; 495cce7d176Sdrh } 496cce7d176Sdrh } 497cce7d176Sdrh } 4984a32431cSdrh } 499c3f9bad2Sdanielk1977 500c3f9bad2Sdanielk1977 /* If we have not already resolved this *.* expression, then maybe 501c3f9bad2Sdanielk1977 * it is a new.* or old.* trigger argument reference */ 502c3f9bad2Sdanielk1977 if( cnt == 0 && pParse->trigStack != 0 ){ 503f29ce559Sdanielk1977 TriggerStack *pTriggerStack = pParse->trigStack; 504c3f9bad2Sdanielk1977 int t = 0; 505f29ce559Sdanielk1977 if( pTriggerStack->newIdx != -1 && sqliteStrICmp("new", zLeft) == 0 ){ 506f29ce559Sdanielk1977 pExpr->iTable = pTriggerStack->newIdx; 507c3f9bad2Sdanielk1977 cntTab++; 508c3f9bad2Sdanielk1977 t = 1; 509c3f9bad2Sdanielk1977 } 510f29ce559Sdanielk1977 if( pTriggerStack->oldIdx != -1 && sqliteStrICmp("old", zLeft) == 0 ){ 511f29ce559Sdanielk1977 pExpr->iTable = pTriggerStack->oldIdx; 512c3f9bad2Sdanielk1977 cntTab++; 513c3f9bad2Sdanielk1977 t = 1; 514c3f9bad2Sdanielk1977 } 515c3f9bad2Sdanielk1977 516f29ce559Sdanielk1977 if( t ){ 517f29ce559Sdanielk1977 int j; 518f29ce559Sdanielk1977 for(j=0; j < pTriggerStack->pTab->nCol; j++) { 519f29ce559Sdanielk1977 if( sqliteStrICmp(pTriggerStack->pTab->aCol[j].zName, zRight)==0 ){ 520c3f9bad2Sdanielk1977 cnt++; 521c3f9bad2Sdanielk1977 pExpr->iColumn = j; 522c3f9bad2Sdanielk1977 } 523c3f9bad2Sdanielk1977 } 524c3f9bad2Sdanielk1977 } 525f29ce559Sdanielk1977 } 526c3f9bad2Sdanielk1977 527c4a3c779Sdrh if( cnt==0 && cntTab==1 && sqliteIsRowid(zRight) ){ 528c4a3c779Sdrh cnt = 1; 529c4a3c779Sdrh pExpr->iColumn = -1; 530c4a3c779Sdrh } 531cce7d176Sdrh sqliteFree(zLeft); 532cce7d176Sdrh sqliteFree(zRight); 533cce7d176Sdrh if( cnt==0 ){ 534967e8b73Sdrh sqliteSetNString(&pParse->zErrMsg, "no such column: ", -1, 535cce7d176Sdrh pLeft->token.z, pLeft->token.n, ".", 1, 536cce7d176Sdrh pRight->token.z, pRight->token.n, 0); 537cce7d176Sdrh pParse->nErr++; 538cce7d176Sdrh return 1; 539cce7d176Sdrh }else if( cnt>1 ){ 540967e8b73Sdrh sqliteSetNString(&pParse->zErrMsg, "ambiguous column name: ", -1, 541cce7d176Sdrh pLeft->token.z, pLeft->token.n, ".", 1, 542cce7d176Sdrh pRight->token.z, pRight->token.n, 0); 543cce7d176Sdrh pParse->nErr++; 544cce7d176Sdrh return 1; 545cce7d176Sdrh } 546cce7d176Sdrh sqliteExprDelete(pLeft); 547cce7d176Sdrh pExpr->pLeft = 0; 548cce7d176Sdrh sqliteExprDelete(pRight); 549cce7d176Sdrh pExpr->pRight = 0; 550967e8b73Sdrh pExpr->op = TK_COLUMN; 551cce7d176Sdrh break; 552cce7d176Sdrh } 553cce7d176Sdrh 554fef5208cSdrh case TK_IN: { 555d8bc7086Sdrh Vdbe *v = sqliteGetVdbe(pParse); 556fef5208cSdrh if( v==0 ) return 1; 557832508b7Sdrh if( sqliteExprResolveIds(pParse, base, pTabList, pEList, pExpr->pLeft) ){ 558cfab11bcSdrh return 1; 559cfab11bcSdrh } 560fef5208cSdrh if( pExpr->pSelect ){ 561fef5208cSdrh /* Case 1: expr IN (SELECT ...) 562fef5208cSdrh ** 563fef5208cSdrh ** Generate code to write the results of the select into a temporary 5644794b980Sdrh ** table. The cursor number of the temporary table has already 5654794b980Sdrh ** been put in iTable by sqliteExprResolveInSelect(). 566fef5208cSdrh */ 567832508b7Sdrh pExpr->iTable = pParse->nTab++; 568c6b52df3Sdrh sqliteVdbeAddOp(v, OP_OpenTemp, pExpr->iTable, 1); 569832508b7Sdrh sqliteSelect(pParse, pExpr->pSelect, SRT_Set, pExpr->iTable, 0,0,0); 570fef5208cSdrh }else if( pExpr->pList ){ 571fef5208cSdrh /* Case 2: expr IN (exprlist) 572fef5208cSdrh ** 573fef5208cSdrh ** Create a set to put the exprlist values in. The Set id is stored 574fef5208cSdrh ** in iTable. 575fef5208cSdrh */ 576fef5208cSdrh int i, iSet; 577fef5208cSdrh for(i=0; i<pExpr->pList->nExpr; i++){ 578fef5208cSdrh Expr *pE2 = pExpr->pList->a[i].pExpr; 5799208643dSdrh if( !sqliteExprIsConstant(pE2) ){ 580fef5208cSdrh sqliteSetString(&pParse->zErrMsg, 581fef5208cSdrh "right-hand side of IN operator must be constant", 0); 582fef5208cSdrh pParse->nErr++; 583fef5208cSdrh return 1; 584fef5208cSdrh } 5854794b980Sdrh if( sqliteExprCheck(pParse, pE2, 0, 0) ){ 5864794b980Sdrh return 1; 5874794b980Sdrh } 588fef5208cSdrh } 589fef5208cSdrh iSet = pExpr->iTable = pParse->nSet++; 590fef5208cSdrh for(i=0; i<pExpr->pList->nExpr; i++){ 591fef5208cSdrh Expr *pE2 = pExpr->pList->a[i].pExpr; 592fef5208cSdrh switch( pE2->op ){ 593fef5208cSdrh case TK_FLOAT: 594fef5208cSdrh case TK_INTEGER: 595fef5208cSdrh case TK_STRING: { 59699fcd718Sdrh int addr = sqliteVdbeAddOp(v, OP_SetInsert, iSet, 0); 597a76b5dfcSdrh assert( pE2->token.z ); 598fef5208cSdrh sqliteVdbeChangeP3(v, addr, pE2->token.z, pE2->token.n); 599fef5208cSdrh sqliteVdbeDequoteP3(v, addr); 600fef5208cSdrh break; 601fef5208cSdrh } 602fef5208cSdrh default: { 603fef5208cSdrh sqliteExprCode(pParse, pE2); 60499fcd718Sdrh sqliteVdbeAddOp(v, OP_SetInsert, iSet, 0); 605fef5208cSdrh break; 606fef5208cSdrh } 607fef5208cSdrh } 608fef5208cSdrh } 609fef5208cSdrh } 610cfab11bcSdrh break; 611fef5208cSdrh } 612fef5208cSdrh 61319a775c2Sdrh case TK_SELECT: { 614fef5208cSdrh /* This has to be a scalar SELECT. Generate code to put the 615fef5208cSdrh ** value of this select in a memory cell and record the number 616967e8b73Sdrh ** of the memory cell in iColumn. 617fef5208cSdrh */ 618967e8b73Sdrh pExpr->iColumn = pParse->nMem++; 619832508b7Sdrh if( sqliteSelect(pParse, pExpr->pSelect, SRT_Mem, pExpr->iColumn,0,0,0) ){ 62019a775c2Sdrh return 1; 62119a775c2Sdrh } 62219a775c2Sdrh break; 62319a775c2Sdrh } 62419a775c2Sdrh 625cce7d176Sdrh /* For all else, just recursively walk the tree */ 626cce7d176Sdrh default: { 627cce7d176Sdrh if( pExpr->pLeft 628832508b7Sdrh && sqliteExprResolveIds(pParse, base, pTabList, pEList, pExpr->pLeft) ){ 629cce7d176Sdrh return 1; 630cce7d176Sdrh } 631cce7d176Sdrh if( pExpr->pRight 632832508b7Sdrh && sqliteExprResolveIds(pParse, base, pTabList, pEList, pExpr->pRight) ){ 633cce7d176Sdrh return 1; 634cce7d176Sdrh } 635cce7d176Sdrh if( pExpr->pList ){ 636cce7d176Sdrh int i; 637cce7d176Sdrh ExprList *pList = pExpr->pList; 638cce7d176Sdrh for(i=0; i<pList->nExpr; i++){ 639832508b7Sdrh Expr *pArg = pList->a[i].pExpr; 640832508b7Sdrh if( sqliteExprResolveIds(pParse, base, pTabList, pEList, pArg) ){ 641cce7d176Sdrh return 1; 642cce7d176Sdrh } 643cce7d176Sdrh } 644cce7d176Sdrh } 645cce7d176Sdrh } 646cce7d176Sdrh } 647cce7d176Sdrh return 0; 648cce7d176Sdrh } 649cce7d176Sdrh 650cce7d176Sdrh /* 651cce7d176Sdrh ** Error check the functions in an expression. Make sure all 652cce7d176Sdrh ** function names are recognized and all functions have the correct 653cce7d176Sdrh ** number of arguments. Leave an error message in pParse->zErrMsg 654cce7d176Sdrh ** if anything is amiss. Return the number of errors. 655cce7d176Sdrh ** 656cce7d176Sdrh ** if pIsAgg is not null and this expression is an aggregate function 657cce7d176Sdrh ** (like count(*) or max(value)) then write a 1 into *pIsAgg. 658cce7d176Sdrh */ 659cce7d176Sdrh int sqliteExprCheck(Parse *pParse, Expr *pExpr, int allowAgg, int *pIsAgg){ 660cce7d176Sdrh int nErr = 0; 661cce7d176Sdrh if( pExpr==0 ) return 0; 662cce7d176Sdrh switch( pExpr->op ){ 663cce7d176Sdrh case TK_FUNCTION: { 664cce7d176Sdrh int n = pExpr->pList ? pExpr->pList->nExpr : 0; 665cce7d176Sdrh int no_such_func = 0; 6668e0a2f90Sdrh int wrong_num_args = 0; 667cce7d176Sdrh int is_agg = 0; 668cce7d176Sdrh int i; 6690bce8354Sdrh FuncDef *pDef; 6700bce8354Sdrh 67189425d5eSdrh pDef = sqliteFindFunction(pParse->db, 67289425d5eSdrh pExpr->token.z, pExpr->token.n, n, 0); 6730bce8354Sdrh if( pDef==0 ){ 6740bce8354Sdrh pDef = sqliteFindFunction(pParse->db, 6758e0a2f90Sdrh pExpr->token.z, pExpr->token.n, -1, 0); 6760bce8354Sdrh if( pDef==0 ){ 677cce7d176Sdrh no_such_func = 1; 6788e0a2f90Sdrh }else{ 6798e0a2f90Sdrh wrong_num_args = 1; 6808e0a2f90Sdrh } 6818e0a2f90Sdrh }else{ 6820bce8354Sdrh is_agg = pDef->xFunc==0; 683cce7d176Sdrh } 6848e0a2f90Sdrh if( is_agg && !allowAgg ){ 6858e0a2f90Sdrh sqliteSetNString(&pParse->zErrMsg, "misuse of aggregate function ", -1, 6868e0a2f90Sdrh pExpr->token.z, pExpr->token.n, "()", 2, 0); 6878e0a2f90Sdrh pParse->nErr++; 6888e0a2f90Sdrh nErr++; 6898e0a2f90Sdrh is_agg = 0; 6908e0a2f90Sdrh }else if( no_such_func ){ 691cce7d176Sdrh sqliteSetNString(&pParse->zErrMsg, "no such function: ", -1, 692cce7d176Sdrh pExpr->token.z, pExpr->token.n, 0); 693cce7d176Sdrh pParse->nErr++; 694cce7d176Sdrh nErr++; 6958e0a2f90Sdrh }else if( wrong_num_args ){ 6968e0a2f90Sdrh sqliteSetNString(&pParse->zErrMsg, 6978e0a2f90Sdrh "wrong number of arguments to function ",-1, 6988e0a2f90Sdrh pExpr->token.z, pExpr->token.n, "()", 2, 0); 6998e0a2f90Sdrh pParse->nErr++; 7008e0a2f90Sdrh nErr++; 701cce7d176Sdrh } 7022282792aSdrh if( is_agg ) pExpr->op = TK_AGG_FUNCTION; 703cce7d176Sdrh if( is_agg && pIsAgg ) *pIsAgg = 1; 704cce7d176Sdrh for(i=0; nErr==0 && i<n; i++){ 7054cfa7934Sdrh nErr = sqliteExprCheck(pParse, pExpr->pList->a[i].pExpr, 7064cfa7934Sdrh allowAgg && !is_agg, pIsAgg); 707cce7d176Sdrh } 708cce7d176Sdrh } 709cce7d176Sdrh default: { 710cce7d176Sdrh if( pExpr->pLeft ){ 7112282792aSdrh nErr = sqliteExprCheck(pParse, pExpr->pLeft, allowAgg, pIsAgg); 712cce7d176Sdrh } 713cce7d176Sdrh if( nErr==0 && pExpr->pRight ){ 7142282792aSdrh nErr = sqliteExprCheck(pParse, pExpr->pRight, allowAgg, pIsAgg); 715cce7d176Sdrh } 716fef5208cSdrh if( nErr==0 && pExpr->pList ){ 717fef5208cSdrh int n = pExpr->pList->nExpr; 718fef5208cSdrh int i; 719fef5208cSdrh for(i=0; nErr==0 && i<n; i++){ 7202282792aSdrh Expr *pE2 = pExpr->pList->a[i].pExpr; 7212282792aSdrh nErr = sqliteExprCheck(pParse, pE2, allowAgg, pIsAgg); 722fef5208cSdrh } 723fef5208cSdrh } 724cce7d176Sdrh break; 725cce7d176Sdrh } 726cce7d176Sdrh } 727cce7d176Sdrh return nErr; 728cce7d176Sdrh } 729cce7d176Sdrh 730cce7d176Sdrh /* 731cce7d176Sdrh ** Generate code into the current Vdbe to evaluate the given 7321ccde15dSdrh ** expression and leave the result on the top of stack. 733cce7d176Sdrh */ 734cce7d176Sdrh void sqliteExprCode(Parse *pParse, Expr *pExpr){ 735cce7d176Sdrh Vdbe *v = pParse->pVdbe; 736cce7d176Sdrh int op; 737daffd0e5Sdrh if( v==0 || pExpr==0 ) return; 738cce7d176Sdrh switch( pExpr->op ){ 739cce7d176Sdrh case TK_PLUS: op = OP_Add; break; 740cce7d176Sdrh case TK_MINUS: op = OP_Subtract; break; 741cce7d176Sdrh case TK_STAR: op = OP_Multiply; break; 742cce7d176Sdrh case TK_SLASH: op = OP_Divide; break; 743cce7d176Sdrh case TK_AND: op = OP_And; break; 744cce7d176Sdrh case TK_OR: op = OP_Or; break; 745cce7d176Sdrh case TK_LT: op = OP_Lt; break; 746cce7d176Sdrh case TK_LE: op = OP_Le; break; 747cce7d176Sdrh case TK_GT: op = OP_Gt; break; 748cce7d176Sdrh case TK_GE: op = OP_Ge; break; 749cce7d176Sdrh case TK_NE: op = OP_Ne; break; 750cce7d176Sdrh case TK_EQ: op = OP_Eq; break; 751cce7d176Sdrh case TK_ISNULL: op = OP_IsNull; break; 752cce7d176Sdrh case TK_NOTNULL: op = OP_NotNull; break; 753cce7d176Sdrh case TK_NOT: op = OP_Not; break; 754cce7d176Sdrh case TK_UMINUS: op = OP_Negative; break; 755bf4133cbSdrh case TK_BITAND: op = OP_BitAnd; break; 756bf4133cbSdrh case TK_BITOR: op = OP_BitOr; break; 757bf4133cbSdrh case TK_BITNOT: op = OP_BitNot; break; 758bf4133cbSdrh case TK_LSHIFT: op = OP_ShiftLeft; break; 759bf4133cbSdrh case TK_RSHIFT: op = OP_ShiftRight; break; 760bf4133cbSdrh case TK_REM: op = OP_Remainder; break; 761cce7d176Sdrh default: break; 762cce7d176Sdrh } 763cce7d176Sdrh switch( pExpr->op ){ 764967e8b73Sdrh case TK_COLUMN: { 7652282792aSdrh if( pParse->useAgg ){ 76699fcd718Sdrh sqliteVdbeAddOp(v, OP_AggGet, 0, pExpr->iAgg); 767c4a3c779Sdrh }else if( pExpr->iColumn>=0 ){ 76899fcd718Sdrh sqliteVdbeAddOp(v, OP_Column, pExpr->iTable, pExpr->iColumn); 769c4a3c779Sdrh }else{ 77099fcd718Sdrh sqliteVdbeAddOp(v, OP_Recno, pExpr->iTable, 0); 7712282792aSdrh } 772cce7d176Sdrh break; 773cce7d176Sdrh } 774cce7d176Sdrh case TK_INTEGER: { 775e6840900Sdrh sqliteVdbeAddOp(v, OP_Integer, atoi(pExpr->token.z), 0); 776e6840900Sdrh sqliteVdbeChangeP3(v, -1, pExpr->token.z, pExpr->token.n); 777e6840900Sdrh break; 778e6840900Sdrh } 779e6840900Sdrh case TK_FLOAT: { 7807a7c7390Sdrh sqliteVdbeAddOp(v, OP_String, 0, 0); 781a76b5dfcSdrh assert( pExpr->token.z ); 7827a7c7390Sdrh sqliteVdbeChangeP3(v, -1, pExpr->token.z, pExpr->token.n); 783cce7d176Sdrh break; 784cce7d176Sdrh } 785cce7d176Sdrh case TK_STRING: { 78699fcd718Sdrh int addr = sqliteVdbeAddOp(v, OP_String, 0, 0); 787a76b5dfcSdrh assert( pExpr->token.z ); 788cce7d176Sdrh sqliteVdbeChangeP3(v, addr, pExpr->token.z, pExpr->token.n); 789cce7d176Sdrh sqliteVdbeDequoteP3(v, addr); 790cce7d176Sdrh break; 791cce7d176Sdrh } 792cce7d176Sdrh case TK_NULL: { 79399fcd718Sdrh sqliteVdbeAddOp(v, OP_String, 0, 0); 794cce7d176Sdrh break; 795cce7d176Sdrh } 796cce7d176Sdrh case TK_AND: 797cce7d176Sdrh case TK_OR: 798cce7d176Sdrh case TK_PLUS: 799cce7d176Sdrh case TK_STAR: 800cce7d176Sdrh case TK_MINUS: 801bf4133cbSdrh case TK_REM: 802bf4133cbSdrh case TK_BITAND: 803bf4133cbSdrh case TK_BITOR: 804cce7d176Sdrh case TK_SLASH: { 805cce7d176Sdrh sqliteExprCode(pParse, pExpr->pLeft); 806cce7d176Sdrh sqliteExprCode(pParse, pExpr->pRight); 80799fcd718Sdrh sqliteVdbeAddOp(v, op, 0, 0); 808cce7d176Sdrh break; 809cce7d176Sdrh } 810bf4133cbSdrh case TK_LSHIFT: 811bf4133cbSdrh case TK_RSHIFT: { 812bf4133cbSdrh sqliteExprCode(pParse, pExpr->pRight); 813bf4133cbSdrh sqliteExprCode(pParse, pExpr->pLeft); 814bf4133cbSdrh sqliteVdbeAddOp(v, op, 0, 0); 815bf4133cbSdrh break; 816bf4133cbSdrh } 8170040077dSdrh case TK_CONCAT: { 8180040077dSdrh sqliteExprCode(pParse, pExpr->pLeft); 8190040077dSdrh sqliteExprCode(pParse, pExpr->pRight); 82099fcd718Sdrh sqliteVdbeAddOp(v, OP_Concat, 2, 0); 8210040077dSdrh break; 8220040077dSdrh } 823cce7d176Sdrh case TK_LT: 824cce7d176Sdrh case TK_LE: 825cce7d176Sdrh case TK_GT: 826cce7d176Sdrh case TK_GE: 827cce7d176Sdrh case TK_NE: 8280ac65892Sdrh case TK_EQ: { 829cce7d176Sdrh int dest; 83099fcd718Sdrh sqliteVdbeAddOp(v, OP_Integer, 1, 0); 831cce7d176Sdrh sqliteExprCode(pParse, pExpr->pLeft); 832cce7d176Sdrh sqliteExprCode(pParse, pExpr->pRight); 833cce7d176Sdrh dest = sqliteVdbeCurrentAddr(v) + 2; 83499fcd718Sdrh sqliteVdbeAddOp(v, op, 0, dest); 83599fcd718Sdrh sqliteVdbeAddOp(v, OP_AddImm, -1, 0); 836cce7d176Sdrh break; 837cce7d176Sdrh } 838cce7d176Sdrh case TK_UMINUS: { 8396e142f54Sdrh assert( pExpr->pLeft ); 8407a7c7390Sdrh if( pExpr->pLeft->op==TK_FLOAT || pExpr->pLeft->op==TK_INTEGER ){ 8416e142f54Sdrh Token *p = &pExpr->pLeft->token; 8426e142f54Sdrh char *z = sqliteMalloc( p->n + 2 ); 8436e142f54Sdrh sprintf(z, "-%.*s", p->n, p->z); 844e6840900Sdrh if( pExpr->pLeft->op==TK_INTEGER ){ 845e6840900Sdrh sqliteVdbeAddOp(v, OP_Integer, atoi(z), 0); 846e6840900Sdrh }else{ 84799fcd718Sdrh sqliteVdbeAddOp(v, OP_String, 0, 0); 848e6840900Sdrh } 84999fcd718Sdrh sqliteVdbeChangeP3(v, -1, z, p->n+1); 8506e142f54Sdrh sqliteFree(z); 8516e142f54Sdrh break; 8526e142f54Sdrh } 8531ccde15dSdrh /* Fall through into TK_NOT */ 8546e142f54Sdrh } 855bf4133cbSdrh case TK_BITNOT: 8566e142f54Sdrh case TK_NOT: { 857cce7d176Sdrh sqliteExprCode(pParse, pExpr->pLeft); 85899fcd718Sdrh sqliteVdbeAddOp(v, op, 0, 0); 859cce7d176Sdrh break; 860cce7d176Sdrh } 861cce7d176Sdrh case TK_ISNULL: 862cce7d176Sdrh case TK_NOTNULL: { 863cce7d176Sdrh int dest; 86499fcd718Sdrh sqliteVdbeAddOp(v, OP_Integer, 1, 0); 865cce7d176Sdrh sqliteExprCode(pParse, pExpr->pLeft); 866cce7d176Sdrh dest = sqliteVdbeCurrentAddr(v) + 2; 86799fcd718Sdrh sqliteVdbeAddOp(v, op, 0, dest); 86899fcd718Sdrh sqliteVdbeAddOp(v, OP_AddImm, -1, 0); 869cce7d176Sdrh break; 870cce7d176Sdrh } 8712282792aSdrh case TK_AGG_FUNCTION: { 87299fcd718Sdrh sqliteVdbeAddOp(v, OP_AggGet, 0, pExpr->iAgg); 8732282792aSdrh break; 8742282792aSdrh } 875cce7d176Sdrh case TK_FUNCTION: { 876cce7d176Sdrh int i; 877cce7d176Sdrh ExprList *pList = pExpr->pList; 87889425d5eSdrh int nExpr = pList ? pList->nExpr : 0; 8790bce8354Sdrh FuncDef *pDef; 8800bce8354Sdrh pDef = sqliteFindFunction(pParse->db, 88189425d5eSdrh pExpr->token.z, pExpr->token.n, nExpr, 0); 8820bce8354Sdrh assert( pDef!=0 ); 88389425d5eSdrh for(i=0; i<nExpr; i++){ 8848e0a2f90Sdrh sqliteExprCode(pParse, pList->a[i].pExpr); 8858e0a2f90Sdrh } 88689425d5eSdrh sqliteVdbeAddOp(v, OP_Function, nExpr, 0); 8870bce8354Sdrh sqliteVdbeChangeP3(v, -1, (char*)pDef, P3_POINTER); 8886ec2733bSdrh break; 8896ec2733bSdrh } 89019a775c2Sdrh case TK_SELECT: { 89199fcd718Sdrh sqliteVdbeAddOp(v, OP_MemLoad, pExpr->iColumn, 0); 89219a775c2Sdrh break; 89319a775c2Sdrh } 894fef5208cSdrh case TK_IN: { 895fef5208cSdrh int addr; 89699fcd718Sdrh sqliteVdbeAddOp(v, OP_Integer, 1, 0); 897fef5208cSdrh sqliteExprCode(pParse, pExpr->pLeft); 898fef5208cSdrh addr = sqliteVdbeCurrentAddr(v); 899fef5208cSdrh if( pExpr->pSelect ){ 90099fcd718Sdrh sqliteVdbeAddOp(v, OP_Found, pExpr->iTable, addr+2); 901fef5208cSdrh }else{ 90299fcd718Sdrh sqliteVdbeAddOp(v, OP_SetFound, pExpr->iTable, addr+2); 903fef5208cSdrh } 90499fcd718Sdrh sqliteVdbeAddOp(v, OP_AddImm, -1, 0); 905fef5208cSdrh break; 906fef5208cSdrh } 907fef5208cSdrh case TK_BETWEEN: { 908fef5208cSdrh int lbl = sqliteVdbeMakeLabel(v); 90999fcd718Sdrh sqliteVdbeAddOp(v, OP_Integer, 0, 0); 910fef5208cSdrh sqliteExprIfFalse(pParse, pExpr, lbl); 91199fcd718Sdrh sqliteVdbeAddOp(v, OP_AddImm, 1, 0); 912fef5208cSdrh sqliteVdbeResolveLabel(v, lbl); 913fef5208cSdrh break; 914fef5208cSdrh } 915a2e00042Sdrh case TK_AS: { 916a2e00042Sdrh sqliteExprCode(pParse, pExpr->pLeft); 917a2e00042Sdrh break; 918a2e00042Sdrh } 91917a7f8ddSdrh case TK_CASE: { 92017a7f8ddSdrh int expr_end_label; 92117a7f8ddSdrh int next_when_label; 92217a7f8ddSdrh int i; 92317a7f8ddSdrh 92417a7f8ddSdrh assert(pExpr->pList); 92517a7f8ddSdrh assert((pExpr->pList->nExpr % 2) == 0); 92617a7f8ddSdrh assert(pExpr->pList->nExpr > 0); 92717a7f8ddSdrh expr_end_label = sqliteVdbeMakeLabel(pParse->pVdbe); 92817a7f8ddSdrh if( pExpr->pLeft ){ 92917a7f8ddSdrh sqliteExprCode(pParse, pExpr->pLeft); 930cce7d176Sdrh } 93117a7f8ddSdrh for(i=0; i<pExpr->pList->nExpr; i=i+2){ 93217a7f8ddSdrh if( i!=0 ){ 93317a7f8ddSdrh sqliteVdbeResolveLabel(pParse->pVdbe, next_when_label); 93417a7f8ddSdrh } 93517a7f8ddSdrh next_when_label = sqliteVdbeMakeLabel(pParse->pVdbe); 93617a7f8ddSdrh if( pExpr->pLeft ){ 93717a7f8ddSdrh sqliteVdbeAddOp(pParse->pVdbe, OP_Dup, 0, 1); 93817a7f8ddSdrh sqliteExprCode(pParse, pExpr->pList->a[i].pExpr); 93917a7f8ddSdrh sqliteVdbeAddOp(pParse->pVdbe, OP_Ne, 0, next_when_label); 94017a7f8ddSdrh }else{ 94117a7f8ddSdrh sqliteExprIfFalse(pParse, pExpr->pList->a[i].pExpr, next_when_label); 94217a7f8ddSdrh } 94317a7f8ddSdrh if( pExpr->pLeft ){ 94417a7f8ddSdrh sqliteVdbeAddOp(pParse->pVdbe, OP_Pop, 1, 0); 94517a7f8ddSdrh } 94617a7f8ddSdrh sqliteExprCode(pParse, pExpr->pList->a[i+1].pExpr); 94717a7f8ddSdrh sqliteVdbeAddOp(pParse->pVdbe, OP_Goto, 0, expr_end_label); 94817a7f8ddSdrh } 94917a7f8ddSdrh sqliteVdbeResolveLabel(pParse->pVdbe, next_when_label); 95017a7f8ddSdrh if( pExpr->pLeft ){ 95117a7f8ddSdrh sqliteVdbeAddOp(pParse->pVdbe, OP_Pop, 1, 0); 95217a7f8ddSdrh } 95317a7f8ddSdrh if( pExpr->pRight ){ 95417a7f8ddSdrh sqliteExprCode(pParse, pExpr->pRight); 95517a7f8ddSdrh }else{ 95617a7f8ddSdrh sqliteVdbeAddOp(pParse->pVdbe, OP_String, 0, 0); 95717a7f8ddSdrh } 95817a7f8ddSdrh sqliteVdbeResolveLabel(pParse->pVdbe, expr_end_label); 95917a7f8ddSdrh } 96017a7f8ddSdrh break; 96117a7f8ddSdrh } 962cce7d176Sdrh } 963cce7d176Sdrh 964cce7d176Sdrh /* 965cce7d176Sdrh ** Generate code for a boolean expression such that a jump is made 966cce7d176Sdrh ** to the label "dest" if the expression is true but execution 967cce7d176Sdrh ** continues straight thru if the expression is false. 968cce7d176Sdrh */ 969cce7d176Sdrh void sqliteExprIfTrue(Parse *pParse, Expr *pExpr, int dest){ 970cce7d176Sdrh Vdbe *v = pParse->pVdbe; 971cce7d176Sdrh int op = 0; 972daffd0e5Sdrh if( v==0 || pExpr==0 ) return; 973cce7d176Sdrh switch( pExpr->op ){ 974cce7d176Sdrh case TK_LT: op = OP_Lt; break; 975cce7d176Sdrh case TK_LE: op = OP_Le; break; 976cce7d176Sdrh case TK_GT: op = OP_Gt; break; 977cce7d176Sdrh case TK_GE: op = OP_Ge; break; 978cce7d176Sdrh case TK_NE: op = OP_Ne; break; 979cce7d176Sdrh case TK_EQ: op = OP_Eq; break; 980cce7d176Sdrh case TK_ISNULL: op = OP_IsNull; break; 981cce7d176Sdrh case TK_NOTNULL: op = OP_NotNull; break; 982cce7d176Sdrh default: break; 983cce7d176Sdrh } 984cce7d176Sdrh switch( pExpr->op ){ 985cce7d176Sdrh case TK_AND: { 986cce7d176Sdrh int d2 = sqliteVdbeMakeLabel(v); 987cce7d176Sdrh sqliteExprIfFalse(pParse, pExpr->pLeft, d2); 988cce7d176Sdrh sqliteExprIfTrue(pParse, pExpr->pRight, dest); 989cce7d176Sdrh sqliteVdbeResolveLabel(v, d2); 990cce7d176Sdrh break; 991cce7d176Sdrh } 992cce7d176Sdrh case TK_OR: { 993cce7d176Sdrh sqliteExprIfTrue(pParse, pExpr->pLeft, dest); 994cce7d176Sdrh sqliteExprIfTrue(pParse, pExpr->pRight, dest); 995cce7d176Sdrh break; 996cce7d176Sdrh } 997cce7d176Sdrh case TK_NOT: { 998cce7d176Sdrh sqliteExprIfFalse(pParse, pExpr->pLeft, dest); 999cce7d176Sdrh break; 1000cce7d176Sdrh } 1001cce7d176Sdrh case TK_LT: 1002cce7d176Sdrh case TK_LE: 1003cce7d176Sdrh case TK_GT: 1004cce7d176Sdrh case TK_GE: 1005cce7d176Sdrh case TK_NE: 10060ac65892Sdrh case TK_EQ: { 1007cce7d176Sdrh sqliteExprCode(pParse, pExpr->pLeft); 1008cce7d176Sdrh sqliteExprCode(pParse, pExpr->pRight); 100999fcd718Sdrh sqliteVdbeAddOp(v, op, 0, dest); 1010cce7d176Sdrh break; 1011cce7d176Sdrh } 1012cce7d176Sdrh case TK_ISNULL: 1013cce7d176Sdrh case TK_NOTNULL: { 1014cce7d176Sdrh sqliteExprCode(pParse, pExpr->pLeft); 101599fcd718Sdrh sqliteVdbeAddOp(v, op, 0, dest); 1016cce7d176Sdrh break; 1017cce7d176Sdrh } 1018fef5208cSdrh case TK_IN: { 1019cfab11bcSdrh sqliteExprCode(pParse, pExpr->pLeft); 1020fef5208cSdrh if( pExpr->pSelect ){ 102199fcd718Sdrh sqliteVdbeAddOp(v, OP_Found, pExpr->iTable, dest); 1022fef5208cSdrh }else{ 102399fcd718Sdrh sqliteVdbeAddOp(v, OP_SetFound, pExpr->iTable, dest); 1024fef5208cSdrh } 1025fef5208cSdrh break; 1026fef5208cSdrh } 1027fef5208cSdrh case TK_BETWEEN: { 1028fef5208cSdrh int lbl = sqliteVdbeMakeLabel(v); 1029fef5208cSdrh sqliteExprCode(pParse, pExpr->pLeft); 103099fcd718Sdrh sqliteVdbeAddOp(v, OP_Dup, 0, 0); 1031fef5208cSdrh sqliteExprCode(pParse, pExpr->pList->a[0].pExpr); 103299fcd718Sdrh sqliteVdbeAddOp(v, OP_Lt, 0, lbl); 1033fef5208cSdrh sqliteExprCode(pParse, pExpr->pList->a[1].pExpr); 103499fcd718Sdrh sqliteVdbeAddOp(v, OP_Le, 0, dest); 103599fcd718Sdrh sqliteVdbeAddOp(v, OP_Integer, 0, 0); 103699fcd718Sdrh sqliteVdbeResolveLabel(v, lbl); 103799fcd718Sdrh sqliteVdbeAddOp(v, OP_Pop, 1, 0); 1038fef5208cSdrh break; 1039fef5208cSdrh } 1040cce7d176Sdrh default: { 1041cce7d176Sdrh sqliteExprCode(pParse, pExpr); 104299fcd718Sdrh sqliteVdbeAddOp(v, OP_If, 0, dest); 1043cce7d176Sdrh break; 1044cce7d176Sdrh } 1045cce7d176Sdrh } 1046cce7d176Sdrh } 1047cce7d176Sdrh 1048cce7d176Sdrh /* 104966b89c8fSdrh ** Generate code for a boolean expression such that a jump is made 1050cce7d176Sdrh ** to the label "dest" if the expression is false but execution 1051cce7d176Sdrh ** continues straight thru if the expression is true. 1052cce7d176Sdrh */ 1053cce7d176Sdrh void sqliteExprIfFalse(Parse *pParse, Expr *pExpr, int dest){ 1054cce7d176Sdrh Vdbe *v = pParse->pVdbe; 1055cce7d176Sdrh int op = 0; 1056daffd0e5Sdrh if( v==0 || pExpr==0 ) return; 1057cce7d176Sdrh switch( pExpr->op ){ 1058cce7d176Sdrh case TK_LT: op = OP_Ge; break; 1059cce7d176Sdrh case TK_LE: op = OP_Gt; break; 1060cce7d176Sdrh case TK_GT: op = OP_Le; break; 1061cce7d176Sdrh case TK_GE: op = OP_Lt; break; 1062cce7d176Sdrh case TK_NE: op = OP_Eq; break; 1063cce7d176Sdrh case TK_EQ: op = OP_Ne; break; 1064cce7d176Sdrh case TK_ISNULL: op = OP_NotNull; break; 1065cce7d176Sdrh case TK_NOTNULL: op = OP_IsNull; break; 1066cce7d176Sdrh default: break; 1067cce7d176Sdrh } 1068cce7d176Sdrh switch( pExpr->op ){ 1069cce7d176Sdrh case TK_AND: { 1070cce7d176Sdrh sqliteExprIfFalse(pParse, pExpr->pLeft, dest); 1071cce7d176Sdrh sqliteExprIfFalse(pParse, pExpr->pRight, dest); 1072cce7d176Sdrh break; 1073cce7d176Sdrh } 1074cce7d176Sdrh case TK_OR: { 1075cce7d176Sdrh int d2 = sqliteVdbeMakeLabel(v); 1076cce7d176Sdrh sqliteExprIfTrue(pParse, pExpr->pLeft, d2); 1077cce7d176Sdrh sqliteExprIfFalse(pParse, pExpr->pRight, dest); 1078cce7d176Sdrh sqliteVdbeResolveLabel(v, d2); 1079cce7d176Sdrh break; 1080cce7d176Sdrh } 1081cce7d176Sdrh case TK_NOT: { 1082cce7d176Sdrh sqliteExprIfTrue(pParse, pExpr->pLeft, dest); 1083cce7d176Sdrh break; 1084cce7d176Sdrh } 1085cce7d176Sdrh case TK_LT: 1086cce7d176Sdrh case TK_LE: 1087cce7d176Sdrh case TK_GT: 1088cce7d176Sdrh case TK_GE: 1089cce7d176Sdrh case TK_NE: 1090cce7d176Sdrh case TK_EQ: { 1091cce7d176Sdrh sqliteExprCode(pParse, pExpr->pLeft); 1092cce7d176Sdrh sqliteExprCode(pParse, pExpr->pRight); 109399fcd718Sdrh sqliteVdbeAddOp(v, op, 0, dest); 1094cce7d176Sdrh break; 1095cce7d176Sdrh } 1096cce7d176Sdrh case TK_ISNULL: 1097cce7d176Sdrh case TK_NOTNULL: { 1098cce7d176Sdrh sqliteExprCode(pParse, pExpr->pLeft); 109999fcd718Sdrh sqliteVdbeAddOp(v, op, 0, dest); 1100cce7d176Sdrh break; 1101cce7d176Sdrh } 1102fef5208cSdrh case TK_IN: { 1103cfab11bcSdrh sqliteExprCode(pParse, pExpr->pLeft); 1104fef5208cSdrh if( pExpr->pSelect ){ 110599fcd718Sdrh sqliteVdbeAddOp(v, OP_NotFound, pExpr->iTable, dest); 1106fef5208cSdrh }else{ 110799fcd718Sdrh sqliteVdbeAddOp(v, OP_SetNotFound, pExpr->iTable, dest); 1108fef5208cSdrh } 1109fef5208cSdrh break; 1110fef5208cSdrh } 1111fef5208cSdrh case TK_BETWEEN: { 1112fef5208cSdrh int addr; 1113fef5208cSdrh sqliteExprCode(pParse, pExpr->pLeft); 111499fcd718Sdrh sqliteVdbeAddOp(v, OP_Dup, 0, 0); 1115fef5208cSdrh sqliteExprCode(pParse, pExpr->pList->a[0].pExpr); 1116fef5208cSdrh addr = sqliteVdbeCurrentAddr(v); 111799fcd718Sdrh sqliteVdbeAddOp(v, OP_Ge, 0, addr+3); 111899fcd718Sdrh sqliteVdbeAddOp(v, OP_Pop, 1, 0); 111999fcd718Sdrh sqliteVdbeAddOp(v, OP_Goto, 0, dest); 1120fef5208cSdrh sqliteExprCode(pParse, pExpr->pList->a[1].pExpr); 112199fcd718Sdrh sqliteVdbeAddOp(v, OP_Gt, 0, dest); 1122fef5208cSdrh break; 1123fef5208cSdrh } 1124cce7d176Sdrh default: { 1125cce7d176Sdrh sqliteExprCode(pParse, pExpr); 112699fcd718Sdrh sqliteVdbeAddOp(v, OP_Not, 0, 0); 112799fcd718Sdrh sqliteVdbeAddOp(v, OP_If, 0, dest); 1128cce7d176Sdrh break; 1129cce7d176Sdrh } 1130cce7d176Sdrh } 1131cce7d176Sdrh } 11322282792aSdrh 11332282792aSdrh /* 11342282792aSdrh ** Do a deep comparison of two expression trees. Return TRUE (non-zero) 11352282792aSdrh ** if they are identical and return FALSE if they differ in any way. 11362282792aSdrh */ 1137d8bc7086Sdrh int sqliteExprCompare(Expr *pA, Expr *pB){ 11382282792aSdrh int i; 11392282792aSdrh if( pA==0 ){ 11402282792aSdrh return pB==0; 11412282792aSdrh }else if( pB==0 ){ 11422282792aSdrh return 0; 11432282792aSdrh } 11442282792aSdrh if( pA->op!=pB->op ) return 0; 1145d8bc7086Sdrh if( !sqliteExprCompare(pA->pLeft, pB->pLeft) ) return 0; 1146d8bc7086Sdrh if( !sqliteExprCompare(pA->pRight, pB->pRight) ) return 0; 11472282792aSdrh if( pA->pList ){ 11482282792aSdrh if( pB->pList==0 ) return 0; 11492282792aSdrh if( pA->pList->nExpr!=pB->pList->nExpr ) return 0; 11502282792aSdrh for(i=0; i<pA->pList->nExpr; i++){ 1151d8bc7086Sdrh if( !sqliteExprCompare(pA->pList->a[i].pExpr, pB->pList->a[i].pExpr) ){ 11522282792aSdrh return 0; 11532282792aSdrh } 11542282792aSdrh } 11552282792aSdrh }else if( pB->pList ){ 11562282792aSdrh return 0; 11572282792aSdrh } 11582282792aSdrh if( pA->pSelect || pB->pSelect ) return 0; 11592282792aSdrh if( pA->token.z ){ 11602282792aSdrh if( pB->token.z==0 ) return 0; 11612282792aSdrh if( pB->token.n!=pA->token.n ) return 0; 11622282792aSdrh if( sqliteStrNICmp(pA->token.z, pB->token.z, pA->token.n)!=0 ) return 0; 11632282792aSdrh } 11642282792aSdrh return 1; 11652282792aSdrh } 11662282792aSdrh 11672282792aSdrh /* 11682282792aSdrh ** Add a new element to the pParse->aAgg[] array and return its index. 11692282792aSdrh */ 11702282792aSdrh static int appendAggInfo(Parse *pParse){ 11712282792aSdrh if( (pParse->nAgg & 0x7)==0 ){ 11722282792aSdrh int amt = pParse->nAgg + 8; 11736d4abfbeSdrh AggExpr *aAgg = sqliteRealloc(pParse->aAgg, amt*sizeof(pParse->aAgg[0])); 11746d4abfbeSdrh if( aAgg==0 ){ 11752282792aSdrh return -1; 11762282792aSdrh } 11776d4abfbeSdrh pParse->aAgg = aAgg; 11782282792aSdrh } 11792282792aSdrh memset(&pParse->aAgg[pParse->nAgg], 0, sizeof(pParse->aAgg[0])); 11802282792aSdrh return pParse->nAgg++; 11812282792aSdrh } 11822282792aSdrh 11832282792aSdrh /* 11842282792aSdrh ** Analyze the given expression looking for aggregate functions and 11852282792aSdrh ** for variables that need to be added to the pParse->aAgg[] array. 11862282792aSdrh ** Make additional entries to the pParse->aAgg[] array as necessary. 11872282792aSdrh ** 11882282792aSdrh ** This routine should only be called after the expression has been 11892282792aSdrh ** analyzed by sqliteExprResolveIds() and sqliteExprCheck(). 11902282792aSdrh ** 11912282792aSdrh ** If errors are seen, leave an error message in zErrMsg and return 11922282792aSdrh ** the number of errors. 11932282792aSdrh */ 11942282792aSdrh int sqliteExprAnalyzeAggregates(Parse *pParse, Expr *pExpr){ 11952282792aSdrh int i; 11962282792aSdrh AggExpr *aAgg; 11972282792aSdrh int nErr = 0; 11982282792aSdrh 11992282792aSdrh if( pExpr==0 ) return 0; 12002282792aSdrh switch( pExpr->op ){ 1201967e8b73Sdrh case TK_COLUMN: { 12022282792aSdrh aAgg = pParse->aAgg; 12032282792aSdrh for(i=0; i<pParse->nAgg; i++){ 12042282792aSdrh if( aAgg[i].isAgg ) continue; 12052282792aSdrh if( aAgg[i].pExpr->iTable==pExpr->iTable 1206967e8b73Sdrh && aAgg[i].pExpr->iColumn==pExpr->iColumn ){ 12072282792aSdrh break; 12082282792aSdrh } 12092282792aSdrh } 12102282792aSdrh if( i>=pParse->nAgg ){ 12112282792aSdrh i = appendAggInfo(pParse); 12122282792aSdrh if( i<0 ) return 1; 12132282792aSdrh pParse->aAgg[i].isAgg = 0; 12142282792aSdrh pParse->aAgg[i].pExpr = pExpr; 12152282792aSdrh } 1216aaf88729Sdrh pExpr->iAgg = i; 12172282792aSdrh break; 12182282792aSdrh } 12192282792aSdrh case TK_AGG_FUNCTION: { 12202282792aSdrh aAgg = pParse->aAgg; 12212282792aSdrh for(i=0; i<pParse->nAgg; i++){ 12222282792aSdrh if( !aAgg[i].isAgg ) continue; 1223d8bc7086Sdrh if( sqliteExprCompare(aAgg[i].pExpr, pExpr) ){ 12242282792aSdrh break; 12252282792aSdrh } 12262282792aSdrh } 12272282792aSdrh if( i>=pParse->nAgg ){ 12282282792aSdrh i = appendAggInfo(pParse); 12292282792aSdrh if( i<0 ) return 1; 12302282792aSdrh pParse->aAgg[i].isAgg = 1; 12312282792aSdrh pParse->aAgg[i].pExpr = pExpr; 12320bce8354Sdrh pParse->aAgg[i].pFunc = sqliteFindFunction(pParse->db, 1233f55f25f0Sdrh pExpr->token.z, pExpr->token.n, 1234f55f25f0Sdrh pExpr->pList ? pExpr->pList->nExpr : 0, 0); 12352282792aSdrh } 12362282792aSdrh pExpr->iAgg = i; 12372282792aSdrh break; 12382282792aSdrh } 12392282792aSdrh default: { 12402282792aSdrh if( pExpr->pLeft ){ 12412282792aSdrh nErr = sqliteExprAnalyzeAggregates(pParse, pExpr->pLeft); 12422282792aSdrh } 12432282792aSdrh if( nErr==0 && pExpr->pRight ){ 12442282792aSdrh nErr = sqliteExprAnalyzeAggregates(pParse, pExpr->pRight); 12452282792aSdrh } 12462282792aSdrh if( nErr==0 && pExpr->pList ){ 12472282792aSdrh int n = pExpr->pList->nExpr; 12482282792aSdrh int i; 12492282792aSdrh for(i=0; nErr==0 && i<n; i++){ 12502282792aSdrh nErr = sqliteExprAnalyzeAggregates(pParse, pExpr->pList->a[i].pExpr); 12512282792aSdrh } 12522282792aSdrh } 12532282792aSdrh break; 12542282792aSdrh } 12552282792aSdrh } 12562282792aSdrh return nErr; 12572282792aSdrh } 12588e0a2f90Sdrh 12598e0a2f90Sdrh /* 12608e0a2f90Sdrh ** Locate a user function given a name and a number of arguments. 12610bce8354Sdrh ** Return a pointer to the FuncDef structure that defines that 12628e0a2f90Sdrh ** function, or return NULL if the function does not exist. 12638e0a2f90Sdrh ** 12640bce8354Sdrh ** If the createFlag argument is true, then a new (blank) FuncDef 12658e0a2f90Sdrh ** structure is created and liked into the "db" structure if a 12668e0a2f90Sdrh ** no matching function previously existed. When createFlag is true 12678e0a2f90Sdrh ** and the nArg parameter is -1, then only a function that accepts 12688e0a2f90Sdrh ** any number of arguments will be returned. 12698e0a2f90Sdrh ** 12708e0a2f90Sdrh ** If createFlag is false and nArg is -1, then the first valid 12718e0a2f90Sdrh ** function found is returned. A function is valid if either xFunc 12728e0a2f90Sdrh ** or xStep is non-zero. 12738e0a2f90Sdrh */ 12740bce8354Sdrh FuncDef *sqliteFindFunction( 12758e0a2f90Sdrh sqlite *db, /* An open database */ 12768e0a2f90Sdrh const char *zName, /* Name of the function. Not null-terminated */ 12778e0a2f90Sdrh int nName, /* Number of characters in the name */ 12788e0a2f90Sdrh int nArg, /* Number of arguments. -1 means any number */ 12798e0a2f90Sdrh int createFlag /* Create new entry if true and does not otherwise exist */ 12808e0a2f90Sdrh ){ 12810bce8354Sdrh FuncDef *pFirst, *p, *pMaybe; 12820bce8354Sdrh pFirst = p = (FuncDef*)sqliteHashFind(&db->aFunc, zName, nName); 12831350b030Sdrh if( p && !createFlag && nArg<0 ){ 12848e0a2f90Sdrh while( p && p->xFunc==0 && p->xStep==0 ){ p = p->pNext; } 12858e0a2f90Sdrh return p; 12868e0a2f90Sdrh } 12878e0a2f90Sdrh pMaybe = 0; 12888e0a2f90Sdrh while( p && p->nArg!=nArg ){ 12898e0a2f90Sdrh if( p->nArg<0 && !createFlag && (p->xFunc || p->xStep) ) pMaybe = p; 12908e0a2f90Sdrh p = p->pNext; 12918e0a2f90Sdrh } 12928e0a2f90Sdrh if( p && !createFlag && p->xFunc==0 && p->xStep==0 ){ 12938e0a2f90Sdrh return 0; 12948e0a2f90Sdrh } 12958e0a2f90Sdrh if( p==0 && pMaybe ){ 12968e0a2f90Sdrh assert( createFlag==0 ); 12978e0a2f90Sdrh return pMaybe; 12988e0a2f90Sdrh } 129989425d5eSdrh if( p==0 && createFlag && (p = sqliteMalloc(sizeof(*p)))!=0 ){ 13008e0a2f90Sdrh p->nArg = nArg; 13018e0a2f90Sdrh p->pNext = pFirst; 13020bce8354Sdrh sqliteHashInsert(&db->aFunc, zName, nName, (void*)p); 13038e0a2f90Sdrh } 13048e0a2f90Sdrh return p; 13058e0a2f90Sdrh } 1306