burncloud-database-impl 0.1.0

Database implementations for multiple backends (PostgreSQL, MySQL, SQLite, MongoDB) for BurnCloud
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
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
118
119
120
121
122
123
124
125
126
127

use burncloud_database_core::{QueryParam};
use burncloud_database_core::error::DatabaseError;

#[derive(Debug, Clone)]
pub struct StringParam(pub String);
#[derive(Debug, Clone)]
pub struct I64Param(pub i64);
#[derive(Debug, Clone)]
pub struct F64Param(pub f64);
#[derive(Debug, Clone)]
pub struct BoolParam(pub bool);
#[derive(Debug, Clone)]
pub struct BytesParam(pub Vec<u8>);

impl QueryParam for StringParam {
    fn as_string(&self) -> String {
        self.0.clone()
    }

    fn as_i64(&self) -> Option<i64> {
        self.0.parse().ok()
    }

    fn as_f64(&self) -> Option<f64> {
        self.0.parse().ok()
    }

    fn as_bool(&self) -> Option<bool> {
        self.0.parse().ok()
    }

    fn as_bytes(&self) -> Option<&[u8]> {
        Some(self.0.as_bytes())
    }
}

impl QueryParam for I64Param {
    fn as_string(&self) -> String {
        self.0.to_string()
    }

    fn as_i64(&self) -> Option<i64> {
        Some(self.0)
    }

    fn as_f64(&self) -> Option<f64> {
        Some(self.0 as f64)
    }

    fn as_bool(&self) -> Option<bool> {
        Some(self.0 != 0)
    }

    fn as_bytes(&self) -> Option<&[u8]> {
        None
    }
}

impl QueryParam for F64Param {
    fn as_string(&self) -> String {
        self.0.to_string()
    }

    fn as_i64(&self) -> Option<i64> {
        Some(self.0 as i64)
    }

    fn as_f64(&self) -> Option<f64> {
        Some(self.0)
    }

    fn as_bool(&self) -> Option<bool> {
        Some(self.0 != 0.0)
    }

    fn as_bytes(&self) -> Option<&[u8]> {
        None
    }
}

impl QueryParam for BoolParam {
    fn as_string(&self) -> String {
        self.0.to_string()
    }

    fn as_i64(&self) -> Option<i64> {
        Some(if self.0 { 1 } else { 0 })
    }

    fn as_f64(&self) -> Option<f64> {
        Some(if self.0 { 1.0 } else { 0.0 })
    }

    fn as_bool(&self) -> Option<bool> {
        Some(self.0)
    }

    fn as_bytes(&self) -> Option<&[u8]> {
        None
    }
}

impl QueryParam for BytesParam {
    fn as_string(&self) -> String {
        String::from_utf8_lossy(&self.0).to_string()
    }

    fn as_i64(&self) -> Option<i64> {
        None
    }

    fn as_f64(&self) -> Option<f64> {
        None
    }

    fn as_bool(&self) -> Option<bool> {
        None
    }

    fn as_bytes(&self) -> Option<&[u8]> {
        Some(&self.0)
    }
}

pub fn map_database_error(error: Box<dyn std::error::Error + Send + Sync>) -> DatabaseError {
    DatabaseError::InternalError(error.to_string())
}