Contents

require "forwardable"
require "csv"

require "faraday"

require "clickhouse/connection"
require "clickhouse/error"
require "clickhouse/version"

module Clickhouse

  def self.logger=(logger)
    @logger = logger
  end

  def self.logger
    @logger if instance_variables.include?(:@logger)
  end

  def self.configurations=(configurations)
    @configurations = configurations.inject({}){|h, (k, v)| h[k.to_s] = v; h}
  end

  def self.configurations
    @configurations if instance_variables.include?(:@configurations)
  end

  def self.establish_connection(arg = {})
    config = arg.is_a?(Hash) ? arg : (configurations || {})[arg.to_s]
    if config
      @connection = Connection.new(config)
      @connection.connect!
    else
      raise InvalidConnectionError, "Invalid connection specified: #{arg.inspect}"
    end
  end

  def self.connection
    @connection if instance_variables.include?(:@connection)
  end

end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
clickhouse-0.1.1	lib/clickhouse.rb
clickhouse-0.1.0	lib/clickhouse.rb