Treatment executeEach

sql::executeEach

Configuration

⬡ pool: sql::SqlPool

Parameters

↳ var bind_symbol: string = "?"
↳ var bindings: Vec<string>
↳ var sql: string
↳ var stop_on_failure: bool = true

Inputs

⇥ bind: Stream<Map> (std/data::Map)

Outputs

↦ affected: Stream<u64>
↦ failure: Stream<string>