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
#[macro_export]
macro_rules! sea_query_driver_rusqlite {
() => {
mod sea_query_driver_rusqlite {
use rusqlite::{types::ToSqlOutput, Result, ToSql};
use sea_query::{Value, Values};
pub struct RusqliteValue(pub Value);
pub struct RusqliteValues(pub Vec<RusqliteValue>);
impl From<Values> for RusqliteValues {
fn from(values: Values) -> RusqliteValues {
RusqliteValues(values.0.into_iter().map(|v| RusqliteValue(v)).collect())
}
}
impl<'a> RusqliteValues {
pub fn as_params(&'a self) -> Vec<&'a dyn ToSql> {
self.0
.iter()
.map(|x| {
let y: &dyn ToSql = x;
y
})
.collect()
}
}
impl ToSql for RusqliteValue {
fn to_sql(&self) -> Result<ToSqlOutput<'_>> {
macro_rules! to_sql {
( $v: expr, $ty: ty ) => {
match $v {
Some(v) => v.to_sql(),
None => None::<$ty>.to_sql(),
}
};
}
macro_rules! box_to_sql {
( $v: expr, $ty: ty ) => {
match $v {
Some(v) => v.as_ref().to_sql(),
None => None::<$ty>.to_sql(),
}
};
}
match &self.0 {
Value::Bool(v) => to_sql!(v, bool),
Value::TinyInt(v) => to_sql!(v, i8),
Value::SmallInt(v) => to_sql!(v, i16),
Value::Int(v) => to_sql!(v, i32),
Value::BigInt(v) => to_sql!(v, i64),
Value::TinyUnsigned(v) => to_sql!(v, u32),
Value::SmallUnsigned(v) => to_sql!(v, u32),
Value::Unsigned(v) => to_sql!(v, u32),
Value::BigUnsigned(v) => to_sql!(v, i64),
Value::Float(v) => to_sql!(v, f32),
Value::Double(v) => to_sql!(v, f64),
Value::String(v) => box_to_sql!(v, String),
Value::Bytes(v) => box_to_sql!(v, Vec<u8>),
_ => {
if self.0.is_json() {
(*self.0.as_ref_json()).to_sql()
} else if self.0.is_date() {
(*self.0.as_ref_date()).to_sql()
} else if self.0.is_time() {
(*self.0.as_ref_time()).to_sql()
} else if self.0.is_date_time() {
(*self.0.as_ref_date_time()).to_sql()
} else if self.0.is_date_time_with_time_zone() {
(*self.0.as_ref_date_time_with_time_zone()).to_sql()
} else if self.0.is_uuid() {
(*self.0.as_ref_uuid()).to_sql()
} else {
unimplemented!();
}
}
}
}
}
}
};
}