sombra 0.3.6

High-performance graph database with ACID transactions, single-file storage, and bindings for Rust, TypeScript, and Python
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

#![allow(clippy::uninlined_format_args)]
#![allow(clippy::useless_vec)]

use sombra::pager::DEFAULT_PAGE_SIZE;
use sombra::{Config, GraphDB, IntegrityOptions, Node};
use std::fs::OpenOptions;
use std::io::{Seek, SeekFrom, Write};
use tempfile::TempDir;

#[test]
fn verify_integrity_reports_clean_state() {
    let temp_dir = TempDir::new().expect("temp dir");
    let db_path = temp_dir.path().join("graph.sombra");

    {
        let mut db = GraphDB::open_with_config(&db_path, Config::production()).expect("open db");
        let mut tx = db.begin_transaction().expect("begin transaction");
        tx.add_node(Node::new(0)).expect("add node");
        tx.add_node(Node::new(0)).expect("add node");
        tx.commit().expect("commit");
        db.flush().expect("flush");
    }

    let mut db = GraphDB::open(&db_path).expect("reopen db");
    let report = db
        .verify_integrity(IntegrityOptions::default())
        .expect("integrity report");
    assert!(report.is_clean(), "expected clean report: {report:?}");
}

#[test]
fn verify_integrity_detects_checksum_mismatch() {
    let temp_dir = TempDir::new().expect("temp dir");
    let db_path = temp_dir.path().join("graph.sombra");

    let mut db = GraphDB::open_with_config(&db_path, Config::production()).expect("open db");
    {
        let mut tx = db.begin_transaction().expect("begin tx");
        tx.add_node(Node::new(0)).expect("add node");
        tx.commit().expect("commit");
    }
    db.flush().expect("flush");

    {
        let mut file = OpenOptions::new()
            .read(true)
            .write(true)
            .open(&db_path)
            .expect("open db file");
        // Corrupt first byte of the first data page (page 1).
        file.seek(SeekFrom::Start(DEFAULT_PAGE_SIZE as u64))
            .expect("seek to page start");
        file.write_all(&[0xAA]).expect("corrupt page data");
    }

    let report = db
        .verify_integrity(IntegrityOptions::default())
        .expect("integrity report");
    assert!(
        !report.is_clean(),
        "expected checksum mismatch to be reported"
    );
    assert!(
        report.checksum_failures > 0,
        "checksum failures should be recorded"
    );
}