transaction

Types

TransactionError

pub type TransactionError(exec_error) {
  TrackError(runtime.TrackError)
  ExecutionError(runtime.SessionExecutionError(exec_error))
}

Constructors

```
TrackError(runtime.TrackError)
```

ExecutionError(runtime.SessionExecutionError(exec_error))

TransactionSession

</>

pub type TransactionSession(connection) {
  TransactionSession(
    connection: connection,
    session: runtime.Session,
  )
}

Constructors

TransactionSession(
  connection: connection,
  session: runtime.Session,
)

Values

begin

</>

pub fn begin(
  connection: connection,
  session: runtime.Session,
) -> TransactionSession(connection)

commit

</>

pub fn commit(
  transaction: TransactionSession(connection),
  executor: fn(query.Query, connection) -> Result(
    result,
    exec_error,
  ),
) -> Result(
  #(execution.FlushExecution(result), runtime.Session),
  TransactionError(exec_error),
)

connection

</>

pub fn connection(
  transaction: TransactionSession(connection),
) -> connection

flush

</>

pub fn flush(
  transaction: TransactionSession(connection),
  executor: fn(query.Query, connection) -> Result(
    result,
    exec_error,
  ),
) -> Result(
  #(
    execution.FlushExecution(result),
    TransactionSession(connection),
  ),
  TransactionError(exec_error),
)

rollback

</>

pub fn rollback(
  transaction: TransactionSession(connection),
) -> TransactionSession(connection)

session

</>

pub fn session(
  transaction: TransactionSession(connection),
) -> runtime.Session

stage

</>

pub fn stage(
  transaction: TransactionSession(connection),
  next_entity: entity.Entity,
) -> Result(
  TransactionSession(connection),
  TransactionError(exec_error),
)

track

</>

pub fn track(
  transaction: TransactionSession(connection),
  next_entity: entity.Entity,
) -> Result(
  TransactionSession(connection),
  TransactionError(exec_error),
)