sqlness 0.6.1

SQL integration test harness
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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92

// Copyright 2022 CeresDB Project Authors. Licensed under Apache-2.0.

use async_trait::async_trait;
use postgres::{Client, Config, NoTls, Row};
use std::{
    fmt::Display,
    sync::{Arc, Mutex},
};

use crate::{Database, DatabaseConfig, QueryContext};

pub struct PostgresqlDatabase {
    client: Arc<Mutex<Client>>,
}

impl PostgresqlDatabase {
    pub fn try_new(config: &DatabaseConfig) -> Result<Self, postgres::Error> {
        let mut postgres_config = Config::new();
        postgres_config
            .port(config.tcp_port)
            .host(&config.ip_or_host);

        if let Some(user) = &config.user {
            postgres_config.user(user);
        }
        if let Some(password) = &config.pass {
            postgres_config.password(password);
        }
        if let Some(dbname) = &config.db_name {
            postgres_config.dbname(dbname);
        }
        let client = postgres_config.connect(NoTls)?;
        Ok(PostgresqlDatabase {
            client: Arc::new(Mutex::new(client)),
        })
    }

    pub fn execute(query: &str, client: Arc<Mutex<Client>>) -> Box<dyn Display> {
        let mut client = match client.lock() {
            Ok(client) => client,
            Err(err) => {
                return Box::new(format!("Failed to get connection, encountered: {:?}", err))
            }
        };

        let result = match client.query(query, &[]) {
            Ok(rows) => {
                format!("{}", PostgresqlFormatter { rows })
            }
            Err(err) => format!("Failed to execute query, encountered: {:?}", err),
        };

        Box::new(result)
    }
}

struct PostgresqlFormatter {
    pub rows: Vec<Row>,
}

impl Display for PostgresqlFormatter {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        if self.rows.is_empty() {
            return f.write_fmt(format_args!("(Empty response)"));
        }

        let top = &self.rows[0];
        let columns = top
            .columns()
            .iter()
            .map(|column| column.name())
            .collect::<Vec<_>>();
        for col in &columns {
            f.write_fmt(format_args!("{},", col))?;
        }

        f.write_str("\n")?;

        for row in &self.rows {
            f.write_fmt(format_args!("{:?}\n", row))?;
        }

        Ok(())
    }
}

#[async_trait]
impl Database for PostgresqlDatabase {
    async fn query(&self, _: QueryContext, query: String) -> Box<dyn Display> {
        Self::execute(&query, Arc::clone(&self.client))
    }
}