View Source Ecto.Adapter.Schema behaviour (Ecto v3.12.0)

Specifies the schema API required from adapters.

Summary

Types

adapter_meta()

Proxy type to the adapter meta

constraints()
fields()
filters()
on_conflict()
options()
placeholders()
returning()
schema_meta()

Ecto.Schema metadata fields

Callbacks

autogenerate(field_type)

Called to autogenerate a value for id/embed_id/binary_id.

delete(adapter_meta, schema_meta, filters, returning, options)

Deletes a single struct with the given filters.

insert(adapter_meta, schema_meta, fields, on_conflict, returning, options)

Inserts a single new struct in the data store.

insert_all(adapter_meta, schema_meta, header, list, on_conflict, returning, placeholders, options)

Inserts multiple entries into the data store.

update(adapter_meta, schema_meta, fields, filters, returning, options)

Updates a single struct with the given filters.

Types

Link to this type

adapter_meta()

View Source 
@type adapter_meta() :: Ecto.Adapter.adapter_meta()

Proxy type to the adapter meta

Link to this type

constraints()

View Source 
@type constraints() :: Keyword.t()
Link to this type

fields()

View Source 
@type fields() :: Keyword.t()
Link to this type

filters()

View Source 
@type filters() :: Keyword.t()
Link to this type

on_conflict()

View Source 
@type on_conflict() ::
  {:raise, list(), []}
  | {:nothing, list(), [atom()]}
  | {[atom()], list(), [atom()]}
  | {Ecto.Query.t(), list(), [atom()]}
Link to this type

options()

View Source 
@type options() :: Keyword.t()
Link to this type

placeholders()

View Source 
@type placeholders() :: [term()]
Link to this type

returning()

View Source 
@type returning() :: [atom()]
Link to this type

schema_meta()

View Source 
@type schema_meta() :: %{
  autogenerate_id:
    {schema_field :: atom(), source_field :: atom(), Ecto.Type.t()},
  context: term(),
  prefix: binary() | nil,
  schema: atom(),
  source: binary()
}

Ecto.Schema metadata fields

Callbacks

Link to this callback

autogenerate(field_type)

View Source 
@callback autogenerate(field_type :: :id | :binary_id | :embed_id) :: term() | nil

Called to autogenerate a value for id/embed_id/binary_id.

Returns the autogenerated value, or nil if it must be autogenerated inside the storage or raise if not supported.

Link to this callback

delete(adapter_meta, schema_meta, filters, returning, options)

View Source 
@callback delete(adapter_meta(), schema_meta(), filters(), returning(), options()) ::
  {:ok, fields()} | {:invalid, constraints()} | {:error, :stale}

Deletes a single struct with the given filters.

While filters can be any record column, it is expected that at least the primary key (or any other key that uniquely identifies an existing record) be given as a filter. Therefore, in case there is no record matching the given filters, {:error, :stale} is returned.

Link to this callback

insert(adapter_meta, schema_meta, fields, on_conflict, returning, options)

View Source 
@callback insert(
  adapter_meta(),
  schema_meta(),
  fields(),
  on_conflict(),
  returning(),
  options()
) ::
  {:ok, fields()} | {:invalid, constraints()}

Inserts a single new struct in the data store.

Autogenerate

The primary key will be automatically included in returning if the field has type :id or :binary_id and no value was set by the developer or none was autogenerated by the adapter.

Link to this callback

insert_all(adapter_meta, schema_meta, header, list, on_conflict, returning, placeholders, options)

View Source 
@callback insert_all(
  adapter_meta(),
  schema_meta(),
  header :: [atom()],
  [[{atom(), term() | {Ecto.Query.t(), list()}}]],
  on_conflict(),
  returning(),
  placeholders(),
  options()
) :: {non_neg_integer(), [[term()]] | nil}

Inserts multiple entries into the data store.

In case an Ecto.Query given as any of the field values by the user, it will be sent to the adapter as a tuple with in the shape of {query, params}.

Link to this callback

update(adapter_meta, schema_meta, fields, filters, returning, options)

View Source 
@callback update(
  adapter_meta(),
  schema_meta(),
  fields(),
  filters(),
  returning(),
  options()
) ::
  {:ok, fields()} | {:invalid, constraints()} | {:error, :stale}

Updates a single struct with the given filters.

While filters can be any record column, it is expected that at least the primary key (or any other key that uniquely identifies an existing record) be given as a filter. Therefore, in case there is no record matching the given filters, {:error, :stale} is returned.