nexus-graph-sdk 2.1.0

Official Rust SDK for Nexus graph database
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
77
78
79
80
81
82
83
84
85
86
87
88
89

//! Basic usage example for Nexus Rust SDK

use nexus_sdk::*;
use std::collections::HashMap;

#[tokio::main]
async fn main() -> Result<()> {
    // Create a client
    let client = NexusClient::new("http://localhost:15474")?;

    // Check server health
    tracing::info!("Checking server health...");
    let healthy = client.health_check().await?;
    tracing::info!("Server is healthy: {}", healthy);

    // Get database statistics
    tracing::info!("\nGetting database statistics...");
    let stats = client.get_stats().await?;
    tracing::info!("Nodes: {}", stats.catalog.node_count);
    tracing::info!("Relationships: {}", stats.catalog.rel_count);
    tracing::info!("Labels: {}", stats.catalog.label_count);
    tracing::info!("Relationship types: {}", stats.catalog.rel_type_count);

    // Execute a simple Cypher query
    tracing::info!("\nExecuting Cypher query...");
    let result = client
        .execute_cypher("RETURN 'Hello, Nexus!' as greeting", None)
        .await?;
    tracing::info!("Query result: {:?}", result);

    // Create a label
    tracing::info!("\nCreating label...");
    let label_response = client.create_label("Person".to_string()).await?;
    tracing::info!("Label creation: {}", label_response.message);

    // List all labels. Each entry is a `LabelInfo { name, id }` —
    // the second field is the catalog id allocated by the engine,
    // not a count. (See issue #2 for the rename history.)
    tracing::info!("\nListing labels...");
    let labels = client.list_labels().await?;
    for label in &labels.labels {
        tracing::info!("  label name={} id={}", label.name, label.id);
    }

    // Create a node
    tracing::info!("\nCreating node...");
    let mut properties = HashMap::new();
    properties.insert("name".to_string(), Value::String("Alice".to_string()));
    properties.insert("age".to_string(), Value::Int(30));
    properties.insert("active".to_string(), Value::Bool(true));

    let create_response = client
        .create_node(vec!["Person".to_string()], properties)
        .await?;
    tracing::info!("Created node with ID: {}", create_response.node_id);

    // Get the node
    tracing::info!("\nGetting node...");
    let get_response = client.get_node(create_response.node_id).await?;
    if let Some(node) = get_response.node {
        tracing::info!("Node ID: {}", node.id);
        tracing::info!("Labels: {:?}", node.labels);
        tracing::info!("Properties: {:?}", node.properties);
    }

    // Update the node
    tracing::info!("\nUpdating node...");
    let mut update_properties = HashMap::new();
    update_properties.insert("age".to_string(), Value::Int(31));
    let update_response = client
        .update_node(create_response.node_id, update_properties)
        .await?;
    tracing::info!("Update result: {}", update_response.message);

    // Create a relationship type
    tracing::info!("\nCreating relationship type...");
    let rel_type_response = client.create_rel_type("KNOWS".to_string()).await?;
    tracing::info!("Relationship type creation: {}", rel_type_response.message);

    // List relationship types. Each entry is a `RelTypeInfo { name, id }`.
    tracing::info!("\nListing relationship types...");
    let types = client.list_rel_types().await?;
    for rel_type in &types.types {
        tracing::info!("  rel_type name={} id={}", rel_type.name, rel_type.id);
    }

    tracing::info!("\nExample completed successfully!");
    Ok(())
}