Change client name

To avoid confusion with the `clickhouse client` CLI client

Author: slabko

clickhouse/client.cpp

@@ -17,7 +17,7 @@
 #include "base/sslsocket.h"
 #endif
 
-#define DBMS_NAME                                       "ClickHouse"
+#define CLIENT_NAME "clickhouse-cpp"
 
 #define DBMS_MIN_REVISION_WITH_TEMPORARY_TABLES         50264
 #define DBMS_MIN_REVISION_WITH_TOTAL_ROWS_IN_PROGRESS   51554
@@ -813,7 +813,7 @@ void Client::Impl::SendQuery(const Query& query, bool finalize) {
         ClientInfo info;
 
         info.query_kind = 1;
-        info.client_name = "ClickHouse client";
+        info.client_name          = CLIENT_NAME;
         info.client_version_major = CLICKHOUSE_CPP_VERSION_MAJOR;
         info.client_version_minor = CLICKHOUSE_CPP_VERSION_MINOR;
         info.client_version_patch = CLICKHOUSE_CPP_VERSION_PATCH;
@@ -978,7 +978,7 @@ void Client::Impl::InitializeStreams(std::unique_ptr<SocketBase>&& socket) {
 
 bool Client::Impl::SendHello() {
     WireFormat::WriteUInt64(*output_, ClientCodes::Hello);
-    WireFormat::WriteString(*output_, std::string(DBMS_NAME) + " client");
+    WireFormat::WriteString(*output_, std::string(CLIENT_NAME));
     WireFormat::WriteUInt64(*output_, CLICKHOUSE_CPP_VERSION_MAJOR);
     WireFormat::WriteUInt64(*output_, CLICKHOUSE_CPP_VERSION_MINOR);
     WireFormat::WriteUInt64(*output_, DMBS_PROTOCOL_REVISION);

ut/client_ut.cpp

@@ -1553,3 +1553,30 @@ TEST_P(ClientCase, QueryParameters) {
 
     client_->Execute("DROP TEMPORARY TABLE " + table_name);
 }
+
+TEST_P(ClientCase, ClientName) {
+    const auto server_info = client_->GetServerInfo();
+
+    std::srand(std::time(nullptr) + reinterpret_cast<int64_t>(&server_info));
+    const auto * test_info = ::testing::UnitTest::GetInstance()->current_test_info();
+    const std::string query_id = std::to_string(std::rand()) + "-" + test_info->test_suite_name() + "/" + test_info->name();
+
+    SCOPED_TRACE(query_id);
+
+    client_->Select("SELECT 1", query_id, [](const Block&) { /* make sure the data is delivered in full */ });
+
+    FlushLogs();
+
+    std::string query_log_query 
+        = "SELECT CAST(client_name, 'String') FROM system.query_log WHERE query_id = '" + query_id + "'";
+
+    size_t total_rows = 0;
+    client_->Select(query_log_query, [&total_rows](const Block& block) {
+        const auto row_count = block.GetRowCount();
+        total_rows += row_count;
+        for (size_t i = 0; i < row_count; ++i) {
+            ASSERT_EQ(block[0]->AsStrict<ColumnString>()->At(i), "clickhouse-cpp");
+        }
+    });
+    ASSERT_GT(total_rows, 0UL) << "Query with query_id " << query_id << " is not found";
+}