class Multiwoven::Integrations::Source::Clickhouse::Client

def query_execution(connection, query)
  response = connection.post do |req|
    req.url "/"
    req.headers["Authorization"] = "Basic #{@auth_token}"
    req.headers["Content-Type"] = "text/plain"
    req.body = query
  end
  column_names = query[/SELECT (.*?) FROM/i, 1].split(",").map(&:strip)
  response.body.strip.split("\n").map do |row|
    columns = row.split("\t")
    column_names.zip(columns).to_h
  end
end