Search documentation of op

# Op.Repo (op v0.1.0)

# Summary

## Functions

aggregate(queryable, aggregate, opts \\ [])

Callback implementation for `Ecto.Repo.aggregate/3`.

aggregate(queryable, aggregate, field, opts)

Callback implementation for `Ecto.Repo.aggregate/4`.

all(queryable, opts \\ [])

Callback implementation for `Ecto.Repo.all/2`.

all_by(queryable, clauses, opts \\ [])

Callback implementation for `Ecto.Repo.all_by/3`.

all_tenants()

Callback implementation for `AshPostgres.Repo.all_tenants/0`.

checked_out?()

Callback implementation for `Ecto.Repo.checked_out?/0`.

checkout(fun, opts \\ [])

Callback implementation for `Ecto.Repo.checkout/2`.

child_spec(opts)
config()

Callback implementation for `Ecto.Repo.config/0`.

create?()

Callback implementation for `AshPostgres.Repo.create?/0`.

create_schemas_in_migrations?()

Callback implementation for `AshPostgres.Repo.create_schemas_in_migrations?/0`.

default_constraint_match_type(type, name)

Callback implementation for `AshPostgres.Repo.default_constraint_match_type/2`.

default_options(operation)

Callback implementation for `Ecto.Repo.default_options/1`.

default_prefix()

Callback implementation for `AshPostgres.Repo.default_prefix/0`.

delete(struct, opts \\ [])

Callback implementation for `Ecto.Repo.delete/2`.

delete!(struct, opts \\ [])

Callback implementation for `Ecto.Repo.delete!/2`.

delete_all(queryable, opts \\ [])

Callback implementation for `Ecto.Repo.delete_all/2`.

disable_atomic_actions?()

Callback implementation for `AshPostgres.Repo.disable_atomic_actions?/0`.

disable_expr_error?()

Callback implementation for `AshPostgres.Repo.disable_expr_error?/0`.

disconnect_all(interval, opts \\ [])

Forces all connections in the repo pool to disconnect within the given interval.

drop?()

Callback implementation for `AshPostgres.Repo.drop?/0`.

exists?(queryable, opts \\ [])

Callback implementation for `Ecto.Repo.exists?/2`.

explain(operation, queryable, opts \\ [])

Executes an EXPLAIN statement or similar for the given query according to its kind and the adapter in the given repository.

from_ecto(other)
get(queryable, id, opts \\ [])

Callback implementation for `Ecto.Repo.get/3`.

get!(queryable, id, opts \\ [])

Callback implementation for `Ecto.Repo.get!/3`.

get_by(queryable, clauses, opts \\ [])

Callback implementation for `Ecto.Repo.get_by/3`.

get_by!(queryable, clauses, opts \\ [])

Callback implementation for `Ecto.Repo.get_by!/3`.

get_dynamic_repo()

Callback implementation for `Ecto.Repo.get_dynamic_repo/0`.

in_transaction?()

Callback implementation for `Ecto.Repo.in_transaction?/0`.

init(type, config)

Callback implementation for `Ecto.Repo.init/2`.

insert(struct, opts \\ [])

Callback implementation for `Ecto.Repo.insert/2`.

insert!(struct, opts \\ [])

Callback implementation for `Ecto.Repo.insert!/2`.

insert_all(schema_or_source, entries, opts \\ [])

Callback implementation for `Ecto.Repo.insert_all/3`.

insert_or_update(changeset, opts \\ [])

Callback implementation for `Ecto.Repo.insert_or_update/2`.

insert_or_update!(changeset, opts \\ [])

Callback implementation for `Ecto.Repo.insert_or_update!/2`.

load(schema_or_types, data)

Callback implementation for `Ecto.Repo.load/2`.

migrations_path()

Callback implementation for `AshPostgres.Repo.migrations_path/0`.

on_transaction_begin(reason)

Callback implementation for `AshPostgres.Repo.on_transaction_begin/1`.

one(queryable, opts \\ [])

Callback implementation for `Ecto.Repo.one/2`.

one!(queryable, opts \\ [])

Callback implementation for `Ecto.Repo.one!/2`.

override_migration_type(type)

Callback implementation for `AshPostgres.Repo.override_migration_type/1`.

prefer_transaction_for_atomic_updates?()

Callback implementation for `AshPostgres.Repo.prefer_transaction_for_atomic_updates?/0`.

preload(struct_or_structs_or_nil, preloads, opts \\ [])

Callback implementation for `Ecto.Repo.preload/3`.

prepare_query(operation, query, opts)

Callback implementation for `Ecto.Repo.prepare_query/3`.

prepare_transaction(fun_or_multi, opts)

Callback implementation for `Ecto.Repo.prepare_transaction/2`.

put_dynamic_repo(dynamic)

Callback implementation for `Ecto.Repo.put_dynamic_repo/1`.

query(sql, params \\ [], opts \\ [])

Runs a custom SQL query.

query!(sql, params \\ [], opts \\ [])

Same as `query/3` but returns result directly without `:ok` tuple and raises on invalid queries

query_many(sql, params \\ [], opts \\ [])

Runs a custom SQL query that returns multiple results on the given repo.

query_many!(sql, params \\ [], opts \\ [])

Same as `query_many/4` but returns result directly without `:ok` tuple and raises on invalid queries

reload(queryable, opts \\ [])

Callback implementation for `Ecto.Repo.reload/2`.

reload!(queryable, opts \\ [])

Callback implementation for `Ecto.Repo.reload!/2`.

rollback(value)

Callback implementation for `Ecto.Repo.rollback/1`.

start_link(opts \\ [])

Callback implementation for `Ecto.Repo.start_link/1`.

stop(timeout \\ 5000)

Callback implementation for `Ecto.Repo.stop/1`.

stream(queryable, opts \\ [])

Callback implementation for `Ecto.Repo.stream/2`.

tenant_migrations_path()

Callback implementation for `AshPostgres.Repo.tenant_migrations_path/0`.

to_ecto(value)
to_sql(operation, queryable)

Converts the given query to SQL according to its kind and the adapter in the given repository.

transact(fun_or_multi, opts \\ [])

Callback implementation for `Ecto.Repo.transact/2`.

transaction(fun_or_multi, opts \\ [])

Callback implementation for `Ecto.Repo.transaction/2`.

transaction!(fun)
update(struct, opts \\ [])

Callback implementation for `Ecto.Repo.update/2`.

update!(struct, opts \\ [])

Callback implementation for `Ecto.Repo.update!/2`.

update_all(queryable, updates, opts \\ [])

Callback implementation for `Ecto.Repo.update_all/3`.

# Functions

# aggregate(queryable, aggregate, opts \\ [])

Callback implementation for `Ecto.Repo.aggregate/3`.

# aggregate(queryable, aggregate, field, opts)

Callback implementation for `Ecto.Repo.aggregate/4`.

# all(queryable, opts \\ [])

Callback implementation for `Ecto.Repo.all/2`.

# all_by(queryable, clauses, opts \\ [])

Callback implementation for `Ecto.Repo.all_by/3`.

# all_tenants()

Callback implementation for `AshPostgres.Repo.all_tenants/0`.

# checked_out?()

Callback implementation for `Ecto.Repo.checked_out?/0`.

# checkout(fun, opts \\ [])

Callback implementation for `Ecto.Repo.checkout/2`.

# child_spec(opts)

# config()

Callback implementation for `Ecto.Repo.config/0`.

# create?()

Callback implementation for `AshPostgres.Repo.create?/0`.

# create_schemas_in_migrations?()

Callback implementation for `AshPostgres.Repo.create_schemas_in_migrations?/0`.

# default_constraint_match_type(type, name)

Callback implementation for `AshPostgres.Repo.default_constraint_match_type/2`.

# default_options(operation)

Callback implementation for `Ecto.Repo.default_options/1`.

# default_prefix()

Callback implementation for `AshPostgres.Repo.default_prefix/0`.

# delete(struct, opts \\ [])

Callback implementation for `Ecto.Repo.delete/2`.

# delete!(struct, opts \\ [])

Callback implementation for `Ecto.Repo.delete!/2`.

# delete_all(queryable, opts \\ [])

Callback implementation for `Ecto.Repo.delete_all/2`.

# disable_atomic_actions?()

Callback implementation for `AshPostgres.Repo.disable_atomic_actions?/0`.

# disable_expr_error?()

Callback implementation for `AshPostgres.Repo.disable_expr_error?/0`.

# disconnect_all(interval, opts \\ [])

    @spec disconnect_all(non_neg_integer(), opts :: Keyword.t()) :: :ok

Forces all connections in the repo pool to disconnect within the given interval.

Once this function is called, the pool will disconnect all of its connections as they are checked in or as they are pinged. Checked in connections will be randomly disconnected within the given time interval. Pinged connections are immediately disconnected - as they are idle (according to `:idle_interval`).

If the connection has a backoff configured (which is the case by default), disconnecting means an attempt at a new connection will be done immediately after, without starting a new process for each connection. However, if backoff has been disabled, the connection process will terminate. In such cases, disconnecting all connections may cause the pool supervisor to restart depending on the max_restarts/max_seconds configuration of the pool, so you will want to set those carefully.

# drop?()

Callback implementation for `AshPostgres.Repo.drop?/0`.

# exists?(queryable, opts \\ [])

Callback implementation for `Ecto.Repo.exists?/2`.

# explain(operation, queryable, opts \\ [])

    @spec explain(
      :all | :update_all | :delete_all,
      Ecto.Queryable.t(),
      opts :: Keyword.t()
    ) ::
      String.t() | Exception.t() | [map()]

Executes an EXPLAIN statement or similar for the given query according to its kind and the adapter in the given repository.

## Examples

    # Postgres
    iex> MyRepo.explain(:all, Post)
    "Seq Scan on posts p0  (cost=0.00..12.12 rows=1 width=443)"

    iex> Ecto.Adapters.SQL.explain(Repo, :all, Post)
    "Seq Scan on posts p0  (cost=0.00..12.12 rows=1 width=443)"

    # MySQL
    iex> MyRepo.explain(:all, from(p in Post, where: p.title == "title")) |> IO.puts()
    +----+-------------+-------+------------+------+---------------+------+---------+------+------+----------+-------------+
    | id | select_type | table | partitions | type | possible_keys | key  | key_len | ref  | rows | filtered | Extra       |
    +----+-------------+-------+------------+------+---------------+------+---------+------+------+----------+-------------+
    |  1 | SIMPLE      | p0    | NULL       | ALL  | NULL          | NULL | NULL    | NULL |    1 |    100.0 | Using where |
    +----+-------------+-------+------------+------+---------------+------+---------+------+------+----------+-------------+

    # Shared opts
    iex> MyRepo.explain(:all, Post, analyze: true, timeout: 20_000)
    "Seq Scan on posts p0  (cost=0.00..11.70 rows=170 width=443) (actual time=0.013..0.013 rows=0 loops=1)\nPlanning Time: 0.031 ms\nExecution Time: 0.021 ms"

It's safe to execute it for updates and deletes, no data change will be committed:

    iex> MyRepo.explain(Repo, :update_all, from(p in Post, update: [set: [title: "new title"]]))
    "Update on posts p0  (cost=0.00..11.70 rows=170 width=449)\n  ->  Seq Scan on posts p0  (cost=0.00..11.70 rows=170 width=449)"

This function is also available under the repository with name `explain`:

    iex> MyRepo.explain(:all, from(p in Post, where: p.title == "title"))
    "Seq Scan on posts p0  (cost=0.00..12.12 rows=1 width=443)\n  Filter: ((title)::text = 'title'::text)"

### Options

Built-in adapters support passing `opts` to the EXPLAIN statement according to the following:

Adapter | Supported opts
--- | ---
Postgrex | `analyze`, `verbose`, `costs`, `settings`, `buffers`, `timing`, `summary`, `format`, `plan`
MyXQL | `format`

All options except `format` are boolean valued and default to `false`.

The allowed `format` values are `:map`, `:yaml`, and `:text`:

- `:map` is the deserialized JSON encoding.
- `:yaml` and `:text` return the result as a string.

The built-in adapters support the following formats:

- Postgrex: `:map`, `:yaml` and `:text`
- MyXQL: `:map` and `:text`

The `:plan` option in Postgrex can take the values `:custom` or `:fallback_generic`. When `:custom` is specified, the explain plan generated will consider the specific values of the query parameters that are supplied. When using `:fallback_generic`, the specific values of the query parameters will be ignored. `:fallback_generic` does not use PostgreSQL's built-in support for a generic explain plan (available as of PostgreSQL 16), but instead uses a special implementation that works for PostgreSQL versions 12 and above. Defaults to `:custom`.

Any other value passed to `opts` will be forwarded to the underlying adapter query function, including shared Repo options such as `:timeout`. Non built-in adapters may have specific behaviour and you should consult their documentation for more details.

For version compatibility, please check your database's documentation:

- Postgrex: PostgreSQL doc.
- MyXQL: MySQL doc.

# from_ecto(other)

# get(queryable, id, opts \\ [])

Callback implementation for `Ecto.Repo.get/3`.

# get!(queryable, id, opts \\ [])

Callback implementation for `Ecto.Repo.get!/3`.

# get_by(queryable, clauses, opts \\ [])

Callback implementation for `Ecto.Repo.get_by/3`.

# get_by!(queryable, clauses, opts \\ [])

Callback implementation for `Ecto.Repo.get_by!/3`.

# get_dynamic_repo()

Callback implementation for `Ecto.Repo.get_dynamic_repo/0`.

# in_transaction?()

Callback implementation for `Ecto.Repo.in_transaction?/0`.

# init(type, config)

Callback implementation for `Ecto.Repo.init/2`.

# insert(struct, opts \\ [])

Callback implementation for `Ecto.Repo.insert/2`.

# insert!(struct, opts \\ [])

Callback implementation for `Ecto.Repo.insert!/2`.

# insert_all(schema_or_source, entries, opts \\ [])

Callback implementation for `Ecto.Repo.insert_all/3`.

# insert_or_update(changeset, opts \\ [])

Callback implementation for `Ecto.Repo.insert_or_update/2`.

# insert_or_update!(changeset, opts \\ [])

Callback implementation for `Ecto.Repo.insert_or_update!/2`.

# load(schema_or_types, data)

Callback implementation for `Ecto.Repo.load/2`.

# migrations_path()

Callback implementation for `AshPostgres.Repo.migrations_path/0`.

# on_transaction_begin(reason)

Callback implementation for `AshPostgres.Repo.on_transaction_begin/1`.

# one(queryable, opts \\ [])

Callback implementation for `Ecto.Repo.one/2`.

# one!(queryable, opts \\ [])

Callback implementation for `Ecto.Repo.one!/2`.

# override_migration_type(type)

Callback implementation for `AshPostgres.Repo.override_migration_type/1`.

# prefer_transaction_for_atomic_updates?()

Callback implementation for `AshPostgres.Repo.prefer_transaction_for_atomic_updates?/0`.

# preload(struct_or_structs_or_nil, preloads, opts \\ [])

Callback implementation for `Ecto.Repo.preload/3`.

# prepare_query(operation, query, opts)

Callback implementation for `Ecto.Repo.prepare_query/3`.

# prepare_transaction(fun_or_multi, opts)

Callback implementation for `Ecto.Repo.prepare_transaction/2`.

# put_dynamic_repo(dynamic)

Callback implementation for `Ecto.Repo.put_dynamic_repo/1`.

# query(sql, params \\ [], opts \\ [])

    @spec query(iodata(), Ecto.Adapters.SQL.query_params(), Keyword.t()) ::
      {:ok, Ecto.Adapters.SQL.query_result()} | {:error, Exception.t()}

Runs a custom SQL query.

If the query was successful, it will return an `:ok` tuple containing a map with at least two keys:

- `:num_rows` - the number of rows affected
- `:rows` - the result set as a list. `nil` may be returned instead of the list if the command does not yield any row as result (but still yields the number of affected rows, like a `delete` command without returning would)

## Options

- `:log` - When false, does not log the query
- `:timeout` - Execute request timeout, accepts: `:infinity` (default: `15000`);

## Examples

    iex> MyRepo.query("SELECT $1::integer + $2", [40, 2])
    {:ok, %{rows: [[42]], num_rows: 1}}

    iex> Ecto.Adapters.SQL.query(MyRepo, "SELECT $1::integer + $2", [40, 2])
    {:ok, %{rows: [[42]], num_rows: 1}}

# query!(sql, params \\ [], opts \\ [])

    @spec query!(iodata(), Ecto.Adapters.SQL.query_params(), Keyword.t()) ::
      Ecto.Adapters.SQL.query_result()

Same as `query/3` but returns result directly without `:ok` tuple and raises on invalid queries

# query_many(sql, params \\ [], opts \\ [])

    @spec query_many(iodata(), Ecto.Adapters.SQL.query_params(), Keyword.t()) ::
      {:ok, [Ecto.Adapters.SQL.query_result()]} | {:error, Exception.t()}

Runs a custom SQL query that returns multiple results on the given repo.

In case of success, it must return an `:ok` tuple containing a list of maps with at least two keys:

- `:num_rows` - the number of rows affected

- `:rows` - the result set as a list. `nil` may be returned instead of the list if the command does not yield any row as result (but still yields the number of affected rows, like a `delete` command without returning would)

## Options

- `:log` - When false, does not log the query
- `:timeout` - Execute request timeout, accepts: `:infinity` (default: `15000`);

## Examples

    iex> MyRepo.query_many("SELECT $1; SELECT $2;", [40, 2])
    {:ok, [%{rows: [[40]], num_rows: 1}, %{rows: [[2]], num_rows: 1}]}

    iex> Ecto.Adapters.SQL.query_many(MyRepo, "SELECT $1; SELECT $2;", [40, 2])
    {:ok, [%{rows: [[40]], num_rows: 1}, %{rows: [[2]], num_rows: 1}]}

# query_many!(sql, params \\ [], opts \\ [])

    @spec query_many!(iodata(), Ecto.Adapters.SQL.query_params(), Keyword.t()) :: [
      Ecto.Adapters.SQL.query_result()
    ]

Same as `query_many/4` but returns result directly without `:ok` tuple and raises on invalid queries

# reload(queryable, opts \\ [])

Callback implementation for `Ecto.Repo.reload/2`.

# reload!(queryable, opts \\ [])

Callback implementation for `Ecto.Repo.reload!/2`.

# rollback(value)

    @spec rollback(term()) :: no_return()

Callback implementation for `Ecto.Repo.rollback/1`.

# start_link(opts \\ [])

Callback implementation for `Ecto.Repo.start_link/1`.

# stop(timeout \\ 5000)

Callback implementation for `Ecto.Repo.stop/1`.

# stream(queryable, opts \\ [])

Callback implementation for `Ecto.Repo.stream/2`.

# tenant_migrations_path()

Callback implementation for `AshPostgres.Repo.tenant_migrations_path/0`.

# to_ecto(value)

# to_sql(operation, queryable)

    @spec to_sql(:all | :update_all | :delete_all, Ecto.Queryable.t()) ::
      {String.t(), Ecto.Adapters.SQL.query_params()}

Converts the given query to SQL according to its kind and the adapter in the given repository.

## Examples

The examples below are meant for reference. Each adapter will return a different result:

    iex> MyRepo.to_sql(:all, Post)
    {"SELECT p.id, p.title, p.inserted_at, p.created_at FROM posts as p", []}

    iex> MyRepo.to_sql(:update_all, from(p in Post, update: [set: [title: ^"hello"]]))
    {"UPDATE posts AS p SET title = $1", ["hello"]}

    iex> Ecto.Adapters.SQL.to_sql(:all, MyRepo, Post)
    {"SELECT p.id, p.title, p.inserted_at, p.created_at FROM posts as p", []}

# transact(fun_or_multi, opts \\ [])

Callback implementation for `Ecto.Repo.transact/2`.

# transaction(fun_or_multi, opts \\ [])

Callback implementation for `Ecto.Repo.transaction/2`.

# transaction!(fun)

# update(struct, opts \\ [])

Callback implementation for `Ecto.Repo.update/2`.

# update!(struct, opts \\ [])

Callback implementation for `Ecto.Repo.update!/2`.

# update_all(queryable, updates, opts \\ [])

Callback implementation for `Ecto.Repo.update_all/3`.