Module: Clickhouse

Defined in:
lib/clickhouse.rb,
lib/clickhouse/cli.rb,
lib/clickhouse/error.rb,
lib/clickhouse/utils.rb,
lib/clickhouse/cluster.rb,
lib/clickhouse/version.rb,
lib/clickhouse/cli/client.rb,
lib/clickhouse/cli/server.rb,
lib/clickhouse/connection.rb,
lib/clickhouse/cli/console.rb,
lib/clickhouse/connection/query.rb,
lib/clickhouse/connection/client.rb,
lib/clickhouse/connection/logger.rb,
lib/clickhouse/connection/query/table.rb,
lib/clickhouse/connection/query/result_row.rb,
lib/clickhouse/connection/query/result_set.rb

Defined Under Namespace

Modules: Utils Classes: CLI, Cluster, Connection, ConnectionError, Error, InvalidConnectionError, InvalidQueryError, QueryError

Constant Summary collapse

MAJOR = 
0
MINOR = 
1
TINY = 
10
VERSION = 
[MAJOR, MINOR, TINY].join(".")

Class Method Summary collapse

Class Method Details

.configurations ⇒ Object 



32
33
34
 
# File 'lib/clickhouse.rb', line 32

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

.configurations=(configurations) ⇒ Object 



28
29
30
 
# File 'lib/clickhouse.rb', line 28

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

.connect(config = {}) ⇒ Object 



50
51
52
53
 
# File 'lib/clickhouse.rb', line 50

def self.connect(config = {})
  klass = (config[:urls] || config["urls"]) ? Cluster : Connection
  klass.new(config)
end

.connect!(config = {}) ⇒ Object 



45
46
47
48
 
# File 'lib/clickhouse.rb', line 45

def self.connect!(config = {})
  @connection = connect(config)
  @connection.connect!
end

.connection ⇒ Object 



55
56
57
 
# File 'lib/clickhouse.rb', line 55

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

.establish_connection(arg = {}) ⇒ Object 



36
37
38
39
40
41
42
43
 
# File 'lib/clickhouse.rb', line 36

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

.logger ⇒ Object 



24
25
26
 
# File 'lib/clickhouse.rb', line 24

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

.logger=(logger) ⇒ Object 



20
21
22
 
# File 'lib/clickhouse.rb', line 20

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