Class: ActiveRecord::Migrator
- Inherits:
-
Object
- Object
- ActiveRecord::Migrator
- Defined in:
- lib/active_record/migration.rb
Overview
:nodoc:
Class Attribute Summary collapse
-
.migrations_paths ⇒ Object
Returns the value of attribute migrations_paths.
Class Method Summary collapse
-
.current_version ⇒ Object
For cases where a table doesn’t exist like loading from schema cache.
Instance Method Summary collapse
- #current_migration ⇒ Object (also: #current)
- #current_version ⇒ Object
-
#initialize(direction, migrations, schema_migration, target_version = nil) ⇒ Migrator
constructor
A new instance of Migrator.
- #load_migrated ⇒ Object
- #migrate ⇒ Object
- #migrated ⇒ Object
- #migrations ⇒ Object
- #pending_migrations ⇒ Object
- #run ⇒ Object
- #runnable ⇒ Object
Constructor Details
#initialize(direction, migrations, schema_migration, target_version = nil) ⇒ Migrator
Returns a new instance of Migrator.
1249 1250 1251 1252 1253 1254 1255 1256 1257 1258 1259 1260 |
# File 'lib/active_record/migration.rb', line 1249 def initialize(direction, migrations, schema_migration, target_version = nil) @direction = direction @target_version = target_version @migrated_versions = nil @migrations = migrations @schema_migration = schema_migration validate(@migrations) @schema_migration.create_table ActiveRecord::InternalMetadata.create_table end |
Class Attribute Details
.migrations_paths ⇒ Object
Returns the value of attribute migrations_paths.
1239 1240 1241 |
# File 'lib/active_record/migration.rb', line 1239 def migrations_paths @migrations_paths end |
Class Method Details
.current_version ⇒ Object
For cases where a table doesn’t exist like loading from schema cache
1242 1243 1244 |
# File 'lib/active_record/migration.rb', line 1242 def current_version MigrationContext.new(migrations_paths, SchemaMigration).current_version end |
Instance Method Details
#current_migration ⇒ Object Also known as: current
1266 1267 1268 |
# File 'lib/active_record/migration.rb', line 1266 def current_migration migrations.detect { |m| m.version == current_version } end |
#current_version ⇒ Object
1262 1263 1264 |
# File 'lib/active_record/migration.rb', line 1262 def current_version migrated.max || 0 end |
#load_migrated ⇒ Object
1311 1312 1313 |
# File 'lib/active_record/migration.rb', line 1311 def load_migrated @migrated_versions = Set.new(@schema_migration.all_versions.map(&:to_i)) end |
#migrate ⇒ Object
1279 1280 1281 1282 1283 1284 1285 |
# File 'lib/active_record/migration.rb', line 1279 def migrate if use_advisory_lock? with_advisory_lock { migrate_without_lock } else migrate_without_lock end end |
#migrated ⇒ Object
1307 1308 1309 |
# File 'lib/active_record/migration.rb', line 1307 def migrated @migrated_versions || load_migrated end |
#migrations ⇒ Object
1298 1299 1300 |
# File 'lib/active_record/migration.rb', line 1298 def migrations down? ? @migrations.reverse : @migrations.sort_by(&:version) end |
#pending_migrations ⇒ Object
1302 1303 1304 1305 |
# File 'lib/active_record/migration.rb', line 1302 def pending_migrations already_migrated = migrated migrations.reject { |m| already_migrated.include?(m.version) } end |
#run ⇒ Object
1271 1272 1273 1274 1275 1276 1277 |
# File 'lib/active_record/migration.rb', line 1271 def run if use_advisory_lock? with_advisory_lock { run_without_lock } else run_without_lock end end |
#runnable ⇒ Object
1287 1288 1289 1290 1291 1292 1293 1294 1295 1296 |
# File 'lib/active_record/migration.rb', line 1287 def runnable runnable = migrations[start..finish] if up? runnable.reject { |m| ran?(m) } else # skip the last migration if we're headed down, but not ALL the way down runnable.pop if target runnable.find_all { |m| ran?(m) } end end |