postgresql - 我无法捕获数据库引用

Question

我正在尝试使用带有Postgresql的Actix-web，async-grahpql和sqlx创建一个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>() 返回包装了对Result的引用的T。您可能想要。

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