grpc/clickhouse: construct query from options

Signed-off-by: Attila Szakacs <attila.szakacs@axoflow.com>
axoflow · Oct 22, 2024 · 4e99781 · 4e99781
1 parent 93bbb5e
commit 4e99781
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/modules/grpc/clickhouse/clickhouse-dest.cpp b/modules/grpc/clickhouse/clickhouse-dest.cpp
@@ -52,6 +52,8 @@ DestDriver::init()
       return false;
     }
 
+  this->query = "INSERT INTO " + this->database + "." + this->table + " FORMAT Protobuf";
+
   if (!this->schema.init())
     return false;
 

diff --git a/modules/grpc/clickhouse/clickhouse-dest.hpp b/modules/grpc/clickhouse/clickhouse-dest.hpp
@@ -82,6 +82,11 @@ class DestDriver final : public syslogng::grpc::DestDriver
     return this->password;
   }
 
+  const std::string &get_query()
+  {
+    return this->query;
+  }
+
   Schema *get_schema()
   {
     return &this->schema;
@@ -98,6 +103,7 @@ class DestDriver final : public syslogng::grpc::DestDriver
   std::string table;
   std::string user;
   std::string password;
+  std::string query;
 
   Schema schema;
 };