ciboulette2pg 0.1.3

Library to execute Ciboulette query to Postgres and build responses back
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

use super::*;

impl<'request> Ciboulette2PgBuilder<'request> {
    /// Generate a insert query for `POST` requests
    pub(crate) fn gen_insert_normal(
        &mut self,
        table: &Ciboulette2PgTable,
        params: Vec<(ArcStr, Ciboulette2PgValue<'request>)>,
        returning: bool,
    ) -> Result<(), Ciboulette2PgError> {
        self.buf.write_all(b"INSERT INTO ")?;
        self.write_table_info(table)?;
        self.buf.write_all(b" ")?;
        match params.len() {
            0 => {
                self.buf.write_all(b"DEFAULT VALUES")?; // Inserts default values if none are provided
            }
            _ => {
                self.gen_normal_insert_values(params, table)?;
            }
        };
        if returning {
            self.buf.write_all(b" RETURNING *")?;
        }
        Ok(())
    }

    /// Generate columns name before the "VALUES" and insert the parameters after that
    fn gen_normal_insert_values(
        &mut self,
        params: Vec<(ArcStr, Ciboulette2PgValue<'request>)>,
        table: &Ciboulette2PgTable,
    ) -> Result<(), Ciboulette2PgError> {
        let mut param_ident: Vec<Ciboulette2PgTableField> = Vec::with_capacity(params.len());
        let mut param_value: Vec<Ciboulette2PgValue<'request>> = Vec::with_capacity(params.len());
        for (n, v) in params.into_iter() {
            param_ident.push(Ciboulette2PgTableField::new(
                Ciboulette2PgSafeIdentSelector::Single(Ciboulette2PgSafeIdent::try_from(n)?),
                None,
                None,
            ));
            param_value.push(v);
        }
        self.write_list(&param_ident, &table, true, Self::insert_ident_name)?;
        self.buf.write_all(b" VALUES ")?;
        self.write_list(param_value, &table, true, Self::insert_params)?;
        Ok(())
    }
}