emdb 0.7.0

A lightweight, high-performance embedded database for Rust.
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

use emdb::{Emdb, Error, Result};

fn tmp_path(name: &str) -> std::path::PathBuf {
    let mut p = std::env::temp_dir();
    let nanos = std::time::SystemTime::now()
        .duration_since(std::time::UNIX_EPOCH)
        .map_or(0_u128, |d| d.as_nanos());
    p.push(format!("emdb-{name}-{nanos}.emdb"));
    p
}

#[test]
fn magic_mismatch_is_reported() {
    let path = tmp_path("magic");
    let wrote = std::fs::write(&path, [0xAA_u8; 64]);
    assert!(wrote.is_ok());

    let opened = Emdb::open(&path);
    assert!(matches!(opened, Err(Error::MagicMismatch)));

    assert!(std::fs::remove_file(path).is_ok());
}

#[test]
fn version_mismatch_is_reported() -> Result<()> {
    let path = tmp_path("version");
    {
        let db = Emdb::open(&path)?;
        db.insert("k", "v")?;
        db.flush()?;
    }

    let mut bytes = std::fs::read(&path)?;
    bytes[8..12].copy_from_slice(&999_u32.to_le_bytes());
    std::fs::write(&path, bytes)?;

    let opened = Emdb::open(&path);
    assert!(matches!(opened, Err(Error::VersionMismatch { .. })));

    assert!(std::fs::remove_file(path).is_ok());
    Ok(())
}

#[test]
fn feature_mismatch_is_reported() -> Result<()> {
    let path = tmp_path("feature");
    {
        let db = Emdb::open(&path)?;
        db.insert("k", "v")?;
        db.flush()?;
    }

    let mut bytes = std::fs::read(&path)?;
    bytes[12..16].copy_from_slice(&(1_u32 << 31).to_le_bytes());
    let crc = crc32fast::hash(&bytes[0..100]);
    bytes[100..104].copy_from_slice(&crc.to_le_bytes());
    std::fs::write(&path, bytes)?;

    let opened = Emdb::open(&path);
    assert!(matches!(opened, Err(Error::FeatureMismatch { .. })));

    assert!(std::fs::remove_file(path).is_ok());
    Ok(())
}