Module: ActiveRecord::Turntable::Migration::Migrator::ClassMethods

Defined in:
lib/active_record/turntable/migration.rb

Instance Method Summary collapse

Instance Method Details

#down_with_turntable(migrations_paths, target_version = nil, &block) ⇒ Object 



123
124
125
126
127
128
129
130
 
# File 'lib/active_record/turntable/migration.rb', line 123

def down_with_turntable(migrations_paths, target_version = nil, &block)
  down_without_turntable(migrations_paths, target_version, &block)

  ActiveRecord::Tasks::DatabaseTasks.each_current_turntable_cluster_connected do |name, configuration|
    puts "[turntable] *** Migrating database: #{configuration['database']}(Shard: #{name})"
    _original_down(migrations_paths, target_version, &block)
  end
end

#run_with_turntable(*args) ⇒ Object 



132
133
134
135
136
137
138
139
 
# File 'lib/active_record/turntable/migration.rb', line 132

def run_with_turntable(*args)
  run_without_turntable(*args)

  ActiveRecord::Tasks::DatabaseTasks.each_current_turntable_cluster_connected do |name, configuration|
    puts "[turntable] *** Migrating database: #{configuration['database']}(Shard: #{name})"
    _original_run(*args)
  end
end

#up_with_turntable(migrations_paths, target_version = nil) ⇒ Object 



114
115
116
117
118
119
120
121
 
# File 'lib/active_record/turntable/migration.rb', line 114

def up_with_turntable(migrations_paths, target_version = nil)
  up_without_turntable(migrations_paths, target_version)

  ActiveRecord::Tasks::DatabaseTasks.each_current_turntable_cluster_connected do |name, configuration|
    puts "[turntable] *** Migrating database: #{configuration['database']}(Shard: #{name})"
    _original_up(migrations_paths, target_version)
  end
end