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
107
108
109
110
111
112
113
114
115
116
117

pub struct ColArg(pub String, pub String);
use super::column::ColumnWriter;
use crate::Syntax;
use crate::model_traits::Column;

type Sql = (String, Option<String>);

pub struct InsertWriter {
    syntax: Syntax,
}

impl InsertWriter {
    pub fn new(syntax: Syntax) -> Self {
        Self { syntax }
    }
    pub fn write(
        &self,
        identifier: &str,
        colargs: &[ColArg],
        columns: &[Column],
        pks: &[Column],
    ) -> Sql {
        match self.syntax {
            Syntax::Mysql => MySql::write(identifier, colargs, columns, pks),
            Syntax::Postgres => Postgres::write(identifier, colargs, columns, pks),
            Syntax::Sqlite => Sqlite::write(identifier, colargs, columns, pks),
            Syntax::Mssql => Mssql::write(identifier, colargs, columns, pks),
        }
    }
}

struct Postgres;

impl Postgres {
    fn write(identifier: &str, colargs: &[ColArg], _columns: &[Column], _pks: &[Column]) -> Sql {
        let cols: Vec<_> = colargs.iter().map(|x| x.0.as_str()).collect();
        let args: Vec<_> = colargs.iter().map(|x| x.1.as_str()).collect();
        let col_group = cols.join(", ");
        let arg_group = args.join(", ");
        (
            format!(
                "INSERT INTO {} ({}) VALUES ({}) RETURNING *",
                identifier, col_group, arg_group
            ),
            None,
        )
    }
}

struct Sqlite;

impl Sqlite {
    fn write(identifier: &str, colargs: &[ColArg], _columns: &[Column], pks: &[Column]) -> Sql {
        let cols: Vec<_> = colargs.iter().map(|x| x.0.as_str()).collect();
        let args: Vec<_> = colargs.iter().map(|x| x.1.as_str()).collect();
        let col_group = cols.join(", ");
        let arg_group = args.join(", ");
        let insert = format!(
            "INSERT INTO {} ({}) VALUES ({})",
            identifier, col_group, arg_group
        );
        let fetch = format!(
            "SELECT * FROM {} where {}=last_insert_rowid()",
            identifier,
            pks[0].name()
        );
        (insert, Some(fetch))
    }
}

struct MySql;

impl MySql {
    fn write(identifier: &str, colargs: &[ColArg], _columns: &[Column], pks: &[Column]) -> Sql {
        let cols: Vec<_> = colargs.iter().map(|x| x.0.as_str()).collect();
        let args: Vec<_> = colargs.iter().map(|x| x.1.as_str()).collect();
        let col_group = cols.join(", ");
        let arg_group = args.join(", ");
        let insert = format!(
            "INSERT INTO {} ({}) VALUES ({})",
            identifier, col_group, arg_group
        );
        let fetch = format!(
            "SELECT * FROM {} where {}=LAST_INSERT_ID()",
            identifier,
            pks[0].name()
        );
        (insert, Some(fetch))
    }
}

struct Mssql;

impl Mssql {
    fn write(identifier: &str, colargs: &[ColArg], columns: &[Column], _pks: &[Column]) -> Sql {
        let cols: Vec<_> = colargs.iter().map(|x| x.0.as_str()).collect();
        let args: Vec<_> = colargs.iter().map(|x| x.1.as_str()).collect();
        let col_group = cols.join(", ");
        let arg_group = args.join(", ");

        // write the column select that will be returned
        let col_write = ColumnWriter::new(Syntax::Mssql);
        let return_col: Vec<String> = columns
            .iter()
            .map(|c| col_write.write("Inserted", c))
            .collect();
        let outputs = return_col.join(", ");

        (
            format!(
                "INSERT INTO {} ({}) OUTPUT {} VALUES ({})",
                identifier, col_group, outputs, arg_group
            ),
            None,
        )
    }
}