redisgraphio 0.2.0

Client library for working with redis graph
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

use crate::{GraphResponse, FromGraphValue, GraphQuery, query};
use redis::{cmd, ConnectionLike, RedisResult};

/// Implements redis graph related commands for an synchronous connection
pub trait GraphCommands: ConnectionLike + Sized {
    /// Send a graph query
    fn graph_query<Q, RT>(
        &mut self,
        graph: &str,
        query: Q,
    ) -> RedisResult<GraphResponse<RT>> where Q: Into<GraphQuery>, RT: FromGraphValue {
        let query = query.into();
        cmd(query.read_type())
            .arg(graph)
            .arg(query.construct_query())
            .arg("--compact")
            .query(self)
    }

    /// Send a graph query and ignore the result data
    fn graph_query_void<Q>(
        &mut self,
        graph: &str,
        query: Q,
    ) -> RedisResult<GraphResponse<()>> where Q: Into<GraphQuery> {
        let query = query.into();
        cmd(query.read_type())
            .arg(graph)
            .arg(query.construct_query())
            .arg("--compact")
            .query(self)
    }


    /// Returns a vector where the index is a label id and the value at that index is the corresponding label name
    fn labels(&mut self, graph: &str) -> RedisResult<Vec<String>> {
        let data: Vec<Vec<String>> = self.graph_query(graph, query!("CALL db.labels()"))?.data;
        Ok(data.into_iter().map(|mut vec| vec.remove(0)).collect())
    }

    /// Returns a vector where the index is a property key id and the value at that index is the corresponding property key name
    fn property_keys(&mut self, graph: &str) -> RedisResult<Vec<String>> {
        let data: Vec<Vec<String>> = self.graph_query(graph, query!("CALL db.propertyKeys()"))?.data;
        Ok(data.into_iter().map(|mut vec| vec.remove(0)).collect())
    }

    /// Returns a vector where the index is a relationship id and the value at that index is the corresponding relationship name
    fn relationship_types(&mut self, graph: &str) -> RedisResult<Vec<String>> {
        let data: Vec<Vec<String>> = self.graph_query(graph, query!("CALL db.relationshipTypes()"))?.data;
        Ok(data.into_iter().map(|mut vec| vec.remove(0)).collect())
    }
}

impl<T> GraphCommands for T where T: ConnectionLike {}