Struct Transaction 

pub struct Transaction { /* private fields */ }

An active Ignite transaction.

Drop without committing will roll back the transaction (best-effort, fire-and-forget). Call .commit() to commit or .rollback() for explicit rollback.

Implementations

impl Transaction

pub fn cache(&self, name: &str) -> IgniteCache

Return a IgniteCache handle that participates in this transaction.

Every cache operation on the returned handle embeds the transaction’s tx_id in the request flags, so reads and writes are part of the current transaction and subject to its commit/rollback.

pub async fn query( &mut self, sql: &str, params: Vec<IgniteValue>, ) -> Result<QueryResult>

Execute a SELECT inside this transaction. All rows fetched eagerly.

pub async fn query_stream( &mut self, sql: &str, params: Vec<IgniteValue>, ) -> Result<QueryStream>

Execute a SELECT inside this transaction and return rows lazily as a QueryStream.

The first page is fetched immediately; subsequent pages are fetched on demand as the stream is polled. The stream shares the transaction’s dedicated connection, so concurrent queries on the same transaction are multiplexed safely.

pub async fn execute( &mut self, sql: &str, params: Vec<IgniteValue>, ) -> Result<UpdateResult>

Execute a DML statement (INSERT/UPDATE/DELETE) inside this transaction.

pub async fn commit(self) -> Result<()>

Commit the transaction.

pub async fn rollback(self) -> Result<()>

Roll back the transaction.

Trait Implementations

impl Drop for Transaction

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.