summaryrefslogtreecommitdiff
path: root/src/mongo/dbtests/commandtests.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/dbtests/commandtests.cpp')
-rw-r--r--src/mongo/dbtests/commandtests.cpp403
1 files changed, 204 insertions, 199 deletions
diff --git a/src/mongo/dbtests/commandtests.cpp b/src/mongo/dbtests/commandtests.cpp
index 59e02c1b01d..c09fd1a3de1 100644
--- a/src/mongo/dbtests/commandtests.cpp
+++ b/src/mongo/dbtests/commandtests.cpp
@@ -37,234 +37,239 @@ using namespace mongo;
namespace CommandTests {
- using std::string;
-
- // one namespace per command
- namespace FileMD5 {
- struct Base {
- Base() : db(&_txn) {
- db.dropCollection(ns());
- ASSERT_OK(dbtests::createIndex(&_txn, ns(),BSON( "files_id" << 1 << "n" << 1 )));
- }
+using std::string;
+
+// one namespace per command
+namespace FileMD5 {
+struct Base {
+ Base() : db(&_txn) {
+ db.dropCollection(ns());
+ ASSERT_OK(dbtests::createIndex(&_txn, ns(), BSON("files_id" << 1 << "n" << 1)));
+ }
- const char* ns() { return "test.fs.chunks"; }
-
- OperationContextImpl _txn;
- DBDirectClient db;
- };
- struct Type0 : Base {
- void run() {
- {
- BSONObjBuilder b;
- b.genOID();
- b.append("files_id", 0);
- b.append("n", 0);
- b.appendBinData("data", 6, BinDataGeneral, "hello ");
- db.insert(ns(), b.obj());
- }
- {
- BSONObjBuilder b;
- b.genOID();
- b.append("files_id", 0);
- b.append("n", 1);
- b.appendBinData("data", 5, BinDataGeneral, "world");
- db.insert(ns(), b.obj());
- }
-
- BSONObj result;
- ASSERT( db.runCommand("test", BSON("filemd5" << 0), result) );
- ASSERT_EQUALS( string("5eb63bbbe01eeed093cb22bb8f5acdc3") , result["md5"].valuestr() );
- }
- };
- struct Type2 : Base {
- void run() {
- {
- BSONObjBuilder b;
- b.genOID();
- b.append("files_id", 0);
- b.append("n", 0);
- b.appendBinDataArrayDeprecated("data", "hello ", 6);
- db.insert(ns(), b.obj());
- }
- {
- BSONObjBuilder b;
- b.genOID();
- b.append("files_id", 0);
- b.append("n", 1);
- b.appendBinDataArrayDeprecated("data", "world", 5);
- db.insert(ns(), b.obj());
- }
-
- BSONObj result;
- ASSERT( db.runCommand("test", BSON("filemd5" << 0), result) );
- ASSERT_EQUALS( string("5eb63bbbe01eeed093cb22bb8f5acdc3") , result["md5"].valuestr() );
- }
- };
+ const char* ns() {
+ return "test.fs.chunks";
}
-namespace SymbolArgument {
- // SERVER-16260
- // The Ruby driver expects server commands to accept the Symbol BSON type as a collection name.
- // This is a historical quirk that we shall support until corrected versions of the Ruby driver
- // can be distributed. Retain these tests until MongoDB 3.0
-
- class Base {
- public:
- Base() : db(&_txn) {
- db.dropCollection(ns());
+ OperationContextImpl _txn;
+ DBDirectClient db;
+};
+struct Type0 : Base {
+ void run() {
+ {
+ BSONObjBuilder b;
+ b.genOID();
+ b.append("files_id", 0);
+ b.append("n", 0);
+ b.appendBinData("data", 6, BinDataGeneral, "hello ");
+ db.insert(ns(), b.obj());
+ }
+ {
+ BSONObjBuilder b;
+ b.genOID();
+ b.append("files_id", 0);
+ b.append("n", 1);
+ b.appendBinData("data", 5, BinDataGeneral, "world");
+ db.insert(ns(), b.obj());
}
- const char* ns() { return "test.symbolarg"; }
- const char* nsDb() { return "test"; }
- const char* nsColl() { return "symbolarg"; }
-
- OperationContextImpl _txn;
- DBDirectClient db;
- };
-
- class Drop : Base {
- public:
- void run() {
- ASSERT( db.createCollection(ns()) );
- {
- BSONObjBuilder cmd;
- cmd.appendSymbol("drop", nsColl()); // Use Symbol for SERVER-16260
-
- BSONObj result;
- bool ok = db.runCommand(nsDb(), cmd.obj(), result);
- log() << result.jsonString();
- ASSERT(ok);
- }
+ BSONObj result;
+ ASSERT(db.runCommand("test", BSON("filemd5" << 0), result));
+ ASSERT_EQUALS(string("5eb63bbbe01eeed093cb22bb8f5acdc3"), result["md5"].valuestr());
+ }
+};
+struct Type2 : Base {
+ void run() {
+ {
+ BSONObjBuilder b;
+ b.genOID();
+ b.append("files_id", 0);
+ b.append("n", 0);
+ b.appendBinDataArrayDeprecated("data", "hello ", 6);
+ db.insert(ns(), b.obj());
+ }
+ {
+ BSONObjBuilder b;
+ b.genOID();
+ b.append("files_id", 0);
+ b.append("n", 1);
+ b.appendBinDataArrayDeprecated("data", "world", 5);
+ db.insert(ns(), b.obj());
}
- };
- class DropIndexes : Base {
- public:
- void run() {
- ASSERT( db.createCollection(ns()) );
+ BSONObj result;
+ ASSERT(db.runCommand("test", BSON("filemd5" << 0), result));
+ ASSERT_EQUALS(string("5eb63bbbe01eeed093cb22bb8f5acdc3"), result["md5"].valuestr());
+ }
+};
+}
+
+namespace SymbolArgument {
+// SERVER-16260
+// The Ruby driver expects server commands to accept the Symbol BSON type as a collection name.
+// This is a historical quirk that we shall support until corrected versions of the Ruby driver
+// can be distributed. Retain these tests until MongoDB 3.0
+
+class Base {
+public:
+ Base() : db(&_txn) {
+ db.dropCollection(ns());
+ }
+
+ const char* ns() {
+ return "test.symbolarg";
+ }
+ const char* nsDb() {
+ return "test";
+ }
+ const char* nsColl() {
+ return "symbolarg";
+ }
+
+ OperationContextImpl _txn;
+ DBDirectClient db;
+};
+class Drop : Base {
+public:
+ void run() {
+ ASSERT(db.createCollection(ns()));
+ {
BSONObjBuilder cmd;
- cmd.appendSymbol("dropIndexes", nsColl()); // Use Symbol for SERVER-16260
- cmd.append("index", "*");
+ cmd.appendSymbol("drop", nsColl()); // Use Symbol for SERVER-16260
BSONObj result;
bool ok = db.runCommand(nsDb(), cmd.obj(), result);
log() << result.jsonString();
ASSERT(ok);
}
- };
-
- class FindAndModify : Base {
- public:
- void run() {
- ASSERT( db.createCollection(ns()) );
- {
- BSONObjBuilder b;
- b.genOID();
- b.append("name", "Tom");
- b.append("rating", 0);
- db.insert(ns(), b.obj());
+ }
+};
+
+class DropIndexes : Base {
+public:
+ void run() {
+ ASSERT(db.createCollection(ns()));
+
+ BSONObjBuilder cmd;
+ cmd.appendSymbol("dropIndexes", nsColl()); // Use Symbol for SERVER-16260
+ cmd.append("index", "*");
+
+ BSONObj result;
+ bool ok = db.runCommand(nsDb(), cmd.obj(), result);
+ log() << result.jsonString();
+ ASSERT(ok);
+ }
+};
+
+class FindAndModify : Base {
+public:
+ void run() {
+ ASSERT(db.createCollection(ns()));
+ {
+ BSONObjBuilder b;
+ b.genOID();
+ b.append("name", "Tom");
+ b.append("rating", 0);
+ db.insert(ns(), b.obj());
+ }
+
+ BSONObjBuilder cmd;
+ cmd.appendSymbol("findAndModify", nsColl()); // Use Symbol for SERVER-16260
+ cmd.append("update", BSON("$inc" << BSON("score" << 1)));
+ cmd.append("new", true);
+
+ BSONObj result;
+ bool ok = db.runCommand(nsDb(), cmd.obj(), result);
+ log() << result.jsonString();
+ ASSERT(ok);
+ // TODO(kangas) test that Tom's score is 1
+ }
+};
+
+class GeoSearch : Base {
+public:
+ void run() {
+ // Subset of geo_haystack1.js
+
+ int n = 0;
+ for (int x = 0; x < 20; x++) {
+ for (int y = 0; y < 20; y++) {
+ db.insert(ns(), BSON("_id" << n << "loc" << BSON_ARRAY(x << y) << "z" << n % 5));
+ n++;
}
+ }
+
+ // Build geoHaystack index. Can's use db.ensureIndex, no way to pass "bucketSize".
+ // So run createIndexes command instead.
+ //
+ // Shell example:
+ // t.ensureIndex( { loc : "geoHaystack" , z : 1 }, { bucketSize : .7 } );
+ {
BSONObjBuilder cmd;
- cmd.appendSymbol("findAndModify", nsColl()); // Use Symbol for SERVER-16260
- cmd.append("update", BSON("$inc" << BSON("score" << 1)) );
- cmd.append("new", true);
+ cmd.append("createIndexes", nsColl());
+ cmd.append("indexes",
+ BSON_ARRAY(BSON("key" << BSON("loc"
+ << "geoHaystack"
+ << "z" << 1.0) << "name"
+ << "loc_geoHaystack_z_1"
+ << "bucketSize" << static_cast<double>(0.7))));
+
+ BSONObj result;
+ ASSERT(db.runCommand(nsDb(), cmd.obj(), result));
+ }
+
+ {
+ BSONObjBuilder cmd;
+ cmd.appendSymbol("geoSearch", nsColl()); // Use Symbol for SERVER-16260
+ cmd.append("near", BSON_ARRAY(7 << 8));
+ cmd.append("maxDistance", 3);
+ cmd.append("search", BSON("z" << 3));
BSONObj result;
bool ok = db.runCommand(nsDb(), cmd.obj(), result);
log() << result.jsonString();
ASSERT(ok);
- // TODO(kangas) test that Tom's score is 1
}
- };
-
- class GeoSearch : Base {
- public:
- void run() {
- // Subset of geo_haystack1.js
-
- int n = 0;
- for (int x = 0; x < 20; x++) {
- for (int y = 0; y < 20; y++) {
- db.insert(ns(), BSON("_id" << n <<
- "loc" << BSON_ARRAY(x << y) <<
- "z" << n % 5));
- n++;
- }
- }
+ }
+};
- // Build geoHaystack index. Can's use db.ensureIndex, no way to pass "bucketSize".
- // So run createIndexes command instead.
- //
- // Shell example:
- // t.ensureIndex( { loc : "geoHaystack" , z : 1 }, { bucketSize : .7 } );
-
- {
- BSONObjBuilder cmd;
- cmd.append("createIndexes", nsColl());
- cmd.append("indexes", BSON_ARRAY(
- BSON("key" << BSON("loc" << "geoHaystack" << "z" << 1.0) <<
- "name" << "loc_geoHaystack_z_1" <<
- "bucketSize" << static_cast<double>(0.7))
- ));
-
- BSONObj result;
- ASSERT( db.runCommand(nsDb(), cmd.obj(), result) );
- }
+class Touch : Base {
+public:
+ void run() {
+ ASSERT(db.createCollection(ns()));
+ {
+ BSONObjBuilder cmd;
+ cmd.appendSymbol("touch", nsColl()); // Use Symbol for SERVER-16260
+ cmd.append("data", true);
+ cmd.append("index", true);
- {
- BSONObjBuilder cmd;
- cmd.appendSymbol("geoSearch", nsColl()); // Use Symbol for SERVER-16260
- cmd.append("near", BSON_ARRAY(7 << 8));
- cmd.append("maxDistance", 3);
- cmd.append("search", BSON("z" << 3));
-
- BSONObj result;
- bool ok = db.runCommand(nsDb(), cmd.obj(), result);
- log() << result.jsonString();
- ASSERT(ok);
- }
- }
- };
-
- class Touch : Base {
- public:
- void run() {
- ASSERT( db.createCollection(ns()) );
- {
- BSONObjBuilder cmd;
- cmd.appendSymbol("touch", nsColl()); // Use Symbol for SERVER-16260
- cmd.append("data", true);
- cmd.append("index", true);
-
- BSONObj result;
- bool ok = db.runCommand(nsDb(), cmd.obj(), result);
- log() << result.jsonString();
- ASSERT(ok || result["code"].Int() == ErrorCodes::CommandNotSupported);
- }
+ BSONObj result;
+ bool ok = db.runCommand(nsDb(), cmd.obj(), result);
+ log() << result.jsonString();
+ ASSERT(ok || result["code"].Int() == ErrorCodes::CommandNotSupported);
}
- };
+ }
+};
} // SymbolArgument
- class All : public Suite {
- public:
- All() : Suite( "commands" ) {
- }
-
- void setupTests() {
- add< FileMD5::Type0 >();
- add< FileMD5::Type2 >();
- add< FileMD5::Type2 >();
- add< SymbolArgument::DropIndexes >();
- add< SymbolArgument::FindAndModify >();
- add< SymbolArgument::Touch >();
- add< SymbolArgument::Drop >();
- add< SymbolArgument::GeoSearch >();
- }
-
- };
+class All : public Suite {
+public:
+ All() : Suite("commands") {}
+
+ void setupTests() {
+ add<FileMD5::Type0>();
+ add<FileMD5::Type2>();
+ add<FileMD5::Type2>();
+ add<SymbolArgument::DropIndexes>();
+ add<SymbolArgument::FindAndModify>();
+ add<SymbolArgument::Touch>();
+ add<SymbolArgument::Drop>();
+ add<SymbolArgument::GeoSearch>();
+ }
+};
- SuiteInstance<All> all;
+SuiteInstance<All> all;
}
View Lorry Controller Status