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
|
'use strict';
// The validate command should work in the following scenarios on a sharded environment with 3 or
// more shards:
//
// 1. Collection in an unsharded DB.
// 2. Sharded collection.
// 3. Sharded collection with chunks on two shards while the collection's DB exists on 3 or more
// shards. We enforce the latter condition by creating a dummy collection within the same
// database and splitting it across the shards. See SERVER-22588 for details.
// 4. The previous scenario, but with validation legitimately failing on one of the shards.
(function() {
const NUM_SHARDS = 3;
assert(NUM_SHARDS >= 3);
var st = new ShardingTest({shards: NUM_SHARDS});
var s = st.s;
var testDb = st.getDB('test');
function setup() {
assert.writeOK(testDb.test.insert({_id: 0}));
assert.writeOK(testDb.test.insert({_id: 1}));
assert.writeOK(testDb.dummy.insert({_id: 0}));
assert.writeOK(testDb.dummy.insert({_id: 1}));
assert.writeOK(testDb.dummy.insert({_id: 2}));
}
function validate(valid) {
var res = testDb.runCommand({validate: 'test'});
assert.commandWorked(res);
assert.eq(res.valid, valid, tojson(res));
}
function setFailValidateFailPointOnShard(enabled, shard) {
var mode;
if (enabled) {
mode = 'alwaysOn';
} else {
mode = 'off';
}
var res =
shard.adminCommand({configureFailPoint: 'validateCmdCollectionNotValid', mode: mode});
assert.commandWorked(res);
}
setup();
// 1. Collection in an unsharded DB.
validate(true);
// 2. Sharded collection in a DB.
assert.commandWorked(s.adminCommand({enableSharding: 'test'}));
st.ensurePrimaryShard('test', st.shard0.shardName);
assert.commandWorked(s.adminCommand({shardCollection: 'test.test', key: {_id: 1}}));
assert.commandWorked(s.adminCommand({shardCollection: 'test.dummy', key: {_id: 1}}));
validate(true);
// 3. Sharded collection with chunks on two shards.
st.ensurePrimaryShard('test', st.shard0.shardName);
assert.commandWorked(s.adminCommand({split: 'test.test', middle: {_id: 1}}));
assert.commandWorked(
testDb.adminCommand({moveChunk: 'test.test', find: {_id: 1}, to: st.shard1.shardName}));
// We move the dummy database to NUM_SHARDS shards so that testDb will exist on all NUM_SHARDS
// shards but the testDb.test collection will only exist on the first two shards. Prior to
// SERVER-22588, this scenario would cause validation to fail.
assert.commandWorked(s.adminCommand({split: 'test.dummy', middle: {_id: 1}}));
assert.commandWorked(s.adminCommand({split: 'test.dummy', middle: {_id: 2}}));
assert.commandWorked(
testDb.adminCommand({moveChunk: 'test.dummy', find: {_id: 1}, to: st.shard1.shardName}));
assert.commandWorked(
testDb.adminCommand({moveChunk: 'test.dummy', find: {_id: 2}, to: st.shard2.shardName}));
assert.eq(st.onNumShards('test'), 2);
assert.eq(st.onNumShards('dummy'), NUM_SHARDS);
validate(true);
// 4. Fail validation on one of the shards.
var primaryShard = st.getPrimaryShard('test');
setFailValidateFailPointOnShard(true, primaryShard);
validate(false);
setFailValidateFailPointOnShard(false, primaryShard);
})();
|
