sqlx同一方法内多次使用PgExecutor报错的解决方案及版本咨询

问题原因 #

impl sqlx::PgExecutor<'_>作为参数时，编译器会按该 trait 最严格的实现语义（即移动语义）处理——部分实现类型（如事务对象Transaction<Postgres>）是所有权语义，调用一次方法后会被移动，无法再次使用，从而触发E0382错误。

解决方案 #

方案1：使用引用类型传递参数 #

将参数改为&impl sqlx::PgExecutor<'_>，通过借用语义避免所有权移动，无论连接池引用还是事务引用都可多次使用：

async fn batch_operation(db: &impl sqlx::PgExecutor<'_>) -> Result<(), sqlx::Error> {
    // 第一次使用
    sqlx::query!("INSERT INTO users (name) VALUES ($1)", "Alice")
        .execute(db)
        .await?;
    
    // 第二次使用
    let count = sqlx::query_scalar!("SELECT COUNT(*) FROM users")
        .fetch_one(db)
        .await?;
    
    Ok(())
}

// 调用示例
// 连接池场景
batch_operation(&pool).await?;
// 事务场景
let mut tx = pool.begin().await?;
batch_operation(&tx).await?;
tx.commit().await?;

方案2：使用动态分发（可选） #

若需灵活管理所有权，可使用Box<dyn sqlx::PgExecutor<'_>>包裹参数，通过动态分发实现多次调用（性能略低于静态分发，适合复杂场景）：

async fn batch_operation(db: Box<dyn sqlx::PgExecutor<'_>>) -> Result<(), sqlx::Error> {
    sqlx::query!("INSERT INTO users (name) VALUES ($1)", "Bob")
        .execute(&*db)
        .await?;
    
    let count = sqlx::query_scalar!("SELECT COUNT(*) FROM users")
        .fetch_one(&*db)
        .await?;
    
    Ok(())
}

SQLx 0.7版本支持情况 #

SQLx 0.7对Executor trait做了核心优化：所有核心方法（如execute、fetch_one）均改为接收&self而非self，因此直接使用impl sqlx::PgExecutor<'_>作为参数时，可在同一方法内多次调用，不会触发移动错误。该版本彻底解决了所有权语义冲突的问题，无需额外修改参数类型即可兼容事务与非事务场景。

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