aykroyd 0.3.1

Zero-overhead ergonomic data access for Rust.
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

pub mod params_iter {
    pub struct ParamsIter<'a>(Vec<&'a (dyn tokio_postgres::types::ToSql + Sync)>);

    impl<'a> ParamsIter<'a> {
        pub fn from_params(
            params: Option<Vec<&'a (dyn tokio_postgres::types::ToSql + Sync)>>,
        ) -> Self {
            let params = match params {
                None => vec![],
                Some(mut params) => {
                    params.reverse();
                    params
                }
            };
            ParamsIter(params)
        }
    }

    impl<'a> std::iter::Iterator for ParamsIter<'a> {
        type Item = &'a (dyn tokio_postgres::types::ToSql + Sync);

        fn next(&mut self) -> Option<&'a (dyn tokio_postgres::types::ToSql + Sync)> {
            self.0.pop()
        }

        fn size_hint(&self) -> (usize, Option<usize>) {
            (self.0.len(), Some(self.0.len()))
        }
    }

    impl<'a> std::iter::ExactSizeIterator for ParamsIter<'a> {}
}

#[macro_export]
macro_rules! postgres_client {
    (
        $client:ty
    ) => {
        /// The type of errors from a `Client`.
        pub type Error = error::Error<tokio_postgres::Error>;

        impl<T> FromColumnIndexed<$client> for T
        where
            T: tokio_postgres::types::FromSqlOwned,
        {
            fn from_column(row: &tokio_postgres::Row, index: usize) -> Result<Self, Error> {
                row.try_get(index).map_err(Error::from_column)
            }
        }

        impl<T> FromColumnNamed<$client> for T
        where
            T: tokio_postgres::types::FromSqlOwned,
        {
            fn from_column(row: &tokio_postgres::Row, name: &str) -> Result<Self, Error> {
                row.try_get(name).map_err(Error::from_column)
            }
        }

        impl<T> ToParam<$client> for T
        where
            T: tokio_postgres::types::ToSql + Sync,
        {
            fn to_param(&self) -> &(dyn tokio_postgres::types::ToSql + Sync) {
                self
            }
        }

        impl $crate::client::Client for $client {
            type Row<'a> = tokio_postgres::Row;
            type Param<'a> = &'a (dyn tokio_postgres::types::ToSql + Sync);
            type Error = tokio_postgres::Error;
        }
    };
}