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

CLICKHOUSE-3700: Fix empty password on replica query

Browse Source
This commit is contained in:
proller 2018-04-10 17:49:52 +03:00
parent d3cf85057b
commit 157067b127
3 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
dbms/src/Interpreters/ClientInfo.h
View File

@ -47,6 +47,7 @@ public:
String current_user;
String current_query_id;
Poco::Net::SocketAddress current_address;
String current_password;
/// When query_kind == INITIAL_QUERY, these values are equal to current.
String initial_user;

1
dbms/src/Interpreters/Context.cpp
View File

@ -564,6 +564,7 @@ void Context::setUser(const String & name, const String & password, const Poco::
client_info.current_user = name;
client_info.current_address = address;
client_info.current_password = password;
if (!quota_key.empty())
client_info.quota_key = quota_key;

2
dbms/src/Storages/StorageReplicatedMergeTree.cpp
View File

@ -3277,7 +3277,7 @@ void StorageReplicatedMergeTree::sendRequestToLeaderReplica(const ASTPtr & query
leader_address.host,
leader_address.queries_port,
leader_address.database,
"", "", timeouts, "ClickHouse replica");
context.getClientInfo().current_user, context.getClientInfo().current_password, timeouts, "ClickHouse replica");
RemoteBlockInputStream stream(connection, formattedAST(new_query), {}, context, &settings);
NullBlockOutputStream output({});