deuterium 0.1.1

Deuterium is a fancy SQL builder for Rust. It's designed to provide a DSL to easily build SQL queries in safe and *typed* way.
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


pub use self::predicate::{PredicateToSql};
pub use self::value::{ToPredicateValue};
#[cfg(feature = "postgres")] pub use self::value::{AsPostgresValue};
pub use self::from::{FromToSql};
pub use self::adapter::{
    SqlAdapter,
    PostgreSqlAdapter,
};

pub mod delete;
pub mod distinct;
pub mod expr_value;
pub mod field;
pub mod function;
pub mod group_by;
pub mod insert;
pub mod join;
pub mod order_by;
pub mod placeholder;
pub mod predicate;
pub mod select;
pub mod from;
pub mod update;
pub mod value;
pub mod adapter;

pub trait QueryToSql: ToSql {
    fn to_final_sql(&self, ctx: &mut SqlContext) -> String {
        let mut sql = format!("{};", self.to_sql(ctx));
        let mut idx = ctx.get_expl_placeholders_count() + 1;
        for i in range(0, ctx.get_impl_placeholders_count()) {
            sql = sql.replace(format!("$${}", i).as_slice(), ctx.adapter().placeholder(idx).as_slice());
            idx += 1
        }

        sql
    }
}

pub trait ToSql {
    fn to_sql(&self, ctx: &mut SqlContext) -> String;
}

#[cfg(feature = "postgres")]
pub type BoxedValue = Box<AsPostgresValue + Send + Sync>;
#[cfg(not(feature = "postgres"))]
pub type BoxedValue = Box<ToPredicateValue + Send + Sync>;
pub type BoxedAdapter = Box<SqlAdapter + Send + Sync>;

#[allow(dead_code)]
pub struct SqlContext {
    impl_placeholders: uint,
    expl_placeholders: uint,
    placeholder_data: Vec<BoxedValue>,
    adapter: Box<SqlAdapter + Send + Sync>,
}

#[allow(dead_code)]
impl SqlContext {
    pub fn new(adapter: Box<SqlAdapter + Send + Sync>) -> SqlContext {
        SqlContext {
            impl_placeholders: 0,
            expl_placeholders: 0,
            placeholder_data: vec![],
            adapter: adapter,
        }
    }

    pub fn hold(&mut self, val: BoxedValue) -> String {
        self.placeholder_data.push(val);
        let res = format!("$${}", self.impl_placeholders);
        self.impl_placeholders += 1;
        res
    }

    pub fn get_impl_placeholders_count(&self) -> uint {
        self.impl_placeholders
    }

    pub fn get_expl_placeholders_count(&self) -> uint {
        self.expl_placeholders
    }

    pub fn adapter(&self) -> &BoxedAdapter {
        &self.adapter
    }

    pub fn expl_indexed_placeholder(&mut self, idx: uint) {
        if idx > self.expl_placeholders { self.expl_placeholders = idx; }
    }

    pub fn data(&self) -> &[BoxedValue] {
        self.placeholder_data.as_slice()
    }
}