Elixir Ecto: 多数据库跨库查询

这篇文章说明了如何在Elixir应用程序中使用多个Repo. Repo可以是不同的数据库, 运行在不同的操作系统上. 本文以一个收藏夹的应用来展示如何在Elixir应用程序中使用多个库进行跨库操作.

为什么需要多个库

我们已经开发了一套系统, 但是这套系统是构建在老的系统上的, 现在我们需要对这套写进行扩展, 增加一些新的功能, 并且需要采用新的技术, 老的系统有一些我们构建这个心的系统需要的数据, 存储在MySQL中, 新的系统我们决定采用Postgresql 进行开发, 因此我们可以在Phoenix应用程序中定义两个库, 配置(config/dev.exs)如下:

use Mix.Config

config :test, Test.LegacyRepo,
  adapter: Ecto.Adapters.MySQL,
  database: "legacy_db",
  username: "postgres",
  password: "postgres",
  hostname: "localhost"

config :test, Test.NewRepo,
  adapter: Ecto.Adapters.Postgres,
  database: "new_db",  
  username: "postgres",
  password: "postgres",
  hostname: "localhost"
  
config :Test, ecto_repos: [Test.LegacyRepo, Test.NewRepo]

把两个库添加到监控树中:

defmodule Test do
  use Application
  def start(_type, _args) do
    import Supervisor.Spec, warn: false
    children = [
      supervisor(Test.LegacyRepo, []), # 遗留系统数据库Repo模块
      supervisor(Test.NewRepo, [])     # 新系统数据库Repo模块
    ]
    opts = [strategy: :one_for_one, name: Test.Supervisor]
    Supervisor.start_link(children, opts)
  end
end

定义Repos

defmodule Test.LegacyRepo do
 use Ecto.Repo, otp_app: :test
end

defmodule Test.NewRepo do
 use Ecto.Repo, otp_app: :test
end

定义用户模型

defmodule Test.Model.User do
  use Ecto.Schema

  schema "users" do
    field :username, :string
    has_many :favorites, Favorite
    timestamps
  end
end

定义收藏夹模型

defmodule Test.Model.Favorite do
  use Ecto.Schema
  
  schema "favorites" do
    field :value, :string
    belongs_to :user, User
    timestamps
  end
end

如何使用

iex> import Ecto.Query
iex> user = Test.LegacyRepo.get_by(User, %{username: "Geo"})
iex> favorites = from(fav in Favorite, where: fav.user_id == ^user.id) |> Test.NewRepo.all

注意

config :Test, ecto_repos: [
  Test.LegacyRepo, 
  Test.NewRepo
  ]

由于在我们的应用程序中配置了多个库, 在执行 mix ecto.migrate, mix ecto.rollback 等 Ecto 命令的时候需要指定 -r 参数, 例如:

mix ecto.migrate -r Test.NewRepo