pub struct Annotated<'a, E> { /* private fields */ }Expand description
A shared-reference annotation wrapper that carries per-query attributes alongside a
borrowed executor. Returned by Pool::with_annotations
and Pool::with_operation.
Implements sqlx::Executor with the same instrumentation as the underlying type, but
with annotation values threaded through to span creation.
Trait Implementations§
Source§impl<'c, DB> Executor<'c> for Annotated<'c, Pool<DB>>
impl<'c, DB> Executor<'c> for Annotated<'c, Pool<DB>>
Source§fn execute<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxFuture<'e, Result<<DB as Database>::QueryResult, Error>>where
E: 'q + Execute<'q, DB>,
'c: 'e,
fn execute<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxFuture<'e, Result<<DB as Database>::QueryResult, Error>>where
E: 'q + Execute<'q, DB>,
'c: 'e,
Execute the query and return the total number of rows affected.
Source§fn execute_many<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxStream<'e, Result<<DB as Database>::QueryResult, Error>>where
E: 'q + Execute<'q, DB>,
'c: 'e,
fn execute_many<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxStream<'e, Result<<DB as Database>::QueryResult, Error>>where
E: 'q + Execute<'q, DB>,
'c: 'e,
Execute multiple queries and return the rows affected from each query, in a stream.
Source§fn fetch<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxStream<'e, Result<<DB as Database>::Row, Error>>where
E: 'q + Execute<'q, DB>,
'c: 'e,
fn fetch<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxStream<'e, Result<<DB as Database>::Row, Error>>where
E: 'q + Execute<'q, DB>,
'c: 'e,
Execute the query and return the generated results as a stream.
Source§fn fetch_many<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxStream<'e, Result<Either<<DB as Database>::QueryResult, <DB as Database>::Row>, Error>>where
E: 'q + Execute<'q, DB>,
'c: 'e,
fn fetch_many<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxStream<'e, Result<Either<<DB as Database>::QueryResult, <DB as Database>::Row>, Error>>where
E: 'q + Execute<'q, DB>,
'c: 'e,
Execute multiple queries and return the generated results as a stream from each query, in a stream.
Source§fn fetch_all<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxFuture<'e, Result<Vec<<DB as Database>::Row>, Error>>where
E: 'q + Execute<'q, DB>,
'c: 'e,
fn fetch_all<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxFuture<'e, Result<Vec<<DB as Database>::Row>, Error>>where
E: 'q + Execute<'q, DB>,
'c: 'e,
Execute the query and return all the generated results, collected into
a Vec.
Source§fn fetch_one<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxFuture<'e, Result<<DB as Database>::Row, Error>>where
E: 'q + Execute<'q, DB>,
'c: 'e,
fn fetch_one<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxFuture<'e, Result<<DB as Database>::Row, Error>>where
E: 'q + Execute<'q, DB>,
'c: 'e,
Execute the query and returns exactly one row.
Source§fn fetch_optional<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxFuture<'e, Result<Option<<DB as Database>::Row>, Error>>where
E: 'q + Execute<'q, DB>,
'c: 'e,
fn fetch_optional<'e, 'q: 'e, E>(
self,
query: E,
) -> BoxFuture<'e, Result<Option<<DB as Database>::Row>, Error>>where
E: 'q + Execute<'q, DB>,
'c: 'e,
Execute the query and returns at most one row.
Source§fn prepare<'e, 'q: 'e>(
self,
query: &'q str,
) -> BoxFuture<'e, Result<<DB as Database>::Statement<'q>, Error>>where
'c: 'e,
fn prepare<'e, 'q: 'e>(
self,
query: &'q str,
) -> BoxFuture<'e, Result<<DB as Database>::Statement<'q>, Error>>where
'c: 'e,
Prepare the SQL query to inspect the type information of its parameters and results.
Be advised that when using the query, query_as, or query_scalar
functions, the query is transparently prepared and executed.
This explicit API is provided to allow access to the statement metadata available after it prepared but before the first row is returned.
Source§fn prepare_with<'e, 'q: 'e>(
self,
sql: &'q str,
parameters: &'e [<DB as Database>::TypeInfo],
) -> BoxFuture<'e, Result<<DB as Database>::Statement<'q>, Error>>where
'c: 'e,
fn prepare_with<'e, 'q: 'e>(
self,
sql: &'q str,
parameters: &'e [<DB as Database>::TypeInfo],
) -> BoxFuture<'e, Result<<DB as Database>::Statement<'q>, Error>>where
'c: 'e,
Prepare the SQL query, with parameter type information, to inspect the type information about its parameters and results.
Only some database drivers (Postgres, MSSQL) can take advantage of this extra information to influence parameter type inference.
type Database = DB
Auto Trait Implementations§
impl<'a, E> Freeze for Annotated<'a, E>
impl<'a, E> !RefUnwindSafe for Annotated<'a, E>
impl<'a, E> Send for Annotated<'a, E>where
E: Sync,
impl<'a, E> Sync for Annotated<'a, E>where
E: Sync,
impl<'a, E> Unpin for Annotated<'a, E>
impl<'a, E> UnsafeUnpin for Annotated<'a, E>
impl<'a, E> !UnwindSafe for Annotated<'a, E>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more