mirror of
https://github.com/mongodb/mongo.git
synced 2024-11-24 00:17:37 +01:00
80 lines
2.6 KiB
JavaScript
80 lines
2.6 KiB
JavaScript
//
|
|
// Tests that mongos validating writes when stale does not DOS config servers
|
|
//
|
|
// Note that this is *unsafe* with broadcast removes and updates
|
|
//
|
|
// @tags: [
|
|
// # TODO (SERVER-88123): Re-enable this test.
|
|
// # Test doesn't start enough mongods to have num_mongos routers
|
|
// embedded_router_incompatible,
|
|
// ]
|
|
import {ShardingTest} from "jstests/libs/shardingtest.js";
|
|
|
|
var st = new ShardingTest({shards: 2, mongos: 3, other: {rsOptions: {verbose: 2}}});
|
|
|
|
var mongos = st.s0;
|
|
var staleMongosA = st.s1;
|
|
var staleMongosB = st.s2;
|
|
|
|
var admin = mongos.getDB("admin");
|
|
const kDbName = "foo";
|
|
assert.commandWorked(
|
|
admin.runCommand({enableSharding: kDbName, primaryShard: st.shard1.shardName}));
|
|
var coll = mongos.getCollection(kDbName + ".bar");
|
|
var staleCollA = staleMongosA.getCollection(coll + "");
|
|
var staleCollB = staleMongosB.getCollection(coll + "");
|
|
|
|
coll.createIndex({a: 1});
|
|
|
|
// Shard the collection on {a: 1} and move one chunk to another shard. Updates need to be across
|
|
// two shards to trigger an error, otherwise they are versioned and will succeed after raising a
|
|
// StaleConfig error.
|
|
st.shardColl(coll, {a: 1}, {a: 0}, {a: 1}, coll.getDB(), true);
|
|
|
|
// Let the stale mongos see the collection state
|
|
staleCollA.findOne();
|
|
staleCollB.findOne();
|
|
|
|
// Change the collection sharding state
|
|
coll.drop();
|
|
coll.createIndex({b: 1});
|
|
st.shardColl(coll, {b: 1}, {b: 0}, {b: 1}, coll.getDB(), true);
|
|
|
|
// Make sure that we can successfully insert, even though we have stale state
|
|
assert.commandWorked(staleCollA.insert({b: "b"}));
|
|
|
|
// Change the collection sharding state
|
|
coll.drop();
|
|
coll.createIndex({c: 1});
|
|
st.shardColl(coll, {c: 1}, {c: 0}, {c: 1}, coll.getDB(), true);
|
|
|
|
// Make sure we can successfully upsert, even though we have stale state
|
|
assert.commandWorked(staleCollA.update({c: "c"}, {c: "c"}, true));
|
|
|
|
// Change the collection sharding state
|
|
coll.drop();
|
|
coll.createIndex({d: 1});
|
|
st.shardColl(coll, {d: 1}, {d: 0}, {d: 1}, coll.getDB(), true);
|
|
|
|
// Make sure we can successfully update, even though we have stale state
|
|
assert.commandWorked(coll.insert({d: "d"}));
|
|
|
|
assert.commandWorked(staleCollA.update({d: "d"}, {$set: {x: "x"}}, false, false));
|
|
assert.eq(staleCollA.findOne().x, "x");
|
|
|
|
assert.eq(staleCollB.findOne().x, "x");
|
|
|
|
// Change the collection sharding state
|
|
coll.drop();
|
|
coll.createIndex({e: 1});
|
|
// Deletes need to be across two shards to trigger an error.
|
|
st.shardColl(coll, {e: 1}, {e: 0}, {e: 1}, coll.getDB(), true);
|
|
|
|
// Make sure we can successfully remove, even though we have stale state
|
|
assert.commandWorked(coll.insert({e: "e"}));
|
|
|
|
assert.commandWorked(staleCollA.remove({e: "e"}, true));
|
|
assert.eq(null, staleCollA.findOne());
|
|
|
|
st.stop();
|