selene-db-graph 1.3.0

In-memory property-graph storage core (ArcSwap + imbl CoW, label/typed indexes, write funnel) for selene-db.
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
68
69
70
71
72
73
74
75
76

use super::*;
use selene_core::db_string;

#[test]
fn new_graph_is_empty() {
    let graph = SeleneGraph::new(GraphId::new(1));
    assert_eq!(graph.node_count(), 0);
    assert_eq!(graph.edge_count(), 0);
    assert_eq!(graph.label_count(), 0);
    assert_eq!(graph.edge_label_count(), 0);
    assert_eq!(graph.property_index_count(), 0);
    assert_eq!(graph.composite_property_index_count(), 0);
    assert_eq!(graph.vector_index_count(), 0);
    assert_eq!(graph.text_index_count(), 0);
    assert!(graph.idx_label.is_empty());
    assert!(graph.idx_edge_label.is_empty());
    assert!(graph.property_index.is_empty());
    assert!(graph.composite_property_index.is_empty());
    assert!(graph.vector_index.is_empty());
    assert!(graph.text_index.is_empty());
    assert_eq!(graph.meta.generation, 0);
    assert_eq!(graph.meta.next_node_id, 1);
    assert_eq!(graph.meta.next_edge_id, 1);
}

#[test]
fn read_accessors_return_none_for_unknown_ids() {
    let graph = SeleneGraph::new(GraphId::new(1));
    assert_eq!(graph.node_labels(NodeId::new(1)), None);
    assert_eq!(graph.edge_label(EdgeId::new(1)), None);
    assert_eq!(
        graph.nodes_with_label(&db_string("graph.missing").unwrap()),
        None
    );
    assert!(!graph.is_node_alive(NodeId::TOMBSTONE));
}

#[test]
fn node_labels_returns_some_for_alive_node() {
    let mut graph = SeleneGraph::new(GraphId::new(1));
    let label = db_string("graph.node").unwrap();
    graph
        .node_store
        .labels
        .push(LabelSet::single(label.clone()));
    graph.node_store.properties.push(PropertyMap::new());
    // BRIEF-Item-4a: a manually built row must also bind id <-> row, the way
    // create_node / rebuild_id_maps do — reads now resolve through the map.
    graph.node_store.row_to_id.push(NodeId::new(1));
    graph
        .node_id_to_row
        .insert(NodeId::new(1), RowIndex::new(0));
    graph.node_store.alive_mut().insert(0);
    assert_eq!(
        graph
            .node_labels(NodeId::new(1))
            .unwrap()
            .iter()
            .cloned()
            .collect::<Vec<_>>(),
        vec![label]
    );
}

#[test]
fn label_count_reports_distinct_labels_only() {
    let mut graph = SeleneGraph::new(GraphId::new(1));
    let label = db_string("graph.same").unwrap();
    let mut bitmap = RoaringBitmap::new();
    bitmap.insert(0);
    bitmap.insert(1);
    graph.idx_label.insert(label.clone(), bitmap);
    assert_eq!(graph.label_count(), 1);
    assert!(graph.nodes_with_label(&label).unwrap().contains(0));
    assert!(graph.nodes_with_label(&label).unwrap().contains(1));
}