easy-sql 0.101.1

Macro-first SQL toolkit with compile-time checked queries, optional migrations on top of 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
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124

#[cfg(all(feature = "postgres", not(feature = "sqlite")))]
use crate::drivers::postgres::{Database, Postgres as TestDriver};

#[cfg(all(feature = "sqlite", not(feature = "postgres")))]
use crate::drivers::sqlite::{Database, Sqlite as TestDriver};

use crate::{Insert, PoolTransaction, Table, Update};
use easy_macros::{add_code, always_context};
use easy_sql_macros::query;

#[derive(Table, Debug, Clone)]
#[sql(no_version)]
struct DocUpdateTable {
    #[sql(primary_key)]
    #[sql(auto_increment)]
    id: i32,
    name: String,
    active: bool,
    nickname: Option<String>,
}

#[derive(Insert)]
#[sql(table = DocUpdateTable)]
#[sql(default = id)]
struct DocUpdateInsert {
    name: String,
    active: bool,
    nickname: Option<String>,
}

type ExampleTable = DocUpdateTable;

#[always_context(skip(!))]
#[no_context]
#[add_code(after = {
    let row: ExampleTable = query!(&mut conn,
        SELECT ExampleTable FROM ExampleTable WHERE ExampleTable.id = 1
    )
    .await?;
    assert_eq!(row.name, "updated");
    assert!(!row.active);
    Ok(())
})]
#[docify::export_content]
async fn update_basic_example(mut conn: PoolTransaction<TestDriver>) -> anyhow::Result<()> {
    #[derive(Update)]
    #[sql(table = ExampleTable)]
    struct UpdateData {
        name: String,
        active: bool,
    }

    let id = 1;
    let update = UpdateData {
        name: "updated".to_string(),
        active: false,
    };

    query!(&mut conn,
        UPDATE ExampleTable SET {update} WHERE ExampleTable.id = {id}
    )
    .await?;
}

#[always_context(skip(!))]
#[no_context]
#[add_code(after = {
    let row: ExampleTable = query!(&mut conn,
        SELECT ExampleTable FROM ExampleTable WHERE ExampleTable.id = 1
    )
    .await?;
    assert_eq!(row.nickname, None);
    Ok(())
})]
#[docify::export_content]
async fn update_partial_example(mut conn: PoolTransaction<TestDriver>) -> anyhow::Result<()> {
    #[derive(Update)]
    #[sql(table = ExampleTable)]
    struct UpdateNickname {
        nickname: Option<String>,
    }

    let id = 1;
    let update = UpdateNickname { nickname: None };

    query!(&mut conn,
        UPDATE ExampleTable SET {&update} WHERE ExampleTable.id = {id}
    )
    .await?;
}

#[always_context(skip(!))]
#[no_context]
#[tokio::test]
async fn test_update_basic_example() -> anyhow::Result<()> {
    let db = Database::setup_for_testing::<ExampleTable>().await?;
    let mut conn = db.transaction().await?;

    let data = DocUpdateInsert {
        name: "original".to_string(),
        active: true,
        nickname: Some("first".to_string()),
    };
    query!(&mut conn, INSERT INTO ExampleTable VALUES {data}).await?;

    update_basic_example(conn).await
}

#[always_context(skip(!))]
#[no_context]
#[tokio::test]
async fn test_update_partial_example() -> anyhow::Result<()> {
    let db = Database::setup_for_testing::<ExampleTable>().await?;
    let mut conn = db.transaction().await?;

    let data = DocUpdateInsert {
        name: "original".to_string(),
        active: true,
        nickname: Some("before".to_string()),
    };
    query!(&mut conn, INSERT INTO ExampleTable VALUES {data}).await?;

    update_partial_example(conn).await
}