Struct Database 

pub struct Database { /* private fields */ }

Database wrapper for LanceDB

Implementations

impl Database

pub async fn open(path: impl Into<PathBuf>) -> Result<Self>

Open or create a database at the given path

pub async fn open_with_project( path: impl Into<PathBuf>, project_id: Option<String>, ) -> Result<Self>

Open or create a database at the given path with a project ID

pub async fn open_with_embedder( path: impl Into<PathBuf>, project_id: Option<String>, embedder: Arc<Embedder>, ) -> Result<Self>

Open or create a database with a pre-existing embedder.

This constructor is useful for connection pooling scenarios where the expensive embedder should be loaded once and shared across multiple database connections.

Arguments

• path - Path to the database directory
• project_id - Optional project ID for scoped operations
• embedder - Shared embedder instance

pub fn set_project_id(&mut self, project_id: Option<String>)

Set the current project ID for scoped operations

pub fn project_id(&self) -> Option<&str>

Get the current project ID

pub async fn store_item(&mut self, item: Item) -> Result<StoreResult>

Store an item with automatic chunking for long content

Returns a StoreResult containing the new item ID and any potential conflicts (items with similarity >= 0.85 to the new content).

pub async fn search_items( &mut self, query: &str, limit: usize, filters: ItemFilters, ) -> Result<Vec<SearchResult>>

Search items by semantic similarity

pub async fn find_similar_items( &mut self, content: &str, min_similarity: f32, limit: usize, ) -> Result<Vec<ConflictInfo>>

Find items similar to the given content (for conflict detection)

This searches the items table directly by content embedding to find potentially conflicting items before storing new content.

pub async fn list_items( &mut self, filters: ItemFilters, limit: Option<usize>, scope: ListScope, ) -> Result<Vec<Item>>

List items with optional filters

pub async fn get_item(&self, id: &str) -> Result<Option<Item>>

Get an item by ID

pub async fn get_items_batch(&self, ids: &[&str]) -> Result<Vec<Item>>

Get multiple items by ID in a single query

pub async fn delete_item(&self, id: &str) -> Result<bool>

Delete an item and its chunks

pub async fn stats(&self) -> Result<DatabaseStats>

Get database statistics