Enum Executor 

pub enum Executor<'a, DB: Database> {
    Pool(&'a Pool<DB>),
    Conn(&'a mut DB::Connection),
}

A unified database executor that can wrap either a connection pool or a single connection.

This allows Premix to remain agnostic about whether it’s executing within a transaction, a shared pool, or a dedicated connection.

Variants

Pool(&'a Pool<DB>)

A shared connection pool.

Conn(&'a mut DB::Connection)

A single, mutable database connection.

Implementations

impl<'a, DB: Database> Executor<'a, DB>

pub async fn execute<'q, A>( &mut self, query: Query<'q, DB, A>, ) -> Result<DB::QueryResult, Error>

where A: IntoArguments<'q, DB> + 'q, DB: SqlDialect, for<'c> &'c mut DB::Connection: Executor<'c, Database = DB>,

Executes a SQL query and returns the database result (e.g., number of rows affected).

pub async fn fetch_all<'q, T, A>( &mut self, query: QueryAs<'q, DB, T, A>, ) -> Result<Vec<T>, Error>

where T: for<'r> FromRow<'r, DB::Row> + Send + Unpin, A: IntoArguments<'q, DB> + 'q, DB: SqlDialect, for<'c> &'c mut DB::Connection: Executor<'c, Database = DB>,

Executes a SQL query and fetches all resulting rows.

pub async fn fetch_optional<'q, T, A>( &mut self, query: QueryAs<'q, DB, T, A>, ) -> Result<Option<T>, Error>

where T: for<'r> FromRow<'r, DB::Row> + Send + Unpin, A: IntoArguments<'q, DB> + 'q, DB: SqlDialect, for<'c> &'c mut DB::Connection: Executor<'c, Database = DB>,

Executes a SQL query and fetches an optional single row.

pub fn fetch_stream<'q, T, A>( self, query: QueryAs<'q, DB, T, A>, ) -> BoxStream<'a, Result<T, Error>>

where T: for<'r> FromRow<'r, DB::Row> + Send + Unpin + 'a, A: IntoArguments<'q, DB> + 'q, DB: SqlDialect, for<'c> &'c mut DB::Connection: Executor<'c, Database = DB>, 'q: 'a,

Executes a SQL query and returns a stream of resulting rows.

Trait Implementations

impl<'a, DB: Database> Debug for Executor<'a, DB>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'a, DB: Database> From<&'a Pool<DB>> for Executor<'a, DB>

fn from(pool: &'a Pool<DB>) -> Self

Converts to this type from the input type.

impl<'a, DB: Database> From<&'a mut <DB as Database>::Connection> for Executor<'a, DB>

fn from(conn: &'a mut DB::Connection) -> Self

Converts to this type from the input type.

impl<'a, DB: SqlDialect> IntoExecutor<'a> for Executor<'a, DB>

type DB = DB

The database dialect associated with this executor.

fn into_executor(self) -> Executor<'a, DB>

Converts the type into an Executor.

impl<'a, DB: Database> Send for Executor<'a, DB>

where DB::Connection: Send,

impl<'a, DB: Database> Sync for Executor<'a, DB>

where DB::Connection: Sync,