Struct AgentDB 

pub struct AgentDB { /* private fields */ }

The main AgentDB connection — your single-file AI database.

Implementations

impl AgentDB

pub fn open(path: &str) -> Result<Self>

Open or create an AgentDB database. Use ":memory:" for tests.

pub fn vectors(&self) -> VectorStore

Access the vector store layer

pub fn memory(&self) -> MemoryGraph

Access the memory graph layer

pub fn fts(&self) -> FullTextStore

Access the full-text search layer

pub fn conversations(&self) -> ConversationStore

Access the conversation / message-threading layer

pub fn workflows(&self) -> WorkflowStore

Access the workflow persistence layer

pub fn traces(&self) -> TraceStore

Access the reasoning-trace layer

pub fn hybrid_query(&self, q: HybridQuery<'_>) -> Result<Vec<HybridResult>>

Run a hybrid graph + vector query

pub fn execute(&self, sql: &str) -> Result<usize>

Execute a raw SQL statement

pub fn execute_params(&self, sql: &str, params: &[&dyn ToSql]) -> Result<usize>

Execute a parameterized SQL statement

pub fn transaction<F, T>(&self, f: F) -> Result<T>

where F: FnOnce(&Transaction<'_>) -> Result<T>,

Run multiple operations atomically inside a single SQLite transaction.

The closure receives a rusqlite::Transaction and may perform any number of reads or writes. If the closure returns Ok, the transaction is committed; if it returns Err (or panics), the transaction is rolled back automatically.

Example

let db = AgentDB::open(":memory:").unwrap();
db.transaction(|tx| {
    tx.execute("INSERT INTO _adb_nodes (id, label, data) VALUES ('x','tag','{}')", [])?;
    tx.execute("INSERT INTO _adb_nodes (id, label, data) VALUES ('y','tag','{}')", [])?;
    Ok(())
}).unwrap();

pub fn execute_batch(&self, sql: &str) -> Result<()>

Execute one or more semicolon-separated SQL statements as a single atomic batch. This is a convenience wrapper around execute_batch that wraps the statements in an explicit transaction so partial execution is never visible to other threads.

Example

let db = AgentDB::open(":memory:").unwrap();
db.execute_batch(
    "INSERT INTO _adb_nodes (id,label,data) VALUES ('a','t','{}');
     INSERT INTO _adb_nodes (id,label,data) VALUES ('b','t','{}');"
).unwrap();

pub fn query_json(&self, sql: &str) -> Result<Vec<Value>>

Query and return rows as JSON values

pub fn close(self) -> Result<()>

Flush dirty HNSW indexes and close gracefully

pub fn stats(&self) -> Result<DbStats>

Return database-wide statistics