xref: /sqlite-3.40.0/src/expr.c (revision f55f25f0)
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*f55f25f0Sdrh ** $Id: expr.c,v 1.50 2002/02/28 01:46:12 drh Exp $
16cce7d176Sdrh */
17cce7d176Sdrh #include "sqliteInt.h"
18cce7d176Sdrh 
19a2e00042Sdrh 
20a2e00042Sdrh /*
21a76b5dfcSdrh ** Construct a new expression node and return a pointer to it.  Memory
22a76b5dfcSdrh ** for this node is obtained from sqliteMalloc().  The calling function
23a76b5dfcSdrh ** is responsible for making sure the node eventually gets freed.
24a76b5dfcSdrh */
25a76b5dfcSdrh Expr *sqliteExpr(int op, Expr *pLeft, Expr *pRight, Token *pToken){
26a76b5dfcSdrh   Expr *pNew;
27a76b5dfcSdrh   pNew = sqliteMalloc( sizeof(Expr) );
28a76b5dfcSdrh   if( pNew==0 ){
29a76b5dfcSdrh     sqliteExprDelete(pLeft);
30a76b5dfcSdrh     sqliteExprDelete(pRight);
31a76b5dfcSdrh     return 0;
32a76b5dfcSdrh   }
33a76b5dfcSdrh   pNew->op = op;
34a76b5dfcSdrh   pNew->pLeft = pLeft;
35a76b5dfcSdrh   pNew->pRight = pRight;
36a76b5dfcSdrh   if( pToken ){
37a76b5dfcSdrh     pNew->token = *pToken;
38a76b5dfcSdrh   }else{
39a76b5dfcSdrh     pNew->token.z = 0;
40a76b5dfcSdrh     pNew->token.n = 0;
41a76b5dfcSdrh   }
42a76b5dfcSdrh   if( pLeft && pRight ){
43a76b5dfcSdrh     sqliteExprSpan(pNew, &pLeft->span, &pRight->span);
44a76b5dfcSdrh   }else{
45a76b5dfcSdrh     pNew->span = pNew->token;
46a76b5dfcSdrh   }
47a76b5dfcSdrh   return pNew;
48a76b5dfcSdrh }
49a76b5dfcSdrh 
50a76b5dfcSdrh /*
51a76b5dfcSdrh ** Set the Expr.token field of the given expression to span all
52a76b5dfcSdrh ** text between the two given tokens.
53a76b5dfcSdrh */
54a76b5dfcSdrh void sqliteExprSpan(Expr *pExpr, Token *pLeft, Token *pRight){
55a76b5dfcSdrh   if( pExpr ){
56a76b5dfcSdrh     pExpr->span.z = pLeft->z;
57a76b5dfcSdrh     pExpr->span.n = pRight->n + Addr(pRight->z) - Addr(pLeft->z);
58a76b5dfcSdrh   }
59a76b5dfcSdrh }
60a76b5dfcSdrh 
61a76b5dfcSdrh /*
62a76b5dfcSdrh ** Construct a new expression node for a function with multiple
63a76b5dfcSdrh ** arguments.
64a76b5dfcSdrh */
65a76b5dfcSdrh Expr *sqliteExprFunction(ExprList *pList, Token *pToken){
66a76b5dfcSdrh   Expr *pNew;
67a76b5dfcSdrh   pNew = sqliteMalloc( sizeof(Expr) );
68a76b5dfcSdrh   if( pNew==0 ){
69a76b5dfcSdrh     sqliteExprListDelete(pList);
70a76b5dfcSdrh     return 0;
71a76b5dfcSdrh   }
72a76b5dfcSdrh   pNew->op = TK_FUNCTION;
73a76b5dfcSdrh   pNew->pList = pList;
74a76b5dfcSdrh   if( pToken ){
75a76b5dfcSdrh     pNew->token = *pToken;
76a76b5dfcSdrh   }else{
77a76b5dfcSdrh     pNew->token.z = 0;
78a76b5dfcSdrh     pNew->token.n = 0;
79a76b5dfcSdrh   }
80a76b5dfcSdrh   return pNew;
81a76b5dfcSdrh }
82a76b5dfcSdrh 
83a76b5dfcSdrh /*
84a2e00042Sdrh ** Recursively delete an expression tree.
85a2e00042Sdrh */
86a2e00042Sdrh void sqliteExprDelete(Expr *p){
87a2e00042Sdrh   if( p==0 ) return;
88a2e00042Sdrh   if( p->op!=TK_AS ){
89a2e00042Sdrh     if( p->pLeft ) sqliteExprDelete(p->pLeft);
90a2e00042Sdrh     if( p->pRight ) sqliteExprDelete(p->pRight);
91a2e00042Sdrh   }
92a2e00042Sdrh   if( p->pList ) sqliteExprListDelete(p->pList);
93a2e00042Sdrh   if( p->pSelect ) sqliteSelectDelete(p->pSelect);
94a2e00042Sdrh   sqliteFree(p);
95a2e00042Sdrh }
96a2e00042Sdrh 
97cce7d176Sdrh /*
98a76b5dfcSdrh ** The following group of functions are used to translate the string
99a76b5dfcSdrh ** pointers of tokens in expression from one buffer to another.
100a76b5dfcSdrh **
101a76b5dfcSdrh ** Normally, the Expr.token.z and Expr.span.z fields point into the
102a76b5dfcSdrh ** original input buffer of an SQL statement.  This is usually OK
103a76b5dfcSdrh ** since the SQL statement is executed and the expression is deleted
104a76b5dfcSdrh ** before the input buffer is freed.  Making the tokens point to the
105a76b5dfcSdrh ** original input buffer saves many calls to malloc() and thus helps
106a76b5dfcSdrh ** the library to run faster.
107a76b5dfcSdrh **
108a76b5dfcSdrh ** But sometimes we need an expression to persist past the time when
109a76b5dfcSdrh ** the input buffer is freed.  (Example: The SELECT clause of a
110a76b5dfcSdrh ** CREATE VIEW statement contains expressions that must persist for
111a76b5dfcSdrh ** the life of the view.)  When that happens we have to make a
112a76b5dfcSdrh ** persistent copy of the input buffer and translate the Expr.token.z
113a76b5dfcSdrh ** and Expr.span.z fields to point to the copy rather than the
114a2ed5601Sdrh ** original input buffer.  The following group of routines handle that
115a76b5dfcSdrh ** translation.
116a76b5dfcSdrh **
117a76b5dfcSdrh ** The "offset" parameter is the distance from the original input buffer
118a76b5dfcSdrh ** to the persistent copy.  These routines recursively walk the entire
119a76b5dfcSdrh ** expression tree and shift all tokens by "offset" amount.
120a76b5dfcSdrh **
121a76b5dfcSdrh ** The work of figuring out the appropriate "offset" and making the
122a76b5dfcSdrh ** presistent copy of the input buffer is done by the calling routine.
123a76b5dfcSdrh */
124a76b5dfcSdrh void sqliteExprMoveStrings(Expr *p, int offset){
125a76b5dfcSdrh   if( p==0 ) return;
126a76b5dfcSdrh   if( p->token.z ) p->token.z += offset;
127a76b5dfcSdrh   if( p->span.z ) p->span.z += offset;
128a76b5dfcSdrh   if( p->pLeft ) sqliteExprMoveStrings(p->pLeft, offset);
129a76b5dfcSdrh   if( p->pRight ) sqliteExprMoveStrings(p->pRight, offset);
130a76b5dfcSdrh   if( p->pList ) sqliteExprListMoveStrings(p->pList, offset);
131a76b5dfcSdrh   if( p->pSelect ) sqliteSelectMoveStrings(p->pSelect, offset);
132a76b5dfcSdrh }
133a76b5dfcSdrh void sqliteExprListMoveStrings(ExprList *pList, int offset){
134a76b5dfcSdrh   int i;
135a76b5dfcSdrh   if( pList==0 ) return;
136a76b5dfcSdrh   for(i=0; i<pList->nExpr; i++){
137a76b5dfcSdrh     sqliteExprMoveStrings(pList->a[i].pExpr, offset);
138a76b5dfcSdrh   }
139a76b5dfcSdrh }
140a76b5dfcSdrh void sqliteSelectMoveStrings(Select *pSelect, int offset){
141a76b5dfcSdrh   if( pSelect==0 ) return;
142a76b5dfcSdrh   sqliteExprListMoveStrings(pSelect->pEList, offset);
143a76b5dfcSdrh   sqliteExprMoveStrings(pSelect->pWhere, offset);
144a76b5dfcSdrh   sqliteExprListMoveStrings(pSelect->pGroupBy, offset);
145a76b5dfcSdrh   sqliteExprMoveStrings(pSelect->pHaving, offset);
146a76b5dfcSdrh   sqliteExprListMoveStrings(pSelect->pOrderBy, offset);
147a76b5dfcSdrh   sqliteSelectMoveStrings(pSelect->pPrior, offset);
148a76b5dfcSdrh }
149a76b5dfcSdrh 
150a76b5dfcSdrh /*
151ff78bd2fSdrh ** The following group of routines make deep copies of expressions,
152ff78bd2fSdrh ** expression lists, ID lists, and select statements.  The copies can
153ff78bd2fSdrh ** be deleted (by being passed to their respective ...Delete() routines)
154ff78bd2fSdrh ** without effecting the originals.
155ff78bd2fSdrh **
156ff78bd2fSdrh ** Note, however, that the Expr.token.z and Expr.span.z fields point to
157ff78bd2fSdrh ** string space that is allocated separately from the expression tree
158ff78bd2fSdrh ** itself.  These routines do NOT duplicate that string space.
159ff78bd2fSdrh **
160ff78bd2fSdrh ** The expression list and ID list return by sqliteExprListDup() and
161ff78bd2fSdrh ** sqliteIdListDup() can not be further expanded by subsequent calls
162ff78bd2fSdrh ** to sqliteExprListAppend() or sqliteIdListAppend().
163ff78bd2fSdrh **
164ff78bd2fSdrh ** Any tables that the ID list might point to are not duplicated.
165ff78bd2fSdrh */
166ff78bd2fSdrh Expr *sqliteExprDup(Expr *p){
167ff78bd2fSdrh   Expr *pNew;
168ff78bd2fSdrh   if( p==0 ) return 0;
169ff78bd2fSdrh   pNew = sqliteMalloc( sizeof(*p) );
170ff78bd2fSdrh   if( pNew==0 ) return 0;
171ff78bd2fSdrh   pNew->op = p->op;
172ff78bd2fSdrh   pNew->pLeft = sqliteExprDup(p->pLeft);
173ff78bd2fSdrh   pNew->pRight = sqliteExprDup(p->pRight);
174ff78bd2fSdrh   pNew->pList = sqliteExprListDup(p->pList);
175ff78bd2fSdrh   pNew->token = p->token;
176ff78bd2fSdrh   pNew->span = p->span;
177ff78bd2fSdrh   pNew->pSelect = sqliteSelectDup(p->pSelect);
178ff78bd2fSdrh   return pNew;
179ff78bd2fSdrh }
180ff78bd2fSdrh ExprList *sqliteExprListDup(ExprList *p){
181ff78bd2fSdrh   ExprList *pNew;
182ff78bd2fSdrh   int i;
183ff78bd2fSdrh   if( p==0 ) return 0;
184ff78bd2fSdrh   pNew = sqliteMalloc( sizeof(*pNew) );
185ff78bd2fSdrh   if( pNew==0 ) return 0;
186ff78bd2fSdrh   pNew->nExpr = p->nExpr;
187ff78bd2fSdrh   pNew->a = sqliteMalloc( p->nExpr*sizeof(p->a[0]) );
188ff78bd2fSdrh   for(i=0; i<p->nExpr; i++){
189ff78bd2fSdrh     pNew->a[i].pExpr = sqliteExprDup(p->a[i].pExpr);
190ff78bd2fSdrh     pNew->a[i].zName = sqliteStrDup(p->a[i].zName);
191ff78bd2fSdrh     pNew->a[i].sortOrder = p->a[i].sortOrder;
192ff78bd2fSdrh     pNew->a[i].isAgg = p->a[i].isAgg;
193ff78bd2fSdrh     pNew->a[i].done = 0;
194ff78bd2fSdrh   }
195ff78bd2fSdrh   return pNew;
196ff78bd2fSdrh }
197ff78bd2fSdrh IdList *sqliteIdListDup(IdList *p){
198ff78bd2fSdrh   IdList *pNew;
199ff78bd2fSdrh   int i;
200ff78bd2fSdrh   if( p==0 ) return 0;
201ff78bd2fSdrh   pNew = sqliteMalloc( sizeof(*pNew) );
202ff78bd2fSdrh   if( pNew==0 ) return 0;
203ff78bd2fSdrh   pNew->nId = p->nId;
204ff78bd2fSdrh   pNew->a = sqliteMalloc( p->nId*sizeof(p->a[0]) );
205ff78bd2fSdrh   for(i=0; i<p->nId; i++){
206ff78bd2fSdrh     pNew->a[i].zName = sqliteStrDup(p->a[i].zName);
207ff78bd2fSdrh     pNew->a[i].zAlias = sqliteStrDup(p->a[i].zAlias);
208ff78bd2fSdrh     pNew->a[i].idx = p->a[i].idx;
209ff78bd2fSdrh     pNew->a[i].pTab = 0;
210ff78bd2fSdrh     pNew->a[i].pSelect = sqliteSelectDup(p->a[i].pSelect);
211ff78bd2fSdrh   }
212ff78bd2fSdrh   return pNew;
213ff78bd2fSdrh }
214ff78bd2fSdrh Select *sqliteSelectDup(Select *p){
215ff78bd2fSdrh   Select *pNew;
216ff78bd2fSdrh   if( p==0 ) return 0;
217ff78bd2fSdrh   pNew = sqliteMalloc( sizeof(*p) );
218ff78bd2fSdrh   if( pNew==0 ) return 0;
219ff78bd2fSdrh   pNew->isDistinct = p->isDistinct;
220ff78bd2fSdrh   pNew->pEList = sqliteExprListDup(p->pEList);
221ff78bd2fSdrh   pNew->pSrc = sqliteIdListDup(p->pSrc);
222ff78bd2fSdrh   pNew->pWhere = sqliteExprDup(p->pWhere);
223ff78bd2fSdrh   pNew->pGroupBy = sqliteExprListDup(p->pGroupBy);
224ff78bd2fSdrh   pNew->pHaving = sqliteExprDup(p->pHaving);
225ff78bd2fSdrh   pNew->pOrderBy = sqliteExprListDup(p->pOrderBy);
226ff78bd2fSdrh   pNew->op = p->op;
227ff78bd2fSdrh   pNew->pPrior = sqliteSelectDup(p->pPrior);
228ff78bd2fSdrh   pNew->nLimit = p->nLimit;
229ff78bd2fSdrh   pNew->nOffset = p->nOffset;
230ff78bd2fSdrh   pNew->zSelect = 0;
231ff78bd2fSdrh   return pNew;
232ff78bd2fSdrh }
233ff78bd2fSdrh 
234ff78bd2fSdrh 
235ff78bd2fSdrh /*
236a76b5dfcSdrh ** Add a new element to the end of an expression list.  If pList is
237a76b5dfcSdrh ** initially NULL, then create a new expression list.
238a76b5dfcSdrh */
239a76b5dfcSdrh ExprList *sqliteExprListAppend(ExprList *pList, Expr *pExpr, Token *pName){
240a76b5dfcSdrh   int i;
241a76b5dfcSdrh   if( pList==0 ){
242a76b5dfcSdrh     pList = sqliteMalloc( sizeof(ExprList) );
243a76b5dfcSdrh     if( pList==0 ){
244a76b5dfcSdrh       sqliteExprDelete(pExpr);
245a76b5dfcSdrh       return 0;
246a76b5dfcSdrh     }
247a76b5dfcSdrh   }
248a76b5dfcSdrh   if( (pList->nExpr & 7)==0 ){
249a76b5dfcSdrh     int n = pList->nExpr + 8;
250a76b5dfcSdrh     struct ExprList_item *a;
251a76b5dfcSdrh     a = sqliteRealloc(pList->a, n*sizeof(pList->a[0]));
252a76b5dfcSdrh     if( a==0 ){
253a76b5dfcSdrh       sqliteExprDelete(pExpr);
254a76b5dfcSdrh       return pList;
255a76b5dfcSdrh     }
256a76b5dfcSdrh     pList->a = a;
257a76b5dfcSdrh   }
258a76b5dfcSdrh   if( pExpr || pName ){
259a76b5dfcSdrh     i = pList->nExpr++;
260a76b5dfcSdrh     pList->a[i].pExpr = pExpr;
261a76b5dfcSdrh     pList->a[i].zName = 0;
262a76b5dfcSdrh     if( pName ){
263a76b5dfcSdrh       sqliteSetNString(&pList->a[i].zName, pName->z, pName->n, 0);
264a76b5dfcSdrh       sqliteDequote(pList->a[i].zName);
265a76b5dfcSdrh     }
266a76b5dfcSdrh   }
267a76b5dfcSdrh   return pList;
268a76b5dfcSdrh }
269a76b5dfcSdrh 
270a76b5dfcSdrh /*
271a76b5dfcSdrh ** Delete an entire expression list.
272a76b5dfcSdrh */
273a76b5dfcSdrh void sqliteExprListDelete(ExprList *pList){
274a76b5dfcSdrh   int i;
275a76b5dfcSdrh   if( pList==0 ) return;
276a76b5dfcSdrh   for(i=0; i<pList->nExpr; i++){
277a76b5dfcSdrh     sqliteExprDelete(pList->a[i].pExpr);
278a76b5dfcSdrh     sqliteFree(pList->a[i].zName);
279a76b5dfcSdrh   }
280a76b5dfcSdrh   sqliteFree(pList->a);
281a76b5dfcSdrh   sqliteFree(pList);
282a76b5dfcSdrh }
283a76b5dfcSdrh 
284a76b5dfcSdrh /*
285fef5208cSdrh ** Walk an expression tree.  Return 1 if the expression is constant
286fef5208cSdrh ** and 0 if it involves variables.
287fef5208cSdrh */
2889208643dSdrh int sqliteExprIsConstant(Expr *p){
289fef5208cSdrh   switch( p->op ){
290fef5208cSdrh     case TK_ID:
291967e8b73Sdrh     case TK_COLUMN:
292fef5208cSdrh     case TK_DOT:
293fef5208cSdrh       return 0;
2949208643dSdrh     case TK_INTEGER:
2959208643dSdrh     case TK_FLOAT:
2969208643dSdrh     case TK_STRING:
2979208643dSdrh       return 1;
298fef5208cSdrh     default: {
2999208643dSdrh       if( p->pLeft && !sqliteExprIsConstant(p->pLeft) ) return 0;
3009208643dSdrh       if( p->pRight && !sqliteExprIsConstant(p->pRight) ) return 0;
301fef5208cSdrh       if( p->pList ){
302fef5208cSdrh         int i;
303fef5208cSdrh         for(i=0; i<p->pList->nExpr; i++){
3049208643dSdrh           if( !sqliteExprIsConstant(p->pList->a[i].pExpr) ) return 0;
305fef5208cSdrh         }
306fef5208cSdrh       }
3079208643dSdrh       return p->pLeft!=0 || p->pRight!=0 || (p->pList && p->pList->nExpr>0);
308fef5208cSdrh     }
309fef5208cSdrh   }
3109208643dSdrh   return 0;
311fef5208cSdrh }
312fef5208cSdrh 
313fef5208cSdrh /*
3144794b980Sdrh ** Walk the expression tree and process operators of the form:
3154794b980Sdrh **
3164794b980Sdrh **       expr IN (SELECT ...)
3174794b980Sdrh **
318967e8b73Sdrh ** These operators have to be processed before column names are
3194794b980Sdrh ** resolved because each such operator increments pParse->nTab
3201ccde15dSdrh ** to reserve cursor numbers for its own use.  But pParse->nTab
321aacc543eSdrh ** needs to be constant once we begin resolving column names.  For
322aacc543eSdrh ** that reason, this procedure needs to be called on every expression
323aacc543eSdrh ** before sqliteExprResolveIds() is called on any expression.
3244794b980Sdrh **
3254794b980Sdrh ** Actually, the processing of IN-SELECT is only started by this
3264794b980Sdrh ** routine.  This routine allocates a cursor number to the IN-SELECT
3274794b980Sdrh ** and then moves on.  The code generation is done by
3284794b980Sdrh ** sqliteExprResolveIds() which must be called afterwards.
3294794b980Sdrh */
3304794b980Sdrh void sqliteExprResolveInSelect(Parse *pParse, Expr *pExpr){
3314794b980Sdrh   if( pExpr==0 ) return;
3324794b980Sdrh   if( pExpr->op==TK_IN && pExpr->pSelect!=0 ){
3334794b980Sdrh     pExpr->iTable = pParse->nTab++;
3344794b980Sdrh   }else{
3354794b980Sdrh     if( pExpr->pLeft ) sqliteExprResolveInSelect(pParse, pExpr->pLeft);
3364794b980Sdrh     if( pExpr->pRight ) sqliteExprResolveInSelect(pParse, pExpr->pRight);
3374794b980Sdrh     if( pExpr->pList ){
3384794b980Sdrh       int i;
3394794b980Sdrh       ExprList *pList = pExpr->pList;
3404794b980Sdrh       for(i=0; i<pList->nExpr; i++){
3414794b980Sdrh         sqliteExprResolveInSelect(pParse, pList->a[i].pExpr);
3424794b980Sdrh       }
3434794b980Sdrh     }
3444794b980Sdrh   }
3454794b980Sdrh }
3464794b980Sdrh 
3474794b980Sdrh /*
348c4a3c779Sdrh ** Return TRUE if the given string is a row-id column name.
349c4a3c779Sdrh */
350c4a3c779Sdrh static int sqliteIsRowid(const char *z){
351c4a3c779Sdrh   if( sqliteStrICmp(z, "_ROWID_")==0 ) return 1;
352c4a3c779Sdrh   if( sqliteStrICmp(z, "ROWID")==0 ) return 1;
353c4a3c779Sdrh   if( sqliteStrICmp(z, "OID")==0 ) return 1;
354c4a3c779Sdrh   return 0;
355c4a3c779Sdrh }
356c4a3c779Sdrh 
357c4a3c779Sdrh /*
358cce7d176Sdrh ** This routine walks an expression tree and resolves references to
359967e8b73Sdrh ** table columns.  Nodes of the form ID.ID or ID resolve into an
360aacc543eSdrh ** index to the table in the table list and a column offset.  The
361aacc543eSdrh ** Expr.opcode for such nodes is changed to TK_COLUMN.  The Expr.iTable
362aacc543eSdrh ** value is changed to the index of the referenced table in pTabList
363aacc543eSdrh ** plus the pParse->nTab value.  This value will ultimately become the
364aacc543eSdrh ** VDBE cursor number for a cursor that is pointing into the referenced
365aacc543eSdrh ** table.  The Expr.iColumn value is changed to the index of the column
366aacc543eSdrh ** of the referenced table.  The Expr.iColumn value for the special
367aacc543eSdrh ** ROWID column is -1.  Any INTEGER PRIMARY KEY column is tried as an
368aacc543eSdrh ** alias for ROWID.
36919a775c2Sdrh **
370fef5208cSdrh ** We also check for instances of the IN operator.  IN comes in two
371fef5208cSdrh ** forms:
372fef5208cSdrh **
373fef5208cSdrh **           expr IN (exprlist)
374fef5208cSdrh ** and
375fef5208cSdrh **           expr IN (SELECT ...)
376fef5208cSdrh **
377fef5208cSdrh ** The first form is handled by creating a set holding the list
378fef5208cSdrh ** of allowed values.  The second form causes the SELECT to generate
379fef5208cSdrh ** a temporary table.
380fef5208cSdrh **
381fef5208cSdrh ** This routine also looks for scalar SELECTs that are part of an expression.
38219a775c2Sdrh ** If it finds any, it generates code to write the value of that select
38319a775c2Sdrh ** into a memory cell.
384cce7d176Sdrh **
385967e8b73Sdrh ** Unknown columns or tables provoke an error.  The function returns
386cce7d176Sdrh ** the number of errors seen and leaves an error message on pParse->zErrMsg.
387cce7d176Sdrh */
388a2e00042Sdrh int sqliteExprResolveIds(
389a2e00042Sdrh   Parse *pParse,     /* The parser context */
390a2e00042Sdrh   IdList *pTabList,  /* List of tables used to resolve column names */
391a2e00042Sdrh   ExprList *pEList,  /* List of expressions used to resolve "AS" */
392a2e00042Sdrh   Expr *pExpr        /* The expression to be analyzed. */
393a2e00042Sdrh ){
394daffd0e5Sdrh   if( pExpr==0 || pTabList==0 ) return 0;
395cce7d176Sdrh   switch( pExpr->op ){
396a2e00042Sdrh     /* A lone identifier.  Try and match it as follows:
397a2e00042Sdrh     **
398a2e00042Sdrh     **     1.  To the name of a column of one of the tables in pTabList
399a2e00042Sdrh     **
400a2e00042Sdrh     **     2.  To the right side of an AS keyword in the column list of
401a2e00042Sdrh     **         a SELECT statement.  (For example, match against 'x' in
402a2e00042Sdrh     **         "SELECT a+b AS 'x' FROM t1".)
403a2e00042Sdrh     **
404a2e00042Sdrh     **     3.  One of the special names "ROWID", "OID", or "_ROWID_".
405a2e00042Sdrh     */
406cce7d176Sdrh     case TK_ID: {
407cce7d176Sdrh       int cnt = 0;      /* Number of matches */
408cce7d176Sdrh       int i;            /* Loop counter */
409a76b5dfcSdrh       char *z;
410a76b5dfcSdrh       assert( pExpr->token.z );
411a76b5dfcSdrh       z = sqliteStrNDup(pExpr->token.z, pExpr->token.n);
4122f4392ffSdrh       sqliteDequote(z);
413daffd0e5Sdrh       if( z==0 ) return 1;
414cce7d176Sdrh       for(i=0; i<pTabList->nId; i++){
415cce7d176Sdrh         int j;
416cce7d176Sdrh         Table *pTab = pTabList->a[i].pTab;
417cce7d176Sdrh         if( pTab==0 ) continue;
418cce7d176Sdrh         for(j=0; j<pTab->nCol; j++){
4197020f651Sdrh           if( sqliteStrICmp(pTab->aCol[j].zName, z)==0 ){
420cce7d176Sdrh             cnt++;
42119a775c2Sdrh             pExpr->iTable = i + pParse->nTab;
4224a32431cSdrh             if( j==pTab->iPKey ){
4234a32431cSdrh               /* Substitute the record number for the INTEGER PRIMARY KEY */
4244a32431cSdrh               pExpr->iColumn = -1;
4254a32431cSdrh             }else{
426967e8b73Sdrh               pExpr->iColumn = j;
427cce7d176Sdrh             }
428a2e00042Sdrh             pExpr->op = TK_COLUMN;
429a2e00042Sdrh           }
430a2e00042Sdrh         }
431a2e00042Sdrh       }
432a2e00042Sdrh       if( cnt==0 && pEList!=0 ){
433a2e00042Sdrh         int j;
434a2e00042Sdrh         for(j=0; j<pEList->nExpr; j++){
435a2e00042Sdrh           char *zAs = pEList->a[j].zName;
436a2e00042Sdrh           if( zAs!=0 && sqliteStrICmp(zAs, z)==0 ){
437a2e00042Sdrh             cnt++;
438a2e00042Sdrh             assert( pExpr->pLeft==0 && pExpr->pRight==0 );
439a2e00042Sdrh             pExpr->op = TK_AS;
440a2e00042Sdrh             pExpr->iColumn = j;
441a2e00042Sdrh             pExpr->pLeft = pEList->a[j].pExpr;
442cce7d176Sdrh           }
443cce7d176Sdrh         }
4444a32431cSdrh       }
445c4a3c779Sdrh       if( cnt==0 && sqliteIsRowid(z) ){
446c4a3c779Sdrh         pExpr->iColumn = -1;
447c4a3c779Sdrh         pExpr->iTable = pParse->nTab;
448c4a3c779Sdrh         cnt = 1 + (pTabList->nId>1);
449a2e00042Sdrh         pExpr->op = TK_COLUMN;
450c4a3c779Sdrh       }
451cce7d176Sdrh       sqliteFree(z);
452cce7d176Sdrh       if( cnt==0 ){
453967e8b73Sdrh         sqliteSetNString(&pParse->zErrMsg, "no such column: ", -1,
454cce7d176Sdrh           pExpr->token.z, pExpr->token.n, 0);
455cce7d176Sdrh         pParse->nErr++;
456cce7d176Sdrh         return 1;
457cce7d176Sdrh       }else if( cnt>1 ){
458967e8b73Sdrh         sqliteSetNString(&pParse->zErrMsg, "ambiguous column name: ", -1,
459cce7d176Sdrh           pExpr->token.z, pExpr->token.n, 0);
460cce7d176Sdrh         pParse->nErr++;
461cce7d176Sdrh         return 1;
462cce7d176Sdrh       }
463cce7d176Sdrh       break;
464cce7d176Sdrh     }
465cce7d176Sdrh 
466967e8b73Sdrh     /* A table name and column name:  ID.ID */
467cce7d176Sdrh     case TK_DOT: {
468cce7d176Sdrh       int cnt = 0;             /* Number of matches */
469c4a3c779Sdrh       int cntTab = 0;          /* Number of matching tables */
470cce7d176Sdrh       int i;                   /* Loop counter */
471cce7d176Sdrh       Expr *pLeft, *pRight;    /* Left and right subbranches of the expr */
472cce7d176Sdrh       char *zLeft, *zRight;    /* Text of an identifier */
473cce7d176Sdrh 
474cce7d176Sdrh       pLeft = pExpr->pLeft;
475cce7d176Sdrh       pRight = pExpr->pRight;
476a76b5dfcSdrh       assert( pLeft && pLeft->op==TK_ID && pLeft->token.z );
477a76b5dfcSdrh       assert( pRight && pRight->op==TK_ID && pRight->token.z );
4786e142f54Sdrh       zLeft = sqliteStrNDup(pLeft->token.z, pLeft->token.n);
4796e142f54Sdrh       zRight = sqliteStrNDup(pRight->token.z, pRight->token.n);
480daffd0e5Sdrh       if( zLeft==0 || zRight==0 ){
481daffd0e5Sdrh         sqliteFree(zLeft);
482daffd0e5Sdrh         sqliteFree(zRight);
483daffd0e5Sdrh         return 1;
484daffd0e5Sdrh       }
48587c40e88Sdrh       sqliteDequote(zLeft);
48687c40e88Sdrh       sqliteDequote(zRight);
487c4a3c779Sdrh       pExpr->iTable = -1;
488cce7d176Sdrh       for(i=0; i<pTabList->nId; i++){
489cce7d176Sdrh         int j;
490cce7d176Sdrh         char *zTab;
491cce7d176Sdrh         Table *pTab = pTabList->a[i].pTab;
492cce7d176Sdrh         if( pTab==0 ) continue;
493cce7d176Sdrh         if( pTabList->a[i].zAlias ){
494cce7d176Sdrh           zTab = pTabList->a[i].zAlias;
495cce7d176Sdrh         }else{
496cce7d176Sdrh           zTab = pTab->zName;
497cce7d176Sdrh         }
498cce7d176Sdrh         if( sqliteStrICmp(zTab, zLeft)!=0 ) continue;
499c4a3c779Sdrh         if( 0==(cntTab++) ) pExpr->iTable = i + pParse->nTab;
500cce7d176Sdrh         for(j=0; j<pTab->nCol; j++){
5017020f651Sdrh           if( sqliteStrICmp(pTab->aCol[j].zName, zRight)==0 ){
502cce7d176Sdrh             cnt++;
50319a775c2Sdrh             pExpr->iTable = i + pParse->nTab;
5044a32431cSdrh             if( j==pTab->iPKey ){
5054a32431cSdrh               /* Substitute the record number for the INTEGER PRIMARY KEY */
5064a32431cSdrh               pExpr->iColumn = -1;
5074a32431cSdrh             }else{
508967e8b73Sdrh               pExpr->iColumn = j;
509cce7d176Sdrh             }
510cce7d176Sdrh           }
511cce7d176Sdrh         }
5124a32431cSdrh       }
513c4a3c779Sdrh       if( cnt==0 && cntTab==1 && sqliteIsRowid(zRight) ){
514c4a3c779Sdrh         cnt = 1;
515c4a3c779Sdrh         pExpr->iColumn = -1;
516c4a3c779Sdrh       }
517cce7d176Sdrh       sqliteFree(zLeft);
518cce7d176Sdrh       sqliteFree(zRight);
519cce7d176Sdrh       if( cnt==0 ){
520967e8b73Sdrh         sqliteSetNString(&pParse->zErrMsg, "no such column: ", -1,
521cce7d176Sdrh           pLeft->token.z, pLeft->token.n, ".", 1,
522cce7d176Sdrh           pRight->token.z, pRight->token.n, 0);
523cce7d176Sdrh         pParse->nErr++;
524cce7d176Sdrh         return 1;
525cce7d176Sdrh       }else if( cnt>1 ){
526967e8b73Sdrh         sqliteSetNString(&pParse->zErrMsg, "ambiguous column name: ", -1,
527cce7d176Sdrh           pLeft->token.z, pLeft->token.n, ".", 1,
528cce7d176Sdrh           pRight->token.z, pRight->token.n, 0);
529cce7d176Sdrh         pParse->nErr++;
530cce7d176Sdrh         return 1;
531cce7d176Sdrh       }
532cce7d176Sdrh       sqliteExprDelete(pLeft);
533cce7d176Sdrh       pExpr->pLeft = 0;
534cce7d176Sdrh       sqliteExprDelete(pRight);
535cce7d176Sdrh       pExpr->pRight = 0;
536967e8b73Sdrh       pExpr->op = TK_COLUMN;
537cce7d176Sdrh       break;
538cce7d176Sdrh     }
539cce7d176Sdrh 
540fef5208cSdrh     case TK_IN: {
541d8bc7086Sdrh       Vdbe *v = sqliteGetVdbe(pParse);
542fef5208cSdrh       if( v==0 ) return 1;
543a2e00042Sdrh       if( sqliteExprResolveIds(pParse, pTabList, pEList, pExpr->pLeft) ){
544cfab11bcSdrh         return 1;
545cfab11bcSdrh       }
546fef5208cSdrh       if( pExpr->pSelect ){
547fef5208cSdrh         /* Case 1:     expr IN (SELECT ...)
548fef5208cSdrh         **
549fef5208cSdrh         ** Generate code to write the results of the select into a temporary
5504794b980Sdrh         ** table.  The cursor number of the temporary table has already
5514794b980Sdrh         ** been put in iTable by sqliteExprResolveInSelect().
552fef5208cSdrh         */
553c6b52df3Sdrh         sqliteVdbeAddOp(v, OP_OpenTemp, pExpr->iTable, 1);
554fef5208cSdrh         if( sqliteSelect(pParse, pExpr->pSelect, SRT_Set, pExpr->iTable) );
555fef5208cSdrh       }else if( pExpr->pList ){
556fef5208cSdrh         /* Case 2:     expr IN (exprlist)
557fef5208cSdrh         **
558fef5208cSdrh         ** Create a set to put the exprlist values in.  The Set id is stored
559fef5208cSdrh         ** in iTable.
560fef5208cSdrh         */
561fef5208cSdrh         int i, iSet;
562fef5208cSdrh         for(i=0; i<pExpr->pList->nExpr; i++){
563fef5208cSdrh           Expr *pE2 = pExpr->pList->a[i].pExpr;
5649208643dSdrh           if( !sqliteExprIsConstant(pE2) ){
565fef5208cSdrh             sqliteSetString(&pParse->zErrMsg,
566fef5208cSdrh               "right-hand side of IN operator must be constant", 0);
567fef5208cSdrh             pParse->nErr++;
568fef5208cSdrh             return 1;
569fef5208cSdrh           }
5704794b980Sdrh           if( sqliteExprCheck(pParse, pE2, 0, 0) ){
5714794b980Sdrh             return 1;
5724794b980Sdrh           }
573fef5208cSdrh         }
574fef5208cSdrh         iSet = pExpr->iTable = pParse->nSet++;
575fef5208cSdrh         for(i=0; i<pExpr->pList->nExpr; i++){
576fef5208cSdrh           Expr *pE2 = pExpr->pList->a[i].pExpr;
577fef5208cSdrh           switch( pE2->op ){
578fef5208cSdrh             case TK_FLOAT:
579fef5208cSdrh             case TK_INTEGER:
580fef5208cSdrh             case TK_STRING: {
58199fcd718Sdrh               int addr = sqliteVdbeAddOp(v, OP_SetInsert, iSet, 0);
582a76b5dfcSdrh               assert( pE2->token.z );
583fef5208cSdrh               sqliteVdbeChangeP3(v, addr, pE2->token.z, pE2->token.n);
584fef5208cSdrh               sqliteVdbeDequoteP3(v, addr);
585fef5208cSdrh               break;
586fef5208cSdrh             }
587fef5208cSdrh             default: {
588fef5208cSdrh               sqliteExprCode(pParse, pE2);
58999fcd718Sdrh               sqliteVdbeAddOp(v, OP_SetInsert, iSet, 0);
590fef5208cSdrh               break;
591fef5208cSdrh             }
592fef5208cSdrh           }
593fef5208cSdrh         }
594fef5208cSdrh       }
595cfab11bcSdrh       break;
596fef5208cSdrh     }
597fef5208cSdrh 
59819a775c2Sdrh     case TK_SELECT: {
599fef5208cSdrh       /* This has to be a scalar SELECT.  Generate code to put the
600fef5208cSdrh       ** value of this select in a memory cell and record the number
601967e8b73Sdrh       ** of the memory cell in iColumn.
602fef5208cSdrh       */
603967e8b73Sdrh       pExpr->iColumn = pParse->nMem++;
604967e8b73Sdrh       if( sqliteSelect(pParse, pExpr->pSelect, SRT_Mem, pExpr->iColumn) ){
60519a775c2Sdrh         return 1;
60619a775c2Sdrh       }
60719a775c2Sdrh       break;
60819a775c2Sdrh     }
60919a775c2Sdrh 
610cce7d176Sdrh     /* For all else, just recursively walk the tree */
611cce7d176Sdrh     default: {
612cce7d176Sdrh       if( pExpr->pLeft
613a2e00042Sdrh       && sqliteExprResolveIds(pParse, pTabList, pEList, pExpr->pLeft) ){
614cce7d176Sdrh         return 1;
615cce7d176Sdrh       }
616cce7d176Sdrh       if( pExpr->pRight
617a2e00042Sdrh       && sqliteExprResolveIds(pParse, pTabList, pEList, pExpr->pRight) ){
618cce7d176Sdrh         return 1;
619cce7d176Sdrh       }
620cce7d176Sdrh       if( pExpr->pList ){
621cce7d176Sdrh         int i;
622cce7d176Sdrh         ExprList *pList = pExpr->pList;
623cce7d176Sdrh         for(i=0; i<pList->nExpr; i++){
624a2e00042Sdrh           if( sqliteExprResolveIds(pParse,pTabList,pEList,pList->a[i].pExpr) ){
625cce7d176Sdrh             return 1;
626cce7d176Sdrh           }
627cce7d176Sdrh         }
628cce7d176Sdrh       }
629cce7d176Sdrh     }
630cce7d176Sdrh   }
631cce7d176Sdrh   return 0;
632cce7d176Sdrh }
633cce7d176Sdrh 
634cce7d176Sdrh /*
635cce7d176Sdrh ** Error check the functions in an expression.  Make sure all
636cce7d176Sdrh ** function names are recognized and all functions have the correct
637cce7d176Sdrh ** number of arguments.  Leave an error message in pParse->zErrMsg
638cce7d176Sdrh ** if anything is amiss.  Return the number of errors.
639cce7d176Sdrh **
640cce7d176Sdrh ** if pIsAgg is not null and this expression is an aggregate function
641cce7d176Sdrh ** (like count(*) or max(value)) then write a 1 into *pIsAgg.
642cce7d176Sdrh */
643cce7d176Sdrh int sqliteExprCheck(Parse *pParse, Expr *pExpr, int allowAgg, int *pIsAgg){
644cce7d176Sdrh   int nErr = 0;
645cce7d176Sdrh   if( pExpr==0 ) return 0;
646cce7d176Sdrh   switch( pExpr->op ){
647cce7d176Sdrh     case TK_FUNCTION: {
648cce7d176Sdrh       int n = pExpr->pList ? pExpr->pList->nExpr : 0;
649cce7d176Sdrh       int no_such_func = 0;
6508e0a2f90Sdrh       int wrong_num_args = 0;
651cce7d176Sdrh       int is_agg = 0;
652cce7d176Sdrh       int i;
6530bce8354Sdrh       FuncDef *pDef;
6540bce8354Sdrh 
6550bce8354Sdrh       pDef = sqliteFindFunction(pParse->db, pExpr->token.z, pExpr->token.n,n,0);
6560bce8354Sdrh       if( pDef==0 ){
6570bce8354Sdrh         pDef = sqliteFindFunction(pParse->db,
6588e0a2f90Sdrh            pExpr->token.z, pExpr->token.n, -1, 0);
6590bce8354Sdrh         if( pDef==0 ){
660cce7d176Sdrh           no_such_func = 1;
6618e0a2f90Sdrh         }else{
6628e0a2f90Sdrh           wrong_num_args = 1;
6638e0a2f90Sdrh         }
6648e0a2f90Sdrh       }else{
6650bce8354Sdrh         is_agg = pDef->xFunc==0;
666cce7d176Sdrh       }
6678e0a2f90Sdrh       if( is_agg && !allowAgg ){
6688e0a2f90Sdrh         sqliteSetNString(&pParse->zErrMsg, "misuse of aggregate function ", -1,
6698e0a2f90Sdrh            pExpr->token.z, pExpr->token.n, "()", 2, 0);
6708e0a2f90Sdrh         pParse->nErr++;
6718e0a2f90Sdrh         nErr++;
6728e0a2f90Sdrh         is_agg = 0;
6738e0a2f90Sdrh       }else if( no_such_func ){
674cce7d176Sdrh         sqliteSetNString(&pParse->zErrMsg, "no such function: ", -1,
675cce7d176Sdrh            pExpr->token.z, pExpr->token.n, 0);
676cce7d176Sdrh         pParse->nErr++;
677cce7d176Sdrh         nErr++;
6788e0a2f90Sdrh       }else if( wrong_num_args ){
6798e0a2f90Sdrh         sqliteSetNString(&pParse->zErrMsg,
6808e0a2f90Sdrh            "wrong number of arguments to function ",-1,
6818e0a2f90Sdrh            pExpr->token.z, pExpr->token.n, "()", 2, 0);
6828e0a2f90Sdrh         pParse->nErr++;
6838e0a2f90Sdrh         nErr++;
684cce7d176Sdrh       }
6852282792aSdrh       if( is_agg ) pExpr->op = TK_AGG_FUNCTION;
686cce7d176Sdrh       if( is_agg && pIsAgg ) *pIsAgg = 1;
687cce7d176Sdrh       for(i=0; nErr==0 && i<n; i++){
6884cfa7934Sdrh         nErr = sqliteExprCheck(pParse, pExpr->pList->a[i].pExpr,
6894cfa7934Sdrh                                allowAgg && !is_agg, pIsAgg);
690cce7d176Sdrh       }
691cce7d176Sdrh     }
692cce7d176Sdrh     default: {
693cce7d176Sdrh       if( pExpr->pLeft ){
6942282792aSdrh         nErr = sqliteExprCheck(pParse, pExpr->pLeft, allowAgg, pIsAgg);
695cce7d176Sdrh       }
696cce7d176Sdrh       if( nErr==0 && pExpr->pRight ){
6972282792aSdrh         nErr = sqliteExprCheck(pParse, pExpr->pRight, allowAgg, pIsAgg);
698cce7d176Sdrh       }
699fef5208cSdrh       if( nErr==0 && pExpr->pList ){
700fef5208cSdrh         int n = pExpr->pList->nExpr;
701fef5208cSdrh         int i;
702fef5208cSdrh         for(i=0; nErr==0 && i<n; i++){
7032282792aSdrh           Expr *pE2 = pExpr->pList->a[i].pExpr;
7042282792aSdrh           nErr = sqliteExprCheck(pParse, pE2, allowAgg, pIsAgg);
705fef5208cSdrh         }
706fef5208cSdrh       }
707cce7d176Sdrh       break;
708cce7d176Sdrh     }
709cce7d176Sdrh   }
710cce7d176Sdrh   return nErr;
711cce7d176Sdrh }
712cce7d176Sdrh 
713cce7d176Sdrh /*
714cce7d176Sdrh ** Generate code into the current Vdbe to evaluate the given
7151ccde15dSdrh ** expression and leave the result on the top of stack.
716cce7d176Sdrh */
717cce7d176Sdrh void sqliteExprCode(Parse *pParse, Expr *pExpr){
718cce7d176Sdrh   Vdbe *v = pParse->pVdbe;
719cce7d176Sdrh   int op;
720daffd0e5Sdrh   if( v==0 || pExpr==0 ) return;
721cce7d176Sdrh   switch( pExpr->op ){
722cce7d176Sdrh     case TK_PLUS:     op = OP_Add;      break;
723cce7d176Sdrh     case TK_MINUS:    op = OP_Subtract; break;
724cce7d176Sdrh     case TK_STAR:     op = OP_Multiply; break;
725cce7d176Sdrh     case TK_SLASH:    op = OP_Divide;   break;
726cce7d176Sdrh     case TK_AND:      op = OP_And;      break;
727cce7d176Sdrh     case TK_OR:       op = OP_Or;       break;
728cce7d176Sdrh     case TK_LT:       op = OP_Lt;       break;
729cce7d176Sdrh     case TK_LE:       op = OP_Le;       break;
730cce7d176Sdrh     case TK_GT:       op = OP_Gt;       break;
731cce7d176Sdrh     case TK_GE:       op = OP_Ge;       break;
732cce7d176Sdrh     case TK_NE:       op = OP_Ne;       break;
733cce7d176Sdrh     case TK_EQ:       op = OP_Eq;       break;
734cce7d176Sdrh     case TK_LIKE:     op = OP_Like;     break;
735cce7d176Sdrh     case TK_GLOB:     op = OP_Glob;     break;
736cce7d176Sdrh     case TK_ISNULL:   op = OP_IsNull;   break;
737cce7d176Sdrh     case TK_NOTNULL:  op = OP_NotNull;  break;
738cce7d176Sdrh     case TK_NOT:      op = OP_Not;      break;
739cce7d176Sdrh     case TK_UMINUS:   op = OP_Negative; break;
740bf4133cbSdrh     case TK_BITAND:   op = OP_BitAnd;   break;
741bf4133cbSdrh     case TK_BITOR:    op = OP_BitOr;    break;
742bf4133cbSdrh     case TK_BITNOT:   op = OP_BitNot;   break;
743bf4133cbSdrh     case TK_LSHIFT:   op = OP_ShiftLeft;  break;
744bf4133cbSdrh     case TK_RSHIFT:   op = OP_ShiftRight; break;
745bf4133cbSdrh     case TK_REM:      op = OP_Remainder;  break;
746cce7d176Sdrh     default: break;
747cce7d176Sdrh   }
748cce7d176Sdrh   switch( pExpr->op ){
749967e8b73Sdrh     case TK_COLUMN: {
7502282792aSdrh       if( pParse->useAgg ){
75199fcd718Sdrh         sqliteVdbeAddOp(v, OP_AggGet, 0, pExpr->iAgg);
752c4a3c779Sdrh       }else if( pExpr->iColumn>=0 ){
75399fcd718Sdrh         sqliteVdbeAddOp(v, OP_Column, pExpr->iTable, pExpr->iColumn);
754c4a3c779Sdrh       }else{
75599fcd718Sdrh         sqliteVdbeAddOp(v, OP_Recno, pExpr->iTable, 0);
7562282792aSdrh       }
757cce7d176Sdrh       break;
758cce7d176Sdrh     }
759ef6764a1Sdrh     case TK_FLOAT:
760cce7d176Sdrh     case TK_INTEGER: {
7617a7c7390Sdrh       sqliteVdbeAddOp(v, OP_String, 0, 0);
762a76b5dfcSdrh       assert( pExpr->token.z );
7637a7c7390Sdrh       sqliteVdbeChangeP3(v, -1, pExpr->token.z, pExpr->token.n);
764cce7d176Sdrh       break;
765cce7d176Sdrh     }
766cce7d176Sdrh     case TK_STRING: {
76799fcd718Sdrh       int addr = sqliteVdbeAddOp(v, OP_String, 0, 0);
768a76b5dfcSdrh       assert( pExpr->token.z );
769cce7d176Sdrh       sqliteVdbeChangeP3(v, addr, pExpr->token.z, pExpr->token.n);
770cce7d176Sdrh       sqliteVdbeDequoteP3(v, addr);
771cce7d176Sdrh       break;
772cce7d176Sdrh     }
773cce7d176Sdrh     case TK_NULL: {
77499fcd718Sdrh       sqliteVdbeAddOp(v, OP_String, 0, 0);
775cce7d176Sdrh       break;
776cce7d176Sdrh     }
777cce7d176Sdrh     case TK_AND:
778cce7d176Sdrh     case TK_OR:
779cce7d176Sdrh     case TK_PLUS:
780cce7d176Sdrh     case TK_STAR:
781cce7d176Sdrh     case TK_MINUS:
782bf4133cbSdrh     case TK_REM:
783bf4133cbSdrh     case TK_BITAND:
784bf4133cbSdrh     case TK_BITOR:
785cce7d176Sdrh     case TK_SLASH: {
786cce7d176Sdrh       sqliteExprCode(pParse, pExpr->pLeft);
787cce7d176Sdrh       sqliteExprCode(pParse, pExpr->pRight);
78899fcd718Sdrh       sqliteVdbeAddOp(v, op, 0, 0);
789cce7d176Sdrh       break;
790cce7d176Sdrh     }
791bf4133cbSdrh     case TK_LSHIFT:
792bf4133cbSdrh     case TK_RSHIFT: {
793bf4133cbSdrh       sqliteExprCode(pParse, pExpr->pRight);
794bf4133cbSdrh       sqliteExprCode(pParse, pExpr->pLeft);
795bf4133cbSdrh       sqliteVdbeAddOp(v, op, 0, 0);
796bf4133cbSdrh       break;
797bf4133cbSdrh     }
7980040077dSdrh     case TK_CONCAT: {
7990040077dSdrh       sqliteExprCode(pParse, pExpr->pLeft);
8000040077dSdrh       sqliteExprCode(pParse, pExpr->pRight);
80199fcd718Sdrh       sqliteVdbeAddOp(v, OP_Concat, 2, 0);
8020040077dSdrh       break;
8030040077dSdrh     }
804cce7d176Sdrh     case TK_LT:
805cce7d176Sdrh     case TK_LE:
806cce7d176Sdrh     case TK_GT:
807cce7d176Sdrh     case TK_GE:
808cce7d176Sdrh     case TK_NE:
809cce7d176Sdrh     case TK_EQ:
810cce7d176Sdrh     case TK_LIKE:
811cce7d176Sdrh     case TK_GLOB: {
812cce7d176Sdrh       int dest;
81399fcd718Sdrh       sqliteVdbeAddOp(v, OP_Integer, 1, 0);
814cce7d176Sdrh       sqliteExprCode(pParse, pExpr->pLeft);
815cce7d176Sdrh       sqliteExprCode(pParse, pExpr->pRight);
816cce7d176Sdrh       dest = sqliteVdbeCurrentAddr(v) + 2;
81799fcd718Sdrh       sqliteVdbeAddOp(v, op, 0, dest);
81899fcd718Sdrh       sqliteVdbeAddOp(v, OP_AddImm, -1, 0);
819cce7d176Sdrh       break;
820cce7d176Sdrh     }
821cce7d176Sdrh     case TK_UMINUS: {
8226e142f54Sdrh       assert( pExpr->pLeft );
8237a7c7390Sdrh       if( pExpr->pLeft->op==TK_FLOAT || pExpr->pLeft->op==TK_INTEGER ){
8246e142f54Sdrh         Token *p = &pExpr->pLeft->token;
8256e142f54Sdrh         char *z = sqliteMalloc( p->n + 2 );
8266e142f54Sdrh         sprintf(z, "-%.*s", p->n, p->z);
82799fcd718Sdrh         sqliteVdbeAddOp(v, OP_String, 0, 0);
82899fcd718Sdrh         sqliteVdbeChangeP3(v, -1, z, p->n+1);
8296e142f54Sdrh         sqliteFree(z);
8306e142f54Sdrh         break;
8316e142f54Sdrh       }
8321ccde15dSdrh       /* Fall through into TK_NOT */
8336e142f54Sdrh     }
834bf4133cbSdrh     case TK_BITNOT:
8356e142f54Sdrh     case TK_NOT: {
836cce7d176Sdrh       sqliteExprCode(pParse, pExpr->pLeft);
83799fcd718Sdrh       sqliteVdbeAddOp(v, op, 0, 0);
838cce7d176Sdrh       break;
839cce7d176Sdrh     }
840cce7d176Sdrh     case TK_ISNULL:
841cce7d176Sdrh     case TK_NOTNULL: {
842cce7d176Sdrh       int dest;
84399fcd718Sdrh       sqliteVdbeAddOp(v, OP_Integer, 1, 0);
844cce7d176Sdrh       sqliteExprCode(pParse, pExpr->pLeft);
845cce7d176Sdrh       dest = sqliteVdbeCurrentAddr(v) + 2;
84699fcd718Sdrh       sqliteVdbeAddOp(v, op, 0, dest);
84799fcd718Sdrh       sqliteVdbeAddOp(v, OP_AddImm, -1, 0);
848cce7d176Sdrh       break;
849cce7d176Sdrh     }
8502282792aSdrh     case TK_AGG_FUNCTION: {
85199fcd718Sdrh       sqliteVdbeAddOp(v, OP_AggGet, 0, pExpr->iAgg);
8522282792aSdrh       break;
8532282792aSdrh     }
854cce7d176Sdrh     case TK_FUNCTION: {
855cce7d176Sdrh       int i;
856cce7d176Sdrh       ExprList *pList = pExpr->pList;
8570bce8354Sdrh       FuncDef *pDef;
8580bce8354Sdrh       pDef = sqliteFindFunction(pParse->db,
8598e0a2f90Sdrh                       pExpr->token.z, pExpr->token.n, pList->nExpr, 0);
8600bce8354Sdrh       assert( pDef!=0 );
8618e0a2f90Sdrh       for(i=0; i<pList->nExpr; i++){
8628e0a2f90Sdrh         sqliteExprCode(pParse, pList->a[i].pExpr);
8638e0a2f90Sdrh       }
8640bce8354Sdrh       sqliteVdbeAddOp(v, OP_Function, pList->nExpr, 0);
8650bce8354Sdrh       sqliteVdbeChangeP3(v, -1, (char*)pDef, P3_POINTER);
8666ec2733bSdrh       break;
8676ec2733bSdrh     }
86819a775c2Sdrh     case TK_SELECT: {
86999fcd718Sdrh       sqliteVdbeAddOp(v, OP_MemLoad, pExpr->iColumn, 0);
87019a775c2Sdrh       break;
87119a775c2Sdrh     }
872fef5208cSdrh     case TK_IN: {
873fef5208cSdrh       int addr;
87499fcd718Sdrh       sqliteVdbeAddOp(v, OP_Integer, 1, 0);
875fef5208cSdrh       sqliteExprCode(pParse, pExpr->pLeft);
876fef5208cSdrh       addr = sqliteVdbeCurrentAddr(v);
877fef5208cSdrh       if( pExpr->pSelect ){
87899fcd718Sdrh         sqliteVdbeAddOp(v, OP_Found, pExpr->iTable, addr+2);
879fef5208cSdrh       }else{
88099fcd718Sdrh         sqliteVdbeAddOp(v, OP_SetFound, pExpr->iTable, addr+2);
881fef5208cSdrh       }
88299fcd718Sdrh       sqliteVdbeAddOp(v, OP_AddImm, -1, 0);
883fef5208cSdrh       break;
884fef5208cSdrh     }
885fef5208cSdrh     case TK_BETWEEN: {
886fef5208cSdrh       int lbl = sqliteVdbeMakeLabel(v);
88799fcd718Sdrh       sqliteVdbeAddOp(v, OP_Integer, 0, 0);
888fef5208cSdrh       sqliteExprIfFalse(pParse, pExpr, lbl);
88999fcd718Sdrh       sqliteVdbeAddOp(v, OP_AddImm, 1, 0);
890fef5208cSdrh       sqliteVdbeResolveLabel(v, lbl);
891fef5208cSdrh       break;
892fef5208cSdrh     }
893a2e00042Sdrh     case TK_AS: {
894a2e00042Sdrh       sqliteExprCode(pParse, pExpr->pLeft);
895a2e00042Sdrh       break;
896a2e00042Sdrh     }
897cce7d176Sdrh   }
898cce7d176Sdrh   return;
899cce7d176Sdrh }
900cce7d176Sdrh 
901cce7d176Sdrh /*
902cce7d176Sdrh ** Generate code for a boolean expression such that a jump is made
903cce7d176Sdrh ** to the label "dest" if the expression is true but execution
904cce7d176Sdrh ** continues straight thru if the expression is false.
905cce7d176Sdrh */
906cce7d176Sdrh void sqliteExprIfTrue(Parse *pParse, Expr *pExpr, int dest){
907cce7d176Sdrh   Vdbe *v = pParse->pVdbe;
908cce7d176Sdrh   int op = 0;
909daffd0e5Sdrh   if( v==0 || pExpr==0 ) return;
910cce7d176Sdrh   switch( pExpr->op ){
911cce7d176Sdrh     case TK_LT:       op = OP_Lt;       break;
912cce7d176Sdrh     case TK_LE:       op = OP_Le;       break;
913cce7d176Sdrh     case TK_GT:       op = OP_Gt;       break;
914cce7d176Sdrh     case TK_GE:       op = OP_Ge;       break;
915cce7d176Sdrh     case TK_NE:       op = OP_Ne;       break;
916cce7d176Sdrh     case TK_EQ:       op = OP_Eq;       break;
917cce7d176Sdrh     case TK_LIKE:     op = OP_Like;     break;
918cce7d176Sdrh     case TK_GLOB:     op = OP_Glob;     break;
919cce7d176Sdrh     case TK_ISNULL:   op = OP_IsNull;   break;
920cce7d176Sdrh     case TK_NOTNULL:  op = OP_NotNull;  break;
921cce7d176Sdrh     default:  break;
922cce7d176Sdrh   }
923cce7d176Sdrh   switch( pExpr->op ){
924cce7d176Sdrh     case TK_AND: {
925cce7d176Sdrh       int d2 = sqliteVdbeMakeLabel(v);
926cce7d176Sdrh       sqliteExprIfFalse(pParse, pExpr->pLeft, d2);
927cce7d176Sdrh       sqliteExprIfTrue(pParse, pExpr->pRight, dest);
928cce7d176Sdrh       sqliteVdbeResolveLabel(v, d2);
929cce7d176Sdrh       break;
930cce7d176Sdrh     }
931cce7d176Sdrh     case TK_OR: {
932cce7d176Sdrh       sqliteExprIfTrue(pParse, pExpr->pLeft, dest);
933cce7d176Sdrh       sqliteExprIfTrue(pParse, pExpr->pRight, dest);
934cce7d176Sdrh       break;
935cce7d176Sdrh     }
936cce7d176Sdrh     case TK_NOT: {
937cce7d176Sdrh       sqliteExprIfFalse(pParse, pExpr->pLeft, dest);
938cce7d176Sdrh       break;
939cce7d176Sdrh     }
940cce7d176Sdrh     case TK_LT:
941cce7d176Sdrh     case TK_LE:
942cce7d176Sdrh     case TK_GT:
943cce7d176Sdrh     case TK_GE:
944cce7d176Sdrh     case TK_NE:
945cce7d176Sdrh     case TK_EQ:
946cce7d176Sdrh     case TK_LIKE:
947cce7d176Sdrh     case TK_GLOB: {
948cce7d176Sdrh       sqliteExprCode(pParse, pExpr->pLeft);
949cce7d176Sdrh       sqliteExprCode(pParse, pExpr->pRight);
95099fcd718Sdrh       sqliteVdbeAddOp(v, op, 0, dest);
951cce7d176Sdrh       break;
952cce7d176Sdrh     }
953cce7d176Sdrh     case TK_ISNULL:
954cce7d176Sdrh     case TK_NOTNULL: {
955cce7d176Sdrh       sqliteExprCode(pParse, pExpr->pLeft);
95699fcd718Sdrh       sqliteVdbeAddOp(v, op, 0, dest);
957cce7d176Sdrh       break;
958cce7d176Sdrh     }
959fef5208cSdrh     case TK_IN: {
960cfab11bcSdrh       sqliteExprCode(pParse, pExpr->pLeft);
961fef5208cSdrh       if( pExpr->pSelect ){
96299fcd718Sdrh         sqliteVdbeAddOp(v, OP_Found, pExpr->iTable, dest);
963fef5208cSdrh       }else{
96499fcd718Sdrh         sqliteVdbeAddOp(v, OP_SetFound, pExpr->iTable, dest);
965fef5208cSdrh       }
966fef5208cSdrh       break;
967fef5208cSdrh     }
968fef5208cSdrh     case TK_BETWEEN: {
969fef5208cSdrh       int lbl = sqliteVdbeMakeLabel(v);
970fef5208cSdrh       sqliteExprCode(pParse, pExpr->pLeft);
97199fcd718Sdrh       sqliteVdbeAddOp(v, OP_Dup, 0, 0);
972fef5208cSdrh       sqliteExprCode(pParse, pExpr->pList->a[0].pExpr);
97399fcd718Sdrh       sqliteVdbeAddOp(v, OP_Lt, 0, lbl);
974fef5208cSdrh       sqliteExprCode(pParse, pExpr->pList->a[1].pExpr);
97599fcd718Sdrh       sqliteVdbeAddOp(v, OP_Le, 0, dest);
97699fcd718Sdrh       sqliteVdbeAddOp(v, OP_Integer, 0, 0);
97799fcd718Sdrh       sqliteVdbeResolveLabel(v, lbl);
97899fcd718Sdrh       sqliteVdbeAddOp(v, OP_Pop, 1, 0);
979fef5208cSdrh       break;
980fef5208cSdrh     }
981cce7d176Sdrh     default: {
982cce7d176Sdrh       sqliteExprCode(pParse, pExpr);
98399fcd718Sdrh       sqliteVdbeAddOp(v, OP_If, 0, dest);
984cce7d176Sdrh       break;
985cce7d176Sdrh     }
986cce7d176Sdrh   }
987cce7d176Sdrh }
988cce7d176Sdrh 
989cce7d176Sdrh /*
99066b89c8fSdrh ** Generate code for a boolean expression such that a jump is made
991cce7d176Sdrh ** to the label "dest" if the expression is false but execution
992cce7d176Sdrh ** continues straight thru if the expression is true.
993cce7d176Sdrh */
994cce7d176Sdrh void sqliteExprIfFalse(Parse *pParse, Expr *pExpr, int dest){
995cce7d176Sdrh   Vdbe *v = pParse->pVdbe;
996cce7d176Sdrh   int op = 0;
997daffd0e5Sdrh   if( v==0 || pExpr==0 ) return;
998cce7d176Sdrh   switch( pExpr->op ){
999cce7d176Sdrh     case TK_LT:       op = OP_Ge;       break;
1000cce7d176Sdrh     case TK_LE:       op = OP_Gt;       break;
1001cce7d176Sdrh     case TK_GT:       op = OP_Le;       break;
1002cce7d176Sdrh     case TK_GE:       op = OP_Lt;       break;
1003cce7d176Sdrh     case TK_NE:       op = OP_Eq;       break;
1004cce7d176Sdrh     case TK_EQ:       op = OP_Ne;       break;
1005cce7d176Sdrh     case TK_LIKE:     op = OP_Like;     break;
1006cce7d176Sdrh     case TK_GLOB:     op = OP_Glob;     break;
1007cce7d176Sdrh     case TK_ISNULL:   op = OP_NotNull;  break;
1008cce7d176Sdrh     case TK_NOTNULL:  op = OP_IsNull;   break;
1009cce7d176Sdrh     default:  break;
1010cce7d176Sdrh   }
1011cce7d176Sdrh   switch( pExpr->op ){
1012cce7d176Sdrh     case TK_AND: {
1013cce7d176Sdrh       sqliteExprIfFalse(pParse, pExpr->pLeft, dest);
1014cce7d176Sdrh       sqliteExprIfFalse(pParse, pExpr->pRight, dest);
1015cce7d176Sdrh       break;
1016cce7d176Sdrh     }
1017cce7d176Sdrh     case TK_OR: {
1018cce7d176Sdrh       int d2 = sqliteVdbeMakeLabel(v);
1019cce7d176Sdrh       sqliteExprIfTrue(pParse, pExpr->pLeft, d2);
1020cce7d176Sdrh       sqliteExprIfFalse(pParse, pExpr->pRight, dest);
1021cce7d176Sdrh       sqliteVdbeResolveLabel(v, d2);
1022cce7d176Sdrh       break;
1023cce7d176Sdrh     }
1024cce7d176Sdrh     case TK_NOT: {
1025cce7d176Sdrh       sqliteExprIfTrue(pParse, pExpr->pLeft, dest);
1026cce7d176Sdrh       break;
1027cce7d176Sdrh     }
1028cce7d176Sdrh     case TK_LT:
1029cce7d176Sdrh     case TK_LE:
1030cce7d176Sdrh     case TK_GT:
1031cce7d176Sdrh     case TK_GE:
1032cce7d176Sdrh     case TK_NE:
1033cce7d176Sdrh     case TK_EQ: {
1034cce7d176Sdrh       sqliteExprCode(pParse, pExpr->pLeft);
1035cce7d176Sdrh       sqliteExprCode(pParse, pExpr->pRight);
103699fcd718Sdrh       sqliteVdbeAddOp(v, op, 0, dest);
1037cce7d176Sdrh       break;
1038cce7d176Sdrh     }
1039cce7d176Sdrh     case TK_LIKE:
1040cce7d176Sdrh     case TK_GLOB: {
1041cce7d176Sdrh       sqliteExprCode(pParse, pExpr->pLeft);
1042cce7d176Sdrh       sqliteExprCode(pParse, pExpr->pRight);
104399fcd718Sdrh       sqliteVdbeAddOp(v, op, 1, dest);
1044cce7d176Sdrh       break;
1045cce7d176Sdrh     }
1046cce7d176Sdrh     case TK_ISNULL:
1047cce7d176Sdrh     case TK_NOTNULL: {
1048cce7d176Sdrh       sqliteExprCode(pParse, pExpr->pLeft);
104999fcd718Sdrh       sqliteVdbeAddOp(v, op, 0, dest);
1050cce7d176Sdrh       break;
1051cce7d176Sdrh     }
1052fef5208cSdrh     case TK_IN: {
1053cfab11bcSdrh       sqliteExprCode(pParse, pExpr->pLeft);
1054fef5208cSdrh       if( pExpr->pSelect ){
105599fcd718Sdrh         sqliteVdbeAddOp(v, OP_NotFound, pExpr->iTable, dest);
1056fef5208cSdrh       }else{
105799fcd718Sdrh         sqliteVdbeAddOp(v, OP_SetNotFound, pExpr->iTable, dest);
1058fef5208cSdrh       }
1059fef5208cSdrh       break;
1060fef5208cSdrh     }
1061fef5208cSdrh     case TK_BETWEEN: {
1062fef5208cSdrh       int addr;
1063fef5208cSdrh       sqliteExprCode(pParse, pExpr->pLeft);
106499fcd718Sdrh       sqliteVdbeAddOp(v, OP_Dup, 0, 0);
1065fef5208cSdrh       sqliteExprCode(pParse, pExpr->pList->a[0].pExpr);
1066fef5208cSdrh       addr = sqliteVdbeCurrentAddr(v);
106799fcd718Sdrh       sqliteVdbeAddOp(v, OP_Ge, 0, addr+3);
106899fcd718Sdrh       sqliteVdbeAddOp(v, OP_Pop, 1, 0);
106999fcd718Sdrh       sqliteVdbeAddOp(v, OP_Goto, 0, dest);
1070fef5208cSdrh       sqliteExprCode(pParse, pExpr->pList->a[1].pExpr);
107199fcd718Sdrh       sqliteVdbeAddOp(v, OP_Gt, 0, dest);
1072fef5208cSdrh       break;
1073fef5208cSdrh     }
1074cce7d176Sdrh     default: {
1075cce7d176Sdrh       sqliteExprCode(pParse, pExpr);
107699fcd718Sdrh       sqliteVdbeAddOp(v, OP_Not, 0, 0);
107799fcd718Sdrh       sqliteVdbeAddOp(v, OP_If, 0, dest);
1078cce7d176Sdrh       break;
1079cce7d176Sdrh     }
1080cce7d176Sdrh   }
1081cce7d176Sdrh }
10822282792aSdrh 
10832282792aSdrh /*
10842282792aSdrh ** Do a deep comparison of two expression trees.  Return TRUE (non-zero)
10852282792aSdrh ** if they are identical and return FALSE if they differ in any way.
10862282792aSdrh */
1087d8bc7086Sdrh int sqliteExprCompare(Expr *pA, Expr *pB){
10882282792aSdrh   int i;
10892282792aSdrh   if( pA==0 ){
10902282792aSdrh     return pB==0;
10912282792aSdrh   }else if( pB==0 ){
10922282792aSdrh     return 0;
10932282792aSdrh   }
10942282792aSdrh   if( pA->op!=pB->op ) return 0;
1095d8bc7086Sdrh   if( !sqliteExprCompare(pA->pLeft, pB->pLeft) ) return 0;
1096d8bc7086Sdrh   if( !sqliteExprCompare(pA->pRight, pB->pRight) ) return 0;
10972282792aSdrh   if( pA->pList ){
10982282792aSdrh     if( pB->pList==0 ) return 0;
10992282792aSdrh     if( pA->pList->nExpr!=pB->pList->nExpr ) return 0;
11002282792aSdrh     for(i=0; i<pA->pList->nExpr; i++){
1101d8bc7086Sdrh       if( !sqliteExprCompare(pA->pList->a[i].pExpr, pB->pList->a[i].pExpr) ){
11022282792aSdrh         return 0;
11032282792aSdrh       }
11042282792aSdrh     }
11052282792aSdrh   }else if( pB->pList ){
11062282792aSdrh     return 0;
11072282792aSdrh   }
11082282792aSdrh   if( pA->pSelect || pB->pSelect ) return 0;
11092282792aSdrh   if( pA->token.z ){
11102282792aSdrh     if( pB->token.z==0 ) return 0;
11112282792aSdrh     if( pB->token.n!=pA->token.n ) return 0;
11122282792aSdrh     if( sqliteStrNICmp(pA->token.z, pB->token.z, pA->token.n)!=0 ) return 0;
11132282792aSdrh   }
11142282792aSdrh   return 1;
11152282792aSdrh }
11162282792aSdrh 
11172282792aSdrh /*
11182282792aSdrh ** Add a new element to the pParse->aAgg[] array and return its index.
11192282792aSdrh */
11202282792aSdrh static int appendAggInfo(Parse *pParse){
11212282792aSdrh   if( (pParse->nAgg & 0x7)==0 ){
11222282792aSdrh     int amt = pParse->nAgg + 8;
11236d4abfbeSdrh     AggExpr *aAgg = sqliteRealloc(pParse->aAgg, amt*sizeof(pParse->aAgg[0]));
11246d4abfbeSdrh     if( aAgg==0 ){
11252282792aSdrh       return -1;
11262282792aSdrh     }
11276d4abfbeSdrh     pParse->aAgg = aAgg;
11282282792aSdrh   }
11292282792aSdrh   memset(&pParse->aAgg[pParse->nAgg], 0, sizeof(pParse->aAgg[0]));
11302282792aSdrh   return pParse->nAgg++;
11312282792aSdrh }
11322282792aSdrh 
11332282792aSdrh /*
11342282792aSdrh ** Analyze the given expression looking for aggregate functions and
11352282792aSdrh ** for variables that need to be added to the pParse->aAgg[] array.
11362282792aSdrh ** Make additional entries to the pParse->aAgg[] array as necessary.
11372282792aSdrh **
11382282792aSdrh ** This routine should only be called after the expression has been
11392282792aSdrh ** analyzed by sqliteExprResolveIds() and sqliteExprCheck().
11402282792aSdrh **
11412282792aSdrh ** If errors are seen, leave an error message in zErrMsg and return
11422282792aSdrh ** the number of errors.
11432282792aSdrh */
11442282792aSdrh int sqliteExprAnalyzeAggregates(Parse *pParse, Expr *pExpr){
11452282792aSdrh   int i;
11462282792aSdrh   AggExpr *aAgg;
11472282792aSdrh   int nErr = 0;
11482282792aSdrh 
11492282792aSdrh   if( pExpr==0 ) return 0;
11502282792aSdrh   switch( pExpr->op ){
1151967e8b73Sdrh     case TK_COLUMN: {
11522282792aSdrh       aAgg = pParse->aAgg;
11532282792aSdrh       for(i=0; i<pParse->nAgg; i++){
11542282792aSdrh         if( aAgg[i].isAgg ) continue;
11552282792aSdrh         if( aAgg[i].pExpr->iTable==pExpr->iTable
1156967e8b73Sdrh          && aAgg[i].pExpr->iColumn==pExpr->iColumn ){
11572282792aSdrh           break;
11582282792aSdrh         }
11592282792aSdrh       }
11602282792aSdrh       if( i>=pParse->nAgg ){
11612282792aSdrh         i = appendAggInfo(pParse);
11622282792aSdrh         if( i<0 ) return 1;
11632282792aSdrh         pParse->aAgg[i].isAgg = 0;
11642282792aSdrh         pParse->aAgg[i].pExpr = pExpr;
11652282792aSdrh       }
1166aaf88729Sdrh       pExpr->iAgg = i;
11672282792aSdrh       break;
11682282792aSdrh     }
11692282792aSdrh     case TK_AGG_FUNCTION: {
11702282792aSdrh       aAgg = pParse->aAgg;
11712282792aSdrh       for(i=0; i<pParse->nAgg; i++){
11722282792aSdrh         if( !aAgg[i].isAgg ) continue;
1173d8bc7086Sdrh         if( sqliteExprCompare(aAgg[i].pExpr, pExpr) ){
11742282792aSdrh           break;
11752282792aSdrh         }
11762282792aSdrh       }
11772282792aSdrh       if( i>=pParse->nAgg ){
11782282792aSdrh         i = appendAggInfo(pParse);
11792282792aSdrh         if( i<0 ) return 1;
11802282792aSdrh         pParse->aAgg[i].isAgg = 1;
11812282792aSdrh         pParse->aAgg[i].pExpr = pExpr;
11820bce8354Sdrh         pParse->aAgg[i].pFunc = sqliteFindFunction(pParse->db,
1183*f55f25f0Sdrh              pExpr->token.z, pExpr->token.n,
1184*f55f25f0Sdrh              pExpr->pList ? pExpr->pList->nExpr : 0, 0);
11852282792aSdrh       }
11862282792aSdrh       pExpr->iAgg = i;
11872282792aSdrh       break;
11882282792aSdrh     }
11892282792aSdrh     default: {
11902282792aSdrh       if( pExpr->pLeft ){
11912282792aSdrh         nErr = sqliteExprAnalyzeAggregates(pParse, pExpr->pLeft);
11922282792aSdrh       }
11932282792aSdrh       if( nErr==0 && pExpr->pRight ){
11942282792aSdrh         nErr = sqliteExprAnalyzeAggregates(pParse, pExpr->pRight);
11952282792aSdrh       }
11962282792aSdrh       if( nErr==0 && pExpr->pList ){
11972282792aSdrh         int n = pExpr->pList->nExpr;
11982282792aSdrh         int i;
11992282792aSdrh         for(i=0; nErr==0 && i<n; i++){
12002282792aSdrh           nErr = sqliteExprAnalyzeAggregates(pParse, pExpr->pList->a[i].pExpr);
12012282792aSdrh         }
12022282792aSdrh       }
12032282792aSdrh       break;
12042282792aSdrh     }
12052282792aSdrh   }
12062282792aSdrh   return nErr;
12072282792aSdrh }
12088e0a2f90Sdrh 
12098e0a2f90Sdrh /*
12108e0a2f90Sdrh ** Locate a user function given a name and a number of arguments.
12110bce8354Sdrh ** Return a pointer to the FuncDef structure that defines that
12128e0a2f90Sdrh ** function, or return NULL if the function does not exist.
12138e0a2f90Sdrh **
12140bce8354Sdrh ** If the createFlag argument is true, then a new (blank) FuncDef
12158e0a2f90Sdrh ** structure is created and liked into the "db" structure if a
12168e0a2f90Sdrh ** no matching function previously existed.  When createFlag is true
12178e0a2f90Sdrh ** and the nArg parameter is -1, then only a function that accepts
12188e0a2f90Sdrh ** any number of arguments will be returned.
12198e0a2f90Sdrh **
12208e0a2f90Sdrh ** If createFlag is false and nArg is -1, then the first valid
12218e0a2f90Sdrh ** function found is returned.  A function is valid if either xFunc
12228e0a2f90Sdrh ** or xStep is non-zero.
12238e0a2f90Sdrh */
12240bce8354Sdrh FuncDef *sqliteFindFunction(
12258e0a2f90Sdrh   sqlite *db,        /* An open database */
12268e0a2f90Sdrh   const char *zName, /* Name of the function.  Not null-terminated */
12278e0a2f90Sdrh   int nName,         /* Number of characters in the name */
12288e0a2f90Sdrh   int nArg,          /* Number of arguments.  -1 means any number */
12298e0a2f90Sdrh   int createFlag     /* Create new entry if true and does not otherwise exist */
12308e0a2f90Sdrh ){
12310bce8354Sdrh   FuncDef *pFirst, *p, *pMaybe;
12320bce8354Sdrh   pFirst = p = (FuncDef*)sqliteHashFind(&db->aFunc, zName, nName);
12331350b030Sdrh   if( p && !createFlag && nArg<0 ){
12348e0a2f90Sdrh     while( p && p->xFunc==0 && p->xStep==0 ){ p = p->pNext; }
12358e0a2f90Sdrh     return p;
12368e0a2f90Sdrh   }
12378e0a2f90Sdrh   pMaybe = 0;
12388e0a2f90Sdrh   while( p && p->nArg!=nArg ){
12398e0a2f90Sdrh     if( p->nArg<0 && !createFlag && (p->xFunc || p->xStep) ) pMaybe = p;
12408e0a2f90Sdrh     p = p->pNext;
12418e0a2f90Sdrh   }
12428e0a2f90Sdrh   if( p && !createFlag && p->xFunc==0 && p->xStep==0 ){
12438e0a2f90Sdrh     return 0;
12448e0a2f90Sdrh   }
12458e0a2f90Sdrh   if( p==0 && pMaybe ){
12468e0a2f90Sdrh     assert( createFlag==0 );
12478e0a2f90Sdrh     return pMaybe;
12488e0a2f90Sdrh   }
12498e0a2f90Sdrh   if( p==0 && createFlag ){
12508e0a2f90Sdrh     p = sqliteMalloc( sizeof(*p) );
12518e0a2f90Sdrh     p->nArg = nArg;
12528e0a2f90Sdrh     p->pNext = pFirst;
12530bce8354Sdrh     sqliteHashInsert(&db->aFunc, zName, nName, (void*)p);
12548e0a2f90Sdrh   }
12558e0a2f90Sdrh   return p;
12568e0a2f90Sdrh }
1257