提交 b9e8ff13 编写于 作者: M Maksim Kita

Fixed build

上级 2f1f9692
...@@ -201,11 +201,13 @@ void registerDictionarySourceClickHouse(DictionarySourceFactory & factory) ...@@ -201,11 +201,13 @@ void registerDictionarySourceClickHouse(DictionarySourceFactory & factory)
UInt16 default_port = getPortFromContext(context_copy, secure); UInt16 default_port = getPortFromContext(context_copy, secure);
std::string settings_config_prefix = config_prefix + ".clickhouse"; std::string settings_config_prefix = config_prefix + ".clickhouse";
std::string host = config.getString(settings_config_prefix + ".host", "localhost");
UInt16 port = static_cast<UInt16>(config.getUInt(settings_config_prefix + ".port", default_port));
ClickHouseDictionarySource::Configuration configuration { ClickHouseDictionarySource::Configuration configuration {
.secure = config.getBool(settings_config_prefix + ".secure", false), .secure = config.getBool(settings_config_prefix + ".secure", false),
.host = config.getString(settings_config_prefix + ".host", "localhost"), .host = host,
.port = static_cast<UInt16>(config.getUInt(settings_config_prefix + ".port", default_port)), .port = port,
.user = config.getString(settings_config_prefix + ".user", "default"), .user = config.getString(settings_config_prefix + ".user", "default"),
.password = config.getString(settings_config_prefix + ".password", ""), .password = config.getString(settings_config_prefix + ".password", ""),
.db = config.getString(settings_config_prefix + ".db", default_database), .db = config.getString(settings_config_prefix + ".db", default_database),
...@@ -213,7 +215,7 @@ void registerDictionarySourceClickHouse(DictionarySourceFactory & factory) ...@@ -213,7 +215,7 @@ void registerDictionarySourceClickHouse(DictionarySourceFactory & factory)
.where = config.getString(settings_config_prefix + ".where", ""), .where = config.getString(settings_config_prefix + ".where", ""),
.update_field = config.getString(settings_config_prefix + ".update_field", ""), .update_field = config.getString(settings_config_prefix + ".update_field", ""),
.invalidate_query = config.getString(settings_config_prefix + ".invalidate_query", ""), .invalidate_query = config.getString(settings_config_prefix + ".invalidate_query", ""),
.is_local = isLocalAddress({configuration.host, configuration.port}, default_port) .is_local = isLocalAddress({host, port}, default_port)
}; };
/// We should set user info even for the case when the dictionary is loaded in-process (without TCP communication). /// We should set user info even for the case when the dictionary is loaded in-process (without TCP communication).
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册