Class: ROM::SQL::Migration::Runner Private
- Inherits:
-
Object
- Object
- ROM::SQL::Migration::Runner
- Defined in:
- lib/rom/sql/migration/runner.rb
This class is part of a private API. You should avoid using this class if possible, as it may be removed or be changed in the future.
Instance Attribute Summary collapse
- #writer ⇒ Object readonly private
Instance Method Summary collapse
-
#alter_foreign_keys(diff, foreign_key_changes) ⇒ Object
private
rubocop:enable Metrics/AbcSize.
-
#alter_table(diff) ⇒ Object
private
rubocop:disable Metrics/AbcSize.
- #apply_constraints(diff) ⇒ Object private
- #apply_schema(diff) ⇒ Object private
- #call(changes) ⇒ Object private
- #create_table(diff) ⇒ Object private
-
#initialize(writer) ⇒ Runner
constructor
private
A new instance of Runner.
Constructor Details
#initialize(writer) ⇒ Runner
This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.
Returns a new instance of Runner.
10 11 12 |
# File 'lib/rom/sql/migration/runner.rb', line 10 def initialize(writer) @writer = writer end |
Instance Attribute Details
#writer ⇒ Object (readonly)
This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.
8 9 10 |
# File 'lib/rom/sql/migration/runner.rb', line 8 def writer @writer end |
Instance Method Details
#alter_foreign_keys(diff, foreign_key_changes) ⇒ Object
This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.
rubocop:enable Metrics/AbcSize
98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 |
# File 'lib/rom/sql/migration/runner.rb', line 98 def alter_foreign_keys(diff, foreign_key_changes) return if foreign_key_changes.empty? writer.migration do |connection| connection.alter_table(diff.table_name) do foreign_key_changes.map do |fk| case fk when SchemaDiff::ForeignKeyAdded add_foreign_key fk.child_keys, fk.parent when SchemaDiff::ForeignKeyRemoved drop_foreign_key fk.child_keys end end end end end |
#alter_table(diff) ⇒ Object
This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.
rubocop:disable Metrics/AbcSize
58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 |
# File 'lib/rom/sql/migration/runner.rb', line 58 def alter_table(diff) return if diff. writer.migration do |connection| connection.alter_table(diff.table_name) do diff.attribute_changes.each do |attribute| case attribute when SchemaDiff::AttributeAdded add_column attribute.name, attribute.type, null: attribute.null? when SchemaDiff::AttributeRemoved drop_column attribute.name when SchemaDiff::AttributeChanged if attribute.type_changed? from, to = attribute.current.unwrap, attribute.target.unwrap raise UnsupportedConversion, "Don't know how to convert #{from.inspect} to #{to.inspect}" end if attribute.nullability_changed? if attribute.null? set_column_allow_null attribute.name else set_column_not_null attribute.name end end end end diff.index_changes.each do |index| case index when SchemaDiff::IndexAdded add_index index.attributes, index. when SchemaDiff::IndexRemoved drop_index index.attributes, index. end end end end end |
#apply_constraints(diff) ⇒ Object
This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.
30 31 32 33 34 35 36 37 |
# File 'lib/rom/sql/migration/runner.rb', line 30 def apply_constraints(diff) case diff when SchemaDiff::TableCreated alter_foreign_keys(diff, diff.foreign_keys) when SchemaDiff::TableAltered alter_foreign_keys(diff, diff.foreign_key_changes) end end |
#apply_schema(diff) ⇒ Object
This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.
21 22 23 24 25 26 27 28 |
# File 'lib/rom/sql/migration/runner.rb', line 21 def apply_schema(diff) case diff when SchemaDiff::TableCreated create_table(diff) when SchemaDiff::TableAltered alter_table(diff) end end |
#call(changes) ⇒ Object
This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.
14 15 16 17 18 19 |
# File 'lib/rom/sql/migration/runner.rb', line 14 def call(changes) changes.each { |diff| apply_schema(diff) } changes.each { |diff| apply_constraints(diff) } self end |
#create_table(diff) ⇒ Object
This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.
39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 |
# File 'lib/rom/sql/migration/runner.rb', line 39 def create_table(diff) writer.migration do |connection| connection.create_table(diff.table_name) do diff.attributes.each do |attribute| if attribute.primary_key? primary_key attribute.name else column attribute.name, attribute.type, null: attribute.null? end end diff.indexes.each do |index| index index.attributes, index. end end end end |