Struct PostgresTransaction 

pub struct PostgresTransaction { /* private fields */ }

Trait Implementations

impl Debug for PostgresTransaction

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for PostgresTransaction

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.

impl Transaction for PostgresTransaction

fn query<'life0, 'life1, 'async_trait>( &'life0 mut self, sql: &'life1 str, schema: CatalogSchemaRef, ) -> Pin<Box<dyn Future<Output = ILResult<RowStream<'_>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute a query and return a stream of rows.

fn execute<'life0, 'life1, 'async_trait>( &'life0 mut self, sql: &'life1 str, ) -> Pin<Box<dyn Future<Output = ILResult<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute a SQL statement.

fn execute_batch<'life0, 'life1, 'async_trait>( &'life0 mut self, sqls: &'life1 [String], ) -> Pin<Box<dyn Future<Output = ILResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute a batch of SQL statements.

fn insert_rows<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 mut self, table_name: &'life1 str, field_names: &'life2 [String], batches: &'life3 [RecordBatch], ) -> Pin<Box<dyn Future<Output = ILResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Bulk insert rows into a table. Each backend uses its optimal strategy (COPY for Postgres, prepared statements for SQLite).

fn commit<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = ILResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Commit the transaction.

fn rollback<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = ILResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Rollback the transaction.