varpulis-db 0.10.0

PostgreSQL database layer for Varpulis Cloud
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

use sqlx::postgres::{PgPool, PgPoolOptions};

use crate::DbError;

/// Create a PostgreSQL connection pool.
pub async fn create_pool(database_url: &str) -> Result<PgPool, DbError> {
    let pool = PgPoolOptions::new()
        .max_connections(20)
        .acquire_timeout(std::time::Duration::from_secs(5))
        .connect(database_url)
        .await
        .map_err(|e| DbError::Pool(e.to_string()))?;

    tracing::info!("PostgreSQL connection pool created");
    Ok(pool)
}

/// Run all pending migrations from the embedded migrations directory.
pub async fn run_migrations(pool: &PgPool) -> Result<(), DbError> {
    sqlx::migrate!("./migrations")
        .run(pool)
        .await
        .map_err(|e| DbError::Migration(e.to_string()))?;

    tracing::info!("Database migrations complete");
    Ok(())
}