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
|
/**
* Tests that the donorStartMigration command throws a error if the provided database prefix
* is unsupported (i.e. '', 'admin', 'local' or 'config') or if the recipient connection string
* matches the donor's connection string.
*
* @tags: [requires_fcv_47]
*/
(function() {
"use strict";
const rst =
new ReplSetTest({nodes: 1, nodeOptions: {setParameter: {enableTenantMigrations: true}}});
rst.startSet();
rst.initiate();
const primary = rst.getPrimary();
// Test unsupported database prefixes.
const unsupportedDBPrefixes = ['', 'admin', 'local', 'config'];
unsupportedDBPrefixes.forEach((dbPrefix) => {
assert.commandFailedWithCode(primary.adminCommand({
donorStartMigration: 1,
migrationId: UUID(),
recipientConnectionString: "testRecipientConnString",
databasePrefix: dbPrefix,
readPreference: {mode: "primary"}
}),
ErrorCodes.BadValue);
});
// Test migrating a database to the donor itself.
assert.commandFailedWithCode(primary.adminCommand({
donorStartMigration: 1,
migrationId: UUID(),
recipientConnectionString: rst.getURL(),
databasePrefix: "testDbPrefix",
readPreference: {mode: "primary"}
}),
ErrorCodes.InvalidOptions);
// Test migrating a database to a recipient that has one or more same hosts as donor
const conflictingRecipientConnectionString = "foo/bar:12345," + primary.host;
assert.commandFailedWithCode(primary.adminCommand({
donorStartMigration: 1,
migrationId: UUID(),
recipientConnectionString: conflictingRecipientConnectionString,
databasePrefix: "testDbPrefix",
readPreference: {mode: "primary"}
}),
ErrorCodes.InvalidOptions);
rst.stopSet();
})();
|
