py_sql 1.0.1

Rust SQL wrapper lang
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

use serde_json::Value;

use crate::ast::RbatisAST;
use crate::node::node::do_child_nodes;
use crate::node::node_type::NodeType;
use rexpr::runtime::RExprRuntime;

#[derive(Clone, Debug)]
pub struct WhereNode {
    pub childs: Vec<NodeType>,
}

impl WhereNode {
    pub fn from(
        source: &str,
        express: &str,
        childs: Vec<NodeType>,
    ) -> Result<Self, crate::error::Error> {
        //let express = express[Self::name().len()..].trim();
        return Ok(WhereNode { childs });
    }
}

impl RbatisAST for WhereNode {
    fn name() -> &'static str {
        "where"
    }
    fn eval(
        &self,
        convert: &dyn crate::StringConvert,
        env: &mut Value,
        engine: &RExprRuntime,
        arg_array: &mut Vec<Value>,
        arg_sql: &mut String,
    ) -> Result<serde_json::Value, crate::error::Error> {
        let mut child_sql = String::new();
        do_child_nodes(
            convert,
            &self.childs,
            env,
            engine,
            arg_array,
            &mut child_sql,
        )?;
        let mut result = child_sql.trim();
        if result.is_empty() {
            return Result::Ok(serde_json::Value::Null);
        } else {
            result = result
                .trim_start_matches("and")
                .trim_start_matches("AND")
                .trim_start_matches("And")
                .trim_start_matches("or")
                .trim_start_matches("Or")
                .trim_start_matches("OR");
            arg_sql.push_str(" WHERE ");
            arg_sql.push_str(result);
            return Result::Ok(serde_json::Value::Null);
        }
    }
}