wip

src/database.rs

@@ -0,0 +1,19 @@
+use anyhow::{anyhow, Context, Result};
+use sqlx::{sqlite::{SqliteConnectOptions, SqlitePoolOptions}, Pool, Sqlite, ConnectOptions};
+use std::str::FromStr;
+
+pub async fn prepare_database(sqlite_db_path: &str) -> Result<Pool<Sqlite>> {
+    let conn_str = format!("sqlite:{}", sqlite_db_path);
+
+    let pool = SqlitePoolOptions::new()
+        .max_connections(50)
+        .connect_with(
+            SqliteConnectOptions::from_str(&conn_str)?
+                .log_statements(log::LevelFilter::Trace)
+        )
+        .await
+        .context("could not connect to database_url")?;
+
+    Ok(pool)
+}
+