microrm 0.6.3

Lightweight ORM using sqlite as a backend
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
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
87
88
89
90
91
92
93
94
95
96
97
98
99
100

use microrm::prelude::*;
use test_log::test;

mod common;

#[derive(Entity)]
struct KV {
    key: usize,
    value: usize,
}

#[derive(Schema)]
struct KVStore {
    kvs: microrm::IDMap<KV>,
}

#[test]
#[should_panic]
fn txn_should_abort() {
    let (pool, db): (_, KVStore) = common::open_test_db!();
    // open two transactions
    let mut txn1 = pool.start().unwrap();
    let mut txn2 = pool.start().unwrap();

    db.kvs.insert(&mut txn2, KV { key: 0, value: 0 }).unwrap();

    // now insert different data via txn1 --- this should fail
    let _err = db.kvs.insert(&mut txn1, KV { key: 0, value: 1 });

    unreachable!()
}

#[test]
fn txn_read_old_data_rollback() {
    let (pool, db): (_, KVStore) = common::open_test_db!();

    let mut itxn = pool.start().unwrap();

    let mut k0 = db
        .kvs
        .insert_and_return(&mut itxn, KV { key: 0, value: 0 })
        .unwrap();

    itxn.commit().unwrap();

    let mut txn1 = pool.start().unwrap();
    let mut txn2 = pool.start().unwrap();

    // use second transaction to overwrite old value
    k0.value = 1;
    k0.sync(&mut txn2).unwrap();

    // this should produce old data when we read k0 again
    let nk0 = db.kvs.by_id(&mut txn1, k0.id()).unwrap().unwrap();
    assert_eq!(nk0.value, 0);

    let Err(microrm::Error::TransactionAbort) = txn2.commit() else {
        panic!("Transaction was successful when it should not have been");
    };
}

#[test]
fn txn_read_old_data_wal() {
    let (pool, db): (_, KVStore) = microrm::ConnectionPool::open(
        microrm::db::ConnectionPoolConfig::new(common::test_db_path("txn_read_old_data_wal"))
            .with_wal(),
    )
    .unwrap();

    let mut itxn = pool.start().unwrap();

    let mut k0 = db
        .kvs
        .insert_and_return(&mut itxn, KV { key: 0, value: 0 })
        .unwrap();

    itxn.commit().unwrap();

    let mut txn1 = pool.start().unwrap();
    let mut txn2 = pool.start().unwrap();

    // use second transaction to overwrite old value
    k0.value = 1;
    k0.sync(&mut txn2).unwrap();

    // this should produce old data when we read k0 again
    let nk0 = db.kvs.by_id(&mut txn1, k0.id()).unwrap().unwrap();
    assert_eq!(nk0.value, 0);

    txn2.commit().unwrap();

    // this should still produce the old data
    let nk0 = db.kvs.by_id(&mut txn1, k0.id()).unwrap().unwrap();
    assert_eq!(nk0.value, 0);

    // but a new transaction should give the new data
    let mut txn1 = pool.start().unwrap();
    let nk0 = db.kvs.by_id(&mut txn1, k0.id()).unwrap().unwrap();
    assert_eq!(nk0.value, 1);
}