Struct Transaction 

pub struct Transaction { /* private fields */ }

Execute multiple SQL statements inside an atomic transaction.

All statements succeed together or are rolled back on the first error.

Safety

Statements are executed as raw SQL. Never build them from untrusted input without proper parameterization. Use Execute with bind parameters for user-supplied values.

Examples

use ironflow_ops_postgres::execute::Transaction;
use ironflow_core::operation::Operation;

let op = Transaction::new(pool, vec![
    "INSERT INTO accounts (id, balance) VALUES (1, 100)".to_string(),
    "UPDATE accounts SET balance = balance - 50 WHERE id = 1".to_string(),
]);
assert_eq!(op.kind(), "postgres");

Implementations

impl Transaction

pub fn new(pool: PgPool, statements: Vec<String>) -> Self

Create a new transaction operation.

pub async fn run( &self, _ctx: &OperationContext, ) -> Result<TransactionOutput, OperationError>

Execute and return a typed result.

Errors

Returns OperationError::External on SQL or connection errors. The transaction is rolled back on any failure.

Trait Implementations

impl Operation for Transaction

fn kind(&self) -> &str

A short, lowercase identifier for this operation type.

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 OperationContext, ) -> Pin<Box<dyn Future<Output = Result<Value, OperationError>> + Send + 'async_trait>>

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

Execute the operation and return the result as JSON.

fn input(&self) -> Option<Value>

Optional JSON representation of the operation input, stored in the step’s input column for observability.

impl TypedOperation for Transaction

type Output = TransactionOutput

The concrete output type that Operation::execute produces.