datasources-postgres 0.1.21

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

use super::command::PostgresCommand;
use super::connection::PostgresConnection;
use super::isolate;
use super::statement_renderer::PostgresStatementRenderer;
use datasources::{Connection, Statement, StatementTextRenderer};
use datasources_tests::RepositoryDialect;
use std::sync::Arc;

fn quote(id: &str) -> String {
    format!("\"{}\"", id.replace('"', "\"\""))
}

fn render(statement: &dyn Statement) -> String {
    StatementTextRenderer::new(Some(Box::new(PostgresStatementRenderer)), None).render(statement)
}

fn dialect() -> RepositoryDialect {
    RepositoryDialect {
        provider: "postgres",
        quote,
        field: super::converters::field,
        types: super::converters::row_type_converters,
        render: Some(render),
    }
}

#[tokio::test]
async fn user_crud() {
    for path in datasources_tests::files() {
        let isolated = isolate::create().await;
        let conn = Arc::new(PostgresConnection::new(Some(isolated.url.clone()), None));
        conn.open().await.unwrap();
        let command = Arc::new(PostgresCommand::new(conn.clone()));
        datasources_tests::run(&path, &dialect(), conn.clone(), command)
            .await
            .unwrap();
        conn.close().await.ok();
        isolated.drop().await;
    }
}