database/sqlite
1
0
Fork 0
mirror of https://github.com/sqlite/sqlite.git synced 2025-07-30 19:03:16 +03:00
Code Activity

Improved processing of DISTINCT.

Browse Source 
FossilOrigin-Name: ba897100fed291d2025f68d09334f9985312298b
This commit is contained in:
drh
2013-06-11 18:59:38 +00:00
parent 8e23daf372
commit 4f402f26b1
5 changed files with 100 additions and 56 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
ext/misc/fuzzer.c
View File

@ -1079,7 +1079,7 @@ static int fuzzerBestIndex(sqlite3_vtab *tab, sqlite3_index_info *pIdxInfo){
int i; int i;
int seenMatch = 0; int seenMatch = 0;
const struct sqlite3_index_constraint *pConstraint; const struct sqlite3_index_constraint *pConstraint;
double rCost = 100000; double rCost = 1e12;
pConstraint = pIdxInfo->aConstraint; pConstraint = pIdxInfo->aConstraint;
for(i=0; i<pIdxInfo->nConstraint; i++, pConstraint++){ for(i=0; i<pIdxInfo->nConstraint; i++, pConstraint++){
@ -1095,7 +1095,7 @@ static int fuzzerBestIndex(sqlite3_vtab *tab, sqlite3_index_info *pIdxInfo){
iPlan |= 1; iPlan |= 1;
pIdxInfo->aConstraintUsage[i].argvIndex = 1; pIdxInfo->aConstraintUsage[i].argvIndex = 1;
pIdxInfo->aConstraintUsage[i].omit = 1; pIdxInfo->aConstraintUsage[i].omit = 1;
rCost /= 1000000.0; rCost /= 1e6;
} }
if( (iPlan & 2)==0 if( (iPlan & 2)==0
&& pConstraint->iColumn==1 && pConstraint->iColumn==1
@ -1132,7 +1132,7 @@ static int fuzzerBestIndex(sqlite3_vtab *tab, sqlite3_index_info *pIdxInfo){
){ ){
pIdxInfo->orderByConsumed = 1; pIdxInfo->orderByConsumed = 1;
} }
if( seenMatch && (iPlan&1)==0 ) rCost *= 1e30; if( seenMatch && (iPlan&1)==0 ) rCost = 1e99;
pIdxInfo->estimatedCost = rCost; pIdxInfo->estimatedCost = rCost;
return SQLITE_OK; return SQLITE_OK;

16
manifest
View File

@ -1,5 +1,5 @@
C Fix\sthe\sParse.nQueryLoop\sstate\svariable\sto\swork\swith\sNGQP. C Improved\sprocessing\sof\sDISTINCT.
D 2013-06-11T13:30:04.431 D 2013-06-11T18:59:38.240
F Makefile.arm-wince-mingw32ce-gcc d6df77f1f48d690bd73162294bbba7f59507c72f F Makefile.arm-wince-mingw32ce-gcc d6df77f1f48d690bd73162294bbba7f59507c72f
F Makefile.in 5e41da95d92656a5004b03d3576e8b226858a28e F Makefile.in 5e41da95d92656a5004b03d3576e8b226858a28e
F Makefile.linux-gcc 91d710bdc4998cb015f39edf3cb314ec4f4d7e23 F Makefile.linux-gcc 91d710bdc4998cb015f39edf3cb314ec4f4d7e23
@ -108,7 +108,7 @@ F ext/icu/icu.c 7538f98eab2854cf17fa5f7797bffa6c76e3863b
F ext/icu/sqliteicu.h 728867a802baa5a96de7495e9689a8e01715ef37 F ext/icu/sqliteicu.h 728867a802baa5a96de7495e9689a8e01715ef37
F ext/misc/amatch.c eae8454cd9dcb287b2a3ec2e65a865a4ac5f0d06 F ext/misc/amatch.c eae8454cd9dcb287b2a3ec2e65a865a4ac5f0d06
F ext/misc/closure.c 997c20ddf35f85ab399f4a02a557a9baa822ec32 F ext/misc/closure.c 997c20ddf35f85ab399f4a02a557a9baa822ec32
F ext/misc/fuzzer.c 79ac20b68794dfe03626f3a31681e6c240583052 F ext/misc/fuzzer.c 136533c53cfce0957f0b48fa11dba27e21c5c01d
F ext/misc/ieee754.c 2565ce373d842977efe0922dc50b8a41b3289556 F ext/misc/ieee754.c 2565ce373d842977efe0922dc50b8a41b3289556
F ext/misc/nextchar.c 1131e2b36116ffc6fe6b2e3464bfdace27978b1e F ext/misc/nextchar.c 1131e2b36116ffc6fe6b2e3464bfdace27978b1e
F ext/misc/percentile.c 4fb5e46c4312b0be74e8e497ac18f805f0e3e6c5 F ext/misc/percentile.c 4fb5e46c4312b0be74e8e497ac18f805f0e3e6c5
@ -220,7 +220,7 @@ F src/shell.c ab6eea968c8745be3aa74e45fedb37d057b4cd0d
F src/sqlite.h.in 5b390ca5d94e09e56e7fee6a51ddde4721b89f8e F src/sqlite.h.in 5b390ca5d94e09e56e7fee6a51ddde4721b89f8e
F src/sqlite3.rc fea433eb0a59f4c9393c8e6d76a6e2596b1fe0c0 F src/sqlite3.rc fea433eb0a59f4c9393c8e6d76a6e2596b1fe0c0
F src/sqlite3ext.h d936f797812c28b81b26ed18345baf8db28a21a5 F src/sqlite3ext.h d936f797812c28b81b26ed18345baf8db28a21a5
F src/sqliteInt.h f2e51444e15f7dd35c1ee139f95f43b0bccf3fb5 F src/sqliteInt.h 026a52f3e24c15603fddb78025e786b96c4c0d2c
F src/sqliteLimit.h 164b0e6749d31e0daa1a4589a169d31c0dec7b3d F src/sqliteLimit.h 164b0e6749d31e0daa1a4589a169d31c0dec7b3d
F src/status.c bedc37ec1a6bb9399944024d63f4c769971955a9 F src/status.c bedc37ec1a6bb9399944024d63f4c769971955a9
F src/table.c 2cd62736f845d82200acfa1287e33feb3c15d62e F src/table.c 2cd62736f845d82200acfa1287e33feb3c15d62e
@ -289,7 +289,7 @@ F src/vtab.c b05e5f1f4902461ba9f5fc49bb7eb7c3a0741a83
F src/wal.c 436bfceb141b9423c45119e68e444358ee0ed35d F src/wal.c 436bfceb141b9423c45119e68e444358ee0ed35d
F src/wal.h df01efe09c5cb8c8e391ff1715cca294f89668a4 F src/wal.h df01efe09c5cb8c8e391ff1715cca294f89668a4
F src/walker.c 4fa43583d0a84b48f93b1e88f11adf2065be4e73 F src/walker.c 4fa43583d0a84b48f93b1e88f11adf2065be4e73
F src/where.c 572357246bee5389751427c670cb0222fe36be78 F src/where.c 2afa8f1a71dd088b137a7772f5c5dfee70c8fbe8
F test/8_3_names.test ebbb5cd36741350040fd28b432ceadf495be25b2 F test/8_3_names.test ebbb5cd36741350040fd28b432ceadf495be25b2
F test/aggerror.test a867e273ef9e3d7919f03ef4f0e8c0d2767944f2 F test/aggerror.test a867e273ef9e3d7919f03ef4f0e8c0d2767944f2
F test/aggnested.test 45c0201e28045ad38a530b5a144b73cd4aa2cfd6 F test/aggnested.test 45c0201e28045ad38a530b5a144b73cd4aa2cfd6
@ -1095,7 +1095,7 @@ F tool/warnings-clang.sh f6aa929dc20ef1f856af04a730772f59283631d4
F tool/warnings.sh fbc018d67fd7395f440c28f33ef0f94420226381 F tool/warnings.sh fbc018d67fd7395f440c28f33ef0f94420226381
F tool/wherecosttest.c 4d0393bdbe7230adb712e925863744dd2b7ffc5b F tool/wherecosttest.c 4d0393bdbe7230adb712e925863744dd2b7ffc5b
F tool/win/sqlite.vsix 97894c2790eda7b5bce3cc79cb2a8ec2fde9b3ac F tool/win/sqlite.vsix 97894c2790eda7b5bce3cc79cb2a8ec2fde9b3ac
P b777b1097dcf9dfeb1b86c71e1b5f6918d68c975 P f1cac24f06b9c71cfa472fdcf2da4cd8689a7cc3
R 1aa8d10751da8bc78a75655bc8318da4 R f41c25fe4af487f857bb0cfd93c46d44
U drh U drh
Z 0a42be2e93f4ddc55a00a5d0e3551610 Z 15fc6bc86393280f1819e7074b4ff66c

2
manifest.uuid
View File

@ -1 +1 @@
f1cac24f06b9c71cfa472fdcf2da4cd8689a7cc3 ba897100fed291d2025f68d09334f9985312298b

6
src/sqliteInt.h
View File

@ -1967,8 +1967,10 @@ struct SrcList {
#define WHERE_ONETABLE_ONLY 0x0040 /* Only code the 1st table in pTabList */ #define WHERE_ONETABLE_ONLY 0x0040 /* Only code the 1st table in pTabList */
#define WHERE_AND_ONLY 0x0080 /* Don't use indices for OR terms */ #define WHERE_AND_ONLY 0x0080 /* Don't use indices for OR terms */
#define WHERE_GROUPBY 0x0100 /* pOrderBy is really a GROUP BY */ #define WHERE_GROUPBY 0x0100 /* pOrderBy is really a GROUP BY */
#define WHERE_DISTINCTBY 0x0200 /* pOrderby is really a DISTINCT clause */
/* Allowed values for WhereInfo.eDistinct and DistinctCtx.eTnctType */ /* Allowed return values from sqlite3WhereIsDistinct()
*/
#define WHERE_DISTINCT_NOOP 0 /* DISTINCT keyword not used */ #define WHERE_DISTINCT_NOOP 0 /* DISTINCT keyword not used */
#define WHERE_DISTINCT_UNIQUE 1 /* No duplicates */ #define WHERE_DISTINCT_UNIQUE 1 /* No duplicates */
#define WHERE_DISTINCT_ORDERED 2 /* All duplicates are adjacent */ #define WHERE_DISTINCT_ORDERED 2 /* All duplicates are adjacent */
@ -2226,7 +2228,7 @@ struct Parse {
/* Information used while coding trigger programs. */ /* Information used while coding trigger programs. */
Parse *pToplevel; /* Parse structure for main program (or NULL) */ Parse *pToplevel; /* Parse structure for main program (or NULL) */
Table *pTriggerTab; /* Table triggers are being coded for */ Table *pTriggerTab; /* Table triggers are being coded for */
u32 grep nQueryLoop; /* Est number of iterations of a query (10*log2(N)) */ u32 nQueryLoop; /* Est number of iterations of a query (10*log2(N)) */
u32 oldmask; /* Mask of old.* columns referenced */ u32 oldmask; /* Mask of old.* columns referenced */
u32 newmask; /* Mask of new.* columns referenced */ u32 newmask; /* Mask of new.* columns referenced */
u8 eTriggerOp; /* TK_UPDATE, TK_INSERT or TK_DELETE */ u8 eTriggerOp; /* TK_UPDATE, TK_INSERT or TK_DELETE */

126
src/where.c
View File

@ -345,9 +345,11 @@ struct WhereInfo {
SrcList *pTabList; /* List of tables in the join */ SrcList *pTabList; /* List of tables in the join */
ExprList *pOrderBy; /* The ORDER BY clause or NULL */ ExprList *pOrderBy; /* The ORDER BY clause or NULL */
ExprList *pDistinct; /* DISTINCT ON values, or NULL */ ExprList *pDistinct; /* DISTINCT ON values, or NULL */
WhereLoop *pLoops; /* List of all WhereLoop objects */
Bitmask revMask; /* Mask of ORDER BY terms that need reversing */ Bitmask revMask; /* Mask of ORDER BY terms that need reversing */
u16 nOBSat; /* Number of ORDER BY terms satisfied by indices */ WhereCost nRowOut; /* Estimated number of output rows */
u16 wctrlFlags; /* Flags originally passed to sqlite3WhereBegin() */ u16 wctrlFlags; /* Flags originally passed to sqlite3WhereBegin() */
u8 bOBSat; /* ORDER BY satisfied by indices */
u8 okOnePass; /* Ok to use one-pass algorithm for UPDATE/DELETE */ u8 okOnePass; /* Ok to use one-pass algorithm for UPDATE/DELETE */
u8 untestedTerms; /* Not all WHERE terms resolved by outer loop */ u8 untestedTerms; /* Not all WHERE terms resolved by outer loop */
u8 eDistinct; /* One of the WHERE_DISTINCT_* values below */ u8 eDistinct; /* One of the WHERE_DISTINCT_* values below */
@ -355,11 +357,9 @@ struct WhereInfo {
int iContinue; /* Jump here to continue with next record */ int iContinue; /* Jump here to continue with next record */
int iBreak; /* Jump here to break out of the loop */ int iBreak; /* Jump here to break out of the loop */
int nLevel; /* Number of nested loop */ int nLevel; /* Number of nested loop */
int savedNQueryLoop; /* pParse->nQueryLoop outside the WHERE loop */
WhereMaskSet sMaskSet; /* Map cursor numbers to bitmasks */ WhereMaskSet sMaskSet; /* Map cursor numbers to bitmasks */
WhereClause sWC; /* Decomposition of the WHERE clause */ WhereClause sWC; /* Decomposition of the WHERE clause */
WhereLoop *pLoops; /* List of all WhereLoop objects */
int savedNQueryLoop; /* pParse->nQueryLoop outside the WHERE loop */
WhereCost nRowOut; /* Estimated number of output rows */
WhereLevel a[1]; /* Information about each nest loop in WHERE */ WhereLevel a[1]; /* Information about each nest loop in WHERE */
}; };
@ -441,7 +441,7 @@ int sqlite3WhereIsDistinct(WhereInfo *pWInfo){
** Return FALSE if the output needs to be sorted. ** Return FALSE if the output needs to be sorted.
*/ */
int sqlite3WhereIsOrdered(WhereInfo *pWInfo){ int sqlite3WhereIsOrdered(WhereInfo *pWInfo){
return pWInfo->nOBSat>0; return pWInfo->bOBSat!=0;
} }
/* /*
@ -1776,15 +1776,16 @@ static int findIndexCol(
/* /*
** Return true if the DISTINCT expression-list passed as the third argument ** Return true if the DISTINCT expression-list passed as the third argument
** is redundant. A DISTINCT list is redundant if the database contains a ** is redundant.
** UNIQUE index that guarantees that the result of the query will be distinct **
** anyway. ** A DISTINCT list is redundant if the database contains some set of
** columns that are unique and non-null.
*/ */
static int isDistinctRedundant( static int isDistinctRedundant(
Parse *pParse, Parse *pParse, /* Parsing context */
SrcList *pTabList, SrcList *pTabList, /* The FROM clause */
WhereClause *pWC, WhereClause *pWC, /* The WHERE clause */
ExprList *pDistinct ExprList *pDistinct /* The result set that needs to be DISTINCT */
){ ){
Table *pTab; Table *pTab;
Index *pIdx; Index *pIdx;
@ -3418,7 +3419,7 @@ static Bitmask codeOneLoopStart(
** this requires some special handling. ** this requires some special handling.
*/ */
if( (pWInfo->wctrlFlags&WHERE_ORDERBY_MIN)!=0 if( (pWInfo->wctrlFlags&WHERE_ORDERBY_MIN)!=0
&& (pWInfo->nOBSat>0) && (pWInfo->bOBSat!=0)
&& (pIdx->nColumn>nEq) && (pIdx->nColumn>nEq)
){ ){
/* assert( pOrderBy->nExpr==1 ); */ /* assert( pOrderBy->nExpr==1 ); */
@ -4493,7 +4494,9 @@ static int whereLoopAddBtree(
){ ){
pNew->iSortIdx = b ? iSortIdx : 0; pNew->iSortIdx = b ? iSortIdx : 0;
pNew->nOut = rSize; pNew->nOut = rSize;
pNew->rRun = whereCostAdd(rSize,rLogSize) + ((m==0 && b) ? 10 : 0); pNew->rRun = whereCostAdd(rSize,rLogSize);
if( m!=0 ) pNew->rRun += rLogSize;
if( b ) pNew->rRun--;
rc = whereLoopInsert(pBuilder, pNew); rc = whereLoopInsert(pBuilder, pNew);
if( rc ) break; if( rc ) break;
} }
@ -4804,11 +4807,13 @@ static int whereLoopAddAll(WhereLoopBuilder *pBuilder){
*/ */
static int wherePathSatisfiesOrderBy( static int wherePathSatisfiesOrderBy(
WhereInfo *pWInfo, /* The WHERE clause */ WhereInfo *pWInfo, /* The WHERE clause */
ExprList *pOrderBy, /* ORDER BY or GROUP BY or DISTINCT clause to check */
WherePath *pPath, /* The WherePath to check */ WherePath *pPath, /* The WherePath to check */
int nLoop, /* Number of entries in pPath->aLoop[] */ u16 wctrlFlags, /* Might contain WHERE_GROUPBY or WHERE_DISTINCTBY */
int isLastLoop, /* True if pLast is the inner-most loop */ u16 nLoop, /* Number of entries in pPath->aLoop[] */
u8 isLastLoop, /* True if pLast is the inner-most loop */
WhereLoop *pLast, /* Add this WhereLoop to the end of pPath->aLoop[] */ WhereLoop *pLast, /* Add this WhereLoop to the end of pPath->aLoop[] */
Bitmask *pRevMask /* Mask of WhereLoops to run in reverse order */ Bitmask *pRevMask /* OUT: Mask of WhereLoops to run in reverse order */
){ ){
u8 revSet; /* True if rev is known */ u8 revSet; /* True if rev is known */
u8 rev; /* Composite sort order */ u8 rev; /* Composite sort order */
@ -4823,7 +4828,6 @@ static int wherePathSatisfiesOrderBy(
int iCur; /* Cursor number for current WhereLoop */ int iCur; /* Cursor number for current WhereLoop */
int iColumn; /* A column number within table iCur */ int iColumn; /* A column number within table iCur */
WhereLoop *pLoop; /* Current WhereLoop being processed. */ WhereLoop *pLoop; /* Current WhereLoop being processed. */
ExprList *pOrderBy = pWInfo->pOrderBy; /* the ORDER BY clause */
WhereTerm *pTerm; /* A single term of the WHERE clause */ WhereTerm *pTerm; /* A single term of the WHERE clause */
Expr *pOBExpr; /* An expression from the ORDER BY clause */ Expr *pOBExpr; /* An expression from the ORDER BY clause */
CollSeq *pColl; /* COLLATE function from an ORDER BY clause term */ CollSeq *pColl; /* COLLATE function from an ORDER BY clause term */
@ -4960,7 +4964,7 @@ static int wherePathSatisfiesOrderBy(
for(i=0; bOnce && i<nOrderBy; i++){ for(i=0; bOnce && i<nOrderBy; i++){
if( MASKBIT(i) & obSat ) continue; if( MASKBIT(i) & obSat ) continue;
pOBExpr = sqlite3ExprSkipCollate(pOrderBy->a[i].pExpr); pOBExpr = sqlite3ExprSkipCollate(pOrderBy->a[i].pExpr);
if( (pWInfo->wctrlFlags & WHERE_GROUPBY)==0 ) bOnce = 0; if( (wctrlFlags & (WHERE_GROUPBY|WHERE_DISTINCTBY))==0 ) bOnce = 0;
if( pOBExpr->op!=TK_COLUMN ) continue; if( pOBExpr->op!=TK_COLUMN ) continue;
if( pOBExpr->iTable!=iCur ) continue; if( pOBExpr->iTable!=iCur ) continue;
if( pOBExpr->iColumn!=iColumn ) continue; if( pOBExpr->iColumn!=iColumn ) continue;
@ -5111,8 +5115,9 @@ static int wherePathSolver(WhereInfo *pWInfo, WhereCost nRowEst){
rCost = whereCostAdd(rCost, pFrom->rCost); rCost = whereCostAdd(rCost, pFrom->rCost);
maskNew = pFrom->maskLoop | pWLoop->maskSelf; maskNew = pFrom->maskLoop | pWLoop->maskSelf;
if( !isOrderedValid ){ if( !isOrderedValid ){
switch( wherePathSatisfiesOrderBy(pWInfo, pFrom, iLoop, iLoop==nLoop-1, switch( wherePathSatisfiesOrderBy(pWInfo,
pWLoop, &revMask) ){ pWInfo->pOrderBy, pFrom, pWInfo->wctrlFlags,
iLoop, iLoop==nLoop-1, pWLoop, &revMask) ){
case 1: /* Yes. pFrom+pWLoop does satisfy the ORDER BY clause */ case 1: /* Yes. pFrom+pWLoop does satisfy the ORDER BY clause */
isOrdered = 1; isOrdered = 1;
isOrderedValid = 1; isOrderedValid = 1;
@ -5249,9 +5254,22 @@ static int wherePathSolver(WhereInfo *pWInfo, WhereCost nRowEst){
pLevel->iFrom = pWLoop->iTab; /* FIXME: Omit the iFrom field */ pLevel->iFrom = pWLoop->iTab; /* FIXME: Omit the iFrom field */
pLevel->iTabCur = pWInfo->pTabList->a[pLevel->iFrom].iCursor; pLevel->iTabCur = pWInfo->pTabList->a[pLevel->iFrom].iCursor;
} }
if( (pWInfo->wctrlFlags & WHERE_DISTINCTBY)==0
&& pWInfo->pDistinct
&& nRowEst
){
Bitmask notUsed;
int rc = wherePathSatisfiesOrderBy(pWInfo, pWInfo->pDistinct, pFrom,
WHERE_DISTINCTBY, nLoop-1, 1, pFrom->aLoop[nLoop-1], &notUsed);
if( rc==1 ) pWInfo->eDistinct = WHERE_DISTINCT_ORDERED;
}
if( pFrom->isOrdered ){ if( pFrom->isOrdered ){
pWInfo->nOBSat = pWInfo->pOrderBy->nExpr; if( pWInfo->wctrlFlags & WHERE_DISTINCTBY ){
pWInfo->revMask = pFrom->revLoop; pWInfo->eDistinct = WHERE_DISTINCT_ORDERED;
}else{
pWInfo->bOBSat = 1;
pWInfo->revMask = pFrom->revLoop;
}
} }
pWInfo->nRowOut = pFrom->nRow; pWInfo->nRowOut = pFrom->nRow;
@ -5327,7 +5345,8 @@ static int whereShortCut(WhereLoopBuilder *pBuilder){
pLoop->maskSelf = getMask(&pWInfo->sMaskSet, iCur); pLoop->maskSelf = getMask(&pWInfo->sMaskSet, iCur);
pWInfo->a[0].iTabCur = iCur; pWInfo->a[0].iTabCur = iCur;
pWInfo->nRowOut = 1; pWInfo->nRowOut = 1;
pWInfo->nOBSat = pWInfo->pOrderBy ? pWInfo->pOrderBy->nExpr : 0; if( pWInfo->pOrderBy ) pWInfo->bOBSat = 1;
if( pWInfo->pDistinct ) pWInfo->eDistinct = WHERE_DISTINCT_UNIQUE;
#ifdef SQLITE_DEBUG #ifdef SQLITE_DEBUG
pLoop->cId = '0'; pLoop->cId = '0';
#endif #endif
@ -5414,15 +5433,6 @@ static int whereShortCut(WhereLoopBuilder *pBuilder){
** pOrderBy is a pointer to the ORDER BY clause of a SELECT statement, ** pOrderBy is a pointer to the ORDER BY clause of a SELECT statement,
** if there is one. If there is no ORDER BY clause or if this routine ** if there is one. If there is no ORDER BY clause or if this routine
** is called from an UPDATE or DELETE statement, then pOrderBy is NULL. ** is called from an UPDATE or DELETE statement, then pOrderBy is NULL.
**
** If an index can be used so that the natural output order of the table
** scan is correct for the ORDER BY clause, then that index is used and
** the returned WhereInfo.nOBSat field is set to pOrderBy->nExpr. This
** is an optimization that prevents an unnecessary sort of the result set
** if an index appropriate for the ORDER BY clause already exists.
**
** If the where clause loops cannot be arranged to provide the correct
** output order, then WhereInfo.nOBSat is 0.
*/ */
WhereInfo *sqlite3WhereBegin( WhereInfo *sqlite3WhereBegin(
Parse *pParse, /* The parser context */ Parse *pParse, /* The parser context */
@ -5558,13 +5568,32 @@ WhereInfo *sqlite3WhereBegin(
goto whereBeginError; goto whereBeginError;
} }
/* If the ORDER BY (or GROUP BY) clause contains references to general
** expressions, then we won't be able to satisfy it using indices, so
** go ahead and disable it now.
*/
if( pOrderBy ){
for(ii=0; ii<pOrderBy->nExpr; ii++){
Expr *pExpr = sqlite3ExprSkipCollate(pOrderBy->a[ii].pExpr);
if( pExpr->op!=TK_COLUMN ){
pWInfo->pOrderBy = pOrderBy = 0;
break;
}
}
}
/* Check if the DISTINCT qualifier, if there is one, is redundant. /* Check if the DISTINCT qualifier, if there is one, is redundant.
** If it is, then set pDistinct to NULL and WhereInfo.eDistinct to ** If it is, then set pDistinct to NULL and WhereInfo.eDistinct to
** WHERE_DISTINCT_UNIQUE to tell the caller to ignore the DISTINCT. ** WHERE_DISTINCT_UNIQUE to tell the caller to ignore the DISTINCT.
*/ */
if( pDistinct && isDistinctRedundant(pParse,pTabList,&pWInfo->sWC,pDistinct) ){ if( pDistinct ){
pDistinct = 0; if( isDistinctRedundant(pParse,pTabList,&pWInfo->sWC,pDistinct) ){
pWInfo->eDistinct = WHERE_DISTINCT_UNIQUE; pDistinct = 0;
pWInfo->eDistinct = WHERE_DISTINCT_UNIQUE;
}else if( pOrderBy==0 ){
pWInfo->wctrlFlags |= WHERE_DISTINCTBY;
pWInfo->pOrderBy = pDistinct;
}
} }
/* Construct the WhereLoop objects */ /* Construct the WhereLoop objects */
@ -5587,7 +5616,7 @@ WhereInfo *sqlite3WhereBegin(
} }
#endif #endif
wherePathSolver(pWInfo, -1); wherePathSolver(pWInfo, 0);
if( db->mallocFailed ) goto whereBeginError; if( db->mallocFailed ) goto whereBeginError;
if( pWInfo->pOrderBy ){ if( pWInfo->pOrderBy ){
wherePathSolver(pWInfo, pWInfo->nRowOut); wherePathSolver(pWInfo, pWInfo->nRowOut);
@ -5603,12 +5632,25 @@ WhereInfo *sqlite3WhereBegin(
#ifdef WHERETRACE_ENABLED #ifdef WHERETRACE_ENABLED
if( sqlite3WhereTrace ){ if( sqlite3WhereTrace ){
int ii; int ii;
sqlite3DebugPrintf("---- Solution"); sqlite3DebugPrintf("---- Solution nRow=%d", pWInfo->nRowOut);
if( pWInfo->nOBSat ){ if( pWInfo->bOBSat ){
sqlite3DebugPrintf(" ORDER BY omitted rev=0x%llx\n", pWInfo->revMask); sqlite3DebugPrintf(" ORDERBY=0x%llx", pWInfo->revMask);
}else{
sqlite3DebugPrintf("\n");
} }
switch( pWInfo->eDistinct ){
case WHERE_DISTINCT_UNIQUE: {
sqlite3DebugPrintf(" DISTINCT=unique");
break;
}
case WHERE_DISTINCT_ORDERED: {
sqlite3DebugPrintf(" DISTINCT=ordered");
break;
}
case WHERE_DISTINCT_UNORDERED: {
sqlite3DebugPrintf(" DISTINCT=unordered");
break;
}
}
sqlite3DebugPrintf("\n");
for(ii=0; ii<nTabList; ii++){ for(ii=0; ii<nTabList; ii++){
whereLoopPrint(pWInfo->a[ii].pWLoop, pTabList); whereLoopPrint(pWInfo->a[ii].pWLoop, pTabList);
} }