Module: CassandraMigrations::Cassandra::KeyspaceOperations

Included in:
CassandraMigrations::Cassandra
Defined in:
lib/cassandra_migrations/cassandra/keyspace_operations.rb

Instance Method Summary collapse

Instance Method Details

#create_keyspace!(env) ⇒ Object 



9
10
11
12
13
14
15
16
17
18
 
# File 'lib/cassandra_migrations/cassandra/keyspace_operations.rb', line 9

def create_keyspace!(env)
  config = Config.configurations[env]
  execute(create_keyspace_statement(config))
  begin
    use(config.keyspace)
  rescue StandardError => exception
    drop_keyspace!(env)
    raise exception
  end
end

#create_keyspace_statement(config) ⇒ Object 



20
21
22
23
24
25
26
27
28
29
 
# File 'lib/cassandra_migrations/cassandra/keyspace_operations.rb', line 20

def create_keyspace_statement(config)
  validate_config(config)
  "    CREATE KEYSPACE \#{config.keyspace}\n    WITH replication = {\n      'class': '\#{config.replication['class']}',\n      \#{replication_options_statement(config)}\n    }\n  CQL\nend\n".strip_heredoc

#drop_keyspace!(env) ⇒ Object 



31
32
33
34
35
36
37
38
 
# File 'lib/cassandra_migrations/cassandra/keyspace_operations.rb', line 31

def drop_keyspace!(env)
  config = Config.configurations[env]
  begin
    execute("DROP KEYSPACE #{config.keyspace}")
  rescue ::Cassandra::Errors::ConfigurationError
    raise Errors::UnexistingKeyspaceError, config.keyspace
  end
end