这篇文章以 Ecto 2.0 为例，讲述了怎么 read, insert, update and delete associations 和 embeds。这篇文章需要你对 Ecto 的 repositories, schema and the query syntax
有基本了解。不太了解可以参考文档 Ecto docs。
Associations
Ecto中的Associations是两张数据表通过外键连接 foreign keys。
这里以 Post 和 Comments 为例，首先创建两张表的migrations：
create table(:posts) do
add :title, :string
add :body, :text
timestamps
end
create table(:comments) do
add :post_id, references(:posts)
add :body, :text
timestamps
end
每个 comment 包含一个 post_id 默认指向了 post 表的 id 。
然后定义 schema
defmodule MyApp.Post do
use Ecto.Schema
schema "posts" do
field :title
field :body
has_many :comments, MyApp.Comment
timestamps
end
end
defmodule MyApp.Comment do
use Ecto.Schema
schema "comments" do
field :body
belongs_to :post, MyApp.Post
timestamps
end
end
所有 schema definitions 像 field, has_many 和其他都在 Ecto.Schema
中定义
与 has_many/3 相类似， has_one/3 定义了父表至多有一个子条目。可以用metadata举例 Post has one metadata 并且 Metadata belongs to post
has_one/3 和 belongs_to/3 的区别就是 foreign key 一直定义在 belongs_to/3 的 schema 中。你可以认为 has_* 是父表，而 belongs_to 是子表。
查询关联关系
Repo.all from p in Post,
preload: [:comments]
定义关联的一个好处就是你可以在查询中使用。
现在所有的posts都会伴随着相应的comments被提取出数据库。
它包含两个查询，一个提取posts，一个提取comments
这通常是关联数据的最简单查询方法，即使只有两个。
我们只需要接受和处理 POSTS + COMMENTS
同样，我们也可以使用join来查询关联数据
Repo.all from p in Post,
join: c in assoc(p, :comments),
where: c.votes > p.votes
preload: [comments: c]
上述例子执行一个查询，找到所有的posts和对应的满足条件的comments。由于查询有个JOIN，所以返回的数据量是POSTS * COMMENTS，Ecto之后再处理和关联评论到相应的post。
最后，Ecto允许你将数据预加载到结构体中
Repo.preload posts, :comments
操作关联
你可以使用一条命令插入多个comment
Repo.insert!(%Post{
title: "Hello",
body: "world",
comments: [
%Comment{body: "Excellent!"}
]
})
你也可以使用changeset
post = Ecto.Changeset.change(%Post{}, title: "Hello", body: "world")
comment = Ecto.Changeset.change(%Comment{}, body: "Excellent!")
post_with_comments = Ecto.Changeset.put_assoc(post, :comments, [comment])
Repo.insert!(post_with_comments)
或者使用transaction
Repo.transaction fn ->
post = Repo.insert!(%Post{title: "Hello", body: "world"})
# Build a comment from the post struct
comment = Ecto.build_assoc(post, :comments, body: "Excellent!")
Repo.insert!(comment)
end
Embed
Embed 与 Assoc 不同的是，child被存储在parent中，而不是被存在另一个单独表里。
像PostgreSQL这种数据库使用JSONB(embeds_one/3) 和数组列来提供这种功能，JSONB和ARRAY都是Ecto默认支持的一等公民。
defmodule MyApp.Permalink do
use Ecto.Schema
embedded_schema do
field :url
timestamps
end
end
defmodule MyApp.Post do
use Ecto.Schema
schema "posts" do
field :title
field :body
has_many :comments, MyApp.Comment
embeds_many :permalinks, MyApp.Permalink
timestamps
end
end
Repo.insert!(%Post{
title: "Hello",
permalinks: [
%Permalink{url: "example.com/thebest"},
%Permalink{url: "another.com/mostaccessed"}
]
})
你也可以用changesets来
# Generate a changeset for the post
changeset = Ecto.Changeset.change(post)
# Let's track the new permalinks
changeset = Ecto.Changeset.put_embed(changeset, :permalinks,
[%Permalink{url: "example.com/thebest"},
%Permalink{url: "another.com/mostaccessed"}]
)
# Now insert the post with permalinks at once
post = Repo.insert!(changeset)
# Remove all permalinks from example.com
permalinks = Enum.reject post.permalinks, fn permalink ->
permalink.url =~ "example.com"
end
# Let's create a new changeset
changeset =
post
|> Ecto.Changeset.change
|> Ecto.Changeset.put_embed(:permalinks, permalinks)
# And update the entry
post = Repo.update!(changeset)
http://blog.plataformatec.com.br/2015/08/working-with-ecto-associations-and-embeds/
