为何Repo.transaction/2闭包与Multi.run/3需传入Repo实例？

Repo.transaction/2 可接收一个接收Repo实例的一元函数：

MyRepo.transaction(fn repo ->
  repo.insert!(%Post{})
end)

但为何需要传入这个Repo实例？为何不能在事务内直接使用Repo.insert!/1这类实现回调？例如：

MyRepo.transaction(fn _repo ->
  MyRepo.insert!(%Post{})
end)

同样的问题也适用于Multi.run/3，它同样会传入Repo实例。

核心原因：绑定当前事务的专属连接 #

Ecto开启事务时，会从数据库连接池获取专属的事务连接，这个连接会被绑定到传入的repo实例中。如果直接调用MyRepo.insert!/1，它会重新从连接池获取新连接——这个新连接不在当前事务上下文内，相当于在事务外部执行操作，完全无法保证事务的原子性。

举个实际例子：假设你在事务中先插入一条数据，接着做业务判断后决定回滚。如果用MyRepo.insert!/1，那这条插入操作已经在独立连接上执行完毕，回滚操作根本影响不到它，数据会被永久保留在数据库里，彻底破坏了事务的一致性。

除此之外，传入Repo实例还带来两个额外好处：

• 灵活性更高：你可以在事务逻辑中动态切换Repo（比如测试环境使用模拟Repo），或者把事务逻辑封装成通用函数，不用硬编码具体的Repo模块名。
• 语义更清晰：明确标识出当前操作是在事务上下文内执行的，避免混淆事务内/外的数据库操作。

Multi.run/3的逻辑和事务完全一致——Multi是用来组合多个事务性操作的工具，必须确保所有操作都复用同一个事务连接，因此也需要传入绑定了当前事务连接的Repo实例。

内容的提问来源于stack exchange，提问作者vaer-k