gluesql-macros 0.18.0

Derive macro for gluesql row conversion
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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

use {
    gluesql_core::{
        data::Value,
        executor::Payload,
        row_conversion::{RowConversionError, SelectExt},
    },
    gluesql_macros::FromGlueRow,
};

#[allow(dead_code)]
#[derive(Debug, FromGlueRow)]
struct NeedsName {
    id: i64,
    name: String,
}

#[test]
fn missing_column() {
    let payload = Payload::Select {
        labels: vec!["id".into()], // name missing
        rows: vec![vec![Value::I64(1)]],
    };
    let err = payload.rows_as::<NeedsName>().unwrap_err();
    assert!(matches!(err, RowConversionError::MissingColumn { .. }));
}

#[allow(dead_code)]
#[derive(Debug, FromGlueRow)]
struct NonNullable {
    id: i64,
    name: String, // name cannot be Null
}

#[test]
fn null_not_allowed() {
    let payload = Payload::Select {
        labels: vec!["id".into(), "name".into()],
        rows: vec![vec![Value::I64(1), Value::Null]],
    };
    let err = payload.rows_as::<NonNullable>().unwrap_err();
    assert!(matches!(err, RowConversionError::NullNotAllowed { .. }));
}

#[allow(dead_code)]
#[derive(Debug, FromGlueRow)]
struct Price {
    price: f64,
}

#[test]
fn type_mismatch() {
    let payload = Payload::Select {
        labels: vec!["price".into()],
        rows: vec![vec![Value::Str("9.99".into())]], // string -> f64 forbidden
    };
    let err = payload.rows_as::<Price>().unwrap_err();
    assert!(matches!(err, RowConversionError::TypeMismatch { .. }));
}

#[derive(Debug, PartialEq, FromGlueRow)]
struct User {
    id: i64,
    name: String,
    email: Option<String>,
}

#[test]
fn not_select_payload() {
    let payload = Payload::Insert(1);
    let err = payload.rows_as::<User>().unwrap_err();
    assert!(matches!(err, RowConversionError::NotSelectPayload));
}

#[test]
fn one_as_not_found() {
    let payload = Payload::Select {
        labels: vec!["id".into()],
        rows: vec![],
    };
    let err = payload.one_as::<User>().unwrap_err();
    assert!(matches!(err, RowConversionError::NotFound));
}

#[test]
fn one_as_more_than_one() {
    let payload = Payload::Select {
        labels: vec!["id".into(), "name".into(), "email".into()],
        rows: vec![
            vec![Value::I64(1), Value::Str("A".into()), Value::Null],
            vec![Value::I64(2), Value::Str("B".into()), Value::Null],
        ],
    };
    let err = payload.one_as::<User>().unwrap_err();
    assert!(matches!(err, RowConversionError::MoreThanOneRow { .. }));
}

#[test]
fn one_as_not_select_payload_on_payload() {
    let payload = Payload::Insert(1);
    let err = payload.one_as::<User>().unwrap_err();
    assert!(matches!(err, RowConversionError::NotSelectPayload));
}