diff options
Diffstat (limited to 'jstests/noPassthroughWithMongod/plan_cache_not_in_regex.js')
| -rw-r--r-- | jstests/noPassthroughWithMongod/plan_cache_not_in_regex.js | 96 |
1 files changed, 48 insertions, 48 deletions
diff --git a/jstests/noPassthroughWithMongod/plan_cache_not_in_regex.js b/jstests/noPassthroughWithMongod/plan_cache_not_in_regex.js index 52829d74717..c19b4a14fcb 100644 --- a/jstests/noPassthroughWithMongod/plan_cache_not_in_regex.js +++ b/jstests/noPassthroughWithMongod/plan_cache_not_in_regex.js @@ -3,62 +3,62 @@ * hijack the cached plan for an earlier $not-$in query. */ (function() { - "use strict"; +"use strict"; - load('jstests/libs/analyze_plan.js'); // For isCollScan. +load('jstests/libs/analyze_plan.js'); // For isCollScan. - const coll = db.plan_cache_not_in_regex; - coll.drop(); +const coll = db.plan_cache_not_in_regex; +coll.drop(); - // Helper function which obtains the cached plan, if any, for a given query shape. - function getPlanForCacheEntry(query, proj, sort) { - const key = {query: query, sort: sort, projection: proj}; - const cursor = coll.aggregate([ - {$planCacheStats: {}}, - { - $match: { - "createdFromQuery.query": query, - "createdFromQuery.projection": proj, - "createdFromQuery.sort": sort - } +// Helper function which obtains the cached plan, if any, for a given query shape. +function getPlanForCacheEntry(query, proj, sort) { + const key = {query: query, sort: sort, projection: proj}; + const cursor = coll.aggregate([ + {$planCacheStats: {}}, + { + $match: { + "createdFromQuery.query": query, + "createdFromQuery.projection": proj, + "createdFromQuery.sort": sort } - ]); - const entryStats = cursor.toArray(); - assert.eq(entryStats.length, 1, `Expected one cached plan, found: ${tojson(entryStats)}`); - return entryStats.shift(); - } + } + ]); + const entryStats = cursor.toArray(); + assert.eq(entryStats.length, 1, `Expected one cached plan, found: ${tojson(entryStats)}`); + return entryStats.shift(); +} - // Insert a document containing a field 'a', and create two indexes that can support queries on - // this field. This is to ensure that the plan we choose will be cached, since if only a single - // index is available, the solution will not be cached. - assert.commandWorked(coll.insert({a: "foo"})); - assert.commandWorked(coll.createIndex({a: 1})); - assert.commandWorked(coll.createIndex({a: 1, b: 1})); +// Insert a document containing a field 'a', and create two indexes that can support queries on +// this field. This is to ensure that the plan we choose will be cached, since if only a single +// index is available, the solution will not be cached. +assert.commandWorked(coll.insert({a: "foo"})); +assert.commandWorked(coll.createIndex({a: 1})); +assert.commandWorked(coll.createIndex({a: 1, b: 1})); - // Repeat the test for query, query with projection, and query with projection and sort. - for (let [proj, sort] of[[{}, {}], [{_id: 0, a: 1}, {}], [{_id: 0, a: 1}, {a: 1}]]) { - // Perform a plain $not-$in query on 'a' and confirm that the plan is cached. - const queryShape = {a: {$not: {$in: [32, 33]}}}; +// Repeat the test for query, query with projection, and query with projection and sort. +for (let [proj, sort] of [[{}, {}], [{_id: 0, a: 1}, {}], [{_id: 0, a: 1}, {a: 1}]]) { + // Perform a plain $not-$in query on 'a' and confirm that the plan is cached. + const queryShape = {a: {$not: {$in: [32, 33]}}}; + assert.eq(1, coll.find(queryShape, proj).sort(sort).itcount()); + let cacheEntry = getPlanForCacheEntry(queryShape, proj, sort); + assert(cacheEntry); + + // If the cached plan is inactive, perform the same query to activate it. + if (cacheEntry.isActive === false) { assert.eq(1, coll.find(queryShape, proj).sort(sort).itcount()); - let cacheEntry = getPlanForCacheEntry(queryShape, proj, sort); + cacheEntry = getPlanForCacheEntry(queryShape, proj, sort); assert(cacheEntry); + assert(cacheEntry.isActive); + } - // If the cached plan is inactive, perform the same query to activate it. - if (cacheEntry.isActive === false) { - assert.eq(1, coll.find(queryShape, proj).sort(sort).itcount()); - cacheEntry = getPlanForCacheEntry(queryShape, proj, sort); - assert(cacheEntry); - assert(cacheEntry.isActive); - } - - // Now perform a $not-$in-$regex query, confirm that it obtains the correct results, and - // that it used a COLLSCAN rather than planning from the cache. - const explainOutput = assert.commandWorked( - coll.find({a: {$not: {$in: [34, /bar/]}}}).explain("executionStats")); - assert(isCollscan(coll.getDB(), explainOutput.queryPlanner.winningPlan)); - assert.eq(1, explainOutput.executionStats.nReturned); + // Now perform a $not-$in-$regex query, confirm that it obtains the correct results, and + // that it used a COLLSCAN rather than planning from the cache. + const explainOutput = + assert.commandWorked(coll.find({a: {$not: {$in: [34, /bar/]}}}).explain("executionStats")); + assert(isCollscan(coll.getDB(), explainOutput.queryPlanner.winningPlan)); + assert.eq(1, explainOutput.executionStats.nReturned); - // Flush the plan cache before the next iteration. - coll.getPlanCache().clear(); - } + // Flush the plan cache before the next iteration. + coll.getPlanCache().clear(); +} })();
\ No newline at end of file |