mendia-db 1.3.0

Database library to be used with the mendia crate.
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

use std::fs;

use serde::{Deserialize, Serialize};

use diesel::mysql::MysqlConnection;
use diesel::prelude::*;

#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)]
pub struct Credentials {
    pub user: String,
    pub password: String,
}

#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)]
pub struct Endpoint {
    pub host: String,
    pub port: i16,
    pub database: String,
    pub credentials: Credentials,
}

pub trait YML {
    fn from_yml(path: &str) -> Endpoint;
}

impl YML for Endpoint {
    fn from_yml(path: &str) -> Endpoint {
        let settings_file_content: &str = &fs::read_to_string(path).unwrap();
        serde_yaml::from_str(settings_file_content).unwrap()
    }
}

pub async fn connect(endpoint: &Endpoint) -> ConnectionResult<MysqlConnection> {
    let url = format!(
        "mysql://{}:{}@{}:{}/{}",
        endpoint.credentials.user,
        endpoint.credentials.password,
        endpoint.host,
        endpoint.port,
        endpoint.database,
    );
    MysqlConnection::establish(&url)
}