Struct SqliteMutationExecutor 

pub struct SqliteMutationExecutor { /* private fields */ }

Implementations

impl SqliteMutationExecutor

pub fn new(connection: Arc<Mutex<Connection>>) -> Self

pub fn from_connection(connection: Connection) -> Self

pub fn connection(&self) -> Arc<Mutex<Connection>>

pub fn ensure_schema( &self, dialect: &SqliteDialect, entities: &[&EntityDescriptor], ) -> Result<(), MutationExecutorError>

pub fn ensure_id_space_table( &self, table_name: &str, ) -> Result<(), MutationExecutorError>

pub fn begin_transaction(&self) -> Result<(), MutationExecutorError>

pub fn commit_transaction(&self) -> Result<(), MutationExecutorError>

pub fn rollback_transaction(&self) -> Result<(), MutationExecutorError>

pub fn execute( &self, query: &CompiledQuery, ) -> Result<u64, MutationExecutorError>

pub fn fetch_all( &self, query: &CompiledQuery, ) -> Result<Vec<Record>, MutationExecutorError>

pub fn fetch_stream( &self, query: &CompiledQuery, chunk_size: usize, ) -> Result<Vec<StreamChunk>, MutationExecutorError>

Fetch rows in streaming mode (chunked). Returns a Vec of StreamChunk, each containing up to chunk_size rows.

pub fn table_exists( &self, table_name: &str, ) -> Result<bool, MutationExecutorError>

pub fn table_columns( &self, table_name: &str, ) -> Result<BTreeSet<String>, MutationExecutorError>

Trait Implementations

impl Clone for SqliteMutationExecutor

fn clone(&self) -> SqliteMutationExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl DataServiceExecutor for SqliteMutationExecutor

type Error = MutationExecutorError

fn capabilities(&self) -> DataServiceCapabilities

impl SqlTransaction for SqliteMutationExecutor

type Error = MutationExecutorError

async fn commit_sql(self) -> Result<(), Self::Error>

async fn rollback_sql(self) -> Result<(), Self::Error>

impl SqlTransactionTransport for SqliteMutationExecutor

type Tx<'a> = SqliteMutationExecutor where Self: 'a

async fn begin_sql(&self) -> Result<Self::Tx<'_>, Self::Error>

impl SqlTransport for SqliteMutationExecutor

type Error = MutationExecutorError

async fn fetch_all_sql( &self, query: &CompiledQuery, ) -> Result<Vec<Record>, Self::Error>

async fn execute_sql(&self, query: &CompiledQuery) -> Result<u64, Self::Error>

impl StreamQueryExecutor for SqliteMutationExecutor

async fn query_stream( &self, request: QueryRequest, chunk_size: usize, ) -> Result<Vec<StreamChunk>, Self::Error>