PostgreSqlLoader implements Loader
FinalYes
PostgreSQL loader for ETL pipelines.
Supports INSERT, UPDATE, and DELETE operations. UPDATE and DELETE issue one statement per row, so only INSERT can reach the bind-parameter cap and is chunked.
Interfaces
- Loader
Methods
- __construct() : mixed
- load() : void
- withDeleteOptions() : self
- withInsertOptions() : self
- withOperation() : self
- withTypesMap() : self
- withUpdateOptions() : self
Methods
__construct()
public
__construct(Client $client, string $table[, EntryTypesMap $typesMap = new EntryTypesMap() ]) : mixed
Parameters
- $client : Client
- $table : string
- $typesMap : EntryTypesMap = new EntryTypesMap()
load()
public
load(Rows $rows, FlowContext $context) : void
Parameters
- $rows : Rows
- $context : FlowContext
withDeleteOptions()
public
withDeleteOptions(DeleteOptions $options) : self
Parameters
- $options : DeleteOptions
Return values
selfwithInsertOptions()
public
withInsertOptions(InsertOptions $options) : self
Parameters
- $options : InsertOptions
Return values
selfwithOperation()
public
withOperation(Operation $operation) : self
Parameters
- $operation : Operation
Return values
selfwithTypesMap()
public
withTypesMap(EntryTypesMap $typesMap) : self
Parameters
- $typesMap : EntryTypesMap
Return values
selfwithUpdateOptions()
public
withUpdateOptions(UpdateOptions $options) : self
Parameters
- $options : UpdateOptions