Struct DbTransactionMiddleware 

pub struct DbTransactionMiddleware { /* private fields */ }

Available on crate feature sea-orm only.

A middleware for automatically creating and managing sea_orm::DatabaseTransactions for incoming requests.

Implementations

impl DbTransactionMiddleware

pub fn new(db: DatabaseConnection) -> Self

Create a new DbTransactionMiddleware.

pub fn with_check_fn<F>(self, check_fn: F) -> Self

where F: Fn(&Response) -> bool + Send + Sync + 'static,

Use a custom function to check if a response is successful.

By default a response is considered successful iff it is neither a client error (400-499) nor a server error (500-599).

Example

use poem::{EndpointExt, Route};
use poem_ext::db::DbTransactionMiddleware;

let app = Route::new().nest("/", api_service).with(
    // commit only if the response status is "200 OK", otherwise rollback the transaction
    DbTransactionMiddleware::new(db_connection).with_check_fn(|response| response.is_ok()),
);

Trait Implementations

impl Debug for DbTransactionMiddleware

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

Formats the value using the given formatter.

impl<E: Endpoint> Middleware<E> for DbTransactionMiddleware

type Output = DbTransactionMwEndpoint<E>

New endpoint type.

fn transform(&self, ep: E) -> Self::Output

Transform the input Endpoint to another one.

fn combine<T>(self, other: T) -> CombineMiddleware<Self, T, E>

where T: Middleware<Self::Output>, Self: Sized,

Create a new middleware by combining two middlewares.

fn combine_if<T>( self, enable: bool, other: T, ) -> EitherMiddleware<Self, CombineMiddleware<Self, T, E>, E>

where T: Middleware<Self::Output>, Self: Sized,

if enable is true then combine the middleware.