async-graphql / examples

217 stars 54 forks source link

deadpool-postgres cursor connections - how to implement? #29

Closed maz000 closed 3 years ago

maz000 commented 3 years ago

I am new to rust and try to implement cursor connections on user lists. please help.

let client: Client = self.pool.get().await.map_err(|err| {
            error!("Error getting client {}", err; "query" => "user_users");
            err
        })?;
let statement = client.prepare("select * from user_users").await?;

        let users = client
            .query(&statement, &[])
            .await
            .map_err(|err| {
                error!("Error getting users. {}", err; "query" => "user_users");
                err
            })?
            .iter()
            .map(|row| User::from_row_ref(row))
            .collect::<Result<Vec<User>, _>>()
            .map_err(|err| {
                error!("Error getting parsing users. {}", err; "query" => "user_users");
                err
            })?;