jstests/replsets/initial_sync_views.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

/**
 * Test initial sync with views present.
 */

(function() {
    "use strict";

    load("jstests/replsets/rslib.js");
    let testName = "initial_sync_views";
    let hostName = getHostName();

    let replTest = new ReplSetTest({name: testName, nodes: 1});
    replTest.startSet();
    replTest.initiate();

    let primaryDB = replTest.getPrimary().getDB(testName);

    for (let i = 0; i < 10; ++i) {
        assert.writeOK(primaryDB.coll.insert({a: i}));
    }

    // Setup view.
    assert.commandWorked(
        primaryDB.runCommand({create: "view", viewOn: "coll", pipeline: [{$match: {a: 5}}]}));

    assert.eq(10, primaryDB.coll.find().itcount());
    assert.eq(1, primaryDB.view.find().itcount());

    // Add new member to the replica set and wait for initial sync to complete.
    let secondary = replTest.add();
    replTest.reInitiate();
    replTest.awaitReplication();
    replTest.awaitSecondaryNodes();

    // Confirm secondary has expected collection and view document count.
    let secondaryDB = secondary.getDB(testName);
    assert.eq(10, secondaryDB.coll.find().itcount());
    assert.eq(1, secondaryDB.view.find().itcount());

    replTest.stopSet();
})();