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
//!
//! Rust Firebird Client
//!
//! High level api
//!
use rsfbclient_core::{FbError, FromRow, IntoParams};
/// Implemented for types that can be used to execute sql queries
pub trait Queryable {
/// Returns the results of the query as an iterator.
///
/// The query must be return an open cursor, so for cases like 'insert .. returning'
/// you will need to use the [execute_returnable](prelude/trait.Execute.html#tymethod.execute_returnable) method instead.
///
/// possible values for argument `params`:
///
/// `()`: no parameters,
///
/// `(param0, param1, param2...)`: a tuple of `IntoParam` values corresponding to positional `?` sql parameters
///
/// A struct for which `IntoParams` has been derived ([see there for details](prelude/derive.IntoParams.html))
fn query_iter<'a, P, R>(
&'a mut self,
sql: &str,
params: P,
) -> Result<Box<dyn Iterator<Item = Result<R, FbError>> + 'a>, FbError>
where
P: IntoParams,
R: FromRow + 'static;
/// Returns the results of the query as a `Vec`
///
/// The query must be return an open cursor, so for cases like 'insert .. returning'
/// you will need to use the [execute_returnable](prelude/trait.Execute.html#tymethod.execute_returnable) method instead.
///
/// possible values for argument `params`:
///
/// `()`: no parameters,
///
/// `(param0, param1, param2...)`: a tuple of `IntoParam` values corresponding to positional `?` sql parameters
///
/// A struct for which `IntoParams` has been derived ([see there for details](prelude/derive.IntoParams.html))
fn query<P, R>(&mut self, sql: &str, params: P) -> Result<Vec<R>, FbError>
where
P: IntoParams,
R: FromRow + 'static,
{
self.query_iter(sql, params)?.collect()
}
/// Returns the first result of the query, or None.
///
/// The query must be return an open cursor, so for cases like 'insert .. returning'
/// you will need to use the [execute_returnable](prelude/trait.Execute.html#tymethod.execute_returnable) method instead.
///
/// possible values for argument `params`:
///
/// `()`: no parameters,
///
/// `(param0, param1, param2...)`: a tuple of `IntoParam` values corresponding to positional `?` sql parameters
///
/// A struct for which `IntoParams` has been derived ([see there for details](prelude/derive.IntoParams.html))
fn query_first<P, R>(&mut self, sql: &str, params: P) -> Result<Option<R>, FbError>
where
P: IntoParams,
R: FromRow + 'static,
{
self.query_iter(sql, params)?.next().transpose()
}
}
/// Implemented for types that can be used to execute sql statements
pub trait Execute {
/// Execute a query, may or may not commit the changes
/// and returns the affected rows count
///
/// possible values for argument `params`:
///
/// `()`: no parameters,
///
/// `(param0, param1, param2...)`: a tuple of `IntoParam` values corresponding to positional `?` sql parameters
///
/// A struct for which `IntoParams` has been derived ([see there for details](prelude/derive.IntoParams.html))
fn execute<P>(&mut self, sql: &str, params: P) -> Result<usize, FbError>
where
P: IntoParams;
/// Execute a query that will return data, like the 'insert ... returning ..' or 'execute procedure'.
///
/// This method is designated for use in cases when you don't have
/// a cursor to fetch. [This link](https://www.ibexpert.net/ibe/pmwiki.php?n=Doc.DataManipulationLanguage#EXECUTEBLOCKStatement)
/// explain the Firebird behavior for this cases.
///
/// possible values for argument `params`:
///
/// `()`: no parameters,
///
/// `(param0, param1, param2...)`: a tuple of `IntoParam` values corresponding to positional `?` sql parameters
///
/// A struct for which `IntoParams` has been derived ([see there for details](prelude/derive.IntoParams.html))
fn execute_returnable<P, R>(&mut self, sql: &str, params: P) -> Result<R, FbError>
where
P: IntoParams,
R: FromRow + 'static;
}