我无法捕获数据库引用

Question

我正在尝试使用 Actix-web、async-grahpql 和 sqlx 与 postgresql

创建一个 API

在 async-graphql 的 QueryRoot 中，我试图捕获数据库的引用并使用 sqlx 查询数据库，但它给了我一个错误

 let items = Todo::list(&pool).await?;
   |                                ^^^^^ expected struct `sqlx::Pool`, found enum `std::result::Result`

这里我要抓取参考

use crate::todo::*;
use async_graphql::{Context, FieldResult};
use sqlx::postgres::PgPool;

pub struct QueryRoot;

#[async_graphql::Object]
impl QueryRoot {
    async fn todos(&self, ctx: &Context<'_>) -> FieldResult<Vec<Todo>> {
        let pool = ctx.data::<PgPool>();
        let items = Todo::list(&pool).await?; //<-- This line generates an error
 
        Ok(items)
    }
}

这里我定义引用

pub fn run(listener: TcpListener, db_pool: PgPool) -> Result<Server, std::io::Error> {

    let data_db_pool = Data::new(db_pool);

    //GraphQL
    let schema = Schema::build(QueryRoot, MutationRoot, EmptySubscription)
        .data(data_db_pool.clone()) //<- DB reference
        .finish();

    let server = HttpServer::new(move || {
        App::new()
            .app_data(db_pool.clone()) //<- DB reference
            .data(schema.clone())
            .route("/graphql", web::post().to(graphql))
            .route("/graphql", web::get().to(graphql_playground))
    })
    .listen(listener)?
    .run();
    Ok(server)
}

我做错了什么？完整代码可见here.

Answer 1

ctx.data::<T>() returns 一个 Result 包装对 T 的引用。你可能想要。

let pool = ctx.data::<PgPool>()?;
                            // ^ return on Err, otherwise yield the &PgPool
let items = Todo::list(pool).await?;
                    // ^^^^ shouldn't need & here

我无法捕获数据库引用

I can't capture the DB reference

postgresql

rust

actix-web

rust-sqlx