Elixir Ecto：如何在多对多关系中存储元信息

你找对方向了！在Ecto里给多对多关系添加元信息，**关联模式（join schema）**就是标准解决方案，我来帮你把代码补全，再详细讲讲怎么操作和查询这些元信息。

首先要创建一个专门的关联模型，用来存储用户和组织之间的元信息。这里我把你的代码补全，加上时间戳和完整的关联定义：

defmodule MyApp.UserOrganization do
  use Ecto.Schema
  import Ecto.Changeset

  # 这个表不需要独立主键，用user_id和organization_id联合做主键
  @primary_key false
  schema "users_organizations" do
    field :position, :string  # 职位字段
    field :joined_at, :utc_datetime_usec  # 自定义时间戳，也可以用Ecto自带的timestamps()

    # 关联到User和Organization主模型
    belongs_to :user, MyApp.User
    belongs_to :organization, MyApp.Organization
  end

  def changeset(user_organization, attrs) do
    user_organization
    |> cast(attrs, [:position, :joined_at, :user_id, :organization_id])
    |> validate_required([:user_id, :organization_id])  # 必须关联两个主模型
  end
end

接下来要修改User和Organization模型，更新它们的多对多关联，指定使用这个join schema：

User模型 #

defmodule MyApp.User do
  use Ecto.Schema
  import Ecto.Changeset

  schema "users" do
    field :name, :string
    # 配置多对多关联，指定join_through为我们的关联模型
    many_to_many :organizations, MyApp.Organization,
      join_through: MyApp.UserOrganization,
      join_keys: [user_id: :id, organization_id: :id]

    timestamps()
  end
end

Organization模型 #

defmodule MyApp.Organization do
  use Ecto.Schema
  import Ecto.Changeset

  schema "organizations" do
    field :name, :string
    many_to_many :users, MyApp.User,
      join_through: MyApp.UserOrganization,
      join_keys: [organization_id: :id, user_id: :id]

    timestamps()
  end
end

最后别忘了创建对应的迁移文件，生成关联表：

defmodule MyApp.Repo.Migrations.CreateUserOrganizations do
  use Ecto.Migration

  def change do
    create table(:users_organizations, primary_key: false) do
      add :position, :string
      add :joined_at, :utc_datetime_usec
      # 用user_id和organization_id作为联合主键
      add :user_id, references(:users, on_delete: :delete_all), primary_key: true
      add :organization_id, references(:organizations, on_delete: :delete_all), primary_key: true
    end

    # 添加索引提升查询效率
    create index(:users_organizations, [:user_id])
    create index(:users_organizations, [:organization_id])
  end
end

要给用户和组织建立关联并添加元信息，最直接的方式是直接创建UserOrganization记录：

# 先获取要关联的用户和组织
user = Repo.get(MyApp.User, 1)
organization = Repo.get(MyApp.Organization, 1)

# 创建并插入关联记录，同时设置职位和加入时间
%MyApp.UserOrganization{
  user_id: user.id,
  organization_id: organization.id,
  position: "Software Engineer",
  joined_at: DateTime.utc_now()
} |> MyApp.Repo.insert!()

如果想用changeset的方式操作，也可以，但要注意put_assoc不会自动处理join schema的额外字段，所以还是直接操作关联模型更清晰。

查询元信息有几种常见场景，我分别举例：

场景1：加载用户及其所有组织的元信息 #

用Repo.preload加载关联时，可以同时加载关联模型的元信息：

# 加载用户、用户的组织，以及每个组织对应的关联元信息
user = MyApp.Repo.get(MyApp.User, 1) 
|> MyApp.Repo.preload([organizations: [:user_organizations]])

# 遍历用户的组织，获取对应的职位和加入时间
for organization <- user.organizations do
  # 找到当前用户和该组织的关联记录
  user_org = Enum.find(organization.user_organizations, &(&1.user_id == user.id))
  IO.puts("组织：#{organization.name}，职位：#{user_org.position}，加入时间：#{user_org.joined_at}")
end

场景2：直接查询用户+组织+元信息的组合（更高效） #

如果不需要加载完整的模型，用Ecto.Query直接查询关联表会更高效：

query = 
  from u in MyApp.User,
    where: u.id == ^user_id,
    join: uo in MyApp.UserOrganization, on: uo.user_id == u.id,
    join: o in MyApp.Organization, on: o.id == uo.organization_id,
    select: {u.name, o.name, uo.position, uo.joined_at}

# 查询结果是包含用户名、组织名、职位、加入时间的元组列表
results = MyApp.Repo.all(query)

场景3：查询某个用户在特定组织的职位 #

要快速获取单个关联的元信息，可以直接查询UserOrganization：

position = 
  from uo in MyApp.UserOrganization,
    where: uo.user_id == ^user_id and uo.organization_id == ^org_id,
    select: uo.position
  |> MyApp.Repo.one()

更新元信息也很简单，找到对应的UserOrganization记录后用changeset更新即可：

# 根据用户ID和组织ID找到关联记录
user_org = MyApp.Repo.get_by(MyApp.UserOrganization, user_id: 1, organization_id: 1)

# 更新职位信息
user_org
|> MyApp.UserOrganization.changeset(%{position: "Senior Software Engineer"})
|> MyApp.Repo.update!()

这样整个流程就覆盖了创建、查询、更新带元信息的多对多关联，完全符合你的需求。

内容的提问来源于stack exchange，提问作者Ole Spaarmann