summaryrefslogtreecommitdiff
path: root/src/mongo/shell/shell_options.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/shell/shell_options.cpp')
-rw-r--r--src/mongo/shell/shell_options.cpp482
1 files changed, 242 insertions, 240 deletions
diff --git a/src/mongo/shell/shell_options.cpp b/src/mongo/shell/shell_options.cpp
index c016e16e241..a54f2bbc567 100644
--- a/src/mongo/shell/shell_options.cpp
+++ b/src/mongo/shell/shell_options.cpp
@@ -47,297 +47,299 @@
namespace mongo {
- using std::cout;
- using std::endl;
- using std::string;
- using std::vector;
+using std::cout;
+using std::endl;
+using std::string;
+using std::vector;
- ShellGlobalParams shellGlobalParams;
+ShellGlobalParams shellGlobalParams;
- Status addMongoShellOptions(moe::OptionSection* options) {
+Status addMongoShellOptions(moe::OptionSection* options) {
+ options->addOptionChaining(
+ "shell", "shell", moe::Switch, "run the shell after executing files");
- options->addOptionChaining("shell", "shell", moe::Switch,
- "run the shell after executing files");
+ options->addOptionChaining("nodb",
+ "nodb",
+ moe::Switch,
+ "don't connect to mongod on startup - no 'db address' arg expected");
- options->addOptionChaining("nodb", "nodb", moe::Switch,
- "don't connect to mongod on startup - no 'db address' arg expected");
+ options->addOptionChaining(
+ "norc", "norc", moe::Switch, "will not run the \".mongorc.js\" file on start up");
- options->addOptionChaining("norc", "norc", moe::Switch,
- "will not run the \".mongorc.js\" file on start up");
+ options->addOptionChaining("quiet", "quiet", moe::Switch, "be less chatty");
- options->addOptionChaining("quiet", "quiet", moe::Switch, "be less chatty");
+ options->addOptionChaining("port", "port", moe::String, "port to connect to");
- options->addOptionChaining("port", "port", moe::String, "port to connect to");
+ options->addOptionChaining("host", "host", moe::String, "server to connect to");
- options->addOptionChaining("host", "host", moe::String, "server to connect to");
+ options->addOptionChaining("eval", "eval", moe::String, "evaluate javascript");
- options->addOptionChaining("eval", "eval", moe::String, "evaluate javascript");
+ moe::OptionSection authenticationOptions("Authentication Options");
- moe::OptionSection authenticationOptions("Authentication Options");
+ authenticationOptions.addOptionChaining(
+ "username", "username,u", moe::String, "username for authentication");
- authenticationOptions.addOptionChaining("username", "username,u", moe::String,
- "username for authentication");
+ authenticationOptions.addOptionChaining(
+ "password", "password,p", moe::String, "password for authentication")
+ .setImplicit(moe::Value(std::string("")));
- authenticationOptions.addOptionChaining("password", "password,p", moe::String,
- "password for authentication")
- .setImplicit(moe::Value(std::string("")));
+ authenticationOptions.addOptionChaining("authenticationDatabase",
+ "authenticationDatabase",
+ moe::String,
+ "user source (defaults to dbname)")
+ .setDefault(moe::Value(std::string("")));
- authenticationOptions.addOptionChaining("authenticationDatabase", "authenticationDatabase",
- moe::String, "user source (defaults to dbname)")
- .setDefault(moe::Value(std::string("")));
+ authenticationOptions.addOptionChaining("authenticationMechanism",
+ "authenticationMechanism",
+ moe::String,
+ "authentication mechanism");
- authenticationOptions.addOptionChaining("authenticationMechanism",
- "authenticationMechanism", moe::String, "authentication mechanism");
+ authenticationOptions.addOptionChaining(
+ "gssapiServiceName",
+ "gssapiServiceName",
+ moe::String,
+ "Service name to use when authenticating using GSSAPI/Kerberos")
+ .setDefault(moe::Value(std::string(saslDefaultServiceName)));
- authenticationOptions.addOptionChaining("gssapiServiceName", "gssapiServiceName",
- moe::String,
- "Service name to use when authenticating using GSSAPI/Kerberos")
- .setDefault(moe::Value(std::string(saslDefaultServiceName)));
+ authenticationOptions.addOptionChaining(
+ "gssapiHostName",
+ "gssapiHostName",
+ moe::String,
+ "Remote host name to use for purpose of GSSAPI/Kerberos authentication");
- authenticationOptions.addOptionChaining("gssapiHostName", "gssapiHostName", moe::String,
- "Remote host name to use for purpose of GSSAPI/Kerberos authentication");
+ options->addSection(authenticationOptions);
- options->addSection(authenticationOptions);
+ options->addOptionChaining("help", "help,h", moe::Switch, "show this usage information");
- options->addOptionChaining("help", "help,h", moe::Switch, "show this usage information");
+ options->addOptionChaining("version", "version", moe::Switch, "show version information");
- options->addOptionChaining("version", "version", moe::Switch, "show version information");
+ options->addOptionChaining("verbose", "verbose", moe::Switch, "increase verbosity");
- options->addOptionChaining("verbose", "verbose", moe::Switch, "increase verbosity");
+ options->addOptionChaining(
+ "ipv6", "ipv6", moe::Switch, "enable IPv6 support (disabled by default)");
- options->addOptionChaining("ipv6", "ipv6", moe::Switch,
- "enable IPv6 support (disabled by default)");
-
- Status ret = Status::OK();
+ Status ret = Status::OK();
#ifdef MONGO_CONFIG_SSL
- ret = addSSLClientOptions(options);
- if (!ret.isOK()) {
- return ret;
- }
+ ret = addSSLClientOptions(options);
+ if (!ret.isOK()) {
+ return ret;
+ }
#endif
- options->addOptionChaining("dbaddress", "dbaddress", moe::String, "dbaddress")
- .hidden()
- .positional(1, 1);
-
- options->addOptionChaining("files", "files", moe::StringVector, "files")
- .hidden()
- .positional(2, -1);
-
- // for testing, kill op will also be disabled automatically if the tests starts a mongo
- // program
- options->addOptionChaining("nokillop", "nokillop", moe::Switch, "nokillop")
- .hidden();
-
- // for testing, will kill op without prompting
- options->addOptionChaining("autokillop", "autokillop", moe::Switch, "autokillop")
- .hidden();
-
- options->addOptionChaining("useLegacyWriteOps",
- "useLegacyWriteOps",
- moe::Switch,
- "use legacy write ops instead of write commands").hidden();
-
- options->addOptionChaining("writeMode",
- "writeMode",
- moe::String,
- "mode to determine how writes are done:"
- " commands, compatibility, legacy").hidden();
-
- options->addOptionChaining("readMode",
- "readMode",
- moe::String,
- "mode to determine how .find() queries are done:"
- " commands, compatibility").hidden();
-
- options->addOptionChaining("rpcProtocols",
- "rpcProtocols",
- moe::String,
- " none, opQueryOnly, opCommandOnly, all").hidden();
-
- return Status::OK();
- }
+ options->addOptionChaining("dbaddress", "dbaddress", moe::String, "dbaddress")
+ .hidden()
+ .positional(1, 1);
- std::string getMongoShellHelp(StringData name, const moe::OptionSection& options) {
- StringBuilder sb;
- sb << "MongoDB shell version: " << mongo::versionString << "\n";
- sb << "usage: " << name << " [options] [db address] [file names (ending in .js)]\n"
- << "db address can be:\n"
- << " foo foo database on local machine\n"
- << " 192.169.0.5/foo foo database on 192.168.0.5 machine\n"
- << " 192.169.0.5:9999/foo foo database on 192.168.0.5 machine on port 9999\n"
- << options.helpString() << "\n"
- << "file names: a list of files to run. files have to end in .js and will exit after "
- << "unless --shell is specified";
- return sb.str();
- }
+ options->addOptionChaining("files", "files", moe::StringVector, "files")
+ .hidden()
+ .positional(2, -1);
- bool handlePreValidationMongoShellOptions(const moe::Environment& params,
- const std::vector<std::string>& args) {
- if (params.count("help")) {
- std::cout << getMongoShellHelp(args[0], moe::startupOptions) << std::endl;
- return false;
- }
- if (params.count("version")) {
- cout << "MongoDB shell version: " << mongo::versionString << endl;
- return false;
- }
- return true;
- }
+ // for testing, kill op will also be disabled automatically if the tests starts a mongo
+ // program
+ options->addOptionChaining("nokillop", "nokillop", moe::Switch, "nokillop").hidden();
- Status storeMongoShellOptions(const moe::Environment& params,
- const std::vector<std::string>& args) {
+ // for testing, will kill op without prompting
+ options->addOptionChaining("autokillop", "autokillop", moe::Switch, "autokillop").hidden();
- if (params.count("quiet")) {
- mongo::serverGlobalParams.quiet = true;
- }
+ options->addOptionChaining("useLegacyWriteOps",
+ "useLegacyWriteOps",
+ moe::Switch,
+ "use legacy write ops instead of write commands").hidden();
+
+ options->addOptionChaining("writeMode",
+ "writeMode",
+ moe::String,
+ "mode to determine how writes are done:"
+ " commands, compatibility, legacy").hidden();
+
+ options->addOptionChaining("readMode",
+ "readMode",
+ moe::String,
+ "mode to determine how .find() queries are done:"
+ " commands, compatibility").hidden();
+
+ options->addOptionChaining("rpcProtocols",
+ "rpcProtocols",
+ moe::String,
+ " none, opQueryOnly, opCommandOnly, all").hidden();
+
+ return Status::OK();
+}
+
+std::string getMongoShellHelp(StringData name, const moe::OptionSection& options) {
+ StringBuilder sb;
+ sb << "MongoDB shell version: " << mongo::versionString << "\n";
+ sb << "usage: " << name << " [options] [db address] [file names (ending in .js)]\n"
+ << "db address can be:\n"
+ << " foo foo database on local machine\n"
+ << " 192.169.0.5/foo foo database on 192.168.0.5 machine\n"
+ << " 192.169.0.5:9999/foo foo database on 192.168.0.5 machine on port 9999\n"
+ << options.helpString() << "\n"
+ << "file names: a list of files to run. files have to end in .js and will exit after "
+ << "unless --shell is specified";
+ return sb.str();
+}
+
+bool handlePreValidationMongoShellOptions(const moe::Environment& params,
+ const std::vector<std::string>& args) {
+ if (params.count("help")) {
+ std::cout << getMongoShellHelp(args[0], moe::startupOptions) << std::endl;
+ return false;
+ }
+ if (params.count("version")) {
+ cout << "MongoDB shell version: " << mongo::versionString << endl;
+ return false;
+ }
+ return true;
+}
+
+Status storeMongoShellOptions(const moe::Environment& params,
+ const std::vector<std::string>& args) {
+ if (params.count("quiet")) {
+ mongo::serverGlobalParams.quiet = true;
+ }
#ifdef MONGO_CONFIG_SSL
- Status ret = storeSSLClientOptions(params);
- if (!ret.isOK()) {
- return ret;
- }
+ Status ret = storeSSLClientOptions(params);
+ if (!ret.isOK()) {
+ return ret;
+ }
#endif
- if (params.count("ipv6")) {
- mongo::enableIPv6();
- }
- if (params.count("verbose")) {
- logger::globalLogDomain()->setMinimumLoggedSeverity(logger::LogSeverity::Debug(1));
- }
+ if (params.count("ipv6")) {
+ mongo::enableIPv6();
+ }
+ if (params.count("verbose")) {
+ logger::globalLogDomain()->setMinimumLoggedSeverity(logger::LogSeverity::Debug(1));
+ }
- if (params.count("port")) {
- shellGlobalParams.port = params["port"].as<string>();
- }
+ if (params.count("port")) {
+ shellGlobalParams.port = params["port"].as<string>();
+ }
- if (params.count("host")) {
- shellGlobalParams.dbhost = params["host"].as<string>();
- }
+ if (params.count("host")) {
+ shellGlobalParams.dbhost = params["host"].as<string>();
+ }
- if (params.count("eval")) {
- shellGlobalParams.script = params["eval"].as<string>();
- }
+ if (params.count("eval")) {
+ shellGlobalParams.script = params["eval"].as<string>();
+ }
- if (params.count("username")) {
- shellGlobalParams.username = params["username"].as<string>();
- }
+ if (params.count("username")) {
+ shellGlobalParams.username = params["username"].as<string>();
+ }
- if (params.count("password")) {
- shellGlobalParams.usingPassword = true;
- shellGlobalParams.password = params["password"].as<string>();
- }
+ if (params.count("password")) {
+ shellGlobalParams.usingPassword = true;
+ shellGlobalParams.password = params["password"].as<string>();
+ }
- if (params.count("authenticationDatabase")) {
- shellGlobalParams.authenticationDatabase =
- params["authenticationDatabase"].as<string>();
- }
+ if (params.count("authenticationDatabase")) {
+ shellGlobalParams.authenticationDatabase = params["authenticationDatabase"].as<string>();
+ }
- if (params.count("authenticationMechanism")) {
- shellGlobalParams.authenticationMechanism =
- params["authenticationMechanism"].as<string>();
- }
+ if (params.count("authenticationMechanism")) {
+ shellGlobalParams.authenticationMechanism = params["authenticationMechanism"].as<string>();
+ }
- if (params.count("gssapiServiceName")) {
- shellGlobalParams.gssapiServiceName = params["gssapiServiceName"].as<string>();
- }
+ if (params.count("gssapiServiceName")) {
+ shellGlobalParams.gssapiServiceName = params["gssapiServiceName"].as<string>();
+ }
- if (params.count("gssapiHostName")) {
- shellGlobalParams.gssapiHostName = params["gssapiHostName"].as<string>();
- }
+ if (params.count("gssapiHostName")) {
+ shellGlobalParams.gssapiHostName = params["gssapiHostName"].as<string>();
+ }
- if (params.count("shell")) {
- shellGlobalParams.runShell = true;
- }
- if (params.count("nodb")) {
- shellGlobalParams.nodb = true;
- }
- if (params.count("norc")) {
- shellGlobalParams.norc = true;
- }
- if (params.count("files")) {
- shellGlobalParams.files = params["files"].as< vector<string> >();
- }
- if (params.count("nokillop")) {
- mongo::shell_utils::_nokillop = true;
- }
- if (params.count("autokillop")) {
- shellGlobalParams.autoKillOp = true;
- }
- if (params.count("useLegacyWriteOps")) {
- shellGlobalParams.writeMode = "legacy";
- }
- if (params.count("writeMode")) {
- std::string mode = params["writeMode"].as<string>();
- if (mode != "commands" && mode != "legacy" && mode != "compatibility") {
- throw MsgAssertionException(17396,
- mongoutils::str::stream() <<
- "Unknown writeMode option: " << mode);
- }
- shellGlobalParams.writeMode = mode;
+ if (params.count("shell")) {
+ shellGlobalParams.runShell = true;
+ }
+ if (params.count("nodb")) {
+ shellGlobalParams.nodb = true;
+ }
+ if (params.count("norc")) {
+ shellGlobalParams.norc = true;
+ }
+ if (params.count("files")) {
+ shellGlobalParams.files = params["files"].as<vector<string>>();
+ }
+ if (params.count("nokillop")) {
+ mongo::shell_utils::_nokillop = true;
+ }
+ if (params.count("autokillop")) {
+ shellGlobalParams.autoKillOp = true;
+ }
+ if (params.count("useLegacyWriteOps")) {
+ shellGlobalParams.writeMode = "legacy";
+ }
+ if (params.count("writeMode")) {
+ std::string mode = params["writeMode"].as<string>();
+ if (mode != "commands" && mode != "legacy" && mode != "compatibility") {
+ throw MsgAssertionException(
+ 17396, mongoutils::str::stream() << "Unknown writeMode option: " << mode);
}
- if (params.count("readMode")) {
- std::string mode = params["readMode"].as<string>();
- if (mode != "commands" && mode != "compatibility") {
- throw MsgAssertionException(17397,
- mongoutils::str::stream()
+ shellGlobalParams.writeMode = mode;
+ }
+ if (params.count("readMode")) {
+ std::string mode = params["readMode"].as<string>();
+ if (mode != "commands" && mode != "compatibility") {
+ throw MsgAssertionException(17397,
+ mongoutils::str::stream()
<< "Unknown readMode option: '" << mode
<< "'. Valid modes are: {commands, compatibility}");
- }
- shellGlobalParams.readMode = mode;
}
- if (params.count("rpcProtocols")) {
- std::string protos = params["rpcProtocols"].as<string>();
- auto parsedRPCProtos = rpc::parseProtocolSet(protos);
- if (!parsedRPCProtos.isOK()) {
- throw MsgAssertionException(28653,
- str::stream()
- << "Unknown RPC Protocols: '" << protos
- << "'. Valid values are {none, opQueryOnly, "
- << "opCommandOnly, all}");
- }
- shellGlobalParams.rpcProtocols = parsedRPCProtos.getValue();
+ shellGlobalParams.readMode = mode;
+ }
+ if (params.count("rpcProtocols")) {
+ std::string protos = params["rpcProtocols"].as<string>();
+ auto parsedRPCProtos = rpc::parseProtocolSet(protos);
+ if (!parsedRPCProtos.isOK()) {
+ throw MsgAssertionException(28653,
+ str::stream() << "Unknown RPC Protocols: '" << protos
+ << "'. Valid values are {none, opQueryOnly, "
+ << "opCommandOnly, all}");
}
+ shellGlobalParams.rpcProtocols = parsedRPCProtos.getValue();
+ }
- /* This is a bit confusing, here are the rules:
- *
- * if nodb is set then all positional parameters are files
- * otherwise the first positional parameter might be a dbaddress, but
- * only if one of these conditions is met:
- * - it contains no '.' after the last appearance of '\' or '/'
- * - it doesn't end in '.js' and it doesn't specify a path to an existing file */
- if (params.count("dbaddress")) {
- string dbaddress = params["dbaddress"].as<string>();
- if (shellGlobalParams.nodb) {
- shellGlobalParams.files.insert( shellGlobalParams.files.begin(), dbaddress );
- }
- else {
- string basename = dbaddress.substr( dbaddress.find_last_of( "/\\" ) + 1 );
- if (basename.find_first_of( '.' ) == string::npos ||
- (basename.find(".js", basename.size() - 3) == string::npos &&
- !::mongo::shell_utils::fileExists(dbaddress))) {
- shellGlobalParams.url = dbaddress;
- }
- else {
- shellGlobalParams.files.insert( shellGlobalParams.files.begin(), dbaddress );
- }
+ /* This is a bit confusing, here are the rules:
+ *
+ * if nodb is set then all positional parameters are files
+ * otherwise the first positional parameter might be a dbaddress, but
+ * only if one of these conditions is met:
+ * - it contains no '.' after the last appearance of '\' or '/'
+ * - it doesn't end in '.js' and it doesn't specify a path to an existing file */
+ if (params.count("dbaddress")) {
+ string dbaddress = params["dbaddress"].as<string>();
+ if (shellGlobalParams.nodb) {
+ shellGlobalParams.files.insert(shellGlobalParams.files.begin(), dbaddress);
+ } else {
+ string basename = dbaddress.substr(dbaddress.find_last_of("/\\") + 1);
+ if (basename.find_first_of('.') == string::npos ||
+ (basename.find(".js", basename.size() - 3) == string::npos &&
+ !::mongo::shell_utils::fileExists(dbaddress))) {
+ shellGlobalParams.url = dbaddress;
+ } else {
+ shellGlobalParams.files.insert(shellGlobalParams.files.begin(), dbaddress);
}
}
+ }
- if ( shellGlobalParams.url == "*" ) {
- StringBuilder sb;
- sb << "ERROR: " << "\"*\" is an invalid db address";
- sb << getMongoShellHelp(args[0], moe::startupOptions);
- return Status(ErrorCodes::BadValue, sb.str());
- }
-
- return Status::OK();
+ if (shellGlobalParams.url == "*") {
+ StringBuilder sb;
+ sb << "ERROR: "
+ << "\"*\" is an invalid db address";
+ sb << getMongoShellHelp(args[0], moe::startupOptions);
+ return Status(ErrorCodes::BadValue, sb.str());
}
- Status validateMongoShellOptions(const moe::Environment& params) {
+ return Status::OK();
+}
+
+Status validateMongoShellOptions(const moe::Environment& params) {
#ifdef MONGO_CONFIG_SSL
- Status ret = validateSSLMongoShellOptions(params);
- if (!ret.isOK()) {
- return ret;
- }
-#endif
- return Status::OK();
+ Status ret = validateSSLMongoShellOptions(params);
+ if (!ret.isOK()) {
+ return ret;
}
+#endif
+ return Status::OK();
+}
}
View Lorry Controller Status