0

我正在尝试使用 Actix-web、async-grahpql 和 sqlx 和 postgresql 创建一个 API

在QueryRootasync-graphql 中，我试图捕获数据库的引用并使用 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)
}

我究竟做错了什么？完整的代码可以在这里找到。

4

1 回答 1

2

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
于 2020-10-18T04:14:30.267 回答