Class: ActiveRecord::Migrator

Inherits:
Object
  • Object
show all
Defined in:
lib/active_record/migration.rb

Overview

:nodoc:

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(direction, migrations_path, target_version = nil) ⇒ Migrator

Returns a new instance of Migrator.

Raises:

  • (StandardError) 


188
189
190
191
192
 
# File 'lib/active_record/migration.rb', line 188

def initialize(direction, migrations_path, target_version = nil)
  raise StandardError.new("This database does not yet support migrations") unless Base.connection.supports_migrations?
  @direction, @migrations_path, @target_version = direction, migrations_path, target_version
  Base.connection.initialize_schema_information
end

Class Method Details

.current_version ⇒ Object 



177
178
179
 
# File 'lib/active_record/migration.rb', line 177

def current_version
  (Base.connection.select_one("SELECT version FROM #{schema_info_table_name}") || {"version" => 0})["version"].to_i
end

.down(migrations_path, target_version = nil) ⇒ Object 



169
170
171
 
# File 'lib/active_record/migration.rb', line 169

def down(migrations_path, target_version = nil)
  self.new(:down, migrations_path, target_version).migrate
end

.migrate(migrations_path, target_version = nil) ⇒ Object 



153
154
155
156
157
158
159
160
161
162
163
 
# File 'lib/active_record/migration.rb', line 153

def migrate(migrations_path, target_version = nil)
  Base.connection.initialize_schema_information
  case
    when target_version.nil?, current_version < target_version
      up(migrations_path, target_version)
    when current_version > target_version
      down(migrations_path, target_version)
    when current_version == target_version
      return # You're on the right version
  end
end

.proper_table_name(name) ⇒ Object 



181
182
183
184
 
# File 'lib/active_record/migration.rb', line 181

def proper_table_name(name)
  # Use the ActiveRecord objects own table_name, or pre/suffix from ActiveRecord::Base if name is a symbol/string
  name.table_name rescue "#{ActiveRecord::Base.table_name_prefix}#{name}#{ActiveRecord::Base.table_name_suffix}"
end

.schema_info_table_name ⇒ Object 



173
174
175
 
# File 'lib/active_record/migration.rb', line 173

def schema_info_table_name
  Base.table_name_prefix + "schema_info" + Base.table_name_suffix
end

.up(migrations_path, target_version = nil) ⇒ Object 



165
166
167
 
# File 'lib/active_record/migration.rb', line 165

def up(migrations_path, target_version = nil)
  self.new(:up, migrations_path, target_version).migrate
end

Instance Method Details

#current_version ⇒ Object 



194
195
196
 
# File 'lib/active_record/migration.rb', line 194

def current_version
  self.class.current_version
end

#migrate ⇒ Object 



198
199
200
201
202
203
204
205
206
207
 
# File 'lib/active_record/migration.rb', line 198

def migrate
  migration_classes.each do |(version, migration_class)|
    Base.logger.info("Reached target version: #{@target_version}") and break if reached_target_version?(version)
    next if irrelevant_migration?(version)

    Base.logger.info "Migrating to #{migration_class} (#{version})"
    migration_class.send(@direction)
    set_schema_version(version)
  end
end