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
use super::{AstPass, QueryBuilder, QueryFragment};
use crate::backend::Backend;
use std::fmt::{self, Debug, Display};
use std::marker::PhantomData;
pub struct DebugQuery<'a, T: 'a, DB> {
pub(crate) query: &'a T,
_marker: PhantomData<DB>,
}
impl<'a, T, DB> DebugQuery<'a, T, DB> {
pub(crate) fn new(query: &'a T) -> Self {
DebugQuery {
query,
_marker: PhantomData,
}
}
}
impl<'a, T, DB> Display for DebugQuery<'a, T, DB>
where
DB: Backend + Default,
DB::QueryBuilder: Default,
T: QueryFragment<DB>,
{
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
let mut query_builder = DB::QueryBuilder::default();
let backend = DB::default();
QueryFragment::<DB>::to_sql(self.query, &mut query_builder, &backend)
.map_err(|_| fmt::Error)?;
let debug_binds = DebugBinds::<_, DB>::new(self.query);
write!(f, "{} -- binds: {:?}", query_builder.finish(), debug_binds)
}
}
impl<'a, T, DB> Debug for DebugQuery<'a, T, DB>
where
DB: Backend + Default,
DB::QueryBuilder: Default,
T: QueryFragment<DB>,
{
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
let mut query_builder = DB::QueryBuilder::default();
let backend = DB::default();
QueryFragment::<DB>::to_sql(self.query, &mut query_builder, &backend)
.map_err(|_| fmt::Error)?;
let debug_binds = DebugBinds::<_, DB>::new(self.query);
f.debug_struct("Query")
.field("sql", &query_builder.finish())
.field("binds", &debug_binds)
.finish()
}
}
pub(crate) struct DebugBinds<'a, T: 'a, DB> {
query: &'a T,
_marker: PhantomData<DB>,
}
impl<'a, T, DB> DebugBinds<'a, T, DB> {
fn new(query: &'a T) -> Self {
DebugBinds {
query,
_marker: PhantomData,
}
}
}
impl<'a, T, DB> Debug for DebugBinds<'a, T, DB>
where
DB: Backend + Default,
T: QueryFragment<DB>,
{
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
let mut buffer = Vec::new();
let backend = DB::default();
let ast_pass = AstPass::debug_binds(&mut buffer, &backend);
self.query.walk_ast(ast_pass).map_err(|_| fmt::Error)?;
let mut list = f.debug_list();
for entry in buffer {
list.entry(entry);
}
list.finish()?;
Ok(())
}
}