mushroomdb 0.6.9

Embedded graph database with Cypher queries, rule triggers, and Arrow export
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

use core_api::{GraphDb, Value};
use std::collections::BTreeMap;

fn m(pairs: &[(&str, Value)]) -> Value {
    Value::Map(
        pairs
            .iter()
            .map(|(k, v)| (k.to_string(), v.clone()))
            .collect(),
    )
}

fn tmp(name: &str) -> std::path::PathBuf {
    let d = std::env::temp_dir().join(format!("graphdb-{}-{}", name, std::process::id()));
    let _ = std::fs::remove_dir_all(&d);
    d
}

#[test]
fn map_value_roundtrips_through_wal_and_snapshot() {
    let dir = tmp("map-roundtrip");
    let nested = m(&[
        ("city", Value::Str("berlin".into())),
        (
            "scores",
            Value::List(vec![Value::Int(1), m(&[("deep", Value::Bool(true))])]),
        ),
    ]);
    {
        let mut db = GraphDb::open(&dir).unwrap();
        db.insert_node("N", "a", vec![("meta".into(), nested.clone())])
            .unwrap();
    }
    // WAL replay
    let db = GraphDb::open(&dir).unwrap();
    assert_eq!(db.get_prop("a", "meta"), Some(nested.clone()));
    drop(db);
    // snapshot (V7 pack) roundtrip
    {
        let mut db = GraphDb::open(&dir).unwrap();
        db.snapshot().unwrap();
    }
    let db = GraphDb::open(&dir).unwrap();
    assert_eq!(db.get_prop("a", "meta"), Some(nested.clone()));
}

#[test]
fn map_equality_in_cypher_where() {
    let dir = tmp("map-cypher-eq");
    let mut db = GraphDb::open(&dir).unwrap();
    let meta = m(&[("k", Value::Int(1))]);
    db.insert_node("N", "a", vec![("meta".into(), meta.clone())])
        .unwrap();
    db.insert_node("N", "b", vec![("meta".into(), m(&[("k", Value::Int(2))]))])
        .unwrap();
    let mut params = BTreeMap::new();
    params.insert("m".to_string(), meta);
    let rs = db
        .query("MATCH (n:N) WHERE n.meta = $m RETURN n.meta", &params)
        .unwrap();
    assert_eq!(rs.len(), 1);
}