blob: 6a67635500ddfda31cdcf0bea7a73293bc3bd7d8 (
plain)
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
|
// @tags: [
// requires_non_retryable_writes,
// sbe_incompatible,
// uses_multiple_connections,
// uses_parallel_shell,
// ]
// Yield and delete test case for query optimizer cursor. SERVER-4401
t = db.jstests_distinct3;
t.drop();
t.createIndex({a: 1});
t.createIndex({b: 1});
var bulk = t.initializeUnorderedBulkOp();
for (i = 0; i < 50; ++i) {
for (j = 0; j < 2; ++j) {
bulk.insert({a: i, c: i, d: j});
}
}
for (i = 0; i < 100; ++i) {
bulk.insert({b: i, c: i + 50});
}
assert.commandWorked(bulk.execute());
// Attempt to remove the last match for the {a:1} index scan while distinct is yielding.
p = startParallelShell('for( i = 0; i < 100; ++i ) { ' +
' var bulk = db.jstests_distinct3.initializeUnorderedBulkOp();' +
' bulk.find( { a:49 } ).remove(); ' +
' for( j = 0; j < 20; ++j ) { ' +
' bulk.insert( { a:49, c:49, d:j } ); ' +
' } ' +
' assert.commandWorked(bulk.execute()); ' +
'} ');
for (i = 0; i < 100; ++i) {
count = t.distinct('c', {$or: [{a: {$gte: 0}, d: 0}, {b: {$gte: 0}}]}).length;
assert.gt(count, 100);
}
p();
|