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
94
95
96
|
/**
* Tests that the validate command detects incorrect WT table logging settings.
*
* @tags: [
* requires_wiredtiger,
* ]
*/
(function() {
'use strict';
load("jstests/libs/columnstore_util.js"); // For setUpServerForColumnStoreIndexTest.
let conn = MongoRunner.runMongod();
const dbpath = conn.dbpath;
const dbName = jsTestName();
const collName = 'coll';
const csiEnabled = setUpServerForColumnStoreIndexTest(conn.getDB(dbName));
const create = function(conn) {
assert.commandWorked(conn.getDB(dbName).createCollection(collName));
if (csiEnabled) {
assert.commandWorked(conn.getDB(dbName)[collName].createIndex({'$**': "columnstore"}));
}
};
const collUri = function(conn) {
return conn.getDB(dbName)[collName]
.aggregate([{$collStats: {storageStats: {}}}])
.toArray()[0]
.storageStats.wiredTiger.uri.split('statistics:')[1];
};
const indexUri = function(conn, indexName) {
return conn.getDB(dbName)[collName]
.aggregate([{$collStats: {storageStats: {}}}])
.toArray()[0]
.storageStats.indexDetails[indexName]
.uri.split('statistics:')[1];
};
// Create the collection and indexes as a standlone, which will cause the tables to be logged.
create(conn);
MongoRunner.stopMongod(conn);
const nodeOptions = {
dbpath: dbpath,
noCleanData: true,
// Skip the normal step of switching the logging setting on the tables.
setParameter: {wiredTigerSkipTableLoggingChecksOnStartup: true},
};
const replTest = new ReplSetTest({
nodes: 1,
nodeOptions: nodeOptions,
});
replTest.startSet();
replTest.initiate();
const primary = replTest.getPrimary();
// Run validate as a replica set, which will expect the tables to not be logged.
let res = assert.commandWorked(primary.getDB(dbName).runCommand({validate: collName}));
assert(!res.valid);
assert.eq(res.errors.length, csiEnabled ? 3 : 2);
checkLog.containsJson(primary, 6898101, {uri: collUri(primary), expected: false});
checkLog.containsJson(
primary, 6898101, {index: '_id_', uri: indexUri(primary, '_id_'), expected: false});
if (csiEnabled) {
checkLog.containsJson(
primary,
6898101,
{index: '$**_columnstore', uri: indexUri(primary, '$**_columnstore'), expected: false});
}
// Create the collection and indexes as a replica set, which will cause the tables to not be logged.
assert.commandWorked(primary.getDB(dbName).runCommand({drop: collName}));
create(primary);
replTest.stopSet(null, false, {noCleanData: true, skipValidation: true});
conn = MongoRunner.runMongod(nodeOptions);
// Run validate as a standalone, which will expect the tables to be logged.
res = assert.commandWorked(conn.getDB(dbName).runCommand({validate: collName}));
assert(!res.valid);
assert.eq(res.errors.length, csiEnabled ? 3 : 2);
checkLog.containsJson(conn, 6898101, {uri: collUri(conn), expected: true});
checkLog.containsJson(conn, 6898101, {index: '_id_', uri: indexUri(conn, '_id_'), expected: true});
if (csiEnabled) {
checkLog.containsJson(
conn,
6898101,
{index: '$**_columnstore', uri: indexUri(conn, '$**_columnstore'), expected: true});
}
MongoRunner.stopMongod(conn, null, {skipValidation: true});
}());
|
