blob: 9d2f3f321951ad35ef7051e55a179ba92c9416a4 (
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
|
//
// Basic tests for refineCollectionShardKey.
//
// Tag this test as 'requires_find_command' to prevent it from running in the legacy passthrough.
// @tags: [
// requires_find_command,
// ]
//
(function() {
'use strict';
const st = new ShardingTest({shards: 1, mongos: 1});
const kDbName = 'db';
const kCollName = 'foo';
const kNsName = kDbName + '.' + kCollName;
const kConfigCollections = 'config.collections';
const kConfigChunks = 'config.chunks';
const kConfigTags = 'config.tags';
const kConfigChangelog = 'config.changelog';
assert.commandWorked(st.s.adminCommand({enableSharding: kDbName}));
assert.commandWorked(st.s.adminCommand({shardCollection: kNsName, key: {_id: 1}}));
assert.commandWorked(st.s.getCollection(kNsName).createIndex({_id: 1, aKey: 1}));
const oldEpoch = st.s.getCollection(kConfigCollections).findOne({_id: kNsName}).lastmodEpoch;
assert.commandWorked(
st.s.adminCommand({refineCollectionShardKey: kNsName, key: {_id: 1, aKey: 1}}));
assert.eq({_id: 1, aKey: 1}, st.s.getCollection(kConfigCollections).findOne({_id: kNsName}).key);
assert.eq(1,
st.s.getCollection(kConfigChangelog)
.find({what: 'refineCollectionShardKey.start', ns: kNsName})
.itcount());
assert.eq(1,
st.s.getCollection(kConfigChangelog)
.find({what: 'refineCollectionShardKey.end', ns: kNsName})
.itcount());
st.stop();
})();
|
