Struct FalkorExecutor 

pub struct FalkorExecutor { /* private fields */ }

Executes Cypher queries against FalkorDB and converts results to Arrow.

MultiplexedConnection is Clone + Send + Sync, so this struct is cheap to clone per-request — no mutex needed.

Implementations

impl FalkorExecutor

pub async fn connect(url: &str, graph: impl Into<String>) -> Result<Self>

pub async fn query( &mut self, cypher: &str, schema: &SchemaRef, ) -> Result<RecordBatch>

Run a read Cypher query; convert the response using the given schema.

pub async fn query_auto(&mut self, cypher: &str) -> Result<RecordBatch>

Run a read Cypher query using the auto-string schema fallback.

Column names are taken from the FalkorDB response header; all values are returned as Utf8. No schema pre-registration is required.

pub async fn execute(&mut self, cypher: &str) -> Result<u64>

Run a write Cypher query (CREATE / MERGE / DELETE …) with no result rows. Returns the number of nodes/relationships affected (from the stats line).

pub fn graph(&self) -> &str

Trait Implementations

impl Clone for FalkorExecutor

fn clone(&self) -> FalkorExecutor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.