Method: ClickHouse::Extend::ConnectionDatabase#create_database

Defined in:

lib/click_house/extend/connection_database.rb

#create_database(name, if_not_exists: false, cluster: nil, engine: nil) ⇒ Object

# File 'lib/click_house/extend/connection_database.rb', line 11

def create_database(name, if_not_exists: false, cluster: nil, engine: nil)
  sql = 'CREATE DATABASE %<exists>s %<name>s %<cluster>s %<engine>s'

  pattern = {
    name: name,
    exists: Util::Statement.ensure(if_not_exists, 'IF NOT EXISTS'),
    cluster: Util::Statement.ensure(cluster, "ON CLUSTER #{cluster}"),
    engine: Util::Statement.ensure(engine, "ENGINE = #{engine}")
  }

  execute(format(sql, pattern), database: nil).success?
end