Struct PartitionConnection 

pub struct PartitionConnection { /* private fields */ }

A connection to a partition SQLite database

Implementations

impl PartitionConnection

pub fn open(path: &Path, partition_id: &str) -> Result<Self, PartitionError>

Open an existing partition database

If the partition is at an older schema version (v1.0), it will be automatically migrated to the current version (v1.1).

pub fn create(path: &Path, partition_id: &str) -> Result<Self, PartitionError>

Create a new partition database with schema

pub fn in_memory(partition_id: &str) -> Result<Self, PartitionError>

Create an in-memory partition database (for testing)

pub fn partition_id(&self) -> &str

Get the partition ID

pub fn get_metadata(&self, key: &str) -> Result<Option<String>, PartitionError>

Get a metadata value

pub fn set_metadata(&self, key: &str, value: &str) -> Result<(), PartitionError>

Set a metadata value

pub fn insert_node(&self, node: &Node) -> Result<(), PartitionError>

Insert a node into the partition

pub fn insert_nodes(&self, nodes: &[Node]) -> Result<(), PartitionError>

Insert multiple nodes in a transaction

pub fn get_node(&self, id: &str) -> Result<Option<Node>, PartitionError>

Get a node by ID

pub fn query_nodes_by_file( &self, file: &str, ) -> Result<Vec<Node>, PartitionError>

Query nodes by file path

pub fn query_all_nodes(&self) -> Result<Vec<Node>, PartitionError>

Query all nodes in the partition

pub fn delete_nodes_by_file(&self, file: &str) -> Result<usize, PartitionError>

Delete nodes by file path

pub fn delete_node(&self, id: &str) -> Result<bool, PartitionError>

Delete a node by ID

pub fn node_count(&self) -> Result<usize, PartitionError>

Get node count

pub fn insert_edge(&self, edge: &Edge) -> Result<(), PartitionError>

Insert an edge into the partition

pub fn insert_edges(&self, edges: &[Edge]) -> Result<(), PartitionError>

Insert multiple edges in a transaction

pub fn query_edges_by_source( &self, source: &str, ) -> Result<Vec<Edge>, PartitionError>

Query edges by source node ID

pub fn query_edges_by_target( &self, target: &str, ) -> Result<Vec<Edge>, PartitionError>

Query edges by target node ID

pub fn query_all_edges(&self) -> Result<Vec<Edge>, PartitionError>

Query all edges in the partition

pub fn delete_edges_involving( &self, node_id: &str, ) -> Result<usize, PartitionError>

Delete edges involving a node (as source or target)

pub fn delete_edges_by_source( &self, source: &str, ) -> Result<usize, PartitionError>

Delete edges by source node

pub fn edge_count(&self) -> Result<usize, PartitionError>

Get edge count

pub fn clear(&self) -> Result<(), PartitionError>

Clear all data from the partition (keeps schema)

pub fn stats(&self) -> Result<PartitionStats, PartitionError>

Get partition statistics