DripDrop.Repo (DripDrop v0.1.0)

Thin delegating wrapper around the host-configured DripDrop repo.

Library code calls this module so applications can provide their own Ecto repo through config :dripdrop, :repo.

Summary

Functions

all(query, opts \\ [])

Runs a query and returns all rows.

get(schema, id, opts \\ [])

Fetches one schema row by primary key, returning nil when it is missing.

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

Fetches one schema row by primary key, raising when it is missing.

insert(changeset, opts \\ [])

Inserts a changeset through the configured repo.

one(query, opts \\ [])

Runs a query expected to return zero or one row.

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

Executes raw SQL through the configured repo.

repo!()

Returns the host-configured Ecto repo or raises when DripDrop is not configured.

transaction(multi, opts \\ [])

Runs an Ecto.Multi transaction through the configured repo.

update(changeset, opts \\ [])

Updates a changeset through the configured repo.

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

Runs an update_all through the configured repo.

Functions

all(query, opts \\ [])

@spec all(
  Ecto.Queryable.t(),
  keyword()
) :: [Ecto.Schema.t()]

Runs a query and returns all rows.

get(schema, id, opts \\ [])

@spec get(module(), term(), keyword()) :: Ecto.Schema.t() | nil

Fetches one schema row by primary key, returning nil when it is missing.

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

@spec get!(module(), term(), keyword()) :: Ecto.Schema.t()

Fetches one schema row by primary key, raising when it is missing.

insert(changeset, opts \\ [])

@spec insert(
  Ecto.Changeset.t(),
  keyword()
) :: {:ok, Ecto.Schema.t()} | {:error, Ecto.Changeset.t()}

Inserts a changeset through the configured repo.

one(query, opts \\ [])

@spec one(
  Ecto.Queryable.t(),
  keyword()
) :: Ecto.Schema.t() | nil

Runs a query expected to return zero or one row.

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

@spec query(String.t(), list(), keyword()) ::
  {:ok, Postgrex.Result.t()} | {:error, term()}

Executes raw SQL through the configured repo.

repo!()

@spec repo!() :: module()

Returns the host-configured Ecto repo or raises when DripDrop is not configured.

transaction(multi, opts \\ [])

@spec transaction(
  Ecto.Multi.t(),
  keyword()
) :: {:ok, map()} | {:error, atom(), term(), map()}

Runs an Ecto.Multi transaction through the configured repo.

update(changeset, opts \\ [])

@spec update(
  Ecto.Changeset.t(),
  keyword()
) :: {:ok, Ecto.Schema.t()} | {:error, Ecto.Changeset.t()}

Updates a changeset through the configured repo.

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

@spec update_all(Ecto.Queryable.t(), keyword(), keyword()) ::
  {non_neg_integer(), nil | [term()]}

Runs an update_all through the configured repo.