jstests/sharding/uuid_propagated_to_config_server_on_shardCollection.js


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

/**
 * Tests that the shardCollection command obtains the collection's UUID from the primary shard and
 * persists it in config.collections.
 */
(function() {
    "use strict";

    load("jstests/libs/uuid_util.js");

    let db = "test";

    let st = new ShardingTest({shards: {rs0: {nodes: 1}, rs1: {nodes: 1}}, other: {config: 3}});

    assert.commandWorked(st.s.adminCommand({enableSharding: db}));
    st.ensurePrimaryShard(db, st.shard0.shardName);

    // Check that shardCollection propagates and persists UUIDs.
    for (let i = 0; i < 3; i++) {
        let coll = "bar" + i;
        let nss = db + "." + coll;

        // It shouldn't matter whether the collection existed on the shard already or not; test
        // both cases.
        if (i === 0) {
            assert.writeOK(st.s.getDB(db).getCollection(coll).insert({x: 1}));
        }

        assert.commandWorked(st.s.adminCommand({shardCollection: nss, key: {_id: 1}}));

        // Check that the entry for the collection in config.collections has a uuid field.
        let collEntryUUID = getUUIDFromConfigCollections(st.s, nss);
        assert.neq(undefined, collEntryUUID);

        // Check that the uuid field in the config.collections entry matches the uuid on the shard.
        let listCollsUUID = getUUIDFromListCollections(st.shard0.getDB(db), coll);
        assert.neq(undefined, listCollsUUID);
        assert.eq(listCollsUUID, collEntryUUID);
    }

    st.stop();
})();