Struct SqliteEngine 

pub struct SqliteEngine { /* private fields */ }

SQLite query engine.

Implementations

impl SqliteEngine

pub fn new(pool: SqlitePool) -> Self

Create a new SQLite engine with the given pool.

pub fn pool(&self) -> &SqlitePool

Get a reference to the connection pool.

pub async fn query_many( &self, table: &str, columns: &[String], filters: &HashMap<String, FilterValue>, sort: &[(String, SortOrder)], limit: Option<u64>, offset: Option<u64>, ) -> Result<Vec<SqliteQueryResult>, SqliteError>

Execute a query and return multiple results.

pub async fn query_one( &self, table: &str, columns: &[String], filters: &HashMap<String, FilterValue>, ) -> Result<SqliteQueryResult, SqliteError>

Execute a query and return a single result.

pub async fn query_optional( &self, table: &str, columns: &[String], filters: &HashMap<String, FilterValue>, ) -> Result<Option<SqliteQueryResult>, SqliteError>

Execute a query and return an optional result.

pub async fn execute_insert( &self, table: &str, data: &HashMap<String, FilterValue>, ) -> Result<SqliteQueryResult, SqliteError>

Execute an INSERT and return the result.

pub async fn execute_update( &self, table: &str, data: &HashMap<String, FilterValue>, filters: &HashMap<String, FilterValue>, ) -> Result<u64, SqliteError>

Execute an UPDATE and return the number of affected rows.

pub async fn execute_delete( &self, table: &str, filters: &HashMap<String, FilterValue>, ) -> Result<u64, SqliteError>

Execute a DELETE and return the number of affected rows.

pub async fn execute_raw( &self, sql: &str, params: &[FilterValue], ) -> Result<Vec<SqliteQueryResult>, SqliteError>

Execute raw SQL and return results.

pub async fn raw_sql( &self, sql: Sql, ) -> Result<Vec<SqliteQueryResult>, SqliteError>

Execute a raw SQL query using the Sql builder from prax-query.

Example

use prax_query::raw::Sql;

let sql = Sql::new("SELECT * FROM users WHERE age > ")
    .bind(18)
    .push(" AND active = ")
    .bind(true);

let results = engine.raw_sql(sql).await?;

pub async fn raw_sql_query( &self, sql: &str, params: &[FilterValue], ) -> Result<Vec<SqliteQueryResult>, SqliteError>

Execute a raw SQL query string with parameters and return results.

Example

let results = engine.raw_sql_query(
    "SELECT * FROM users WHERE age > ? AND active = ?",
    &[FilterValue::Int(18), FilterValue::Bool(true)]
).await?;

pub async fn raw_sql_execute( &self, sql: &str, params: &[FilterValue], ) -> Result<u64, SqliteError>

Execute a raw SQL statement and return the number of affected rows.

Use this for INSERT, UPDATE, DELETE, or other statements that don’t return rows.

Example

let affected = engine.raw_sql_execute(
    "UPDATE users SET last_login = datetime('now') WHERE id = ?",
    &[FilterValue::Int(user_id)]
).await?;
println!("Updated {} rows", affected);

pub async fn raw_sql_first( &self, sql: &str, params: &[FilterValue], ) -> Result<SqliteQueryResult, SqliteError>

Execute a raw SQL query and return the first result.

Returns an error if no rows are returned.

Example

let user = engine.raw_sql_first(
    "SELECT * FROM users WHERE id = ?",
    &[FilterValue::Int(user_id)]
).await?;

pub async fn raw_sql_optional( &self, sql: &str, params: &[FilterValue], ) -> Result<Option<SqliteQueryResult>, SqliteError>

Execute a raw SQL query and return the first result, or None if no rows.

Example

let user = engine.raw_sql_optional(
    "SELECT * FROM users WHERE email = ?",
    &[FilterValue::String("test@example.com".into())]
).await?;

pub async fn raw_sql_scalar<T>( &self, sql: &str, params: &[FilterValue], ) -> Result<T, SqliteError>

where T: for<'a> Deserialize<'a>,

Execute a raw SQL query and return a single scalar value.

Example

let count: i64 = engine.raw_sql_scalar(
    "SELECT COUNT(*) FROM users WHERE active = ?",
    &[FilterValue::Bool(true)]
).await?;

pub async fn raw_sql_batch(&self, sql: &str) -> Result<(), SqliteError>

Execute multiple raw SQL statements in a batch.

This is useful for running schema migrations or multiple DDL statements.

Example

engine.raw_sql_batch(r#"
    CREATE TABLE IF NOT EXISTS users (id INTEGER PRIMARY KEY);
    CREATE TABLE IF NOT EXISTS posts (id INTEGER PRIMARY KEY);
"#).await?;

pub async fn count( &self, table: &str, filters: &HashMap<String, FilterValue>, ) -> Result<u64, SqliteError>

Count rows matching the filter.

Trait Implementations

impl Clone for SqliteEngine

fn clone(&self) -> SqliteEngine

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.