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.commandWorked(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();
})();