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
|
/**
* Typically, time-series collections use measurements that always contain data for every field.
* This test provides coverage for when this is not the case.
* @tags: [
* assumes_no_implicit_collection_creation_after_drop,
* does_not_support_stepdowns,
* does_not_support_transactions,
* requires_getmore,
* ]
*/
(function() {
"use strict";
load("jstests/core/timeseries/libs/timeseries.js");
TimeseriesTest.run((insert) => {
const collNamePrefix = 'timeseries_sparse_';
const timeFieldName = 'time';
let collCount = 0;
/**
* Accepts two lists of measurements. The first list is used to create a new bucket. The second
* list is used to append measurements to the new bucket. We should see one bucket created in
* the time-series collection.
*/
const runTest = function(docsInsert, docsUpdate) {
const coll = db.getCollection(collNamePrefix + collCount++);
const bucketsColl = db.getCollection('system.buckets.' + coll.getName());
coll.drop();
jsTestLog('Running test: collection: ' + coll.getFullName() + '; bucket collection: ' +
bucketsColl.getFullName() + '; initial measurements: ' + tojson(docsInsert) +
'; measurements to append: ' + tojson(docsUpdate));
assert.commandWorked(
db.createCollection(coll.getName(), {timeseries: {timeField: timeFieldName}}));
assert.contains(bucketsColl.getName(), db.getCollectionNames());
assert.commandWorked(insert(coll, docsInsert),
'failed to create bucket with initial docs: ' + tojson(docsInsert));
assert.commandWorked(insert(coll, docsUpdate),
'failed to append docs to bucket : ' + tojson(docsUpdate));
// Check view.
let docs = docsInsert.concat(docsUpdate);
const viewDocs = coll.find({}).sort({_id: 1}).toArray();
assert.eq(docs.length, viewDocs.length, viewDocs);
for (let i = 0; i < docs.length; i++) {
assert.docEq(docs[i], viewDocs[i], 'unexpected doc from view: ' + i);
}
// Check bucket collection.
const bucketDocs = bucketsColl.find().sort({'control.min._id': 1}).toArray();
assert.eq(1, bucketDocs.length, bucketDocs);
// Check bucket.
assert.eq(docs.length,
Object.keys(bucketDocs[0].data[timeFieldName]).length,
'invalid number of measurements in first bucket: ' + tojson(bucketDocs[0]));
};
// Ensure _id order of docs in the bucket collection by using constant times.
const t = [
ISODate("2020-11-26T00:00:00.000Z"),
ISODate("2020-11-26T00:10:00.000Z"),
ISODate("2020-11-26T00:20:00.000Z"),
ISODate("2020-11-26T00:30:00.000Z"),
];
// One field per measurement. No overlap in (non-time) data fields.
runTest(
[
{_id: 0, time: t[0], a: 0},
{_id: 1, time: t[1], b: 10},
],
[
{_id: 2, time: t[2], c: 20},
{_id: 3, time: t[3], d: 30},
]);
// Two fields per measurement. Fields overlaps with previous measurement in a sliding window.
runTest(
[
{_id: 0, time: t[0], a: 0, d: 100},
{_id: 1, time: t[1], a: 11, b: 10},
],
[
{_id: 2, time: t[2], b: 22, c: 20},
{_id: 3, time: t[3], c: 33, d: 30},
]);
});
})();
|
