welds 0.4.23

An async ORM for (postgres, mssql, mysql, sqlite)
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

use crate::Syntax;
use crate::query::builder::ManualParam;
use crate::query::builder::QueryBuilder;

// Testing that the tail end of the SQL is correct
// Limits / skips / orders
use crate::WeldsModel;

#[derive(Debug, Default, WeldsModel)]
#[welds(table = "nums")]
#[welds_path(crate)] // needed only within the welds crate.
struct Product {
    #[welds(primary_key)]
    pub id: i32,
    pub a: i32,
    pub b: i32,
}

// Tests

#[test]
fn should_be_able_to_write_simple_set_value() {
    futures::executor::block_on(async move {
        // setup the query
        let q = QueryBuilder::<Product>::new();
        let bulk = q.set(|p| p.a, 1);

        //setup the fake client and run it.
        let client = welds_connections::noop::build(Syntax::Postgres);
        let _ = bulk.run(&client).await;

        let ran_sql = client
            .last_sql()
            .expect("Expected to get SQL back from client");

        let expected = "UPDATE nums SET \"a\"=$1";
        assert_eq!(expected, &ran_sql);

        assert_eq!(client.args_count().unwrap(), 1);
    });
}

#[test]
fn should_be_able_to_write_complex_set_values() {
    futures::executor::block_on(async move {
        // setup the query
        let q = QueryBuilder::<Product>::new().where_col(|c| c.id.gt(10));
        let bulk = q.set(|p| p.a, 1).set(|p| p.b, 2);

        //setup the fake client and run it.
        let client = welds_connections::noop::build(Syntax::Postgres);
        let _ = bulk.run(&client).await;

        let ran_sql = client
            .last_sql()
            .expect("Expected to get SQL back from client");

        let expected = "UPDATE nums SET \"a\"=$1, \"b\"=$2 WHERE ( nums.\"id\" > $3 )";
        assert_eq!(expected, &ran_sql);

        assert_eq!(client.args_count().unwrap(), 3);
    });
}

#[test]
fn should_be_able_to_write_complex_set_col_values() {
    futures::executor::block_on(async move {
        let q = QueryBuilder::<Product>::new().where_col(|c| c.id.gt(10));

        let bulk = q.set_col(|x| x.a.equal(2)).set_col(|p| p.b.equal(2));

        //setup the fake client and run it.
        let client = welds_connections::noop::build(Syntax::Postgres);
        let _ = bulk.run(&client).await;

        let ran_sql = client
            .last_sql()
            .expect("Expected to get SQL back from client");

        //let expected = "UPDATE nums SET nums.a = $1, nums.b = $2 WHERE ( nums.id > $3 )";
        let expected = "UPDATE nums SET \"a\"=$1, \"b\"=$2 WHERE ( nums.\"id\" > $3 )";
        assert_eq!(expected, &ran_sql);
    });
}

#[test]
fn should_be_able_to_write_a_custom_set_statement() {
    futures::executor::block_on(async move {
        let params = ManualParam::new().push(42);

        let q = QueryBuilder::<Product>::new()
            .where_col(|c| c.id.gt(10))
            .set_manual(|p| p.a, "$.b + ?", params);

        //setup the fake client and run it.
        let client = welds_connections::noop::build(Syntax::Postgres);
        let _ = q.run(&client).await;

        let ran_sql = client
            .last_sql()
            .expect("Expected to get SQL back from client");

        let expected = "UPDATE nums SET \"a\" = ( nums.b + $1 ) WHERE ( nums.\"id\" > $2 )";
        assert_eq!(expected, &ran_sql);
    });
}