class ActiveRecord::Migration
Experimental RBS support (using type sampling data from the type_fusion
project).
# sig/active_record/migration.rbs class ActiveRecord::Migration def maintain_test_schema!: () -> nil end
are in a Migration with self.disable_ddl_transaction!
.
Remember that you can still open your own transactions, even if you
end
end
execute “ALTER TYPE model_size ADD VALUE ‘new_value’”
def up
disable_ddl_transaction!
class ChangeEnum < ActiveRecord::Migration[7.0]
you can turn the automatic transactions off.
can’t execute inside a transaction though, and for these situations
automatically be wrapped in a transaction. There are queries that you
If the database adapter supports DDL transactions, all migrations will
== Transactional MigrationsActiveRecord::Migration::CommandRecorder
.
For a list of commands that are reversible, please see
the migration is moving down.ActiveRecord::IrreversibleMigration
exception will be raised when
If a command cannot be reversed, an
as before.
and down in these cases, you should define the up
and down
methods
Some commands cannot be reversed. If you care to define how to move up
automatically figure out how to drop the table on the way down.
This migration will create the horses table for you on the way up, and
end
end
end
t.column :remind_at, :datetime
t.column :content, :text
create_table(:horses) do |t|
def change
class TenderloveMigration < ActiveRecord::Migration[7.0]
migration like this:
To define a reversible migration, define the change
method in your
how to execute the down commands for you.
You simply supply the up
logic, and the Migration system figures out
Reversible migrations are migrations that know how to go down
for you.
== Reversible Migrations
In application.rb.
config.active_record.timestamped_migrations = false
off by setting:
If you’d prefer to use numeric prefixes, you can turn timestamped migrations
The prefix is a generation timestamp (in UTC).
20080717013526_your_migration_name.rb
By default, Rails generates migrations that look like:
== Timestamped Migrations
benchmark for the block when the block completes.
The phrase “Updating salaries…” would then be printed, along with the
end
…
end
end
p.update_attribute :salary, SalaryCalculator.compute(p)
Person.all.each do |p|
say_with_time “Updating salaries…” do
…
def up
method:
You can also insert your own messages and benchmarks by using the say_with_time
You can quiet them down by setting ActiveRecord::Migration.verbose = false.
long each step took.
them to the console as they happen, along with benchmarks describing how
By default, migrations will describe the actions they are taking, writing
== Controlling verbosity
end
end
end
p.update_attribute :salary, SalaryCalculator.compute(p)
Person.all.each do |p|
Person.reset_column_information
add_column :people, :salary, :integer
def up
class AddPeopleSalary < ActiveRecord::Migration[7.0]
latest column data from after the new column was added. Example:Base#reset_column_information
in order to ensure that the model has the
immediately after. In that case, you’ll need to make a call to
Sometimes you’ll want to add a column in a migration and populate it
== Using a model after changing its table
end
end
execute “ALTER TABLE ‘pages_linked_pages` DROP INDEX `page_id_linked_page_id`”
def down
end
execute “ALTER TABLE `pages_linked_pages` ADD UNIQUE `page_id_linked_page_id` (`page_id`,`linked_page_id`)”
def up
class MakeJoinUnique < ActiveRecord::Migration[7.0]
And sometimes you need to do something in SQL not abstracted directly by migrations:
end
end
add_column :items, :completed_items_count
add_column :items, :incomplete_items_count
def down
end
remove_column :items, :completed_items_count
remove_column :items, :incomplete_items_count
def up
class RemoveUnnecessaryItemAttributes < ActiveRecord::Migration[7.0]
Others remove columns when they migrate up instead of down:
end
end
raise ActiveRecord::IrreversibleMigration, “Can’t recover the deleted tags”
# not much we can do to restore deleted data
def down
end
Tag.all.each { |tag| tag.destroy if tag.pages.empty? }
def up
class RemoveEmptyTags < ActiveRecord::Migration[7.0]
Not all migrations change the schema. Some just fix the data:
== More examples
that step will fail and you’ll have some manual work to do.
If any of the migrations throw an ActiveRecord::IrreversibleMigration
exception,
the latest two migrations.
wish to rollback last few migrations. bin/rails db:rollback STEP=2
will rollback
you wish to downgrade. Alternatively, you can also use the STEP option if youbin/rails db:rollback VERSION=X
where X
is the version to which
To roll the database back to a previous migration version, use
to match the structure of your database.
invoke the db:schema:dump command, which will update your db/schema.rb file
(see “About the schema_migrations table” section below) if missing. It will also
pending migrations, creating the schema_migrations
tablebin/rails db:migrate
. This will update the database by running all of the
To run migrations against the currently configured database, use
end
end
add_column :tablenames, :fieldname, :string
def change
class AddFieldnameToTablename < ActiveRecord::Migration[7.0]
This will generate the file timestamp_add_fieldname_to_tablename.rb
, which will look like this:
bin/rails generate migration add_fieldname_to_tablename fieldname:string
There is a special syntactic shortcut to generate migrations that add fields to a table.
UTC formatted date and time that the migration was generated.
in the db/migrate/
directory where timestamp
is the
create an empty migration file timestamp_my_new_migration.rb
where MyNewMigration is the name of your migration. The generator will
bin/rails generate migration MyNewMigration
To generate a new migration, you can use
The Rails package has several tools to help create and apply migrations.
== Running migrations from within Rails
exception in their down
method.
Migrations of that kind should raise an ActiveRecord::IrreversibleMigration
Some transformations are destructive in a manner that cannot be reversed.
== Irreversible transformations
columns (created_at
and updated_at
) from the table definition.
* remove_timestamps(table_name, options)
: Removes the timestamp
reference(s) on table_name
specified by ref_name
.
* remove_reference(table_name, ref_name, options)
: Removes the
specified by index_name
.
* remove_index(table_name, name: index_name)
: Removes the index
specified by column_names
.
* remove_index(table_name, column: column_names)
: Removes the index
given foreign key from the table called table_name
.
* remove_foreign_key(from_table, to_table = nil, **options)
: Removes the
columns from the table definition.
* remove_columns(table_name, *column_names)
: Removes the given
named column_name
from the table called table_name
.
* remove_column(table_name, column_name, type, options)
: Removes the column
specified by the given arguments.
* drop_join_table(table_1, table_2, options)
: Drops the join table
* drop_table(name)
: Drops the table called name
.
=== Deletion
to new_name
.
* rename_table(old_name, new_name)
: Renames the table called old_name
* rename_index(table_name, old_name, new_name)
: Renames an index.
a column but keeps the type and content.
* rename_column(table_name, column_name, new_column_name)
: Renames
can then add/remove columns, indexes, or foreign keys to it.
the table called name
. It makes the table object available to a block that
* change_table(name, options)
: Allows to make column alterations to
details.
ActiveRecord::ConnectionAdapters::SchemaStatements#change_column_null for
indicates whether the value can be NULL
. See
Sets or removes a NOT NULL
constraint on column_name
. The null
flag
* change_column_null(table_name, column_name, null, default = nil)
:
as default_or_changes
will make this change reversible in the migration.table_name
. Passing a hash containing :from
and :to
Sets a default value for column_name
defined by default_or_changes
on
* change_column_default(table_name, column_name, default_or_changes)
:
the column to a different type using the same parameters as add_column.
* change_column(table_name, column_name, type, options)
: Changes
=== Modification
and updated_at
) columns to table_name
.
* add_timestamps(table_name, options)
: Adds timestamps (created_at
ActiveRecord::ConnectionAdapters::SchemaStatements#add_reference for details.reference_name_id
by default an integer. See
* add_reference(:table_name, :reference_name)
: Adds a new column
(e.g. { order: { name: :desc } }
).{ name: 'users_name_index', unique: true }
) and :order
:name
, :unique
(e.g.
with the name of the column. Other options include
* add_index(table_name, column_names, options)
: Adds a new index
the referenced primary key.
foreign key. from_table
is the table with the key column, to_table
contains
* add_foreign_key(from_table, to_table, options)
: Adds a new
ActiveRecord::ConnectionAdapters::TableDefinition#column for details.{ limit: 50, null: false }
) – see
Other options include :limit
and :null
(e.g.
specified by passing an options
hash like { default: 11 }
.:date
, :binary
, :boolean
. A default value can be:decimal
, :datetime
, :timestamp
, :time
,:string
, :text
, :integer
, :float
,
named column_name
specified to be one of the following types:
to the table called table_name
* add_column(table_name, column_name, type, options)
: Adds a new column
table definition.
is for fragments like “DEFAULT CHARSET=UTF-8” that are appended to the create
following the same format as add_column
. See example above. The options hash
makes the table object available to a block that can then add columns to it,
* create_table(name, options)
: Creates a table called name
and
details.
ActiveRecord::ConnectionAdapters::SchemaStatements#create_join_table for
arguments. See
table having its name as the lexical order of the first two
* create_join_table(table_1, table_2, options)
: Creates a join
=== Creation
== Available transformations
complete table schema in one block call.
also uses the more advanced create_table
syntax where you can specify a
first row in it using the Active Record model that relies on the table. It
This migration first adds the system_settings
table, then creates the very
end
end
drop_table :system_settings
def down
end
value: 1
label: ‘Use notice?’,
SystemSetting.create name: ‘notice’,
end
t.integer :position
t.string :type
t.text :value
t.string :label
t.string :name
create_table :system_settings do |t|
def up
class AddSystemSettings < ActiveRecord::Migration[7.0]
Example of a more complex migration that also needs to initialize data:
transformations.
but may also contain regular Ruby code for generating data needed for the
of both the migration specific methods like add_column
and remove_column
,
required to implement or remove the migration. These methods can consist
two methods up
and down
that describes the transformations
if you’re backing out of the migration. It shows how all migrations have
This migration will add a boolean flag to the accounts table and remove it
end
end
remove_column :accounts, :ssl_enabled
def down
end
add_column :accounts, :ssl_enabled, :boolean, default: true
def up
class AddSsl < ActiveRecord::Migration[7.0]
Example of a simple migration:
another database that might be one, two, or five versions behind.
that can be checked into version control systems and executed against
migrations, you can describe the transformations in self-contained classes
push that change to other developers and to the production server. With
a new feature work in your local database, but being unsure of how to
databases. It’s a solution to the common problem of adding a field to make
Migrations can manage the evolution of a schema used by several physical
= Active Record Migrations
def self.[](version)
def self.[](version) Compatibility.find(version) end
def self.current_version
def self.current_version ActiveRecord::VERSION::STRING.to_f end
def self.inherited(subclass) # :nodoc:
def self.inherited(subclass) # :nodoc: super if subclass.superclass == Migration major = ActiveRecord::VERSION::MAJOR minor = ActiveRecord::VERSION::MINOR raise StandardError, "Directly inheriting from ActiveRecord::Migration is not supported. " \ "Please specify the Active Record release the migration was written for:\n" \ "\n" \ " class #{subclass} < ActiveRecord::Migration[#{major}.#{minor}]" end end
def announce(message)
def announce(message) text = "#{version} #{name}: #{message}" length = [0, 75 - text.length].max write "== %s %s" % [text, "=" * length] end
def check_pending!(connection = Base.connection)
def check_pending!(connection = Base.connection) raise ActiveRecord::PendingMigrationError if connection.migration_context.needs_migration? end
def command_recorder
def command_recorder CommandRecorder.new(connection) end
def connection
def connection @connection || ActiveRecord::Base.connection end
def copy(destination, sources, options = {})
def copy(destination, sources, options = {}) copied = [] schema_migration = options[:schema_migration] || ActiveRecord::SchemaMigration FileUtils.mkdir_p(destination) unless File.exist?(destination) destination_migrations = ActiveRecord::MigrationContext.new(destination, schema_migration).migrations last = destination_migrations.last sources.each do |scope, path| source_migrations = ActiveRecord::MigrationContext.new(path, schema_migration).migrations source_migrations.each do |migration| source = File.binread(migration.filename) inserted_comment = "# This migration comes from #{scope} (originally #{migration.version})\n" magic_comments = +"" loop do # If we have a magic comment in the original migration, # insert our comment after the first newline(end of the magic comment line) # so the magic keep working. # Note that magic comments must be at the first line(except sh-bang). source.sub!(/\A(?:#.*\b(?:en)?coding:\s*\S+|#\s*frozen_string_literal:\s*(?:true|false)).*\n/) do |magic_comment| magic_comments << magic_comment; "" end || break end if !magic_comments.empty? && source.start_with?("\n") magic_comments << "\n" source = source[1..-1] end source = "#{magic_comments}#{inserted_comment}#{source}" if duplicate = destination_migrations.detect { |m| m.name == migration.name } if options[:on_skip] && duplicate.scope != scope.to_s options[:on_skip].call(scope, migration) end next end migration.version = next_migration_number(last ? last.version + 1 : 0).to_i new_path = File.join(destination, "#{migration.version}_#{migration.name.underscore}.#{scope}.rb") old_path, migration.filename = migration.filename, new_path last = migration File.binwrite(migration.filename, source) copied << migration options[:on_copy].call(scope, migration, old_path) if options[:on_copy] destination_migrations << migration end end copied end
def disable_ddl_transaction # :nodoc:
def disable_ddl_transaction # :nodoc: self.class.disable_ddl_transaction end
def disable_ddl_transaction!
You can still create your own transactions even after calling #disable_ddl_transaction!
Disable the transaction wrapping this migration.
def disable_ddl_transaction! @disable_ddl_transaction = true end
def down
def down self.class.delegate = self return unless self.class.respond_to?(:down) self.class.down end
def exec_migration(conn, direction)
def exec_migration(conn, direction) @connection = conn if respond_to?(:change) if direction == :down revert { change } else change end else public_send(direction) end ensure @connection = nil end
def execute_block
def execute_block if connection.respond_to? :execute_block super # use normal delegation to record the block else yield end end
def initialize(name = self.class.name, version = nil)
def initialize(name = self.class.name, version = nil) @name = name @version = version @connection = nil end
def load_schema_if_pending!
def load_schema_if_pending! current_db_config = Base.connection_db_config all_configs = ActiveRecord::Base.configurations.configs_for(env_name: Rails.env) needs_update = !all_configs.all? do |db_config| Tasks::DatabaseTasks.schema_up_to_date?(db_config, ActiveRecord.schema_format) end if needs_update # Roundtrip to Rake to allow plugins to hook into database initialization. root = defined?(ENGINE_ROOT) ? ENGINE_ROOT : Rails.root FileUtils.cd(root) do Base.clear_all_connections! system("bin/rails db:test:prepare") end end # Establish a new connection, the old database may be gone (db:test:prepare uses purge) Base.establish_connection(current_db_config) check_pending! end
def maintain_test_schema! # :nodoc:
Experimental RBS support (using type sampling data from the type_fusion
project).
def maintain_test_schema!: () -> nil
This signature was generated using 1 sample from 1 application.
def maintain_test_schema! # :nodoc: if ActiveRecord.maintain_test_schema suppress_messages { load_schema_if_pending! } end end
def method_missing(name, *args, &block) # :nodoc:
def method_missing(name, *args, &block) # :nodoc: nearest_delegate.send(name, *args, &block) end
def method_missing(method, *arguments, &block)
def method_missing(method, *arguments, &block) arg_list = arguments.map(&:inspect) * ", " say_with_time "#{method}(#{arg_list})" do unless connection.respond_to? :revert unless arguments.empty? || [:execute, :enable_extension, :disable_extension].include?(method) arguments[0] = proper_table_name(arguments.first, table_name_options) if method == :rename_table || (method == :remove_foreign_key && !arguments.second.is_a?(Hash)) arguments[1] = proper_table_name(arguments.second, table_name_options) end end end return super unless connection.respond_to?(method) connection.send(method, *arguments, &block) end end
def migrate(direction)
def migrate(direction) new.migrate direction end
def migrate(direction)
def migrate(direction) return unless respond_to?(direction) case direction when :up then announce "migrating" when :down then announce "reverting" end time = nil ActiveRecord::Base.connection_pool.with_connection do |conn| time = Benchmark.measure do exec_migration(conn, direction) end end case direction when :up then announce "migrated (%.4fs)" % time.real; write when :down then announce "reverted (%.4fs)" % time.real; write end end
def nearest_delegate # :nodoc:
def nearest_delegate # :nodoc: delegate || superclass.nearest_delegate end
def next_migration_number(number)
def next_migration_number(number) if ActiveRecord.timestamped_migrations [Time.now.utc.strftime("%Y%m%d%H%M%S"), "%.14d" % number].max else SchemaMigration.normalize_migration_number(number) end end
def proper_table_name(name, options = {})
Uses the Active Record object's own table_name, or pre/suffix from the
Finds the correct table name given an Active Record object.
def proper_table_name(name, options = {}) if name.respond_to? :table_name name.table_name else "#{options[:table_name_prefix]}#{name}#{options[:table_name_suffix]}" end end
def reversible
end
revert { add_column :users, :full_name, :string }
end
end
u.save
dir.down { u.full_name = "#{u.first_name} #{u.last_name}" }
dir.up { u.first_name, u.last_name = u.full_name.split(' ') }
User.all.each do |u|
User.reset_column_information
reversible do |dir|
add_column :users, :last_name, :string
add_column :users, :first_name, :string
def change
class SplitNameMigration < ActiveRecord::Migration[7.0]
even when migrating down:
when the three columns 'first_name', 'last_name' and 'full_name' exist,
In the following example, the looping on users will always be done
The whole block will be called in the right order within the migration.
only in one given direction.
Call the methods +up+ and +down+ of the yielded object to run a block
Used to specify an operation that can be run in one direction or another.
def reversible helper = ReversibleBlockHelper.new(reverting?) execute_block { yield helper } end
def revert(*migration_classes, &block)
end
end
end
t.string :variety
create_table(:apples) do |t|
revert TenderloveMigration
def change
class FixupTLMigration < ActiveRecord::Migration[7.0]
require_relative "20121212123456_tenderlove_migration"
documentation for Migration:
Or equivalently, if +TenderloveMigration+ is defined as in the
end
end
end
t.string :variety
create_table(:apples) do |t|
end
end
t.datetime :remind_at
t.text :content
create_table(:horses) do |t|
revert do
def change
class FixTLMigration < ActiveRecord::Migration[7.0]
on the way down.
and create the table 'apples' on the way up, and the reverse
The following migration will remove the table 'horses'
the given migrations.
Reverses the migration commands for the given block and
def revert(*migration_classes, &block) run(*migration_classes.reverse, revert: true) unless migration_classes.empty? if block_given? if connection.respond_to? :revert connection.revert(&block) else recorder = command_recorder @connection = recorder suppress_messages do connection.revert(&block) end @connection = recorder.delegate recorder.replay(self) end end end
def reverting?
def reverting? connection.respond_to?(:reverting) && connection.reverting end
def run(*migration_classes)
- +:direction+ - Default is +:up+.
Last argument can specify options:
Runs the given migration classes.
def run(*migration_classes) opts = migration_classes.extract_options! dir = opts[:direction] || :up dir = (dir == :down ? :up : :down) if opts[:revert] if reverting? # If in revert and going :up, say, we want to execute :down without reverting, so revert { run(*migration_classes, direction: dir, revert: true) } else migration_classes.each do |migration_class| migration_class.new.exec_migration(connection, dir) end end end
def say(message, subitem = false)
Takes a message argument and outputs it as is.
def say(message, subitem = false) write "#{subitem ? " ->" : "--"} #{message}" end
def say_with_time(message)
Outputs text along with how long it took to run its block.
def say_with_time(message) say(message) result = nil time = Benchmark.measure { result = yield } say "%.4fs" % time.real, :subitem say("#{result} rows", :subitem) if result.is_a?(Integer) result end
def suppress_messages
def suppress_messages save, self.verbose = verbose, false yield ensure self.verbose = save end
def table_name_options(config = ActiveRecord::Base) # :nodoc:
the Active Record object's table_name prefix and suffix
Builds a hash for use in ActiveRecord::Migration#proper_table_name using
def table_name_options(config = ActiveRecord::Base) # :nodoc: { table_name_prefix: config.table_name_prefix, table_name_suffix: config.table_name_suffix } end
def up
def up self.class.delegate = self return unless self.class.respond_to?(:up) self.class.up end
def up_only(&block)
end
end
execute "update posts set published = 'true'"
up_only do
add_column :posts, :published, :boolean, default: false
def change
class AddPublishedToPosts < ActiveRecord::Migration[7.0]
the value +true+ for all existing records.
In the following example, the new column +published+ will be given
(for example, populating a new column with its initial values).
Used to specify an operation that is only run when migrating up
def up_only(&block) execute_block(&block) unless reverting? end
def write(text = "")
def write(text = "") puts(text) if verbose end