Struct SqlBackend 

pub struct SqlBackend { /* private fields */ }

Unified SQL backend using SQLx

Supports SQLite, PostgreSQL, and MySQL with a single interface.

Implementations

impl SqlBackend

pub async fn new(config: SqlBackendConfig) -> Result<Self>

Create a new SQL backend

Arguments

• config - Backend configuration (SQLite path, Postgres URL, or MySQL URL)

Examples

use agentsql::{SqlBackend, SqlBackendConfig};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // SQLite
    let db = SqlBackend::sqlite("agent.db").await?;

    // PostgreSQL (requires "postgres" feature)
    let db = SqlBackend::postgres("postgres://user:pass@localhost/db").await?;

    // MySQL (requires "mysql" feature)
    let db = SqlBackend::mysql("mysql://user:pass@localhost/db").await?;

    Ok(())
}

pub async fn sqlite(path: impl Into<String>) -> Result<Self>

Convenience constructor for SQLite

Trait Implementations

impl AgentDB for SqlBackend

fn family(&self) -> BackendFamily

Get backend family type

fn capabilities(&self) -> &dyn Capabilities

Get backend capabilities

fn put<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, value: Value, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Store a key-value pair

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieve a value by key

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete a key

fn exists<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Check if a key exists

fn query<'life0, 'life1, 'async_trait>( &'life0 self, query_str: &'life1 str, _params: Vec<Value>, ) -> Pin<Box<dyn Future<Output = Result<QueryResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute a query (backend-specific)

fn scan<'life0, 'life1, 'async_trait>( &'life0 self, prefix: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<ScanResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Scan keys with a prefix

fn begin<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Transaction>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Begin a transaction

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Close the database connection