Packages
ecto
3.13.6
3.14.1
3.14.0
3.13.6
3.13.5
3.13.4
3.13.3
3.13.2
3.13.1
3.13.0
3.12.6
3.12.5
3.12.4
3.12.3
3.12.2
3.12.1
3.12.0
3.11.2
3.11.1
3.11.0
3.10.3
3.10.2
3.10.1
3.10.0
3.9.6
3.9.5
3.9.4
3.9.3
3.9.2
3.9.1
3.9.0
3.8.4
3.8.3
3.8.2
3.8.1
3.8.0
3.7.2
3.7.1
3.7.0
3.6.2
3.6.1
3.6.0
3.5.8
3.5.7
3.5.6
3.5.5
3.5.4
3.5.3
3.5.2
3.5.1
3.5.0
3.5.0-rc.1
3.5.0-rc.0
3.4.6
3.4.5
3.4.4
3.4.3
3.4.2
3.4.1
3.4.0
3.3.4
3.3.3
3.3.2
3.3.1
3.3.0
3.2.5
3.2.4
3.2.3
3.2.2
3.2.1
3.2.0
3.1.7
3.1.6
3.1.5
3.1.4
3.1.3
3.1.2
3.1.1
3.1.0
3.0.9
3.0.8
3.0.7
3.0.6
3.0.5
3.0.4
3.0.3
3.0.2
3.0.1
3.0.0
3.0.0-rc.1
3.0.0-rc.0
2.2.12
2.2.11
2.2.10
2.2.9
2.2.8
2.2.7
2.2.6
2.2.5
2.2.4
2.2.3
2.2.2
2.2.1
2.2.0
2.2.0-rc.1
2.2.0-rc.0
2.1.6
2.1.5
2.1.4
2.1.3
2.1.2
2.1.1
2.1.0
2.1.0-rc.5
2.1.0-rc.4
2.1.0-rc.3
2.1.0-rc.2
2.1.0-rc.1
2.1.0-rc.0
2.0.6
2.0.5
2.0.4
2.0.3
2.0.2
2.0.1
2.0.0
2.0.0-rc.6
2.0.0-rc.5
2.0.0-rc.4
2.0.0-rc.3
2.0.0-rc.2
2.0.0-rc.1
2.0.0-rc.0
2.0.0-beta.2
2.0.0-beta.1
2.0.0-beta.0
1.1.9
1.1.8
1.1.7
1.1.6
1.1.5
1.1.4
1.1.3
1.1.2
1.1.1
1.1.0
1.0.7
1.0.6
1.0.5
1.0.4
1.0.3
1.0.2
1.0.1
1.0.0
0.16.0
0.15.0
0.14.3
0.14.2
0.14.1
0.14.0
0.13.1
0.13.0
0.12.1
0.12.0
0.12.0-rc
0.11.3
0.11.2
0.11.1
0.11.0
0.10.3
0.10.2
0.10.1
0.10.0
0.9.0
0.8.1
0.8.0
0.7.2
0.7.1
0.7.0
0.6.0
0.5.1
0.5.0
0.4.0
0.3.0
0.2.8
0.2.7
0.2.6
0.2.5
0.2.4
0.2.3
0.2.2
0.2.1
0.2.0
0.1.0
A toolkit for data mapping and language integrated query for Elixir
Current section
Files
Jump to
Current section
Files
lib/ecto/repo/transaction.ex
defmodule Ecto.Repo.Transaction do
@moduledoc false
@dialyzer :no_opaque
def transact(repo, name, fun, adapter_opts) when is_function(fun, 0) do
transact(repo, name, fn _repo -> fun.() end, adapter_opts)
end
def transact(repo, _name, fun, {adapter_meta, opts}) when is_function(fun, 1) do
adapter_meta.adapter.transaction(adapter_meta, opts, fn ->
case fun.(repo) do
{:ok, result} ->
result
{:error, reason} ->
adapter_meta.adapter.rollback(adapter_meta, reason)
other ->
raise ArgumentError,
"expected to return {:ok, _} or {:error, _}, got: #{inspect(other)}"
end
end)
end
def transact(repo, _name, %Ecto.Multi{} = multi, {adapter_meta, opts}) do
%{adapter: adapter} = adapter_meta
wrap = &adapter.transaction(adapter_meta, opts, &1)
return = &adapter.rollback(adapter_meta, &1)
case Ecto.Multi.__apply__(multi, repo, wrap, return) do
{:ok, values} ->
{:ok, values}
{:error, {key, error_value, values}} ->
{:error, key, error_value, values}
{:error, operation} ->
raise """
operation #{inspect(operation)} is rolling back unexpectedly.
This can happen if `repo.rollback/1` is manually called, which is not \
supported by `Ecto.Multi`. It can also occur if a nested transaction \
has rolled back and its error is not bubbled up to the outer multi. \
Nested transactions are discouraged when using `Ecto.Multi`. Consider \
flattening out the transaction instead.
"""
end
end
def in_transaction?(name) do
%{adapter: adapter} = meta = Ecto.Repo.Registry.lookup(name)
adapter.in_transaction?(meta)
end
def rollback(name, value) do
%{adapter: adapter} = meta = Ecto.Repo.Registry.lookup(name)
adapter.rollback(meta, value)
end
end