toasty 0.11.0

An async ORM for Rust supporting SQL and NoSQL databases
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

use toasty_core::{
    driver::{ExecResponse, operation},
    stmt,
};

use crate::{
    Result,
    engine::{exec::Exec, mir},
};

impl Exec<'_> {
    pub(super) async fn exec_upsert(&mut self, action: &mir::Upsert) -> Result<ExecResponse> {
        let mut stmt = stmt::Statement::from(action.stmt.clone());

        if !action.inputs.is_empty() {
            let input = self.collect_input(action.inputs.iter().copied()).await?;
            stmt.substitute(&input);
            self.engine.simplify_stmt(&mut stmt);
        }

        let params = self.engine.prepare_for_driver(&mut stmt);
        let op = operation::Upsert {
            stmt: stmt.into_insert_unwrap(),
            params,
            ret: mir::row_field_types(&action.ty),
        };

        self.connection.exec(&self.engine.schema, op.into()).await
    }
}