Struct ExecuteBatch 

pub struct ExecuteBatch { /* private fields */ }

Execute multiple SQL statements in sequence (not transactional).

Each statement is executed independently. If a statement fails, the remaining statements are not executed.

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::ExecuteBatch;
use ironflow_core::operation::Operation;

let op = ExecuteBatch::new(pool, vec![
    "CREATE TABLE IF NOT EXISTS t (id int)".to_string(),
    "INSERT INTO t VALUES (1)".to_string(),
]);
assert_eq!(op.kind(), "postgres");

Implementations

impl ExecuteBatch

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

Create a new batch-execute operation.

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

Execute and return a typed result.

Errors

Returns OperationError::External on SQL or connection errors. Stops at the first failing statement.

Trait Implementations

impl Operation for ExecuteBatch

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 ExecuteBatch

type Output = ExecuteBatchOutput

The concrete output type that Operation::execute produces.