Contents

module Clickhouse
  class Connection
    module Client

      def connect!
        ping! unless connected?
      end

      def ping!
        ensure_authentication
        status = client.get("/").status
        if status != 200
          raise ConnectionError, "Unexpected response status: #{status}"
        end
        true
      rescue Faraday::Error => e
        raise ConnectionError, e.message
      end

      def connected?
        instance_variables.include?(:@client) && !!@client
      end

      def get(query)
        request(:get, query)
      end

      def post(query, body = nil)
        request(:post, query, body)
      end

      def url
        "#{@config[:scheme]}://#{@config[:host]}:#{@config[:port]}"
      end

    private

      def path(query)
        database = "database=#{@config[:database]}&" if @config[:database]
        "/?#{database}query=#{CGI.escape(query)}"
      end

      def client
        @client ||= Faraday.new(:url => url)
      end

      def ensure_authentication
        username, password = @config.values_at(:username, :password)
        client.basic_auth(username || "default", password) if username || password
      end

      def request(method, query, body = nil)
        connect!
        query = query.to_s.strip
        start = Time.now
        client.send(method, path(query), body).tap do |response|
          log :info, "\n  SQL (#{((Time.now - start) * 1000).round(1)}ms)  #{query.gsub(/( FORMAT \w+|;$)/, "")};"
          raise QueryError, response.body unless response.status == 200
        end
      rescue Faraday::Error => e
        raise ConnectionError, e.message
      end

    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
clickhouse-0.1.4	lib/clickhouse/connection/client.rb
clickhouse-0.1.3	lib/clickhouse/connection/client.rb
clickhouse-0.1.2	lib/clickhouse/connection/client.rb