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 Migrations
ActiveRecord::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 you
bin/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 table
bin/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:

: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)

Raises ActiveRecord::PendingMigrationError error if any migrations are pending.
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:

:nodoc:
def disable_ddl_transaction # :nodoc:
  self.class.disable_ddl_transaction
end

def disable_ddl_transaction!

For more details read the {"Transactional Migrations" section above}[rdoc-ref:Migration].

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.

:nodoc:
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:

: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)

Execute this migration in the named 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:

:nodoc:
def nearest_delegate # :nodoc:
  delegate || superclass.nearest_delegate
end

def next_migration_number(number)

Determines the version number of the next migration.
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 = {})

options passed in.
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
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)

This command can be nested.

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)

- +:revert+ - Default is +false+.
- +: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)

A second boolean argument can be passed to specify whether to indent or not.
Takes a message argument and outputs it as is.
def say(message, subitem = false)
  write "#{subitem ? "   ->" : "--"} #{message}"
end

def say_with_time(message)

If the block returns an integer it assumes it is the number of rows affected.
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

Takes a block as an argument and suppresses any output generated by the block.
def suppress_messages
  save, self.verbose = verbose, false
  yield
ensure
  self.verbose = save
end

def table_name_options(config = ActiveRecord::Base) # :nodoc:

: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
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