如何提交sqlx事务？PgConnection无commit方法报错及参数选型疑问

报错信息 #

error[E0599]: no method named commit found for mutable reference &mut sqlx::PgConnection in the current scope
--> src/main.rs:103:12
|
103 | db.commit().await?;
| ^^^^^^ method not found in &mut PgConnection

需求与疑问 #

我需要仅当db为None时提交事务（此时是通过&mut self.pool.begin().await?开启的新事务）。想请教：

• 使用db: Option<&mut sqlx::PgConnection>作为参数类型是否合适？
• 还是应该用Acquire trait这类其他类型？

相关代码 #

pub async fn find_player_id(
    &self,
    db: Option<&mut sqlx::PgConnection>,
    id: &str,
    team_id: &str,
) -> Result<String, Error> {
    let db = match db {
        Some(db) => db,
        None => &mut self.pool.begin().await?,
    };

    let _ = self.team_service.find_team_id(Some(db), team_id).await?;

    let player_id = self.repo.find_player_id(Some(db), id).await?;

    db.commit().await?;

    Ok(player_id)
}

更新说明 #

有人将此问题标记为重复，指向关于“为何需要导入trait才能使用其定义的方法”的问题，但我认为并非重复，请先完整阅读问题再处理。

1. 解决commit方法找不到的问题 #

commit方法不属于PgConnection本身，而是定义在sqlx::Transaction trait中，首先需要确保导入该trait：

use sqlx::Transaction;

另外你的代码存在逻辑错误：当db是传入的外部连接时，调用commit()会提交外部事务，违背了你“仅提交自己开启的事务”的需求。需要修改逻辑，区分外部连接和内部事务，仅提交后者：

pub async fn find_player_id(
    &self,
    db: Option<&mut sqlx::PgConnection>,
    id: &str,
    team_id: &str,
) -> Result<String, Error> {
    // 用枚举区分外部连接与内部事务
    enum DbHandle<'a> {
        External(&'a mut sqlx::PgConnection),
        Internal(sqlx::Transaction<'a, sqlx::Postgres>),
    }

    let mut db_handle = match db {
        Some(db) => DbHandle::External(db),
        None => DbHandle::Internal(self.pool.begin().await?),
    };

    // 获取统一的连接引用供业务调用
    let db: &mut sqlx::PgConnection = match &mut db_handle {
        DbHandle::External(conn) => conn,
        DbHandle::Internal(tx) => tx.as_mut(),
    };

    let _ = self.team_service.find_team_id(Some(db), team_id).await?;
    let player_id = self.repo.find_player_id(Some(db), id).await?;

    // 仅当是内部开启的事务时提交
    if let DbHandle::Internal(tx) = db_handle {
        tx.commit().await?;
    }

    Ok(player_id)
}

2. 参数类型的合理性分析 #

使用Option<&mut sqlx::PgConnection>作为参数是可行的，优势在于逻辑直观，明确区分“复用外部连接”和“内部创建事务”两种场景，但需要注意：

• 生命周期约束：&mut引用会限制调用方的使用方式，确保连接在方法执行期间的唯一性，避免并发问题。
• 如果想支持更灵活的连接来源（比如直接传入连接池或事务对象），可以考虑Acquire trait，但这种方式会丢失“是否需要提交事务”的上下文，反而增加逻辑复杂度，对于你的场景，当前参数类型已经足够清晰，不需要过度设计。

内容的提问来源于stack exchange，提问作者Fred Hors