1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
/**
* Tests that the server returns the correct number of results in the presence of multiple $skips
* and $limits. There are a number of optimizations and special checks the server implements -
* especially in a sharded cluster - which we intend to stress with this test.
*/
(function() {
"use strict";
const coll = db.skip_with_limit;
coll.drop();
// Insert twenty documents: {x: 4, y: 0}, {x: 4, y: 1}, ..., {x: 4, y: 19}.
const bulk = coll.initializeOrderedBulkOp();
Array.from({length: 20}, (_, i) => ({x: 4, y: i})).forEach(doc => bulk.insert(doc));
assert.commandWorked(bulk.execute());
var count = coll.aggregate([{$match: {x: 4}}, {$skip: 10}, {$limit: 5}]).itcount();
assert.eq(count, 5);
count = coll.aggregate([{$match: {x: 4}}, {$skip: 7}, {$skip: 3}, {$limit: 5}]).itcount();
assert.eq(count, 5);
count = coll.aggregate([{$match: {x: 4}}, {$limit: 10}, {$skip: 5}]).itcount();
assert.eq(count, 5);
count = coll.aggregate([{$match: {x: 4}}, {$skip: 10}, {$addFields: {y: 1}}, {$limit: 5}])
.itcount();
assert.eq(count, 5);
count = coll.aggregate([{$match: {x: 4}}, {$skip: 10}, {$group: {_id: '$y'}}, {$limit: 5}])
.itcount();
assert.eq(count, 5);
// For the pipelines with a $skip before the $limit, repeat the tests with larger skip values to
// ensure that the skip is actually working. The large skips exhaust our 20 documents, so we get
// fewer results.
count = coll.aggregate([{$match: {x: 4}}, {$skip: 18}, {$limit: 5}]).itcount();
assert.eq(count, 2);
count = coll.aggregate([{$match: {x: 4}}, {$skip: 11}, {$skip: 7}, {$limit: 5}]).itcount();
assert.eq(count, 2);
count = coll.aggregate([{$match: {x: 4}}, {$skip: 18}, {$addFields: {y: 1}}, {$limit: 5}])
.itcount();
assert.eq(count, 2);
count = coll.aggregate([{$match: {x: 4}}, {$skip: 18}, {$group: {_id: '$y'}}, {$limit: 5}])
.itcount();
assert.eq(count, 2);
}());
|
