Eliir 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.Queryiex> 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关键字：elixir, ecto
版权声明
本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处。如若内容有涉嫌抄袭侵权/违法违规/事实不符，请点击 举报 进行投诉反馈！
