使用rocket_sync_db_pools查询Diesel MySQL数据库时遇Trait实现错误

错误原因分析 #

1. 第一个错误LoadConnection未实现：代码同时导入了独立diesel crate和rocket_sync_db_pools集成的diesel模块，导致连接类型不匹配——rocket_sync_db_pools::diesel::MysqlConnection与独立diesel crate的LoadConnection trait不兼容。
2. 第二个错误Poolable未满足：rocket_sync_db_pools仅为自身集成的rocket_sync_db_pools::diesel::MysqlConnection实现了Poolable trait，直接使用diesel::MySqlConnection不符合池化要求。

修复步骤及代码调整 #

1. 统一Diesel模块导入 #

所有Diesel相关导入都使用rocket_sync_db_pools提供的版本，避免类型冲突。修改main.rs中的导入：

// 替换原有的 use diesel::prelude::*;
use rocket_sync_db_pools::diesel::prelude::*;
// 新增必要类型导入
use rocket::serde::json::Json;
use crate::db_utils::models::Price;

2. 保留正确的数据库连接定义 #

维持DbConn使用rocket_sync_db_pools集成的连接类型，不要替换为独立的diesel::MySqlConnection：

#[database("my_db")]
pub struct DbConn(rocket_sync_db_pools::diesel::MysqlConnection);

3. 调整查询逻辑并处理错误 #

load方法返回Result，需在路由函数中处理；同时无需传递&mut c，run闭包中的c已是可直接使用的连接引用：

#[get("/")]
fn index(conn: DbConn) -> Result<Json<Vec<Price>>, diesel::result::Error> {
    conn.run(|c| {
        schema::prices::dsl::prices.load::<Price>(c)
    })
}

4. 同步模型文件的Diesel导入 #

修改db_utils/models.rs中的Diesel导入，确保与主文件使用同一版本：

use rocket_sync_db_pools::diesel::prelude::*;

#[derive(Queryable)]
pub struct Price {
  pub id: i32,
  pub date: String,
  pub ticker: String,
  pub price: f32
}

5. 完整修改后的main.rs #

#[macro_use] extern crate rocket;
#[macro_use] extern crate diesel;
#[macro_use] extern crate diesel_migrations;
#[macro_use] extern crate rocket_sync_db_pools;

mod schema;
mod db_utils;

use rocket::{Rocket, Build};
use rocket::serde::json::Json;
use rocket_sync_db_pools::diesel::prelude::*;
use crate::db_utils::models::Price;

#[database("my_db")]
pub struct DbConn(rocket_sync_db_pools::diesel::MysqlConnection);

#[get("/")]
fn index(conn: DbConn) -> Result<Json<Vec<Price>>, diesel::result::Error> {
    conn.run(|c| {
        schema::prices::dsl::prices.load::<Price>(c)
    })
}

#[launch]
fn rocket() -> _ {
    rocket::build()
        .attach(DbConn::fairing())
        .mount("/", routes![index])
}

关键说明 #

• rocket_sync_db_pools内部封装了Diesel连接池实现，必须使用其提供的diesel子模块和连接类型，才能保证trait兼容性。
• 路由函数返回Result可让Rocket自动处理错误状态码（如500），无需手动捕获。

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