23 releases

0.2.17 Feb 19, 2025
0.2.15 Feb 19, 2025
0.2.5 Sep 15, 2023
0.2.2 Aug 18, 2023
0.1.10 Aug 17, 2023

#11 in #reconnect

Download history 3/week @ 2024-11-13 11/week @ 2024-11-20 12/week @ 2024-11-27 17/week @ 2024-12-04 23/week @ 2024-12-11 10/week @ 2024-12-18 7/week @ 2025-01-08 8/week @ 2025-01-15 15/week @ 2025-01-22 7/week @ 2025-01-29 10/week @ 2025-02-05 1/week @ 2025-02-12 1338/week @ 2025-02-19 101/week @ 2025-02-26

1,453 downloads per month
Used in 8 crates (5 directly)

MulanPSL-2.0

45KB
559 lines

Base on tokio postgres

Keep one postgres connection, will auto reconnect when connect close

基于 tokio postgres , 保留一个 postgres 连接 , 连接关闭时会自动重新连接

use pgw::{NONE, Pg, Sql};
use static_init::dynamic;
use tokio::time;

// get postgres connection uri from environment
#[dynamic]
static PG: Pg = Pg::from_env("PG_URL");

// prepared sql
#[dynamic]
static SQL_NSPNAME: Sql = PG.sql("SELECT oid FROM pg_catalog.pg_namespace LIMIT 2");

use tokio_postgres::types::Oid;

#[tokio::test]
async fn main() -> anyhow::Result<()> {
  loginit::init();
  // dbg!(li().await?);
  for i in 0..2 {
    println!("loop {i}");
    match PG.q(&SQL_NSPNAME, &[]).await {
      Ok(li) => {
        for i in li {
          let oid: Oid = i.try_get(0).unwrap();
          dbg!(oid);
        }
      }
      Err(err) => {
        dbg!(err);
      }
    }
    let oid: Oid = PG
      .q00("SELECT oid FROM pg_catalog.pg_namespace LIMIT 1", NONE)
      .await?;
    dbg!(oid);
    time::sleep(std::time::Duration::from_secs(1)).await;
  }
  Ok(())
}

About

This project is an open-source component of i18n.site ⋅ Internationalization Solution.

关于

本项目为 i18n.site ⋅ 国际化解决方案 的开源组件。

Dependencies

~19–30MB
~551K SLoC