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
|
/**
* Tests basic index creation and operations on a time-series bucket collection.
*
* @tags: [
* does_not_support_stepdowns,
* does_not_support_transactions,
* requires_fcv_53,
* requires_getmore,
* ]
*/
(function() {
"use strict";
load("jstests/core/timeseries/libs/timeseries.js");
load("jstests/libs/analyze_plan.js"); // For 'planHasStage' helper.
TimeseriesTest.run((insert) => {
const coll = db.timeseries_bucket_index;
const bucketsColl = db.getCollection('system.buckets.' + coll.getName());
const timeFieldName = 'time';
coll.drop();
assert.commandWorked(
db.createCollection(coll.getName(), {timeseries: {timeField: timeFieldName}}));
assert.contains(bucketsColl.getName(), db.getCollectionNames());
assert.commandWorked(bucketsColl.createIndex({"control.min.time": 1}));
const t = new Date();
const doc = {_id: 0, [timeFieldName]: t, x: 0};
assert.commandWorked(insert(coll, doc), 'failed to insert doc: ' + tojson(doc));
assert.commandWorked(bucketsColl.createIndex({"control.max.time": 1}));
let buckets = bucketsColl.find().toArray();
assert.eq(buckets.length, 1, 'Expected one bucket but found ' + tojson(buckets));
const bucketId = buckets[0]._id;
const minTime = buckets[0].control.min.time;
const maxTime = buckets[0].control.max.time;
assert.docEq(buckets, bucketsColl.find({_id: bucketId}).toArray());
let explain = bucketsColl.find({_id: bucketId}).explain();
assert(planHasStage(db, explain, "CLUSTERED_IXSCAN"), explain);
assert.docEq(buckets, bucketsColl.find({"control.max.time": maxTime}).toArray());
explain = bucketsColl.find({"control.max.time": minTime}).explain();
assert(planHasStage(db, explain, "IXSCAN"), explain);
let res = assert.commandWorked(bucketsColl.validate());
assert(res.valid, res);
assert.commandWorked(bucketsColl.remove({_id: bucketId}));
assert.docEq([], bucketsColl.find().toArray());
});
})();
|
