TransactionalDbalLoader implements Closure, Loader, OverridingLoader
FinalYes
Tags
Interfaces
- Closure
- Loader
- OverridingLoader
Methods
- __construct() : mixed
- closure() : void
- Rows a wrapped Transformation buffered (blocking operations - sortBy, aggregate, groupBy->aggregate, pivot, window functions, collect, join) are delivered during the forwarded closure() drain, so delivery here must be transactional too: one transaction over everything the drain flushes, rolled back when it fails.
- fromConnection() : self
- Since Connection::getParams() is marked as an internal method, please use this constructor with caution.
- load() : void
- loaders() : array<string|int, mixed>
- withIsolationLevel() : self
Methods
__construct()
public
__construct(array<string, mixed> $connectionParams, Loader ...$loaders) : mixed
Parameters
- $connectionParams : array<string, mixed>
- $loaders : Loader
closure()
Rows a wrapped Transformation buffered (blocking operations - sortBy, aggregate, groupBy->aggregate, pivot, window functions, collect, join) are delivered during the forwarded closure() drain, so delivery here must be transactional too: one transaction over everything the drain flushes, rolled back when it fails.
public
closure(FlowContext $context) : void
Parameters
- $context : FlowContext
fromConnection()
Since Connection::getParams() is marked as an internal method, please use this constructor with caution.
public
static fromConnection(Connection $connection, Loader ...$loaders) : self
Parameters
- $connection : Connection
- $loaders : Loader
Return values
selfload()
public
load(Rows $rows, FlowContext $context) : void
Parameters
- $rows : Rows
- $context : FlowContext
loaders()
public
loaders() : array<string|int, mixed>
Return values
array<string|int, mixed>withIsolationLevel()
public
withIsolationLevel(TransactionIsolationLevel $level) : self
Parameters
- $level : TransactionIsolationLevel