Class: Mongoid::Migrator
- Inherits:
-
Object
- Object
- Mongoid::Migrator
- Defined in:
- lib/mongoid_rails_migrations/active_record_ext/migrations.rb
Overview
:nodoc:
Class Method Summary collapse
- .current_version ⇒ Object
- .down(migrations_path, target_version = nil) ⇒ Object
- .forward(migrations_path, steps = 1) ⇒ Object
-
.get_all_versions ⇒ Object
def schema_migrations_table_name # Base.table_name_prefix + ‘schema_migrations’ + Base.table_name_suffix ‘data_migrations’ end.
- .migrate(migrations_path, target_version = nil) ⇒ Object
- .migrations_path ⇒ Object
- .proper_table_name(name) ⇒ Object
- .rollback(migrations_path, steps = 1) ⇒ Object
- .run(direction, migrations_path, target_version) ⇒ Object
- .up(migrations_path, target_version = nil) ⇒ Object
Instance Method Summary collapse
- #current_migration ⇒ Object
- #current_version ⇒ Object
-
#initialize(direction, migrations_path, target_version = nil) ⇒ Migrator
constructor
A new instance of Migrator.
- #migrate ⇒ Object
- #migrated ⇒ Object
- #migrations ⇒ Object
- #pending_migrations ⇒ Object
- #run ⇒ Object
Constructor Details
#initialize(direction, migrations_path, target_version = nil) ⇒ Migrator
Returns a new instance of Migrator.
259 260 261 262 263 |
# File 'lib/mongoid_rails_migrations/active_record_ext/migrations.rb', line 259 def initialize(direction, migrations_path, target_version = nil) # raise StandardError.new("This database does not yet support migrations") unless Base.connection.supports_migrations? # Base.connection.initialize_schema_migrations_table @direction, @migrations_path, @target_version = direction, migrations_path, target_version end |
Class Method Details
.current_version ⇒ Object
229 230 231 232 233 234 235 236 237 |
# File 'lib/mongoid_rails_migrations/active_record_ext/migrations.rb', line 229 def current_version # sm_table = schema_migrations_table_name # if Base.connection.table_exists?(sm_table) # get_all_versions.max || 0 # else # 0 # end get_all_versions.max || 0 end |
.down(migrations_path, target_version = nil) ⇒ Object
206 207 208 |
# File 'lib/mongoid_rails_migrations/active_record_ext/migrations.rb', line 206 def down(migrations_path, target_version = nil) self.new(:down, migrations_path, target_version).migrate end |
.forward(migrations_path, steps = 1) ⇒ Object
198 199 200 |
# File 'lib/mongoid_rails_migrations/active_record_ext/migrations.rb', line 198 def forward(migrations_path, steps=1) move(:up, migrations_path, steps) end |
.get_all_versions ⇒ Object
def schema_migrations_table_name
# Base.table_name_prefix + 'schema_migrations' + Base.table_name_suffix
'data_migrations'
end
223 224 225 226 227 |
# File 'lib/mongoid_rails_migrations/active_record_ext/migrations.rb', line 223 def get_all_versions # table = Arel::Table.new(schema_migrations_table_name) # Base.connection.select_values(table.project(table['version']).to_sql).map(&:to_i).sort DataMigration.all.map {|datamigration| datamigration.version.to_i }.sort end |
.migrate(migrations_path, target_version = nil) ⇒ Object
186 187 188 189 190 191 192 |
# File 'lib/mongoid_rails_migrations/active_record_ext/migrations.rb', line 186 def migrate(migrations_path, target_version = nil) case when target_version.nil? then up(migrations_path, target_version) when current_version > target_version then down(migrations_path, target_version) else up(migrations_path, target_version) end end |
.migrations_path ⇒ Object
214 215 216 |
# File 'lib/mongoid_rails_migrations/active_record_ext/migrations.rb', line 214 def migrations_path 'db/migrate' end |
.proper_table_name(name) ⇒ Object
239 240 241 242 243 |
# File 'lib/mongoid_rails_migrations/active_record_ext/migrations.rb', line 239 def proper_table_name(name) # Use the Active Record 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}" name end |
.rollback(migrations_path, steps = 1) ⇒ Object
194 195 196 |
# File 'lib/mongoid_rails_migrations/active_record_ext/migrations.rb', line 194 def rollback(migrations_path, steps=1) move(:down, migrations_path, steps) end |
.run(direction, migrations_path, target_version) ⇒ Object
210 211 212 |
# File 'lib/mongoid_rails_migrations/active_record_ext/migrations.rb', line 210 def run(direction, migrations_path, target_version) self.new(direction, migrations_path, target_version).run end |
.up(migrations_path, target_version = nil) ⇒ Object
202 203 204 |
# File 'lib/mongoid_rails_migrations/active_record_ext/migrations.rb', line 202 def up(migrations_path, target_version = nil) self.new(:up, migrations_path, target_version).migrate end |
Instance Method Details
#current_migration ⇒ Object
269 270 271 |
# File 'lib/mongoid_rails_migrations/active_record_ext/migrations.rb', line 269 def current_migration migrations.detect { |m| m.version == current_version } end |
#current_version ⇒ Object
265 266 267 |
# File 'lib/mongoid_rails_migrations/active_record_ext/migrations.rb', line 265 def current_version migrated.last || 0 end |
#migrate ⇒ Object
282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 |
# File 'lib/mongoid_rails_migrations/active_record_ext/migrations.rb', line 282 def migrate current = migrations.detect { |m| m.version == current_version } target = migrations.detect { |m| m.version == @target_version } if target.nil? && !@target_version.nil? && @target_version > 0 raise UnknownMigrationVersionError.new(@target_version) end start = up? ? 0 : (migrations.index(current) || 0) finish = migrations.index(target) || migrations.size - 1 runnable = migrations[start..finish] # skip the last migration if we're headed down, but not ALL the way down runnable.pop if down? && !target.nil? runnable.each do |migration| Rails.logger.info "Migrating to #{migration.name} (#{migration.version})" if Rails.logger # On our way up, we skip migrating the ones we've already migrated next if up? && migrated.include?(migration.version.to_i) # On our way down, we skip reverting the ones we've never migrated if down? && !migrated.include?(migration.version.to_i) migration.announce 'never migrated, skipping'; migration.write next end # begin # ddl_transaction do # migration.migrate(@direction) # record_version_state_after_migrating(migration.version) # end # rescue => e # canceled_msg = Base.connection.supports_ddl_transactions? ? "this and " : "" # raise StandardError, "An error has occurred, #{canceled_msg}all later migrations canceled:\n\n#{e}", e.backtrace # end begin migration.migrate(@direction) (migration.version) rescue => e raise StandardError, "An error has occurred, #{migration.version} and all later migrations canceled:\n\n#{e}", e.backtrace end end end |
#migrated ⇒ Object
362 363 364 |
# File 'lib/mongoid_rails_migrations/active_record_ext/migrations.rb', line 362 def migrated @migrated_versions ||= self.class.get_all_versions end |
#migrations ⇒ Object
327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 |
# File 'lib/mongoid_rails_migrations/active_record_ext/migrations.rb', line 327 def migrations @migrations ||= begin files = Dir["#{@migrations_path}/[0-9]*_*.rb"] migrations = files.inject([]) do |klasses, file| version, name = file.scan(/([0-9]+)_([_a-z0-9]*).rb/).first raise IllegalMigrationNameError.new(file) unless version version = version.to_i if klasses.detect { |m| m.version == version } raise DuplicateMigrationVersionError.new(version) end if klasses.detect { |m| m.name == name.camelize } raise DuplicateMigrationNameError.new(name.camelize) end migration = MigrationProxy.new migration.name = name.camelize migration.version = version migration.filename = file klasses << migration end migrations = migrations.sort_by(&:version) down? ? migrations.reverse : migrations end end |
#pending_migrations ⇒ Object
357 358 359 360 |
# File 'lib/mongoid_rails_migrations/active_record_ext/migrations.rb', line 357 def pending_migrations already_migrated = migrated migrations.reject { |m| already_migrated.include?(m.version.to_i) } end |
#run ⇒ Object
273 274 275 276 277 278 279 280 |
# File 'lib/mongoid_rails_migrations/active_record_ext/migrations.rb', line 273 def run target = migrations.detect { |m| m.version == @target_version } raise UnknownMigrationVersionError.new(@target_version) if target.nil? unless (up? && migrated.include?(target.version.to_i)) || (down? && !migrated.include?(target.version.to_i)) target.migrate(@direction) (target.version) end end |