Ecto.Adapters.SQL.Connection

all/1

(callback) # ↑

Specs:

all(Ecto.Query.t) :: String.t

Receives a query and must return a SELECT query.

Source

begin_transaction/0

(callback) # ↑

Specs:

begin_transaction :: String.t

Command to begin transaction.

Source

commit/0

(callback) # ↑

Specs:

commit :: String.t

Command to commit transaction.

Source

connect/1

(callback) # ↑

Specs:

connect(Keyword.t) :: {:ok, pid} | {:error, term}

Connects to the underlying database.

Should return a process which is linked to the caller process or an error.

Source

ddl_exists/1

(callback) # ↑

Specs:

ddl_exists(Ecto.Adapter.Migration.ddl_object) :: String.t

Receives a DDL object and returns a query that checks its existence.

Source

delete/3

(callback) # ↑

Specs:

delete(table :: String.t, filters :: Keyword.t, returning :: [atom]) :: String.t

Returns a DELETE for the filters returning the given returning.

Source

delete_all/1

(callback) # ↑

Specs:

delete_all(Ecto.Query.t) :: String.t

Receives a query and must return a DELETE query.

Source

disconnect/1

(callback) # ↑

Specs:

disconnect(pid) :: :ok

Disconnects the given pid.

If the given pid no longer exists, it should not raise.

Source

execute_ddl/1

(callback) # ↑

Specs:

execute_ddl(Ecto.Adapter.Migration.command) :: String.t

Receives a DDL command and returns a query that executes it.

Source

insert/3

(callback) # ↑

Specs:

insert(table :: String.t, fields :: Keyword.t, returning :: [atom]) :: String.t

Returns an INSERT for the given fields in table returning the given returning.

Source

query/4

(callback) # ↑

Specs:

query(pid, query :: binary, params :: list, opts :: Keyword.t) :: {:ok, %{rows: nil | [tuple], num_rows: non_neg_integer}} | {:error, Exception.t}

Executes the given query with params in connection.

In case of success, it must 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)

Source

rollback/0

(callback) # ↑

Specs:

rollback :: String.t

Command to rollback transaction.

Source

rollback_to_savepoint/1

(callback) # ↑

Specs:

rollback_to_savepoint(savepoint :: String.t) :: String.t

Command to rollback to savepoint.

Source

savepoint/1

(callback) # ↑

Specs:

savepoint(savepoint :: String.t) :: String.t

Command to emit savepoint.

Source

update/4

(callback) # ↑

Specs:

update(table :: String.t, filters :: Keyword.t, fields :: Keyword.t, returning :: [atom]) :: String.t

Returns an UPDATE for the given fields in table filtered by filters returning the given returning.

Source

update_all/2

(callback) # ↑

Specs:

update_all(Ecto.Query.t, values :: Keyword.t) :: String.t

Receives a query and values to update and must return an UPDATE query.

Source

Ecto.Adapters.SQL.Connection behaviour

Callbacks