datasources-postgres 0.1.13

Postgres datasource provider
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

use crate::connection::connect_url;
use tokio_postgres::NoTls;
use uuid::Uuid;

pub struct Isolated {
    pub url: String,
    name: String,
    base: String,
}

fn replace_db(url: &str, name: &str) -> String {
    match url.rfind('/') {
        Some(index) if url[..index].contains("://") => {
            let prefix = &url[..=index];
            match url[index + 1..].find('?') {
                Some(q) => format!("{prefix}{name}{}", &url[index + 1 + q..]),
                None => format!("{prefix}{name}"),
            }
        }
        _ => url.to_string(),
    }
}

async fn admin(url: &str) -> tokio_postgres::Client {
    let (client, connection) = tokio_postgres::connect(&connect_url(url), NoTls)
        .await
        .unwrap();
    tokio::spawn(async move {
        let _ = connection.await;
    });
    client
}

pub async fn create() -> Isolated {
    let base = std::env::var("POSTGRES_URL").expect("POSTGRES_URL");
    let name = format!("ds_{}", Uuid::new_v4().simple());
    admin(&base)
        .await
        .batch_execute(&format!("CREATE DATABASE {name}"))
        .await
        .unwrap();
    Isolated {
        url: replace_db(&base, &name),
        name,
        base,
    }
}

impl Isolated {
    pub async fn drop(self) {
        let client = admin(&self.base).await;
        client
            .batch_execute(&format!(
                "SELECT pg_terminate_backend(pid) FROM pg_stat_activity WHERE datname = '{}' AND pid <> pg_backend_pid()",
                self.name
            ))
            .await
            .ok();
        client
            .batch_execute(&format!("DROP DATABASE {}", self.name))
            .await
            .ok();
    }
}