nautilus-orm-connector 1.3.4

Database executors and connection management for Nautilus ORM
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

use nautilus_core::{RowAccess, Value};

pub struct StandardUserExpectation<'a> {
    pub id: i64,
    pub name: &'a str,
    pub email: &'a str,
    pub age: i64,
    pub score: f64,
    pub active: bool,
    pub data: &'a [u8],
}

pub fn assert_standard_user_row<'row, R>(row: &'row R, expected: StandardUserExpectation<'_>)
where
    R: RowAccess<'row>,
{
    assert_eq!(row.get("id"), Some(&Value::I64(expected.id)));
    assert_eq!(
        row.get("name"),
        Some(&Value::String(expected.name.to_string()))
    );
    assert_eq!(
        row.get("email"),
        Some(&Value::String(expected.email.to_string()))
    );
    assert_eq!(row.get("age"), Some(&Value::I64(expected.age)));
    assert_eq!(row.get("score"), Some(&Value::F64(expected.score)));
    assert_eq!(row.get("active"), Some(&Value::Bool(expected.active)));
    assert_eq!(row.get("data"), Some(&Value::Bytes(expected.data.to_vec())));
}

pub fn assert_positional_projection<'row, R>(row: &'row R, id: i64, name: &str)
where
    R: RowAccess<'row>,
{
    assert_eq!(row.get_by_pos(0), Some(&Value::I64(id)));
    assert_eq!(row.get_by_pos(1), Some(&Value::String(name.to_string())));
    assert_eq!(row.get_by_pos(2), Some(&Value::Null));
    assert_eq!(row.get_by_pos(3), None);
}

pub fn assert_null_user_row<'row, R>(row: &'row R, id: i64, name: &str)
where
    R: RowAccess<'row>,
{
    assert_eq!(row.get("id"), Some(&Value::I64(id)));
    assert_eq!(row.get("name"), Some(&Value::String(name.to_string())));
    assert_eq!(row.get("email"), Some(&Value::Null));
    assert_eq!(row.get("age"), Some(&Value::Null));
    assert_eq!(row.get("score"), Some(&Value::Null));
    assert_eq!(row.get("active"), Some(&Value::Null));
    assert_eq!(row.get("data"), Some(&Value::Null));
}

pub fn assert_duplicate_projection<'row, R>(row: &'row R, id: i64, name: &str)
where
    R: RowAccess<'row>,
{
    assert_eq!(row.get("id"), Some(&Value::I64(id)));
    assert_eq!(row.len(), 3);
    assert_eq!(row.get_by_pos(0), Some(&Value::I64(id)));
    assert_eq!(row.get_by_pos(1), Some(&Value::String(name.to_string())));
    assert_eq!(row.get_by_pos(2), Some(&Value::I64(id)));
}

pub fn assert_sequential_user_rows<'row, R>(rows: &'row [R], start: i64)
where
    R: RowAccess<'row>,
{
    for (i, row) in rows.iter().enumerate() {
        let expected_id = start + i as i64;
        assert_eq!(row.get("id"), Some(&Value::I64(expected_id)));
        assert_eq!(
            row.get("name"),
            Some(&Value::String(format!("User{}", expected_id)))
        );
    }
}