blob: ddd3e6248fa8b178b7fa887deba4bf0ea6edd6b2 [file] [log] [blame]
drh75897232000-05-29 14:26:00 +00001/*
drhb19a2bc2001-09-16 00:13:26 +00002** 2001 September 15
drh75897232000-05-29 14:26:00 +00003**
drhb19a2bc2001-09-16 00:13:26 +00004** The author disclaims copyright to this source code. In place of
5** a legal notice, here is a blessing:
drh75897232000-05-29 14:26:00 +00006**
drhb19a2bc2001-09-16 00:13:26 +00007** May you do good and not evil.
8** May you find forgiveness for yourself and forgive others.
9** May you share freely, never taking more than you give.
drh75897232000-05-29 14:26:00 +000010**
11*************************************************************************
12** This module contains C code that generates VDBE code used to process
drh51669862004-12-18 18:40:26 +000013** the WHERE clause of SQL statements. This module is reponsible for
14** generating the code that loops through a table looking for applicable
15** rows. Indices are selected and used to speed the search when doing
16** so is applicable. Because this module is responsible for selecting
17** indices, you might also think of this module as the "query optimizer".
drh75897232000-05-29 14:26:00 +000018**
danielk1977d0a69322005-02-02 01:10:44 +000019** $Id: where.c,v 1.134 2005/02/02 01:10:45 danielk1977 Exp $
drh75897232000-05-29 14:26:00 +000020*/
21#include "sqliteInt.h"
22
23/*
24** The query generator uses an array of instances of this structure to
25** help it analyze the subexpressions of the WHERE clause. Each WHERE
26** clause subexpression is separated from the others by an AND operator.
drh51669862004-12-18 18:40:26 +000027**
28** The idxLeft and idxRight fields are the VDBE cursor numbers for the
29** table that contains the column that appears on the left-hand and
30** right-hand side of ExprInfo.p. If either side of ExprInfo.p is
31** something other than a simple column reference, then idxLeft or
32** idxRight are -1.
33**
34** It is the VDBE cursor number is the value stored in Expr.iTable
35** when Expr.op==TK_COLUMN and the value stored in SrcList.a[].iCursor.
36**
37** prereqLeft, prereqRight, and prereqAll record sets of cursor numbers,
38** but they do so indirectly. A single ExprMaskSet structure translates
39** cursor number into bits and the translated bit is stored in the prereq
40** fields. The translation is used in order to maximize the number of
41** bits that will fit in a Bitmask. The VDBE cursor numbers might be
42** spread out over the non-negative integers. For example, the cursor
43** numbers might be 3, 8, 9, 10, 20, 23, 41, and 45. The ExprMaskSet
44** translates these sparse cursor numbers into consecutive integers
45** beginning with 0 in order to make the best possible use of the available
46** bits in the Bitmask. So, in the example above, the cursor numbers
47** would be mapped into integers 0 through 7.
48**
49** prereqLeft tells us every VDBE cursor that is referenced on the
50** left-hand side of ExprInfo.p. prereqRight does the same for the
51** right-hand side of the expression. The following identity always
52** holds:
53**
54** prereqAll = prereqLeft | prereqRight
55**
56** The ExprInfo.indexable field is true if the ExprInfo.p expression
57** is of a form that might control an index. Indexable expressions
58** look like this:
59**
60** <column> <op> <expr>
61**
62** Where <column> is a simple column name and <op> is on of the operators
63** that allowedOp() recognizes.
drh75897232000-05-29 14:26:00 +000064*/
65typedef struct ExprInfo ExprInfo;
66struct ExprInfo {
67 Expr *p; /* Pointer to the subexpression */
drhe3184742002-06-19 14:27:05 +000068 u8 indexable; /* True if this subexprssion is usable by an index */
69 short int idxLeft; /* p->pLeft is a column in this table number. -1 if
drh967e8b72000-06-21 13:59:10 +000070 ** p->pLeft is not the column of any table */
drhe3184742002-06-19 14:27:05 +000071 short int idxRight; /* p->pRight is a column in this table number. -1 if
drh967e8b72000-06-21 13:59:10 +000072 ** p->pRight is not the column of any table */
drh51669862004-12-18 18:40:26 +000073 Bitmask prereqLeft; /* Bitmask of tables referenced by p->pLeft */
74 Bitmask prereqRight; /* Bitmask of tables referenced by p->pRight */
75 Bitmask prereqAll; /* Bitmask of tables referenced by p */
drh75897232000-05-29 14:26:00 +000076};
77
78/*
drh6a3ea0e2003-05-02 14:32:12 +000079** An instance of the following structure keeps track of a mapping
drh51669862004-12-18 18:40:26 +000080** between VDBE cursor numbers and bits of the bitmasks in ExprInfo.
81**
82** The VDBE cursor numbers are small integers contained in
83** SrcList_item.iCursor and Expr.iTable fields. For any given WHERE
84** clause, the cursor numbers might not begin with 0 and they might
85** contain gaps in the numbering sequence. But we want to make maximum
86** use of the bits in our bitmasks. This structure provides a mapping
87** from the sparse cursor numbers into consecutive integers beginning
88** with 0.
89**
90** If ExprMaskSet.ix[A]==B it means that The A-th bit of a Bitmask
91** corresponds VDBE cursor number B. The A-th bit of a bitmask is 1<<A.
92**
93** For example, if the WHERE clause expression used these VDBE
94** cursors: 4, 5, 8, 29, 57, 73. Then the ExprMaskSet structure
95** would map those cursor numbers into bits 0 through 5.
96**
97** Note that the mapping is not necessarily ordered. In the example
98** above, the mapping might go like this: 4->3, 5->1, 8->2, 29->0,
99** 57->5, 73->4. Or one of 719 other combinations might be used. It
100** does not really matter. What is important is that sparse cursor
101** numbers all get mapped into bit numbers that begin with 0 and contain
102** no gaps.
drh6a3ea0e2003-05-02 14:32:12 +0000103*/
104typedef struct ExprMaskSet ExprMaskSet;
105struct ExprMaskSet {
drh1398ad32005-01-19 23:24:50 +0000106 int n; /* Number of assigned cursor values */
107 int ix[sizeof(Bitmask)*8]; /* Cursor assigned to each bit */
drh6a3ea0e2003-05-02 14:32:12 +0000108};
109
110/*
drh75897232000-05-29 14:26:00 +0000111** Determine the number of elements in an array.
112*/
113#define ARRAYSIZE(X) (sizeof(X)/sizeof(X[0]))
114
115/*
drh51669862004-12-18 18:40:26 +0000116** This routine identifies subexpressions in the WHERE clause where
117** each subexpression is separate by the AND operator. aSlot is
118** filled with pointers to the subexpressions. For example:
drh75897232000-05-29 14:26:00 +0000119**
drh51669862004-12-18 18:40:26 +0000120** WHERE a=='hello' AND coalesce(b,11)<10 AND (c+12!=d OR c==22)
121** \________/ \_______________/ \________________/
122** slot[0] slot[1] slot[2]
123**
124** The original WHERE clause in pExpr is unaltered. All this routine
125** does is make aSlot[] entries point to substructure within pExpr.
126**
127** aSlot[] is an array of subexpressions structures. There are nSlot
128** spaces left in this array. This routine finds as many AND-separated
129** subexpressions as it can and puts pointers to those subexpressions
130** into aSlot[] entries. The return value is the number of slots filled.
drh75897232000-05-29 14:26:00 +0000131*/
132static int exprSplit(int nSlot, ExprInfo *aSlot, Expr *pExpr){
133 int cnt = 0;
134 if( pExpr==0 || nSlot<1 ) return 0;
135 if( nSlot==1 || pExpr->op!=TK_AND ){
136 aSlot[0].p = pExpr;
137 return 1;
138 }
139 if( pExpr->pLeft->op!=TK_AND ){
140 aSlot[0].p = pExpr->pLeft;
141 cnt = 1 + exprSplit(nSlot-1, &aSlot[1], pExpr->pRight);
142 }else{
drhdcd997e2003-01-31 17:21:49 +0000143 cnt = exprSplit(nSlot, aSlot, pExpr->pLeft);
144 cnt += exprSplit(nSlot-cnt, &aSlot[cnt], pExpr->pRight);
drh75897232000-05-29 14:26:00 +0000145 }
146 return cnt;
147}
148
149/*
drh6a3ea0e2003-05-02 14:32:12 +0000150** Initialize an expression mask set
151*/
152#define initMaskSet(P) memset(P, 0, sizeof(*P))
153
154/*
drh1398ad32005-01-19 23:24:50 +0000155** Return the bitmask for the given cursor number. Return 0 if
156** iCursor is not in the set.
drh6a3ea0e2003-05-02 14:32:12 +0000157*/
drh51669862004-12-18 18:40:26 +0000158static Bitmask getMask(ExprMaskSet *pMaskSet, int iCursor){
drh6a3ea0e2003-05-02 14:32:12 +0000159 int i;
160 for(i=0; i<pMaskSet->n; i++){
drh51669862004-12-18 18:40:26 +0000161 if( pMaskSet->ix[i]==iCursor ){
162 return ((Bitmask)1)<<i;
163 }
drh6a3ea0e2003-05-02 14:32:12 +0000164 }
drh6a3ea0e2003-05-02 14:32:12 +0000165 return 0;
166}
167
168/*
drh1398ad32005-01-19 23:24:50 +0000169** Create a new mask for cursor iCursor.
170*/
171static void createMask(ExprMaskSet *pMaskSet, int iCursor){
172 if( pMaskSet->n<ARRAYSIZE(pMaskSet->ix) ){
173 pMaskSet->ix[pMaskSet->n++] = iCursor;
174 }
175}
176
177/*
drh6a3ea0e2003-05-02 14:32:12 +0000178** Destroy an expression mask set
179*/
180#define freeMaskSet(P) /* NO-OP */
181
182/*
drh75897232000-05-29 14:26:00 +0000183** This routine walks (recursively) an expression tree and generates
184** a bitmask indicating which tables are used in that expression
drh6a3ea0e2003-05-02 14:32:12 +0000185** tree.
drh75897232000-05-29 14:26:00 +0000186**
187** In order for this routine to work, the calling function must have
drh626a8792005-01-17 22:08:19 +0000188** previously invoked sqlite3ExprResolveNames() on the expression. See
drh75897232000-05-29 14:26:00 +0000189** the header comment on that routine for additional information.
drh626a8792005-01-17 22:08:19 +0000190** The sqlite3ExprResolveNames() routines looks for column names and
drh6a3ea0e2003-05-02 14:32:12 +0000191** sets their opcodes to TK_COLUMN and their Expr.iTable fields to
192** the VDBE cursor number of the table.
drh75897232000-05-29 14:26:00 +0000193*/
danielk1977b3bce662005-01-29 08:32:43 +0000194static Bitmask exprListTableUsage(ExprMaskSet *, ExprList *);
drh51669862004-12-18 18:40:26 +0000195static Bitmask exprTableUsage(ExprMaskSet *pMaskSet, Expr *p){
196 Bitmask mask = 0;
drh75897232000-05-29 14:26:00 +0000197 if( p==0 ) return 0;
drh967e8b72000-06-21 13:59:10 +0000198 if( p->op==TK_COLUMN ){
drh8feb4b12004-07-19 02:12:14 +0000199 mask = getMask(pMaskSet, p->iTable);
drh8feb4b12004-07-19 02:12:14 +0000200 return mask;
drh75897232000-05-29 14:26:00 +0000201 }
danielk1977b3bce662005-01-29 08:32:43 +0000202 mask = exprTableUsage(pMaskSet, p->pRight);
203 mask |= exprTableUsage(pMaskSet, p->pLeft);
204 mask |= exprListTableUsage(pMaskSet, p->pList);
205 if( p->pSelect ){
206 Select *pS = p->pSelect;
207 mask |= exprListTableUsage(pMaskSet, pS->pEList);
208 mask |= exprListTableUsage(pMaskSet, pS->pGroupBy);
209 mask |= exprListTableUsage(pMaskSet, pS->pOrderBy);
210 mask |= exprTableUsage(pMaskSet, pS->pWhere);
211 mask |= exprTableUsage(pMaskSet, pS->pHaving);
drh75897232000-05-29 14:26:00 +0000212 }
danielk1977b3bce662005-01-29 08:32:43 +0000213 return mask;
214}
215static Bitmask exprListTableUsage(ExprMaskSet *pMaskSet, ExprList *pList){
216 int i;
217 Bitmask mask = 0;
218 if( pList ){
219 for(i=0; i<pList->nExpr; i++){
220 mask |= exprTableUsage(pMaskSet, pList->a[i].pExpr);
drhdd579122002-04-02 01:58:57 +0000221 }
222 }
drh75897232000-05-29 14:26:00 +0000223 return mask;
224}
225
226/*
drh487ab3c2001-11-08 00:45:21 +0000227** Return TRUE if the given operator is one of the operators that is
drh51669862004-12-18 18:40:26 +0000228** allowed for an indexable WHERE clause term. The allowed operators are
drhc27a1ce2002-06-14 20:58:45 +0000229** "=", "<", ">", "<=", ">=", and "IN".
drh487ab3c2001-11-08 00:45:21 +0000230*/
231static int allowedOp(int op){
drh9a432672004-10-04 13:38:09 +0000232 assert( TK_GT==TK_LE-1 && TK_LE==TK_LT-1 && TK_LT==TK_GE-1 && TK_EQ==TK_GT-1);
233 return op==TK_IN || (op>=TK_EQ && op<=TK_GE);
drh487ab3c2001-11-08 00:45:21 +0000234}
235
236/*
drh51669862004-12-18 18:40:26 +0000237** Swap two objects of type T.
drh193bd772004-07-20 18:23:14 +0000238*/
239#define SWAP(TYPE,A,B) {TYPE t=A; A=B; B=t;}
240
241/*
242** Return the index in the SrcList that uses cursor iCur. If iCur is
243** used by the first entry in SrcList return 0. If iCur is used by
244** the second entry return 1. And so forth.
245**
246** SrcList is the set of tables in the FROM clause in the order that
247** they will be processed. The value returned here gives us an index
248** of which tables will be processed first.
249*/
250static int tableOrder(SrcList *pList, int iCur){
251 int i;
drh51669862004-12-18 18:40:26 +0000252 struct SrcList_item *pItem;
253 for(i=0, pItem=pList->a; i<pList->nSrc; i++, pItem++){
254 if( pItem->iCursor==iCur ) return i;
drh193bd772004-07-20 18:23:14 +0000255 }
256 return -1;
257}
258
259/*
drh75897232000-05-29 14:26:00 +0000260** The input to this routine is an ExprInfo structure with only the
261** "p" field filled in. The job of this routine is to analyze the
262** subexpression and populate all the other fields of the ExprInfo
263** structure.
264*/
drh193bd772004-07-20 18:23:14 +0000265static void exprAnalyze(SrcList *pSrc, ExprMaskSet *pMaskSet, ExprInfo *pInfo){
drh75897232000-05-29 14:26:00 +0000266 Expr *pExpr = pInfo->p;
drh6a3ea0e2003-05-02 14:32:12 +0000267 pInfo->prereqLeft = exprTableUsage(pMaskSet, pExpr->pLeft);
268 pInfo->prereqRight = exprTableUsage(pMaskSet, pExpr->pRight);
269 pInfo->prereqAll = exprTableUsage(pMaskSet, pExpr);
drh75897232000-05-29 14:26:00 +0000270 pInfo->indexable = 0;
271 pInfo->idxLeft = -1;
272 pInfo->idxRight = -1;
drh487ab3c2001-11-08 00:45:21 +0000273 if( allowedOp(pExpr->op) && (pInfo->prereqRight & pInfo->prereqLeft)==0 ){
drhd99f7062002-06-08 23:25:08 +0000274 if( pExpr->pRight && pExpr->pRight->op==TK_COLUMN ){
drh6a3ea0e2003-05-02 14:32:12 +0000275 pInfo->idxRight = pExpr->pRight->iTable;
drh75897232000-05-29 14:26:00 +0000276 pInfo->indexable = 1;
277 }
drh967e8b72000-06-21 13:59:10 +0000278 if( pExpr->pLeft->op==TK_COLUMN ){
drh6a3ea0e2003-05-02 14:32:12 +0000279 pInfo->idxLeft = pExpr->pLeft->iTable;
drh75897232000-05-29 14:26:00 +0000280 pInfo->indexable = 1;
281 }
282 }
drh193bd772004-07-20 18:23:14 +0000283 if( pInfo->indexable ){
284 assert( pInfo->idxLeft!=pInfo->idxRight );
285
286 /* We want the expression to be of the form "X = expr", not "expr = X".
287 ** So flip it over if necessary. If the expression is "X = Y", then
288 ** we want Y to come from an earlier table than X.
289 **
290 ** The collating sequence rule is to always choose the left expression.
291 ** So if we do a flip, we also have to move the collating sequence.
292 */
293 if( tableOrder(pSrc,pInfo->idxLeft)<tableOrder(pSrc,pInfo->idxRight) ){
294 assert( pExpr->op!=TK_IN );
295 SWAP(CollSeq*,pExpr->pRight->pColl,pExpr->pLeft->pColl);
296 SWAP(Expr*,pExpr->pRight,pExpr->pLeft);
drh9a432672004-10-04 13:38:09 +0000297 if( pExpr->op>=TK_GT ){
298 assert( TK_LT==TK_GT+2 );
299 assert( TK_GE==TK_LE+2 );
300 assert( TK_GT>TK_EQ );
301 assert( TK_GT<TK_LE );
302 assert( pExpr->op>=TK_GT && pExpr->op<=TK_GE );
303 pExpr->op = ((pExpr->op-TK_GT)^2)+TK_GT;
drh193bd772004-07-20 18:23:14 +0000304 }
305 SWAP(unsigned, pInfo->prereqLeft, pInfo->prereqRight);
306 SWAP(short int, pInfo->idxLeft, pInfo->idxRight);
307 }
308 }
309
drh75897232000-05-29 14:26:00 +0000310}
311
312/*
drh51669862004-12-18 18:40:26 +0000313** This routine decides if pIdx can be used to satisfy the ORDER BY
314** clause. If it can, it returns 1. If pIdx cannot satisfy the
315** ORDER BY clause, this routine returns 0.
316**
317** pOrderBy is an ORDER BY clause from a SELECT statement. pTab is the
318** left-most table in the FROM clause of that same SELECT statement and
319** the table has a cursor number of "base". pIdx is an index on pTab.
320**
321** nEqCol is the number of columns of pIdx that are used as equality
322** constraints. Any of these columns may be missing from the ORDER BY
323** clause and the match can still be a success.
324**
325** If the index is UNIQUE, then the ORDER BY clause is allowed to have
326** additional terms past the end of the index and the match will still
327** be a success.
328**
329** All terms of the ORDER BY that match against the index must be either
330** ASC or DESC. (Terms of the ORDER BY clause past the end of a UNIQUE
331** index do not need to satisfy this constraint.) The *pbRev value is
332** set to 1 if the ORDER BY clause is all DESC and it is set to 0 if
333** the ORDER BY clause is all ASC.
334*/
335static int isSortingIndex(
336 Parse *pParse, /* Parsing context */
337 Index *pIdx, /* The index we are testing */
338 Table *pTab, /* The table to be sorted */
339 int base, /* Cursor number for pTab */
340 ExprList *pOrderBy, /* The ORDER BY clause */
341 int nEqCol, /* Number of index columns with == constraints */
342 int *pbRev /* Set to 1 if ORDER BY is DESC */
343){
344 int i, j; /* Loop counters */
345 int sortOrder; /* Which direction we are sorting */
346 int nTerm; /* Number of ORDER BY terms */
347 struct ExprList_item *pTerm; /* A term of the ORDER BY clause */
348 sqlite3 *db = pParse->db;
349
350 assert( pOrderBy!=0 );
351 nTerm = pOrderBy->nExpr;
352 assert( nTerm>0 );
353
354 /* Match terms of the ORDER BY clause against columns of
355 ** the index.
356 */
357 for(i=j=0, pTerm=pOrderBy->a; j<nTerm && i<pIdx->nColumn; i++){
358 Expr *pExpr; /* The expression of the ORDER BY pTerm */
359 CollSeq *pColl; /* The collating sequence of pExpr */
360
361 pExpr = pTerm->pExpr;
362 if( pExpr->op!=TK_COLUMN || pExpr->iTable!=base ){
363 /* Can not use an index sort on anything that is not a column in the
364 ** left-most table of the FROM clause */
365 return 0;
366 }
367 pColl = sqlite3ExprCollSeq(pParse, pExpr);
368 if( !pColl ) pColl = db->pDfltColl;
drh9012bcb2004-12-19 00:11:35 +0000369 if( pExpr->iColumn!=pIdx->aiColumn[i] || pColl!=pIdx->keyInfo.aColl[i] ){
370 /* Term j of the ORDER BY clause does not match column i of the index */
371 if( i<nEqCol ){
drh51669862004-12-18 18:40:26 +0000372 /* If an index column that is constrained by == fails to match an
373 ** ORDER BY term, that is OK. Just ignore that column of the index
374 */
375 continue;
376 }else{
377 /* If an index column fails to match and is not constrained by ==
378 ** then the index cannot satisfy the ORDER BY constraint.
379 */
380 return 0;
381 }
382 }
383 if( i>nEqCol ){
384 if( pTerm->sortOrder!=sortOrder ){
385 /* Indices can only be used if all ORDER BY terms past the
386 ** equality constraints are all either DESC or ASC. */
387 return 0;
388 }
389 }else{
390 sortOrder = pTerm->sortOrder;
391 }
392 j++;
393 pTerm++;
394 }
395
396 /* The index can be used for sorting if all terms of the ORDER BY clause
397 ** or covered or if we ran out of index columns and the it is a UNIQUE
398 ** index.
399 */
400 if( j>=nTerm || (i>=pIdx->nColumn && pIdx->onError!=OE_None) ){
401 *pbRev = sortOrder==SQLITE_SO_DESC;
402 return 1;
403 }
404 return 0;
405}
406
407/*
drhb6c29892004-11-22 19:12:19 +0000408** Check table to see if the ORDER BY clause in pOrderBy can be satisfied
409** by sorting in order of ROWID. Return true if so and set *pbRev to be
410** true for reverse ROWID and false for forward ROWID order.
411*/
412static int sortableByRowid(
413 int base, /* Cursor number for table to be sorted */
414 ExprList *pOrderBy, /* The ORDER BY clause */
415 int *pbRev /* Set to 1 if ORDER BY is DESC */
416){
417 Expr *p;
418
419 assert( pOrderBy!=0 );
420 assert( pOrderBy->nExpr>0 );
421 p = pOrderBy->a[0].pExpr;
422 if( p->op==TK_COLUMN && p->iTable==base && p->iColumn==-1 ){
423 *pbRev = pOrderBy->a[0].sortOrder;
424 return 1;
425 }
426 return 0;
427}
428
429
430/*
drh2ffb1182004-07-19 19:14:01 +0000431** Disable a term in the WHERE clause. Except, do not disable the term
432** if it controls a LEFT OUTER JOIN and it did not originate in the ON
433** or USING clause of that join.
434**
435** Consider the term t2.z='ok' in the following queries:
436**
437** (1) SELECT * FROM t1 LEFT JOIN t2 ON t1.a=t2.x WHERE t2.z='ok'
438** (2) SELECT * FROM t1 LEFT JOIN t2 ON t1.a=t2.x AND t2.z='ok'
439** (3) SELECT * FROM t1, t2 WHERE t1.a=t2.x AND t2.z='ok'
440**
drh23bf66d2004-12-14 03:34:34 +0000441** The t2.z='ok' is disabled in the in (2) because it originates
drh2ffb1182004-07-19 19:14:01 +0000442** in the ON clause. The term is disabled in (3) because it is not part
443** of a LEFT OUTER JOIN. In (1), the term is not disabled.
444**
445** Disabling a term causes that term to not be tested in the inner loop
446** of the join. Disabling is an optimization. We would get the correct
447** results if nothing were ever disabled, but joins might run a little
448** slower. The trick is to disable as much as we can without disabling
449** too much. If we disabled in (1), we'd get the wrong answer.
450** See ticket #813.
451*/
452static void disableTerm(WhereLevel *pLevel, Expr **ppExpr){
453 Expr *pExpr = *ppExpr;
454 if( pLevel->iLeftJoin==0 || ExprHasProperty(pExpr, EP_FromJoin) ){
455 *ppExpr = 0;
456 }
457}
458
459/*
drh94a11212004-09-25 13:12:14 +0000460** Generate code that builds a probe for an index. Details:
461**
462** * Check the top nColumn entries on the stack. If any
463** of those entries are NULL, jump immediately to brk,
464** which is the loop exit, since no index entry will match
465** if any part of the key is NULL.
466**
467** * Construct a probe entry from the top nColumn entries in
468** the stack with affinities appropriate for index pIdx.
469*/
470static void buildIndexProbe(Vdbe *v, int nColumn, int brk, Index *pIdx){
471 sqlite3VdbeAddOp(v, OP_NotNull, -nColumn, sqlite3VdbeCurrentAddr(v)+3);
472 sqlite3VdbeAddOp(v, OP_Pop, nColumn, 0);
473 sqlite3VdbeAddOp(v, OP_Goto, 0, brk);
474 sqlite3VdbeAddOp(v, OP_MakeRecord, nColumn, 0);
475 sqlite3IndexAffinityStr(v, pIdx);
476}
477
478/*
479** Generate code for an equality term of the WHERE clause. An equality
480** term can be either X=expr or X IN (...). pTerm is the X.
481*/
482static void codeEqualityTerm(
483 Parse *pParse, /* The parsing context */
484 ExprInfo *pTerm, /* The term of the WHERE clause to be coded */
485 int brk, /* Jump here to abandon the loop */
486 WhereLevel *pLevel /* When level of the FROM clause we are working on */
487){
488 Expr *pX = pTerm->p;
489 if( pX->op!=TK_IN ){
490 assert( pX->op==TK_EQ );
491 sqlite3ExprCode(pParse, pX->pRight);
danielk1977b3bce662005-01-29 08:32:43 +0000492#ifndef SQLITE_OMIT_SUBQUERY
drh94a11212004-09-25 13:12:14 +0000493 }else{
danielk1977b3bce662005-01-29 08:32:43 +0000494 int iTab;
drh94a11212004-09-25 13:12:14 +0000495 Vdbe *v = pParse->pVdbe;
danielk1977b3bce662005-01-29 08:32:43 +0000496
497 sqlite3CodeSubselect(pParse, pX);
498 iTab = pX->iTable;
drh94a11212004-09-25 13:12:14 +0000499 sqlite3VdbeAddOp(v, OP_Rewind, iTab, brk);
500 sqlite3VdbeAddOp(v, OP_KeyAsData, iTab, 1);
danielk1977b3bce662005-01-29 08:32:43 +0000501 VdbeComment((v, "# %.*s", pX->span.n, pX->span.z));
drh9012bcb2004-12-19 00:11:35 +0000502 pLevel->inP2 = sqlite3VdbeAddOp(v, OP_Column, iTab, 0);
drh94a11212004-09-25 13:12:14 +0000503 pLevel->inOp = OP_Next;
504 pLevel->inP1 = iTab;
danielk1977b3bce662005-01-29 08:32:43 +0000505#endif
drh94a11212004-09-25 13:12:14 +0000506 }
507 disableTerm(pLevel, &pTerm->p);
508}
509
drh51669862004-12-18 18:40:26 +0000510/*
511** The number of bits in a Bitmask
512*/
513#define BMS (sizeof(Bitmask)*8-1)
514
drh94a11212004-09-25 13:12:14 +0000515
516/*
drhe3184742002-06-19 14:27:05 +0000517** Generate the beginning of the loop used for WHERE clause processing.
drhacf3b982005-01-03 01:27:18 +0000518** The return value is a pointer to an opaque structure that contains
drh75897232000-05-29 14:26:00 +0000519** information needed to terminate the loop. Later, the calling routine
danielk19774adee202004-05-08 08:23:19 +0000520** should invoke sqlite3WhereEnd() with the return value of this function
drh75897232000-05-29 14:26:00 +0000521** in order to complete the WHERE clause processing.
522**
523** If an error occurs, this routine returns NULL.
drhc27a1ce2002-06-14 20:58:45 +0000524**
525** The basic idea is to do a nested loop, one loop for each table in
526** the FROM clause of a select. (INSERT and UPDATE statements are the
527** same as a SELECT with only a single table in the FROM clause.) For
528** example, if the SQL is this:
529**
530** SELECT * FROM t1, t2, t3 WHERE ...;
531**
532** Then the code generated is conceptually like the following:
533**
534** foreach row1 in t1 do \ Code generated
danielk19774adee202004-05-08 08:23:19 +0000535** foreach row2 in t2 do |-- by sqlite3WhereBegin()
drhc27a1ce2002-06-14 20:58:45 +0000536** foreach row3 in t3 do /
537** ...
538** end \ Code generated
danielk19774adee202004-05-08 08:23:19 +0000539** end |-- by sqlite3WhereEnd()
drhc27a1ce2002-06-14 20:58:45 +0000540** end /
541**
542** There are Btree cursors associated with each table. t1 uses cursor
drh6a3ea0e2003-05-02 14:32:12 +0000543** number pTabList->a[0].iCursor. t2 uses the cursor pTabList->a[1].iCursor.
544** And so forth. This routine generates code to open those VDBE cursors
danielk19774adee202004-05-08 08:23:19 +0000545** and sqlite3WhereEnd() generates the code to close them.
drhc27a1ce2002-06-14 20:58:45 +0000546**
drhe6f85e72004-12-25 01:03:13 +0000547** The code that sqlite3WhereBegin() generates leaves the cursors named
548** in pTabList pointing at their appropriate entries. The [...] code
drh7465a802005-01-03 01:28:51 +0000549** can use OP_Column and OP_Recno opcodes on these cursors to extract
drhe6f85e72004-12-25 01:03:13 +0000550** data from the various tables of the loop.
551**
drhc27a1ce2002-06-14 20:58:45 +0000552** If the WHERE clause is empty, the foreach loops must each scan their
553** entire tables. Thus a three-way join is an O(N^3) operation. But if
554** the tables have indices and there are terms in the WHERE clause that
555** refer to those indices, a complete table scan can be avoided and the
556** code will run much faster. Most of the work of this routine is checking
557** to see if there are indices that can be used to speed up the loop.
558**
559** Terms of the WHERE clause are also used to limit which rows actually
560** make it to the "..." in the middle of the loop. After each "foreach",
561** terms of the WHERE clause that use only terms in that loop and outer
562** loops are evaluated and if false a jump is made around all subsequent
563** inner loops (or around the "..." if the test occurs within the inner-
564** most loop)
565**
566** OUTER JOINS
567**
568** An outer join of tables t1 and t2 is conceptally coded as follows:
569**
570** foreach row1 in t1 do
571** flag = 0
572** foreach row2 in t2 do
573** start:
574** ...
575** flag = 1
576** end
drhe3184742002-06-19 14:27:05 +0000577** if flag==0 then
578** move the row2 cursor to a null row
579** goto start
580** fi
drhc27a1ce2002-06-14 20:58:45 +0000581** end
582**
drhe3184742002-06-19 14:27:05 +0000583** ORDER BY CLAUSE PROCESSING
584**
585** *ppOrderBy is a pointer to the ORDER BY clause of a SELECT statement,
586** if there is one. If there is no ORDER BY clause or if this routine
587** is called from an UPDATE or DELETE statement, then ppOrderBy is NULL.
588**
589** If an index can be used so that the natural output order of the table
590** scan is correct for the ORDER BY clause, then that index is used and
591** *ppOrderBy is set to NULL. This is an optimization that prevents an
592** unnecessary sort of the result set if an index appropriate for the
593** ORDER BY clause already exists.
594**
595** If the where clause loops cannot be arranged to provide the correct
596** output order, then the *ppOrderBy is unchanged.
drh75897232000-05-29 14:26:00 +0000597*/
danielk19774adee202004-05-08 08:23:19 +0000598WhereInfo *sqlite3WhereBegin(
danielk1977ed326d72004-11-16 15:50:19 +0000599 Parse *pParse, /* The parser context */
600 SrcList *pTabList, /* A list of all tables to be scanned */
601 Expr *pWhere, /* The WHERE clause */
drhe4e72072004-11-23 01:47:30 +0000602 ExprList **ppOrderBy, /* An ORDER BY clause, or NULL */
603 Fetch *pFetch /* Initial location of cursors. NULL otherwise */
drh75897232000-05-29 14:26:00 +0000604){
605 int i; /* Loop counter */
606 WhereInfo *pWInfo; /* Will become the return value of this function */
607 Vdbe *v = pParse->pVdbe; /* The virtual database engine */
drhd4f5ee22003-07-16 00:54:31 +0000608 int brk, cont = 0; /* Addresses used during code generation */
drh75897232000-05-29 14:26:00 +0000609 int nExpr; /* Number of subexpressions in the WHERE clause */
drh51669862004-12-18 18:40:26 +0000610 Bitmask loopMask; /* One bit set for each outer loop */
drh193bd772004-07-20 18:23:14 +0000611 ExprInfo *pTerm; /* A single term in the WHERE clause; ptr to aExpr[] */
drh6a3ea0e2003-05-02 14:32:12 +0000612 ExprMaskSet maskSet; /* The expression mask set */
drh51669862004-12-18 18:40:26 +0000613 int iDirectEq[BMS]; /* Term of the form ROWID==X for the N-th table */
614 int iDirectLt[BMS]; /* Term of the form ROWID<X or ROWID<=X */
615 int iDirectGt[BMS]; /* Term of the form ROWID>X or ROWID>=X */
drh193bd772004-07-20 18:23:14 +0000616 ExprInfo aExpr[101]; /* The WHERE clause is divided into these terms */
drh9012bcb2004-12-19 00:11:35 +0000617 struct SrcList_item *pTabItem; /* A single entry from pTabList */
618 WhereLevel *pLevel; /* A single level in the pWInfo list */
drh75897232000-05-29 14:26:00 +0000619
drh1398ad32005-01-19 23:24:50 +0000620 /* The number of terms in the FROM clause is limited by the number of
621 ** bits in a Bitmask
622 */
623 if( pTabList->nSrc>sizeof(Bitmask)*8 ){
624 sqlite3ErrorMsg(pParse, "at most %d tables in a join",
625 sizeof(Bitmask)*8);
626 return 0;
627 }
628
drh83dcb1a2002-06-28 01:02:38 +0000629 /* Split the WHERE clause into separate subexpressions where each
630 ** subexpression is separated by an AND operator. If the aExpr[]
631 ** array fills up, the last entry might point to an expression which
632 ** contains additional unfactored AND operators.
633 */
drh6a3ea0e2003-05-02 14:32:12 +0000634 initMaskSet(&maskSet);
drh83dcb1a2002-06-28 01:02:38 +0000635 memset(aExpr, 0, sizeof(aExpr));
636 nExpr = exprSplit(ARRAYSIZE(aExpr), aExpr, pWhere);
637 if( nExpr==ARRAYSIZE(aExpr) ){
danielk19774adee202004-05-08 08:23:19 +0000638 sqlite3ErrorMsg(pParse, "WHERE clause too complex - no more "
drhf7a9e1a2004-02-22 18:40:56 +0000639 "than %d terms allowed", (int)ARRAYSIZE(aExpr)-1);
drh83dcb1a2002-06-28 01:02:38 +0000640 return 0;
641 }
drh1398ad32005-01-19 23:24:50 +0000642
drh75897232000-05-29 14:26:00 +0000643 /* Allocate and initialize the WhereInfo structure that will become the
644 ** return value.
645 */
drhad3cab52002-05-24 02:04:32 +0000646 pWInfo = sqliteMalloc( sizeof(WhereInfo) + pTabList->nSrc*sizeof(WhereLevel));
danielk1977132872b2004-05-10 10:37:18 +0000647 if( sqlite3_malloc_failed ){
drh193bd772004-07-20 18:23:14 +0000648 /* sqliteFree(pWInfo); // Leak memory when malloc fails */
drh75897232000-05-29 14:26:00 +0000649 return 0;
650 }
651 pWInfo->pParse = pParse;
652 pWInfo->pTabList = pTabList;
danielk19774adee202004-05-08 08:23:19 +0000653 pWInfo->iBreak = sqlite3VdbeMakeLabel(v);
drh08192d52002-04-30 19:20:28 +0000654
655 /* Special case: a WHERE clause that is constant. Evaluate the
656 ** expression and either jump over all of the code or fall thru.
657 */
danielk19774adee202004-05-08 08:23:19 +0000658 if( pWhere && (pTabList->nSrc==0 || sqlite3ExprIsConstant(pWhere)) ){
659 sqlite3ExprIfFalse(pParse, pWhere, pWInfo->iBreak, 1);
drhdf199a22002-06-14 22:38:41 +0000660 pWhere = 0;
drh08192d52002-04-30 19:20:28 +0000661 }
drh75897232000-05-29 14:26:00 +0000662
drh75897232000-05-29 14:26:00 +0000663 /* Analyze all of the subexpressions.
664 */
drh1398ad32005-01-19 23:24:50 +0000665 for(i=0; i<pTabList->nSrc; i++){
666 createMask(&maskSet, pTabList->a[i].iCursor);
667 }
drh193bd772004-07-20 18:23:14 +0000668 for(pTerm=aExpr, i=0; i<nExpr; i++, pTerm++){
drh193bd772004-07-20 18:23:14 +0000669 exprAnalyze(pTabList, &maskSet, pTerm);
drh75897232000-05-29 14:26:00 +0000670 }
671
drh75897232000-05-29 14:26:00 +0000672 /* Figure out what index to use (if any) for each nested loop.
drh6b563442001-11-07 16:48:26 +0000673 ** Make pWInfo->a[i].pIdx point to the index to use for the i-th nested
drhad3cab52002-05-24 02:04:32 +0000674 ** loop where i==0 is the outer loop and i==pTabList->nSrc-1 is the inner
drh8aff1012001-12-22 14:49:24 +0000675 ** loop.
676 **
677 ** If terms exist that use the ROWID of any table, then set the
678 ** iDirectEq[], iDirectLt[], or iDirectGt[] elements for that table
679 ** to the index of the term containing the ROWID. We always prefer
680 ** to use a ROWID which can directly access a table rather than an
drh0a36c572002-02-18 22:49:59 +0000681 ** index which requires reading an index first to get the rowid then
682 ** doing a second read of the actual database table.
drh75897232000-05-29 14:26:00 +0000683 **
684 ** Actually, if there are more than 32 tables in the join, only the
drh0a36c572002-02-18 22:49:59 +0000685 ** first 32 tables are candidates for indices. This is (again) due
686 ** to the limit of 32 bits in an integer bitmask.
drh75897232000-05-29 14:26:00 +0000687 */
688 loopMask = 0;
drh9012bcb2004-12-19 00:11:35 +0000689 pTabItem = pTabList->a;
690 pLevel = pWInfo->a;
691 for(i=0; i<pTabList->nSrc && i<ARRAYSIZE(iDirectEq); i++,pTabItem++,pLevel++){
drhc4a3c772001-04-04 11:48:57 +0000692 int j;
drh9012bcb2004-12-19 00:11:35 +0000693 int iCur = pTabItem->iCursor; /* The cursor for this table */
drh51669862004-12-18 18:40:26 +0000694 Bitmask mask = getMask(&maskSet, iCur); /* Cursor mask for this table */
drh9012bcb2004-12-19 00:11:35 +0000695 Table *pTab = pTabItem->pTab;
drh75897232000-05-29 14:26:00 +0000696 Index *pIdx;
697 Index *pBestIdx = 0;
drh487ab3c2001-11-08 00:45:21 +0000698 int bestScore = 0;
drh51669862004-12-18 18:40:26 +0000699 int bestRev = 0;
drh75897232000-05-29 14:26:00 +0000700
drhc4a3c772001-04-04 11:48:57 +0000701 /* Check to see if there is an expression that uses only the
drh8aff1012001-12-22 14:49:24 +0000702 ** ROWID field of this table. For terms of the form ROWID==expr
703 ** set iDirectEq[i] to the index of the term. For terms of the
704 ** form ROWID<expr or ROWID<=expr set iDirectLt[i] to the term index.
705 ** For terms like ROWID>expr or ROWID>=expr set iDirectGt[i].
drh174b6192002-12-03 02:22:52 +0000706 **
707 ** (Added:) Treat ROWID IN expr like ROWID=expr.
drhc4a3c772001-04-04 11:48:57 +0000708 */
drh9012bcb2004-12-19 00:11:35 +0000709 pLevel->iIdxCur = -1;
drh8aff1012001-12-22 14:49:24 +0000710 iDirectEq[i] = -1;
711 iDirectLt[i] = -1;
712 iDirectGt[i] = -1;
drh193bd772004-07-20 18:23:14 +0000713 for(pTerm=aExpr, j=0; j<nExpr; j++, pTerm++){
714 Expr *pX = pTerm->p;
715 if( pTerm->idxLeft==iCur && pX->pLeft->iColumn<0
716 && (pTerm->prereqRight & loopMask)==pTerm->prereqRight ){
717 switch( pX->op ){
drhd99f7062002-06-08 23:25:08 +0000718 case TK_IN:
drh8aff1012001-12-22 14:49:24 +0000719 case TK_EQ: iDirectEq[i] = j; break;
720 case TK_LE:
721 case TK_LT: iDirectLt[i] = j; break;
722 case TK_GE:
723 case TK_GT: iDirectGt[i] = j; break;
724 }
drhc4a3c772001-04-04 11:48:57 +0000725 }
drhc4a3c772001-04-04 11:48:57 +0000726 }
drhb6c29892004-11-22 19:12:19 +0000727
728 /* If we found a term that tests ROWID with == or IN, that term
729 ** will be used to locate the rows in the database table. There
730 ** is not need to continue into the code below that looks for
731 ** an index. We will always use the ROWID over an index.
732 */
drh8aff1012001-12-22 14:49:24 +0000733 if( iDirectEq[i]>=0 ){
drh6a3ea0e2003-05-02 14:32:12 +0000734 loopMask |= mask;
drh94a11212004-09-25 13:12:14 +0000735 pLevel->pIdx = 0;
drhc4a3c772001-04-04 11:48:57 +0000736 continue;
737 }
738
drh75897232000-05-29 14:26:00 +0000739 /* Do a search for usable indices. Leave pBestIdx pointing to
drh487ab3c2001-11-08 00:45:21 +0000740 ** the "best" index. pBestIdx is left set to NULL if no indices
741 ** are usable.
drh75897232000-05-29 14:26:00 +0000742 **
drhacf3b982005-01-03 01:27:18 +0000743 ** The best index is the one with the highest score. The score
744 ** for the index is determined as follows. For each of the
drh487ab3c2001-11-08 00:45:21 +0000745 ** left-most terms that is fixed by an equality operator, add
drh51669862004-12-18 18:40:26 +0000746 ** 32 to the score. The right-most term of the index may be
747 ** constrained by an inequality. Add 4 if for an "x<..." constraint
748 ** and add 8 for an "x>..." constraint. If both constraints
749 ** are present, add 12.
750 **
751 ** If the left-most term of the index uses an IN operator
752 ** (ex: "x IN (...)") then add 16 to the score.
753 **
754 ** If an index can be used for sorting, add 2 to the score.
755 ** If an index contains all the terms of a table that are ever
756 ** used by any expression in the SQL statement, then add 1 to
757 ** the score.
drh487ab3c2001-11-08 00:45:21 +0000758 **
759 ** This scoring system is designed so that the score can later be
drh51669862004-12-18 18:40:26 +0000760 ** used to determine how the index is used. If the score&0x1c is 0
761 ** then all constraints are equalities. If score&0x4 is not 0 then
drh487ab3c2001-11-08 00:45:21 +0000762 ** there is an inequality used as a termination key. (ex: "x<...")
drh51669862004-12-18 18:40:26 +0000763 ** If score&0x8 is not 0 then there is an inequality used as the
764 ** start key. (ex: "x>..."). A score or 0x10 is the special case
drhc045ec52002-12-04 20:01:06 +0000765 ** of an IN operator constraint. (ex: "x IN ...").
drhd99f7062002-06-08 23:25:08 +0000766 **
drhc27a1ce2002-06-14 20:58:45 +0000767 ** The IN operator (as in "<expr> IN (...)") is treated the same as
768 ** an equality comparison except that it can only be used on the
769 ** left-most column of an index and other terms of the WHERE clause
770 ** cannot be used in conjunction with the IN operator to help satisfy
771 ** other columns of the index.
drh75897232000-05-29 14:26:00 +0000772 */
773 for(pIdx=pTab->pIndex; pIdx; pIdx=pIdx->pNext){
drh51669862004-12-18 18:40:26 +0000774 Bitmask eqMask = 0; /* Index columns covered by an x=... term */
775 Bitmask ltMask = 0; /* Index columns covered by an x<... term */
776 Bitmask gtMask = 0; /* Index columns covered by an x>... term */
777 Bitmask inMask = 0; /* Index columns covered by an x IN .. term */
778 Bitmask m;
779 int nEq, score, bRev = 0;
drh75897232000-05-29 14:26:00 +0000780
drh51669862004-12-18 18:40:26 +0000781 if( pIdx->nColumn>sizeof(eqMask)*8 ){
782 continue; /* Ignore indices with too many columns to analyze */
783 }
drh193bd772004-07-20 18:23:14 +0000784 for(pTerm=aExpr, j=0; j<nExpr; j++, pTerm++){
drh193bd772004-07-20 18:23:14 +0000785 Expr *pX = pTerm->p;
drh94a11212004-09-25 13:12:14 +0000786 CollSeq *pColl = sqlite3ExprCollSeq(pParse, pX->pLeft);
drh193bd772004-07-20 18:23:14 +0000787 if( !pColl && pX->pRight ){
788 pColl = sqlite3ExprCollSeq(pParse, pX->pRight);
danielk19770202b292004-06-09 09:55:16 +0000789 }
790 if( !pColl ){
791 pColl = pParse->db->pDfltColl;
792 }
drh193bd772004-07-20 18:23:14 +0000793 if( pTerm->idxLeft==iCur
794 && (pTerm->prereqRight & loopMask)==pTerm->prereqRight ){
795 int iColumn = pX->pLeft->iColumn;
drh75897232000-05-29 14:26:00 +0000796 int k;
danielk1977e014a832004-05-17 10:48:57 +0000797 char idxaff = pIdx->pTable->aCol[iColumn].affinity;
drh967e8b72000-06-21 13:59:10 +0000798 for(k=0; k<pIdx->nColumn; k++){
danielk19770202b292004-06-09 09:55:16 +0000799 /* If the collating sequences or affinities don't match,
800 ** ignore this index. */
801 if( pColl!=pIdx->keyInfo.aColl[k] ) continue;
drh193bd772004-07-20 18:23:14 +0000802 if( !sqlite3IndexAffinityOk(pX, idxaff) ) continue;
danielk19770202b292004-06-09 09:55:16 +0000803 if( pIdx->aiColumn[k]==iColumn ){
drh193bd772004-07-20 18:23:14 +0000804 switch( pX->op ){
drh48185c12002-06-09 01:55:20 +0000805 case TK_IN: {
806 if( k==0 ) inMask |= 1;
807 break;
808 }
drh487ab3c2001-11-08 00:45:21 +0000809 case TK_EQ: {
drh51669862004-12-18 18:40:26 +0000810 eqMask |= ((Bitmask)1)<<k;
drh487ab3c2001-11-08 00:45:21 +0000811 break;
812 }
813 case TK_LE:
814 case TK_LT: {
drh51669862004-12-18 18:40:26 +0000815 ltMask |= ((Bitmask)1)<<k;
drh487ab3c2001-11-08 00:45:21 +0000816 break;
817 }
818 case TK_GE:
819 case TK_GT: {
drh51669862004-12-18 18:40:26 +0000820 gtMask |= ((Bitmask)1)<<k;
drh487ab3c2001-11-08 00:45:21 +0000821 break;
822 }
823 default: {
824 /* CANT_HAPPEN */
825 assert( 0 );
826 break;
827 }
828 }
drh75897232000-05-29 14:26:00 +0000829 break;
830 }
831 }
832 }
drh75897232000-05-29 14:26:00 +0000833 }
drhc045ec52002-12-04 20:01:06 +0000834
835 /* The following loop ends with nEq set to the number of columns
836 ** on the left of the index with == constraints.
837 */
drh487ab3c2001-11-08 00:45:21 +0000838 for(nEq=0; nEq<pIdx->nColumn; nEq++){
drh51669862004-12-18 18:40:26 +0000839 m = (((Bitmask)1)<<(nEq+1))-1;
drh487ab3c2001-11-08 00:45:21 +0000840 if( (m & eqMask)!=m ) break;
841 }
drh51669862004-12-18 18:40:26 +0000842
843 /* Begin assemblying the score
844 */
845 score = nEq*32; /* Base score is 32 times number of == constraints */
846 m = ((Bitmask)1)<<nEq;
847 if( m & ltMask ) score+=4; /* Increase score for a < constraint */
848 if( m & gtMask ) score+=8; /* Increase score for a > constraint */
849 if( score==0 && inMask ) score = 16; /* Default score for IN constraint */
850
851 /* Give bonus points if this index can be used for sorting
852 */
drh9012bcb2004-12-19 00:11:35 +0000853 if( i==0 && score!=16 && ppOrderBy && *ppOrderBy ){
drh51669862004-12-18 18:40:26 +0000854 int base = pTabList->a[0].iCursor;
855 if( isSortingIndex(pParse, pIdx, pTab, base, *ppOrderBy, nEq, &bRev) ){
856 score += 2;
857 }
858 }
859
drh9012bcb2004-12-19 00:11:35 +0000860 /* Check to see if we can get away with using just the index without
861 ** ever reading the table. If that is the case, then add one bonus
862 ** point to the score.
863 */
864 if( score && pTabItem->colUsed < (((Bitmask)1)<<(BMS-1)) ){
865 for(m=0, j=0; j<pIdx->nColumn; j++){
866 int x = pIdx->aiColumn[j];
867 if( x<BMS-1 ){
868 m |= ((Bitmask)1)<<x;
869 }
870 }
871 if( (pTabItem->colUsed & m)==pTabItem->colUsed ){
872 score++;
873 }
874 }
875
drh51669862004-12-18 18:40:26 +0000876 /* If the score for this index is the best we have seen so far, then
877 ** save it
878 */
drh487ab3c2001-11-08 00:45:21 +0000879 if( score>bestScore ){
880 pBestIdx = pIdx;
881 bestScore = score;
drh51669862004-12-18 18:40:26 +0000882 bestRev = bRev;
drh75897232000-05-29 14:26:00 +0000883 }
884 }
drh94a11212004-09-25 13:12:14 +0000885 pLevel->pIdx = pBestIdx;
886 pLevel->score = bestScore;
drh51669862004-12-18 18:40:26 +0000887 pLevel->bRev = bestRev;
drh6a3ea0e2003-05-02 14:32:12 +0000888 loopMask |= mask;
drh6b563442001-11-07 16:48:26 +0000889 if( pBestIdx ){
drh9012bcb2004-12-19 00:11:35 +0000890 pLevel->iIdxCur = pParse->nTab++;
drh6b563442001-11-07 16:48:26 +0000891 }
drh75897232000-05-29 14:26:00 +0000892 }
893
drhe3184742002-06-19 14:27:05 +0000894 /* Check to see if the ORDER BY clause is or can be satisfied by the
895 ** use of an index on the first table.
896 */
897 if( ppOrderBy && *ppOrderBy && pTabList->nSrc>0 ){
drh9012bcb2004-12-19 00:11:35 +0000898 Index *pIdx; /* Index derived from the WHERE clause */
899 Table *pTab; /* Left-most table in the FROM clause */
900 int bRev = 0; /* True to reverse the output order */
901 int iCur; /* Btree-cursor that will be used by pTab */
902 WhereLevel *pLevel0 = &pWInfo->a[0];
drhe3184742002-06-19 14:27:05 +0000903
drh9012bcb2004-12-19 00:11:35 +0000904 pTab = pTabList->a[0].pTab;
905 pIdx = pLevel0->pIdx;
906 iCur = pTabList->a[0].iCursor;
907 if( pIdx==0 && sortableByRowid(iCur, *ppOrderBy, &bRev) ){
908 /* The ORDER BY clause specifies ROWID order, which is what we
909 ** were going to be doing anyway...
910 */
911 *ppOrderBy = 0;
912 pLevel0->bRev = bRev;
913 }else if( pLevel0->score==16 ){
914 /* If there is already an IN index on the left-most table,
915 ** it will not give the correct sort order.
916 ** So, pretend that no suitable index is found.
917 */
918 }else if( iDirectEq[0]>=0 || iDirectLt[0]>=0 || iDirectGt[0]>=0 ){
919 /* If the left-most column is accessed using its ROWID, then do
920 ** not try to sort by index. But do delete the ORDER BY clause
921 ** if it is redundant.
922 */
923 }else if( (pLevel0->score&2)!=0 ){
924 /* The index that was selected for searching will cause rows to
925 ** appear in sorted order.
926 */
927 *ppOrderBy = 0;
drh75897232000-05-29 14:26:00 +0000928 }
929 }
930
drh9012bcb2004-12-19 00:11:35 +0000931 /* Open all tables in the pTabList and any indices selected for
932 ** searching those tables.
933 */
934 sqlite3CodeVerifySchema(pParse, -1); /* Insert the cookie verifier Goto */
935 pLevel = pWInfo->a;
936 for(i=0, pTabItem=pTabList->a; i<pTabList->nSrc; i++, pTabItem++, pLevel++){
937 Table *pTab;
938 Index *pIx;
939 int iIdxCur = pLevel->iIdxCur;
940
941 pTab = pTabItem->pTab;
942 if( pTab->isTransient || pTab->pSelect ) continue;
943 if( (pLevel->score & 1)==0 ){
944 sqlite3OpenTableForReading(v, pTabItem->iCursor, pTab);
945 }
946 pLevel->iTabCur = pTabItem->iCursor;
947 if( (pIx = pLevel->pIdx)!=0 ){
948 sqlite3VdbeAddOp(v, OP_Integer, pIx->iDb, 0);
949 sqlite3VdbeOp3(v, OP_OpenRead, iIdxCur, pIx->tnum,
950 (char*)&pIx->keyInfo, P3_KEYINFO);
951 }
952 if( (pLevel->score & 1)!=0 ){
953 sqlite3VdbeAddOp(v, OP_KeyAsData, iIdxCur, 1);
954 sqlite3VdbeAddOp(v, OP_SetNumColumns, iIdxCur, pIx->nColumn+1);
955 }
956 sqlite3CodeVerifySchema(pParse, pTab->iDb);
957 }
958 pWInfo->iTop = sqlite3VdbeCurrentAddr(v);
959
drh75897232000-05-29 14:26:00 +0000960 /* Generate the code to do the search
961 */
drh75897232000-05-29 14:26:00 +0000962 loopMask = 0;
drh9012bcb2004-12-19 00:11:35 +0000963 pLevel = pWInfo->a;
964 pTabItem = pTabList->a;
965 for(i=0; i<pTabList->nSrc; i++, pTabItem++, pLevel++){
drh75897232000-05-29 14:26:00 +0000966 int j, k;
drh9012bcb2004-12-19 00:11:35 +0000967 int iCur = pTabItem->iCursor; /* The VDBE cursor for the table */
968 Index *pIdx; /* The index we will be using */
969 int iIdxCur; /* The VDBE cursor for the index */
970 int omitTable; /* True if we use the index only */
971
972 pIdx = pLevel->pIdx;
973 iIdxCur = pLevel->iIdxCur;
974 pLevel->inOp = OP_Noop;
975
976 /* Check to see if it is appropriate to omit the use of the table
977 ** here and use its index instead.
978 */
979 omitTable = (pLevel->score&1)!=0;
drh75897232000-05-29 14:26:00 +0000980
drhad2d8302002-05-24 20:31:36 +0000981 /* If this is the right table of a LEFT OUTER JOIN, allocate and
drh174b6192002-12-03 02:22:52 +0000982 ** initialize a memory cell that records if this table matches any
drhc27a1ce2002-06-14 20:58:45 +0000983 ** row of the left table of the join.
drhad2d8302002-05-24 20:31:36 +0000984 */
985 if( i>0 && (pTabList->a[i-1].jointype & JT_LEFT)!=0 ){
986 if( !pParse->nMem ) pParse->nMem++;
987 pLevel->iLeftJoin = pParse->nMem++;
danielk19770f69c1e2004-05-29 11:24:50 +0000988 sqlite3VdbeAddOp(v, OP_String8, 0, 0);
danielk19774adee202004-05-08 08:23:19 +0000989 sqlite3VdbeAddOp(v, OP_MemStore, pLevel->iLeftJoin, 1);
drhad6d9462004-09-19 02:15:24 +0000990 VdbeComment((v, "# init LEFT JOIN no-match flag"));
drhad2d8302002-05-24 20:31:36 +0000991 }
992
drh94a11212004-09-25 13:12:14 +0000993 if( i<ARRAYSIZE(iDirectEq) && (k = iDirectEq[i])>=0 ){
drh8aff1012001-12-22 14:49:24 +0000994 /* Case 1: We can directly reference a single row using an
drhc27a1ce2002-06-14 20:58:45 +0000995 ** equality comparison against the ROWID field. Or
996 ** we reference multiple rows using a "rowid IN (...)"
997 ** construct.
drhc4a3c772001-04-04 11:48:57 +0000998 */
drh8aff1012001-12-22 14:49:24 +0000999 assert( k<nExpr );
drh193bd772004-07-20 18:23:14 +00001000 pTerm = &aExpr[k];
1001 assert( pTerm->p!=0 );
drh193bd772004-07-20 18:23:14 +00001002 assert( pTerm->idxLeft==iCur );
drh9012bcb2004-12-19 00:11:35 +00001003 assert( omitTable==0 );
drh94a11212004-09-25 13:12:14 +00001004 brk = pLevel->brk = sqlite3VdbeMakeLabel(v);
1005 codeEqualityTerm(pParse, pTerm, brk, pLevel);
danielk19774adee202004-05-08 08:23:19 +00001006 cont = pLevel->cont = sqlite3VdbeMakeLabel(v);
1007 sqlite3VdbeAddOp(v, OP_MustBeInt, 1, brk);
danielk19774adee202004-05-08 08:23:19 +00001008 sqlite3VdbeAddOp(v, OP_NotExists, iCur, brk);
tpoindex7a9b1612005-01-03 18:13:18 +00001009 VdbeComment((v, "pk"));
drh6b563442001-11-07 16:48:26 +00001010 pLevel->op = OP_Noop;
drh9012bcb2004-12-19 00:11:35 +00001011 }else if( pIdx!=0 && pLevel->score>3 && (pLevel->score&0x0c)==0 ){
drhc27a1ce2002-06-14 20:58:45 +00001012 /* Case 2: There is an index and all terms of the WHERE clause that
drhb6c29892004-11-22 19:12:19 +00001013 ** refer to the index using the "==" or "IN" operators.
drh75897232000-05-29 14:26:00 +00001014 */
drh6b563442001-11-07 16:48:26 +00001015 int start;
drh51669862004-12-18 18:40:26 +00001016 int nColumn = (pLevel->score+16)/32;
danielk19774adee202004-05-08 08:23:19 +00001017 brk = pLevel->brk = sqlite3VdbeMakeLabel(v);
drh772ae622004-05-19 13:13:08 +00001018
1019 /* For each column of the index, find the term of the WHERE clause that
1020 ** constraints that column. If the WHERE clause term is X=expr, then
1021 ** evaluation expr and leave the result on the stack */
drh487ab3c2001-11-08 00:45:21 +00001022 for(j=0; j<nColumn; j++){
drh193bd772004-07-20 18:23:14 +00001023 for(pTerm=aExpr, k=0; k<nExpr; k++, pTerm++){
1024 Expr *pX = pTerm->p;
drhd99f7062002-06-08 23:25:08 +00001025 if( pX==0 ) continue;
drh193bd772004-07-20 18:23:14 +00001026 if( pTerm->idxLeft==iCur
1027 && (pTerm->prereqRight & loopMask)==pTerm->prereqRight
drhd99f7062002-06-08 23:25:08 +00001028 && pX->pLeft->iColumn==pIdx->aiColumn[j]
drhac931eb2005-01-11 18:13:56 +00001029 && (pX->op==TK_EQ || pX->op==TK_IN)
drh75897232000-05-29 14:26:00 +00001030 ){
danielk1977e014a832004-05-17 10:48:57 +00001031 char idxaff = pIdx->pTable->aCol[pX->pLeft->iColumn].affinity;
drh94a11212004-09-25 13:12:14 +00001032 if( sqlite3IndexAffinityOk(pX, idxaff) ){
1033 codeEqualityTerm(pParse, pTerm, brk, pLevel);
1034 break;
drhd99f7062002-06-08 23:25:08 +00001035 }
drh75897232000-05-29 14:26:00 +00001036 }
drh75897232000-05-29 14:26:00 +00001037 }
1038 }
drh6b563442001-11-07 16:48:26 +00001039 pLevel->iMem = pParse->nMem++;
danielk19774adee202004-05-08 08:23:19 +00001040 cont = pLevel->cont = sqlite3VdbeMakeLabel(v);
drh94a11212004-09-25 13:12:14 +00001041 buildIndexProbe(v, nColumn, brk, pIdx);
danielk19773d1bfea2004-05-14 11:00:53 +00001042 sqlite3VdbeAddOp(v, OP_MemStore, pLevel->iMem, 0);
drh772ae622004-05-19 13:13:08 +00001043
drh772ae622004-05-19 13:13:08 +00001044 /* Generate code (1) to move to the first matching element of the table.
1045 ** Then generate code (2) that jumps to "brk" after the cursor is past
1046 ** the last matching element of the table. The code (1) is executed
1047 ** once to initialize the search, the code (2) is executed before each
1048 ** iteration of the scan to see if the scan has finished. */
drhc045ec52002-12-04 20:01:06 +00001049 if( pLevel->bRev ){
1050 /* Scan in reverse order */
drh9012bcb2004-12-19 00:11:35 +00001051 sqlite3VdbeAddOp(v, OP_MoveLe, iIdxCur, brk);
danielk19774adee202004-05-08 08:23:19 +00001052 start = sqlite3VdbeAddOp(v, OP_MemLoad, pLevel->iMem, 0);
drh9012bcb2004-12-19 00:11:35 +00001053 sqlite3VdbeAddOp(v, OP_IdxLT, iIdxCur, brk);
drhc045ec52002-12-04 20:01:06 +00001054 pLevel->op = OP_Prev;
1055 }else{
1056 /* Scan in the forward order */
drh9012bcb2004-12-19 00:11:35 +00001057 sqlite3VdbeAddOp(v, OP_MoveGe, iIdxCur, brk);
danielk19774adee202004-05-08 08:23:19 +00001058 start = sqlite3VdbeAddOp(v, OP_MemLoad, pLevel->iMem, 0);
drh9012bcb2004-12-19 00:11:35 +00001059 sqlite3VdbeOp3(v, OP_IdxGE, iIdxCur, brk, "+", P3_STATIC);
drhc045ec52002-12-04 20:01:06 +00001060 pLevel->op = OP_Next;
1061 }
drh9012bcb2004-12-19 00:11:35 +00001062 sqlite3VdbeAddOp(v, OP_RowKey, iIdxCur, 0);
danielk19774adee202004-05-08 08:23:19 +00001063 sqlite3VdbeAddOp(v, OP_IdxIsNull, nColumn, cont);
drhe6f85e72004-12-25 01:03:13 +00001064 if( !omitTable ){
drh9012bcb2004-12-19 00:11:35 +00001065 sqlite3VdbeAddOp(v, OP_IdxRecno, iIdxCur, 0);
drhe6f85e72004-12-25 01:03:13 +00001066 sqlite3VdbeAddOp(v, OP_MoveGe, iCur, 0);
drh75897232000-05-29 14:26:00 +00001067 }
drh9012bcb2004-12-19 00:11:35 +00001068 pLevel->p1 = iIdxCur;
drh6b563442001-11-07 16:48:26 +00001069 pLevel->p2 = start;
drh8aff1012001-12-22 14:49:24 +00001070 }else if( i<ARRAYSIZE(iDirectLt) && (iDirectLt[i]>=0 || iDirectGt[i]>=0) ){
1071 /* Case 3: We have an inequality comparison against the ROWID field.
1072 */
1073 int testOp = OP_Noop;
1074 int start;
drhb6c29892004-11-22 19:12:19 +00001075 int bRev = pLevel->bRev;
drh8aff1012001-12-22 14:49:24 +00001076
drh9012bcb2004-12-19 00:11:35 +00001077 assert( omitTable==0 );
danielk19774adee202004-05-08 08:23:19 +00001078 brk = pLevel->brk = sqlite3VdbeMakeLabel(v);
1079 cont = pLevel->cont = sqlite3VdbeMakeLabel(v);
drhb6c29892004-11-22 19:12:19 +00001080 if( bRev ){
1081 int t = iDirectGt[i];
1082 iDirectGt[i] = iDirectLt[i];
1083 iDirectLt[i] = t;
1084 }
drh8aff1012001-12-22 14:49:24 +00001085 if( iDirectGt[i]>=0 ){
drh94a11212004-09-25 13:12:14 +00001086 Expr *pX;
drh8aff1012001-12-22 14:49:24 +00001087 k = iDirectGt[i];
1088 assert( k<nExpr );
drh193bd772004-07-20 18:23:14 +00001089 pTerm = &aExpr[k];
drh94a11212004-09-25 13:12:14 +00001090 pX = pTerm->p;
1091 assert( pX!=0 );
drh193bd772004-07-20 18:23:14 +00001092 assert( pTerm->idxLeft==iCur );
drh94a11212004-09-25 13:12:14 +00001093 sqlite3ExprCode(pParse, pX->pRight);
danielk1977d0a69322005-02-02 01:10:44 +00001094 sqlite3VdbeAddOp(v, OP_ForceInt, pX->op==TK_LE || pX->op==TK_GT, brk);
drhb6c29892004-11-22 19:12:19 +00001095 sqlite3VdbeAddOp(v, bRev ? OP_MoveLt : OP_MoveGe, iCur, brk);
tpoindex7a9b1612005-01-03 18:13:18 +00001096 VdbeComment((v, "pk"));
drh193bd772004-07-20 18:23:14 +00001097 disableTerm(pLevel, &pTerm->p);
drh8aff1012001-12-22 14:49:24 +00001098 }else{
drhb6c29892004-11-22 19:12:19 +00001099 sqlite3VdbeAddOp(v, bRev ? OP_Last : OP_Rewind, iCur, brk);
drh8aff1012001-12-22 14:49:24 +00001100 }
1101 if( iDirectLt[i]>=0 ){
drh94a11212004-09-25 13:12:14 +00001102 Expr *pX;
drh8aff1012001-12-22 14:49:24 +00001103 k = iDirectLt[i];
1104 assert( k<nExpr );
drh193bd772004-07-20 18:23:14 +00001105 pTerm = &aExpr[k];
drh94a11212004-09-25 13:12:14 +00001106 pX = pTerm->p;
1107 assert( pX!=0 );
drh193bd772004-07-20 18:23:14 +00001108 assert( pTerm->idxLeft==iCur );
drh94a11212004-09-25 13:12:14 +00001109 sqlite3ExprCode(pParse, pX->pRight);
drh8aff1012001-12-22 14:49:24 +00001110 pLevel->iMem = pParse->nMem++;
danielk19774adee202004-05-08 08:23:19 +00001111 sqlite3VdbeAddOp(v, OP_MemStore, pLevel->iMem, 1);
drh94a11212004-09-25 13:12:14 +00001112 if( pX->op==TK_LT || pX->op==TK_GT ){
drhb6c29892004-11-22 19:12:19 +00001113 testOp = bRev ? OP_Le : OP_Ge;
drh8aff1012001-12-22 14:49:24 +00001114 }else{
drhb6c29892004-11-22 19:12:19 +00001115 testOp = bRev ? OP_Lt : OP_Gt;
drh8aff1012001-12-22 14:49:24 +00001116 }
drh193bd772004-07-20 18:23:14 +00001117 disableTerm(pLevel, &pTerm->p);
drh8aff1012001-12-22 14:49:24 +00001118 }
danielk19774adee202004-05-08 08:23:19 +00001119 start = sqlite3VdbeCurrentAddr(v);
drhb6c29892004-11-22 19:12:19 +00001120 pLevel->op = bRev ? OP_Prev : OP_Next;
drh6a3ea0e2003-05-02 14:32:12 +00001121 pLevel->p1 = iCur;
drh8aff1012001-12-22 14:49:24 +00001122 pLevel->p2 = start;
1123 if( testOp!=OP_Noop ){
danielk19774adee202004-05-08 08:23:19 +00001124 sqlite3VdbeAddOp(v, OP_Recno, iCur, 0);
1125 sqlite3VdbeAddOp(v, OP_MemLoad, pLevel->iMem, 0);
1126 sqlite3VdbeAddOp(v, testOp, 0, brk);
drh8aff1012001-12-22 14:49:24 +00001127 }
drh8aff1012001-12-22 14:49:24 +00001128 }else if( pIdx==0 ){
drhc27a1ce2002-06-14 20:58:45 +00001129 /* Case 4: There is no usable index. We must do a complete
drh8aff1012001-12-22 14:49:24 +00001130 ** scan of the entire database table.
1131 */
1132 int start;
drhb6c29892004-11-22 19:12:19 +00001133 int opRewind;
drh8aff1012001-12-22 14:49:24 +00001134
drh9012bcb2004-12-19 00:11:35 +00001135 assert( omitTable==0 );
danielk19774adee202004-05-08 08:23:19 +00001136 brk = pLevel->brk = sqlite3VdbeMakeLabel(v);
1137 cont = pLevel->cont = sqlite3VdbeMakeLabel(v);
drhb6c29892004-11-22 19:12:19 +00001138 if( pLevel->bRev ){
1139 opRewind = OP_Last;
1140 pLevel->op = OP_Prev;
1141 }else{
1142 opRewind = OP_Rewind;
1143 pLevel->op = OP_Next;
1144 }
1145 sqlite3VdbeAddOp(v, opRewind, iCur, brk);
danielk19774adee202004-05-08 08:23:19 +00001146 start = sqlite3VdbeCurrentAddr(v);
drh6a3ea0e2003-05-02 14:32:12 +00001147 pLevel->p1 = iCur;
drh8aff1012001-12-22 14:49:24 +00001148 pLevel->p2 = start;
drh487ab3c2001-11-08 00:45:21 +00001149 }else{
drhc27a1ce2002-06-14 20:58:45 +00001150 /* Case 5: The WHERE clause term that refers to the right-most
1151 ** column of the index is an inequality. For example, if
1152 ** the index is on (x,y,z) and the WHERE clause is of the
1153 ** form "x=5 AND y<10" then this case is used. Only the
1154 ** right-most column can be an inequality - the rest must
1155 ** use the "==" operator.
drhe3184742002-06-19 14:27:05 +00001156 **
1157 ** This case is also used when there are no WHERE clause
1158 ** constraints but an index is selected anyway, in order
1159 ** to force the output order to conform to an ORDER BY.
drh487ab3c2001-11-08 00:45:21 +00001160 */
1161 int score = pLevel->score;
drh51669862004-12-18 18:40:26 +00001162 int nEqColumn = score/32;
drh487ab3c2001-11-08 00:45:21 +00001163 int start;
danielk1977f7df9cc2004-06-16 12:02:47 +00001164 int leFlag=0, geFlag=0;
drh487ab3c2001-11-08 00:45:21 +00001165 int testOp;
1166
1167 /* Evaluate the equality constraints
1168 */
1169 for(j=0; j<nEqColumn; j++){
drh94a11212004-09-25 13:12:14 +00001170 int iIdxCol = pIdx->aiColumn[j];
drh193bd772004-07-20 18:23:14 +00001171 for(pTerm=aExpr, k=0; k<nExpr; k++, pTerm++){
drh94a11212004-09-25 13:12:14 +00001172 Expr *pX = pTerm->p;
1173 if( pX==0 ) continue;
drh193bd772004-07-20 18:23:14 +00001174 if( pTerm->idxLeft==iCur
drh94a11212004-09-25 13:12:14 +00001175 && pX->op==TK_EQ
drh193bd772004-07-20 18:23:14 +00001176 && (pTerm->prereqRight & loopMask)==pTerm->prereqRight
drh94a11212004-09-25 13:12:14 +00001177 && pX->pLeft->iColumn==iIdxCol
drh487ab3c2001-11-08 00:45:21 +00001178 ){
drh94a11212004-09-25 13:12:14 +00001179 sqlite3ExprCode(pParse, pX->pRight);
drh193bd772004-07-20 18:23:14 +00001180 disableTerm(pLevel, &pTerm->p);
drh487ab3c2001-11-08 00:45:21 +00001181 break;
1182 }
1183 }
1184 }
1185
drhc27a1ce2002-06-14 20:58:45 +00001186 /* Duplicate the equality term values because they will all be
drh487ab3c2001-11-08 00:45:21 +00001187 ** used twice: once to make the termination key and once to make the
1188 ** start key.
1189 */
1190 for(j=0; j<nEqColumn; j++){
danielk19774adee202004-05-08 08:23:19 +00001191 sqlite3VdbeAddOp(v, OP_Dup, nEqColumn-1, 0);
drh487ab3c2001-11-08 00:45:21 +00001192 }
1193
drhc045ec52002-12-04 20:01:06 +00001194 /* Labels for the beginning and end of the loop
1195 */
danielk19774adee202004-05-08 08:23:19 +00001196 cont = pLevel->cont = sqlite3VdbeMakeLabel(v);
1197 brk = pLevel->brk = sqlite3VdbeMakeLabel(v);
drhc045ec52002-12-04 20:01:06 +00001198
drh487ab3c2001-11-08 00:45:21 +00001199 /* Generate the termination key. This is the key value that
1200 ** will end the search. There is no termination key if there
drhc27a1ce2002-06-14 20:58:45 +00001201 ** are no equality terms and no "X<..." term.
drhc045ec52002-12-04 20:01:06 +00001202 **
1203 ** 2002-Dec-04: On a reverse-order scan, the so-called "termination"
1204 ** key computed here really ends up being the start key.
drh487ab3c2001-11-08 00:45:21 +00001205 */
drh51669862004-12-18 18:40:26 +00001206 if( (score & 4)!=0 ){
drh193bd772004-07-20 18:23:14 +00001207 for(pTerm=aExpr, k=0; k<nExpr; k++, pTerm++){
drh94a11212004-09-25 13:12:14 +00001208 Expr *pX = pTerm->p;
1209 if( pX==0 ) continue;
drh193bd772004-07-20 18:23:14 +00001210 if( pTerm->idxLeft==iCur
drh94a11212004-09-25 13:12:14 +00001211 && (pX->op==TK_LT || pX->op==TK_LE)
drh193bd772004-07-20 18:23:14 +00001212 && (pTerm->prereqRight & loopMask)==pTerm->prereqRight
drh94a11212004-09-25 13:12:14 +00001213 && pX->pLeft->iColumn==pIdx->aiColumn[j]
drh487ab3c2001-11-08 00:45:21 +00001214 ){
drh94a11212004-09-25 13:12:14 +00001215 sqlite3ExprCode(pParse, pX->pRight);
1216 leFlag = pX->op==TK_LE;
drh193bd772004-07-20 18:23:14 +00001217 disableTerm(pLevel, &pTerm->p);
drh487ab3c2001-11-08 00:45:21 +00001218 break;
1219 }
1220 }
1221 testOp = OP_IdxGE;
1222 }else{
1223 testOp = nEqColumn>0 ? OP_IdxGE : OP_Noop;
1224 leFlag = 1;
1225 }
1226 if( testOp!=OP_Noop ){
drh51669862004-12-18 18:40:26 +00001227 int nCol = nEqColumn + ((score & 4)!=0);
drh487ab3c2001-11-08 00:45:21 +00001228 pLevel->iMem = pParse->nMem++;
drh94a11212004-09-25 13:12:14 +00001229 buildIndexProbe(v, nCol, brk, pIdx);
drhc045ec52002-12-04 20:01:06 +00001230 if( pLevel->bRev ){
drh7cf6e4d2004-05-19 14:56:55 +00001231 int op = leFlag ? OP_MoveLe : OP_MoveLt;
drh9012bcb2004-12-19 00:11:35 +00001232 sqlite3VdbeAddOp(v, op, iIdxCur, brk);
drhc045ec52002-12-04 20:01:06 +00001233 }else{
danielk19774adee202004-05-08 08:23:19 +00001234 sqlite3VdbeAddOp(v, OP_MemStore, pLevel->iMem, 1);
drhc045ec52002-12-04 20:01:06 +00001235 }
1236 }else if( pLevel->bRev ){
drh9012bcb2004-12-19 00:11:35 +00001237 sqlite3VdbeAddOp(v, OP_Last, iIdxCur, brk);
drh487ab3c2001-11-08 00:45:21 +00001238 }
1239
1240 /* Generate the start key. This is the key that defines the lower
drhc27a1ce2002-06-14 20:58:45 +00001241 ** bound on the search. There is no start key if there are no
1242 ** equality terms and if there is no "X>..." term. In
drh487ab3c2001-11-08 00:45:21 +00001243 ** that case, generate a "Rewind" instruction in place of the
1244 ** start key search.
drhc045ec52002-12-04 20:01:06 +00001245 **
1246 ** 2002-Dec-04: In the case of a reverse-order search, the so-called
1247 ** "start" key really ends up being used as the termination key.
drh487ab3c2001-11-08 00:45:21 +00001248 */
drh51669862004-12-18 18:40:26 +00001249 if( (score & 8)!=0 ){
drh193bd772004-07-20 18:23:14 +00001250 for(pTerm=aExpr, k=0; k<nExpr; k++, pTerm++){
drh94a11212004-09-25 13:12:14 +00001251 Expr *pX = pTerm->p;
1252 if( pX==0 ) continue;
drh193bd772004-07-20 18:23:14 +00001253 if( pTerm->idxLeft==iCur
drh94a11212004-09-25 13:12:14 +00001254 && (pX->op==TK_GT || pX->op==TK_GE)
drh193bd772004-07-20 18:23:14 +00001255 && (pTerm->prereqRight & loopMask)==pTerm->prereqRight
drh94a11212004-09-25 13:12:14 +00001256 && pX->pLeft->iColumn==pIdx->aiColumn[j]
drh487ab3c2001-11-08 00:45:21 +00001257 ){
drh94a11212004-09-25 13:12:14 +00001258 sqlite3ExprCode(pParse, pX->pRight);
1259 geFlag = pX->op==TK_GE;
drh193bd772004-07-20 18:23:14 +00001260 disableTerm(pLevel, &pTerm->p);
drh487ab3c2001-11-08 00:45:21 +00001261 break;
1262 }
1263 }
drh7900ead2001-11-12 13:51:43 +00001264 }else{
1265 geFlag = 1;
drh487ab3c2001-11-08 00:45:21 +00001266 }
drh51669862004-12-18 18:40:26 +00001267 if( nEqColumn>0 || (score&8)!=0 ){
1268 int nCol = nEqColumn + ((score&8)!=0);
drh94a11212004-09-25 13:12:14 +00001269 buildIndexProbe(v, nCol, brk, pIdx);
drhc045ec52002-12-04 20:01:06 +00001270 if( pLevel->bRev ){
1271 pLevel->iMem = pParse->nMem++;
danielk19774adee202004-05-08 08:23:19 +00001272 sqlite3VdbeAddOp(v, OP_MemStore, pLevel->iMem, 1);
drhc045ec52002-12-04 20:01:06 +00001273 testOp = OP_IdxLT;
1274 }else{
drh7cf6e4d2004-05-19 14:56:55 +00001275 int op = geFlag ? OP_MoveGe : OP_MoveGt;
drh9012bcb2004-12-19 00:11:35 +00001276 sqlite3VdbeAddOp(v, op, iIdxCur, brk);
drhc045ec52002-12-04 20:01:06 +00001277 }
1278 }else if( pLevel->bRev ){
1279 testOp = OP_Noop;
drh487ab3c2001-11-08 00:45:21 +00001280 }else{
drh9012bcb2004-12-19 00:11:35 +00001281 sqlite3VdbeAddOp(v, OP_Rewind, iIdxCur, brk);
drh487ab3c2001-11-08 00:45:21 +00001282 }
1283
1284 /* Generate the the top of the loop. If there is a termination
1285 ** key we have to test for that key and abort at the top of the
1286 ** loop.
1287 */
danielk19774adee202004-05-08 08:23:19 +00001288 start = sqlite3VdbeCurrentAddr(v);
drh487ab3c2001-11-08 00:45:21 +00001289 if( testOp!=OP_Noop ){
danielk19774adee202004-05-08 08:23:19 +00001290 sqlite3VdbeAddOp(v, OP_MemLoad, pLevel->iMem, 0);
drh9012bcb2004-12-19 00:11:35 +00001291 sqlite3VdbeAddOp(v, testOp, iIdxCur, brk);
danielk19773d1bfea2004-05-14 11:00:53 +00001292 if( (leFlag && !pLevel->bRev) || (!geFlag && pLevel->bRev) ){
1293 sqlite3VdbeChangeP3(v, -1, "+", P3_STATIC);
1294 }
drh487ab3c2001-11-08 00:45:21 +00001295 }
drh9012bcb2004-12-19 00:11:35 +00001296 sqlite3VdbeAddOp(v, OP_RowKey, iIdxCur, 0);
drh51669862004-12-18 18:40:26 +00001297 sqlite3VdbeAddOp(v, OP_IdxIsNull, nEqColumn + ((score&4)!=0), cont);
drhe6f85e72004-12-25 01:03:13 +00001298 if( !omitTable ){
drh9012bcb2004-12-19 00:11:35 +00001299 sqlite3VdbeAddOp(v, OP_IdxRecno, iIdxCur, 0);
drhe6f85e72004-12-25 01:03:13 +00001300 sqlite3VdbeAddOp(v, OP_MoveGe, iCur, 0);
drh487ab3c2001-11-08 00:45:21 +00001301 }
1302
1303 /* Record the instruction used to terminate the loop.
1304 */
drhc045ec52002-12-04 20:01:06 +00001305 pLevel->op = pLevel->bRev ? OP_Prev : OP_Next;
drh9012bcb2004-12-19 00:11:35 +00001306 pLevel->p1 = iIdxCur;
drh487ab3c2001-11-08 00:45:21 +00001307 pLevel->p2 = start;
drh75897232000-05-29 14:26:00 +00001308 }
drh6a3ea0e2003-05-02 14:32:12 +00001309 loopMask |= getMask(&maskSet, iCur);
drh75897232000-05-29 14:26:00 +00001310
1311 /* Insert code to test every subexpression that can be completely
1312 ** computed using the current set of tables.
1313 */
drh193bd772004-07-20 18:23:14 +00001314 for(pTerm=aExpr, j=0; j<nExpr; j++, pTerm++){
1315 if( pTerm->p==0 ) continue;
1316 if( (pTerm->prereqAll & loopMask)!=pTerm->prereqAll ) continue;
1317 if( pLevel->iLeftJoin && !ExprHasProperty(pTerm->p,EP_FromJoin) ){
drh1f162302002-10-27 19:35:33 +00001318 continue;
1319 }
drh193bd772004-07-20 18:23:14 +00001320 sqlite3ExprIfFalse(pParse, pTerm->p, cont, 1);
1321 pTerm->p = 0;
drh75897232000-05-29 14:26:00 +00001322 }
1323 brk = cont;
drhad2d8302002-05-24 20:31:36 +00001324
1325 /* For a LEFT OUTER JOIN, generate code that will record the fact that
1326 ** at least one row of the right table has matched the left table.
1327 */
1328 if( pLevel->iLeftJoin ){
danielk19774adee202004-05-08 08:23:19 +00001329 pLevel->top = sqlite3VdbeCurrentAddr(v);
1330 sqlite3VdbeAddOp(v, OP_Integer, 1, 0);
1331 sqlite3VdbeAddOp(v, OP_MemStore, pLevel->iLeftJoin, 1);
drhad6d9462004-09-19 02:15:24 +00001332 VdbeComment((v, "# record LEFT JOIN hit"));
drh193bd772004-07-20 18:23:14 +00001333 for(pTerm=aExpr, j=0; j<nExpr; j++, pTerm++){
1334 if( pTerm->p==0 ) continue;
1335 if( (pTerm->prereqAll & loopMask)!=pTerm->prereqAll ) continue;
drh193bd772004-07-20 18:23:14 +00001336 sqlite3ExprIfFalse(pParse, pTerm->p, cont, 1);
1337 pTerm->p = 0;
drh1cc093c2002-06-24 22:01:57 +00001338 }
drhad2d8302002-05-24 20:31:36 +00001339 }
drh75897232000-05-29 14:26:00 +00001340 }
1341 pWInfo->iContinue = cont;
drh6a3ea0e2003-05-02 14:32:12 +00001342 freeMaskSet(&maskSet);
drh75897232000-05-29 14:26:00 +00001343 return pWInfo;
1344}
1345
1346/*
drhc27a1ce2002-06-14 20:58:45 +00001347** Generate the end of the WHERE loop. See comments on
danielk19774adee202004-05-08 08:23:19 +00001348** sqlite3WhereBegin() for additional information.
drh75897232000-05-29 14:26:00 +00001349*/
danielk19774adee202004-05-08 08:23:19 +00001350void sqlite3WhereEnd(WhereInfo *pWInfo){
drh75897232000-05-29 14:26:00 +00001351 Vdbe *v = pWInfo->pParse->pVdbe;
drh19a775c2000-06-05 18:54:46 +00001352 int i;
drh6b563442001-11-07 16:48:26 +00001353 WhereLevel *pLevel;
drhad3cab52002-05-24 02:04:32 +00001354 SrcList *pTabList = pWInfo->pTabList;
drh9012bcb2004-12-19 00:11:35 +00001355 struct SrcList_item *pTabItem;
drh19a775c2000-06-05 18:54:46 +00001356
drh9012bcb2004-12-19 00:11:35 +00001357 /* Generate loop termination code.
1358 */
drhad3cab52002-05-24 02:04:32 +00001359 for(i=pTabList->nSrc-1; i>=0; i--){
drh6b563442001-11-07 16:48:26 +00001360 pLevel = &pWInfo->a[i];
danielk19774adee202004-05-08 08:23:19 +00001361 sqlite3VdbeResolveLabel(v, pLevel->cont);
drh6b563442001-11-07 16:48:26 +00001362 if( pLevel->op!=OP_Noop ){
danielk19774adee202004-05-08 08:23:19 +00001363 sqlite3VdbeAddOp(v, pLevel->op, pLevel->p1, pLevel->p2);
drh19a775c2000-06-05 18:54:46 +00001364 }
danielk19774adee202004-05-08 08:23:19 +00001365 sqlite3VdbeResolveLabel(v, pLevel->brk);
drhd99f7062002-06-08 23:25:08 +00001366 if( pLevel->inOp!=OP_Noop ){
danielk19774adee202004-05-08 08:23:19 +00001367 sqlite3VdbeAddOp(v, pLevel->inOp, pLevel->inP1, pLevel->inP2);
drhd99f7062002-06-08 23:25:08 +00001368 }
drhad2d8302002-05-24 20:31:36 +00001369 if( pLevel->iLeftJoin ){
1370 int addr;
danielk19774adee202004-05-08 08:23:19 +00001371 addr = sqlite3VdbeAddOp(v, OP_MemLoad, pLevel->iLeftJoin, 0);
drh9012bcb2004-12-19 00:11:35 +00001372 sqlite3VdbeAddOp(v, OP_NotNull, 1, addr+4 + (pLevel->iIdxCur>=0));
danielk19774adee202004-05-08 08:23:19 +00001373 sqlite3VdbeAddOp(v, OP_NullRow, pTabList->a[i].iCursor, 0);
drh9012bcb2004-12-19 00:11:35 +00001374 if( pLevel->iIdxCur>=0 ){
1375 sqlite3VdbeAddOp(v, OP_NullRow, pLevel->iIdxCur, 0);
drh7f09b3e2002-08-13 13:15:49 +00001376 }
danielk19774adee202004-05-08 08:23:19 +00001377 sqlite3VdbeAddOp(v, OP_Goto, 0, pLevel->top);
drhad2d8302002-05-24 20:31:36 +00001378 }
drh19a775c2000-06-05 18:54:46 +00001379 }
drh9012bcb2004-12-19 00:11:35 +00001380
1381 /* The "break" point is here, just past the end of the outer loop.
1382 ** Set it.
1383 */
danielk19774adee202004-05-08 08:23:19 +00001384 sqlite3VdbeResolveLabel(v, pWInfo->iBreak);
drh9012bcb2004-12-19 00:11:35 +00001385
drhacf3b982005-01-03 01:27:18 +00001386 /* Close all of the cursors that were opend by sqlite3WhereBegin.
drh9012bcb2004-12-19 00:11:35 +00001387 */
1388 pLevel = pWInfo->a;
1389 pTabItem = pTabList->a;
1390 for(i=0; i<pTabList->nSrc; i++, pTabItem++, pLevel++){
1391 Table *pTab = pTabItem->pTab;
drh5cf590c2003-04-24 01:45:04 +00001392 assert( pTab!=0 );
1393 if( pTab->isTransient || pTab->pSelect ) continue;
drh9012bcb2004-12-19 00:11:35 +00001394 if( (pLevel->score & 1)==0 ){
1395 sqlite3VdbeAddOp(v, OP_Close, pTabItem->iCursor, 0);
1396 }
drh6b563442001-11-07 16:48:26 +00001397 if( pLevel->pIdx!=0 ){
drh9012bcb2004-12-19 00:11:35 +00001398 sqlite3VdbeAddOp(v, OP_Close, pLevel->iIdxCur, 0);
1399 }
1400
drhacf3b982005-01-03 01:27:18 +00001401 /* Make cursor substitutions for cases where we want to use
drh9012bcb2004-12-19 00:11:35 +00001402 ** just the index and never reference the table.
1403 **
1404 ** Calls to the code generator in between sqlite3WhereBegin and
1405 ** sqlite3WhereEnd will have created code that references the table
1406 ** directly. This loop scans all that code looking for opcodes
1407 ** that reference the table and converts them into opcodes that
1408 ** reference the index.
1409 */
1410 if( pLevel->score & 1 ){
1411 int i, j, last;
1412 VdbeOp *pOp;
1413 Index *pIdx = pLevel->pIdx;
1414
1415 assert( pIdx!=0 );
1416 pOp = sqlite3VdbeGetOp(v, pWInfo->iTop);
1417 last = sqlite3VdbeCurrentAddr(v);
1418 for(i=pWInfo->iTop; i<last; i++, pOp++){
1419 if( pOp->p1!=pLevel->iTabCur ) continue;
1420 if( pOp->opcode==OP_Column ){
1421 pOp->p1 = pLevel->iIdxCur;
1422 for(j=0; j<pIdx->nColumn; j++){
1423 if( pOp->p2==pIdx->aiColumn[j] ){
1424 pOp->p2 = j;
1425 break;
1426 }
1427 }
1428 }else if( pOp->opcode==OP_Recno ){
1429 pOp->p1 = pLevel->iIdxCur;
1430 pOp->opcode = OP_IdxRecno;
danielk19776c18b6e2005-01-30 09:17:58 +00001431 }else if( pOp->opcode==OP_NullRow ){
1432 pOp->opcode = OP_Noop;
drh9012bcb2004-12-19 00:11:35 +00001433 }
1434 }
drh6b563442001-11-07 16:48:26 +00001435 }
drh19a775c2000-06-05 18:54:46 +00001436 }
drh9012bcb2004-12-19 00:11:35 +00001437
1438 /* Final cleanup
1439 */
drh75897232000-05-29 14:26:00 +00001440 sqliteFree(pWInfo);
1441 return;
1442}