Struct TransactionConn 

pub struct TransactionConn { /* private fields */ }

事务连接持有者

在 TransactionMiddleware 中创建，注入到 request extensions 供 handler 复用同一连接执行查询。handler 通过 web::ReqData<TransactionConn> 提取。

连接包装在 Arc<Mutex<Option<PooledConnection>>> 中：

• Some(conn)：事务进行中，handler 可获取连接执行查询
• None：事务已结束（中间件取回连接执行 commit/rollback）

用法

use actix_web::web::ReqData;
use sz_orm_actix::TransactionConn;

async fn handler(tx: ReqData<TransactionConn>) -> impl Responder {
    if let Some(mut guard) = tx.conn().await {
        if let Some(conn) = guard.as_mut() {
            conn.execute("INSERT INTO users (name) VALUES ('Alice')").await?;
        }
    }
    HttpResponse::Ok()
}

Implementations

impl TransactionConn

pub async fn conn(&self) -> Option<MutexGuard<'_, Option<PooledConnection>>>

获取连接的可变引用

返回 MutexGuard<Option<PooledConnection>>，调用方通过 guard.as_mut() 获取 &mut Option<PooledConnection>，再 .as_mut().unwrap() 得到 &mut PooledConnection。

如果中间件已取回连接（事务结束），返回 None。

Trait Implementations

impl Clone for TransactionConn

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl FromRequest for TransactionConn

type Error = Error

The associated error which can be returned.

type Future = Ready<Result<TransactionConn, <TransactionConn as FromRequest>::Error>>

Future that resolves to a Self.

fn from_request(req: &HttpRequest, _: &mut Payload) -> Self::Future

Create a Self from request parts asynchronously.

fn extract(req: &HttpRequest) -> Self::Future

Create a Self from request head asynchronously.