deuterium 0.0.1 

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


use std::sync::Arc;
use sql::{FromToSql};
use select_query::{SelectQuery, Selectable};
use insert_query::{InsertQuery, Insertable};
use update_query::{Updatable};
use delete_query::{Deletable};

use field::{NamedField, Field};
use expression::{ExprValue};

pub trait From { 
    fn as_sql(&self) -> &FromToSql;
    fn upcast_from(&self) -> RcFrom;
}

pub type BoxedFrom = Box<From + Send + Sync>;
pub type RcFrom = Arc<BoxedFrom>;

pub trait Table: Clone {
    fn upcast_table(&self) -> RcTable;
    fn get_table_name(&self) -> &String;
    fn get_table_alias(&self) -> &Option<String>;
}

pub type BoxedTable = Box<Table + Send + Sync>;
pub type RcTable = Arc<BoxedTable>;

#[deriving(Clone)]
pub struct TableDef {
    name: String,
    alias: Option<String>
}

// FIXME: Remove after all stuff in InsertQuery will be fixed
macro_rules! insert(
    ($name:ident, $(($t:ident, $arg:ident)),+) => (
        #[doc(hidden)]
        fn $name<$($t:Clone,)+>(&self, $($arg: &NamedField<$t>,)+) -> InsertQuery<($($t,)+), ($(ExprValue<$t>,)+), (), (), ()> {
            let mut cols = vec![];
            $(cols.push((*$arg).upcast_field());)+
            InsertQuery::new_with_cols(self, cols)
        }
    )
)

#[allow(dead_code)]
impl TableDef {
    pub fn new(name: &str) -> TableDef {
        TableDef { name: name.to_string(), alias: None }
    }

    pub fn new_with_alias(name: &str, alias: &str) -> TableDef {
        TableDef { name: name.to_string(), alias: Some(alias.to_string()) }
    }

    pub fn alias(&self, alias: &str) -> TableDef {
        let mut table_def = self.clone();
        table_def.alias = Some(alias.to_string());
        table_def
    }

    // FIXME: Remove after all stuff in InsertQuery will be fixed
    insert!(insert_1, (T0, _t0))
    #[doc(hidden)]
    pub fn insert_1_for_test(&self, name: &NamedField<String>) -> InsertQuery<(String,), (ExprValue<String>,), (), (), ()> {
        self.insert_1(name)
    }
}

impl Table for TableDef {
    fn upcast_table(&self) -> RcTable {
        Arc::new(box self.clone() as BoxedTable)
    }

    fn get_table_name(&self) -> &String {
        &self.name
    }

    fn get_table_alias(&self) -> &Option<String> {
        &self.alias
    }
}

impl From for TableDef {
    fn as_sql(&self) -> &FromToSql {
        self
    }

    fn upcast_from(&self) -> RcFrom {
        Arc::new(box self.clone() as BoxedFrom)
    }
}

impl Selectable<()> for TableDef {}
impl Insertable<()> for TableDef {}
impl Updatable<()> for TableDef {}
impl Deletable<()> for TableDef {}

#[deriving(Clone)]
pub struct FromSelect<T, L, M> {
    pub select: SelectQuery<T, L, M>,
    pub alias: String 
}

impl<T: Clone, L: Clone, M: Clone> From for FromSelect<T, L, M> {
    fn as_sql(&self) -> &FromToSql {
        self
    }

    fn upcast_from(&self) -> RcFrom {
        Arc::new(box self.clone() as BoxedFrom)
    }
}

impl<T: Clone, L: Clone, M: Clone> Selectable<M> for FromSelect<T, L, M> {}