Struct BaseHandler 

pub struct BaseHandler { /* private fields */ }

Core query executor: transactional writes via sqlx, and optionally analytical reads via a pluggable [ReadEngine] (DuckDB or DataFusion).

Implementations

impl BaseHandler

pub fn new(pool: AnyPool) -> Self

Create a handler for writes against the given sqlx pool.

pub fn has_read_engine(&self) -> bool

Whether an analytical read engine is attached.

pub fn pool(&self) -> &AnyPool

Get a reference to the write pool.

pub fn normalize_name(name: &str) -> String

Unicode NFD normalization — decomposes characters then lowercases. Useful for matching names with different Unicode representations.

pub async fn execute_write( &self, op: WriteOp<'_>, ) -> Result<QueryResult<AnyRow>, DbkitError>

Execute a write operation against the transactional pool.

Placeholders are backend-native: $1, $2, … for Postgres, ? for MySQL/SQLite. sqlx’s Any driver does not rewrite them, so write the SQL for the backend you connected to.