Struct SqliteRawEngine 

pub struct SqliteRawEngine { /* private fields */ }

Legacy SQLite query engine with JSON results.

Implementations

impl SqliteRawEngine

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<SqliteJsonRow>, SqliteError>

Execute a query and return multiple results.

pub async fn query_one( &self, table: &str, columns: &[String], filters: &HashMap<String, FilterValue>, ) -> Result<SqliteJsonRow, 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<SqliteJsonRow>, SqliteError>

Execute a query and return an optional result.

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

Execute an INSERT and return the result.

The returned row echoes the submitted values plus the rowid of the new row under the id key (skipped if an id value was submitted); it does not re-read the persisted row, so database-generated defaults and trigger effects are not reflected.

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<SqliteJsonRow>, SqliteError>

Execute raw SQL and return results.

pub async fn raw_sql(&self, sql: Sql) -> Result<Vec<SqliteJsonRow>, 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<SqliteJsonRow>, 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<SqliteJsonRow, 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<SqliteJsonRow>, 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 SqliteRawEngine

fn clone(&self) -> SqliteRawEngine

Returns a duplicate of the value.

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

Performs copy-assignment from source.