mirror of https://github.com/mongodb/mongo
74 lines
2.1 KiB
JavaScript
74 lines
2.1 KiB
JavaScript
/**
|
|
* Tests that a txnNumber for a transaction that was aborted in-memory can be reused by a new
|
|
* primary. Mongos does this as an optimization.
|
|
* @tags: [uses_transactions, uses_prepare_transaction]
|
|
*/
|
|
import {ReplSetTest} from "jstests/libs/replsettest.js";
|
|
|
|
const rst = new ReplSetTest({name: "invalidate_sessions_on_stepdown", nodes: 2});
|
|
rst.startSet();
|
|
rst.initiate();
|
|
|
|
const dbName = "test";
|
|
const collName = "coll";
|
|
const node0 = rst.getPrimary();
|
|
const node1 = rst.getSecondary();
|
|
const node0Session = node0.startSession();
|
|
const sessionId = node0Session.getSessionId();
|
|
const node0SessionDB = node0Session.getDatabase(dbName);
|
|
|
|
assert.commandWorked(node0SessionDB.coll.insert({a: 1}, {writeConcern: {"w": "majority"}}));
|
|
|
|
jsTestLog("Run a transaction with txnNumber 0 on the primary.");
|
|
assert.commandWorked(
|
|
node0SessionDB.runCommand({
|
|
insert: collName,
|
|
documents: [{b: 1}],
|
|
txnNumber: NumberLong(0),
|
|
startTransaction: true,
|
|
autocommit: false,
|
|
}),
|
|
);
|
|
|
|
jsTestLog("Step up the secondary. The primary will abort the transaction when it steps down.");
|
|
rst.stepUp(node1);
|
|
|
|
const node1DB = node1.getDB(dbName);
|
|
|
|
jsTestLog("Run a transaction with txnNumber 0 and the same session ID on the new primary.");
|
|
assert.commandWorked(
|
|
node1DB.runCommand({
|
|
insert: collName,
|
|
documents: [{c: 1}],
|
|
lsid: sessionId,
|
|
txnNumber: NumberLong(0),
|
|
startTransaction: true,
|
|
autocommit: false,
|
|
}),
|
|
);
|
|
let res = assert.commandWorked(
|
|
node1DB.adminCommand({
|
|
prepareTransaction: 1,
|
|
lsid: sessionId,
|
|
txnNumber: NumberLong(0),
|
|
autocommit: false,
|
|
writeConcern: {w: "majority"},
|
|
}),
|
|
);
|
|
assert.commandWorked(
|
|
node1DB.adminCommand({
|
|
commitTransaction: 1,
|
|
commitTimestamp: res.prepareTimestamp,
|
|
lsid: sessionId,
|
|
txnNumber: NumberLong(0),
|
|
autocommit: false,
|
|
writeConcern: {w: "majority"},
|
|
}),
|
|
);
|
|
rst.awaitReplication();
|
|
assert.eq(2, node0SessionDB.coll.find().itcount());
|
|
assert.eq(0, node0SessionDB.coll.find({b: 1}).itcount());
|
|
assert.eq(1, node0SessionDB.coll.find({c: 1}).itcount());
|
|
|
|
rst.stopSet();
|