FastORM 0.1.0

ORM based on sqlx
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 fastorm_trait::CmpOperator;
use fastorm_trait::Location;
use fastorm_trait::LocationExpr;
use fastorm_trait::Selection;
use fastorm_macro::Location;
use fastorm_macro::Selection;
use serde::{Deserialize, Serialize};
use serde_json;
use sqlx::any::AnyArguments;
use sqlx::Arguments;
use sqlx::{any::AnyRow, Row};

#[derive(Selection, Serialize, Deserialize, Clone, Debug)]
pub struct UserSelection {
    #[serde(skip_serializing_if = "Option::is_none")]
    name: Option<bool>,
    #[serde(skip_serializing_if = "Option::is_none")]
    age: Option<bool>,
}

#[derive(Location, Serialize, Deserialize, Clone, Debug)]
pub struct UserLocation {
    #[serde(skip_serializing_if = "Option::is_none")]
    name: Option<LocationExpr<String>>,
    #[serde(skip_serializing_if = "Option::is_none")]
    age: Option<LocationExpr<i32>>,
}

#[derive(Selection, Serialize, Deserialize, Clone, Debug)]
pub struct ClassSelection {
    #[serde(skip_serializing_if = "Option::is_none")]
    student_name: Option<bool>,
    #[serde(skip_serializing_if = "Option::is_none")]
    class_name: Option<bool>,
}

#[derive(Location, Serialize, Deserialize, Clone, Debug)]
pub struct ClassLocation {
    #[serde(skip_serializing_if = "Option::is_none")]
    student_name: Option<LocationExpr<String>>,
    #[serde(skip_serializing_if = "Option::is_none")]
    class_name: Option<LocationExpr<String>>,
}

#[derive(Serialize, Deserialize, Debug, Clone)]
pub struct UserJoinedQuery {
    selection: UserSelection,
    location: UserLocation,
}

#[derive(Serialize, Deserialize, Debug, Clone)]
pub struct ClassJoinedQuery {
    #[serde(flatten)]
    selection: ClassSelection,
    #[serde(alias = "where")]
    location: ClassLocation,
}

#[derive(Serialize, Deserialize, Debug, Clone)]
pub struct JoinedQuery {
    student: UserJoinedQuery,
    class: ClassJoinedQuery,
}

#[tokio::test]
pub async fn test_location() {
    let content = "{ \"student_name\": true, \"class_name\": null }";
    let result: Result<ClassSelection, _> = serde_json::from_str(content);
    assert_eq!(result.is_ok(), true);
    let ClassSelection {
        student_name,
        class_name,
    } = result.unwrap();
    assert_eq!(student_name, Some(true));
    assert_eq!(class_name, None);

    let content = "{ \"student_name\": true }";
    let result: Result<ClassSelection, _> = serde_json::from_str(content);
    assert_eq!(result.is_ok(), true);
    let ClassSelection {
        student_name,
        class_name,
    } = result.unwrap();
    assert_eq!(student_name, Some(true));
    assert_eq!(class_name, None);

    let content = "{ \"student_name\": {\"cmp\": \"=\", \"val\": \"hello\"} }";
    let result: Result<ClassLocation, _> = serde_json::from_str(content);
    dbg!(&result);
    assert_eq!(result.is_ok(), true);
    let ClassLocation {
        student_name,
        class_name,
    } = result.unwrap();
    assert_eq!(
        student_name,
        Some(LocationExpr {
            cmp: CmpOperator::Eq,
            val: "hello".to_string()
        })
    );
}