serde-pgrow 0.3.6

Deserialize a serde-type from a PgRow
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
70
71

mod common;

use ::serde_json::Value as JsValue;

#[tokio::test]
// #[ignore]
async fn t_pg_arr_of_bool_as_vec_bool() {
    // common::init_logger();
    let out = common::pg_query_and_de::<Vec<bool>>(
        "SELECT array_agg(R.a) FROM (SELECT true a UNION ALL SELECT false) R",
        &[],
    )
    .await
    .unwrap();
    assert_eq!(out, vec![vec![true, false]])
}

#[tokio::test]
// #[ignore]
async fn t_pg_arr_of_int4_as_vec_i32() {
    // common::init_logger();
    let out = common::pg_query_and_de::<Vec<i32>>(
        "SELECT array_agg(R.a) FROM (SELECT 42 a UNION ALL SELECT 0) R",
        &[],
    )
    .await
    .unwrap();
    assert_eq!(out, vec![vec![42, 0]])
}

#[tokio::test]
// #[ignore]
async fn t_pg_arr_of_text_as_vec_nullable_string() {
    // common::init_logger();
    let out = common::pg_query_and_de::<Vec<Option<String>>>(
        "SELECT array_agg(R.a) FROM (SELECT 'a string' a UNION ALL SELECT NULL) R",
        &[],
    )
    .await
    .unwrap();
    assert_eq!(out, vec![vec![Some("a string".to_owned()), None]])
}

#[tokio::test]
// #[ignore]
async fn t_pg_arr_of_varchar_as_vec_nullable_string() {
    // common::init_logger();
    let out = common::pg_query_and_de::<Vec<Option<String>>>(
        "SELECT array_agg(R.a) FROM (SELECT 'a string' :: VARCHAR a UNION ALL SELECT NULL) R",
        &[],
    )
    .await
    .unwrap();
    assert_eq!(out, vec![vec![Some("a string".to_owned()), None]])
}

#[tokio::test]
// #[ignore]
async fn t_pg_arr_of_jsonb_as_vec_of_jsvalue() {
    // common::init_logger();
    let out = common::pg_query_and_de::<Vec<JsValue>>(
        "SELECT array_agg(R.a) FROM (SELECT '1' :: JSONB a UNION ALL SELECT '2' :: JSONB) R",
        &[],
    )
    .await
    .unwrap();
    assert_eq!(
        out,
        vec![vec![::serde_json::json!(1), ::serde_json::json!(2),]]
    )
}