Database.Persist.Postgresql.Streaming.Internal

Documentation

rawSelectStream :: MonadResource m => ([PersistValue] -> Either Text result) -> Text -> [PersistValue] -> ConduitT () result (ReaderT (RawPostgresql SqlBackend) m) ()

Run a Text query, with interpolated PersistValues, against a PostgreSQL backend using cursors, parsing the results with a custom parser function and streaming them back.

If the parser function returns Left for any row, a PersistException will be thrown.