mirror of https://github.com/mongodb/mongo
80 lines
2.8 KiB
JavaScript
80 lines
2.8 KiB
JavaScript
/**
|
|
* Tests that the 'prepareTransaction', 'commitTransaction', and 'abortTransaction' fail on
|
|
* secondaries.
|
|
*
|
|
* @tags: [uses_transactions, uses_prepare_transaction]
|
|
*/
|
|
|
|
(function() {
|
|
"use strict";
|
|
load("jstests/core/txns/libs/prepare_helpers.js");
|
|
|
|
const name = "prepared_transaction_commands_fail_on_secondaries";
|
|
const rst = new ReplSetTest({
|
|
nodes: [
|
|
{},
|
|
{rsConfig: {priority: 0}},
|
|
],
|
|
});
|
|
const nodes = rst.startSet();
|
|
rst.initiate();
|
|
|
|
const dbName = "test";
|
|
const collName = name;
|
|
|
|
const primary = rst.getPrimary();
|
|
const secondary = rst.getSecondary();
|
|
const testDB = primary.getDB(dbName);
|
|
|
|
assert.commandWorked(testDB.runCommand({create: collName, writeConcern: {w: "majority"}}));
|
|
|
|
const priSession = primary.startSession({causalConsistency: false});
|
|
const priSessionDB = priSession.getDatabase(dbName);
|
|
const priSessionColl = priSessionDB.getCollection(collName);
|
|
|
|
const secSession = PrepareHelpers.createSessionWithGivenId(
|
|
secondary, priSession.getSessionId(), {causalConsistency: false});
|
|
|
|
priSession.startTransaction();
|
|
const doc = {
|
|
_id: 1
|
|
};
|
|
assert.commandWorked(priSessionColl.insert(doc));
|
|
rst.awaitReplication();
|
|
|
|
jsTestLog("Test that prepare fails on a secondary");
|
|
const txnNumber = NumberLong(priSession.getTxnNumber_forTesting());
|
|
assert.commandFailedWithCode(secSession.getDatabase('admin').adminCommand(
|
|
{prepareTransaction: 1, txnNumber: txnNumber, autocommit: false}),
|
|
ErrorCodes.NotWritablePrimary);
|
|
|
|
const prepareTimestamp = PrepareHelpers.prepareTransaction(priSession);
|
|
rst.awaitReplication();
|
|
|
|
jsTestLog("Test that prepared commit fails on a secondary");
|
|
// Add 1 to the increment so that the commitTimestamp is "after" the prepareTimestamp.
|
|
const commitTimestamp = Timestamp(prepareTimestamp.getTime(), prepareTimestamp.getInc() + 1);
|
|
assert.commandFailedWithCode(secSession.getDatabase('admin').adminCommand({
|
|
commitTransaction: 1,
|
|
commitTimestamp: commitTimestamp,
|
|
txnNumber: txnNumber,
|
|
autocommit: false
|
|
}),
|
|
ErrorCodes.NotWritablePrimary);
|
|
|
|
jsTestLog("Test that prepared abort fails on a secondary");
|
|
assert.commandFailedWithCode(secSession.getDatabase('admin').adminCommand(
|
|
{abortTransaction: 1, txnNumber: txnNumber, autocommit: false}),
|
|
ErrorCodes.NotWritablePrimary);
|
|
|
|
jsTestLog("Test that we can still commit the transaction");
|
|
assert.commandWorked(PrepareHelpers.commitTransaction(priSession, commitTimestamp));
|
|
rst.awaitReplication();
|
|
assert.docEq(doc, testDB[collName].findOne());
|
|
assert.eq(1, testDB[collName].find().itcount());
|
|
assert.docEq(doc, secondary.getDB(dbName)[collName].findOne());
|
|
assert.eq(1, secondary.getDB(dbName)[collName].find().itcount());
|
|
|
|
rst.stopSet();
|
|
})();
|