Database.Beam.Postgres.Conduit

More efficient query execution functions for beam-postgres. These functions use the conduit package, to execute beam-postgres statements in an arbitrary MonadIO. These functions may be more efficient for streaming operations than MonadBeam.

SELECT

runSelect :: (MonadIO m, MonadFail m, MonadBaseControl IO m, FromBackendRow Postgres a) => Connection -> SqlSelect Postgres a -> (ConduitT () a m () -> m b) -> m b

Run a PostgreSQL SELECT statement in any MonadIO.

INSERT

runInsert :: MonadIO m => Connection -> SqlInsert Postgres tbl -> m Int64

Run a PostgreSQL INSERT statement in any MonadIO. Returns the number of rows affected.

runInsertReturning :: (MonadIO m, MonadFail m, MonadBaseControl IO m, FromBackendRow Postgres a) => Connection -> PgInsertReturning a -> (ConduitT () a m () -> m b) -> m b

Run a PostgreSQL INSERT ... RETURNING ... statement in any MonadIO and get a Source of the newly inserted rows.

UPDATE

runUpdate :: MonadIO m => Connection -> SqlUpdate Postgres tbl -> m Int64

Run a PostgreSQL UPDATE statement in any MonadIO. Returns the number of rows affected.

runUpdateReturning :: (MonadIO m, MonadFail m, MonadBaseControl IO m, FromBackendRow Postgres a) => Connection -> PgUpdateReturning a -> (ConduitT () a m () -> m b) -> m b

Run a PostgreSQL UPDATE ... RETURNING ... statement in any MonadIO and get a Source of the newly updated rows.

DELETE

runDelete :: MonadIO m => Connection -> SqlDelete Postgres tbl -> m Int64

Run a PostgreSQL DELETE statement in any MonadIO. Returns the number of rows affected.

runDeleteReturning :: (MonadIO m, MonadFail m, MonadBaseControl IO m, FromBackendRow Postgres a) => Connection -> PgDeleteReturning a -> (ConduitT () a m () -> m b) -> m b

Run a PostgreSQl DELETE ... RETURNING ... statement in any MonadIO and get a Source of the deleted rows.

Convenience functions

executeStatement :: MonadIO m => Connection -> PgSyntax -> m Int64

Run any DML statement. Return the number of rows affected

runQueryReturning :: (MonadIO m, MonadFail m, MonadBaseControl IO m, Functor m, FromBackendRow Postgres r) => Connection -> PgSyntax -> (ConduitT () r m () -> m b) -> m b

Runs any query that returns a set of values