主页 / coding / 问题 / 79312544
Accepted
Kadiem Alqazzaz
Asked: 2024-12-28 02:26:03 +0800 CST

Rust Axum 将状态传递给嵌套路由器

  • 772

以下是主要Router内容async fn main()

let pool = PgPoolOptions::new()
    .max_connections(5)
    .acquire_timeout(Duration::from_secs(3))
    .connect(&db_connection_str)
    .await
    .expect("can't connect to database");

let app = Router::new().nest("/products", create_products_router()).with_state(&pool);

出现此错误&pool

类型不匹配 [E0308] 预期()，但发现 &sqlx_core::pool::Pool<sqlx_postgres::database::Postgres>

这是嵌套的Router

pub fn create_products_router() -> Router {
    Router::new()
        .route("/products", get(get_products_list::get_products_list))
}

收到此错误：

类型不匹配 [E0308] 预期 axum::routing::method_routing::MethodRouter，但发现 axum::routing::method_routing::MethodRouter<sqlx_postgres::PgPool>

最后函数本身

pub async fn get_products_list(State(pool): State<PgPool>,) -> Result<String, (StatusCode, String)> {
   sqlx::query_scalar("select * from product")
        .fetch(&pool)
       .await
       .map_err(internal_error)
}

如何pool从主函数传递Router到嵌套Router函数get_products_list？

rust

1 个回答

  1. Best Answer

    在类型中Router<S>，S是缺失状态的类型。在此函数中：

    pub fn create_products_router() -> Router { ... }

    由于您没有指定S，因此默认为()。明确指定通用参数为路由器所需的状态类型：

    pub fn create_products_router() -> Router<PgPool> { ... }
    • 1

相关问题