Struct TursoExecutor 

pub struct TursoExecutor { /* private fields */ }

An async Turso/libSQL executor.

Provides async database operations via the QueryExecutor trait.

Implementations

impl TursoExecutor

pub async fn new<F, Fut>(connector: F) -> Result<Self, DBError>

where F: FnOnce() -> Fut, Fut: Future<Output = Result<Connection, Error>> + Send + 'static,

Creates a new Turso executor using the given connector function.

pub fn conn(&self) -> &Connection

Returns a reference to the underlying Turso connection.

pub fn transaction( &self, ) -> impl Future<Output = Result<TursoTransaction<'_>, DBError>>

Starts a new transaction using Turso’s default behavior.

The returned handle supports query_void, query_one, query_list, commit, and rollback.

Trait Implementations

impl Debug for TursoExecutor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl QueryExecutor for TursoExecutor

type Error = DBError

Backend error type.

fn query_void(&self, query: Query) -> impl Future<Output = Result<(), DBError>>

Executes a query, discarding results.

fn query_one<T: FromRow + Send + 'static>( &self, query: Query, ) -> impl Future<Output = Result<Option<T>, DBError>>

Executes a query, returning at most one row.

fn query_list<T: FromRow + Send + 'static>( &self, query: Query, ) -> impl Future<Output = Result<Vec<T>, DBError>>

Executes a query, returning a list of rows.

fn batch( &self, scripts: &[fn() -> Query], ) -> impl Future<Output = Result<(), DBError>>

Executes a sequence of queries in order.