minigraf 1.0.0

Zero-config, single-file, embedded graph database with bi-temporal Datalog queries
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

//! Memory profiling target for heaptrack.
//!
//! Usage: cargo run --example memory_profile --release -- <fact_count>
//!
//! Inserts <fact_count> `:eN :val N` facts into a checkpointed file-backed DB,
//! then runs a single point-entity query. Run under heaptrack to capture
//! peak heap and allocation counts.
//!
//! Not applicable on WASM targets (no filesystem, no heaptrack).

#[cfg(not(target_arch = "wasm32"))]
use minigraf::OpenOptions;

#[cfg(not(target_arch = "wasm32"))]
fn main() -> anyhow::Result<()> {
    let n: usize = std::env::args()
        .nth(1)
        .and_then(|s| s.parse().ok())
        .unwrap_or(10_000);

    let dir = tempfile::tempdir()?;
    let path = dir.path().join("profile.graph");
    let path_str = path.to_str().unwrap();

    let db = OpenOptions {
        wal_checkpoint_threshold: usize::MAX,
        ..Default::default()
    }
    .page_cache_size(256)
    .path(path_str)
    .open()?;

    // Insert in batches of 100, matching the bench helper pattern
    const BATCH: usize = 100;
    for batch_start in (0..n).step_by(BATCH) {
        let batch_end = (batch_start + BATCH).min(n);
        let mut cmd = String::from("(transact [");
        for i in batch_start..batch_end {
            cmd.push_str(&format!("[:e{} :val {}]", i, i));
        }
        cmd.push_str("])");
        db.execute(&cmd)?;
    }

    db.checkpoint()?;

    // Representative point-entity query
    let _ = db.execute("(query [:find ?v :where [:e0 :val ?v]])")?;

    eprintln!("memory_profile: inserted and queried {} facts", n);
    Ok(())
}

#[cfg(target_arch = "wasm32")]
fn main() {}