Sha256: b915b0a94d36778188771114e31a681a7b2bbff4bb2a3646b97cc5a22516fa0c
Contents?: true
Size: 1.09 KB
Versions: 9
Compression:
Stored size: 1.09 KB
Contents
#!/usr/bin/env ruby
require "logger"
require "bundler"
Bundler.require :default, :development
def connect!(config = {})
Clickhouse.logger = Logger.new(STDOUT)
Clickhouse.establish_connection(config)
end
def conn(config = {})
connect!(config) unless Clickhouse.connection
Clickhouse.connection
end
def events
"events"
end
def create_table
conn.create_table(events) do |t|
t.fixed_string :id, 16
t.uint16 :year
t.date :date
t.date_time :time
t.string :event
t.uint32 :user_id
t.float32 :revenue
t.engine "MergeTree(date, (year, date), 8192)"
end
end
def insert_rows
conn.insert_rows(events, :names => %w(id year date time event user_id revenue)) do |rows|
rows << [
"d91d1c90",
2016,
"2016-10-17",
"2016-10-17 23:14:28",
"click",
1982,
0.18
]
rows << [
"d91d2294",
2016,
"2016-10-17",
"2016-10-17 23:14:41",
"click",
1947,
0.203
]
end
end
puts "Loading Clickhouse development environment (#{Clickhouse::VERSION})"
Pry.start
Version data entries
9 entries across 9 versions & 2 rubygems