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
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
/**
* Tests upgrading a cluster from last stable to current version.
*/
load('./jstests/multiVersion/libs/multi_rs.js');
load('./jstests/multiVersion/libs/multi_cluster.js');
(function() {
/**
* @param isRSCluster {bool} use replica set shards.
*/
var runTest = function(isRSCluster) {
"use strict";
jsTest.log("Starting" + (isRSCluster ? " (replica set)" : "") + " cluster" + "...");
var testCRUD = function(db) {
assert.writeOK(db.foo.insert({x: 1}));
assert.writeOK(db.foo.insert({x: -1}));
assert.writeOK(db.foo.update({x: 1}, {$set: {y: 1}}));
assert.writeOK(db.foo.update({x: -1}, {$set: {y: 1}}));
var doc1 = db.foo.findOne({x: 1});
assert.eq(1, doc1.y);
var doc2 = db.foo.findOne({x: -1});
assert.eq(1, doc2.y);
assert.writeOK(db.foo.remove({x: 1}, true));
assert.writeOK(db.foo.remove({x: -1}, true));
assert.eq(null, db.foo.findOne());
};
var st = new ShardingTest({
shards: 2,
mongos: 1,
other: {
mongosOptions: {binVersion: "last-stable"},
configOptions: {binVersion: "last-stable"},
shardOptions: {binVersion: "last-stable"},
rsOptions: {binVersion: "last-stable"},
rs: isRSCluster,
// TODO: SERVER-24163 remove after v3.4
waitForCSRSSecondaries: false
}
});
st.configRS.awaitReplication();
// check that config.version document gets initialized properly
var version = st.s.getCollection('config.version').findOne();
assert.eq(version.minCompatibleVersion, 5);
assert.eq(version.currentVersion, 6);
var clusterID = version.clusterId;
assert.neq(null, clusterID);
assert.eq(version.excluding, undefined);
// Setup sharded collection
assert.commandWorked(st.s.adminCommand({enableSharding: 'sharded'}));
st.ensurePrimaryShard('sharded', st.shard0.shardName);
// We explicitly create an index on the shard key to avoid having mongos attempt to
// implicitly create one. This is necessary because mongos would otherwise explicitly
// include the "collation" option in the requested index to prevent potentially inheriting
// the collation-default collation. However, specifying the "collation" option requires a
// v=2 index and that may not be possible if the server has featureCompatibilityVersion=3.2.
//
// TODO SERVER-25955: Allow mongos to implicitly create the shard key index when sharding a
// collection with a "simple" default collation and update this test case to not explicitly
// create it.
assert.commandWorked(st.s.getDB('sharded').foo.createIndex({x: 1}));
assert.commandWorked(st.s.adminCommand({shardCollection: 'sharded.foo', key: {x: 1}}));
assert.commandWorked(st.s.adminCommand({split: 'sharded.foo', middle: {x: 0}}));
assert.commandWorked(
st.s.adminCommand({moveChunk: 'sharded.foo', find: {x: 1}, to: st.shard1.shardName}));
testCRUD(st.s.getDB('unsharded'));
testCRUD(st.s.getDB('sharded'));
// upgrade the config servers first
jsTest.log('upgrading config servers');
st.upgradeCluster("latest", {upgradeMongos: false, upgradeShards: false});
st.restartMongoses();
testCRUD(st.s.getDB('unsharded'));
testCRUD(st.s.getDB('sharded'));
// Then upgrade the shards.
jsTest.log('upgrading shard servers');
st.upgradeCluster("latest", {upgradeMongos: false, upgradeConfigs: false});
st.restartMongoses();
testCRUD(st.s.getDB('unsharded'));
testCRUD(st.s.getDB('sharded'));
// Finally, upgrade mongos
jsTest.log('upgrading mongos servers');
st.upgradeCluster("latest", {upgradeConfigs: false, upgradeShards: false});
st.restartMongoses();
testCRUD(st.s.getDB('unsharded'));
testCRUD(st.s.getDB('sharded'));
// Check that version document is unmodified.
version = st.s.getCollection('config.version').findOne();
assert.eq(version.minCompatibleVersion, 5);
assert.eq(version.currentVersion, 6);
assert.neq(clusterID, version.clusterId);
assert.eq(version.excluding, undefined);
st.stop();
};
runTest(false);
runTest(true);
})();
|
