thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-22 15:42:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Move host and port to options

Browse Source
This commit is contained in:
pufit 2023-04-02 16:51:10 -04:00
parent 3380e467d9
commit 892e436046
1 changed files with 15 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
programs/keeper-client/KeeperClient.cpp
View File

@ -85,9 +85,19 @@ void KeeperClient::defineOptions(Poco::Util::OptionSet & options)
Poco::Util::Application::defineOptions(options); Poco::Util::Application::defineOptions(options);
options.addOption( options.addOption(
Poco::Util::Option("help", "h", "show help and exit") Poco::Util::Option("help", "", "show help and exit")
.binding("help")); .binding("help"));
options.addOption(
Poco::Util::Option("host", "h", "server hostname. default `localhost`")
.argument("host")
.binding("host"));
options.addOption(
Poco::Util::Option("port", "p", "server port. default `2181`")
.argument("port")
.binding("port"));
options.addOption( options.addOption(
Poco::Util::Option("query", "q", "will execute given query, then exit.") Poco::Util::Option("query", "q", "will execute given query, then exit.")
.argument("query") .argument("query")
@ -284,13 +294,12 @@ void KeeperClient::runInteractive()
} }
} }
int KeeperClient::main(const std::vector<String> & args) int KeeperClient::main(const std::vector<String> & /* args */)
{ {
if (args.empty())
zk_args.hosts = {"localhost:2181"};
else
zk_args.hosts = {args[0]};
auto host = config().getString("host", "localhost");
auto port = config().getString("port", "2181");
zk_args.hosts = {host + ":" + port};
zk_args.connection_timeout_ms = config().getInt("connection-timeout", 10) * 1000; zk_args.connection_timeout_ms = config().getInt("connection-timeout", 10) * 1000;
zk_args.session_timeout_ms = config().getInt("session-timeout", 10) * 1000; zk_args.session_timeout_ms = config().getInt("session-timeout", 10) * 1000;
zk_args.operation_timeout_ms = config().getInt("operation-timeout", 10) * 1000; zk_args.operation_timeout_ms = config().getInt("operation-timeout", 10) * 1000;