dbkit-rs 0.5.2

Multi-backend database infrastructure: sqlx writes (Postgres/MySQL/SQLite) with optional DuckDB/DataFusion analytical reads, pooling, caching, and migrations
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
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

//! Verifies the backend-aware migration runner on SQLite (tracking table DDL,
//! placeholders, dedup-by-hash, and the `applied_at` text cast all work on a
//! non-Postgres backend).
//!
//!   cargo test --features sqlite --test migrations
#![cfg(feature = "sqlite")]

use dbkit::{ConnectionManager, InitializationHandler};

struct TempDb(std::path::PathBuf);
impl Drop for TempDb {
    fn drop(&mut self) {
        let _ = std::fs::remove_file(&self.0);
    }
}

#[tokio::test]
async fn migrations_tracked_on_sqlite() {
    let path = std::env::temp_dir().join(format!("dbkit_migr_{}.db", std::process::id()));
    let _ = std::fs::remove_file(&path);
    let _guard = TempDb(path.clone());
    let url = format!("sqlite://{}", path.display());

    let conn = ConnectionManager::new(&url).await.expect("connect sqlite");
    let init = InitializationHandler::new(conn.pool().clone(), conn.backend());

    let v1 = "CREATE TABLE users (id INTEGER PRIMARY KEY, name TEXT)";

    // First application runs the DDL and records it.
    init.run_named_migration("001_users", v1)
        .await
        .expect("apply 001");

    // Re-applying identical content is a no-op (same hash).
    init.run_named_migration("001_users", v1)
        .await
        .expect("re-apply 001 is a no-op");

    // Same name, changed content -> error.
    let changed = init
        .run_named_migration(
            "001_users",
            "CREATE TABLE users (id INTEGER PRIMARY KEY, name TEXT, email TEXT)",
        )
        .await;
    assert!(changed.is_err(), "changed migration content must error");

    // A second migration.
    init.run_named_migration("002_posts", "CREATE TABLE posts (id INTEGER PRIMARY KEY)")
        .await
        .expect("apply 002");

    // Listing reflects both, in order, with non-empty timestamps.
    let applied = init.applied_migrations().await.expect("list applied");
    let names: Vec<&str> = applied.iter().map(|(n, _, _)| n.as_str()).collect();
    assert_eq!(names, vec!["001_users", "002_posts"]);
    assert!(
        applied.iter().all(|(_, _, at)| !at.is_empty()),
        "applied_at should render as non-empty text"
    );
}