gatekeep-sqlx 0.1.0

SQLx query lowering adapter for gatekeep
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
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69

use sqlx::{
    Postgres, QueryBuilder,
    types::{
        Uuid,
        time::{Date, PrimitiveDateTime, Time},
    },
};

use crate::support::{TestError, TestResult, pool, push_typed_bind};

#[tokio::test]
#[ignore = "requires docker postgres; run `make test-db`"]
async fn common_postgres_bind_values_round_trip() -> TestResult<()> {
    let pool = pool().await?;
    let uuid = Uuid::from_u128(0x123e_4567_e89b_12d3_a456_4266_1417_4000);
    let date = Date::from_ordinal_date(2026, 171).map_err(|_| TestError::InvalidTemporalValue)?;
    let time = Time::from_hms(14, 30, 15).map_err(|_| TestError::InvalidTemporalValue)?;
    let timestamp = PrimitiveDateTime::new(date, time);
    let timestamptz = timestamp.assume_utc();
    let bytes = vec![1, 2, 3, 4];
    let mut query = QueryBuilder::<Postgres>::new("SELECT ");

    push_typed_bind(&mut query, true, "boolean", false);
    push_typed_bind(&mut query, 7_i16, "smallint", true);
    push_typed_bind(&mut query, 42_i32, "integer", true);
    push_typed_bind(&mut query, 99_i64, "bigint", true);
    push_typed_bind(&mut query, "owner", "text", true);
    push_typed_bind(&mut query, bytes.clone(), "bytea", true);
    push_typed_bind(&mut query, uuid, "uuid", true);
    push_typed_bind(&mut query, date, "date", true);
    push_typed_bind(&mut query, time, "time", true);
    push_typed_bind(&mut query, timestamp, "timestamp", true);
    push_typed_bind(&mut query, timestamptz, "timestamptz", true);

    let row = query
        .build_query_as::<(
            bool,
            i16,
            i32,
            i64,
            String,
            Vec<u8>,
            Uuid,
            Date,
            Time,
            PrimitiveDateTime,
            sqlx::types::time::OffsetDateTime,
        )>()
        .fetch_one(&pool)
        .await?;

    assert_eq!(
        row,
        (
            true,
            7,
            42,
            99,
            "owner".to_owned(),
            bytes,
            uuid,
            date,
            time,
            timestamp,
            timestamptz,
        )
    );
    Ok(())
}