citadeldb-txn 0.11.0

Transaction manager with MVCC, commit protocol, and pending-free chain for Citadel
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
101
102
103
104
105
106
107
108
109
110
111
112
113

use crate::manager::tests::create_test_manager;

#[test]
fn table_scan_iter_walks_all_entries() {
    let mgr = create_test_manager();
    {
        let mut wtx = mgr.begin_write().unwrap();
        wtx.create_table(b"t").unwrap();
        for i in 0..10u32 {
            wtx.table_insert(b"t", &i.to_be_bytes(), &[i as u8])
                .unwrap();
        }
        wtx.commit().unwrap();
    }
    let mut rtx = mgr.begin_read();
    let mut iter = rtx.table_scan_iter(b"t", b"").unwrap();
    let mut collected: Vec<(u32, u8)> = Vec::new();
    while let Some((k, v)) = iter.next().unwrap() {
        let mut kbuf = [0u8; 4];
        kbuf.copy_from_slice(k);
        collected.push((u32::from_be_bytes(kbuf), v[0]));
    }
    assert_eq!(collected.len(), 10);
    for (i, (k, v)) in collected.iter().enumerate() {
        assert_eq!(*k as usize, i);
        assert_eq!(*v as usize, i);
    }
}

#[test]
fn table_scan_iter_start_key() {
    let mgr = create_test_manager();
    {
        let mut wtx = mgr.begin_write().unwrap();
        wtx.create_table(b"t").unwrap();
        for i in 0..10u32 {
            wtx.table_insert(b"t", &i.to_be_bytes(), &[i as u8])
                .unwrap();
        }
        wtx.commit().unwrap();
    }
    let mut rtx = mgr.begin_read();
    let mut iter = rtx.table_scan_iter(b"t", &5u32.to_be_bytes()).unwrap();
    let mut count = 0;
    let mut first_key: Option<u32> = None;
    while let Some((k, _)) = iter.next().unwrap() {
        if first_key.is_none() {
            let mut kbuf = [0u8; 4];
            kbuf.copy_from_slice(k);
            first_key = Some(u32::from_be_bytes(kbuf));
        }
        count += 1;
    }
    assert_eq!(count, 5);
    assert_eq!(first_key, Some(5));
}

#[test]
fn table_scan_iter_empty() {
    let mgr = create_test_manager();
    {
        let mut wtx = mgr.begin_write().unwrap();
        wtx.create_table(b"t").unwrap();
        wtx.commit().unwrap();
    }
    let mut rtx = mgr.begin_read();
    let mut iter = rtx.table_scan_iter(b"t", b"").unwrap();
    assert!(iter.next().unwrap().is_none());
}

#[test]
fn table_scan_iter_skips_tombstones() {
    let mgr = create_test_manager();
    {
        let mut wtx = mgr.begin_write().unwrap();
        wtx.create_table(b"t").unwrap();
        for i in 0..5u32 {
            wtx.table_insert(b"t", &i.to_be_bytes(), &[i as u8])
                .unwrap();
        }
        wtx.commit().unwrap();
    }
    {
        let mut wtx = mgr.begin_write().unwrap();
        wtx.table_delete(b"t", &2u32.to_be_bytes()).unwrap();
        wtx.commit().unwrap();
    }
    let mut rtx = mgr.begin_read();
    let mut iter = rtx.table_scan_iter(b"t", b"").unwrap();
    let mut keys: Vec<u32> = Vec::new();
    while let Some((k, _)) = iter.next().unwrap() {
        let mut kbuf = [0u8; 4];
        kbuf.copy_from_slice(k);
        keys.push(u32::from_be_bytes(kbuf));
    }
    assert_eq!(keys, vec![0, 1, 3, 4]);
}

#[test]
fn table_scan_iter_write_txn() {
    let mgr = create_test_manager();
    let mut wtx = mgr.begin_write().unwrap();
    wtx.create_table(b"t").unwrap();
    for i in 0..4u32 {
        wtx.table_insert(b"t", &i.to_be_bytes(), b"v").unwrap();
    }
    let mut iter = wtx.table_scan_iter(b"t", b"").unwrap();
    let mut count = 0;
    while iter.next().unwrap().is_some() {
        count += 1;
    }
    assert_eq!(count, 4);
}