diff options
author | Esha Maharishi <esha.maharishi@mongodb.com> | 2018-03-05 13:58:42 -0500 |
---|---|---|
committer | Esha Maharishi <esha.maharishi@mongodb.com> | 2018-03-06 11:32:05 -0500 |
commit | 29be917dd176b883880198347d872fa10d1ad701 (patch) | |
tree | 9bea37add5550cd06d246e75659a8ea04adeb5bf /src/mongo/dbtests/jstests.cpp | |
parent | 495788543be6775994029fd7b7ee4c4c141a1e8e (diff) | |
download | mongo-29be917dd176b883880198347d872fa10d1ad701.tar.gz |
SERVER-33668 Get rid of OperationShardingState::unsetShardVersion()
Diffstat (limited to 'src/mongo/dbtests/jstests.cpp')
-rw-r--r-- | src/mongo/dbtests/jstests.cpp | 80 |
1 files changed, 49 insertions, 31 deletions
diff --git a/src/mongo/dbtests/jstests.cpp b/src/mongo/dbtests/jstests.cpp index 192076f08e1..eccc7acb752 100644 --- a/src/mongo/dbtests/jstests.cpp +++ b/src/mongo/dbtests/jstests.cpp @@ -1119,39 +1119,46 @@ class TestRoundTrip { public: virtual ~TestRoundTrip() {} void run() { - // Insert in Javascript -> Find using DBDirectClient + { + // Insert in Javascript -> Find using DBDirectClient - // Drop the collection - const ServiceContext::UniqueOperationContext opCtxPtr = cc().makeOperationContext(); - OperationContext& opCtx = *opCtxPtr; - DBDirectClient client(&opCtx); + // Drop the collection + const ServiceContext::UniqueOperationContext opCtxPtr = cc().makeOperationContext(); + OperationContext& opCtx = *opCtxPtr; + DBDirectClient client(&opCtx); - client.dropCollection("unittest.testroundtrip"); + client.dropCollection("unittest.testroundtrip"); - // Insert in Javascript - stringstream jsInsert; - jsInsert << "db.testroundtrip.insert(" << jsonIn() << ")"; - ASSERT_TRUE(client.eval("unittest", jsInsert.str())); + // Insert in Javascript + stringstream jsInsert; + jsInsert << "db.testroundtrip.insert(" << jsonIn() << ")"; + ASSERT_TRUE(client.eval("unittest", jsInsert.str())); - // Find using DBDirectClient - BSONObj excludeIdProjection = BSON("_id" << 0); - BSONObj directFind = client.findOne("unittest.testroundtrip", "", &excludeIdProjection); - bsonEquals(bson(), directFind); + // Find using DBDirectClient + BSONObj excludeIdProjection = BSON("_id" << 0); + BSONObj directFind = client.findOne("unittest.testroundtrip", "", &excludeIdProjection); + bsonEquals(bson(), directFind); + } + { + // Insert using DBDirectClient -> Find in Javascript - // Insert using DBDirectClient -> Find in Javascript + const ServiceContext::UniqueOperationContext opCtxPtr = cc().makeOperationContext(); + OperationContext& opCtx = *opCtxPtr; + DBDirectClient client(&opCtx); - // Drop the collection - client.dropCollection("unittest.testroundtrip"); + // Drop the collection + client.dropCollection("unittest.testroundtrip"); - // Insert using DBDirectClient - client.insert("unittest.testroundtrip", bson()); + // Insert using DBDirectClient + client.insert("unittest.testroundtrip", bson()); - // Find in Javascript - stringstream jsFind; - jsFind << "dbref = db.testroundtrip.findOne( { } , { _id : 0 } )\n" - << "assert.eq(dbref, " << jsonOut() << ")"; - ASSERT_TRUE(client.eval("unittest", jsFind.str())); + // Find in Javascript + stringstream jsFind; + jsFind << "dbref = db.testroundtrip.findOne( { } , { _id : 0 } )\n" + << "assert.eq(dbref, " << jsonOut() << ")"; + ASSERT_TRUE(client.eval("unittest", jsFind.str())); + } } protected: @@ -2230,18 +2237,29 @@ public: update.append("_id", "invalidstoredjs1"); update.appendCode("value", "function () { db.test.find().forEach(function(obj) { continue; }); }"); - - const ServiceContext::UniqueOperationContext opCtxPtr = cc().makeOperationContext(); - OperationContext& opCtx = *opCtxPtr; - DBDirectClient client(&opCtx); - client.update("test.system.js", query.obj(), update.obj(), true /* upsert */); + { + const ServiceContext::UniqueOperationContext opCtxPtr = cc().makeOperationContext(); + OperationContext& opCtx = *opCtxPtr; + DBDirectClient client(&opCtx); + client.update("test.system.js", query.obj(), update.obj(), true /* upsert */); + } unique_ptr<Scope> s(getGlobalScriptEngine()->newScope()); - client.eval("test", "invalidstoredjs1()"); + { + const ServiceContext::UniqueOperationContext opCtxPtr = cc().makeOperationContext(); + OperationContext& opCtx = *opCtxPtr; + DBDirectClient client(&opCtx); + client.eval("test", "invalidstoredjs1()"); + } BSONObj info; BSONElement ret; - ASSERT(client.eval("test", "return 5 + 12", info, ret)); + { + const ServiceContext::UniqueOperationContext opCtxPtr = cc().makeOperationContext(); + OperationContext& opCtx = *opCtxPtr; + DBDirectClient client(&opCtx); + ASSERT(client.eval("test", "return 5 + 12", info, ret)); + } ASSERT_EQUALS(17, ret.number()); } }; |