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
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
|
/**
* Verify that some metadata is properly changed after the upgrade and downgrade of a sharded
* cluster. More specifically:
*
* 1. Create a sharded cluster in replica set running an old binary version
* 2. Setup some data on cluster
* 3. Upgrade binaries and FCV of the cluster to the latest version
* 4. Verify the data consistency after the upgrade procedure
* 5. Downgrade binaries and FCV of the cluster to an old version
* 6. Verify the data consistency after the downgrade procedure
*/
(function() {
'use strict';
load('jstests/multiVersion/libs/multi_cluster.js'); // For upgradeCluster
load("jstests/libs/feature_flag_util.js");
const dbName = jsTestName();
function setupClusterAndDatabase(binVersion) {
const st = new ShardingTest({
mongos: 1,
config: 1,
shards: 2,
other: {
mongosOptions: {binVersion: binVersion},
configOptions: {binVersion: binVersion},
rsOptions: {
binVersion: binVersion,
},
rs: {nodes: 2},
}
});
st.configRS.awaitReplication();
assert.commandWorked(
st.s.adminCommand({enableSharding: dbName, primaryShard: st.shard0.shardName}));
return st;
}
function getNodeName(node) {
const info = node.adminCommand({hello: 1});
return info.setName + '_' + (info.secondary ? 'secondary' : 'primary');
}
function checkConfigVersionDoc() {
// TODO: SERVER-68889 remove this function once 7.0 becomes last LTS
const versionDoc = st.s.getCollection('config.version').findOne();
if (FeatureFlagUtil.isPresentAndEnabled(st.s, "StopUsingConfigVersion")) {
// Check that the version doc doesn't contain any of the deprecatedFields
const deprecatedFields = [
"excluding",
"upgradeId",
"upgradeState",
"currentVersion",
"minCompatibleVersion",
];
deprecatedFields.forEach(deprecatedField => {
assert(!versionDoc.hasOwnProperty(deprecatedField),
`Found deprecated field '${deprecatedField}' in version document ${
tojson(versionDoc)}`);
});
} else {
assert.eq(versionDoc.minCompatibleVersion,
5,
"Version doc does not contain expected value for minCompatibleVersion field");
assert.eq(versionDoc.currentVersion,
6,
"Version doc does not contain expected value for currentVersion field");
}
}
function checkConfigAndShardsFCV(expectedFCV) {
const configPrimary = st.configRS.getPrimary();
const shard0Primary = st.rs0.getPrimary();
const shard0Secondary = st.rs0.getSecondary();
shard0Secondary.setSecondaryOk();
const shard1Primary = st.rs1.getPrimary();
const shard1Secondary = st.rs1.getSecondary();
shard1Secondary.setSecondaryOk();
for (const node
of [configPrimary, shard0Primary, shard0Secondary, shard1Primary, shard1Secondary]) {
jsTest.log('Verify that the FCV is properly set on node ' + getNodeName(node));
const fcvDoc = node.adminCommand({getParameter: 1, featureCompatibilityVersion: 1});
assert.eq(expectedFCV, fcvDoc.featureCompatibilityVersion.version);
}
}
function checkClusterBeforeUpgrade(fcv) {
checkConfigAndShardsFCV(fcv);
checkConfigVersionDoc();
}
function checkClusterAfterBinaryUpgrade() {
checkConfigVersionDoc();
}
function checkClusterAfterFCVUpgrade(fcv) {
checkConfigAndShardsFCV(fcv);
checkConfigVersionDoc();
}
function checkClusterAfterFCVDowngrade() {
checkConfigVersionDoc();
}
function checkClusterAfterBinaryDowngrade(fcv) {
checkConfigAndShardsFCV(fcv);
checkConfigVersionDoc();
}
for (const oldVersion of [lastLTSFCV, lastContinuousFCV]) {
//////////////////////////////
// Setting and testing cluster using old binaries in default FCV mode
jsTest.log('Deploying cluster version ' + oldVersion);
var st = setupClusterAndDatabase(oldVersion);
checkClusterBeforeUpgrade(oldVersion);
//////////////////////////////
// Setting and testing cluster using latest binaries in latest FCV mode
jsTest.log('Upgrading binaries to latest version');
st.upgradeCluster('latest');
checkClusterAfterBinaryUpgrade();
jsTest.log('Upgrading FCV to ' + latestFCV);
assert.commandWorked(st.s.adminCommand({setFeatureCompatibilityVersion: latestFCV}));
checkClusterAfterFCVUpgrade(latestFCV);
//////////////////////////////
// Setting and testing cluster using old binaries in old FCV mode
jsTest.log('Downgrading FCV to ' + oldVersion);
assert.commandWorked(st.s.adminCommand({setFeatureCompatibilityVersion: oldVersion}));
checkClusterAfterFCVDowngrade();
jsTest.log('Downgrading binaries to version ' + oldVersion);
st.downgradeCluster(oldVersion);
checkClusterAfterBinaryDowngrade(oldVersion);
st.stop();
}
})();
|
