INNER CODE UNIT · Rust

new

Trow-Registry/trow · src/repositories/mod.rs:41

    pub async fn new(db_file: &str) -> Result<Self, MigrateError> {
        let options = SqliteConnectOptions::new()
            .filename(db_file)
            .synchronous(sqlx::sqlite::SqliteSynchronous::Normal)
            .journal_mode(sqlx::sqlite::SqliteJournalMode::Wal)
            .foreign_keys(true);

        let db_rw = SqlitePoolOptions::new()
            .max_connections(1)
            .connect_with(options.clone().create_if_missing(true))
            .await?;

        let db_ro = SqlitePoolOptions::new()
            .connect_with(options.read_only(true))
            .await?;

        sqlx::migrate!().run(&db_rw).await?;

View source record →