Struct SqliteGraphBackend 

pub struct SqliteGraphBackend { /* private fields */ }

SQLite-backed implementation of the GraphBackend trait.

This struct wraps a SqliteGraph instance and implements all GraphBackend methods by delegating to the underlying SQLite-based graph operations.

Implementations

impl SqliteGraphBackend

pub fn in_memory() -> Result<Self, SqliteGraphError>

Create a new SQLite backend with an in-memory database.

pub fn from_graph(graph: SqliteGraph) -> Self

Create a new SQLite backend from an existing SqliteGraph instance.

pub fn graph(&self) -> &SqliteGraph

Get a reference to the underlying SqliteGraph instance.

pub fn create_hnsw_storage( &self, _index_name: impl Into<String>, ) -> Option<Box<dyn VectorStorage>>

Create a new HNSW vector storage using this SQLite backend

Arguments

• index_name - Name for the HNSW index (used for table naming)

Returns

Some(Box<dyn VectorStorage>) containing a storage backed by SQLite

Example

let backend = SqliteGraphBackend::in_memory().unwrap();
let storage = backend.create_hnsw_storage("my_index").unwrap();

pub fn entity_ids(&self) -> Result<Vec<i64>, SqliteGraphError>

Get all entity IDs from the graph.

Trait Implementations

impl GraphBackend for SqliteGraphBackend

fn insert_node(&self, node: NodeSpec) -> Result<i64, SqliteGraphError>

fn get_node( &self, snapshot_id: SnapshotId, id: i64, ) -> Result<GraphEntity, SqliteGraphError>

fn insert_edge(&self, edge: EdgeSpec) -> Result<i64, SqliteGraphError>

fn delete_entity(&self, id: i64) -> Result<(), SqliteGraphError>

Delete an entity (node) from the graph by ID

fn update_node( &self, node_id: i64, node: NodeSpec, ) -> Result<i64, SqliteGraphError>

Update an existing node in place without allocating a new node ID

fn entity_ids(&self) -> Result<Vec<i64>, SqliteGraphError>

Get all entity IDs from the graph

fn neighbors( &self, snapshot_id: SnapshotId, node: i64, query: NeighborQuery, ) -> Result<Vec<i64>, SqliteGraphError>

fn bfs( &self, snapshot_id: SnapshotId, start: i64, depth: u32, ) -> Result<Vec<i64>, SqliteGraphError>

fn shortest_path( &self, snapshot_id: SnapshotId, start: i64, end: i64, ) -> Result<Option<Vec<i64>>, SqliteGraphError>

fn node_degree( &self, snapshot_id: SnapshotId, node: i64, ) -> Result<(usize, usize), SqliteGraphError>

fn k_hop( &self, snapshot_id: SnapshotId, start: i64, depth: u32, direction: BackendDirection, ) -> Result<Vec<i64>, SqliteGraphError>

fn k_hop_filtered( &self, snapshot_id: SnapshotId, start: i64, depth: u32, direction: BackendDirection, allowed_edge_types: &[&str], ) -> Result<Vec<i64>, SqliteGraphError>

fn chain_query( &self, snapshot_id: SnapshotId, start: i64, chain: &[ChainStep], ) -> Result<Vec<i64>, SqliteGraphError>

fn pattern_search( &self, snapshot_id: SnapshotId, start: i64, pattern: &PatternQuery, ) -> Result<Vec<PatternMatch>, SqliteGraphError>

fn checkpoint(&self) -> Result<(), SqliteGraphError>

Trigger WAL checkpoint for backends that support write-ahead logging

fn flush(&self) -> Result<(), SqliteGraphError>

Force immediate flush of WAL buffer to disk

fn backup(&self, backup_dir: &Path) -> Result<BackupResult, SqliteGraphError>

Create a backup of the database

fn snapshot_export( &self, export_dir: &Path, ) -> Result<SnapshotMetadata, SqliteGraphError>

Export database snapshot to the specified directory

fn snapshot_import( &self, import_dir: &Path, ) -> Result<ImportMetadata, SqliteGraphError>

Import database snapshot from the specified directory

fn subscribe( &self, filter: SubscriptionFilter, ) -> Result<(u64, Receiver<PubSubEvent>), SqliteGraphError>

Subscribe to graph change events

fn unsubscribe(&self, subscriber_id: u64) -> Result<bool, SqliteGraphError>

Unsubscribe from events

fn query_nodes_by_kind( &self, _snapshot_id: SnapshotId, kind: &str, ) -> Result<Vec<i64>, SqliteGraphError>

Query all nodes with a given kind

fn query_nodes_by_name_pattern( &self, _snapshot_id: SnapshotId, pattern: &str, ) -> Result<Vec<i64>, SqliteGraphError>

Query nodes by name pattern using glob matching

fn all_entity_ids(&self) -> Result<Vec<i64>, SqliteGraphError>

Alias for entity_ids() for backward compatibility with algorithms

fn fetch_outgoing(&self, node: i64) -> Result<Vec<i64>, SqliteGraphError>

Get outgoing neighbors for a node (convenience method)

fn fetch_incoming(&self, node: i64) -> Result<Vec<i64>, SqliteGraphError>

Get incoming neighbors for a node (convenience method)