Base on tokio postgres

Keep one postgres connection, will auto reconnect when connect close

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

→ tests/main.rs

```rust use lazystatic::lazystatic; use pgw::{Pg, Sql}; use tokio::time;

lazystatic! { // get postgres connection uri from environment ( without prefix ) static ref PG: Pg = Pg::newwithenv("PGURI"); // prepared sql static ref SQLNSPNAME: Sql = PG.sql("SELECT oid FROM pgcatalog.pgnamespace LIMIT 2"); } use tokiopostgres::types::Oid; // // lazystatic! { // pub static ref SQLLI: pgw::Sql = PG.sql("SELECT task.id FROM bot.task,bot.civitaiimg WHERE hash IS NOT NULL AND bot.task.rid=bot.civitaiimg.id AND task.adult=0 AND cid=1 ORDER BY star DESC LIMIT 512"); // } // // pub async fn li() -> Result, pgw::Error> { // Ok( // PG.query(&*SQL_LI, &[]) // .await? // .iter() // .map(|r| r.get::<_, u64>(0)) // .collect(), // ) // }

[tokio::test]

async fn main() -> anyhow::Result<()> { loginit::init(); // dbg!(li().await?); for i in 0..99999 { println!("loop {i}"); match PG.query(&*SQLNSPNAME, &[]).await { Ok(li) => { for i in li { let oid: Oid = i.tryget(0).unwrap(); dbg!(oid); } } Err(err) => { dbg!(err); } } match PG .queryone("SELECT oid FROM pgcatalog.pgnamespace LIMIT 1", &[]) .await { Ok(i) => { let oid: Oid = i.tryget(0).unwrap(); dbg!(oid); } Err(err) => { dbg!(err); } } time::sleep(std::time::Duration::from_secs(6)).await; } Ok(()) } ```