pub trait Executor<'c>: Send + Debug + Sized {
type Database: Database;
fn fetch_many<'e, 'q: 'e, E: 'q>(
self,
query: E
) -> BoxStream<'e, Result<Either<<Self::Database as Database>::QueryResult, <Self::Database as Database>::Row>, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>;
fn fetch_optional<'e, 'q: 'e, E: 'q>(
self,
query: E
) -> BoxFuture<'e, Result<Option<<Self::Database as Database>::Row>, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>;
fn prepare_with<'e, 'q: 'e>(
self,
sql: &'q str,
parameters: &'e [<Self::Database as Database>::TypeInfo]
) -> BoxFuture<'e, Result<<Self::Database as HasStatement<'q>>::Statement, Error>>
where
'c: 'e;
fn execute<'e, 'q: 'e, E: 'q>(
self,
query: E
) -> BoxFuture<'e, Result<<Self::Database as Database>::QueryResult, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>,
{ ... }
fn execute_many<'e, 'q: 'e, E: 'q>(
self,
query: E
) -> BoxStream<'e, Result<<Self::Database as Database>::QueryResult, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>,
{ ... }
fn fetch<'e, 'q: 'e, E: 'q>(
self,
query: E
) -> BoxStream<'e, Result<<Self::Database as Database>::Row, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>,
{ ... }
fn fetch_all<'e, 'q: 'e, E: 'q>(
self,
query: E
) -> BoxFuture<'e, Result<Vec<<Self::Database as Database>::Row>, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>,
{ ... }
fn fetch_one<'e, 'q: 'e, E: 'q>(
self,
query: E
) -> BoxFuture<'e, Result<<Self::Database as Database>::Row, Error>>
where
'c: 'e,
E: Execute<'q, Self::Database>,
{ ... }
fn prepare<'e, 'q: 'e>(
self,
query: &'q str
) -> BoxFuture<'e, Result<<Self::Database as HasStatement<'q>>::Statement, Error>>
where
'c: 'e,
{ ... }
}Expand description
A type that contains or can provide a database connection to use for executing queries against the database.
No guarantees are provided that successive queries run on the same physical database connection.
A Connection is an Executor that guarantees that
successive queries are ran on the same physical database connection.
Implemented for the following:
Required Associated Types
Required Methods
Execute multiple queries and return the generated results as a stream from each query, in a stream.
Execute the query and returns at most one row.
Prepare the SQL query, with parameter type information, to inspect the type information about its parameters and results.
Only some database drivers (PostgreSQL, MSSQL) can take advantage of this extra information to influence parameter type inference.
Provided Methods
Execute the query and return the total number of rows affected.
fn execute_many<'e, 'q: 'e, E: 'q>(
self,
query: E
) -> BoxStream<'e, Result<<Self::Database as Database>::QueryResult, Error>> where
'c: 'e,
E: Execute<'q, Self::Database>,
fn execute_many<'e, 'q: 'e, E: 'q>(
self,
query: E
) -> BoxStream<'e, Result<<Self::Database as Database>::QueryResult, Error>> where
'c: 'e,
E: Execute<'q, Self::Database>,
Execute multiple queries and return the rows affected from each query, in a stream.
Execute the query and return the generated results as a stream.
Execute the query and return all the generated results, collected into a Vec.
Execute the query and returns exactly one row.
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.