关于&diesel::MysqlConnection未实现diesel::Connection trait的技术问询

我之前踩过这个Diesel的坑，这个错误本质是Diesel的Connection trait并没有为不可变引用&MysqlConnection实现，它只对MysqlConnection本身和可变引用&mut MysqlConnection提供了实现。结合你给出的代码片段，我来一步步帮你解决：

1. 先补全你的establish_connection函数 #

你代码里的连接建立逻辑没写完，先把这部分修正为正确的实现：

#![recursion_limit = "128"]
#[macro_use] extern crate diesel;
#[macro_use] extern crate diesel_infer_schema;
extern crate dotenv;

use diesel::mysql::MysqlConnection;
use diesel::prelude::*;
use dotenv::dotenv;
use std::env;

pub fn establish_connection() -> MysqlConnection {
    dotenv().ok();
    let db_url = env::var("DB_URL").expect("DB_URL must be set");
    // 补全连接建立逻辑
    MysqlConnection::establish(&db_url)
        .expect(&format!("Failed to connect to database: {}", db_url))
}

2. 核心错误修复：传递可变引用而非不可变引用 #

你大概率是在后续调用查询/写入方法时，传递了&conn（不可变引用），而Diesel的操作（比如load、insert_into）需要的是&mut impl Connection。举个例子：

错误写法（会触发你的报错）： #

let conn = establish_connection();
// 这里传了不可变引用&conn，导致报错
let users = users::table.load::<User>(&conn)?;

正确写法： #

// 声明为可变变量
let mut conn = establish_connection();
// 传递可变引用&mut conn
let users = users::table.load::<User>(&mut conn)?;

3. 多线程场景下的扩展方案 #

如果你的代码需要在多线程中共享连接，直接传可变引用会有所有权问题，这时候可以用Arc<Mutex>来包裹连接，通过锁获取可变引用：

use std::sync::{Arc, Mutex};

// 初始化线程安全的连接
let shared_conn = Arc::new(Mutex::new(establish_connection()));

// 在子线程中使用
let conn_clone = Arc::clone(&shared_conn);
std::thread::spawn(move || {
    let mut locked_conn = conn_clone.lock().unwrap();
    let users = users::table.load::<User>(&mut locked_conn).unwrap();
    // 处理查询结果
}).join().unwrap();

额外提示 #

• 确认你的Diesel版本是稳定版（比如最新的1.x系列），不同版本的trait实现细节可能略有差异，但核心规则不变：数据库操作需要修改连接状态，因此需要可变访问权限。
• 如果你使用事务，同样需要传递可变引用：conn.transaction(|tx| { ... })里的tx本身就是可变的连接引用。

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