blob: 4c7440fa42e805aa5b742ccea9f2934696530e4c (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
|
ALLOWED_DUPLICATES = [20180410220657, 20180831171112].freeze
module ActiveRecord
class Migrator
old_initialize = instance_method(:initialize)
define_method(:initialize) do |direction, migrations, target_version|
migrated = Set.new(Base.connection.migration_context.get_all_versions)
migrations.group_by(&:name).each do |name, duplicates|
if duplicates.length > 1 && duplicates.all? { |m| ALLOWED_DUPLICATES.include?(m.version) }
# We have a set of allowed duplicates. Keep the migrated one, if any.
non_migrated = duplicates.reject { |m| migrated.include?(m.version.to_i) }
if duplicates.length == non_migrated.length
# There weren't any migrated one, so we have to pick one “canonical” migration
migrations = migrations - duplicates[1..-1]
else
# Just reject every duplicate which hasn't been migrated yet
migrations = migrations - non_migrated
end
end
end
old_initialize.bind(self).(direction, migrations, target_version)
end
end
end
|