Struct HookOperation 

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

Wrapper around a database connection passed to CommitHook::pre_commit().

Implements AtomicOperation to allow executing database queries within the transaction. Whether it also supports registering further commit hooks depends on how it was constructed — see the staged field below and “Re-entrant Registration” in the module docs.

Trait Implementations

impl<'c> AtomicOperation for HookOperation<'c>

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

Lets a hook’s own pre_commit isolate its multi-statement work in a SAVEPOINT — see SavepointOperation.

Hooks registered inside stage normally and, on release, fold into this HookOperation’s own buffer exactly like a top-level savepoint folds into a DbOp — if this HookOperation is on a real commit pass (supports_hooks is true). On the force_execute_pre_commit path staged is None, so registering a hook inside the savepoint fails the same way it would have on this HookOperation directly — the SAVEPOINT/RELEASE/ROLLBACK machinery itself still works, since it needs only the connection.

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

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

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<H: CommitHook>(&mut self, hook: H) -> Result<(), H>

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>

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.

fn supports_hooks(&self) -> bool

Whether this operation supports commit hooks.

fn clock(&self) -> &ClockHandle

Returns the clock handle for time operations.

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

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