EctoBootMigration (ecto_boot_migration v0.3.0)

Helper module that can be used to easily ensure that Ecto database was migrated before rest of the application was started.

Rationale

There are many strategies how to deal with this issue, e.g. see https://hexdocs.pm/distillery/guides/running_migrations.html

However, if you have any workers that are relying on the DB schema that are launched upon boot with some methods, such as release post_start hooks you can easily enter race condition. Application may crash as these workers will not find tables or columns they expect and it will happen sooner than the post_start hook script will send the commands to the the application process.

In stateless environments such as Docker it is just sometimes more convenient to perform migration upon boot. This is exactly what this library does.

Currently it works only with PostgreSQL databases but that will be easy to extend.

Usage

defmodule MyApp do
  use Application

  def start(_type, _args) do
    import Supervisor.Spec, warn: false

    {:ok, _} = EctoBootMigration.migrate(:my_app)

    children = [
      supervisor(MyApp.Endpoint, []),
      worker(MyApp.Repo, []),
    ]
    Supervisor.start_link(children, [strategy: :one_for_one, name: MyApp.Supervisor])
  end
end

Credits

Inspired by https://github.com/bitwalker/distillery/blob/master/docs/Running Migrations.md

Link to this section Summary

Functions

Tries to run migrations.

Tries to run migrations.

Start apps necessary for executing migrations

Start the Repo(s) for app, returns pids

Link to this section Functions

Specs

migrate(any()) ::
  {:ok, :noop} | {:ok, {:migrated, [pos_integer()]}} | {:error, any()}

Tries to run migrations.

Returns {:ok, {:migrated, list_of_migration_ids}} if any migrations have happened.

Returns {:ok, :noop} if no migrations have happened.

Returns {:error, reason} if error occured.

Specs

migrated?(any()) :: boolean()

Tries to run migrations.

Returns true if any migrations have happened.

Returns false if no migrations have happened.

Throws if error occured.

Link to this function

run_migrations(repos)

Link to this function

start_dependencies()

Start apps necessary for executing migrations

Link to this function

start_repos(repos)

Start the Repo(s) for app, returns pids

Link to this function

stop_repos(repos_pids)