Class: Sequel::IntegerMigrator

Inherits:
Migrator show all
Defined in:
lib/sequel/extensions/migration.rb

Overview

The default migrator, recommended in most cases. Uses a simple incrementing version number starting with 1, where missing or duplicate migration file versions are not allowed. Part of the migration extension.

Constant Summary collapse

DEFAULT_SCHEMA_COLUMN = 
:version
DEFAULT_SCHEMA_TABLE = 
:schema_info
Error = 
Migrator::Error

Constants inherited from Migrator

Migrator::MIGRATION_FILE_PATTERN, Migrator::MIGRATION_SPLITTER, Migrator::MINIMUM_TIMESTAMP

Instance Attribute Summary collapse

Attributes inherited from Migrator

#column, #db, #directory, #ds, #files, #table, #target

Instance Method Summary collapse

Methods inherited from Migrator

apply, run

Constructor Details

#initialize(db, directory, opts = {}) ⇒ IntegerMigrator

Set up all state for the migrator instance

Raises:



475
476
477
478
479
480
481
482
483
484
485
 
# File 'lib/sequel/extensions/migration.rb', line 475

def initialize(db, directory, opts={})
  super
  @target = opts[:target] || latest_migration_version
  @current = opts[:current] || current_migration_version

  raise(Error, "No current version available") unless current
  raise(Error, "No target version available, probably because no migration files found or filenames don't follow the migration filename convention") unless target

  @direction = current < target ? :up : :down
  @migrations = get_migrations
end

Instance Attribute Details

#current ⇒ Object (readonly)

The current version for this migrator



466
467
468
 
# File 'lib/sequel/extensions/migration.rb', line 466

def current
  @current
end

#direction ⇒ Object (readonly)

The direction of the migrator, either :up or :down



469
470
471
 
# File 'lib/sequel/extensions/migration.rb', line 469

def direction
  @direction
end

#migrations ⇒ Object (readonly)

The migrations used by this migrator



472
473
474
 
# File 'lib/sequel/extensions/migration.rb', line 472

def migrations
  @migrations
end

Instance Method Details

#run ⇒ Object

Apply all migrations on the database



488
489
490
491
492
493
494
495
496
497
498
499
500
501
 
# File 'lib/sequel/extensions/migration.rb', line 488

def run
  migrations.zip(version_numbers).each do |m, v|
    t = Time.now
    lv = up? ? v : v + 1
    db.log_info("Begin applying migration version #{lv}, direction: #{direction}")
    checked_transaction(m) do
      m.apply(db, direction)
      set_migration_version(v)
    end
    db.log_info("Finished applying migration version #{lv}, direction: #{direction}, took #{sprintf('%0.6f', Time.now - t)} seconds")
  end
  
  target
end