Struct DbOpWithTime 

pub struct DbOpWithTime<'c> { /* private fields */ }

Equivileant of DbOp just that the time is guaranteed to be cached.

Used as a wrapper of a sqlx::Transaction with cached time of the transaction.

Implementations

impl<'c> DbOpWithTime<'c>

pub fn now(&self) -> DateTime<Utc>

The cached chrono::DateTime

pub async fn begin(&mut self) -> Result<DbOpWithTime<'_>, Error>

Begins a nested transaction.

pub async fn with_savepoint<T, E, F>( &mut self, f: F, ) -> Result<Result<T, E>, Error>

where F: AsyncFnOnce(&mut SavepointOp<'_>) -> Result<T, E>,

Runs f inside a SAVEPOINT — see DbOp::with_savepoint.

The cached time is propagated, so the SavepointOp reports it from maybe_now and wrapping it in OpWithTime is free.

pub async fn begin_savepoint(&mut self) -> Result<SavepointOp<'_>, Error>

Begins a SAVEPOINT scope explicitly — see DbOp::begin_savepoint.

pub async fn commit(self) -> Result<(), Error>

Commits the inner transaction.

pub fn tx_mut(&mut self) -> &mut Transaction<'c, Db>

Gets a mutable handle to the inner transaction

Trait Implementations

impl<'o> AtomicOperation for DbOpWithTime<'o>

fn maybe_now(&self) -> Option<DateTime<Utc>>

Function for querying when the operation is taking place - if it is cached.

fn clock(&self) -> &ClockHandle

Returns the clock handle for time operations.

fn connection(&mut self) -> &mut Connection

Returns the raw underlying connection. The desired way to represent this would actually be as a GAT:

fn add_commit_hook_dyn( &mut self, type_id: TypeId, hook: Box<dyn DynHook>, ) -> Result<(), Box<dyn DynHook>>

Object-safe, type-erased form of add_commit_hook.

fn commit_hook_dyn(&self, type_id: TypeId) -> Option<&dyn DynHook>

Object-safe, type-erased form of commit_hook.

fn supports_hooks(&self) -> bool

Whether this operation supports commit hooks.

fn savepoint_parts(&mut self) -> (&mut Connection, HookSlot<'_>)

Simultaneous access to the connection and the commit-hook buffer a nested SAVEPOINT folds into when released. Implementing this is the only thing an operation must do to get the whole of SavepointOperation — with_savepoint, begin_savepoint, and arbitrary-depth nesting — for free.

fn as_executor(&mut self) -> OneTimeExecutor<'_, &mut Connection>

Returns the sqlx::Executor implementation that statements should be executed through.

fn add_commit_hook<H: CommitHook>(&mut self, hook: H) -> Result<(), H>

where Self: Sized,

Registers a commit hook that will run pre_commit before and post_commit after the transaction commits. Returns Ok(()) if the hook was registered, Err(hook) if hooks are not supported.

fn commit_hook<H: CommitHook>(&self) -> Option<&H>

where Self: Sized,

Typed shared access to the currently-accumulating commit hook of type H, if this operation supports commit hooks and one is registered. Returns the hook a subsequent add_commit_hook::<H> call would merge into.

impl<'o> AtomicOperationWithTime for DbOpWithTime<'o>

fn now(&self) -> DateTime<Utc>