collocate postgres migrations

integration_test/pg/migration.exs

@@ -0,0 +1,57 @@
+defmodule Flop.Repo.Postgres.Migration do
+  use Ecto.Migration
+
+  def change do
+    execute(
+      "CREATE TYPE public.distance AS (unit varchar, value float);",
+      "DROP TYPE public.distance;"
+    )
+
+    create table(:owners) do
+      add(:age, :integer)
+      add(:email, :string)
+      add(:name, :string)
+      add(:tags, {:array, :string})
+      add(:attributes, :map)
+      add(:extra, {:map, :string})
+    end
+
+    create table(:pets) do
+      add(:age, :integer)
+      add(:family_name, :string)
+      add(:given_name, :string)
+      add(:name, :string)
+      add(:owner_id, references(:owners))
+      add(:species, :string)
+      add(:mood, :string)
+      add(:tags, {:array, :string})
+    end
+
+    create table(:fruits) do
+      add(:family, :string)
+      add(:name, :string)
+      add(:attributes, :map)
+      add(:extra, {:map, :string})
+      add(:owner_id, references(:owners))
+    end
+
+    create table(:walking_distances) do
+      add(:trip, :distance)
+    end
+
+    # create pets table in other schema
+
+    execute("CREATE SCHEMA other_schema;", "DROP SCHEMA other_schema;")
+
+    create table(:pets, prefix: "other_schema") do
+      add(:age, :integer)
+      add(:family_name, :string)
+      add(:given_name, :string)
+      add(:name, :string)
+      add(:owner_id, :integer)
+      add(:species, :string)
+      add(:mood, :string)
+      add(:tags, {:array, :string})
+    end
+  end
+end

integration_test/pg/test_helper.exs

@@ -23,16 +23,19 @@ defmodule Flop.Integration.Case do
   end
 end
 
+Code.require_file("migration.exs", __DIR__)
+
 {:ok, _} =
   Ecto.Adapters.Postgres.ensure_all_started(Flop.Repo.config(), :temporary)
 
 # Load up the repository, start it, and run migrations
-_ = Ecto.Adapters.Postgres.storage_down(Flop.Repo.config())
-:ok = Ecto.Adapters.Postgres.storage_up(Flop.Repo.config())
+Ecto.Adapters.Postgres.storage_down(Flop.Repo.config())
+Ecto.Adapters.Postgres.storage_up(Flop.Repo.config())
 
 {:ok, _pid} = Flop.Repo.start_link()
 
-[_ | _] = Ecto.Migrator.run(Flop.Repo, :up, log: true, all: true)
+Ecto.Migrator.up(Flop.Repo, 0, Flop.Repo.Postgres.Migration, log: true)
+
 Ecto.Adapters.SQL.Sandbox.mode(Flop.Repo, :manual)
 
 {:ok, _} = Application.ensure_all_started(:ex_machina)

integration_test/sqlite/migration.exs

@@ -1,4 +1,4 @@
-defmodule Flop.Repo.SQLite.Migration do
+defmodule Flop.Repo.Postgres.Migration do
   use Ecto.Migration
 
   def change do