mirror of https://github.com/mongodb/mongo
82 lines
2.5 KiB
JavaScript
82 lines
2.5 KiB
JavaScript
/**
|
|
* Tests that we emit info level log messages for DDL write operations at
|
|
* the expected points on both primaries and secondaries.
|
|
* @tags: [
|
|
* uses_transactions,
|
|
* requires_fcv_70,
|
|
* ]
|
|
*/
|
|
import {ReplSetTest} from "jstests/libs/replsettest.js";
|
|
|
|
const name = jsTestName();
|
|
const rst = new ReplSetTest({name: name, nodes: 2});
|
|
rst.startSet();
|
|
|
|
const nodes = rst.nodeList();
|
|
rst.initiate({
|
|
"_id": name,
|
|
"members": [
|
|
{"_id": 0, "host": nodes[0]},
|
|
{"_id": 1, "host": nodes[1], "priority": 0},
|
|
],
|
|
});
|
|
|
|
const primary = rst.getPrimary();
|
|
const secondary = rst.getSecondary();
|
|
|
|
const testDB = primary.getDB(name);
|
|
const collectionName = "log_collection";
|
|
|
|
rst.awaitReplication();
|
|
|
|
assert.commandWorked(testDB.createCollection(collectionName));
|
|
assert.commandWorked(testDB.getCollection(collectionName).createIndex({x: 1}));
|
|
assert.commandWorked(testDB.runCommand({collMod: collectionName, index: {keyPattern: {x: 1}, hidden: true}}));
|
|
assert.commandWorked(testDB.getCollection(collectionName).dropIndex({x: 1}));
|
|
|
|
const newCollectionName = "log_collection_renamed";
|
|
|
|
assert.commandWorked(
|
|
primary
|
|
.getDB("admin")
|
|
.runCommand({renameCollection: `${name}.${collectionName}`, to: `${name}.${newCollectionName}`}),
|
|
);
|
|
assert.commandWorked(testDB.runCommand({drop: newCollectionName}));
|
|
assert.commandWorked(testDB.runCommand({dropDatabase: 1}));
|
|
|
|
const txnCollectionName = "log_collection_txn";
|
|
|
|
const session = testDB.getMongo().startSession();
|
|
const sessionDB = session.getDatabase(name);
|
|
|
|
session.startTransaction();
|
|
assert.commandWorked(sessionDB.createCollection(txnCollectionName));
|
|
assert.commandWorked(sessionDB.getCollection(txnCollectionName).createIndex({x: 1}));
|
|
session.commitTransaction();
|
|
|
|
rst.awaitReplication();
|
|
|
|
const primaryLogCodes = [
|
|
7360100, // createIndexes in txn
|
|
7360101, // createIndexes
|
|
7360102, // create in txn
|
|
7360103, // create
|
|
7360104, // collMod
|
|
7360105, // dropDatabase
|
|
7360106, // drop
|
|
7360107, // dropIndexes
|
|
7360108, // renameCollection
|
|
];
|
|
for (const code of primaryLogCodes) {
|
|
checkLog.contains(primary, code, 1 * 1000);
|
|
}
|
|
|
|
const opsLogged = ["createIndexes", "create", "collMod", "dropDatabase", "drop", "dropIndexes", "renameCollection"];
|
|
|
|
for (const op of opsLogged) {
|
|
checkLog.contains(secondary, new RegExp(`7360109.*${op}`), 1 * 1000); // OplogBatcher message
|
|
checkLog.contains(secondary, new RegExp(`7360110.*${op}`), 1 * 1000); // OplogApplier message
|
|
}
|
|
|
|
rst.stopSet();
|