uni-db 1.1.0

Embedded graph database with OpenCypher queries, vector search, and columnar storage
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

use uni_db::Uni;
use uni_query::Value;

#[tokio::test]
async fn test_labels_function() {
    let db = Uni::in_memory().build().await.unwrap();

    let tx = db.session().tx().await.unwrap();
    tx.execute("CREATE (:Person:Student {name: 'Alice'})")
        .await
        .unwrap();
    tx.commit().await.unwrap();
    let result = db
        .session()
        .query("MATCH (n:Person) RETURN labels(n) AS l")
        .await
        .unwrap();
    let val = result.rows()[0].value("l").unwrap();
    println!("Labels: {:?}", val);

    if let Value::List(l) = val {
        assert_eq!(l.len(), 2);
        assert!(l.contains(&Value::String("Person".to_string())));
        assert!(l.contains(&Value::String("Student".to_string())));
    } else {
        panic!("Expected List, got {:?}", val);
    }
}

#[tokio::test]
async fn test_path_functions() {
    let db = Uni::in_memory().build().await.unwrap();

    let tx = db.session().tx().await.unwrap();
    tx.execute("CREATE (a:Person {name: 'Alice'})-[:KNOWS]->(b:Person {name: 'Bob'})")
        .await
        .unwrap();
    tx.commit().await.unwrap();
    let result = db
        .session()
        .query(
            "MATCH p = (a:Person)-[:KNOWS]->(b:Person) RETURN nodes(p) AS n, relationships(p) AS r",
        )
        .await
        .unwrap();

    let nodes = result.rows()[0].value("n").unwrap();
    let rels = result.rows()[0].value("r").unwrap();

    // nodes(p) should return a list of Node objects
    if let Value::List(l) = nodes {
        assert_eq!(l.len(), 2);
        // ... verify Node content ...
    } else {
        panic!("Expected List for nodes(p), got {:?}", nodes);
    }

    // relationships(p) should return a list of Relationship objects
    if let Value::List(l) = rels {
        assert_eq!(l.len(), 1);
        // ... verify Relationship content ...
    } else {
        panic!("Expected List for relationships(p), got {:?}", rels);
    }
}