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
|
/**
* Tests that collMod can change the expireAfterSeconds option on a time-series collection.
*
* @tags: [
* # We need a timeseries collection.
* requires_timeseries,
* ]
*/
(function() {
"use strict";
const coll = db.timeseries_expire_collmod;
coll.drop();
const timeFieldName = 'time';
const expireAfterSeconds = NumberLong(5);
assert.commandWorked(db.createCollection(
coll.getName(),
{timeseries: {timeField: timeFieldName}, expireAfterSeconds: expireAfterSeconds}));
const bucketsColl = db.getCollection('system.buckets.' + coll.getName());
// Cannot use the 'clusteredIndex' option on collections that aren't time-series bucket collections.
const collNotClustered = db.getCollection(coll.getName() + '_not_clustered');
collNotClustered.drop();
assert.commandWorked(db.createCollection(collNotClustered.getName()));
assert.commandFailedWithCode(
db.runCommand({collMod: collNotClustered.getName(), expireAfterSeconds: 10}),
ErrorCodes.InvalidOptions);
// Check for invalid input on the time-series collection.
assert.commandFailedWithCode(db.runCommand({collMod: coll.getName(), expireAfterSeconds: "10"}),
ErrorCodes.InvalidOptions);
assert.commandFailedWithCode(db.runCommand({collMod: coll.getName(), expireAfterSeconds: {}}),
ErrorCodes.TypeMismatch);
assert.commandFailedWithCode(db.runCommand({collMod: coll.getName(), expireAfterSeconds: -10}),
ErrorCodes.InvalidOptions);
let res = assert.commandWorked(
db.runCommand({listCollections: 1, filter: {name: bucketsColl.getName()}}));
assert.eq(expireAfterSeconds,
res.cursor.firstBatch[0].options.expireAfterSeconds,
bucketsColl.getName() + ': ' + expireAfterSeconds + ': ' + tojson(res));
/**
* Runs collMod on 'collToChange' with the given 'expireAfterSeconds' value and checks the expected
* value using listCollections on the bucketCollection.
*/
const runTest = function(collToChange, expireAfterSeconds) {
assert.commandWorked(db.runCommand({
collMod: collToChange.getName(),
expireAfterSeconds: expireAfterSeconds,
}));
res = assert.commandWorked(
db.runCommand({listCollections: 1, filter: {name: bucketsColl.getName()}}));
if (expireAfterSeconds !== 'off') {
assert.eq(expireAfterSeconds,
res.cursor.firstBatch[0].options.expireAfterSeconds,
collToChange.getFullName() + ': ' + expireAfterSeconds + ': ' + tojson(res));
} else {
assert(!res.cursor.firstBatch[0].options.hasOwnProperty("expireAfterSeconds"),
collToChange.getFullName() + ': ' + expireAfterSeconds + ': ' + tojson(res));
}
};
// Tests for collMod on the time-series collection.
// Change expireAfterSeconds to 10.
runTest(coll, 10);
// Change expireAfterSeconds to 0.
runTest(coll, 0);
// Disable expireAfterSeconds.
runTest(coll, 'off');
// Enable expireAfterSeconds again.
runTest(coll, 100);
})();
|
