switchy_database 0.5.0

Switchy database package
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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86

#![cfg(all(feature = "sqlite-rusqlite", feature = "schema"))]

use std::sync::Arc;
use switchy_database::{
    Database,
    rusqlite::RusqliteDatabase,
    schema::{Column, DataType},
};

fn column(name: &str) -> Column {
    Column {
        name: name.into(),
        data_type: DataType::Int,
        nullable: false,
        auto_increment: false,
        default: None,
    }
}

#[tokio::test]
async fn composite_keys_and_explicit_references_preserve_order_and_exact_names() {
    let db = RusqliteDatabase::new(vec![Arc::new(switchy_async::sync::Mutex::new(
        rusqlite::Connection::open_in_memory().unwrap(),
    ))]);
    db.create_table("parent")
        .column(column("event_seq"))
        .primary_key("event_seq")
        .execute(&db)
        .await
        .unwrap();
    // Legacy schema column declarations accept SQL fragments with raw-sql.
    // Composite keys and rusqlite returning inserts receive exact physical names.
    #[cfg(feature = "raw-sql")]
    let key_column = "\"key, quoted\"\"\"";
    #[cfg(not(feature = "raw-sql"))]
    let key_column = "key, quoted\"";
    db.create_table("child")
        .column(column("producer"))
        .column(column(key_column))
        .column(column("event_seq"))
        .primary_key_columns(["producer", "key, quoted\""])
        .foreign_key_column("event_seq", "parent", "event_seq")
        .execute(&db)
        .await
        .unwrap();
    db.insert("parent")
        .value("event_seq", 1)
        .execute(&db)
        .await
        .unwrap();
    db.insert("child")
        .value("producer", 1)
        .value("key, quoted\"", 2)
        .value("event_seq", 1)
        .execute(&db)
        .await
        .unwrap();
    assert!(
        db.insert("child")
            .value("producer", 1)
            .value("key, quoted\"", 2)
            .value("event_seq", 1)
            .execute(&db)
            .await
            .is_err()
    );
    let info = db.get_table_info("child").await.unwrap().unwrap();
    assert_eq!(
        info.foreign_keys.values().next().unwrap().referenced_column,
        "event_seq"
    );
    use switchy_database::query::FilterableQuery;
    let row = db
        .select("sqlite_master")
        .columns(&["sql"])
        .where_eq("name", "child")
        .execute_first(&db)
        .await
        .unwrap()
        .unwrap();
    let switchy_database::DatabaseValue::String(sql) = row.get("sql").unwrap() else {
        panic!("stored schema")
    };
    assert!(sql.contains("PRIMARY KEY (\"producer\", \"key, quoted\"\"\")"));
    db.close().await.unwrap();
}