mirror of
https://github.com/mongodb/mongo.git
synced 2024-11-24 00:17:37 +01:00
70 lines
2.6 KiB
JavaScript
70 lines
2.6 KiB
JavaScript
// @tags: [uses_transactions]
|
|
import {
|
|
migrateStepNames,
|
|
moveChunkParallel,
|
|
moveChunkStepNames,
|
|
pauseMigrateAtStep,
|
|
pauseMoveChunkAtStep,
|
|
unpauseMigrateAtStep,
|
|
unpauseMoveChunkAtStep,
|
|
waitForMigrateStep,
|
|
waitForMoveChunkStep,
|
|
} from "jstests/libs/chunk_manipulation_util.js";
|
|
import {ShardingTest} from "jstests/libs/shardingtest.js";
|
|
|
|
let staticMongod = MongoRunner.runMongod({});
|
|
|
|
let st = new ShardingTest({shards: 2});
|
|
|
|
assert.commandWorked(
|
|
st.s0.adminCommand({enableSharding: 'test', primaryShard: st.shard0.shardName}));
|
|
assert.commandWorked(st.s0.adminCommand({shardCollection: 'test.user', key: {_id: 1}}));
|
|
|
|
let coll = st.s.getDB('test').user;
|
|
assert.commandWorked(coll.insert({_id: 'updateMe'}));
|
|
assert.commandWorked(coll.insert({_id: 'deleteMe'}));
|
|
assert.commandWorked(coll.insert({_id: 'deleteMeUsingFindAndModify'}));
|
|
|
|
pauseMigrateAtStep(st.shard1, migrateStepNames.rangeDeletionTaskScheduled);
|
|
|
|
let joinMoveChunk =
|
|
moveChunkParallel(staticMongod, st.s0.host, {_id: 0}, null, 'test.user', st.shard1.shardName);
|
|
|
|
waitForMigrateStep(st.shard1, migrateStepNames.rangeDeletionTaskScheduled);
|
|
|
|
let session = st.s.startSession();
|
|
let sessionDB = session.getDatabase('test');
|
|
let sessionColl = sessionDB.getCollection('user');
|
|
|
|
session.startTransaction();
|
|
sessionColl.insert({_id: 'insertMe'});
|
|
sessionColl.update({_id: 'updateMe'}, {$inc: {y: 1}});
|
|
sessionColl.remove({_id: 'deleteMe'});
|
|
sessionColl.findAndModify({query: {_id: 'deleteMeUsingFindAndModify'}, remove: true});
|
|
|
|
pauseMoveChunkAtStep(st.shard0, moveChunkStepNames.reachedSteadyState);
|
|
unpauseMigrateAtStep(st.shard1, migrateStepNames.rangeDeletionTaskScheduled);
|
|
waitForMoveChunkStep(st.shard0, moveChunkStepNames.reachedSteadyState);
|
|
|
|
let recipientColl = st.rs1.getPrimary().getDB('test').user;
|
|
assert.eq(null, recipientColl.findOne({_id: 'insertMe'}));
|
|
assert.eq({_id: 'updateMe'}, recipientColl.findOne({_id: 'updateMe'}));
|
|
assert.eq({_id: 'deleteMe'}, recipientColl.findOne({_id: 'deleteMe'}));
|
|
assert.eq({_id: 'deleteMeUsingFindAndModify'},
|
|
recipientColl.findOne({_id: 'deleteMeUsingFindAndModify'}));
|
|
|
|
assert.commandWorked(session.commitTransaction_forTesting());
|
|
|
|
unpauseMoveChunkAtStep(st.shard0, moveChunkStepNames.reachedSteadyState);
|
|
joinMoveChunk();
|
|
|
|
assert.eq({_id: 'insertMe'}, recipientColl.findOne({_id: 'insertMe'}));
|
|
assert.eq({_id: 'updateMe', y: 1}, recipientColl.findOne({_id: 'updateMe'}));
|
|
assert.eq(null, recipientColl.findOne({_id: 'deleteMe'}));
|
|
assert.eq(null, recipientColl.findOne({_id: 'deleteMeUsingFindAndModify'}));
|
|
|
|
assert.eq(null, recipientColl.findOne({x: 1}));
|
|
|
|
st.stop();
|
|
MongoRunner.stopMongod(staticMongod);
|