Rust crate for accessing the cypher endpoint of a neo4j server
This is a prototype for accessing the cypher endpoint of a neo4j server, like a sql driver for a relational database.
You can execute queries inside a transaction or simply execute queries that commit immediately.
serde
vs rustc-serialize
By default, rusted-cypher
supports types that implement serde
traits, Serialize
and Deserialize
, in query parameters and to retrieve result values.
If you want to use rustc-serialize
instead, just add the feature rustc-serialize
:
toml
[dependencies]
rusted_cypher = { version = "*", features = ["rustc-serialize"] }
Code in examples are assumed to be wrapped in:
```rust extern crate rusted_cypher;
use std::collections::BTreeMap; use rustedcypher::GraphClient; use rustedcypher::cypher::Statement;
fn main() { // Connect to the database let graph = GraphClient::connect( "http://neo4j:neo4j@localhost:7474/db/data").unwrap();
// Example code here! } ```
```rust let mut query = graph.cypher().query();
// Statement implements From<&str> query.add_statement( "CREATE (n:LANG { name: 'Rust', level: 'low', safe: true })");
let statement = Statement::new( "CREATE (n:LANG { name: 'C++', level: 'low', safe: {safeness} })") .with_param("safeness", false);
query.add_statement(statement);
query.send().unwrap();
graph.cypher().exec( "CREATE (n:LANG { name: 'Python', level: 'high', safe: true })") .unwrap();
let result = graph.cypher().exec( "MATCH (n:LANG) RETURN n.name, n.level, n.safe") .unwrap();
assert_eq!(result.data.len(), 3);
for row in result.rows() { let name: String = row.get("n.name").unwrap(); let level: String = row.get("n.level").unwrap(); let safeness: bool = row.get("n.safe").unwrap(); println!("name: {}, level: {}, safe: {}", name, level, safeness); }
graph.cypher().exec("MATCH (n:LANG) DELETE n").unwrap(); ```
```rust let transaction = graph.cypher().transaction() .withstatement("CREATE (n:INTRANSACTION { name: 'Rust', level: 'low', safe: true })");
let (mut transaction, results) = transaction.begin().unwrap();
// Use exec
to execute a single statement
transaction.exec("CREATE (n:IN_TRANSACTION { name: 'Python', level: 'high', safe: true })")
.unwrap();
// use add_statement
(or with_statement
) and send
to executes multiple statements
let stmt = Statement::new("MATCH (n:INTRANSACTION) WHERE (n.safe = {safeness}) RETURN n")
.withparam("safeness", true);
transaction.add_statement(stmt); let results = transaction.send().unwrap();
assert_eq!(results[0].data.len(), 2);
transaction.rollback(); ```
There is a macro to help building statements
```rust let statement = cypherstmt!( "CREATE (n:WITHMACRO { name: {name}, level: {level}, safe: {safe} })" { "name" => "Rust", "level" => "low", "safe" => true } ); graph.cypher().exec(statement).unwrap();
let statement = cypherstmt!("MATCH (n:WITHMACRO) WHERE n.name = {name} RETURN n" { "name" => "Rust" });
let results = graph.cypher().exec(statement).unwrap(); assert_eq!(results.data.len(), 1);
let statement = cypherstmt!("MATCH (n:WITHMACRO) DELETE n"); graph.cypher().exec(statement).unwrap(); ```