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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
|
/**
* Test the behavior of $last.
*/
(function() {
"use strict";
load("jstests/aggregation/extras/window_function_helpers.js");
const coll = db[jsTestName()];
coll.drop();
// Create a collection of tickers and prices.
const nDocsPerTicker = 10;
seedWithTickerData(coll, nDocsPerTicker);
// Run the suite of partition and bounds tests against the $last function.
testAccumAgainstGroup(coll, "$last");
// Like most other window functions, the default window for $last is [unbounded, unbounded].
coll.drop();
assert.commandWorked(coll.insert([
{x: 0, y: 0},
{x: 1, y: 42},
{x: 2, y: 67},
{x: 3, y: 99},
{x: 4, y: 20},
]));
let result = coll.aggregate([
{
$setWindowFields: {
sortBy: {x: 1},
output: {
last: {$last: "$y"},
}
}
},
{$unset: "_id"},
])
.toArray();
assert.sameMembers(result, [
{x: 0, y: 0, last: 20},
{x: 1, y: 42, last: 20},
{x: 2, y: 67, last: 20},
{x: 3, y: 99, last: 20},
{x: 4, y: 20, last: 20},
]);
// A default value of NULL is returned if there is no last document.
coll.drop();
assert.commandWorked(coll.insert([
{x: 1, y: 5},
{x: 2, y: 4},
{x: 3, y: 6},
{x: 4, y: 5},
]));
result = coll.aggregate([
{
$setWindowFields: {
sortBy: {x: 1},
partitionBy: "$x",
output: {
last: {$last: "$y", window: {documents: [-1, -1]}},
}
}
},
{$unset: "_id"},
])
.toArray();
assert.sameMembers(result, [
{x: 1, y: 5, last: null},
{x: 2, y: 4, last: null},
{x: 3, y: 6, last: null},
{x: 4, y: 5, last: null},
]);
// Nonobject window fields cause parse errors
result = coll.runCommand({
explain: {
aggregate: coll.getName(),
cursor: {},
pipeline: [
{
$setWindowFields: {
sortBy: {x: 1},
output: {
last: {$last: "$y", window: [0, 1]},
}
}
},
]
}
});
assert.commandFailedWithCode(result, ErrorCodes.FailedToParse, "'window' field must be an object");
})();
|
