xref: /sqlite-3.40.0/src/expr.c (revision 4e7f36a2)
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*4e7f36a2Sdanielk1977 ** $Id: expr.c,v 1.396 2008/10/02 16:42:07 danielk1977 Exp $
16cce7d176Sdrh */
17cce7d176Sdrh #include "sqliteInt.h"
1804738cb9Sdrh #include <ctype.h>
19a2e00042Sdrh 
20e014a838Sdanielk1977 /*
21e014a838Sdanielk1977 ** Return the 'affinity' of the expression pExpr if any.
22e014a838Sdanielk1977 **
23e014a838Sdanielk1977 ** If pExpr is a column, a reference to a column via an 'AS' alias,
24e014a838Sdanielk1977 ** or a sub-select with a column as the return value, then the
25e014a838Sdanielk1977 ** affinity of that column is returned. Otherwise, 0x00 is returned,
26e014a838Sdanielk1977 ** indicating no affinity for the expression.
27e014a838Sdanielk1977 **
28e014a838Sdanielk1977 ** i.e. the WHERE clause expresssions in the following statements all
29e014a838Sdanielk1977 ** have an affinity:
30e014a838Sdanielk1977 **
31e014a838Sdanielk1977 ** CREATE TABLE t1(a);
32e014a838Sdanielk1977 ** SELECT * FROM t1 WHERE a;
33e014a838Sdanielk1977 ** SELECT a AS b FROM t1 WHERE b;
34e014a838Sdanielk1977 ** SELECT * FROM t1 WHERE (select a from t1);
35e014a838Sdanielk1977 */
36bf3b721fSdanielk1977 char sqlite3ExprAffinity(Expr *pExpr){
37487e262fSdrh   int op = pExpr->op;
38487e262fSdrh   if( op==TK_SELECT ){
39bf3b721fSdanielk1977     return sqlite3ExprAffinity(pExpr->pSelect->pEList->a[0].pExpr);
40a37cdde0Sdanielk1977   }
41487e262fSdrh #ifndef SQLITE_OMIT_CAST
42487e262fSdrh   if( op==TK_CAST ){
438a51256cSdrh     return sqlite3AffinityType(&pExpr->token);
44487e262fSdrh   }
45487e262fSdrh #endif
467d10d5a6Sdrh   if( (op==TK_COLUMN || op==TK_REGISTER) && pExpr->pTab!=0 ){
477d10d5a6Sdrh     /* op==TK_REGISTER && pExpr->pTab!=0 happens when pExpr was originally
487d10d5a6Sdrh     ** a TK_COLUMN but was previously evaluated and cached in a register */
497d10d5a6Sdrh     int j = pExpr->iColumn;
507d10d5a6Sdrh     if( j<0 ) return SQLITE_AFF_INTEGER;
517d10d5a6Sdrh     assert( pExpr->pTab && j<pExpr->pTab->nCol );
527d10d5a6Sdrh     return pExpr->pTab->aCol[j].affinity;
537d10d5a6Sdrh   }
54a37cdde0Sdanielk1977   return pExpr->affinity;
55a37cdde0Sdanielk1977 }
56a37cdde0Sdanielk1977 
5753db1458Sdrh /*
588b4c40d8Sdrh ** Set the collating sequence for expression pExpr to be the collating
598b4c40d8Sdrh ** sequence named by pToken.   Return a pointer to the revised expression.
60a34001c9Sdrh ** The collating sequence is marked as "explicit" using the EP_ExpCollate
61a34001c9Sdrh ** flag.  An explicit collating sequence will override implicit
62a34001c9Sdrh ** collating sequences.
638b4c40d8Sdrh */
647d10d5a6Sdrh Expr *sqlite3ExprSetColl(Parse *pParse, Expr *pExpr, Token *pCollName){
6539002505Sdanielk1977   char *zColl = 0;            /* Dequoted name of collation sequence */
668b4c40d8Sdrh   CollSeq *pColl;
67633e6d57Sdrh   sqlite3 *db = pParse->db;
687d10d5a6Sdrh   zColl = sqlite3NameFromToken(db, pCollName);
6939002505Sdanielk1977   if( pExpr && zColl ){
7039002505Sdanielk1977     pColl = sqlite3LocateCollSeq(pParse, zColl, -1);
718b4c40d8Sdrh     if( pColl ){
728b4c40d8Sdrh       pExpr->pColl = pColl;
738b4c40d8Sdrh       pExpr->flags |= EP_ExpCollate;
748b4c40d8Sdrh     }
7539002505Sdanielk1977   }
76633e6d57Sdrh   sqlite3DbFree(db, zColl);
778b4c40d8Sdrh   return pExpr;
788b4c40d8Sdrh }
798b4c40d8Sdrh 
808b4c40d8Sdrh /*
810202b29eSdanielk1977 ** Return the default collation sequence for the expression pExpr. If
820202b29eSdanielk1977 ** there is no default collation type, return 0.
830202b29eSdanielk1977 */
847cedc8d4Sdanielk1977 CollSeq *sqlite3ExprCollSeq(Parse *pParse, Expr *pExpr){
857cedc8d4Sdanielk1977   CollSeq *pColl = 0;
867d10d5a6Sdrh   Expr *p = pExpr;
877d10d5a6Sdrh   while( p ){
887e09fe0bSdrh     int op;
897d10d5a6Sdrh     pColl = p->pColl;
907d10d5a6Sdrh     if( pColl ) break;
917d10d5a6Sdrh     op = p->op;
927d10d5a6Sdrh     if( (op==TK_COLUMN || op==TK_REGISTER) && p->pTab!=0 ){
937d10d5a6Sdrh       /* op==TK_REGISTER && p->pTab!=0 happens when pExpr was originally
947d10d5a6Sdrh       ** a TK_COLUMN but was previously evaluated and cached in a register */
957d10d5a6Sdrh       const char *zColl;
967d10d5a6Sdrh       int j = p->iColumn;
977d10d5a6Sdrh       if( j>=0 ){
987d10d5a6Sdrh         sqlite3 *db = pParse->db;
997d10d5a6Sdrh         zColl = p->pTab->aCol[j].zColl;
1007d10d5a6Sdrh         pColl = sqlite3FindCollSeq(db, ENC(db), zColl, -1, 0);
1017d10d5a6Sdrh         pExpr->pColl = pColl;
1020202b29eSdanielk1977       }
1037d10d5a6Sdrh       break;
1047d10d5a6Sdrh     }
1057d10d5a6Sdrh     if( op!=TK_CAST && op!=TK_UPLUS ){
1067d10d5a6Sdrh       break;
1077d10d5a6Sdrh     }
1087d10d5a6Sdrh     p = p->pLeft;
1090202b29eSdanielk1977   }
1107cedc8d4Sdanielk1977   if( sqlite3CheckCollSeq(pParse, pColl) ){
1117cedc8d4Sdanielk1977     pColl = 0;
1127cedc8d4Sdanielk1977   }
1137cedc8d4Sdanielk1977   return pColl;
1140202b29eSdanielk1977 }
1150202b29eSdanielk1977 
1160202b29eSdanielk1977 /*
117626a879aSdrh ** pExpr is an operand of a comparison operator.  aff2 is the
118626a879aSdrh ** type affinity of the other operand.  This routine returns the
11953db1458Sdrh ** type affinity that should be used for the comparison operator.
12053db1458Sdrh */
121e014a838Sdanielk1977 char sqlite3CompareAffinity(Expr *pExpr, char aff2){
122bf3b721fSdanielk1977   char aff1 = sqlite3ExprAffinity(pExpr);
123e014a838Sdanielk1977   if( aff1 && aff2 ){
1248df447f0Sdrh     /* Both sides of the comparison are columns. If one has numeric
1258df447f0Sdrh     ** affinity, use that. Otherwise use no affinity.
126e014a838Sdanielk1977     */
1278a51256cSdrh     if( sqlite3IsNumericAffinity(aff1) || sqlite3IsNumericAffinity(aff2) ){
128e014a838Sdanielk1977       return SQLITE_AFF_NUMERIC;
129e014a838Sdanielk1977     }else{
130e014a838Sdanielk1977       return SQLITE_AFF_NONE;
131e014a838Sdanielk1977     }
132e014a838Sdanielk1977   }else if( !aff1 && !aff2 ){
1335f6a87b3Sdrh     /* Neither side of the comparison is a column.  Compare the
1345f6a87b3Sdrh     ** results directly.
135e014a838Sdanielk1977     */
1365f6a87b3Sdrh     return SQLITE_AFF_NONE;
137e014a838Sdanielk1977   }else{
138e014a838Sdanielk1977     /* One side is a column, the other is not. Use the columns affinity. */
139fe05af87Sdrh     assert( aff1==0 || aff2==0 );
140e014a838Sdanielk1977     return (aff1 + aff2);
141e014a838Sdanielk1977   }
142e014a838Sdanielk1977 }
143e014a838Sdanielk1977 
14453db1458Sdrh /*
14553db1458Sdrh ** pExpr is a comparison operator.  Return the type affinity that should
14653db1458Sdrh ** be applied to both operands prior to doing the comparison.
14753db1458Sdrh */
148e014a838Sdanielk1977 static char comparisonAffinity(Expr *pExpr){
149e014a838Sdanielk1977   char aff;
150e014a838Sdanielk1977   assert( pExpr->op==TK_EQ || pExpr->op==TK_IN || pExpr->op==TK_LT ||
151e014a838Sdanielk1977           pExpr->op==TK_GT || pExpr->op==TK_GE || pExpr->op==TK_LE ||
152e014a838Sdanielk1977           pExpr->op==TK_NE );
153e014a838Sdanielk1977   assert( pExpr->pLeft );
154bf3b721fSdanielk1977   aff = sqlite3ExprAffinity(pExpr->pLeft);
155e014a838Sdanielk1977   if( pExpr->pRight ){
156e014a838Sdanielk1977     aff = sqlite3CompareAffinity(pExpr->pRight, aff);
157e014a838Sdanielk1977   }
158e014a838Sdanielk1977   else if( pExpr->pSelect ){
159e014a838Sdanielk1977     aff = sqlite3CompareAffinity(pExpr->pSelect->pEList->a[0].pExpr, aff);
160e014a838Sdanielk1977   }
161e014a838Sdanielk1977   else if( !aff ){
162de087bd5Sdrh     aff = SQLITE_AFF_NONE;
163e014a838Sdanielk1977   }
164e014a838Sdanielk1977   return aff;
165e014a838Sdanielk1977 }
166e014a838Sdanielk1977 
167e014a838Sdanielk1977 /*
168e014a838Sdanielk1977 ** pExpr is a comparison expression, eg. '=', '<', IN(...) etc.
169e014a838Sdanielk1977 ** idx_affinity is the affinity of an indexed column. Return true
170e014a838Sdanielk1977 ** if the index with affinity idx_affinity may be used to implement
171e014a838Sdanielk1977 ** the comparison in pExpr.
172e014a838Sdanielk1977 */
173e014a838Sdanielk1977 int sqlite3IndexAffinityOk(Expr *pExpr, char idx_affinity){
174e014a838Sdanielk1977   char aff = comparisonAffinity(pExpr);
1758a51256cSdrh   switch( aff ){
1768a51256cSdrh     case SQLITE_AFF_NONE:
1778a51256cSdrh       return 1;
1788a51256cSdrh     case SQLITE_AFF_TEXT:
1798a51256cSdrh       return idx_affinity==SQLITE_AFF_TEXT;
1808a51256cSdrh     default:
1818a51256cSdrh       return sqlite3IsNumericAffinity(idx_affinity);
1828a51256cSdrh   }
183e014a838Sdanielk1977 }
184e014a838Sdanielk1977 
185a37cdde0Sdanielk1977 /*
18635573356Sdrh ** Return the P5 value that should be used for a binary comparison
187a37cdde0Sdanielk1977 ** opcode (OP_Eq, OP_Ge etc.) used to compare pExpr1 and pExpr2.
188a37cdde0Sdanielk1977 */
18935573356Sdrh static u8 binaryCompareP5(Expr *pExpr1, Expr *pExpr2, int jumpIfNull){
19035573356Sdrh   u8 aff = (char)sqlite3ExprAffinity(pExpr2);
19135573356Sdrh   aff = sqlite3CompareAffinity(pExpr1, aff) | jumpIfNull;
19235573356Sdrh   return aff;
193a37cdde0Sdanielk1977 }
194a37cdde0Sdanielk1977 
195a2e00042Sdrh /*
1960202b29eSdanielk1977 ** Return a pointer to the collation sequence that should be used by
1970202b29eSdanielk1977 ** a binary comparison operator comparing pLeft and pRight.
1980202b29eSdanielk1977 **
1990202b29eSdanielk1977 ** If the left hand expression has a collating sequence type, then it is
2000202b29eSdanielk1977 ** used. Otherwise the collation sequence for the right hand expression
2010202b29eSdanielk1977 ** is used, or the default (BINARY) if neither expression has a collating
2020202b29eSdanielk1977 ** type.
203bcbb04e5Sdanielk1977 **
204bcbb04e5Sdanielk1977 ** Argument pRight (but not pLeft) may be a null pointer. In this case,
205bcbb04e5Sdanielk1977 ** it is not considered.
2060202b29eSdanielk1977 */
207bcbb04e5Sdanielk1977 CollSeq *sqlite3BinaryCompareCollSeq(
208bcbb04e5Sdanielk1977   Parse *pParse,
209bcbb04e5Sdanielk1977   Expr *pLeft,
210bcbb04e5Sdanielk1977   Expr *pRight
211bcbb04e5Sdanielk1977 ){
212ec41ddacSdrh   CollSeq *pColl;
213ec41ddacSdrh   assert( pLeft );
214ec41ddacSdrh   if( pLeft->flags & EP_ExpCollate ){
215ec41ddacSdrh     assert( pLeft->pColl );
216ec41ddacSdrh     pColl = pLeft->pColl;
217bcbb04e5Sdanielk1977   }else if( pRight && pRight->flags & EP_ExpCollate ){
218ec41ddacSdrh     assert( pRight->pColl );
219ec41ddacSdrh     pColl = pRight->pColl;
220ec41ddacSdrh   }else{
221ec41ddacSdrh     pColl = sqlite3ExprCollSeq(pParse, pLeft);
2220202b29eSdanielk1977     if( !pColl ){
2237cedc8d4Sdanielk1977       pColl = sqlite3ExprCollSeq(pParse, pRight);
2240202b29eSdanielk1977     }
225ec41ddacSdrh   }
2260202b29eSdanielk1977   return pColl;
2270202b29eSdanielk1977 }
2280202b29eSdanielk1977 
2290202b29eSdanielk1977 /*
230da250ea5Sdrh ** Generate the operands for a comparison operation.  Before
231da250ea5Sdrh ** generating the code for each operand, set the EP_AnyAff
232da250ea5Sdrh ** flag on the expression so that it will be able to used a
233da250ea5Sdrh ** cached column value that has previously undergone an
234da250ea5Sdrh ** affinity change.
235da250ea5Sdrh */
236da250ea5Sdrh static void codeCompareOperands(
237da250ea5Sdrh   Parse *pParse,    /* Parsing and code generating context */
238da250ea5Sdrh   Expr *pLeft,      /* The left operand */
239da250ea5Sdrh   int *pRegLeft,    /* Register where left operand is stored */
240da250ea5Sdrh   int *pFreeLeft,   /* Free this register when done */
241da250ea5Sdrh   Expr *pRight,     /* The right operand */
242da250ea5Sdrh   int *pRegRight,   /* Register where right operand is stored */
243da250ea5Sdrh   int *pFreeRight   /* Write temp register for right operand there */
244da250ea5Sdrh ){
245da250ea5Sdrh   while( pLeft->op==TK_UPLUS ) pLeft = pLeft->pLeft;
246da250ea5Sdrh   pLeft->flags |= EP_AnyAff;
247da250ea5Sdrh   *pRegLeft = sqlite3ExprCodeTemp(pParse, pLeft, pFreeLeft);
248da250ea5Sdrh   while( pRight->op==TK_UPLUS ) pRight = pRight->pLeft;
249da250ea5Sdrh   pRight->flags |= EP_AnyAff;
250da250ea5Sdrh   *pRegRight = sqlite3ExprCodeTemp(pParse, pRight, pFreeRight);
251da250ea5Sdrh }
252da250ea5Sdrh 
253da250ea5Sdrh /*
254be5c89acSdrh ** Generate code for a comparison operator.
255be5c89acSdrh */
256be5c89acSdrh static int codeCompare(
257be5c89acSdrh   Parse *pParse,    /* The parsing (and code generating) context */
258be5c89acSdrh   Expr *pLeft,      /* The left operand */
259be5c89acSdrh   Expr *pRight,     /* The right operand */
260be5c89acSdrh   int opcode,       /* The comparison opcode */
26135573356Sdrh   int in1, int in2, /* Register holding operands */
262be5c89acSdrh   int dest,         /* Jump here if true.  */
263be5c89acSdrh   int jumpIfNull    /* If true, jump if either operand is NULL */
264be5c89acSdrh ){
26535573356Sdrh   int p5;
26635573356Sdrh   int addr;
26735573356Sdrh   CollSeq *p4;
26835573356Sdrh 
26935573356Sdrh   p4 = sqlite3BinaryCompareCollSeq(pParse, pLeft, pRight);
27035573356Sdrh   p5 = binaryCompareP5(pLeft, pRight, jumpIfNull);
27135573356Sdrh   addr = sqlite3VdbeAddOp4(pParse->pVdbe, opcode, in2, dest, in1,
27235573356Sdrh                            (void*)p4, P4_COLLSEQ);
27335573356Sdrh   sqlite3VdbeChangeP5(pParse->pVdbe, p5);
274e49b146fSdrh   if( (p5 & SQLITE_AFF_MASK)!=SQLITE_AFF_NONE ){
275da250ea5Sdrh     sqlite3ExprCacheAffinityChange(pParse, in1, 1);
276da250ea5Sdrh     sqlite3ExprCacheAffinityChange(pParse, in2, 1);
2772f7794c1Sdrh   }
27835573356Sdrh   return addr;
279be5c89acSdrh }
280be5c89acSdrh 
2814b5255acSdanielk1977 #if SQLITE_MAX_EXPR_DEPTH>0
2824b5255acSdanielk1977 /*
2834b5255acSdanielk1977 ** Check that argument nHeight is less than or equal to the maximum
2844b5255acSdanielk1977 ** expression depth allowed. If it is not, leave an error message in
2854b5255acSdanielk1977 ** pParse.
2864b5255acSdanielk1977 */
2877d10d5a6Sdrh int sqlite3ExprCheckHeight(Parse *pParse, int nHeight){
2884b5255acSdanielk1977   int rc = SQLITE_OK;
2894b5255acSdanielk1977   int mxHeight = pParse->db->aLimit[SQLITE_LIMIT_EXPR_DEPTH];
2904b5255acSdanielk1977   if( nHeight>mxHeight ){
2914b5255acSdanielk1977     sqlite3ErrorMsg(pParse,
2924b5255acSdanielk1977        "Expression tree is too large (maximum depth %d)", mxHeight
2934b5255acSdanielk1977     );
2944b5255acSdanielk1977     rc = SQLITE_ERROR;
2954b5255acSdanielk1977   }
2964b5255acSdanielk1977   return rc;
2974b5255acSdanielk1977 }
2984b5255acSdanielk1977 
2994b5255acSdanielk1977 /* The following three functions, heightOfExpr(), heightOfExprList()
3004b5255acSdanielk1977 ** and heightOfSelect(), are used to determine the maximum height
3014b5255acSdanielk1977 ** of any expression tree referenced by the structure passed as the
3024b5255acSdanielk1977 ** first argument.
3034b5255acSdanielk1977 **
3044b5255acSdanielk1977 ** If this maximum height is greater than the current value pointed
3054b5255acSdanielk1977 ** to by pnHeight, the second parameter, then set *pnHeight to that
3064b5255acSdanielk1977 ** value.
3074b5255acSdanielk1977 */
3084b5255acSdanielk1977 static void heightOfExpr(Expr *p, int *pnHeight){
3094b5255acSdanielk1977   if( p ){
3104b5255acSdanielk1977     if( p->nHeight>*pnHeight ){
3114b5255acSdanielk1977       *pnHeight = p->nHeight;
3124b5255acSdanielk1977     }
3134b5255acSdanielk1977   }
3144b5255acSdanielk1977 }
3154b5255acSdanielk1977 static void heightOfExprList(ExprList *p, int *pnHeight){
3164b5255acSdanielk1977   if( p ){
3174b5255acSdanielk1977     int i;
3184b5255acSdanielk1977     for(i=0; i<p->nExpr; i++){
3194b5255acSdanielk1977       heightOfExpr(p->a[i].pExpr, pnHeight);
3204b5255acSdanielk1977     }
3214b5255acSdanielk1977   }
3224b5255acSdanielk1977 }
3234b5255acSdanielk1977 static void heightOfSelect(Select *p, int *pnHeight){
3244b5255acSdanielk1977   if( p ){
3254b5255acSdanielk1977     heightOfExpr(p->pWhere, pnHeight);
3264b5255acSdanielk1977     heightOfExpr(p->pHaving, pnHeight);
3274b5255acSdanielk1977     heightOfExpr(p->pLimit, pnHeight);
3284b5255acSdanielk1977     heightOfExpr(p->pOffset, pnHeight);
3294b5255acSdanielk1977     heightOfExprList(p->pEList, pnHeight);
3304b5255acSdanielk1977     heightOfExprList(p->pGroupBy, pnHeight);
3314b5255acSdanielk1977     heightOfExprList(p->pOrderBy, pnHeight);
3324b5255acSdanielk1977     heightOfSelect(p->pPrior, pnHeight);
3334b5255acSdanielk1977   }
3344b5255acSdanielk1977 }
3354b5255acSdanielk1977 
3364b5255acSdanielk1977 /*
3374b5255acSdanielk1977 ** Set the Expr.nHeight variable in the structure passed as an
3384b5255acSdanielk1977 ** argument. An expression with no children, Expr.pList or
3394b5255acSdanielk1977 ** Expr.pSelect member has a height of 1. Any other expression
3404b5255acSdanielk1977 ** has a height equal to the maximum height of any other
3414b5255acSdanielk1977 ** referenced Expr plus one.
3424b5255acSdanielk1977 */
3434b5255acSdanielk1977 static void exprSetHeight(Expr *p){
3444b5255acSdanielk1977   int nHeight = 0;
3454b5255acSdanielk1977   heightOfExpr(p->pLeft, &nHeight);
3464b5255acSdanielk1977   heightOfExpr(p->pRight, &nHeight);
3474b5255acSdanielk1977   heightOfExprList(p->pList, &nHeight);
3484b5255acSdanielk1977   heightOfSelect(p->pSelect, &nHeight);
3494b5255acSdanielk1977   p->nHeight = nHeight + 1;
3504b5255acSdanielk1977 }
3514b5255acSdanielk1977 
3524b5255acSdanielk1977 /*
3534b5255acSdanielk1977 ** Set the Expr.nHeight variable using the exprSetHeight() function. If
3544b5255acSdanielk1977 ** the height is greater than the maximum allowed expression depth,
3554b5255acSdanielk1977 ** leave an error in pParse.
3564b5255acSdanielk1977 */
3574b5255acSdanielk1977 void sqlite3ExprSetHeight(Parse *pParse, Expr *p){
3584b5255acSdanielk1977   exprSetHeight(p);
3597d10d5a6Sdrh   sqlite3ExprCheckHeight(pParse, p->nHeight);
3604b5255acSdanielk1977 }
3614b5255acSdanielk1977 
3624b5255acSdanielk1977 /*
3634b5255acSdanielk1977 ** Return the maximum height of any expression tree referenced
3644b5255acSdanielk1977 ** by the select statement passed as an argument.
3654b5255acSdanielk1977 */
3664b5255acSdanielk1977 int sqlite3SelectExprHeight(Select *p){
3674b5255acSdanielk1977   int nHeight = 0;
3684b5255acSdanielk1977   heightOfSelect(p, &nHeight);
3694b5255acSdanielk1977   return nHeight;
3704b5255acSdanielk1977 }
3714b5255acSdanielk1977 #else
3724b5255acSdanielk1977   #define exprSetHeight(y)
3734b5255acSdanielk1977 #endif /* SQLITE_MAX_EXPR_DEPTH>0 */
3744b5255acSdanielk1977 
375be5c89acSdrh /*
376a76b5dfcSdrh ** Construct a new expression node and return a pointer to it.  Memory
37717435752Sdrh ** for this node is obtained from sqlite3_malloc().  The calling function
378a76b5dfcSdrh ** is responsible for making sure the node eventually gets freed.
379a76b5dfcSdrh */
38017435752Sdrh Expr *sqlite3Expr(
381a1644fd8Sdanielk1977   sqlite3 *db,            /* Handle for sqlite3DbMallocZero() (may be null) */
38217435752Sdrh   int op,                 /* Expression opcode */
38317435752Sdrh   Expr *pLeft,            /* Left operand */
38417435752Sdrh   Expr *pRight,           /* Right operand */
38517435752Sdrh   const Token *pToken     /* Argument token */
38617435752Sdrh ){
387a76b5dfcSdrh   Expr *pNew;
38826e4a8b1Sdrh   pNew = sqlite3DbMallocZero(db, sizeof(Expr));
389a76b5dfcSdrh   if( pNew==0 ){
390d5d56523Sdanielk1977     /* When malloc fails, delete pLeft and pRight. Expressions passed to
391d5d56523Sdanielk1977     ** this function must always be allocated with sqlite3Expr() for this
392d5d56523Sdanielk1977     ** reason.
393d5d56523Sdanielk1977     */
394633e6d57Sdrh     sqlite3ExprDelete(db, pLeft);
395633e6d57Sdrh     sqlite3ExprDelete(db, pRight);
396a76b5dfcSdrh     return 0;
397a76b5dfcSdrh   }
398a76b5dfcSdrh   pNew->op = op;
399a76b5dfcSdrh   pNew->pLeft = pLeft;
400a76b5dfcSdrh   pNew->pRight = pRight;
401a58fdfb1Sdanielk1977   pNew->iAgg = -1;
402e49b146fSdrh   pNew->span.z = (u8*)"";
403a76b5dfcSdrh   if( pToken ){
4044b59ab5eSdrh     assert( pToken->dyn==0 );
405145716b3Sdrh     pNew->span = pNew->token = *pToken;
406a34001c9Sdrh   }else if( pLeft ){
407a34001c9Sdrh     if( pRight ){
408e49b146fSdrh       if( pRight->span.dyn==0 && pLeft->span.dyn==0 ){
4094adee20fSdanielk1977         sqlite3ExprSpan(pNew, &pLeft->span, &pRight->span);
410e49b146fSdrh       }
4115ffb3ac8Sdrh       if( pRight->flags & EP_ExpCollate ){
412a34001c9Sdrh         pNew->flags |= EP_ExpCollate;
413a34001c9Sdrh         pNew->pColl = pRight->pColl;
414a34001c9Sdrh       }
415a34001c9Sdrh     }
4165ffb3ac8Sdrh     if( pLeft->flags & EP_ExpCollate ){
417a34001c9Sdrh       pNew->flags |= EP_ExpCollate;
418a34001c9Sdrh       pNew->pColl = pLeft->pColl;
419a34001c9Sdrh     }
420a76b5dfcSdrh   }
421fc976065Sdanielk1977 
4224b5255acSdanielk1977   exprSetHeight(pNew);
423a76b5dfcSdrh   return pNew;
424a76b5dfcSdrh }
425a76b5dfcSdrh 
426a76b5dfcSdrh /*
42717435752Sdrh ** Works like sqlite3Expr() except that it takes an extra Parse*
42817435752Sdrh ** argument and notifies the associated connection object if malloc fails.
429206f3d96Sdrh */
43017435752Sdrh Expr *sqlite3PExpr(
43117435752Sdrh   Parse *pParse,          /* Parsing context */
43217435752Sdrh   int op,                 /* Expression opcode */
43317435752Sdrh   Expr *pLeft,            /* Left operand */
43417435752Sdrh   Expr *pRight,           /* Right operand */
43517435752Sdrh   const Token *pToken     /* Argument token */
43617435752Sdrh ){
4374b5255acSdanielk1977   Expr *p = sqlite3Expr(pParse->db, op, pLeft, pRight, pToken);
4384b5255acSdanielk1977   if( p ){
4397d10d5a6Sdrh     sqlite3ExprCheckHeight(pParse, p->nHeight);
4404b5255acSdanielk1977   }
4414b5255acSdanielk1977   return p;
442206f3d96Sdrh }
443206f3d96Sdrh 
444206f3d96Sdrh /*
4454e0cff60Sdrh ** When doing a nested parse, you can include terms in an expression
446b7654111Sdrh ** that look like this:   #1 #2 ...  These terms refer to registers
447b7654111Sdrh ** in the virtual machine.  #N is the N-th register.
4484e0cff60Sdrh **
4494e0cff60Sdrh ** This routine is called by the parser to deal with on of those terms.
4504e0cff60Sdrh ** It immediately generates code to store the value in a memory location.
4514e0cff60Sdrh ** The returns an expression that will code to extract the value from
4524e0cff60Sdrh ** that memory location as needed.
4534e0cff60Sdrh */
4544e0cff60Sdrh Expr *sqlite3RegisterExpr(Parse *pParse, Token *pToken){
4554e0cff60Sdrh   Vdbe *v = pParse->pVdbe;
4564e0cff60Sdrh   Expr *p;
4574e0cff60Sdrh   if( pParse->nested==0 ){
4584e0cff60Sdrh     sqlite3ErrorMsg(pParse, "near \"%T\": syntax error", pToken);
459a1644fd8Sdanielk1977     return sqlite3PExpr(pParse, TK_NULL, 0, 0, 0);
4604e0cff60Sdrh   }
461bb7ac00bSdrh   if( v==0 ) return 0;
462a1644fd8Sdanielk1977   p = sqlite3PExpr(pParse, TK_REGISTER, 0, 0, pToken);
46373c42a13Sdrh   if( p==0 ){
46473c42a13Sdrh     return 0;  /* Malloc failed */
46573c42a13Sdrh   }
466b7654111Sdrh   p->iTable = atoi((char*)&pToken->z[1]);
4674e0cff60Sdrh   return p;
4684e0cff60Sdrh }
4694e0cff60Sdrh 
4704e0cff60Sdrh /*
47191bb0eedSdrh ** Join two expressions using an AND operator.  If either expression is
47291bb0eedSdrh ** NULL, then just return the other expression.
47391bb0eedSdrh */
4741e536953Sdanielk1977 Expr *sqlite3ExprAnd(sqlite3 *db, Expr *pLeft, Expr *pRight){
47591bb0eedSdrh   if( pLeft==0 ){
47691bb0eedSdrh     return pRight;
47791bb0eedSdrh   }else if( pRight==0 ){
47891bb0eedSdrh     return pLeft;
47991bb0eedSdrh   }else{
480880c15beSdanielk1977     return sqlite3Expr(db, TK_AND, pLeft, pRight, 0);
48191bb0eedSdrh   }
48291bb0eedSdrh }
48391bb0eedSdrh 
48491bb0eedSdrh /*
4856977fea8Sdrh ** Set the Expr.span field of the given expression to span all
486e49b146fSdrh ** text between the two given tokens.  Both tokens must be pointing
487e49b146fSdrh ** at the same string.
488a76b5dfcSdrh */
4894adee20fSdanielk1977 void sqlite3ExprSpan(Expr *pExpr, Token *pLeft, Token *pRight){
4904efc4754Sdrh   assert( pRight!=0 );
4914efc4754Sdrh   assert( pLeft!=0 );
492e54a62adSdrh   if( pExpr ){
4936977fea8Sdrh     pExpr->span.z = pLeft->z;
49497903fefSdrh     pExpr->span.n = pRight->n + (pRight->z - pLeft->z);
495a76b5dfcSdrh   }
496a76b5dfcSdrh }
497a76b5dfcSdrh 
498a76b5dfcSdrh /*
499a76b5dfcSdrh ** Construct a new expression node for a function with multiple
500a76b5dfcSdrh ** arguments.
501a76b5dfcSdrh */
50217435752Sdrh Expr *sqlite3ExprFunction(Parse *pParse, ExprList *pList, Token *pToken){
503a76b5dfcSdrh   Expr *pNew;
504633e6d57Sdrh   sqlite3 *db = pParse->db;
5054b202ae2Sdanielk1977   assert( pToken );
506633e6d57Sdrh   pNew = sqlite3DbMallocZero(db, sizeof(Expr) );
507a76b5dfcSdrh   if( pNew==0 ){
508633e6d57Sdrh     sqlite3ExprListDelete(db, pList); /* Avoid leaking memory when malloc fails */
509a76b5dfcSdrh     return 0;
510a76b5dfcSdrh   }
511a76b5dfcSdrh   pNew->op = TK_FUNCTION;
512a76b5dfcSdrh   pNew->pList = pList;
5134b59ab5eSdrh   assert( pToken->dyn==0 );
514a76b5dfcSdrh   pNew->token = *pToken;
5156977fea8Sdrh   pNew->span = pNew->token;
516fc976065Sdanielk1977 
5174b5255acSdanielk1977   sqlite3ExprSetHeight(pParse, pNew);
518a76b5dfcSdrh   return pNew;
519a76b5dfcSdrh }
520a76b5dfcSdrh 
521a76b5dfcSdrh /*
522fa6bc000Sdrh ** Assign a variable number to an expression that encodes a wildcard
523fa6bc000Sdrh ** in the original SQL statement.
524fa6bc000Sdrh **
525fa6bc000Sdrh ** Wildcards consisting of a single "?" are assigned the next sequential
526fa6bc000Sdrh ** variable number.
527fa6bc000Sdrh **
528fa6bc000Sdrh ** Wildcards of the form "?nnn" are assigned the number "nnn".  We make
529fa6bc000Sdrh ** sure "nnn" is not too be to avoid a denial of service attack when
530fa6bc000Sdrh ** the SQL statement comes from an external source.
531fa6bc000Sdrh **
532fa6bc000Sdrh ** Wildcards of the form ":aaa" or "$aaa" are assigned the same number
533fa6bc000Sdrh ** as the previous instance of the same wildcard.  Or if this is the first
534fa6bc000Sdrh ** instance of the wildcard, the next sequenial variable number is
535fa6bc000Sdrh ** assigned.
536fa6bc000Sdrh */
537fa6bc000Sdrh void sqlite3ExprAssignVarNumber(Parse *pParse, Expr *pExpr){
538fa6bc000Sdrh   Token *pToken;
53917435752Sdrh   sqlite3 *db = pParse->db;
54017435752Sdrh 
541fa6bc000Sdrh   if( pExpr==0 ) return;
542fa6bc000Sdrh   pToken = &pExpr->token;
543fa6bc000Sdrh   assert( pToken->n>=1 );
544fa6bc000Sdrh   assert( pToken->z!=0 );
545fa6bc000Sdrh   assert( pToken->z[0]!=0 );
546fa6bc000Sdrh   if( pToken->n==1 ){
547fa6bc000Sdrh     /* Wildcard of the form "?".  Assign the next variable number */
548fa6bc000Sdrh     pExpr->iTable = ++pParse->nVar;
549fa6bc000Sdrh   }else if( pToken->z[0]=='?' ){
550fa6bc000Sdrh     /* Wildcard of the form "?nnn".  Convert "nnn" to an integer and
551fa6bc000Sdrh     ** use it as the variable number */
552fa6bc000Sdrh     int i;
5532646da7eSdrh     pExpr->iTable = i = atoi((char*)&pToken->z[1]);
554c5499befSdrh     testcase( i==0 );
555c5499befSdrh     testcase( i==1 );
556c5499befSdrh     testcase( i==db->aLimit[SQLITE_LIMIT_VARIABLE_NUMBER]-1 );
557c5499befSdrh     testcase( i==db->aLimit[SQLITE_LIMIT_VARIABLE_NUMBER] );
558bb4957f8Sdrh     if( i<1 || i>db->aLimit[SQLITE_LIMIT_VARIABLE_NUMBER] ){
559fa6bc000Sdrh       sqlite3ErrorMsg(pParse, "variable number must be between ?1 and ?%d",
560bb4957f8Sdrh           db->aLimit[SQLITE_LIMIT_VARIABLE_NUMBER]);
561fa6bc000Sdrh     }
562fa6bc000Sdrh     if( i>pParse->nVar ){
563fa6bc000Sdrh       pParse->nVar = i;
564fa6bc000Sdrh     }
565fa6bc000Sdrh   }else{
566fa6bc000Sdrh     /* Wildcards of the form ":aaa" or "$aaa".  Reuse the same variable
567fa6bc000Sdrh     ** number as the prior appearance of the same name, or if the name
568fa6bc000Sdrh     ** has never appeared before, reuse the same variable number
569fa6bc000Sdrh     */
570fa6bc000Sdrh     int i, n;
571fa6bc000Sdrh     n = pToken->n;
572fa6bc000Sdrh     for(i=0; i<pParse->nVarExpr; i++){
573fa6bc000Sdrh       Expr *pE;
574fa6bc000Sdrh       if( (pE = pParse->apVarExpr[i])!=0
575fa6bc000Sdrh           && pE->token.n==n
576fa6bc000Sdrh           && memcmp(pE->token.z, pToken->z, n)==0 ){
577fa6bc000Sdrh         pExpr->iTable = pE->iTable;
578fa6bc000Sdrh         break;
579fa6bc000Sdrh       }
580fa6bc000Sdrh     }
581fa6bc000Sdrh     if( i>=pParse->nVarExpr ){
582fa6bc000Sdrh       pExpr->iTable = ++pParse->nVar;
583fa6bc000Sdrh       if( pParse->nVarExpr>=pParse->nVarExprAlloc-1 ){
584fa6bc000Sdrh         pParse->nVarExprAlloc += pParse->nVarExprAlloc + 10;
58517435752Sdrh         pParse->apVarExpr =
58617435752Sdrh             sqlite3DbReallocOrFree(
58717435752Sdrh               db,
58817435752Sdrh               pParse->apVarExpr,
58917435752Sdrh               pParse->nVarExprAlloc*sizeof(pParse->apVarExpr[0])
59017435752Sdrh             );
591fa6bc000Sdrh       }
59217435752Sdrh       if( !db->mallocFailed ){
593fa6bc000Sdrh         assert( pParse->apVarExpr!=0 );
594fa6bc000Sdrh         pParse->apVarExpr[pParse->nVarExpr++] = pExpr;
595fa6bc000Sdrh       }
596fa6bc000Sdrh     }
597fa6bc000Sdrh   }
598bb4957f8Sdrh   if( !pParse->nErr && pParse->nVar>db->aLimit[SQLITE_LIMIT_VARIABLE_NUMBER] ){
599832b2664Sdanielk1977     sqlite3ErrorMsg(pParse, "too many SQL variables");
600832b2664Sdanielk1977   }
601fa6bc000Sdrh }
602fa6bc000Sdrh 
603fa6bc000Sdrh /*
604a2e00042Sdrh ** Recursively delete an expression tree.
605a2e00042Sdrh */
606633e6d57Sdrh void sqlite3ExprDelete(sqlite3 *db, Expr *p){
607a2e00042Sdrh   if( p==0 ) return;
608633e6d57Sdrh   if( p->span.dyn ) sqlite3DbFree(db, (char*)p->span.z);
609633e6d57Sdrh   if( p->token.dyn ) sqlite3DbFree(db, (char*)p->token.z);
610633e6d57Sdrh   sqlite3ExprDelete(db, p->pLeft);
611633e6d57Sdrh   sqlite3ExprDelete(db, p->pRight);
612633e6d57Sdrh   sqlite3ExprListDelete(db, p->pList);
613633e6d57Sdrh   sqlite3SelectDelete(db, p->pSelect);
614633e6d57Sdrh   sqlite3DbFree(db, p);
615a2e00042Sdrh }
616a2e00042Sdrh 
617d2687b77Sdrh /*
618d2687b77Sdrh ** The Expr.token field might be a string literal that is quoted.
619d2687b77Sdrh ** If so, remove the quotation marks.
620d2687b77Sdrh */
62117435752Sdrh void sqlite3DequoteExpr(sqlite3 *db, Expr *p){
622d2687b77Sdrh   if( ExprHasAnyProperty(p, EP_Dequoted) ){
623d2687b77Sdrh     return;
624d2687b77Sdrh   }
625d2687b77Sdrh   ExprSetProperty(p, EP_Dequoted);
626d2687b77Sdrh   if( p->token.dyn==0 ){
62717435752Sdrh     sqlite3TokenCopy(db, &p->token, &p->token);
628d2687b77Sdrh   }
629d2687b77Sdrh   sqlite3Dequote((char*)p->token.z);
630d2687b77Sdrh }
631d2687b77Sdrh 
632a76b5dfcSdrh /*
633ff78bd2fSdrh ** The following group of routines make deep copies of expressions,
634ff78bd2fSdrh ** expression lists, ID lists, and select statements.  The copies can
635ff78bd2fSdrh ** be deleted (by being passed to their respective ...Delete() routines)
636ff78bd2fSdrh ** without effecting the originals.
637ff78bd2fSdrh **
6384adee20fSdanielk1977 ** The expression list, ID, and source lists return by sqlite3ExprListDup(),
6394adee20fSdanielk1977 ** sqlite3IdListDup(), and sqlite3SrcListDup() can not be further expanded
640ad3cab52Sdrh ** by subsequent calls to sqlite*ListAppend() routines.
641ff78bd2fSdrh **
642ad3cab52Sdrh ** Any tables that the SrcList might point to are not duplicated.
643ff78bd2fSdrh */
6441e536953Sdanielk1977 Expr *sqlite3ExprDup(sqlite3 *db, Expr *p){
645ff78bd2fSdrh   Expr *pNew;
646ff78bd2fSdrh   if( p==0 ) return 0;
64717435752Sdrh   pNew = sqlite3DbMallocRaw(db, sizeof(*p) );
648ff78bd2fSdrh   if( pNew==0 ) return 0;
6493b167c75Sdrh   memcpy(pNew, p, sizeof(*pNew));
6506977fea8Sdrh   if( p->token.z!=0 ){
65117435752Sdrh     pNew->token.z = (u8*)sqlite3DbStrNDup(db, (char*)p->token.z, p->token.n);
6524b59ab5eSdrh     pNew->token.dyn = 1;
6534b59ab5eSdrh   }else{
6544efc4754Sdrh     assert( pNew->token.z==0 );
6554b59ab5eSdrh   }
6566977fea8Sdrh   pNew->span.z = 0;
65717435752Sdrh   pNew->pLeft = sqlite3ExprDup(db, p->pLeft);
65817435752Sdrh   pNew->pRight = sqlite3ExprDup(db, p->pRight);
65917435752Sdrh   pNew->pList = sqlite3ExprListDup(db, p->pList);
66017435752Sdrh   pNew->pSelect = sqlite3SelectDup(db, p->pSelect);
661ff78bd2fSdrh   return pNew;
662ff78bd2fSdrh }
66317435752Sdrh void sqlite3TokenCopy(sqlite3 *db, Token *pTo, Token *pFrom){
664633e6d57Sdrh   if( pTo->dyn ) sqlite3DbFree(db, (char*)pTo->z);
6654b59ab5eSdrh   if( pFrom->z ){
6664b59ab5eSdrh     pTo->n = pFrom->n;
66717435752Sdrh     pTo->z = (u8*)sqlite3DbStrNDup(db, (char*)pFrom->z, pFrom->n);
6684b59ab5eSdrh     pTo->dyn = 1;
6694b59ab5eSdrh   }else{
6704b59ab5eSdrh     pTo->z = 0;
6714b59ab5eSdrh   }
6724b59ab5eSdrh }
67317435752Sdrh ExprList *sqlite3ExprListDup(sqlite3 *db, ExprList *p){
674ff78bd2fSdrh   ExprList *pNew;
675145716b3Sdrh   struct ExprList_item *pItem, *pOldItem;
676ff78bd2fSdrh   int i;
677ff78bd2fSdrh   if( p==0 ) return 0;
67817435752Sdrh   pNew = sqlite3DbMallocRaw(db, sizeof(*pNew) );
679ff78bd2fSdrh   if( pNew==0 ) return 0;
68031dad9daSdanielk1977   pNew->iECursor = 0;
6814305d103Sdrh   pNew->nExpr = pNew->nAlloc = p->nExpr;
68217435752Sdrh   pNew->a = pItem = sqlite3DbMallocRaw(db,  p->nExpr*sizeof(p->a[0]) );
683e0048400Sdanielk1977   if( pItem==0 ){
684633e6d57Sdrh     sqlite3DbFree(db, pNew);
685e0048400Sdanielk1977     return 0;
686e0048400Sdanielk1977   }
687145716b3Sdrh   pOldItem = p->a;
688145716b3Sdrh   for(i=0; i<p->nExpr; i++, pItem++, pOldItem++){
6894b59ab5eSdrh     Expr *pNewExpr, *pOldExpr;
69017435752Sdrh     pItem->pExpr = pNewExpr = sqlite3ExprDup(db, pOldExpr = pOldItem->pExpr);
6916977fea8Sdrh     if( pOldExpr->span.z!=0 && pNewExpr ){
6926977fea8Sdrh       /* Always make a copy of the span for top-level expressions in the
6934b59ab5eSdrh       ** expression list.  The logic in SELECT processing that determines
6944b59ab5eSdrh       ** the names of columns in the result set needs this information */
69517435752Sdrh       sqlite3TokenCopy(db, &pNewExpr->span, &pOldExpr->span);
6964b59ab5eSdrh     }
6971f3e905cSdrh     assert( pNewExpr==0 || pNewExpr->span.z!=0
6986f7adc8aSdrh             || pOldExpr->span.z==0
69917435752Sdrh             || db->mallocFailed );
70017435752Sdrh     pItem->zName = sqlite3DbStrDup(db, pOldItem->zName);
701145716b3Sdrh     pItem->sortOrder = pOldItem->sortOrder;
7023e7bc9caSdrh     pItem->done = 0;
7037d10d5a6Sdrh     pItem->iCol = pOldItem->iCol;
7048b213899Sdrh     pItem->iAlias = pOldItem->iAlias;
705ff78bd2fSdrh   }
706ff78bd2fSdrh   return pNew;
707ff78bd2fSdrh }
70893758c8dSdanielk1977 
70993758c8dSdanielk1977 /*
71093758c8dSdanielk1977 ** If cursors, triggers, views and subqueries are all omitted from
71193758c8dSdanielk1977 ** the build, then none of the following routines, except for
71293758c8dSdanielk1977 ** sqlite3SelectDup(), can be called. sqlite3SelectDup() is sometimes
71393758c8dSdanielk1977 ** called with a NULL argument.
71493758c8dSdanielk1977 */
7156a67fe8eSdanielk1977 #if !defined(SQLITE_OMIT_VIEW) || !defined(SQLITE_OMIT_TRIGGER) \
7166a67fe8eSdanielk1977  || !defined(SQLITE_OMIT_SUBQUERY)
71717435752Sdrh SrcList *sqlite3SrcListDup(sqlite3 *db, SrcList *p){
718ad3cab52Sdrh   SrcList *pNew;
719ad3cab52Sdrh   int i;
720113088ecSdrh   int nByte;
721ad3cab52Sdrh   if( p==0 ) return 0;
722113088ecSdrh   nByte = sizeof(*p) + (p->nSrc>0 ? sizeof(p->a[0]) * (p->nSrc-1) : 0);
72317435752Sdrh   pNew = sqlite3DbMallocRaw(db, nByte );
724ad3cab52Sdrh   if( pNew==0 ) return 0;
7254305d103Sdrh   pNew->nSrc = pNew->nAlloc = p->nSrc;
726ad3cab52Sdrh   for(i=0; i<p->nSrc; i++){
7274efc4754Sdrh     struct SrcList_item *pNewItem = &pNew->a[i];
7284efc4754Sdrh     struct SrcList_item *pOldItem = &p->a[i];
729ed8a3bb1Sdrh     Table *pTab;
73017435752Sdrh     pNewItem->zDatabase = sqlite3DbStrDup(db, pOldItem->zDatabase);
73117435752Sdrh     pNewItem->zName = sqlite3DbStrDup(db, pOldItem->zName);
73217435752Sdrh     pNewItem->zAlias = sqlite3DbStrDup(db, pOldItem->zAlias);
7334efc4754Sdrh     pNewItem->jointype = pOldItem->jointype;
7344efc4754Sdrh     pNewItem->iCursor = pOldItem->iCursor;
7351787ccabSdanielk1977     pNewItem->isPopulated = pOldItem->isPopulated;
736ed8a3bb1Sdrh     pTab = pNewItem->pTab = pOldItem->pTab;
737ed8a3bb1Sdrh     if( pTab ){
738ed8a3bb1Sdrh       pTab->nRef++;
739a1cb183dSdanielk1977     }
74017435752Sdrh     pNewItem->pSelect = sqlite3SelectDup(db, pOldItem->pSelect);
74117435752Sdrh     pNewItem->pOn = sqlite3ExprDup(db, pOldItem->pOn);
74217435752Sdrh     pNewItem->pUsing = sqlite3IdListDup(db, pOldItem->pUsing);
7436c18b6e0Sdanielk1977     pNewItem->colUsed = pOldItem->colUsed;
744ad3cab52Sdrh   }
745ad3cab52Sdrh   return pNew;
746ad3cab52Sdrh }
74717435752Sdrh IdList *sqlite3IdListDup(sqlite3 *db, IdList *p){
748ff78bd2fSdrh   IdList *pNew;
749ff78bd2fSdrh   int i;
750ff78bd2fSdrh   if( p==0 ) return 0;
75117435752Sdrh   pNew = sqlite3DbMallocRaw(db, sizeof(*pNew) );
752ff78bd2fSdrh   if( pNew==0 ) return 0;
7534305d103Sdrh   pNew->nId = pNew->nAlloc = p->nId;
75417435752Sdrh   pNew->a = sqlite3DbMallocRaw(db, p->nId*sizeof(p->a[0]) );
755d5d56523Sdanielk1977   if( pNew->a==0 ){
756633e6d57Sdrh     sqlite3DbFree(db, pNew);
757d5d56523Sdanielk1977     return 0;
758d5d56523Sdanielk1977   }
759ff78bd2fSdrh   for(i=0; i<p->nId; i++){
7604efc4754Sdrh     struct IdList_item *pNewItem = &pNew->a[i];
7614efc4754Sdrh     struct IdList_item *pOldItem = &p->a[i];
76217435752Sdrh     pNewItem->zName = sqlite3DbStrDup(db, pOldItem->zName);
7634efc4754Sdrh     pNewItem->idx = pOldItem->idx;
764ff78bd2fSdrh   }
765ff78bd2fSdrh   return pNew;
766ff78bd2fSdrh }
76717435752Sdrh Select *sqlite3SelectDup(sqlite3 *db, Select *p){
768ff78bd2fSdrh   Select *pNew;
769ff78bd2fSdrh   if( p==0 ) return 0;
77017435752Sdrh   pNew = sqlite3DbMallocRaw(db, sizeof(*p) );
771ff78bd2fSdrh   if( pNew==0 ) return 0;
77217435752Sdrh   pNew->pEList = sqlite3ExprListDup(db, p->pEList);
77317435752Sdrh   pNew->pSrc = sqlite3SrcListDup(db, p->pSrc);
77417435752Sdrh   pNew->pWhere = sqlite3ExprDup(db, p->pWhere);
77517435752Sdrh   pNew->pGroupBy = sqlite3ExprListDup(db, p->pGroupBy);
77617435752Sdrh   pNew->pHaving = sqlite3ExprDup(db, p->pHaving);
77717435752Sdrh   pNew->pOrderBy = sqlite3ExprListDup(db, p->pOrderBy);
778ff78bd2fSdrh   pNew->op = p->op;
77917435752Sdrh   pNew->pPrior = sqlite3SelectDup(db, p->pPrior);
78017435752Sdrh   pNew->pLimit = sqlite3ExprDup(db, p->pLimit);
78117435752Sdrh   pNew->pOffset = sqlite3ExprDup(db, p->pOffset);
78292b01d53Sdrh   pNew->iLimit = 0;
78392b01d53Sdrh   pNew->iOffset = 0;
7847d10d5a6Sdrh   pNew->selFlags = p->selFlags & ~SF_UsesEphemeral;
7850342b1f5Sdrh   pNew->pRightmost = 0;
786b9bb7c18Sdrh   pNew->addrOpenEphm[0] = -1;
787b9bb7c18Sdrh   pNew->addrOpenEphm[1] = -1;
788b9bb7c18Sdrh   pNew->addrOpenEphm[2] = -1;
789ff78bd2fSdrh   return pNew;
790ff78bd2fSdrh }
79193758c8dSdanielk1977 #else
79217435752Sdrh Select *sqlite3SelectDup(sqlite3 *db, Select *p){
79393758c8dSdanielk1977   assert( p==0 );
79493758c8dSdanielk1977   return 0;
79593758c8dSdanielk1977 }
79693758c8dSdanielk1977 #endif
797ff78bd2fSdrh 
798ff78bd2fSdrh 
799ff78bd2fSdrh /*
800a76b5dfcSdrh ** Add a new element to the end of an expression list.  If pList is
801a76b5dfcSdrh ** initially NULL, then create a new expression list.
802a76b5dfcSdrh */
80317435752Sdrh ExprList *sqlite3ExprListAppend(
80417435752Sdrh   Parse *pParse,          /* Parsing context */
80517435752Sdrh   ExprList *pList,        /* List to which to append. Might be NULL */
80617435752Sdrh   Expr *pExpr,            /* Expression to be appended */
80717435752Sdrh   Token *pName            /* AS keyword for the expression */
80817435752Sdrh ){
80917435752Sdrh   sqlite3 *db = pParse->db;
810a76b5dfcSdrh   if( pList==0 ){
81117435752Sdrh     pList = sqlite3DbMallocZero(db, sizeof(ExprList) );
812a76b5dfcSdrh     if( pList==0 ){
813d5d56523Sdanielk1977       goto no_mem;
814a76b5dfcSdrh     }
8154efc4754Sdrh     assert( pList->nAlloc==0 );
816a76b5dfcSdrh   }
8174305d103Sdrh   if( pList->nAlloc<=pList->nExpr ){
818d5d56523Sdanielk1977     struct ExprList_item *a;
819d5d56523Sdanielk1977     int n = pList->nAlloc*2 + 4;
82026783a58Sdanielk1977     a = sqlite3DbRealloc(db, pList->a, n*sizeof(pList->a[0]));
821d5d56523Sdanielk1977     if( a==0 ){
822d5d56523Sdanielk1977       goto no_mem;
823a76b5dfcSdrh     }
824d5d56523Sdanielk1977     pList->a = a;
825d5d56523Sdanielk1977     pList->nAlloc = n;
826a76b5dfcSdrh   }
8274efc4754Sdrh   assert( pList->a!=0 );
8284efc4754Sdrh   if( pExpr || pName ){
8294efc4754Sdrh     struct ExprList_item *pItem = &pList->a[pList->nExpr++];
8304efc4754Sdrh     memset(pItem, 0, sizeof(*pItem));
83117435752Sdrh     pItem->zName = sqlite3NameFromToken(db, pName);
832e94ddc9eSdanielk1977     pItem->pExpr = pExpr;
8338b213899Sdrh     pItem->iAlias = 0;
834a76b5dfcSdrh   }
835a76b5dfcSdrh   return pList;
836d5d56523Sdanielk1977 
837d5d56523Sdanielk1977 no_mem:
838d5d56523Sdanielk1977   /* Avoid leaking memory if malloc has failed. */
839633e6d57Sdrh   sqlite3ExprDelete(db, pExpr);
840633e6d57Sdrh   sqlite3ExprListDelete(db, pList);
841d5d56523Sdanielk1977   return 0;
842a76b5dfcSdrh }
843a76b5dfcSdrh 
844a76b5dfcSdrh /*
8457a15a4beSdanielk1977 ** If the expression list pEList contains more than iLimit elements,
8467a15a4beSdanielk1977 ** leave an error message in pParse.
8477a15a4beSdanielk1977 */
8487a15a4beSdanielk1977 void sqlite3ExprListCheckLength(
8497a15a4beSdanielk1977   Parse *pParse,
8507a15a4beSdanielk1977   ExprList *pEList,
8517a15a4beSdanielk1977   const char *zObject
8527a15a4beSdanielk1977 ){
853b1a6c3c1Sdrh   int mx = pParse->db->aLimit[SQLITE_LIMIT_COLUMN];
854c5499befSdrh   testcase( pEList && pEList->nExpr==mx );
855c5499befSdrh   testcase( pEList && pEList->nExpr==mx+1 );
856b1a6c3c1Sdrh   if( pEList && pEList->nExpr>mx ){
8577a15a4beSdanielk1977     sqlite3ErrorMsg(pParse, "too many columns in %s", zObject);
8587a15a4beSdanielk1977   }
8597a15a4beSdanielk1977 }
8607a15a4beSdanielk1977 
8617a15a4beSdanielk1977 /*
862a76b5dfcSdrh ** Delete an entire expression list.
863a76b5dfcSdrh */
864633e6d57Sdrh void sqlite3ExprListDelete(sqlite3 *db, ExprList *pList){
865a76b5dfcSdrh   int i;
866be5c89acSdrh   struct ExprList_item *pItem;
867a76b5dfcSdrh   if( pList==0 ) return;
8681bdd9b57Sdrh   assert( pList->a!=0 || (pList->nExpr==0 && pList->nAlloc==0) );
8691bdd9b57Sdrh   assert( pList->nExpr<=pList->nAlloc );
870be5c89acSdrh   for(pItem=pList->a, i=0; i<pList->nExpr; i++, pItem++){
871633e6d57Sdrh     sqlite3ExprDelete(db, pItem->pExpr);
872633e6d57Sdrh     sqlite3DbFree(db, pItem->zName);
873a76b5dfcSdrh   }
874633e6d57Sdrh   sqlite3DbFree(db, pList->a);
875633e6d57Sdrh   sqlite3DbFree(db, pList);
876a76b5dfcSdrh }
877a76b5dfcSdrh 
878a76b5dfcSdrh /*
8797d10d5a6Sdrh ** These routines are Walker callbacks.  Walker.u.pi is a pointer
8807d10d5a6Sdrh ** to an integer.  These routines are checking an expression to see
8817d10d5a6Sdrh ** if it is a constant.  Set *Walker.u.pi to 0 if the expression is
8827d10d5a6Sdrh ** not constant.
88373b211abSdrh **
8847d10d5a6Sdrh ** These callback routines are used to implement the following:
885626a879aSdrh **
8867d10d5a6Sdrh **     sqlite3ExprIsConstant()
8877d10d5a6Sdrh **     sqlite3ExprIsConstantNotJoin()
8887d10d5a6Sdrh **     sqlite3ExprIsConstantOrFunction()
88987abf5c0Sdrh **
890626a879aSdrh */
8917d10d5a6Sdrh static int exprNodeIsConstant(Walker *pWalker, Expr *pExpr){
892626a879aSdrh 
8937d10d5a6Sdrh   /* If pWalker->u.i is 3 then any term of the expression that comes from
8940a168377Sdrh   ** the ON or USING clauses of a join disqualifies the expression
8950a168377Sdrh   ** from being considered constant. */
8967d10d5a6Sdrh   if( pWalker->u.i==3 && ExprHasAnyProperty(pExpr, EP_FromJoin) ){
8977d10d5a6Sdrh     pWalker->u.i = 0;
8987d10d5a6Sdrh     return WRC_Abort;
8990a168377Sdrh   }
9000a168377Sdrh 
901626a879aSdrh   switch( pExpr->op ){
902eb55bd2fSdrh     /* Consider functions to be constant if all their arguments are constant
9037d10d5a6Sdrh     ** and pWalker->u.i==2 */
904eb55bd2fSdrh     case TK_FUNCTION:
9057d10d5a6Sdrh       if( pWalker->u.i==2 ) return 0;
906eb55bd2fSdrh       /* Fall through */
907626a879aSdrh     case TK_ID:
908626a879aSdrh     case TK_COLUMN:
909626a879aSdrh     case TK_DOT:
910626a879aSdrh     case TK_AGG_FUNCTION:
91113449892Sdrh     case TK_AGG_COLUMN:
912fe2093d7Sdrh #ifndef SQLITE_OMIT_SUBQUERY
913fe2093d7Sdrh     case TK_SELECT:
914fe2093d7Sdrh     case TK_EXISTS:
915c5499befSdrh       testcase( pExpr->op==TK_SELECT );
916c5499befSdrh       testcase( pExpr->op==TK_EXISTS );
917fe2093d7Sdrh #endif
918c5499befSdrh       testcase( pExpr->op==TK_ID );
919c5499befSdrh       testcase( pExpr->op==TK_COLUMN );
920c5499befSdrh       testcase( pExpr->op==TK_DOT );
921c5499befSdrh       testcase( pExpr->op==TK_AGG_FUNCTION );
922c5499befSdrh       testcase( pExpr->op==TK_AGG_COLUMN );
9237d10d5a6Sdrh       pWalker->u.i = 0;
9247d10d5a6Sdrh       return WRC_Abort;
925626a879aSdrh     default:
9267d10d5a6Sdrh       return WRC_Continue;
927626a879aSdrh   }
928626a879aSdrh }
9297d10d5a6Sdrh static int selectNodeIsConstant(Walker *pWalker, Select *pSelect){
9307d10d5a6Sdrh   pWalker->u.i = 0;
9317d10d5a6Sdrh   return WRC_Abort;
9327d10d5a6Sdrh }
9337d10d5a6Sdrh static int exprIsConst(Expr *p, int initFlag){
9347d10d5a6Sdrh   Walker w;
9357d10d5a6Sdrh   w.u.i = initFlag;
9367d10d5a6Sdrh   w.xExprCallback = exprNodeIsConstant;
9377d10d5a6Sdrh   w.xSelectCallback = selectNodeIsConstant;
9387d10d5a6Sdrh   sqlite3WalkExpr(&w, p);
9397d10d5a6Sdrh   return w.u.i;
9407d10d5a6Sdrh }
941626a879aSdrh 
942626a879aSdrh /*
943fef5208cSdrh ** Walk an expression tree.  Return 1 if the expression is constant
944eb55bd2fSdrh ** and 0 if it involves variables or function calls.
9452398937bSdrh **
9462398937bSdrh ** For the purposes of this function, a double-quoted string (ex: "abc")
9472398937bSdrh ** is considered a variable but a single-quoted string (ex: 'abc') is
9482398937bSdrh ** a constant.
949fef5208cSdrh */
9504adee20fSdanielk1977 int sqlite3ExprIsConstant(Expr *p){
9517d10d5a6Sdrh   return exprIsConst(p, 1);
952fef5208cSdrh }
953fef5208cSdrh 
954fef5208cSdrh /*
955eb55bd2fSdrh ** Walk an expression tree.  Return 1 if the expression is constant
9560a168377Sdrh ** that does no originate from the ON or USING clauses of a join.
9570a168377Sdrh ** Return 0 if it involves variables or function calls or terms from
9580a168377Sdrh ** an ON or USING clause.
9590a168377Sdrh */
9600a168377Sdrh int sqlite3ExprIsConstantNotJoin(Expr *p){
9617d10d5a6Sdrh   return exprIsConst(p, 3);
9620a168377Sdrh }
9630a168377Sdrh 
9640a168377Sdrh /*
9650a168377Sdrh ** Walk an expression tree.  Return 1 if the expression is constant
966eb55bd2fSdrh ** or a function call with constant arguments.  Return and 0 if there
967eb55bd2fSdrh ** are any variables.
968eb55bd2fSdrh **
969eb55bd2fSdrh ** For the purposes of this function, a double-quoted string (ex: "abc")
970eb55bd2fSdrh ** is considered a variable but a single-quoted string (ex: 'abc') is
971eb55bd2fSdrh ** a constant.
972eb55bd2fSdrh */
973eb55bd2fSdrh int sqlite3ExprIsConstantOrFunction(Expr *p){
9747d10d5a6Sdrh   return exprIsConst(p, 2);
975eb55bd2fSdrh }
976eb55bd2fSdrh 
977eb55bd2fSdrh /*
97873b211abSdrh ** If the expression p codes a constant integer that is small enough
979202b2df7Sdrh ** to fit in a 32-bit integer, return 1 and put the value of the integer
980202b2df7Sdrh ** in *pValue.  If the expression is not an integer or if it is too big
981202b2df7Sdrh ** to fit in a signed 32-bit integer, return 0 and leave *pValue unchanged.
982e4de1febSdrh */
9834adee20fSdanielk1977 int sqlite3ExprIsInteger(Expr *p, int *pValue){
98492b01d53Sdrh   int rc = 0;
98592b01d53Sdrh   if( p->flags & EP_IntValue ){
98692b01d53Sdrh     *pValue = p->iTable;
987e4de1febSdrh     return 1;
988e4de1febSdrh   }
98992b01d53Sdrh   switch( p->op ){
99092b01d53Sdrh     case TK_INTEGER: {
99192b01d53Sdrh       rc = sqlite3GetInt32((char*)p->token.z, pValue);
992202b2df7Sdrh       break;
993202b2df7Sdrh     }
9944b59ab5eSdrh     case TK_UPLUS: {
99592b01d53Sdrh       rc = sqlite3ExprIsInteger(p->pLeft, pValue);
996f6e369a1Sdrh       break;
9974b59ab5eSdrh     }
998e4de1febSdrh     case TK_UMINUS: {
999e4de1febSdrh       int v;
10004adee20fSdanielk1977       if( sqlite3ExprIsInteger(p->pLeft, &v) ){
1001e4de1febSdrh         *pValue = -v;
100292b01d53Sdrh         rc = 1;
1003e4de1febSdrh       }
1004e4de1febSdrh       break;
1005e4de1febSdrh     }
1006e4de1febSdrh     default: break;
1007e4de1febSdrh   }
100892b01d53Sdrh   if( rc ){
100992b01d53Sdrh     p->op = TK_INTEGER;
101092b01d53Sdrh     p->flags |= EP_IntValue;
101192b01d53Sdrh     p->iTable = *pValue;
101292b01d53Sdrh   }
101392b01d53Sdrh   return rc;
1014e4de1febSdrh }
1015e4de1febSdrh 
1016e4de1febSdrh /*
1017c4a3c779Sdrh ** Return TRUE if the given string is a row-id column name.
1018c4a3c779Sdrh */
10194adee20fSdanielk1977 int sqlite3IsRowid(const char *z){
10204adee20fSdanielk1977   if( sqlite3StrICmp(z, "_ROWID_")==0 ) return 1;
10214adee20fSdanielk1977   if( sqlite3StrICmp(z, "ROWID")==0 ) return 1;
10224adee20fSdanielk1977   if( sqlite3StrICmp(z, "OID")==0 ) return 1;
1023c4a3c779Sdrh   return 0;
1024c4a3c779Sdrh }
1025c4a3c779Sdrh 
10269a96b668Sdanielk1977 #ifdef SQLITE_TEST
10279a96b668Sdanielk1977   int sqlite3_enable_in_opt = 1;
10289a96b668Sdanielk1977 #else
10299a96b668Sdanielk1977   #define sqlite3_enable_in_opt 1
10309a96b668Sdanielk1977 #endif
10319a96b668Sdanielk1977 
10329a96b668Sdanielk1977 /*
1033b287f4b6Sdrh ** Return true if the IN operator optimization is enabled and
1034b287f4b6Sdrh ** the SELECT statement p exists and is of the
1035b287f4b6Sdrh ** simple form:
1036b287f4b6Sdrh **
1037b287f4b6Sdrh **     SELECT <column> FROM <table>
1038b287f4b6Sdrh **
1039b287f4b6Sdrh ** If this is the case, it may be possible to use an existing table
1040b287f4b6Sdrh ** or index instead of generating an epheremal table.
1041b287f4b6Sdrh */
1042b287f4b6Sdrh #ifndef SQLITE_OMIT_SUBQUERY
1043b287f4b6Sdrh static int isCandidateForInOpt(Select *p){
1044b287f4b6Sdrh   SrcList *pSrc;
1045b287f4b6Sdrh   ExprList *pEList;
1046b287f4b6Sdrh   Table *pTab;
1047b287f4b6Sdrh   if( !sqlite3_enable_in_opt ) return 0; /* IN optimization must be enabled */
1048b287f4b6Sdrh   if( p==0 ) return 0;                   /* right-hand side of IN is SELECT */
1049b287f4b6Sdrh   if( p->pPrior ) return 0;              /* Not a compound SELECT */
10507d10d5a6Sdrh   if( p->selFlags & (SF_Distinct|SF_Aggregate) ){
10517d10d5a6Sdrh       return 0; /* No DISTINCT keyword and no aggregate functions */
10527d10d5a6Sdrh   }
1053b287f4b6Sdrh   if( p->pGroupBy ) return 0;            /* Has no GROUP BY clause */
1054b287f4b6Sdrh   if( p->pLimit ) return 0;              /* Has no LIMIT clause */
1055b287f4b6Sdrh   if( p->pOffset ) return 0;
1056b287f4b6Sdrh   if( p->pWhere ) return 0;              /* Has no WHERE clause */
1057b287f4b6Sdrh   pSrc = p->pSrc;
1058b287f4b6Sdrh   if( pSrc==0 ) return 0;                /* A single table in the FROM clause */
1059b287f4b6Sdrh   if( pSrc->nSrc!=1 ) return 0;
1060b287f4b6Sdrh   if( pSrc->a[0].pSelect ) return 0;     /* FROM clause is not a subquery */
1061b287f4b6Sdrh   pTab = pSrc->a[0].pTab;
1062b287f4b6Sdrh   if( pTab==0 ) return 0;
1063b287f4b6Sdrh   if( pTab->pSelect ) return 0;          /* FROM clause is not a view */
1064b287f4b6Sdrh   if( IsVirtual(pTab) ) return 0;        /* FROM clause not a virtual table */
1065b287f4b6Sdrh   pEList = p->pEList;
1066b287f4b6Sdrh   if( pEList->nExpr!=1 ) return 0;       /* One column in the result set */
1067b287f4b6Sdrh   if( pEList->a[0].pExpr->op!=TK_COLUMN ) return 0; /* Result is a column */
1068b287f4b6Sdrh   return 1;
1069b287f4b6Sdrh }
1070b287f4b6Sdrh #endif /* SQLITE_OMIT_SUBQUERY */
1071b287f4b6Sdrh 
1072b287f4b6Sdrh /*
10739a96b668Sdanielk1977 ** This function is used by the implementation of the IN (...) operator.
10749a96b668Sdanielk1977 ** It's job is to find or create a b-tree structure that may be used
10759a96b668Sdanielk1977 ** either to test for membership of the (...) set or to iterate through
107685b623f2Sdrh ** its members, skipping duplicates.
10779a96b668Sdanielk1977 **
10789a96b668Sdanielk1977 ** The cursor opened on the structure (database table, database index
10799a96b668Sdanielk1977 ** or ephermal table) is stored in pX->iTable before this function returns.
10809a96b668Sdanielk1977 ** The returned value indicates the structure type, as follows:
10819a96b668Sdanielk1977 **
10829a96b668Sdanielk1977 **   IN_INDEX_ROWID - The cursor was opened on a database table.
10832d401ab8Sdrh **   IN_INDEX_INDEX - The cursor was opened on a database index.
10849a96b668Sdanielk1977 **   IN_INDEX_EPH -   The cursor was opened on a specially created and
10859a96b668Sdanielk1977 **                    populated epheremal table.
10869a96b668Sdanielk1977 **
10879a96b668Sdanielk1977 ** An existing structure may only be used if the SELECT is of the simple
10889a96b668Sdanielk1977 ** form:
10899a96b668Sdanielk1977 **
10909a96b668Sdanielk1977 **     SELECT <column> FROM <table>
10919a96b668Sdanielk1977 **
10920cdc022eSdanielk1977 ** If prNotFound parameter is 0, then the structure will be used to iterate
10939a96b668Sdanielk1977 ** through the set members, skipping any duplicates. In this case an
10949a96b668Sdanielk1977 ** epheremal table must be used unless the selected <column> is guaranteed
10959a96b668Sdanielk1977 ** to be unique - either because it is an INTEGER PRIMARY KEY or it
10969a96b668Sdanielk1977 ** is unique by virtue of a constraint or implicit index.
10970cdc022eSdanielk1977 **
10980cdc022eSdanielk1977 ** If the prNotFound parameter is not 0, then the structure will be used
10990cdc022eSdanielk1977 ** for fast set membership tests. In this case an epheremal table must
11000cdc022eSdanielk1977 ** be used unless <column> is an INTEGER PRIMARY KEY or an index can
11010cdc022eSdanielk1977 ** be found with <column> as its left-most column.
11020cdc022eSdanielk1977 **
11030cdc022eSdanielk1977 ** When the structure is being used for set membership tests, the user
11040cdc022eSdanielk1977 ** needs to know whether or not the structure contains an SQL NULL
11050cdc022eSdanielk1977 ** value in order to correctly evaluate expressions like "X IN (Y, Z)".
11060cdc022eSdanielk1977 ** If there is a chance that the structure may contain a NULL value at
11070cdc022eSdanielk1977 ** runtime, then a register is allocated and the register number written
11080cdc022eSdanielk1977 ** to *prNotFound. If there is no chance that the structure contains a
11090cdc022eSdanielk1977 ** NULL value, then *prNotFound is left unchanged.
11100cdc022eSdanielk1977 **
11110cdc022eSdanielk1977 ** If a register is allocated and its location stored in *prNotFound, then
11120cdc022eSdanielk1977 ** its initial value is NULL. If the structure does not remain constant
11130cdc022eSdanielk1977 ** for the duration of the query (i.e. the set is a correlated sub-select),
11140cdc022eSdanielk1977 ** the value of the allocated register is reset to NULL each time the
11150cdc022eSdanielk1977 ** structure is repopulated. This allows the caller to use vdbe code
11160cdc022eSdanielk1977 ** equivalent to the following:
11170cdc022eSdanielk1977 **
11180cdc022eSdanielk1977 **   if( register==NULL ){
11190cdc022eSdanielk1977 **     has_null = <test if data structure contains null>
11200cdc022eSdanielk1977 **     register = 1
11210cdc022eSdanielk1977 **   }
11220cdc022eSdanielk1977 **
11230cdc022eSdanielk1977 ** in order to avoid running the <test if data structure contains null>
11240cdc022eSdanielk1977 ** test more often than is necessary.
11259a96b668Sdanielk1977 */
1126284f4acaSdanielk1977 #ifndef SQLITE_OMIT_SUBQUERY
11270cdc022eSdanielk1977 int sqlite3FindInIndex(Parse *pParse, Expr *pX, int *prNotFound){
11289a96b668Sdanielk1977   Select *p;
11299a96b668Sdanielk1977   int eType = 0;
11309a96b668Sdanielk1977   int iTab = pParse->nTab++;
11310cdc022eSdanielk1977   int mustBeUnique = !prNotFound;
11329a96b668Sdanielk1977 
11339a96b668Sdanielk1977   /* The follwing if(...) expression is true if the SELECT is of the
11349a96b668Sdanielk1977   ** simple form:
11359a96b668Sdanielk1977   **
11369a96b668Sdanielk1977   **     SELECT <column> FROM <table>
11379a96b668Sdanielk1977   **
11389a96b668Sdanielk1977   ** If this is the case, it may be possible to use an existing table
11399a96b668Sdanielk1977   ** or index instead of generating an epheremal table.
11409a96b668Sdanielk1977   */
1141b287f4b6Sdrh   p = pX->pSelect;
1142b287f4b6Sdrh   if( isCandidateForInOpt(p) ){
11439a96b668Sdanielk1977     sqlite3 *db = pParse->db;
11449a96b668Sdanielk1977     Index *pIdx;
11459a96b668Sdanielk1977     Expr *pExpr = p->pEList->a[0].pExpr;
11469a96b668Sdanielk1977     int iCol = pExpr->iColumn;
11479a96b668Sdanielk1977     Vdbe *v = sqlite3GetVdbe(pParse);
11489a96b668Sdanielk1977 
11499a96b668Sdanielk1977     /* This function is only called from two places. In both cases the vdbe
11509a96b668Sdanielk1977     ** has already been allocated. So assume sqlite3GetVdbe() is always
11519a96b668Sdanielk1977     ** successful here.
11529a96b668Sdanielk1977     */
11539a96b668Sdanielk1977     assert(v);
11549a96b668Sdanielk1977     if( iCol<0 ){
11550a07c107Sdrh       int iMem = ++pParse->nMem;
11569a96b668Sdanielk1977       int iAddr;
11579a96b668Sdanielk1977       Table *pTab = p->pSrc->a[0].pTab;
11589a96b668Sdanielk1977       int iDb = sqlite3SchemaToIndex(db, pTab->pSchema);
11599a96b668Sdanielk1977       sqlite3VdbeUsesBtree(v, iDb);
11609a96b668Sdanielk1977 
1161892d3179Sdrh       iAddr = sqlite3VdbeAddOp1(v, OP_If, iMem);
11624c583128Sdrh       sqlite3VdbeAddOp2(v, OP_Integer, 1, iMem);
11639a96b668Sdanielk1977 
11649a96b668Sdanielk1977       sqlite3OpenTable(pParse, iTab, iDb, pTab, OP_OpenRead);
11659a96b668Sdanielk1977       eType = IN_INDEX_ROWID;
11669a96b668Sdanielk1977 
11679a96b668Sdanielk1977       sqlite3VdbeJumpHere(v, iAddr);
11689a96b668Sdanielk1977     }else{
11699a96b668Sdanielk1977       /* The collation sequence used by the comparison. If an index is to
11709a96b668Sdanielk1977       ** be used in place of a temp-table, it must be ordered according
11719a96b668Sdanielk1977       ** to this collation sequence.
11729a96b668Sdanielk1977       */
11739a96b668Sdanielk1977       CollSeq *pReq = sqlite3BinaryCompareCollSeq(pParse, pX->pLeft, pExpr);
11749a96b668Sdanielk1977 
11759a96b668Sdanielk1977       /* Check that the affinity that will be used to perform the
11769a96b668Sdanielk1977       ** comparison is the same as the affinity of the column. If
11779a96b668Sdanielk1977       ** it is not, it is not possible to use any index.
11789a96b668Sdanielk1977       */
11799a96b668Sdanielk1977       Table *pTab = p->pSrc->a[0].pTab;
11809a96b668Sdanielk1977       char aff = comparisonAffinity(pX);
11819a96b668Sdanielk1977       int affinity_ok = (pTab->aCol[iCol].affinity==aff||aff==SQLITE_AFF_NONE);
11829a96b668Sdanielk1977 
11839a96b668Sdanielk1977       for(pIdx=pTab->pIndex; pIdx && eType==0 && affinity_ok; pIdx=pIdx->pNext){
11849a96b668Sdanielk1977         if( (pIdx->aiColumn[0]==iCol)
11859a96b668Sdanielk1977          && (pReq==sqlite3FindCollSeq(db, ENC(db), pIdx->azColl[0], -1, 0))
11869a96b668Sdanielk1977          && (!mustBeUnique || (pIdx->nColumn==1 && pIdx->onError!=OE_None))
11879a96b668Sdanielk1977         ){
11889a96b668Sdanielk1977           int iDb;
11890a07c107Sdrh           int iMem = ++pParse->nMem;
11909a96b668Sdanielk1977           int iAddr;
11919a96b668Sdanielk1977           char *pKey;
11929a96b668Sdanielk1977 
11939a96b668Sdanielk1977           pKey = (char *)sqlite3IndexKeyinfo(pParse, pIdx);
11949a96b668Sdanielk1977           iDb = sqlite3SchemaToIndex(db, pIdx->pSchema);
11959a96b668Sdanielk1977           sqlite3VdbeUsesBtree(v, iDb);
11969a96b668Sdanielk1977 
1197892d3179Sdrh           iAddr = sqlite3VdbeAddOp1(v, OP_If, iMem);
11984c583128Sdrh           sqlite3VdbeAddOp2(v, OP_Integer, 1, iMem);
11999a96b668Sdanielk1977 
1200cd3e8f7cSdanielk1977           sqlite3VdbeAddOp2(v, OP_SetNumColumns, 0, pIdx->nColumn);
1201207872a4Sdanielk1977           sqlite3VdbeAddOp4(v, OP_OpenRead, iTab, pIdx->tnum, iDb,
120266a5167bSdrh                                pKey,P4_KEYINFO_HANDOFF);
1203207872a4Sdanielk1977           VdbeComment((v, "%s", pIdx->zName));
12049a96b668Sdanielk1977           eType = IN_INDEX_INDEX;
12059a96b668Sdanielk1977 
12069a96b668Sdanielk1977           sqlite3VdbeJumpHere(v, iAddr);
12070cdc022eSdanielk1977           if( prNotFound && !pTab->aCol[iCol].notNull ){
12080cdc022eSdanielk1977             *prNotFound = ++pParse->nMem;
12090cdc022eSdanielk1977           }
12109a96b668Sdanielk1977         }
12119a96b668Sdanielk1977       }
12129a96b668Sdanielk1977     }
12139a96b668Sdanielk1977   }
12149a96b668Sdanielk1977 
12159a96b668Sdanielk1977   if( eType==0 ){
12160cdc022eSdanielk1977     int rMayHaveNull = 0;
121741a05b7bSdanielk1977     eType = IN_INDEX_EPH;
12180cdc022eSdanielk1977     if( prNotFound ){
12190cdc022eSdanielk1977       *prNotFound = rMayHaveNull = ++pParse->nMem;
122041a05b7bSdanielk1977     }else if( pX->pLeft->iColumn<0 && pX->pSelect==0 ){
122141a05b7bSdanielk1977       eType = IN_INDEX_ROWID;
12220cdc022eSdanielk1977     }
122341a05b7bSdanielk1977     sqlite3CodeSubselect(pParse, pX, rMayHaveNull, eType==IN_INDEX_ROWID);
12249a96b668Sdanielk1977   }else{
12259a96b668Sdanielk1977     pX->iTable = iTab;
12269a96b668Sdanielk1977   }
12279a96b668Sdanielk1977   return eType;
12289a96b668Sdanielk1977 }
1229284f4acaSdanielk1977 #endif
1230626a879aSdrh 
1231626a879aSdrh /*
12329cbe6352Sdrh ** Generate code for scalar subqueries used as an expression
12339cbe6352Sdrh ** and IN operators.  Examples:
1234626a879aSdrh **
12359cbe6352Sdrh **     (SELECT a FROM b)          -- subquery
12369cbe6352Sdrh **     EXISTS (SELECT a FROM b)   -- EXISTS subquery
12379cbe6352Sdrh **     x IN (4,5,11)              -- IN operator with list on right-hand side
12389cbe6352Sdrh **     x IN (SELECT a FROM b)     -- IN operator with subquery on the right
1239fef5208cSdrh **
12409cbe6352Sdrh ** The pExpr parameter describes the expression that contains the IN
12419cbe6352Sdrh ** operator or subquery.
124241a05b7bSdanielk1977 **
124341a05b7bSdanielk1977 ** If parameter isRowid is non-zero, then expression pExpr is guaranteed
124441a05b7bSdanielk1977 ** to be of the form "<rowid> IN (?, ?, ?)", where <rowid> is a reference
124541a05b7bSdanielk1977 ** to some integer key column of a table B-Tree. In this case, use an
124641a05b7bSdanielk1977 ** intkey B-Tree to store the set of IN(...) values instead of the usual
124741a05b7bSdanielk1977 ** (slower) variable length keys B-Tree.
1248cce7d176Sdrh */
124951522cd3Sdrh #ifndef SQLITE_OMIT_SUBQUERY
125041a05b7bSdanielk1977 void sqlite3CodeSubselect(
125141a05b7bSdanielk1977   Parse *pParse,
125241a05b7bSdanielk1977   Expr *pExpr,
125341a05b7bSdanielk1977   int rMayHaveNull,
125441a05b7bSdanielk1977   int isRowid
125541a05b7bSdanielk1977 ){
125657dbd7b3Sdrh   int testAddr = 0;                       /* One-time test address */
1257b3bce662Sdanielk1977   Vdbe *v = sqlite3GetVdbe(pParse);
1258b3bce662Sdanielk1977   if( v==0 ) return;
1259b3bce662Sdanielk1977 
1260fc976065Sdanielk1977 
126157dbd7b3Sdrh   /* This code must be run in its entirety every time it is encountered
126257dbd7b3Sdrh   ** if any of the following is true:
126357dbd7b3Sdrh   **
126457dbd7b3Sdrh   **    *  The right-hand side is a correlated subquery
126557dbd7b3Sdrh   **    *  The right-hand side is an expression list containing variables
126657dbd7b3Sdrh   **    *  We are inside a trigger
126757dbd7b3Sdrh   **
126857dbd7b3Sdrh   ** If all of the above are false, then we can run this code just once
126957dbd7b3Sdrh   ** save the results, and reuse the same result on subsequent invocations.
1270b3bce662Sdanielk1977   */
1271b3bce662Sdanielk1977   if( !ExprHasAnyProperty(pExpr, EP_VarSelect) && !pParse->trigStack ){
12720a07c107Sdrh     int mem = ++pParse->nMem;
1273892d3179Sdrh     sqlite3VdbeAddOp1(v, OP_If, mem);
1274892d3179Sdrh     testAddr = sqlite3VdbeAddOp2(v, OP_Integer, 1, mem);
127517435752Sdrh     assert( testAddr>0 || pParse->db->mallocFailed );
1276b3bce662Sdanielk1977   }
1277b3bce662Sdanielk1977 
1278cce7d176Sdrh   switch( pExpr->op ){
1279fef5208cSdrh     case TK_IN: {
1280e014a838Sdanielk1977       char affinity;
1281d3d39e93Sdrh       KeyInfo keyInfo;
1282b9bb7c18Sdrh       int addr;        /* Address of OP_OpenEphemeral instruction */
128341a05b7bSdanielk1977       Expr *pLeft = pExpr->pLeft;
1284d3d39e93Sdrh 
12850cdc022eSdanielk1977       if( rMayHaveNull ){
12860cdc022eSdanielk1977         sqlite3VdbeAddOp2(v, OP_Null, 0, rMayHaveNull);
12870cdc022eSdanielk1977       }
12880cdc022eSdanielk1977 
128941a05b7bSdanielk1977       affinity = sqlite3ExprAffinity(pLeft);
1290e014a838Sdanielk1977 
1291e014a838Sdanielk1977       /* Whether this is an 'x IN(SELECT...)' or an 'x IN(<exprlist>)'
129257dbd7b3Sdrh       ** expression it is handled the same way. A virtual table is
1293e014a838Sdanielk1977       ** filled with single-field index keys representing the results
1294e014a838Sdanielk1977       ** from the SELECT or the <exprlist>.
1295fef5208cSdrh       **
1296e014a838Sdanielk1977       ** If the 'x' expression is a column value, or the SELECT...
1297e014a838Sdanielk1977       ** statement returns a column value, then the affinity of that
1298e014a838Sdanielk1977       ** column is used to build the index keys. If both 'x' and the
1299e014a838Sdanielk1977       ** SELECT... statement are columns, then numeric affinity is used
1300e014a838Sdanielk1977       ** if either column has NUMERIC or INTEGER affinity. If neither
1301e014a838Sdanielk1977       ** 'x' nor the SELECT... statement are columns, then numeric affinity
1302e014a838Sdanielk1977       ** is used.
1303fef5208cSdrh       */
1304832508b7Sdrh       pExpr->iTable = pParse->nTab++;
130541a05b7bSdanielk1977       addr = sqlite3VdbeAddOp2(v, OP_OpenEphemeral, pExpr->iTable, !isRowid);
1306d3d39e93Sdrh       memset(&keyInfo, 0, sizeof(keyInfo));
1307d3d39e93Sdrh       keyInfo.nField = 1;
1308e014a838Sdanielk1977 
1309e014a838Sdanielk1977       if( pExpr->pSelect ){
1310e014a838Sdanielk1977         /* Case 1:     expr IN (SELECT ...)
1311e014a838Sdanielk1977         **
1312e014a838Sdanielk1977         ** Generate code to write the results of the select into the temporary
1313e014a838Sdanielk1977         ** table allocated and opened above.
1314e014a838Sdanielk1977         */
13151013c932Sdrh         SelectDest dest;
1316be5c89acSdrh         ExprList *pEList;
13171013c932Sdrh 
131841a05b7bSdanielk1977         assert( !isRowid );
13191013c932Sdrh         sqlite3SelectDestInit(&dest, SRT_Set, pExpr->iTable);
13201013c932Sdrh         dest.affinity = (int)affinity;
1321e014a838Sdanielk1977         assert( (pExpr->iTable&0x0000FFFF)==pExpr->iTable );
13227d10d5a6Sdrh         if( sqlite3Select(pParse, pExpr->pSelect, &dest) ){
132394ccde58Sdrh           return;
132494ccde58Sdrh         }
1325be5c89acSdrh         pEList = pExpr->pSelect->pEList;
1326be5c89acSdrh         if( pEList && pEList->nExpr>0 ){
1327bcbb04e5Sdanielk1977           keyInfo.aColl[0] = sqlite3BinaryCompareCollSeq(pParse, pExpr->pLeft,
1328be5c89acSdrh               pEList->a[0].pExpr);
13290202b29eSdanielk1977         }
1330fef5208cSdrh       }else if( pExpr->pList ){
1331fef5208cSdrh         /* Case 2:     expr IN (exprlist)
1332fef5208cSdrh         **
1333e014a838Sdanielk1977         ** For each expression, build an index key from the evaluation and
1334e014a838Sdanielk1977         ** store it in the temporary table. If <expr> is a column, then use
1335e014a838Sdanielk1977         ** that columns affinity when building index keys. If <expr> is not
1336e014a838Sdanielk1977         ** a column, use numeric affinity.
1337fef5208cSdrh         */
1338e014a838Sdanielk1977         int i;
133957dbd7b3Sdrh         ExprList *pList = pExpr->pList;
134057dbd7b3Sdrh         struct ExprList_item *pItem;
1341ecc31805Sdrh         int r1, r2, r3;
134257dbd7b3Sdrh 
1343e014a838Sdanielk1977         if( !affinity ){
13448159a35fSdrh           affinity = SQLITE_AFF_NONE;
1345e014a838Sdanielk1977         }
13467d10d5a6Sdrh         keyInfo.aColl[0] = sqlite3ExprCollSeq(pParse, pExpr->pLeft);
1347e014a838Sdanielk1977 
1348e014a838Sdanielk1977         /* Loop through each expression in <exprlist>. */
13492d401ab8Sdrh         r1 = sqlite3GetTempReg(pParse);
13502d401ab8Sdrh         r2 = sqlite3GetTempReg(pParse);
1351*4e7f36a2Sdanielk1977         sqlite3VdbeAddOp2(v, OP_Null, 0, r2);
135257dbd7b3Sdrh         for(i=pList->nExpr, pItem=pList->a; i>0; i--, pItem++){
135357dbd7b3Sdrh           Expr *pE2 = pItem->pExpr;
1354e014a838Sdanielk1977 
135557dbd7b3Sdrh           /* If the expression is not constant then we will need to
135657dbd7b3Sdrh           ** disable the test that was generated above that makes sure
135757dbd7b3Sdrh           ** this code only executes once.  Because for a non-constant
135857dbd7b3Sdrh           ** expression we need to rerun this code each time.
135957dbd7b3Sdrh           */
1360892d3179Sdrh           if( testAddr && !sqlite3ExprIsConstant(pE2) ){
1361892d3179Sdrh             sqlite3VdbeChangeToNoop(v, testAddr-1, 2);
136257dbd7b3Sdrh             testAddr = 0;
13634794b980Sdrh           }
1364e014a838Sdanielk1977 
1365e014a838Sdanielk1977           /* Evaluate the expression and insert it into the temp table */
1366e55cbd72Sdrh           pParse->disableColCache++;
1367ecc31805Sdrh           r3 = sqlite3ExprCodeTarget(pParse, pE2, r1);
1368c5499befSdrh           assert( pParse->disableColCache>0 );
1369e55cbd72Sdrh           pParse->disableColCache--;
137041a05b7bSdanielk1977 
137141a05b7bSdanielk1977           if( isRowid ){
137241a05b7bSdanielk1977             sqlite3VdbeAddOp2(v, OP_MustBeInt, r3, sqlite3VdbeCurrentAddr(v)+2);
137341a05b7bSdanielk1977             sqlite3VdbeAddOp3(v, OP_Insert, pExpr->iTable, r2, r3);
137441a05b7bSdanielk1977           }else{
1375ecc31805Sdrh             sqlite3VdbeAddOp4(v, OP_MakeRecord, r3, 1, r2, &affinity, 1);
13763c31fc23Sdrh             sqlite3ExprCacheAffinityChange(pParse, r3, 1);
13772d401ab8Sdrh             sqlite3VdbeAddOp2(v, OP_IdxInsert, pExpr->iTable, r2);
1378fef5208cSdrh           }
137941a05b7bSdanielk1977         }
13802d401ab8Sdrh         sqlite3ReleaseTempReg(pParse, r1);
13812d401ab8Sdrh         sqlite3ReleaseTempReg(pParse, r2);
1382fef5208cSdrh       }
138341a05b7bSdanielk1977       if( !isRowid ){
138466a5167bSdrh         sqlite3VdbeChangeP4(v, addr, (void *)&keyInfo, P4_KEYINFO);
138541a05b7bSdanielk1977       }
1386b3bce662Sdanielk1977       break;
1387fef5208cSdrh     }
1388fef5208cSdrh 
138951522cd3Sdrh     case TK_EXISTS:
139019a775c2Sdrh     case TK_SELECT: {
1391fef5208cSdrh       /* This has to be a scalar SELECT.  Generate code to put the
1392fef5208cSdrh       ** value of this select in a memory cell and record the number
1393967e8b73Sdrh       ** of the memory cell in iColumn.
1394fef5208cSdrh       */
13952646da7eSdrh       static const Token one = { (u8*)"1", 0, 1 };
139651522cd3Sdrh       Select *pSel;
13976c8c8ce0Sdanielk1977       SelectDest dest;
13981398ad36Sdrh 
139951522cd3Sdrh       pSel = pExpr->pSelect;
14001013c932Sdrh       sqlite3SelectDestInit(&dest, 0, ++pParse->nMem);
140151522cd3Sdrh       if( pExpr->op==TK_SELECT ){
14026c8c8ce0Sdanielk1977         dest.eDest = SRT_Mem;
14034c583128Sdrh         sqlite3VdbeAddOp2(v, OP_Null, 0, dest.iParm);
1404d4e70ebdSdrh         VdbeComment((v, "Init subquery result"));
140551522cd3Sdrh       }else{
14066c8c8ce0Sdanielk1977         dest.eDest = SRT_Exists;
14074c583128Sdrh         sqlite3VdbeAddOp2(v, OP_Integer, 0, dest.iParm);
1408d4e70ebdSdrh         VdbeComment((v, "Init EXISTS result"));
140951522cd3Sdrh       }
1410633e6d57Sdrh       sqlite3ExprDelete(pParse->db, pSel->pLimit);
1411a1644fd8Sdanielk1977       pSel->pLimit = sqlite3PExpr(pParse, TK_INTEGER, 0, 0, &one);
14127d10d5a6Sdrh       if( sqlite3Select(pParse, pSel, &dest) ){
141394ccde58Sdrh         return;
141494ccde58Sdrh       }
14156c8c8ce0Sdanielk1977       pExpr->iColumn = dest.iParm;
1416b3bce662Sdanielk1977       break;
141719a775c2Sdrh     }
1418cce7d176Sdrh   }
1419b3bce662Sdanielk1977 
142057dbd7b3Sdrh   if( testAddr ){
1421892d3179Sdrh     sqlite3VdbeJumpHere(v, testAddr-1);
1422b3bce662Sdanielk1977   }
1423fc976065Sdanielk1977 
1424b3bce662Sdanielk1977   return;
1425cce7d176Sdrh }
142651522cd3Sdrh #endif /* SQLITE_OMIT_SUBQUERY */
1427cce7d176Sdrh 
1428cce7d176Sdrh /*
1429598f1340Sdrh ** Duplicate an 8-byte value
1430598f1340Sdrh */
1431598f1340Sdrh static char *dup8bytes(Vdbe *v, const char *in){
1432598f1340Sdrh   char *out = sqlite3DbMallocRaw(sqlite3VdbeDb(v), 8);
1433598f1340Sdrh   if( out ){
1434598f1340Sdrh     memcpy(out, in, 8);
1435598f1340Sdrh   }
1436598f1340Sdrh   return out;
1437598f1340Sdrh }
1438598f1340Sdrh 
1439598f1340Sdrh /*
1440598f1340Sdrh ** Generate an instruction that will put the floating point
14419cbf3425Sdrh ** value described by z[0..n-1] into register iMem.
14420cf19ed8Sdrh **
14430cf19ed8Sdrh ** The z[] string will probably not be zero-terminated.  But the
14440cf19ed8Sdrh ** z[n] character is guaranteed to be something that does not look
14450cf19ed8Sdrh ** like the continuation of the number.
1446598f1340Sdrh */
14479de221dfSdrh static void codeReal(Vdbe *v, const char *z, int n, int negateFlag, int iMem){
1448598f1340Sdrh   assert( z || v==0 || sqlite3VdbeDb(v)->mallocFailed );
1449598f1340Sdrh   if( z ){
1450598f1340Sdrh     double value;
1451598f1340Sdrh     char *zV;
14520cf19ed8Sdrh     assert( !isdigit(z[n]) );
1453598f1340Sdrh     sqlite3AtoF(z, &value);
14542eaf93d3Sdrh     if( sqlite3IsNaN(value) ){
14552eaf93d3Sdrh       sqlite3VdbeAddOp2(v, OP_Null, 0, iMem);
14562eaf93d3Sdrh     }else{
1457598f1340Sdrh       if( negateFlag ) value = -value;
1458598f1340Sdrh       zV = dup8bytes(v, (char*)&value);
14599de221dfSdrh       sqlite3VdbeAddOp4(v, OP_Real, 0, iMem, 0, zV, P4_REAL);
1460598f1340Sdrh     }
1461598f1340Sdrh   }
14622eaf93d3Sdrh }
1463598f1340Sdrh 
1464598f1340Sdrh 
1465598f1340Sdrh /*
1466fec19aadSdrh ** Generate an instruction that will put the integer describe by
14679cbf3425Sdrh ** text z[0..n-1] into register iMem.
14680cf19ed8Sdrh **
14690cf19ed8Sdrh ** The z[] string will probably not be zero-terminated.  But the
14700cf19ed8Sdrh ** z[n] character is guaranteed to be something that does not look
14710cf19ed8Sdrh ** like the continuation of the number.
1472fec19aadSdrh */
147392b01d53Sdrh static void codeInteger(Vdbe *v, Expr *pExpr, int negFlag, int iMem){
147492b01d53Sdrh   const char *z;
147592b01d53Sdrh   if( pExpr->flags & EP_IntValue ){
147692b01d53Sdrh     int i = pExpr->iTable;
147792b01d53Sdrh     if( negFlag ) i = -i;
147892b01d53Sdrh     sqlite3VdbeAddOp2(v, OP_Integer, i, iMem);
147992b01d53Sdrh   }else if( (z = (char*)pExpr->token.z)!=0 ){
1480fec19aadSdrh     int i;
148192b01d53Sdrh     int n = pExpr->token.n;
14820cf19ed8Sdrh     assert( !isdigit(z[n]) );
14836fec0762Sdrh     if( sqlite3GetInt32(z, &i) ){
14849de221dfSdrh       if( negFlag ) i = -i;
14859de221dfSdrh       sqlite3VdbeAddOp2(v, OP_Integer, i, iMem);
14869de221dfSdrh     }else if( sqlite3FitsIn64Bits(z, negFlag) ){
1487598f1340Sdrh       i64 value;
1488598f1340Sdrh       char *zV;
1489598f1340Sdrh       sqlite3Atoi64(z, &value);
14909de221dfSdrh       if( negFlag ) value = -value;
1491598f1340Sdrh       zV = dup8bytes(v, (char*)&value);
14929de221dfSdrh       sqlite3VdbeAddOp4(v, OP_Int64, 0, iMem, 0, zV, P4_INT64);
1493fec19aadSdrh     }else{
14949de221dfSdrh       codeReal(v, z, n, negFlag, iMem);
1495fec19aadSdrh     }
1496fec19aadSdrh   }
1497c9cf901dSdanielk1977 }
1498fec19aadSdrh 
1499945498f3Sdrh 
1500945498f3Sdrh /*
1501945498f3Sdrh ** Generate code that will extract the iColumn-th column from
1502e55cbd72Sdrh ** table pTab and store the column value in a register.  An effort
1503e55cbd72Sdrh ** is made to store the column value in register iReg, but this is
1504e55cbd72Sdrh ** not guaranteed.  The location of the column value is returned.
1505e55cbd72Sdrh **
1506e55cbd72Sdrh ** There must be an open cursor to pTab in iTable when this routine
1507e55cbd72Sdrh ** is called.  If iColumn<0 then code is generated that extracts the rowid.
1508da250ea5Sdrh **
1509da250ea5Sdrh ** This routine might attempt to reuse the value of the column that
1510da250ea5Sdrh ** has already been loaded into a register.  The value will always
1511da250ea5Sdrh ** be used if it has not undergone any affinity changes.  But if
1512da250ea5Sdrh ** an affinity change has occurred, then the cached value will only be
1513da250ea5Sdrh ** used if allowAffChng is true.
1514945498f3Sdrh */
1515e55cbd72Sdrh int sqlite3ExprCodeGetColumn(
1516e55cbd72Sdrh   Parse *pParse,   /* Parsing and code generating context */
15172133d822Sdrh   Table *pTab,     /* Description of the table we are reading from */
15182133d822Sdrh   int iColumn,     /* Index of the table column */
15192133d822Sdrh   int iTable,      /* The cursor pointing to the table */
1520da250ea5Sdrh   int iReg,        /* Store results here */
1521da250ea5Sdrh   int allowAffChng /* True if prior affinity changes are OK */
15222133d822Sdrh ){
1523e55cbd72Sdrh   Vdbe *v = pParse->pVdbe;
1524e55cbd72Sdrh   int i;
1525da250ea5Sdrh   struct yColCache *p;
1526e55cbd72Sdrh 
1527da250ea5Sdrh   for(i=0, p=pParse->aColCache; i<pParse->nColCache; i++, p++){
1528da250ea5Sdrh     if( p->iTable==iTable && p->iColumn==iColumn
1529da250ea5Sdrh            && (!p->affChange || allowAffChng) ){
1530e55cbd72Sdrh #if 0
1531e55cbd72Sdrh       sqlite3VdbeAddOp0(v, OP_Noop);
1532da250ea5Sdrh       VdbeComment((v, "OPT: tab%d.col%d -> r%d", iTable, iColumn, p->iReg));
1533e55cbd72Sdrh #endif
1534da250ea5Sdrh       return p->iReg;
1535e55cbd72Sdrh     }
1536e55cbd72Sdrh   }
1537e55cbd72Sdrh   assert( v!=0 );
1538945498f3Sdrh   if( iColumn<0 ){
1539945498f3Sdrh     int op = (pTab && IsVirtual(pTab)) ? OP_VRowid : OP_Rowid;
15402133d822Sdrh     sqlite3VdbeAddOp2(v, op, iTable, iReg);
1541945498f3Sdrh   }else if( pTab==0 ){
15422133d822Sdrh     sqlite3VdbeAddOp3(v, OP_Column, iTable, iColumn, iReg);
1543945498f3Sdrh   }else{
1544945498f3Sdrh     int op = IsVirtual(pTab) ? OP_VColumn : OP_Column;
15452133d822Sdrh     sqlite3VdbeAddOp3(v, op, iTable, iColumn, iReg);
1546945498f3Sdrh     sqlite3ColumnDefault(v, pTab, iColumn);
1547945498f3Sdrh #ifndef SQLITE_OMIT_FLOATING_POINT
1548945498f3Sdrh     if( pTab->aCol[iColumn].affinity==SQLITE_AFF_REAL ){
15492133d822Sdrh       sqlite3VdbeAddOp1(v, OP_RealAffinity, iReg);
1550945498f3Sdrh     }
1551945498f3Sdrh #endif
1552945498f3Sdrh   }
1553e55cbd72Sdrh   if( pParse->disableColCache==0 ){
1554e55cbd72Sdrh     i = pParse->iColCache;
1555da250ea5Sdrh     p = &pParse->aColCache[i];
1556da250ea5Sdrh     p->iTable = iTable;
1557da250ea5Sdrh     p->iColumn = iColumn;
1558da250ea5Sdrh     p->iReg = iReg;
1559c5499befSdrh     p->affChange = 0;
1560e55cbd72Sdrh     i++;
15612f7794c1Sdrh     if( i>=ArraySize(pParse->aColCache) ) i = 0;
1562e55cbd72Sdrh     if( i>pParse->nColCache ) pParse->nColCache = i;
15632f7794c1Sdrh     pParse->iColCache = i;
1564e55cbd72Sdrh   }
1565e55cbd72Sdrh   return iReg;
1566e55cbd72Sdrh }
1567e55cbd72Sdrh 
1568e55cbd72Sdrh /*
1569e55cbd72Sdrh ** Clear all column cache entries associated with the vdbe
1570e55cbd72Sdrh ** cursor with cursor number iTable.
1571e55cbd72Sdrh */
1572e55cbd72Sdrh void sqlite3ExprClearColumnCache(Parse *pParse, int iTable){
1573e55cbd72Sdrh   if( iTable<0 ){
1574e55cbd72Sdrh     pParse->nColCache = 0;
1575e55cbd72Sdrh     pParse->iColCache = 0;
1576e55cbd72Sdrh   }else{
1577e55cbd72Sdrh     int i;
1578e55cbd72Sdrh     for(i=0; i<pParse->nColCache; i++){
1579e55cbd72Sdrh       if( pParse->aColCache[i].iTable==iTable ){
1580c5499befSdrh         testcase( i==pParse->nColCache-1 );
1581e55cbd72Sdrh         pParse->aColCache[i] = pParse->aColCache[--pParse->nColCache];
1582e55cbd72Sdrh         pParse->iColCache = pParse->nColCache;
1583e55cbd72Sdrh       }
1584e55cbd72Sdrh     }
1585da250ea5Sdrh   }
1586da250ea5Sdrh }
1587e55cbd72Sdrh 
1588e55cbd72Sdrh /*
1589da250ea5Sdrh ** Record the fact that an affinity change has occurred on iCount
1590da250ea5Sdrh ** registers starting with iStart.
1591e55cbd72Sdrh */
1592da250ea5Sdrh void sqlite3ExprCacheAffinityChange(Parse *pParse, int iStart, int iCount){
1593da250ea5Sdrh   int iEnd = iStart + iCount - 1;
1594e55cbd72Sdrh   int i;
1595e55cbd72Sdrh   for(i=0; i<pParse->nColCache; i++){
1596e55cbd72Sdrh     int r = pParse->aColCache[i].iReg;
1597da250ea5Sdrh     if( r>=iStart && r<=iEnd ){
1598da250ea5Sdrh       pParse->aColCache[i].affChange = 1;
1599e55cbd72Sdrh     }
1600e55cbd72Sdrh   }
1601e55cbd72Sdrh }
1602e55cbd72Sdrh 
1603e55cbd72Sdrh /*
1604b21e7c70Sdrh ** Generate code to move content from registers iFrom...iFrom+nReg-1
1605b21e7c70Sdrh ** over to iTo..iTo+nReg-1. Keep the column cache up-to-date.
1606e55cbd72Sdrh */
1607b21e7c70Sdrh void sqlite3ExprCodeMove(Parse *pParse, int iFrom, int iTo, int nReg){
1608e55cbd72Sdrh   int i;
1609e55cbd72Sdrh   if( iFrom==iTo ) return;
1610b21e7c70Sdrh   sqlite3VdbeAddOp3(pParse->pVdbe, OP_Move, iFrom, iTo, nReg);
1611e55cbd72Sdrh   for(i=0; i<pParse->nColCache; i++){
1612b21e7c70Sdrh     int x = pParse->aColCache[i].iReg;
1613b21e7c70Sdrh     if( x>=iFrom && x<iFrom+nReg ){
1614b21e7c70Sdrh       pParse->aColCache[i].iReg += iTo-iFrom;
1615e55cbd72Sdrh     }
1616e55cbd72Sdrh   }
1617945498f3Sdrh }
1618945498f3Sdrh 
1619fec19aadSdrh /*
162092b01d53Sdrh ** Generate code to copy content from registers iFrom...iFrom+nReg-1
162192b01d53Sdrh ** over to iTo..iTo+nReg-1.
162292b01d53Sdrh */
162392b01d53Sdrh void sqlite3ExprCodeCopy(Parse *pParse, int iFrom, int iTo, int nReg){
162492b01d53Sdrh   int i;
162592b01d53Sdrh   if( iFrom==iTo ) return;
162692b01d53Sdrh   for(i=0; i<nReg; i++){
162792b01d53Sdrh     sqlite3VdbeAddOp2(pParse->pVdbe, OP_Copy, iFrom+i, iTo+i);
162892b01d53Sdrh   }
162992b01d53Sdrh }
163092b01d53Sdrh 
163192b01d53Sdrh /*
1632652fbf55Sdrh ** Return true if any register in the range iFrom..iTo (inclusive)
1633652fbf55Sdrh ** is used as part of the column cache.
1634652fbf55Sdrh */
1635652fbf55Sdrh static int usedAsColumnCache(Parse *pParse, int iFrom, int iTo){
1636652fbf55Sdrh   int i;
1637652fbf55Sdrh   for(i=0; i<pParse->nColCache; i++){
1638652fbf55Sdrh     int r = pParse->aColCache[i].iReg;
1639652fbf55Sdrh     if( r>=iFrom && r<=iTo ) return 1;
1640652fbf55Sdrh   }
1641652fbf55Sdrh   return 0;
1642652fbf55Sdrh }
1643652fbf55Sdrh 
1644652fbf55Sdrh /*
1645652fbf55Sdrh ** Theres is a value in register iCurrent.  We ultimately want
1646652fbf55Sdrh ** the value to be in register iTarget.  It might be that
1647652fbf55Sdrh ** iCurrent and iTarget are the same register.
1648652fbf55Sdrh **
1649652fbf55Sdrh ** We are going to modify the value, so we need to make sure it
1650652fbf55Sdrh ** is not a cached register.  If iCurrent is a cached register,
1651652fbf55Sdrh ** then try to move the value over to iTarget.  If iTarget is a
1652652fbf55Sdrh ** cached register, then clear the corresponding cache line.
1653652fbf55Sdrh **
1654652fbf55Sdrh ** Return the register that the value ends up in.
1655652fbf55Sdrh */
1656652fbf55Sdrh int sqlite3ExprWritableRegister(Parse *pParse, int iCurrent, int iTarget){
1657da250ea5Sdrh   int i;
1658652fbf55Sdrh   assert( pParse->pVdbe!=0 );
1659652fbf55Sdrh   if( !usedAsColumnCache(pParse, iCurrent, iCurrent) ){
1660652fbf55Sdrh     return iCurrent;
1661652fbf55Sdrh   }
16622f7794c1Sdrh   if( iCurrent!=iTarget ){
1663652fbf55Sdrh     sqlite3VdbeAddOp2(pParse->pVdbe, OP_SCopy, iCurrent, iTarget);
16642f7794c1Sdrh   }
1665da250ea5Sdrh   for(i=0; i<pParse->nColCache; i++){
1666da250ea5Sdrh     if( pParse->aColCache[i].iReg==iTarget ){
1667da250ea5Sdrh       pParse->aColCache[i] = pParse->aColCache[--pParse->nColCache];
1668da250ea5Sdrh       pParse->iColCache = pParse->nColCache;
1669da250ea5Sdrh     }
1670da250ea5Sdrh   }
1671652fbf55Sdrh   return iTarget;
1672652fbf55Sdrh }
1673652fbf55Sdrh 
1674652fbf55Sdrh /*
1675191b54cbSdrh ** If the last instruction coded is an ephemeral copy of any of
1676191b54cbSdrh ** the registers in the nReg registers beginning with iReg, then
1677191b54cbSdrh ** convert the last instruction from OP_SCopy to OP_Copy.
1678191b54cbSdrh */
1679191b54cbSdrh void sqlite3ExprHardCopy(Parse *pParse, int iReg, int nReg){
1680191b54cbSdrh   int addr;
1681191b54cbSdrh   VdbeOp *pOp;
1682191b54cbSdrh   Vdbe *v;
1683191b54cbSdrh 
1684191b54cbSdrh   v = pParse->pVdbe;
1685191b54cbSdrh   addr = sqlite3VdbeCurrentAddr(v);
1686191b54cbSdrh   pOp = sqlite3VdbeGetOp(v, addr-1);
1687d7eb2ed5Sdanielk1977   assert( pOp || pParse->db->mallocFailed );
1688d7eb2ed5Sdanielk1977   if( pOp && pOp->opcode==OP_SCopy && pOp->p1>=iReg && pOp->p1<iReg+nReg ){
1689191b54cbSdrh     pOp->opcode = OP_Copy;
1690191b54cbSdrh   }
1691191b54cbSdrh }
1692191b54cbSdrh 
1693191b54cbSdrh /*
16948b213899Sdrh ** Generate code to store the value of the iAlias-th alias in register
16958b213899Sdrh ** target.  The first time this is called, pExpr is evaluated to compute
16968b213899Sdrh ** the value of the alias.  The value is stored in an auxiliary register
16978b213899Sdrh ** and the number of that register is returned.  On subsequent calls,
16988b213899Sdrh ** the register number is returned without generating any code.
16998b213899Sdrh **
17008b213899Sdrh ** Note that in order for this to work, code must be generated in the
17018b213899Sdrh ** same order that it is executed.
17028b213899Sdrh **
17038b213899Sdrh ** Aliases are numbered starting with 1.  So iAlias is in the range
17048b213899Sdrh ** of 1 to pParse->nAlias inclusive.
17058b213899Sdrh **
17068b213899Sdrh ** pParse->aAlias[iAlias-1] records the register number where the value
17078b213899Sdrh ** of the iAlias-th alias is stored.  If zero, that means that the
17088b213899Sdrh ** alias has not yet been computed.
17098b213899Sdrh */
17108b213899Sdrh static int codeAlias(Parse *pParse, int iAlias, Expr *pExpr){
17118b213899Sdrh   sqlite3 *db = pParse->db;
17128b213899Sdrh   int iReg;
17138b213899Sdrh   if( pParse->aAlias==0 ){
17148b213899Sdrh     pParse->aAlias = sqlite3DbMallocZero(db,
17158b213899Sdrh                                  sizeof(pParse->aAlias[0])*pParse->nAlias );
17168b213899Sdrh     if( db->mallocFailed ) return 0;
17178b213899Sdrh   }
17188b213899Sdrh   assert( iAlias>0 && iAlias<=pParse->nAlias );
17198b213899Sdrh   iReg = pParse->aAlias[iAlias-1];
17208b213899Sdrh   if( iReg==0 ){
17218b213899Sdrh     iReg = ++pParse->nMem;
17228b213899Sdrh     sqlite3ExprCode(pParse, pExpr, iReg);
17238b213899Sdrh     pParse->aAlias[iAlias-1] = iReg;
17248b213899Sdrh   }
17258b213899Sdrh   return iReg;
17268b213899Sdrh }
17278b213899Sdrh 
17288b213899Sdrh /*
1729cce7d176Sdrh ** Generate code into the current Vdbe to evaluate the given
17302dcef11bSdrh ** expression.  Attempt to store the results in register "target".
17312dcef11bSdrh ** Return the register where results are stored.
1732389a1adbSdrh **
17338b213899Sdrh ** With this routine, there is no guarantee that results will
17342dcef11bSdrh ** be stored in target.  The result might be stored in some other
17352dcef11bSdrh ** register if it is convenient to do so.  The calling function
17362dcef11bSdrh ** must check the return code and move the results to the desired
17372dcef11bSdrh ** register.
1738cce7d176Sdrh */
1739678ccce8Sdrh int sqlite3ExprCodeTarget(Parse *pParse, Expr *pExpr, int target){
17402dcef11bSdrh   Vdbe *v = pParse->pVdbe;  /* The VM under construction */
17412dcef11bSdrh   int op;                   /* The opcode being coded */
17422dcef11bSdrh   int inReg = target;       /* Results stored in register inReg */
17432dcef11bSdrh   int regFree1 = 0;         /* If non-zero free this temporary register */
17442dcef11bSdrh   int regFree2 = 0;         /* If non-zero free this temporary register */
1745678ccce8Sdrh   int r1, r2, r3, r4;       /* Various register numbers */
17468b213899Sdrh   sqlite3 *db;
1747ffe07b2dSdrh 
17488b213899Sdrh   db = pParse->db;
17498b213899Sdrh   assert( v!=0 || db->mallocFailed );
17509cbf3425Sdrh   assert( target>0 && target<=pParse->nMem );
1751389a1adbSdrh   if( v==0 ) return 0;
1752389a1adbSdrh 
1753389a1adbSdrh   if( pExpr==0 ){
1754389a1adbSdrh     op = TK_NULL;
1755389a1adbSdrh   }else{
1756f2bc013cSdrh     op = pExpr->op;
1757389a1adbSdrh   }
1758f2bc013cSdrh   switch( op ){
175913449892Sdrh     case TK_AGG_COLUMN: {
176013449892Sdrh       AggInfo *pAggInfo = pExpr->pAggInfo;
176113449892Sdrh       struct AggInfo_col *pCol = &pAggInfo->aCol[pExpr->iAgg];
176213449892Sdrh       if( !pAggInfo->directMode ){
17639de221dfSdrh         assert( pCol->iMem>0 );
17649de221dfSdrh         inReg = pCol->iMem;
176513449892Sdrh         break;
176613449892Sdrh       }else if( pAggInfo->useSortingIdx ){
1767389a1adbSdrh         sqlite3VdbeAddOp3(v, OP_Column, pAggInfo->sortingIdx,
1768389a1adbSdrh                               pCol->iSorterColumn, target);
176913449892Sdrh         break;
177013449892Sdrh       }
177113449892Sdrh       /* Otherwise, fall thru into the TK_COLUMN case */
177213449892Sdrh     }
1773967e8b73Sdrh     case TK_COLUMN: {
1774ffe07b2dSdrh       if( pExpr->iTable<0 ){
1775ffe07b2dSdrh         /* This only happens when coding check constraints */
1776aa9b8963Sdrh         assert( pParse->ckBase>0 );
1777aa9b8963Sdrh         inReg = pExpr->iColumn + pParse->ckBase;
1778c4a3c779Sdrh       }else{
1779c5499befSdrh         testcase( (pExpr->flags & EP_AnyAff)!=0 );
1780e55cbd72Sdrh         inReg = sqlite3ExprCodeGetColumn(pParse, pExpr->pTab,
1781da250ea5Sdrh                                  pExpr->iColumn, pExpr->iTable, target,
1782da250ea5Sdrh                                  pExpr->flags & EP_AnyAff);
17832282792aSdrh       }
1784cce7d176Sdrh       break;
1785cce7d176Sdrh     }
1786cce7d176Sdrh     case TK_INTEGER: {
178792b01d53Sdrh       codeInteger(v, pExpr, 0, target);
1788fec19aadSdrh       break;
178951e9a445Sdrh     }
1790598f1340Sdrh     case TK_FLOAT: {
17919de221dfSdrh       codeReal(v, (char*)pExpr->token.z, pExpr->token.n, 0, target);
1792598f1340Sdrh       break;
1793598f1340Sdrh     }
1794fec19aadSdrh     case TK_STRING: {
17958b213899Sdrh       sqlite3DequoteExpr(db, pExpr);
17969de221dfSdrh       sqlite3VdbeAddOp4(v,OP_String8, 0, target, 0,
179766a5167bSdrh                         (char*)pExpr->token.z, pExpr->token.n);
1798cce7d176Sdrh       break;
1799cce7d176Sdrh     }
1800f0863fe5Sdrh     case TK_NULL: {
18019de221dfSdrh       sqlite3VdbeAddOp2(v, OP_Null, 0, target);
1802f0863fe5Sdrh       break;
1803f0863fe5Sdrh     }
18045338a5f7Sdanielk1977 #ifndef SQLITE_OMIT_BLOB_LITERAL
1805c572ef7fSdanielk1977     case TK_BLOB: {
18066c8c6cecSdrh       int n;
18076c8c6cecSdrh       const char *z;
1808ca48c90fSdrh       char *zBlob;
1809ca48c90fSdrh       assert( pExpr->token.n>=3 );
1810ca48c90fSdrh       assert( pExpr->token.z[0]=='x' || pExpr->token.z[0]=='X' );
1811ca48c90fSdrh       assert( pExpr->token.z[1]=='\'' );
1812ca48c90fSdrh       assert( pExpr->token.z[pExpr->token.n-1]=='\'' );
18136c8c6cecSdrh       n = pExpr->token.n - 3;
18142646da7eSdrh       z = (char*)pExpr->token.z + 2;
1815ca48c90fSdrh       zBlob = sqlite3HexToBlob(sqlite3VdbeDb(v), z, n);
1816ca48c90fSdrh       sqlite3VdbeAddOp4(v, OP_Blob, n/2, target, 0, zBlob, P4_DYNAMIC);
1817c572ef7fSdanielk1977       break;
1818c572ef7fSdanielk1977     }
18195338a5f7Sdanielk1977 #endif
182050457896Sdrh     case TK_VARIABLE: {
18219de221dfSdrh       sqlite3VdbeAddOp2(v, OP_Variable, pExpr->iTable, target);
1822895d7472Sdrh       if( pExpr->token.n>1 ){
182366a5167bSdrh         sqlite3VdbeChangeP4(v, -1, (char*)pExpr->token.z, pExpr->token.n);
1824895d7472Sdrh       }
182550457896Sdrh       break;
182650457896Sdrh     }
18274e0cff60Sdrh     case TK_REGISTER: {
18289de221dfSdrh       inReg = pExpr->iTable;
18294e0cff60Sdrh       break;
18304e0cff60Sdrh     }
18318b213899Sdrh     case TK_AS: {
18328b213899Sdrh       inReg = codeAlias(pParse, pExpr->iTable, pExpr->pLeft);
18338b213899Sdrh       break;
18348b213899Sdrh     }
1835487e262fSdrh #ifndef SQLITE_OMIT_CAST
1836487e262fSdrh     case TK_CAST: {
1837487e262fSdrh       /* Expressions of the form:   CAST(pLeft AS token) */
1838f0113000Sdanielk1977       int aff, to_op;
18392dcef11bSdrh       inReg = sqlite3ExprCodeTarget(pParse, pExpr->pLeft, target);
18408a51256cSdrh       aff = sqlite3AffinityType(&pExpr->token);
1841f0113000Sdanielk1977       to_op = aff - SQLITE_AFF_TEXT + OP_ToText;
1842f0113000Sdanielk1977       assert( to_op==OP_ToText    || aff!=SQLITE_AFF_TEXT    );
1843f0113000Sdanielk1977       assert( to_op==OP_ToBlob    || aff!=SQLITE_AFF_NONE    );
1844f0113000Sdanielk1977       assert( to_op==OP_ToNumeric || aff!=SQLITE_AFF_NUMERIC );
1845f0113000Sdanielk1977       assert( to_op==OP_ToInt     || aff!=SQLITE_AFF_INTEGER );
1846f0113000Sdanielk1977       assert( to_op==OP_ToReal    || aff!=SQLITE_AFF_REAL    );
1847c5499befSdrh       testcase( to_op==OP_ToText );
1848c5499befSdrh       testcase( to_op==OP_ToBlob );
1849c5499befSdrh       testcase( to_op==OP_ToNumeric );
1850c5499befSdrh       testcase( to_op==OP_ToInt );
1851c5499befSdrh       testcase( to_op==OP_ToReal );
18522dcef11bSdrh       sqlite3VdbeAddOp1(v, to_op, inReg);
1853c5499befSdrh       testcase( usedAsColumnCache(pParse, inReg, inReg) );
1854b3843a82Sdrh       sqlite3ExprCacheAffinityChange(pParse, inReg, 1);
1855487e262fSdrh       break;
1856487e262fSdrh     }
1857487e262fSdrh #endif /* SQLITE_OMIT_CAST */
1858c9b84a1fSdrh     case TK_LT:
1859c9b84a1fSdrh     case TK_LE:
1860c9b84a1fSdrh     case TK_GT:
1861c9b84a1fSdrh     case TK_GE:
1862c9b84a1fSdrh     case TK_NE:
1863c9b84a1fSdrh     case TK_EQ: {
1864f2bc013cSdrh       assert( TK_LT==OP_Lt );
1865f2bc013cSdrh       assert( TK_LE==OP_Le );
1866f2bc013cSdrh       assert( TK_GT==OP_Gt );
1867f2bc013cSdrh       assert( TK_GE==OP_Ge );
1868f2bc013cSdrh       assert( TK_EQ==OP_Eq );
1869f2bc013cSdrh       assert( TK_NE==OP_Ne );
1870c5499befSdrh       testcase( op==TK_LT );
1871c5499befSdrh       testcase( op==TK_LE );
1872c5499befSdrh       testcase( op==TK_GT );
1873c5499befSdrh       testcase( op==TK_GE );
1874c5499befSdrh       testcase( op==TK_EQ );
1875c5499befSdrh       testcase( op==TK_NE );
1876da250ea5Sdrh       codeCompareOperands(pParse, pExpr->pLeft, &r1, &regFree1,
1877da250ea5Sdrh                                   pExpr->pRight, &r2, &regFree2);
187835573356Sdrh       codeCompare(pParse, pExpr->pLeft, pExpr->pRight, op,
187935573356Sdrh                   r1, r2, inReg, SQLITE_STOREP2);
1880c5499befSdrh       testcase( regFree1==0 );
1881c5499befSdrh       testcase( regFree2==0 );
1882a37cdde0Sdanielk1977       break;
1883c9b84a1fSdrh     }
1884cce7d176Sdrh     case TK_AND:
1885cce7d176Sdrh     case TK_OR:
1886cce7d176Sdrh     case TK_PLUS:
1887cce7d176Sdrh     case TK_STAR:
1888cce7d176Sdrh     case TK_MINUS:
1889bf4133cbSdrh     case TK_REM:
1890bf4133cbSdrh     case TK_BITAND:
1891bf4133cbSdrh     case TK_BITOR:
189217c40294Sdrh     case TK_SLASH:
1893bf4133cbSdrh     case TK_LSHIFT:
1894855eb1cfSdrh     case TK_RSHIFT:
18950040077dSdrh     case TK_CONCAT: {
1896f2bc013cSdrh       assert( TK_AND==OP_And );
1897f2bc013cSdrh       assert( TK_OR==OP_Or );
1898f2bc013cSdrh       assert( TK_PLUS==OP_Add );
1899f2bc013cSdrh       assert( TK_MINUS==OP_Subtract );
1900f2bc013cSdrh       assert( TK_REM==OP_Remainder );
1901f2bc013cSdrh       assert( TK_BITAND==OP_BitAnd );
1902f2bc013cSdrh       assert( TK_BITOR==OP_BitOr );
1903f2bc013cSdrh       assert( TK_SLASH==OP_Divide );
1904f2bc013cSdrh       assert( TK_LSHIFT==OP_ShiftLeft );
1905f2bc013cSdrh       assert( TK_RSHIFT==OP_ShiftRight );
1906f2bc013cSdrh       assert( TK_CONCAT==OP_Concat );
1907c5499befSdrh       testcase( op==TK_AND );
1908c5499befSdrh       testcase( op==TK_OR );
1909c5499befSdrh       testcase( op==TK_PLUS );
1910c5499befSdrh       testcase( op==TK_MINUS );
1911c5499befSdrh       testcase( op==TK_REM );
1912c5499befSdrh       testcase( op==TK_BITAND );
1913c5499befSdrh       testcase( op==TK_BITOR );
1914c5499befSdrh       testcase( op==TK_SLASH );
1915c5499befSdrh       testcase( op==TK_LSHIFT );
1916c5499befSdrh       testcase( op==TK_RSHIFT );
1917c5499befSdrh       testcase( op==TK_CONCAT );
19182dcef11bSdrh       r1 = sqlite3ExprCodeTemp(pParse, pExpr->pLeft, &regFree1);
19192dcef11bSdrh       r2 = sqlite3ExprCodeTemp(pParse, pExpr->pRight, &regFree2);
19205b6afba9Sdrh       sqlite3VdbeAddOp3(v, op, r2, r1, target);
1921c5499befSdrh       testcase( regFree1==0 );
1922c5499befSdrh       testcase( regFree2==0 );
19230040077dSdrh       break;
19240040077dSdrh     }
1925cce7d176Sdrh     case TK_UMINUS: {
1926fec19aadSdrh       Expr *pLeft = pExpr->pLeft;
1927fec19aadSdrh       assert( pLeft );
1928fec19aadSdrh       if( pLeft->op==TK_FLOAT || pLeft->op==TK_INTEGER ){
1929fec19aadSdrh         if( pLeft->op==TK_FLOAT ){
193092b01d53Sdrh           codeReal(v, (char*)pLeft->token.z, pLeft->token.n, 1, target);
1931e6840900Sdrh         }else{
193292b01d53Sdrh           codeInteger(v, pLeft, 1, target);
1933e6840900Sdrh         }
19343c84ddffSdrh       }else{
19352dcef11bSdrh         regFree1 = r1 = sqlite3GetTempReg(pParse);
19363c84ddffSdrh         sqlite3VdbeAddOp2(v, OP_Integer, 0, r1);
1937e55cbd72Sdrh         r2 = sqlite3ExprCodeTemp(pParse, pExpr->pLeft, &regFree2);
19382dcef11bSdrh         sqlite3VdbeAddOp3(v, OP_Subtract, r2, r1, target);
1939c5499befSdrh         testcase( regFree2==0 );
19403c84ddffSdrh       }
19419de221dfSdrh       inReg = target;
19426e142f54Sdrh       break;
19436e142f54Sdrh     }
1944bf4133cbSdrh     case TK_BITNOT:
19456e142f54Sdrh     case TK_NOT: {
1946f2bc013cSdrh       assert( TK_BITNOT==OP_BitNot );
1947f2bc013cSdrh       assert( TK_NOT==OP_Not );
1948c5499befSdrh       testcase( op==TK_BITNOT );
1949c5499befSdrh       testcase( op==TK_NOT );
19502dcef11bSdrh       inReg = sqlite3ExprCodeTarget(pParse, pExpr->pLeft, target);
1951c5499befSdrh       testcase( inReg==target );
1952c5499befSdrh       testcase( usedAsColumnCache(pParse, inReg, inReg) );
1953652fbf55Sdrh       inReg = sqlite3ExprWritableRegister(pParse, inReg, target);
19542dcef11bSdrh       sqlite3VdbeAddOp1(v, op, inReg);
1955cce7d176Sdrh       break;
1956cce7d176Sdrh     }
1957cce7d176Sdrh     case TK_ISNULL:
1958cce7d176Sdrh     case TK_NOTNULL: {
19596a288a33Sdrh       int addr;
1960f2bc013cSdrh       assert( TK_ISNULL==OP_IsNull );
1961f2bc013cSdrh       assert( TK_NOTNULL==OP_NotNull );
1962c5499befSdrh       testcase( op==TK_ISNULL );
1963c5499befSdrh       testcase( op==TK_NOTNULL );
19649de221dfSdrh       sqlite3VdbeAddOp2(v, OP_Integer, 1, target);
19652dcef11bSdrh       r1 = sqlite3ExprCodeTemp(pParse, pExpr->pLeft, &regFree1);
1966c5499befSdrh       testcase( regFree1==0 );
19672dcef11bSdrh       addr = sqlite3VdbeAddOp1(v, op, r1);
19689de221dfSdrh       sqlite3VdbeAddOp2(v, OP_AddImm, target, -1);
19696a288a33Sdrh       sqlite3VdbeJumpHere(v, addr);
1970a37cdde0Sdanielk1977       break;
1971f2bc013cSdrh     }
19722282792aSdrh     case TK_AGG_FUNCTION: {
197313449892Sdrh       AggInfo *pInfo = pExpr->pAggInfo;
19747e56e711Sdrh       if( pInfo==0 ){
19757e56e711Sdrh         sqlite3ErrorMsg(pParse, "misuse of aggregate: %T",
19767e56e711Sdrh             &pExpr->span);
19777e56e711Sdrh       }else{
19789de221dfSdrh         inReg = pInfo->aFunc[pExpr->iAgg].iMem;
19797e56e711Sdrh       }
19802282792aSdrh       break;
19812282792aSdrh     }
1982b71090fdSdrh     case TK_CONST_FUNC:
1983cce7d176Sdrh     case TK_FUNCTION: {
1984cce7d176Sdrh       ExprList *pList = pExpr->pList;
198589425d5eSdrh       int nExpr = pList ? pList->nExpr : 0;
19860bce8354Sdrh       FuncDef *pDef;
19874b59ab5eSdrh       int nId;
19884b59ab5eSdrh       const char *zId;
198913449892Sdrh       int constMask = 0;
1990682f68b0Sdanielk1977       int i;
199117435752Sdrh       u8 enc = ENC(db);
1992dc1bdc4fSdanielk1977       CollSeq *pColl = 0;
199317435752Sdrh 
1994c5499befSdrh       testcase( op==TK_CONST_FUNC );
1995c5499befSdrh       testcase( op==TK_FUNCTION );
19962646da7eSdrh       zId = (char*)pExpr->token.z;
1997b71090fdSdrh       nId = pExpr->token.n;
19988b213899Sdrh       pDef = sqlite3FindFunction(db, zId, nId, nExpr, enc, 0);
19990bce8354Sdrh       assert( pDef!=0 );
2000892d3179Sdrh       if( pList ){
2001892d3179Sdrh         nExpr = pList->nExpr;
20022dcef11bSdrh         r1 = sqlite3GetTempRange(pParse, nExpr);
2003191b54cbSdrh         sqlite3ExprCodeExprList(pParse, pList, r1, 1);
2004892d3179Sdrh       }else{
2005d847eaadSdrh         nExpr = r1 = 0;
2006892d3179Sdrh       }
2007b7f6f68fSdrh #ifndef SQLITE_OMIT_VIRTUALTABLE
2008a43fa227Sdrh       /* Possibly overload the function if the first argument is
2009a43fa227Sdrh       ** a virtual table column.
2010a43fa227Sdrh       **
2011a43fa227Sdrh       ** For infix functions (LIKE, GLOB, REGEXP, and MATCH) use the
2012a43fa227Sdrh       ** second argument, not the first, as the argument to test to
2013a43fa227Sdrh       ** see if it is a column in a virtual table.  This is done because
2014a43fa227Sdrh       ** the left operand of infix functions (the operand we want to
2015a43fa227Sdrh       ** control overloading) ends up as the second argument to the
2016a43fa227Sdrh       ** function.  The expression "A glob B" is equivalent to
2017a43fa227Sdrh       ** "glob(B,A).  We want to use the A in "A glob B" to test
2018a43fa227Sdrh       ** for function overloading.  But we use the B term in "glob(B,A)".
2019a43fa227Sdrh       */
20206a03a1c5Sdrh       if( nExpr>=2 && (pExpr->flags & EP_InfixFunc) ){
202117435752Sdrh         pDef = sqlite3VtabOverloadFunction(db, pDef, nExpr, pList->a[1].pExpr);
20226a03a1c5Sdrh       }else if( nExpr>0 ){
202317435752Sdrh         pDef = sqlite3VtabOverloadFunction(db, pDef, nExpr, pList->a[0].pExpr);
2024b7f6f68fSdrh       }
2025b7f6f68fSdrh #endif
2026682f68b0Sdanielk1977       for(i=0; i<nExpr && i<32; i++){
2027d02eb1fdSdanielk1977         if( sqlite3ExprIsConstant(pList->a[i].pExpr) ){
202813449892Sdrh           constMask |= (1<<i);
2029d02eb1fdSdanielk1977         }
2030dc1bdc4fSdanielk1977         if( pDef->needCollSeq && !pColl ){
2031dc1bdc4fSdanielk1977           pColl = sqlite3ExprCollSeq(pParse, pList->a[i].pExpr);
2032dc1bdc4fSdanielk1977         }
2033dc1bdc4fSdanielk1977       }
2034dc1bdc4fSdanielk1977       if( pDef->needCollSeq ){
20358b213899Sdrh         if( !pColl ) pColl = db->pDfltColl;
203666a5167bSdrh         sqlite3VdbeAddOp4(v, OP_CollSeq, 0, 0, 0, (char *)pColl, P4_COLLSEQ);
2037682f68b0Sdanielk1977       }
20382dcef11bSdrh       sqlite3VdbeAddOp4(v, OP_Function, constMask, r1, target,
203966a5167bSdrh                         (char*)pDef, P4_FUNCDEF);
204098757157Sdrh       sqlite3VdbeChangeP5(v, nExpr);
20412dcef11bSdrh       if( nExpr ){
20422dcef11bSdrh         sqlite3ReleaseTempRange(pParse, r1, nExpr);
20432dcef11bSdrh       }
2044da250ea5Sdrh       sqlite3ExprCacheAffinityChange(pParse, r1, nExpr);
20456ec2733bSdrh       break;
20466ec2733bSdrh     }
2047fe2093d7Sdrh #ifndef SQLITE_OMIT_SUBQUERY
2048fe2093d7Sdrh     case TK_EXISTS:
204919a775c2Sdrh     case TK_SELECT: {
2050c5499befSdrh       testcase( op==TK_EXISTS );
2051c5499befSdrh       testcase( op==TK_SELECT );
205241714d6fSdrh       if( pExpr->iColumn==0 ){
205341a05b7bSdanielk1977         sqlite3CodeSubselect(pParse, pExpr, 0, 0);
205441714d6fSdrh       }
20559de221dfSdrh       inReg = pExpr->iColumn;
205619a775c2Sdrh       break;
205719a775c2Sdrh     }
2058fef5208cSdrh     case TK_IN: {
20590cdc022eSdanielk1977       int rNotFound = 0;
20600cdc022eSdanielk1977       int rMayHaveNull = 0;
20616fccc35aSdrh       int j2, j3, j4, j5;
206294a11211Sdrh       char affinity;
20639a96b668Sdanielk1977       int eType;
20649a96b668Sdanielk1977 
20653c31fc23Sdrh       VdbeNoopComment((v, "begin IN expr r%d", target));
20660cdc022eSdanielk1977       eType = sqlite3FindInIndex(pParse, pExpr, &rMayHaveNull);
20670cdc022eSdanielk1977       if( rMayHaveNull ){
20680cdc022eSdanielk1977         rNotFound = ++pParse->nMem;
20690cdc022eSdanielk1977       }
2070e014a838Sdanielk1977 
2071e014a838Sdanielk1977       /* Figure out the affinity to use to create a key from the results
2072e014a838Sdanielk1977       ** of the expression. affinityStr stores a static string suitable for
207366a5167bSdrh       ** P4 of OP_MakeRecord.
2074e014a838Sdanielk1977       */
207594a11211Sdrh       affinity = comparisonAffinity(pExpr);
2076e014a838Sdanielk1977 
2077e014a838Sdanielk1977 
2078e014a838Sdanielk1977       /* Code the <expr> from "<expr> IN (...)". The temporary table
2079e014a838Sdanielk1977       ** pExpr->iTable contains the values that make up the (...) set.
2080e014a838Sdanielk1977       */
208166ba23ceSdrh       pParse->disableColCache++;
208266ba23ceSdrh       sqlite3ExprCode(pParse, pExpr->pLeft, target);
208366ba23ceSdrh       pParse->disableColCache--;
208466ba23ceSdrh       j2 = sqlite3VdbeAddOp1(v, OP_IsNull, target);
20859a96b668Sdanielk1977       if( eType==IN_INDEX_ROWID ){
208666ba23ceSdrh         j3 = sqlite3VdbeAddOp1(v, OP_MustBeInt, target);
208766ba23ceSdrh         j4 = sqlite3VdbeAddOp3(v, OP_NotExists, pExpr->iTable, 0, target);
208866ba23ceSdrh         sqlite3VdbeAddOp2(v, OP_Integer, 1, target);
20896a288a33Sdrh         j5 = sqlite3VdbeAddOp0(v, OP_Goto);
20906a288a33Sdrh         sqlite3VdbeJumpHere(v, j3);
20916a288a33Sdrh         sqlite3VdbeJumpHere(v, j4);
20920cdc022eSdanielk1977         sqlite3VdbeAddOp2(v, OP_Integer, 0, target);
20939a96b668Sdanielk1977       }else{
20942dcef11bSdrh         r2 = regFree2 = sqlite3GetTempReg(pParse);
20950cdc022eSdanielk1977 
20960cdc022eSdanielk1977         /* Create a record and test for set membership. If the set contains
20970cdc022eSdanielk1977         ** the value, then jump to the end of the test code. The target
20980cdc022eSdanielk1977         ** register still contains the true (1) value written to it earlier.
20990cdc022eSdanielk1977         */
210066ba23ceSdrh         sqlite3VdbeAddOp4(v, OP_MakeRecord, target, 1, r2, &affinity, 1);
210166ba23ceSdrh         sqlite3VdbeAddOp2(v, OP_Integer, 1, target);
21022dcef11bSdrh         j5 = sqlite3VdbeAddOp3(v, OP_Found, pExpr->iTable, 0, r2);
21030cdc022eSdanielk1977 
21040cdc022eSdanielk1977         /* If the set membership test fails, then the result of the
21050cdc022eSdanielk1977         ** "x IN (...)" expression must be either 0 or NULL. If the set
21060cdc022eSdanielk1977         ** contains no NULL values, then the result is 0. If the set
21070cdc022eSdanielk1977         ** contains one or more NULL values, then the result of the
21080cdc022eSdanielk1977         ** expression is also NULL.
21090cdc022eSdanielk1977         */
21100cdc022eSdanielk1977         if( rNotFound==0 ){
21110cdc022eSdanielk1977           /* This branch runs if it is known at compile time (now) that
21120cdc022eSdanielk1977           ** the set contains no NULL values. This happens as the result
21130cdc022eSdanielk1977           ** of a "NOT NULL" constraint in the database schema. No need
21140cdc022eSdanielk1977           ** to test the data structure at runtime in this case.
21150cdc022eSdanielk1977           */
21160cdc022eSdanielk1977           sqlite3VdbeAddOp2(v, OP_Integer, 0, target);
21170cdc022eSdanielk1977         }else{
21180cdc022eSdanielk1977           /* This block populates the rNotFound register with either NULL
21190cdc022eSdanielk1977           ** or 0 (an integer value). If the data structure contains one
21200cdc022eSdanielk1977           ** or more NULLs, then set rNotFound to NULL. Otherwise, set it
21210cdc022eSdanielk1977           ** to 0. If register rMayHaveNull is already set to some value
21220cdc022eSdanielk1977           ** other than NULL, then the test has already been run and
21230cdc022eSdanielk1977           ** rNotFound is already populated.
21240cdc022eSdanielk1977           */
212566ba23ceSdrh           static const char nullRecord[] = { 0x02, 0x00 };
21260cdc022eSdanielk1977           j3 = sqlite3VdbeAddOp1(v, OP_NotNull, rMayHaveNull);
21270cdc022eSdanielk1977           sqlite3VdbeAddOp2(v, OP_Null, 0, rNotFound);
212866ba23ceSdrh           sqlite3VdbeAddOp4(v, OP_Blob, 2, rMayHaveNull, 0,
212966ba23ceSdrh                              nullRecord, P4_STATIC);
213066ba23ceSdrh           j4 = sqlite3VdbeAddOp3(v, OP_Found, pExpr->iTable, 0, rMayHaveNull);
21310cdc022eSdanielk1977           sqlite3VdbeAddOp2(v, OP_Integer, 0, rNotFound);
21320cdc022eSdanielk1977           sqlite3VdbeJumpHere(v, j4);
21330cdc022eSdanielk1977           sqlite3VdbeJumpHere(v, j3);
21340cdc022eSdanielk1977 
21350cdc022eSdanielk1977           /* Copy the value of register rNotFound (which is either NULL or 0)
21360cdc022eSdanielk1977           ** into the target register. This will be the result of the
21370cdc022eSdanielk1977           ** expression.
21380cdc022eSdanielk1977           */
21390cdc022eSdanielk1977           sqlite3VdbeAddOp2(v, OP_Copy, rNotFound, target);
21409a96b668Sdanielk1977         }
21410cdc022eSdanielk1977       }
21426a288a33Sdrh       sqlite3VdbeJumpHere(v, j2);
21436a288a33Sdrh       sqlite3VdbeJumpHere(v, j5);
21443c31fc23Sdrh       VdbeComment((v, "end IN expr r%d", target));
2145fef5208cSdrh       break;
2146fef5208cSdrh     }
214793758c8dSdanielk1977 #endif
21482dcef11bSdrh     /*
21492dcef11bSdrh     **    x BETWEEN y AND z
21502dcef11bSdrh     **
21512dcef11bSdrh     ** This is equivalent to
21522dcef11bSdrh     **
21532dcef11bSdrh     **    x>=y AND x<=z
21542dcef11bSdrh     **
21552dcef11bSdrh     ** X is stored in pExpr->pLeft.
21562dcef11bSdrh     ** Y is stored in pExpr->pList->a[0].pExpr.
21572dcef11bSdrh     ** Z is stored in pExpr->pList->a[1].pExpr.
21582dcef11bSdrh     */
2159fef5208cSdrh     case TK_BETWEEN: {
2160be5c89acSdrh       Expr *pLeft = pExpr->pLeft;
2161be5c89acSdrh       struct ExprList_item *pLItem = pExpr->pList->a;
2162be5c89acSdrh       Expr *pRight = pLItem->pExpr;
216335573356Sdrh 
2164da250ea5Sdrh       codeCompareOperands(pParse, pLeft, &r1, &regFree1,
2165da250ea5Sdrh                                   pRight, &r2, &regFree2);
2166c5499befSdrh       testcase( regFree1==0 );
2167c5499befSdrh       testcase( regFree2==0 );
21682dcef11bSdrh       r3 = sqlite3GetTempReg(pParse);
2169678ccce8Sdrh       r4 = sqlite3GetTempReg(pParse);
217035573356Sdrh       codeCompare(pParse, pLeft, pRight, OP_Ge,
217135573356Sdrh                   r1, r2, r3, SQLITE_STOREP2);
2172be5c89acSdrh       pLItem++;
2173be5c89acSdrh       pRight = pLItem->pExpr;
21742dcef11bSdrh       sqlite3ReleaseTempReg(pParse, regFree2);
21752dcef11bSdrh       r2 = sqlite3ExprCodeTemp(pParse, pRight, &regFree2);
2176c5499befSdrh       testcase( regFree2==0 );
2177678ccce8Sdrh       codeCompare(pParse, pLeft, pRight, OP_Le, r1, r2, r4, SQLITE_STOREP2);
2178678ccce8Sdrh       sqlite3VdbeAddOp3(v, OP_And, r3, r4, target);
21792dcef11bSdrh       sqlite3ReleaseTempReg(pParse, r3);
2180678ccce8Sdrh       sqlite3ReleaseTempReg(pParse, r4);
2181fef5208cSdrh       break;
2182fef5208cSdrh     }
21834f07e5fbSdrh     case TK_UPLUS: {
21842dcef11bSdrh       inReg = sqlite3ExprCodeTarget(pParse, pExpr->pLeft, target);
2185a2e00042Sdrh       break;
2186a2e00042Sdrh     }
21872dcef11bSdrh 
21882dcef11bSdrh     /*
21892dcef11bSdrh     ** Form A:
21902dcef11bSdrh     **   CASE x WHEN e1 THEN r1 WHEN e2 THEN r2 ... WHEN eN THEN rN ELSE y END
21912dcef11bSdrh     **
21922dcef11bSdrh     ** Form B:
21932dcef11bSdrh     **   CASE WHEN e1 THEN r1 WHEN e2 THEN r2 ... WHEN eN THEN rN ELSE y END
21942dcef11bSdrh     **
21952dcef11bSdrh     ** Form A is can be transformed into the equivalent form B as follows:
21962dcef11bSdrh     **   CASE WHEN x=e1 THEN r1 WHEN x=e2 THEN r2 ...
21972dcef11bSdrh     **        WHEN x=eN THEN rN ELSE y END
21982dcef11bSdrh     **
21992dcef11bSdrh     ** X (if it exists) is in pExpr->pLeft.
22002dcef11bSdrh     ** Y is in pExpr->pRight.  The Y is also optional.  If there is no
22012dcef11bSdrh     ** ELSE clause and no other term matches, then the result of the
22022dcef11bSdrh     ** exprssion is NULL.
22032dcef11bSdrh     ** Ei is in pExpr->pList->a[i*2] and Ri is pExpr->pList->a[i*2+1].
22042dcef11bSdrh     **
22052dcef11bSdrh     ** The result of the expression is the Ri for the first matching Ei,
22062dcef11bSdrh     ** or if there is no matching Ei, the ELSE term Y, or if there is
22072dcef11bSdrh     ** no ELSE term, NULL.
22082dcef11bSdrh     */
220917a7f8ddSdrh     case TK_CASE: {
22102dcef11bSdrh       int endLabel;                     /* GOTO label for end of CASE stmt */
22112dcef11bSdrh       int nextCase;                     /* GOTO label for next WHEN clause */
22122dcef11bSdrh       int nExpr;                        /* 2x number of WHEN terms */
22132dcef11bSdrh       int i;                            /* Loop counter */
22142dcef11bSdrh       ExprList *pEList;                 /* List of WHEN terms */
22152dcef11bSdrh       struct ExprList_item *aListelem;  /* Array of WHEN terms */
22162dcef11bSdrh       Expr opCompare;                   /* The X==Ei expression */
22172dcef11bSdrh       Expr cacheX;                      /* Cached expression X */
22182dcef11bSdrh       Expr *pX;                         /* The X expression */
22192dcef11bSdrh       Expr *pTest;                      /* X==Ei (form A) or just Ei (form B) */
222017a7f8ddSdrh 
222117a7f8ddSdrh       assert(pExpr->pList);
222217a7f8ddSdrh       assert((pExpr->pList->nExpr % 2) == 0);
222317a7f8ddSdrh       assert(pExpr->pList->nExpr > 0);
2224be5c89acSdrh       pEList = pExpr->pList;
2225be5c89acSdrh       aListelem = pEList->a;
2226be5c89acSdrh       nExpr = pEList->nExpr;
22272dcef11bSdrh       endLabel = sqlite3VdbeMakeLabel(v);
22282dcef11bSdrh       if( (pX = pExpr->pLeft)!=0 ){
22292dcef11bSdrh         cacheX = *pX;
2230c5499befSdrh         testcase( pX->op==TK_COLUMN || pX->op==TK_REGISTER );
22312dcef11bSdrh         cacheX.iTable = sqlite3ExprCodeTemp(pParse, pX, &regFree1);
2232c5499befSdrh         testcase( regFree1==0 );
22332dcef11bSdrh         cacheX.op = TK_REGISTER;
22342dcef11bSdrh         opCompare.op = TK_EQ;
22352dcef11bSdrh         opCompare.pLeft = &cacheX;
22362dcef11bSdrh         pTest = &opCompare;
2237cce7d176Sdrh       }
2238c5499befSdrh       pParse->disableColCache++;
2239f5905aa7Sdrh       for(i=0; i<nExpr; i=i+2){
22402dcef11bSdrh         if( pX ){
22412dcef11bSdrh           opCompare.pRight = aListelem[i].pExpr;
2242f5905aa7Sdrh         }else{
22432dcef11bSdrh           pTest = aListelem[i].pExpr;
224417a7f8ddSdrh         }
22452dcef11bSdrh         nextCase = sqlite3VdbeMakeLabel(v);
2246c5499befSdrh         testcase( pTest->op==TK_COLUMN || pTest->op==TK_REGISTER );
22472dcef11bSdrh         sqlite3ExprIfFalse(pParse, pTest, nextCase, SQLITE_JUMPIFNULL);
2248c5499befSdrh         testcase( aListelem[i+1].pExpr->op==TK_COLUMN );
2249c5499befSdrh         testcase( aListelem[i+1].pExpr->op==TK_REGISTER );
22509de221dfSdrh         sqlite3ExprCode(pParse, aListelem[i+1].pExpr, target);
22512dcef11bSdrh         sqlite3VdbeAddOp2(v, OP_Goto, 0, endLabel);
22522dcef11bSdrh         sqlite3VdbeResolveLabel(v, nextCase);
2253f570f011Sdrh       }
225417a7f8ddSdrh       if( pExpr->pRight ){
22559de221dfSdrh         sqlite3ExprCode(pParse, pExpr->pRight, target);
225617a7f8ddSdrh       }else{
22579de221dfSdrh         sqlite3VdbeAddOp2(v, OP_Null, 0, target);
225817a7f8ddSdrh       }
22592dcef11bSdrh       sqlite3VdbeResolveLabel(v, endLabel);
2260c5499befSdrh       assert( pParse->disableColCache>0 );
2261c5499befSdrh       pParse->disableColCache--;
22626f34903eSdanielk1977       break;
22636f34903eSdanielk1977     }
22645338a5f7Sdanielk1977 #ifndef SQLITE_OMIT_TRIGGER
22656f34903eSdanielk1977     case TK_RAISE: {
22666f34903eSdanielk1977       if( !pParse->trigStack ){
22674adee20fSdanielk1977         sqlite3ErrorMsg(pParse,
2268da93d238Sdrh                        "RAISE() may only be used within a trigger-program");
2269389a1adbSdrh         return 0;
22706f34903eSdanielk1977       }
2271ad6d9460Sdrh       if( pExpr->iColumn!=OE_Ignore ){
2272ad6d9460Sdrh          assert( pExpr->iColumn==OE_Rollback ||
22736f34903eSdanielk1977                  pExpr->iColumn == OE_Abort ||
2274ad6d9460Sdrh                  pExpr->iColumn == OE_Fail );
22758b213899Sdrh          sqlite3DequoteExpr(db, pExpr);
227666a5167bSdrh          sqlite3VdbeAddOp4(v, OP_Halt, SQLITE_CONSTRAINT, pExpr->iColumn, 0,
22772646da7eSdrh                         (char*)pExpr->token.z, pExpr->token.n);
22786f34903eSdanielk1977       } else {
22796f34903eSdanielk1977          assert( pExpr->iColumn == OE_Ignore );
228066a5167bSdrh          sqlite3VdbeAddOp2(v, OP_ContextPop, 0, 0);
228166a5167bSdrh          sqlite3VdbeAddOp2(v, OP_Goto, 0, pParse->trigStack->ignoreJump);
2282d4e70ebdSdrh          VdbeComment((v, "raise(IGNORE)"));
22836f34903eSdanielk1977       }
2284ffe07b2dSdrh       break;
228517a7f8ddSdrh     }
22865338a5f7Sdanielk1977 #endif
2287ffe07b2dSdrh   }
22882dcef11bSdrh   sqlite3ReleaseTempReg(pParse, regFree1);
22892dcef11bSdrh   sqlite3ReleaseTempReg(pParse, regFree2);
22902dcef11bSdrh   return inReg;
22915b6afba9Sdrh }
22922dcef11bSdrh 
22932dcef11bSdrh /*
22942dcef11bSdrh ** Generate code to evaluate an expression and store the results
22952dcef11bSdrh ** into a register.  Return the register number where the results
22962dcef11bSdrh ** are stored.
22972dcef11bSdrh **
22982dcef11bSdrh ** If the register is a temporary register that can be deallocated,
2299678ccce8Sdrh ** then write its number into *pReg.  If the result register is not
23002dcef11bSdrh ** a temporary, then set *pReg to zero.
23012dcef11bSdrh */
23022dcef11bSdrh int sqlite3ExprCodeTemp(Parse *pParse, Expr *pExpr, int *pReg){
23032dcef11bSdrh   int r1 = sqlite3GetTempReg(pParse);
23042dcef11bSdrh   int r2 = sqlite3ExprCodeTarget(pParse, pExpr, r1);
23052dcef11bSdrh   if( r2==r1 ){
23062dcef11bSdrh     *pReg = r1;
23072dcef11bSdrh   }else{
23082dcef11bSdrh     sqlite3ReleaseTempReg(pParse, r1);
23092dcef11bSdrh     *pReg = 0;
23102dcef11bSdrh   }
23112dcef11bSdrh   return r2;
23122dcef11bSdrh }
23132dcef11bSdrh 
23142dcef11bSdrh /*
23152dcef11bSdrh ** Generate code that will evaluate expression pExpr and store the
23162dcef11bSdrh ** results in register target.  The results are guaranteed to appear
23172dcef11bSdrh ** in register target.
23182dcef11bSdrh */
23192dcef11bSdrh int sqlite3ExprCode(Parse *pParse, Expr *pExpr, int target){
23209cbf3425Sdrh   int inReg;
23219cbf3425Sdrh 
23229cbf3425Sdrh   assert( target>0 && target<=pParse->nMem );
23239cbf3425Sdrh   inReg = sqlite3ExprCodeTarget(pParse, pExpr, target);
23240e359b30Sdrh   assert( pParse->pVdbe || pParse->db->mallocFailed );
23250e359b30Sdrh   if( inReg!=target && pParse->pVdbe ){
23269cbf3425Sdrh     sqlite3VdbeAddOp2(pParse->pVdbe, OP_SCopy, inReg, target);
232717a7f8ddSdrh   }
2328389a1adbSdrh   return target;
2329cce7d176Sdrh }
2330cce7d176Sdrh 
2331cce7d176Sdrh /*
23322dcef11bSdrh ** Generate code that evalutes the given expression and puts the result
2333de4fcfddSdrh ** in register target.
233425303780Sdrh **
23352dcef11bSdrh ** Also make a copy of the expression results into another "cache" register
23362dcef11bSdrh ** and modify the expression so that the next time it is evaluated,
23372dcef11bSdrh ** the result is a copy of the cache register.
23382dcef11bSdrh **
23392dcef11bSdrh ** This routine is used for expressions that are used multiple
23402dcef11bSdrh ** times.  They are evaluated once and the results of the expression
23412dcef11bSdrh ** are reused.
234225303780Sdrh */
23432dcef11bSdrh int sqlite3ExprCodeAndCache(Parse *pParse, Expr *pExpr, int target){
234425303780Sdrh   Vdbe *v = pParse->pVdbe;
23452dcef11bSdrh   int inReg;
23462dcef11bSdrh   inReg = sqlite3ExprCode(pParse, pExpr, target);
2347de4fcfddSdrh   assert( target>0 );
23482dcef11bSdrh   if( pExpr->op!=TK_REGISTER ){
234925303780Sdrh     int iMem;
23502dcef11bSdrh     iMem = ++pParse->nMem;
23512dcef11bSdrh     sqlite3VdbeAddOp2(v, OP_Copy, inReg, iMem);
23522dcef11bSdrh     pExpr->iTable = iMem;
235325303780Sdrh     pExpr->op = TK_REGISTER;
235425303780Sdrh   }
23552dcef11bSdrh   return inReg;
235625303780Sdrh }
23572dcef11bSdrh 
2358678ccce8Sdrh /*
235947de955eSdrh ** Return TRUE if pExpr is an constant expression that is appropriate
236047de955eSdrh ** for factoring out of a loop.  Appropriate expressions are:
236147de955eSdrh **
236247de955eSdrh **    *  Any expression that evaluates to two or more opcodes.
236347de955eSdrh **
236447de955eSdrh **    *  Any OP_Integer, OP_Real, OP_String, OP_Blob, OP_Null,
236547de955eSdrh **       or OP_Variable that does not need to be placed in a
236647de955eSdrh **       specific register.
236747de955eSdrh **
236847de955eSdrh ** There is no point in factoring out single-instruction constant
236947de955eSdrh ** expressions that need to be placed in a particular register.
237047de955eSdrh ** We could factor them out, but then we would end up adding an
237147de955eSdrh ** OP_SCopy instruction to move the value into the correct register
237247de955eSdrh ** later.  We might as well just use the original instruction and
237347de955eSdrh ** avoid the OP_SCopy.
237447de955eSdrh */
237547de955eSdrh static int isAppropriateForFactoring(Expr *p){
237647de955eSdrh   if( !sqlite3ExprIsConstantNotJoin(p) ){
237747de955eSdrh     return 0;  /* Only constant expressions are appropriate for factoring */
237847de955eSdrh   }
237947de955eSdrh   if( (p->flags & EP_FixedDest)==0 ){
238047de955eSdrh     return 1;  /* Any constant without a fixed destination is appropriate */
238147de955eSdrh   }
238247de955eSdrh   while( p->op==TK_UPLUS ) p = p->pLeft;
238347de955eSdrh   switch( p->op ){
238447de955eSdrh #ifndef SQLITE_OMIT_BLOB_LITERAL
238547de955eSdrh     case TK_BLOB:
238647de955eSdrh #endif
238747de955eSdrh     case TK_VARIABLE:
238847de955eSdrh     case TK_INTEGER:
238947de955eSdrh     case TK_FLOAT:
239047de955eSdrh     case TK_NULL:
239147de955eSdrh     case TK_STRING: {
239247de955eSdrh       testcase( p->op==TK_BLOB );
239347de955eSdrh       testcase( p->op==TK_VARIABLE );
239447de955eSdrh       testcase( p->op==TK_INTEGER );
239547de955eSdrh       testcase( p->op==TK_FLOAT );
239647de955eSdrh       testcase( p->op==TK_NULL );
239747de955eSdrh       testcase( p->op==TK_STRING );
239847de955eSdrh       /* Single-instruction constants with a fixed destination are
239947de955eSdrh       ** better done in-line.  If we factor them, they will just end
240047de955eSdrh       ** up generating an OP_SCopy to move the value to the destination
240147de955eSdrh       ** register. */
240247de955eSdrh       return 0;
240347de955eSdrh     }
240447de955eSdrh     case TK_UMINUS: {
240547de955eSdrh        if( p->pLeft->op==TK_FLOAT || p->pLeft->op==TK_INTEGER ){
240647de955eSdrh          return 0;
240747de955eSdrh        }
240847de955eSdrh        break;
240947de955eSdrh     }
241047de955eSdrh     default: {
241147de955eSdrh       break;
241247de955eSdrh     }
241347de955eSdrh   }
241447de955eSdrh   return 1;
241547de955eSdrh }
241647de955eSdrh 
241747de955eSdrh /*
241847de955eSdrh ** If pExpr is a constant expression that is appropriate for
241947de955eSdrh ** factoring out of a loop, then evaluate the expression
2420678ccce8Sdrh ** into a register and convert the expression into a TK_REGISTER
2421678ccce8Sdrh ** expression.
2422678ccce8Sdrh */
24237d10d5a6Sdrh static int evalConstExpr(Walker *pWalker, Expr *pExpr){
24247d10d5a6Sdrh   Parse *pParse = pWalker->pParse;
242547de955eSdrh   switch( pExpr->op ){
242647de955eSdrh     case TK_REGISTER: {
2427678ccce8Sdrh       return 1;
2428678ccce8Sdrh     }
242947de955eSdrh     case TK_FUNCTION:
243047de955eSdrh     case TK_AGG_FUNCTION:
243147de955eSdrh     case TK_CONST_FUNC: {
243247de955eSdrh       /* The arguments to a function have a fixed destination.
243347de955eSdrh       ** Mark them this way to avoid generated unneeded OP_SCopy
243447de955eSdrh       ** instructions.
243547de955eSdrh       */
243647de955eSdrh       ExprList *pList = pExpr->pList;
243747de955eSdrh       if( pList ){
243847de955eSdrh         int i = pList->nExpr;
243947de955eSdrh         struct ExprList_item *pItem = pList->a;
244047de955eSdrh         for(; i>0; i--, pItem++){
244147de955eSdrh           if( pItem->pExpr ) pItem->pExpr->flags |= EP_FixedDest;
244247de955eSdrh         }
244347de955eSdrh       }
244447de955eSdrh       break;
244547de955eSdrh     }
244647de955eSdrh   }
244747de955eSdrh   if( isAppropriateForFactoring(pExpr) ){
2448678ccce8Sdrh     int r1 = ++pParse->nMem;
2449678ccce8Sdrh     int r2;
2450678ccce8Sdrh     r2 = sqlite3ExprCodeTarget(pParse, pExpr, r1);
2451c5499befSdrh     if( r1!=r2 ) sqlite3ReleaseTempReg(pParse, r1);
2452678ccce8Sdrh     pExpr->op = TK_REGISTER;
2453678ccce8Sdrh     pExpr->iTable = r2;
24547d10d5a6Sdrh     return WRC_Prune;
2455678ccce8Sdrh   }
24567d10d5a6Sdrh   return WRC_Continue;
2457678ccce8Sdrh }
2458678ccce8Sdrh 
2459678ccce8Sdrh /*
2460678ccce8Sdrh ** Preevaluate constant subexpressions within pExpr and store the
2461678ccce8Sdrh ** results in registers.  Modify pExpr so that the constant subexpresions
2462678ccce8Sdrh ** are TK_REGISTER opcodes that refer to the precomputed values.
2463678ccce8Sdrh */
2464678ccce8Sdrh void sqlite3ExprCodeConstants(Parse *pParse, Expr *pExpr){
24657d10d5a6Sdrh   Walker w;
24667d10d5a6Sdrh   w.xExprCallback = evalConstExpr;
24677d10d5a6Sdrh   w.xSelectCallback = 0;
24687d10d5a6Sdrh   w.pParse = pParse;
24697d10d5a6Sdrh   sqlite3WalkExpr(&w, pExpr);
2470678ccce8Sdrh }
2471678ccce8Sdrh 
247225303780Sdrh 
247325303780Sdrh /*
2474268380caSdrh ** Generate code that pushes the value of every element of the given
24759cbf3425Sdrh ** expression list into a sequence of registers beginning at target.
2476268380caSdrh **
2477892d3179Sdrh ** Return the number of elements evaluated.
2478268380caSdrh */
24794adee20fSdanielk1977 int sqlite3ExprCodeExprList(
2480268380caSdrh   Parse *pParse,     /* Parsing context */
2481389a1adbSdrh   ExprList *pList,   /* The expression list to be coded */
2482191b54cbSdrh   int target,        /* Where to write results */
2483d176611bSdrh   int doHardCopy     /* Make a hard copy of every element */
2484268380caSdrh ){
2485268380caSdrh   struct ExprList_item *pItem;
24869cbf3425Sdrh   int i, n;
24879d8b3072Sdrh   assert( pList!=0 );
24889cbf3425Sdrh   assert( target>0 );
2489268380caSdrh   n = pList->nExpr;
2490191b54cbSdrh   for(pItem=pList->a, i=0; i<n; i++, pItem++){
24918b213899Sdrh     if( pItem->iAlias ){
24928b213899Sdrh       int iReg = codeAlias(pParse, pItem->iAlias, pItem->pExpr);
24938b213899Sdrh       Vdbe *v = sqlite3GetVdbe(pParse);
24948b213899Sdrh       sqlite3VdbeAddOp2(v, OP_SCopy, iReg, target+i);
2495d176611bSdrh     }else{
2496191b54cbSdrh       sqlite3ExprCode(pParse, pItem->pExpr, target+i);
24978b213899Sdrh     }
2498d176611bSdrh     if( doHardCopy ){
2499d176611bSdrh       sqlite3ExprHardCopy(pParse, target, n);
2500d176611bSdrh     }
2501268380caSdrh   }
2502f9b596ebSdrh   return n;
2503268380caSdrh }
2504268380caSdrh 
2505268380caSdrh /*
2506cce7d176Sdrh ** Generate code for a boolean expression such that a jump is made
2507cce7d176Sdrh ** to the label "dest" if the expression is true but execution
2508cce7d176Sdrh ** continues straight thru if the expression is false.
2509f5905aa7Sdrh **
2510f5905aa7Sdrh ** If the expression evaluates to NULL (neither true nor false), then
251135573356Sdrh ** take the jump if the jumpIfNull flag is SQLITE_JUMPIFNULL.
2512f2bc013cSdrh **
2513f2bc013cSdrh ** This code depends on the fact that certain token values (ex: TK_EQ)
2514f2bc013cSdrh ** are the same as opcode values (ex: OP_Eq) that implement the corresponding
2515f2bc013cSdrh ** operation.  Special comments in vdbe.c and the mkopcodeh.awk script in
2516f2bc013cSdrh ** the make process cause these values to align.  Assert()s in the code
2517f2bc013cSdrh ** below verify that the numbers are aligned correctly.
2518cce7d176Sdrh */
25194adee20fSdanielk1977 void sqlite3ExprIfTrue(Parse *pParse, Expr *pExpr, int dest, int jumpIfNull){
2520cce7d176Sdrh   Vdbe *v = pParse->pVdbe;
2521cce7d176Sdrh   int op = 0;
25222dcef11bSdrh   int regFree1 = 0;
25232dcef11bSdrh   int regFree2 = 0;
25242dcef11bSdrh   int r1, r2;
25252dcef11bSdrh 
252635573356Sdrh   assert( jumpIfNull==SQLITE_JUMPIFNULL || jumpIfNull==0 );
2527daffd0e5Sdrh   if( v==0 || pExpr==0 ) return;
2528f2bc013cSdrh   op = pExpr->op;
2529f2bc013cSdrh   switch( op ){
2530cce7d176Sdrh     case TK_AND: {
25314adee20fSdanielk1977       int d2 = sqlite3VdbeMakeLabel(v);
2532c5499befSdrh       testcase( jumpIfNull==0 );
2533c5499befSdrh       testcase( pParse->disableColCache==0 );
253435573356Sdrh       sqlite3ExprIfFalse(pParse, pExpr->pLeft, d2,jumpIfNull^SQLITE_JUMPIFNULL);
2535e55cbd72Sdrh       pParse->disableColCache++;
25364adee20fSdanielk1977       sqlite3ExprIfTrue(pParse, pExpr->pRight, dest, jumpIfNull);
2537c5499befSdrh       assert( pParse->disableColCache>0 );
2538e55cbd72Sdrh       pParse->disableColCache--;
25394adee20fSdanielk1977       sqlite3VdbeResolveLabel(v, d2);
2540cce7d176Sdrh       break;
2541cce7d176Sdrh     }
2542cce7d176Sdrh     case TK_OR: {
2543c5499befSdrh       testcase( jumpIfNull==0 );
2544c5499befSdrh       testcase( pParse->disableColCache==0 );
25454adee20fSdanielk1977       sqlite3ExprIfTrue(pParse, pExpr->pLeft, dest, jumpIfNull);
2546e55cbd72Sdrh       pParse->disableColCache++;
25474adee20fSdanielk1977       sqlite3ExprIfTrue(pParse, pExpr->pRight, dest, jumpIfNull);
2548c5499befSdrh       assert( pParse->disableColCache>0 );
2549e55cbd72Sdrh       pParse->disableColCache--;
2550cce7d176Sdrh       break;
2551cce7d176Sdrh     }
2552cce7d176Sdrh     case TK_NOT: {
2553c5499befSdrh       testcase( jumpIfNull==0 );
25544adee20fSdanielk1977       sqlite3ExprIfFalse(pParse, pExpr->pLeft, dest, jumpIfNull);
2555cce7d176Sdrh       break;
2556cce7d176Sdrh     }
2557cce7d176Sdrh     case TK_LT:
2558cce7d176Sdrh     case TK_LE:
2559cce7d176Sdrh     case TK_GT:
2560cce7d176Sdrh     case TK_GE:
2561cce7d176Sdrh     case TK_NE:
25620ac65892Sdrh     case TK_EQ: {
2563f2bc013cSdrh       assert( TK_LT==OP_Lt );
2564f2bc013cSdrh       assert( TK_LE==OP_Le );
2565f2bc013cSdrh       assert( TK_GT==OP_Gt );
2566f2bc013cSdrh       assert( TK_GE==OP_Ge );
2567f2bc013cSdrh       assert( TK_EQ==OP_Eq );
2568f2bc013cSdrh       assert( TK_NE==OP_Ne );
2569c5499befSdrh       testcase( op==TK_LT );
2570c5499befSdrh       testcase( op==TK_LE );
2571c5499befSdrh       testcase( op==TK_GT );
2572c5499befSdrh       testcase( op==TK_GE );
2573c5499befSdrh       testcase( op==TK_EQ );
2574c5499befSdrh       testcase( op==TK_NE );
2575c5499befSdrh       testcase( jumpIfNull==0 );
2576da250ea5Sdrh       codeCompareOperands(pParse, pExpr->pLeft, &r1, &regFree1,
2577da250ea5Sdrh                                   pExpr->pRight, &r2, &regFree2);
257835573356Sdrh       codeCompare(pParse, pExpr->pLeft, pExpr->pRight, op,
25792dcef11bSdrh                   r1, r2, dest, jumpIfNull);
2580c5499befSdrh       testcase( regFree1==0 );
2581c5499befSdrh       testcase( regFree2==0 );
2582cce7d176Sdrh       break;
2583cce7d176Sdrh     }
2584cce7d176Sdrh     case TK_ISNULL:
2585cce7d176Sdrh     case TK_NOTNULL: {
2586f2bc013cSdrh       assert( TK_ISNULL==OP_IsNull );
2587f2bc013cSdrh       assert( TK_NOTNULL==OP_NotNull );
2588c5499befSdrh       testcase( op==TK_ISNULL );
2589c5499befSdrh       testcase( op==TK_NOTNULL );
25902dcef11bSdrh       r1 = sqlite3ExprCodeTemp(pParse, pExpr->pLeft, &regFree1);
25912dcef11bSdrh       sqlite3VdbeAddOp2(v, op, r1, dest);
2592c5499befSdrh       testcase( regFree1==0 );
2593cce7d176Sdrh       break;
2594cce7d176Sdrh     }
2595fef5208cSdrh     case TK_BETWEEN: {
25962dcef11bSdrh       /*    x BETWEEN y AND z
25970202b29eSdanielk1977       **
25982dcef11bSdrh       ** Is equivalent to
25992dcef11bSdrh       **
26002dcef11bSdrh       **    x>=y AND x<=z
26012dcef11bSdrh       **
26022dcef11bSdrh       ** Code it as such, taking care to do the common subexpression
26032dcef11bSdrh       ** elementation of x.
26040202b29eSdanielk1977       */
26052dcef11bSdrh       Expr exprAnd;
26062dcef11bSdrh       Expr compLeft;
26072dcef11bSdrh       Expr compRight;
26082dcef11bSdrh       Expr exprX;
26090202b29eSdanielk1977 
26102dcef11bSdrh       exprX = *pExpr->pLeft;
26112dcef11bSdrh       exprAnd.op = TK_AND;
26122dcef11bSdrh       exprAnd.pLeft = &compLeft;
26132dcef11bSdrh       exprAnd.pRight = &compRight;
26142dcef11bSdrh       compLeft.op = TK_GE;
26152dcef11bSdrh       compLeft.pLeft = &exprX;
26162dcef11bSdrh       compLeft.pRight = pExpr->pList->a[0].pExpr;
26172dcef11bSdrh       compRight.op = TK_LE;
26182dcef11bSdrh       compRight.pLeft = &exprX;
26192dcef11bSdrh       compRight.pRight = pExpr->pList->a[1].pExpr;
26202dcef11bSdrh       exprX.iTable = sqlite3ExprCodeTemp(pParse, &exprX, &regFree1);
2621c5499befSdrh       testcase( regFree1==0 );
26222dcef11bSdrh       exprX.op = TK_REGISTER;
2623c5499befSdrh       testcase( jumpIfNull==0 );
26242dcef11bSdrh       sqlite3ExprIfTrue(pParse, &exprAnd, dest, jumpIfNull);
2625fef5208cSdrh       break;
2626fef5208cSdrh     }
2627cce7d176Sdrh     default: {
26282dcef11bSdrh       r1 = sqlite3ExprCodeTemp(pParse, pExpr, &regFree1);
26292dcef11bSdrh       sqlite3VdbeAddOp3(v, OP_If, r1, dest, jumpIfNull!=0);
2630c5499befSdrh       testcase( regFree1==0 );
2631c5499befSdrh       testcase( jumpIfNull==0 );
2632cce7d176Sdrh       break;
2633cce7d176Sdrh     }
2634cce7d176Sdrh   }
26352dcef11bSdrh   sqlite3ReleaseTempReg(pParse, regFree1);
26362dcef11bSdrh   sqlite3ReleaseTempReg(pParse, regFree2);
2637cce7d176Sdrh }
2638cce7d176Sdrh 
2639cce7d176Sdrh /*
264066b89c8fSdrh ** Generate code for a boolean expression such that a jump is made
2641cce7d176Sdrh ** to the label "dest" if the expression is false but execution
2642cce7d176Sdrh ** continues straight thru if the expression is true.
2643f5905aa7Sdrh **
2644f5905aa7Sdrh ** If the expression evaluates to NULL (neither true nor false) then
264535573356Sdrh ** jump if jumpIfNull is SQLITE_JUMPIFNULL or fall through if jumpIfNull
264635573356Sdrh ** is 0.
2647cce7d176Sdrh */
26484adee20fSdanielk1977 void sqlite3ExprIfFalse(Parse *pParse, Expr *pExpr, int dest, int jumpIfNull){
2649cce7d176Sdrh   Vdbe *v = pParse->pVdbe;
2650cce7d176Sdrh   int op = 0;
26512dcef11bSdrh   int regFree1 = 0;
26522dcef11bSdrh   int regFree2 = 0;
26532dcef11bSdrh   int r1, r2;
26542dcef11bSdrh 
265535573356Sdrh   assert( jumpIfNull==SQLITE_JUMPIFNULL || jumpIfNull==0 );
2656daffd0e5Sdrh   if( v==0 || pExpr==0 ) return;
2657f2bc013cSdrh 
2658f2bc013cSdrh   /* The value of pExpr->op and op are related as follows:
2659f2bc013cSdrh   **
2660f2bc013cSdrh   **       pExpr->op            op
2661f2bc013cSdrh   **       ---------          ----------
2662f2bc013cSdrh   **       TK_ISNULL          OP_NotNull
2663f2bc013cSdrh   **       TK_NOTNULL         OP_IsNull
2664f2bc013cSdrh   **       TK_NE              OP_Eq
2665f2bc013cSdrh   **       TK_EQ              OP_Ne
2666f2bc013cSdrh   **       TK_GT              OP_Le
2667f2bc013cSdrh   **       TK_LE              OP_Gt
2668f2bc013cSdrh   **       TK_GE              OP_Lt
2669f2bc013cSdrh   **       TK_LT              OP_Ge
2670f2bc013cSdrh   **
2671f2bc013cSdrh   ** For other values of pExpr->op, op is undefined and unused.
2672f2bc013cSdrh   ** The value of TK_ and OP_ constants are arranged such that we
2673f2bc013cSdrh   ** can compute the mapping above using the following expression.
2674f2bc013cSdrh   ** Assert()s verify that the computation is correct.
2675f2bc013cSdrh   */
2676f2bc013cSdrh   op = ((pExpr->op+(TK_ISNULL&1))^1)-(TK_ISNULL&1);
2677f2bc013cSdrh 
2678f2bc013cSdrh   /* Verify correct alignment of TK_ and OP_ constants
2679f2bc013cSdrh   */
2680f2bc013cSdrh   assert( pExpr->op!=TK_ISNULL || op==OP_NotNull );
2681f2bc013cSdrh   assert( pExpr->op!=TK_NOTNULL || op==OP_IsNull );
2682f2bc013cSdrh   assert( pExpr->op!=TK_NE || op==OP_Eq );
2683f2bc013cSdrh   assert( pExpr->op!=TK_EQ || op==OP_Ne );
2684f2bc013cSdrh   assert( pExpr->op!=TK_LT || op==OP_Ge );
2685f2bc013cSdrh   assert( pExpr->op!=TK_LE || op==OP_Gt );
2686f2bc013cSdrh   assert( pExpr->op!=TK_GT || op==OP_Le );
2687f2bc013cSdrh   assert( pExpr->op!=TK_GE || op==OP_Lt );
2688f2bc013cSdrh 
2689cce7d176Sdrh   switch( pExpr->op ){
2690cce7d176Sdrh     case TK_AND: {
2691c5499befSdrh       testcase( jumpIfNull==0 );
2692c5499befSdrh       testcase( pParse->disableColCache==0 );
26934adee20fSdanielk1977       sqlite3ExprIfFalse(pParse, pExpr->pLeft, dest, jumpIfNull);
2694e55cbd72Sdrh       pParse->disableColCache++;
26954adee20fSdanielk1977       sqlite3ExprIfFalse(pParse, pExpr->pRight, dest, jumpIfNull);
2696c5499befSdrh       assert( pParse->disableColCache>0 );
2697e55cbd72Sdrh       pParse->disableColCache--;
2698cce7d176Sdrh       break;
2699cce7d176Sdrh     }
2700cce7d176Sdrh     case TK_OR: {
27014adee20fSdanielk1977       int d2 = sqlite3VdbeMakeLabel(v);
2702c5499befSdrh       testcase( jumpIfNull==0 );
2703c5499befSdrh       testcase( pParse->disableColCache==0 );
270435573356Sdrh       sqlite3ExprIfTrue(pParse, pExpr->pLeft, d2, jumpIfNull^SQLITE_JUMPIFNULL);
2705e55cbd72Sdrh       pParse->disableColCache++;
27064adee20fSdanielk1977       sqlite3ExprIfFalse(pParse, pExpr->pRight, dest, jumpIfNull);
2707c5499befSdrh       assert( pParse->disableColCache>0 );
2708e55cbd72Sdrh       pParse->disableColCache--;
27094adee20fSdanielk1977       sqlite3VdbeResolveLabel(v, d2);
2710cce7d176Sdrh       break;
2711cce7d176Sdrh     }
2712cce7d176Sdrh     case TK_NOT: {
27134adee20fSdanielk1977       sqlite3ExprIfTrue(pParse, pExpr->pLeft, dest, jumpIfNull);
2714cce7d176Sdrh       break;
2715cce7d176Sdrh     }
2716cce7d176Sdrh     case TK_LT:
2717cce7d176Sdrh     case TK_LE:
2718cce7d176Sdrh     case TK_GT:
2719cce7d176Sdrh     case TK_GE:
2720cce7d176Sdrh     case TK_NE:
2721cce7d176Sdrh     case TK_EQ: {
2722c5499befSdrh       testcase( op==TK_LT );
2723c5499befSdrh       testcase( op==TK_LE );
2724c5499befSdrh       testcase( op==TK_GT );
2725c5499befSdrh       testcase( op==TK_GE );
2726c5499befSdrh       testcase( op==TK_EQ );
2727c5499befSdrh       testcase( op==TK_NE );
2728c5499befSdrh       testcase( jumpIfNull==0 );
2729da250ea5Sdrh       codeCompareOperands(pParse, pExpr->pLeft, &r1, &regFree1,
2730da250ea5Sdrh                                   pExpr->pRight, &r2, &regFree2);
273135573356Sdrh       codeCompare(pParse, pExpr->pLeft, pExpr->pRight, op,
27322dcef11bSdrh                   r1, r2, dest, jumpIfNull);
2733c5499befSdrh       testcase( regFree1==0 );
2734c5499befSdrh       testcase( regFree2==0 );
2735cce7d176Sdrh       break;
2736cce7d176Sdrh     }
2737cce7d176Sdrh     case TK_ISNULL:
2738cce7d176Sdrh     case TK_NOTNULL: {
2739c5499befSdrh       testcase( op==TK_ISNULL );
2740c5499befSdrh       testcase( op==TK_NOTNULL );
27412dcef11bSdrh       r1 = sqlite3ExprCodeTemp(pParse, pExpr->pLeft, &regFree1);
27422dcef11bSdrh       sqlite3VdbeAddOp2(v, op, r1, dest);
2743c5499befSdrh       testcase( regFree1==0 );
2744cce7d176Sdrh       break;
2745cce7d176Sdrh     }
2746fef5208cSdrh     case TK_BETWEEN: {
27472dcef11bSdrh       /*    x BETWEEN y AND z
27480202b29eSdanielk1977       **
27492dcef11bSdrh       ** Is equivalent to
27502dcef11bSdrh       **
27512dcef11bSdrh       **    x>=y AND x<=z
27522dcef11bSdrh       **
27532dcef11bSdrh       ** Code it as such, taking care to do the common subexpression
27542dcef11bSdrh       ** elementation of x.
27550202b29eSdanielk1977       */
27562dcef11bSdrh       Expr exprAnd;
27572dcef11bSdrh       Expr compLeft;
27582dcef11bSdrh       Expr compRight;
27592dcef11bSdrh       Expr exprX;
2760be5c89acSdrh 
27612dcef11bSdrh       exprX = *pExpr->pLeft;
27622dcef11bSdrh       exprAnd.op = TK_AND;
27632dcef11bSdrh       exprAnd.pLeft = &compLeft;
27642dcef11bSdrh       exprAnd.pRight = &compRight;
27652dcef11bSdrh       compLeft.op = TK_GE;
27662dcef11bSdrh       compLeft.pLeft = &exprX;
27672dcef11bSdrh       compLeft.pRight = pExpr->pList->a[0].pExpr;
27682dcef11bSdrh       compRight.op = TK_LE;
27692dcef11bSdrh       compRight.pLeft = &exprX;
27702dcef11bSdrh       compRight.pRight = pExpr->pList->a[1].pExpr;
27712dcef11bSdrh       exprX.iTable = sqlite3ExprCodeTemp(pParse, &exprX, &regFree1);
2772c5499befSdrh       testcase( regFree1==0 );
27732dcef11bSdrh       exprX.op = TK_REGISTER;
2774c5499befSdrh       testcase( jumpIfNull==0 );
27752dcef11bSdrh       sqlite3ExprIfFalse(pParse, &exprAnd, dest, jumpIfNull);
2776fef5208cSdrh       break;
2777fef5208cSdrh     }
2778cce7d176Sdrh     default: {
27792dcef11bSdrh       r1 = sqlite3ExprCodeTemp(pParse, pExpr, &regFree1);
27802dcef11bSdrh       sqlite3VdbeAddOp3(v, OP_IfNot, r1, dest, jumpIfNull!=0);
2781c5499befSdrh       testcase( regFree1==0 );
2782c5499befSdrh       testcase( jumpIfNull==0 );
2783cce7d176Sdrh       break;
2784cce7d176Sdrh     }
2785cce7d176Sdrh   }
27862dcef11bSdrh   sqlite3ReleaseTempReg(pParse, regFree1);
27872dcef11bSdrh   sqlite3ReleaseTempReg(pParse, regFree2);
2788cce7d176Sdrh }
27892282792aSdrh 
27902282792aSdrh /*
27912282792aSdrh ** Do a deep comparison of two expression trees.  Return TRUE (non-zero)
27922282792aSdrh ** if they are identical and return FALSE if they differ in any way.
2793d40aab0eSdrh **
2794d40aab0eSdrh ** Sometimes this routine will return FALSE even if the two expressions
2795d40aab0eSdrh ** really are equivalent.  If we cannot prove that the expressions are
2796d40aab0eSdrh ** identical, we return FALSE just to be safe.  So if this routine
2797d40aab0eSdrh ** returns false, then you do not really know for certain if the two
2798d40aab0eSdrh ** expressions are the same.  But if you get a TRUE return, then you
2799d40aab0eSdrh ** can be sure the expressions are the same.  In the places where
2800d40aab0eSdrh ** this routine is used, it does not hurt to get an extra FALSE - that
2801d40aab0eSdrh ** just might result in some slightly slower code.  But returning
2802d40aab0eSdrh ** an incorrect TRUE could lead to a malfunction.
28032282792aSdrh */
28044adee20fSdanielk1977 int sqlite3ExprCompare(Expr *pA, Expr *pB){
28052282792aSdrh   int i;
28064b202ae2Sdanielk1977   if( pA==0||pB==0 ){
28074b202ae2Sdanielk1977     return pB==pA;
28082282792aSdrh   }
28092282792aSdrh   if( pA->op!=pB->op ) return 0;
2810fd357974Sdrh   if( (pA->flags & EP_Distinct)!=(pB->flags & EP_Distinct) ) return 0;
28114adee20fSdanielk1977   if( !sqlite3ExprCompare(pA->pLeft, pB->pLeft) ) return 0;
28124adee20fSdanielk1977   if( !sqlite3ExprCompare(pA->pRight, pB->pRight) ) return 0;
28132282792aSdrh   if( pA->pList ){
28142282792aSdrh     if( pB->pList==0 ) return 0;
28152282792aSdrh     if( pA->pList->nExpr!=pB->pList->nExpr ) return 0;
28162282792aSdrh     for(i=0; i<pA->pList->nExpr; i++){
28174adee20fSdanielk1977       if( !sqlite3ExprCompare(pA->pList->a[i].pExpr, pB->pList->a[i].pExpr) ){
28182282792aSdrh         return 0;
28192282792aSdrh       }
28202282792aSdrh     }
28212282792aSdrh   }else if( pB->pList ){
28222282792aSdrh     return 0;
28232282792aSdrh   }
28242282792aSdrh   if( pA->pSelect || pB->pSelect ) return 0;
28252f2c01e5Sdrh   if( pA->iTable!=pB->iTable || pA->iColumn!=pB->iColumn ) return 0;
2826dd73521bSdrh   if( pA->op!=TK_COLUMN && pA->token.z ){
28272282792aSdrh     if( pB->token.z==0 ) return 0;
28286977fea8Sdrh     if( pB->token.n!=pA->token.n ) return 0;
28292646da7eSdrh     if( sqlite3StrNICmp((char*)pA->token.z,(char*)pB->token.z,pB->token.n)!=0 ){
28302646da7eSdrh       return 0;
28312646da7eSdrh     }
28322282792aSdrh   }
28332282792aSdrh   return 1;
28342282792aSdrh }
28352282792aSdrh 
283613449892Sdrh 
28372282792aSdrh /*
283813449892Sdrh ** Add a new element to the pAggInfo->aCol[] array.  Return the index of
283913449892Sdrh ** the new element.  Return a negative number if malloc fails.
28402282792aSdrh */
284117435752Sdrh static int addAggInfoColumn(sqlite3 *db, AggInfo *pInfo){
284213449892Sdrh   int i;
2843cf643729Sdrh   pInfo->aCol = sqlite3ArrayAllocate(
284417435752Sdrh        db,
2845cf643729Sdrh        pInfo->aCol,
2846cf643729Sdrh        sizeof(pInfo->aCol[0]),
2847cf643729Sdrh        3,
2848cf643729Sdrh        &pInfo->nColumn,
2849cf643729Sdrh        &pInfo->nColumnAlloc,
2850cf643729Sdrh        &i
2851cf643729Sdrh   );
285213449892Sdrh   return i;
28532282792aSdrh }
285413449892Sdrh 
285513449892Sdrh /*
285613449892Sdrh ** Add a new element to the pAggInfo->aFunc[] array.  Return the index of
285713449892Sdrh ** the new element.  Return a negative number if malloc fails.
285813449892Sdrh */
285917435752Sdrh static int addAggInfoFunc(sqlite3 *db, AggInfo *pInfo){
286013449892Sdrh   int i;
2861cf643729Sdrh   pInfo->aFunc = sqlite3ArrayAllocate(
286217435752Sdrh        db,
2863cf643729Sdrh        pInfo->aFunc,
2864cf643729Sdrh        sizeof(pInfo->aFunc[0]),
2865cf643729Sdrh        3,
2866cf643729Sdrh        &pInfo->nFunc,
2867cf643729Sdrh        &pInfo->nFuncAlloc,
2868cf643729Sdrh        &i
2869cf643729Sdrh   );
287013449892Sdrh   return i;
28712282792aSdrh }
28722282792aSdrh 
28732282792aSdrh /*
28747d10d5a6Sdrh ** This is the xExprCallback for a tree walker.  It is used to
28757d10d5a6Sdrh ** implement sqlite3ExprAnalyzeAggregates().  See sqlite3ExprAnalyzeAggregates
2876626a879aSdrh ** for additional information.
28772282792aSdrh */
28787d10d5a6Sdrh static int analyzeAggregate(Walker *pWalker, Expr *pExpr){
28792282792aSdrh   int i;
28807d10d5a6Sdrh   NameContext *pNC = pWalker->u.pNC;
2881a58fdfb1Sdanielk1977   Parse *pParse = pNC->pParse;
2882a58fdfb1Sdanielk1977   SrcList *pSrcList = pNC->pSrcList;
288313449892Sdrh   AggInfo *pAggInfo = pNC->pAggInfo;
288413449892Sdrh 
28852282792aSdrh   switch( pExpr->op ){
288689c69d00Sdrh     case TK_AGG_COLUMN:
2887967e8b73Sdrh     case TK_COLUMN: {
28888b213899Sdrh       testcase( pExpr->op==TK_AGG_COLUMN );
28898b213899Sdrh       testcase( pExpr->op==TK_COLUMN );
289013449892Sdrh       /* Check to see if the column is in one of the tables in the FROM
289113449892Sdrh       ** clause of the aggregate query */
289213449892Sdrh       if( pSrcList ){
289313449892Sdrh         struct SrcList_item *pItem = pSrcList->a;
289413449892Sdrh         for(i=0; i<pSrcList->nSrc; i++, pItem++){
289513449892Sdrh           struct AggInfo_col *pCol;
289613449892Sdrh           if( pExpr->iTable==pItem->iCursor ){
289713449892Sdrh             /* If we reach this point, it means that pExpr refers to a table
289813449892Sdrh             ** that is in the FROM clause of the aggregate query.
289913449892Sdrh             **
290013449892Sdrh             ** Make an entry for the column in pAggInfo->aCol[] if there
290113449892Sdrh             ** is not an entry there already.
290213449892Sdrh             */
29037f906d63Sdrh             int k;
290413449892Sdrh             pCol = pAggInfo->aCol;
29057f906d63Sdrh             for(k=0; k<pAggInfo->nColumn; k++, pCol++){
290613449892Sdrh               if( pCol->iTable==pExpr->iTable &&
290713449892Sdrh                   pCol->iColumn==pExpr->iColumn ){
29082282792aSdrh                 break;
29092282792aSdrh               }
29102282792aSdrh             }
29111e536953Sdanielk1977             if( (k>=pAggInfo->nColumn)
29121e536953Sdanielk1977              && (k = addAggInfoColumn(pParse->db, pAggInfo))>=0
29131e536953Sdanielk1977             ){
29147f906d63Sdrh               pCol = &pAggInfo->aCol[k];
29150817d0dfSdanielk1977               pCol->pTab = pExpr->pTab;
291613449892Sdrh               pCol->iTable = pExpr->iTable;
291713449892Sdrh               pCol->iColumn = pExpr->iColumn;
29180a07c107Sdrh               pCol->iMem = ++pParse->nMem;
291913449892Sdrh               pCol->iSorterColumn = -1;
29205774b806Sdrh               pCol->pExpr = pExpr;
292113449892Sdrh               if( pAggInfo->pGroupBy ){
292213449892Sdrh                 int j, n;
292313449892Sdrh                 ExprList *pGB = pAggInfo->pGroupBy;
292413449892Sdrh                 struct ExprList_item *pTerm = pGB->a;
292513449892Sdrh                 n = pGB->nExpr;
292613449892Sdrh                 for(j=0; j<n; j++, pTerm++){
292713449892Sdrh                   Expr *pE = pTerm->pExpr;
292813449892Sdrh                   if( pE->op==TK_COLUMN && pE->iTable==pExpr->iTable &&
292913449892Sdrh                       pE->iColumn==pExpr->iColumn ){
293013449892Sdrh                     pCol->iSorterColumn = j;
293113449892Sdrh                     break;
29322282792aSdrh                   }
293313449892Sdrh                 }
293413449892Sdrh               }
293513449892Sdrh               if( pCol->iSorterColumn<0 ){
293613449892Sdrh                 pCol->iSorterColumn = pAggInfo->nSortingColumn++;
293713449892Sdrh               }
293813449892Sdrh             }
293913449892Sdrh             /* There is now an entry for pExpr in pAggInfo->aCol[] (either
294013449892Sdrh             ** because it was there before or because we just created it).
294113449892Sdrh             ** Convert the pExpr to be a TK_AGG_COLUMN referring to that
294213449892Sdrh             ** pAggInfo->aCol[] entry.
294313449892Sdrh             */
294413449892Sdrh             pExpr->pAggInfo = pAggInfo;
294513449892Sdrh             pExpr->op = TK_AGG_COLUMN;
29467f906d63Sdrh             pExpr->iAgg = k;
294713449892Sdrh             break;
294813449892Sdrh           } /* endif pExpr->iTable==pItem->iCursor */
294913449892Sdrh         } /* end loop over pSrcList */
2950a58fdfb1Sdanielk1977       }
29517d10d5a6Sdrh       return WRC_Prune;
29522282792aSdrh     }
29532282792aSdrh     case TK_AGG_FUNCTION: {
295413449892Sdrh       /* The pNC->nDepth==0 test causes aggregate functions in subqueries
295513449892Sdrh       ** to be ignored */
2956a58fdfb1Sdanielk1977       if( pNC->nDepth==0 ){
295713449892Sdrh         /* Check to see if pExpr is a duplicate of another aggregate
295813449892Sdrh         ** function that is already in the pAggInfo structure
295913449892Sdrh         */
296013449892Sdrh         struct AggInfo_func *pItem = pAggInfo->aFunc;
296113449892Sdrh         for(i=0; i<pAggInfo->nFunc; i++, pItem++){
296213449892Sdrh           if( sqlite3ExprCompare(pItem->pExpr, pExpr) ){
29632282792aSdrh             break;
29642282792aSdrh           }
29652282792aSdrh         }
296613449892Sdrh         if( i>=pAggInfo->nFunc ){
296713449892Sdrh           /* pExpr is original.  Make a new entry in pAggInfo->aFunc[]
296813449892Sdrh           */
296914db2665Sdanielk1977           u8 enc = ENC(pParse->db);
29701e536953Sdanielk1977           i = addAggInfoFunc(pParse->db, pAggInfo);
297113449892Sdrh           if( i>=0 ){
297213449892Sdrh             pItem = &pAggInfo->aFunc[i];
297313449892Sdrh             pItem->pExpr = pExpr;
29740a07c107Sdrh             pItem->iMem = ++pParse->nMem;
297513449892Sdrh             pItem->pFunc = sqlite3FindFunction(pParse->db,
29762646da7eSdrh                    (char*)pExpr->token.z, pExpr->token.n,
2977d8123366Sdanielk1977                    pExpr->pList ? pExpr->pList->nExpr : 0, enc, 0);
2978fd357974Sdrh             if( pExpr->flags & EP_Distinct ){
2979fd357974Sdrh               pItem->iDistinct = pParse->nTab++;
2980fd357974Sdrh             }else{
2981fd357974Sdrh               pItem->iDistinct = -1;
2982fd357974Sdrh             }
29832282792aSdrh           }
298413449892Sdrh         }
298513449892Sdrh         /* Make pExpr point to the appropriate pAggInfo->aFunc[] entry
298613449892Sdrh         */
29872282792aSdrh         pExpr->iAgg = i;
298813449892Sdrh         pExpr->pAggInfo = pAggInfo;
29897d10d5a6Sdrh         return WRC_Prune;
29902282792aSdrh       }
29912282792aSdrh     }
2992a58fdfb1Sdanielk1977   }
29937d10d5a6Sdrh   return WRC_Continue;
29947d10d5a6Sdrh }
29957d10d5a6Sdrh static int analyzeAggregatesInSelect(Walker *pWalker, Select *pSelect){
29967d10d5a6Sdrh   NameContext *pNC = pWalker->u.pNC;
29977d10d5a6Sdrh   if( pNC->nDepth==0 ){
2998a58fdfb1Sdanielk1977     pNC->nDepth++;
29997d10d5a6Sdrh     sqlite3WalkSelect(pWalker, pSelect);
3000a58fdfb1Sdanielk1977     pNC->nDepth--;
30017d10d5a6Sdrh     return WRC_Prune;
30027d10d5a6Sdrh   }else{
30037d10d5a6Sdrh     return WRC_Continue;
3004a58fdfb1Sdanielk1977   }
30052282792aSdrh }
3006626a879aSdrh 
3007626a879aSdrh /*
3008626a879aSdrh ** Analyze the given expression looking for aggregate functions and
3009626a879aSdrh ** for variables that need to be added to the pParse->aAgg[] array.
3010626a879aSdrh ** Make additional entries to the pParse->aAgg[] array as necessary.
3011626a879aSdrh **
3012626a879aSdrh ** This routine should only be called after the expression has been
30137d10d5a6Sdrh ** analyzed by sqlite3ResolveExprNames().
3014626a879aSdrh */
3015d2b3e23bSdrh void sqlite3ExprAnalyzeAggregates(NameContext *pNC, Expr *pExpr){
30167d10d5a6Sdrh   Walker w;
30177d10d5a6Sdrh   w.xExprCallback = analyzeAggregate;
30187d10d5a6Sdrh   w.xSelectCallback = analyzeAggregatesInSelect;
30197d10d5a6Sdrh   w.u.pNC = pNC;
30207d10d5a6Sdrh   sqlite3WalkExpr(&w, pExpr);
30212282792aSdrh }
30225d9a4af9Sdrh 
30235d9a4af9Sdrh /*
30245d9a4af9Sdrh ** Call sqlite3ExprAnalyzeAggregates() for every expression in an
30255d9a4af9Sdrh ** expression list.  Return the number of errors.
30265d9a4af9Sdrh **
30275d9a4af9Sdrh ** If an error is found, the analysis is cut short.
30285d9a4af9Sdrh */
3029d2b3e23bSdrh void sqlite3ExprAnalyzeAggList(NameContext *pNC, ExprList *pList){
30305d9a4af9Sdrh   struct ExprList_item *pItem;
30315d9a4af9Sdrh   int i;
30325d9a4af9Sdrh   if( pList ){
3033d2b3e23bSdrh     for(pItem=pList->a, i=0; i<pList->nExpr; i++, pItem++){
3034d2b3e23bSdrh       sqlite3ExprAnalyzeAggregates(pNC, pItem->pExpr);
30355d9a4af9Sdrh     }
30365d9a4af9Sdrh   }
30375d9a4af9Sdrh }
3038892d3179Sdrh 
3039892d3179Sdrh /*
3040892d3179Sdrh ** Allocate or deallocate temporary use registers during code generation.
3041892d3179Sdrh */
3042892d3179Sdrh int sqlite3GetTempReg(Parse *pParse){
3043e55cbd72Sdrh   if( pParse->nTempReg==0 ){
3044892d3179Sdrh     return ++pParse->nMem;
3045892d3179Sdrh   }
30462f425f6bSdanielk1977   return pParse->aTempReg[--pParse->nTempReg];
3047892d3179Sdrh }
3048892d3179Sdrh void sqlite3ReleaseTempReg(Parse *pParse, int iReg){
30492dcef11bSdrh   if( iReg && pParse->nTempReg<ArraySize(pParse->aTempReg) ){
3050a7d8b859Sdanielk1977     sqlite3ExprWritableRegister(pParse, iReg, iReg);
3051892d3179Sdrh     pParse->aTempReg[pParse->nTempReg++] = iReg;
3052892d3179Sdrh   }
3053892d3179Sdrh }
3054892d3179Sdrh 
3055892d3179Sdrh /*
3056892d3179Sdrh ** Allocate or deallocate a block of nReg consecutive registers
3057892d3179Sdrh */
3058892d3179Sdrh int sqlite3GetTempRange(Parse *pParse, int nReg){
3059e55cbd72Sdrh   int i, n;
3060892d3179Sdrh   i = pParse->iRangeReg;
3061e55cbd72Sdrh   n = pParse->nRangeReg;
3062e55cbd72Sdrh   if( nReg<=n && !usedAsColumnCache(pParse, i, i+n-1) ){
3063892d3179Sdrh     pParse->iRangeReg += nReg;
3064892d3179Sdrh     pParse->nRangeReg -= nReg;
3065892d3179Sdrh   }else{
3066892d3179Sdrh     i = pParse->nMem+1;
3067892d3179Sdrh     pParse->nMem += nReg;
3068892d3179Sdrh   }
3069892d3179Sdrh   return i;
3070892d3179Sdrh }
3071892d3179Sdrh void sqlite3ReleaseTempRange(Parse *pParse, int iReg, int nReg){
3072892d3179Sdrh   if( nReg>pParse->nRangeReg ){
3073892d3179Sdrh     pParse->nRangeReg = nReg;
3074892d3179Sdrh     pParse->iRangeReg = iReg;
3075892d3179Sdrh   }
3076892d3179Sdrh }
3077