pgw 0.2.17

auto reconnect tokio postgres
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

use tokio_postgres::types::ToSql;

use crate::Pg;

#[static_init::dynamic]
pub static PG: Pg = Pg::from_env("PG_URL");

pub struct Sqlify<T: ToSql + Sync>(pub T);

impl<T: ToSql + Sync> From<T> for Sqlify<T> {
  fn from(value: T) -> Self {
    Self(value)
  }
}

impl From<u64> for Sqlify<i64> {
  fn from(value: u64) -> Self {
    Self(value as i64)
  }
}

macro_rules! def {
  ($($name:ident),+) => {
$(
  #[macro_export]
  macro_rules! $name {
    ($$sql:expr) => {{
      use $crate::Sqlify;
      $crate::PG.$name($$sql, &[]).await
    }};
    ($$sql:expr, $$($$arg:expr),+) => {{
      use $crate::Sqlify;
      $crate::PG.$name($$sql, &[$$(
        &Into::<Sqlify<_>>::into($$arg).0
      ),+]).await
    }};
  }
)+
  };
}

def!(q, q0, q00, q0_, q00_);