Module type Caqti_connection_sig.PopulateSource

Sourcetype +'a fiber
Sourcetype (+'a, +'err) stream

Insertion

Sourceval populate : table:string -> columns:string list -> 'a Caqti_type.t -> ('a, 'err) stream -> (unit, [> Caqti_error.call_or_retrieve | `Congested of 'err ]) result fiber

populate table columns row_type seq inputs the contents of seq into the database in whatever manner is most efficient as decided by the driver.