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
|
/**
* Tests tenant migration with time-series collections.
*
* @tags: [
* incompatible_with_macos,
* incompatible_with_windows_tls,
* requires_majority_read_concern,
* requires_persistence,
* serverless,
* ]
*/
(function() {
"use strict";
load("jstests/libs/uuid_util.js");
load("jstests/replsets/libs/tenant_migration_test.js");
const tenantMigrationTest = new TenantMigrationTest({name: jsTestName()});
const donorPrimary = tenantMigrationTest.getDonorPrimary();
const tenantId = ObjectId().str;
const tsDB = tenantMigrationTest.tenantDB(tenantId, "tsDB");
const collName = "tsColl";
const donorTSDB = donorPrimary.getDB(tsDB);
assert.commandWorked(donorTSDB.createCollection(collName, {timeseries: {timeField: "time"}}));
assert.commandWorked(donorTSDB.runCommand(
{insert: collName, documents: [{_id: 1, time: ISODate()}, {_id: 2, time: ISODate()}]}));
const migrationId = UUID();
const migrationOpts = {
migrationIdString: extractUUIDFromObject(migrationId),
tenantId,
};
TenantMigrationTest.assertCommitted(tenantMigrationTest.runMigration(migrationOpts));
const donorPrimaryCountDocumentsResult = donorTSDB[collName].countDocuments({});
const donorPrimaryCountResult = donorTSDB[collName].count();
// Creating a timeseries collection internally creates a view. Reading from timeseries collection
// works only if the view associated with the timeseries is present. So, this step ensures both the
// timeseries collection and the view are copied correctly to recipient.
tenantMigrationTest.getRecipientRst().nodes.forEach(node => {
jsTestLog(`Checking ${tsDB}.${collName} on ${node}`);
// Use "countDocuments" to check actual docs, "count" to check sizeStorer data.
assert.eq(donorPrimaryCountDocumentsResult,
node.getDB(tsDB)[collName].countDocuments({}),
"countDocuments");
assert.eq(donorPrimaryCountResult, node.getDB(tsDB)[collName].count(), "count");
});
tenantMigrationTest.stop();
})();
|
