Method: Cassandro::Migrator#initialize

Defined in:
lib/cassandro/ext/migrator.rb

#initialize(path, logger = ::Logger.new(STDOUT)) ⇒ Migrator

Returns a new instance of Migrator.



6
7
8
9
10
11
12
13
14
15
16
 
# File 'lib/cassandro/ext/migrator.rb', line 6

def initialize(path, logger = ::Logger.new(STDOUT))
  Dir["#{path}/**/*.rb"].each { |file| require file }
  @migrations = Cassandro::Migration.migrations
  @logger = logger

  Cassandro.client.execute CassandroMigration.schema

  version = CassandroMigration[name: 'version'] || CassandroMigration.create(name: 'version', value: "0")

  @current_version = version
end