xitca-postgres 0.4.0

an async postgres client
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

//! example of implementing proc macro to expand functionality of xitca-postgres

use std::future::IntoFuture;

use xitca_postgres::{Execute, Postgres, iter::AsyncLendingIterator};
// an example proc macro
use xitca_postgres_codegen::sql;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
    let (cli, drv) = Postgres::new("postgres://postgres:postgres@localhost:5432")
        .connect()
        .await?;
    tokio::spawn(drv.into_future());

    std::path::Path::new("./samples/test.sql").execute(&cli).await?;

    // this macro is expand into xitca_postgres::statement::Statement::unnamed
    // it's also possible to utilize xitca-postgres's Execute traits for more customizable macro usage
    let mut stream = sql!("SELECT * FROM foo WHERE id = $1 AND name = $2", &1i32, &"alice")
        .query(&cli)
        .await?;

    // the macro also have basic function for sql validation check. try uncomment below to see compile error.
    // let _ = sql!("SELECT * FRO foo WHERR id = $1 AN name = $2", &1i32, &"alice");

    let row = stream.try_next().await?.ok_or("row not found")?;

    assert_eq!(row.get::<&str>("name"), "alice");

    Ok(())
}