src/repo/pool.rs


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

use std::str::FromStr;

use sqlx::sqlite::{SqliteConnectOptions, SqlitePool, SqlitePoolOptions};

pub async fn prepare(url: &str) -> sqlx::Result<SqlitePool> {
    let pool = create(url).await?;
    sqlx::migrate!().run(&pool).await?;
    Ok(pool)
}

async fn create(database_url: &str) -> sqlx::Result<SqlitePool> {
    let options = SqliteConnectOptions::from_str(database_url)?
        .create_if_missing(true)
        .optimize_on_close(true, /* analysis_limit */ None);

    let pool = SqlitePoolOptions::new().connect_with(options).await?;
    Ok(pool)
}