Rust Actix-web使用sqlx操作MySQL时无法启动连接事务

你遇到的兼容问题来自两个核心原因：

• MySQL预处理语句协议本身不支持BEGIN/COMMIT/ROLLBACK这类会话级事务控制命令，这类命令必须走非预处理的简单查询路径执行，sqlx::query()默认走预处理逻辑，所以直接执行会失败。
• 你改用fetch_optional的写法存在逻辑错误，sqlx的MySQL驱动会默认给传入的查询追加RETURNING *子句尝试拉取返回结果，而MySQL不支持通用的RETURNING语法，因此触发1064语法错误。

不要手动编写事务控制SQL，直接使用sqlx内置的连接与事务抽象，这套抽象已经对PostgreSQL、MySQL、SQLite做了底层协议适配，完全可以保留你现有的中间件设计，不需要改动业务层代码逻辑。

最小改动实现 #

你不需要推翻现有PoolConnection的封装，只需要把三个事务控制方法里手写SQL的逻辑替换为sqlx连接自带的原生事务方法即可，底层会自动适配不同数据库的执行逻辑，自动绕过MySQL预处理语句的限制：

// 若使用MySQL，修改NativeConnection类型别名即可，PostgreSQL场景保持原有定义
pub type NativeConnection = sqlx::pool::PoolConnection<MySql>;

// 其余结构体定义、get()/transaction()方法保持原有逻辑不变
impl PoolConnection {
    pub async fn begin(&mut self) -> Result<bool, Error> {
        // 替换手写的"BEGIN" SQL执行，调用连接原生begin方法
        self.connection.begin().await.map_err(|e| {
            error!("Unable to begin transaction: {}", &e);
            e
        })?;
        self.transactions += 1;
        Ok(true)
    }

    pub async fn commit(&mut self) -> Result<bool, Error> {
        if self.transactions == 0 {
            panic!("Attempt to commit on a connection with no transaction open.");
        }
        if self.transactions == 1 {
            // 替换手写的"COMMIT" SQL执行
            self.connection.commit().await.map_err(|e| {
                error!("Unable to commit transaction: {}", &e);
                e
            })?;
            self.transactions = 0;
            Ok(false)
        } else {
            self.transactions -= 1;
            Ok(self.transaction())
        }
    }

    pub async fn rollback(&mut self) -> Result<bool, Error> {
        if self.transactions == 0 {
            panic!("Attempt to rollback on a connection with no transaction open.");
        }
        // 替换手写的"ROLLBACK" SQL执行
        self.connection.rollback().await.map_err(|e| {
            error!("Unable to rollback transaction: {}", &e);
            e
        })?;
        self.transactions = 0;
        Ok(false)
    }
}

注意：使用上述原生事务方法前，需要导入use sqlx::Connection; trait，否则编译器无法识别对应方法。

优化建议 #

针对你提到的「直接传Transaction对象对只读端点冗余」的问题，可以通过以下方式解决，完全匹配你的设计诉求：

• 封装的PoolConnection同时兼容两种模式：未开启事务时直接对外暴露裸连接供只读查询使用，开启事务时通过Deref trait自动对外暴露事务包裹的连接，业务层代码完全感知不到差异，不需要修改任何查询逻辑。
• 在中间件层增加简单的路由标记：比如给写操作路由加事务标识，中间件根据标识判断是否需要开启事务；测试环境下强制所有请求开启事务，请求结束后自动回滚，完全避免测试数据污染数据库。
• 如果需要支持嵌套事务，不需要自己维护事务计数，直接使用sqlx内置的保存点（Savepoint）能力即可，调用事务对象的begin()方法会自动创建保存点，提交/回滚时自动匹配对应保存点，跨数据库兼容，可靠性更高。

如果需要一套代码同时兼容PostgreSQL和MySQL，可以直接使用sqlx的AnyConnection/AnyPool抽象，不需要为不同数据库写分支逻辑。

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