module Database.PostgreSQL.PQTypes.Class
(
MonadDB (..)
, BackendPid (..)
, QueryName (..)
) where
import Control.Monad.Trans
import Control.Monad.Trans.Control
import GHC.Stack
import Database.PostgreSQL.PQTypes.FromRow
import Database.PostgreSQL.PQTypes.Internal.BackendPid
import Database.PostgreSQL.PQTypes.Internal.Connection
import Database.PostgreSQL.PQTypes.Internal.Notification
import Database.PostgreSQL.PQTypes.Internal.QueryResult
import Database.PostgreSQL.PQTypes.SQL.Class
import Database.PostgreSQL.PQTypes.Transaction.Settings
class (Applicative m, Monad m) => MonadDB m where
runQuery :: (HasCallStack, IsSQL sql) => sql -> m Int
runPreparedQuery :: (HasCallStack, IsSQL sql) => QueryName -> sql -> m Int
getLastQuery :: m SomeSQL
withFrozenLastQuery :: m a -> m a
getBackendPid :: m BackendPid
getConnectionStats :: HasCallStack => m ConnectionStats
getQueryResult :: FromRow row => m (Maybe (QueryResult row))
clearQueryResult :: m ()
getTransactionSettings :: m TransactionSettings
setTransactionSettings :: TransactionSettings -> m ()
getNotification :: Int -> m (Maybe Notification)
withNewConnection :: m a -> m a
instance
{-# OVERLAPPABLE #-}
( Applicative (t m)
, Monad (t m)
, MonadTrans t
, MonadTransControl t
, MonadDB m
)
=> MonadDB (t m)
where
runQuery :: forall sql. (HasCallStack, IsSQL sql) => sql -> t m Int
runQuery = (HasCallStack => sql -> t m Int) -> sql -> t m Int
forall a. HasCallStack => (HasCallStack => a) -> a
withFrozenCallStack ((HasCallStack => sql -> t m Int) -> sql -> t m Int)
-> (HasCallStack => sql -> t m Int) -> sql -> t m Int
forall a b. (a -> b) -> a -> b
$ m Int -> t m Int
forall (m :: * -> *) a. Monad m => m a -> t m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
(MonadTrans t, Monad m) =>
m a -> t m a
lift (m Int -> t m Int) -> (sql -> m Int) -> sql -> t m Int
forall b c a. (b -> c) -> (a -> b) -> a -> c
. sql -> m Int
forall sql. (HasCallStack, IsSQL sql) => sql -> m Int
forall (m :: * -> *) sql.
(MonadDB m, HasCallStack, IsSQL sql) =>
sql -> m Int
runQuery
runPreparedQuery :: forall sql.
(HasCallStack, IsSQL sql) =>
QueryName -> sql -> t m Int
runPreparedQuery QueryName
name = (HasCallStack => sql -> t m Int) -> sql -> t m Int
forall a. HasCallStack => (HasCallStack => a) -> a
withFrozenCallStack ((HasCallStack => sql -> t m Int) -> sql -> t m Int)
-> (HasCallStack => sql -> t m Int) -> sql -> t m Int
forall a b. (a -> b) -> a -> b
$ m Int -> t m Int
forall (m :: * -> *) a. Monad m => m a -> t m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
(MonadTrans t, Monad m) =>
m a -> t m a
lift (m Int -> t m Int) -> (sql -> m Int) -> sql -> t m Int
forall b c a. (b -> c) -> (a -> b) -> a -> c
. QueryName -> sql -> m Int
forall sql. (HasCallStack, IsSQL sql) => QueryName -> sql -> m Int
forall (m :: * -> *) sql.
(MonadDB m, HasCallStack, IsSQL sql) =>
QueryName -> sql -> m Int
runPreparedQuery QueryName
name
getLastQuery :: t m SomeSQL
getLastQuery = m SomeSQL -> t m SomeSQL
forall (m :: * -> *) a. Monad m => m a -> t m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
(MonadTrans t, Monad m) =>
m a -> t m a
lift m SomeSQL
forall (m :: * -> *). MonadDB m => m SomeSQL
getLastQuery
withFrozenLastQuery :: forall a. t m a -> t m a
withFrozenLastQuery t m a
m = (Run t -> m (StT t a)) -> t m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
(MonadTransControl t, Monad (t m), Monad m) =>
(Run t -> m (StT t a)) -> t m a
controlT ((Run t -> m (StT t a)) -> t m a)
-> (Run t -> m (StT t a)) -> t m a
forall a b. (a -> b) -> a -> b
$ \Run t
run -> m (StT t a) -> m (StT t a)
forall a. m a -> m a
forall (m :: * -> *) a. MonadDB m => m a -> m a
withFrozenLastQuery (t m a -> m (StT t a)
Run t
run t m a
m)
getBackendPid :: t m BackendPid
getBackendPid = m BackendPid -> t m BackendPid
forall (m :: * -> *) a. Monad m => m a -> t m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
(MonadTrans t, Monad m) =>
m a -> t m a
lift m BackendPid
forall (m :: * -> *). MonadDB m => m BackendPid
getBackendPid
getConnectionStats :: HasCallStack => t m ConnectionStats
getConnectionStats = (HasCallStack => t m ConnectionStats) -> t m ConnectionStats
forall a. HasCallStack => (HasCallStack => a) -> a
withFrozenCallStack ((HasCallStack => t m ConnectionStats) -> t m ConnectionStats)
-> (HasCallStack => t m ConnectionStats) -> t m ConnectionStats
forall a b. (a -> b) -> a -> b
$ m ConnectionStats -> t m ConnectionStats
forall (m :: * -> *) a. Monad m => m a -> t m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
(MonadTrans t, Monad m) =>
m a -> t m a
lift m ConnectionStats
forall (m :: * -> *).
(MonadDB m, HasCallStack) =>
m ConnectionStats
getConnectionStats
getQueryResult :: forall row. FromRow row => t m (Maybe (QueryResult row))
getQueryResult = m (Maybe (QueryResult row)) -> t m (Maybe (QueryResult row))
forall (m :: * -> *) a. Monad m => m a -> t m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
(MonadTrans t, Monad m) =>
m a -> t m a
lift m (Maybe (QueryResult row))
forall row. FromRow row => m (Maybe (QueryResult row))
forall (m :: * -> *) row.
(MonadDB m, FromRow row) =>
m (Maybe (QueryResult row))
getQueryResult
clearQueryResult :: t m ()
clearQueryResult = m () -> t m ()
forall (m :: * -> *) a. Monad m => m a -> t m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
(MonadTrans t, Monad m) =>
m a -> t m a
lift m ()
forall (m :: * -> *). MonadDB m => m ()
clearQueryResult
getTransactionSettings :: t m TransactionSettings
getTransactionSettings = m TransactionSettings -> t m TransactionSettings
forall (m :: * -> *) a. Monad m => m a -> t m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
(MonadTrans t, Monad m) =>
m a -> t m a
lift m TransactionSettings
forall (m :: * -> *). MonadDB m => m TransactionSettings
getTransactionSettings
setTransactionSettings :: TransactionSettings -> t m ()
setTransactionSettings = m () -> t m ()
forall (m :: * -> *) a. Monad m => m a -> t m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
(MonadTrans t, Monad m) =>
m a -> t m a
lift (m () -> t m ())
-> (TransactionSettings -> m ()) -> TransactionSettings -> t m ()
forall b c a. (b -> c) -> (a -> b) -> a -> c
. TransactionSettings -> m ()
forall (m :: * -> *). MonadDB m => TransactionSettings -> m ()
setTransactionSettings
getNotification :: Int -> t m (Maybe Notification)
getNotification = m (Maybe Notification) -> t m (Maybe Notification)
forall (m :: * -> *) a. Monad m => m a -> t m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
(MonadTrans t, Monad m) =>
m a -> t m a
lift (m (Maybe Notification) -> t m (Maybe Notification))
-> (Int -> m (Maybe Notification))
-> Int
-> t m (Maybe Notification)
forall b c a. (b -> c) -> (a -> b) -> a -> c
. Int -> m (Maybe Notification)
forall (m :: * -> *). MonadDB m => Int -> m (Maybe Notification)
getNotification
withNewConnection :: forall a. t m a -> t m a
withNewConnection t m a
m = (Run t -> m (StT t a)) -> t m a
forall (t :: (* -> *) -> * -> *) (m :: * -> *) a.
(MonadTransControl t, Monad (t m), Monad m) =>
(Run t -> m (StT t a)) -> t m a
controlT ((Run t -> m (StT t a)) -> t m a)
-> (Run t -> m (StT t a)) -> t m a
forall a b. (a -> b) -> a -> b
$ \Run t
run -> m (StT t a) -> m (StT t a)
forall a. m a -> m a
forall (m :: * -> *) a. MonadDB m => m a -> m a
withNewConnection (t m a -> m (StT t a)
Run t
run t m a
m)