blob: 38e33baeb4bd0c05c6013bfcbb62ffa0b4031a67 (
plain)
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
|
// Contains helper for checking format version of unique indexes.
/**
* Verifies that all unique indexes belonging to all collections on all databases on the server
* are in correct data format version.
*/
function checkUniqueIndexFormatVersion(adminDB) {
// Data format version is WiredTiger specific and not required to be tested for other
// storage engines.
const isWiredTiger =
assert.commandWorked(adminDB.serverStatus()).storageEngine.name === "wiredTiger";
if (!isWiredTiger)
return;
let res = assert.commandWorked(adminDB.runCommand({"listDatabases": 1}));
let databaseList = res.databases;
databaseList.forEach(function(database) {
let currentDatabase = adminDB.getSiblingDB(database.name);
// Get the list of collections including collections that are pending drop. This is to
// ensure that every unique index has the correct format version.
let collectionsWithPending =
currentDatabase.runCommand("listCollections", {includePendingDrops: true})
.cursor.firstBatch;
collectionsWithPending.forEach(function(c) {
if (c.type == "view") {
return;
}
let currentCollection = currentDatabase.getCollection(c.name);
currentCollection.getIndexes().forEach(function(index) {
if (index.unique && !index.clustered) {
let ifv = currentCollection.aggregate({$collStats: {storageStats: {}}})
.next()
.storageStats.indexDetails[index.name]
.metadata.formatVersion;
if (index.v === 2) {
assert(ifv == 12 || ifv == 14,
"Expected index format version 12 or 14 for unique index: " +
tojson(index));
} else {
assert(ifv == 11 || ifv == 13,
"Expected index format version 11 or 13 for unique index: " +
tojson(index));
}
}
});
});
});
}
|
