thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-21 09:10:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Initial implementation of is_secure

Browse Source
This commit is contained in:
Antonio Andelic 2022-03-28 06:31:10 +00:00
parent 03a09dc914
commit 893b8a9513
3 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Interpreters/ClientInfo.cpp
View File

@ -70,6 +70,8 @@ void ClientInfo::write(WriteBuffer & out, UInt64 server_protocol_revision) const
writeVarUInt(client_version_patch, out);
}
writeBinary(static_cast<UInt8>(is_secure), out);
if (server_protocol_revision >= DBMS_MIN_REVISION_WITH_OPENTELEMETRY)
{
if (client_trace_context.trace_id != UUID())
@ -165,6 +167,12 @@ void ClientInfo::read(ReadBuffer & in, UInt64 client_protocol_revision)
client_version_patch = client_tcp_protocol_version;
}
{
UInt8 value;
readBinary(value, in);
is_secure = value;
}
if (client_protocol_revision >= DBMS_MIN_REVISION_WITH_OPENTELEMETRY)
{
uint8_t have_trace_id = 0;

1
src/Interpreters/ClientInfo.h
View File

@ -69,6 +69,7 @@ public:
/// All below are parameters related to initial query.
Interface interface = Interface::TCP;
bool is_secure = false;
/// For tcp
String os_user;

5
src/Interpreters/QueryLog.cpp
View File

@ -116,7 +116,8 @@ NamesAndTypesList QueryLogElement::getNamesAndTypes()
{"used_formats", std::make_shared<DataTypeArray>(std::make_shared<DataTypeString>())},
{"used_functions", std::make_shared<DataTypeArray>(std::make_shared<DataTypeString>())},
{"used_storages", std::make_shared<DataTypeArray>(std::make_shared<DataTypeString>())},
{"used_table_functions", std::make_shared<DataTypeArray>(std::make_shared<DataTypeString>())}
{"used_table_functions", std::make_shared<DataTypeArray>(std::make_shared<DataTypeString>())},
{"is_secure", std::make_shared<DataTypeUInt8>()}
};
}
@ -291,5 +292,7 @@ void QueryLogElement::appendClientInfo(const ClientInfo & client_info, MutableCo
columns[i++]->insert(client_info.quota_key);
columns[i++]->insert(client_info.distributed_depth);
columns[i++]->insert(static_cast<UInt64>(client_info.is_secure));
}
}