persistent-postgresql-streaming-0.1.0.0: Memory-constant streaming of Persistent entities from PostgreSQL
Safe HaskellNone
LanguageHaskell2010

Database.Persist.Postgresql.Streaming.Internal

Synopsis

Documentation

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

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.