src/database/mod.rs


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

pub mod album;
pub mod artist;
pub mod search_results;
pub mod song;
pub mod user;

use serde::{Deserialize, Serialize};
use sqlx::mysql::{MySqlPool, MySqlPoolOptions};
use utoipa::ToSchema;
use std::env;

#[derive(Serialize, Deserialize, ToSchema)]
pub struct Delete {
    #[schema(example = "1", required = true)]
    pub id: Option<String>,
}

pub struct DatabaseWrapper {
    db_pool: MySqlPool,
}

impl DatabaseWrapper {
    pub async fn new() -> Result<DatabaseWrapper, sqlx::Error> {
        let pool: MySqlPool = MySqlPoolOptions::new()
            .max_connections(10)
            .connect(
                env::var("DATABASE_URL")
                    .expect("Environment variable DATABASE_URL is *probably not setted up!!")
                    .as_str(),
            )
            .await
            .unwrap(); /* This will break in case of error. It's intended. */

        Ok(DatabaseWrapper { db_pool: pool })
    }
}