rusted_cypher
Rust crate for accessing the cypher endpoint of a neo4j server
This crate allows you to send cypher queries to the REST endpoint of a neo4j database. You can execute queries inside a transaction or simply send queries that commit immediately.
Examples
Connecting to a Neo4j database
use rusted_cypher::GraphClient;
let graph = GraphClient::connect(
"http://neo4j:neo4j@localhost:7474/db/data");
Performing Queries
let mut query = graph.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()?;
graph.exec(
"CREATE (n:LANG { name: 'Python', level: 'high', safe: true })")?;
let result = graph.exec(
"MATCH (n:LANG) RETURN n.name, n.level, n.safe")?;
assert_eq!(result.data.len(), 3);
for row in result.rows() {
let name: String = row.get("n.name")?;
let level: String = row.get("n.level")?;
let safeness: bool = row.get("n.safe")?;
println!("name: {}, level: {}, safe: {}", name, level, safeness);
}
graph.exec("MATCH (n:LANG) DELETE n")?;
With Transactions
let transaction = graph
.transaction()
.with_statement(
"CREATE (n:IN_TRANSACTION { 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 })")?;
// use `add_statement` (or `with_statement`) and `send` to executes multiple statements
let stmt = Statement::new(
"MATCH (n:IN_TRANSACTION) WHERE (n.safe = {safeness}) RETURN n")
.with_param("safeness", true)?;
transaction.add_statement(stmt);
let results = transaction.send()?;
assert_eq!(results[0].data.len(), 2);
transaction.rollback()?;
}
Statements with Macro
There is a macro to help building statements
"Rust", "level" => "low", "safe" => true } )?; graph.exec(statement)?; let statement = cypher_stmt!( "MATCH (n:WITH_MACRO) WHERE n.name = {name} RETURN n", { "name" => "Rust" } )?; let results = graph.exec(statement)?; assert_eq!(results.data.len(), 1); let statement = cypher_stmt!("MATCH (n:WITH_MACRO) DELETE n")?; graph.exec(statement)?;">
let statement = cypher_stmt!( "CREATE (n:WITH_MACRO { name: {name}, level: {level}, safe: {safe} })", { "name" => "Rust", "level" => "low", "safe" => true } )?; graph.exec(statement)?; let statement = cypher_stmt!( "MATCH (n:WITH_MACRO) WHERE n.name = {name} RETURN n", { "name" => "Rust" } )?; let results = graph.exec(statement)?; assert_eq!(results.data.len(), 1); let statement = cypher_stmt!("MATCH (n:WITH_MACRO) DELETE n")?; graph.exec(statement)?;
License
Licensed under either of
- Apache License, Version 2.0, (LICENSE-APACHE or http://www.apache.org/licenses/LICENSE-2.0)
- MIT license (LICENSE-MIT or http://opensource.org/licenses/MIT)
at your option.
Contribution
Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.
38 Jan 2, 2024
5 Apr 26, 2022
12 Jan 21, 2023
82 Jan 1, 2023
7.6k Dec 31, 2022
3 Mar 24, 2022
16 Jan 2, 2023
3 Nov 14, 2021
9 Jul 9, 2022
1 Nov 15, 2021
3 Jan 22, 2022
37 Dec 18, 2022
17 Oct 6, 2022
7 May 2, 2023
12 Jul 27, 2022
33 Dec 16, 2022
306 Dec 28, 2022
218 Dec 27, 2022
249 Oct 18, 2022