axa 0.1.0

Small shared library for services built directly on Axum and sqlx.
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

//! Database connection helpers.

#[cfg(feature = "sea-orm")]
use crate::{Result, config::Database};

/// Connect a pool from configuration.
///
/// # Errors
///
/// Fails when the database cannot be reached.
#[cfg(feature = "sea-orm")]
pub async fn connect(config: &Database) -> Result<sea_orm::DatabaseConnection> {
    use std::time::Duration;

    let mut options = sea_orm::ConnectOptions::new(config.uri.clone());
    options
        .min_connections(config.min_connections)
        .max_connections(config.max_connections)
        .connect_timeout(Duration::from_millis(config.connect_timeout))
        .idle_timeout(Duration::from_millis(config.idle_timeout))
        .sqlx_logging(config.enable_logging);
    Ok(sea_orm::Database::connect(options).await?)
}

/// Delete every row of one entity's table.
///
/// # Errors
///
/// Propagates the database error.
#[cfg(feature = "sea-orm")]
pub async fn truncate_table<T: sea_orm::EntityTrait>(
    db: &sea_orm::DatabaseConnection,
    _entity: T,
) -> std::result::Result<(), sea_orm::DbErr> {
    T::delete_many().exec(db).await?;
    Ok(())
}