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.
1250 1251 1252 1253 1254 1255 1256 1257 1258 1259 1260 1261 |
# File 'lib/active_record/migration.rb', line 1250 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.
1240 1241 1242 |
# File 'lib/active_record/migration.rb', line 1240 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
1243 1244 1245 |
# File 'lib/active_record/migration.rb', line 1243 def current_version MigrationContext.new(migrations_paths, SchemaMigration).current_version end |
Instance Method Details
#current_migration ⇒ Object Also known as: current
1267 1268 1269 |
# File 'lib/active_record/migration.rb', line 1267 def current_migration migrations.detect { |m| m.version == current_version } end |
#current_version ⇒ Object
1263 1264 1265 |
# File 'lib/active_record/migration.rb', line 1263 def current_version migrated.max || 0 end |
#load_migrated ⇒ Object
1312 1313 1314 |
# File 'lib/active_record/migration.rb', line 1312 def load_migrated @migrated_versions = Set.new(@schema_migration.all_versions.map(&:to_i)) end |
#migrate ⇒ Object
1280 1281 1282 1283 1284 1285 1286 |
# File 'lib/active_record/migration.rb', line 1280 def migrate if use_advisory_lock? with_advisory_lock { migrate_without_lock } else migrate_without_lock end end |
#migrated ⇒ Object
1308 1309 1310 |
# File 'lib/active_record/migration.rb', line 1308 def migrated @migrated_versions || load_migrated end |
#migrations ⇒ Object
1299 1300 1301 |
# File 'lib/active_record/migration.rb', line 1299 def migrations down? ? @migrations.reverse : @migrations.sort_by(&:version) end |
#pending_migrations ⇒ Object
1303 1304 1305 1306 |
# File 'lib/active_record/migration.rb', line 1303 def pending_migrations already_migrated = migrated migrations.reject { |m| already_migrated.include?(m.version) } end |
#run ⇒ Object
1272 1273 1274 1275 1276 1277 1278 |
# File 'lib/active_record/migration.rb', line 1272 def run if use_advisory_lock? with_advisory_lock { run_without_lock } else run_without_lock end end |
#runnable ⇒ Object
1288 1289 1290 1291 1292 1293 1294 1295 1296 1297 |
# File 'lib/active_record/migration.rb', line 1288 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 |