mongreldb-core 0.64.15

MongrelDB core: log-structured columnar store with sub-ms writes, learned indexes, and an AI-native access layer.
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

use mongreldb_core::schema::{ColumnDef, ColumnFlags, Schema, TypeId};
use mongreldb_core::{MongrelError, Table, Value};
use tempfile::tempdir;

fn schema() -> Schema {
    Schema {
        schema_id: 1,
        columns: vec![ColumnDef {
            id: 1,
            name: "id".into(),
            ty: TypeId::Int64,
            flags: ColumnFlags::empty().with(ColumnFlags::PRIMARY_KEY),
            default_value: None,
            embedding_source: None,
        }],
        ..Schema::default()
    }
}

#[test]
fn reopen_reserves_canonical_orphan_run_ids() {
    let dir = tempdir().unwrap();
    drop(Table::create(dir.path(), schema(), 1).unwrap());
    std::fs::write(dir.path().join("_runs/r-99.sr"), b"orphan").unwrap();

    let mut table = Table::open(dir.path()).unwrap();
    table.set_mutable_run_spill_bytes(1);
    table.put(vec![(1, Value::Int64(1))]).unwrap();
    table.flush().unwrap();

    assert!(dir.path().join("_runs/r-100.sr").is_file());
}

#[test]
fn maximum_on_disk_run_id_exhausts_namespace_without_wrap() {
    let dir = tempdir().unwrap();
    drop(Table::create(dir.path(), schema(), 1).unwrap());
    std::fs::write(
        dir.path().join(format!("_runs/r-{}.sr", u64::MAX)),
        b"orphan",
    )
    .unwrap();

    assert!(matches!(
        Table::open(dir.path()),
        Err(MongrelError::Full(_))
    ));
}