From e82dcc253719e899d5a23edd598f5b65fc0ce896 Mon Sep 17 00:00:00 2001 From: Lucietta O'Crescendo Date: Tue, 28 Jan 2025 21:25:19 -0500 Subject: [PATCH] patch batch test --- tests/test_load_tx.rs | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) diff --git a/tests/test_load_tx.rs b/tests/test_load_tx.rs index 21e2a48..9d0520f 100644 --- a/tests/test_load_tx.rs +++ b/tests/test_load_tx.rs @@ -41,7 +41,7 @@ async fn test_tx_batch() -> anyhow::Result<()> { assert!(res.created_tx == txs.len() as u64); let cypher_query = query( - "MATCH ()-[r]->() + "MATCH ()-[r:Tx]->() RETURN count(r) AS total_tx_count", ); @@ -54,6 +54,18 @@ async fn test_tx_batch() -> anyhow::Result<()> { assert!(total_tx_count == txs.len() as i64); + + let cypher_query = query( + "MATCH ()-[r:Lifetime]->() + RETURN count(r) AS total_tx_count", + ); + // Execute the query + let mut result = graph.execute(cypher_query).await?; + // Fetch the first row only + let row = result.next().await?.unwrap(); + let total_tx_count: i64 = row.get("total_tx_count").unwrap(); + assert!(total_tx_count == 18 as i64); + // check there are transaction records with function args. let cypher_query = query( "MATCH ()-[r]->()