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
|
use anyhow::Error;
use anyhow::Result;
use clap::ArgMatches;
use diesel::pg::PgConnection;
use diesel::prelude::*;
use getset::Getters;
use crate::config::Configuration;
#[derive(Debug, Getters)]
pub struct DbConnectionConfig {
#[getset(get = "pub")]
database_host: String,
#[getset(get = "pub")]
database_port: String,
#[getset(get = "pub")]
database_user: String,
#[getset(get = "pub")]
database_password: String,
#[getset(get = "pub")]
database_name: String,
}
impl Into<String> for DbConnectionConfig {
fn into(self) -> String {
format!("postgres://{user}:{password}@{host}:{port}/{name}",
host = self.database_host,
port = self.database_port,
user = self.database_user,
password = self.database_password,
name = self.database_name)
}
}
pub fn parse_db_connection_config(config: &Configuration, cli: &ArgMatches) -> DbConnectionConfig {
fn find_value<F>(cli: &ArgMatches, key: &str, alternative: F) -> String
where F: FnOnce() -> String
{
cli.value_of(key).map(String::from).unwrap_or_else(alternative)
}
let database_host = find_value(cli, "database_host", || config.database_host().to_string());
let database_port = find_value(cli, "database_port", || config.database_port().to_string());
let database_user = find_value(cli, "database_user", || config.database_user().to_string());
let database_password = find_value(cli, "database_password", || config.database_password().to_string());
let database_name = find_value(cli, "database_name", || config.database_name().to_string());
DbConnectionConfig {
database_host,
database_port,
database_user,
database_password,
database_name,
}
}
pub fn establish_connection(conn_config: DbConnectionConfig) -> Result<PgConnection> {
let database_uri: String = conn_config.into();
debug!("Trying to connect to database: {}", database_uri);
PgConnection::establish(&database_uri).map_err(Error::from)
}
|
