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
|
/**
* Tests that time-series collection that require extended range support are properly recognized
* during startup recovery.
* @tags: [
* requires_replication,
* # The primary is restarted and must retain its data.
* requires_persistence,
* ]
*/
(function() {
'use strict';
const getExtendedRangeCount = (db) => {
return assert.commandWorked(db.adminCommand({serverStatus: 1}))
.catalogStats.timeseriesExtendedRange;
};
const rst = new ReplSetTest({name: jsTest.name(), nodes: 2});
rst.startSet();
rst.initiateWithHighElectionTimeout();
const primary = rst.getPrimary();
const secondary = rst.getSecondary();
const dbName = "testDB";
const primaryDB = primary.getDB(dbName);
assert.eq(undefined, getExtendedRangeCount(primary));
assert.eq(undefined, getExtendedRangeCount(secondary));
assert.commandWorked(primaryDB.createCollection("standard", {timeseries: {timeField: "time"}}));
assert.commandWorked(primaryDB.createCollection("extended", {timeseries: {timeField: "time"}}));
assert.commandWorked(
primaryDB.standard.insert({time: ISODate("1980-01-01T00:00:00.000Z")}, {w: 2}));
assert.commandWorked(
primaryDB.extended.insert({time: ISODate("2040-01-01T00:00:00.000Z")}, {w: 2}));
// Make sure the collections got flagged properly during the initial write.
assert(checkLog.checkContainsWithCountJson(
primary, 6679402, {"nss": "testDB.standard", "timeField": "time"}, 0));
assert(checkLog.checkContainsWithCountJson(
secondary, 6679402, {"nss": "testDB.standard", "timeField": "time"}, 0));
assert(checkLog.checkContainsWithCountJson(
primary, 6679402, {"nss": "testDB.extended", "timeField": "time"}, 1));
assert(checkLog.checkContainsWithCountJson(
secondary, 6679402, {"nss": "testDB.extended", "timeField": "time"}, 1));
assert.eq(1, getExtendedRangeCount(primary));
assert.eq(1, getExtendedRangeCount(secondary));
rst.restart(primary);
rst.waitForState(primary, ReplSetTest.State.SECONDARY);
assert.eq(1, primaryDB.standard.count());
assert.eq(1, primaryDB.extended.count());
// Make sure the collections get flagged properly again after startup.
assert.eq(1, getExtendedRangeCount(primary));
rst.stopSet();
})();
|
