hpqtypes

Safe Haskell	None
Language	Haskell2010

Database.PostgreSQL.PQTypes.Internal.State

Contents

ConnectionData
DBState

Description

Definition of internal DBT state.

Synopsis

data ConnectionData (m :: Type -> Type)
getConnectionSource :: forall (m :: Type -> Type). ConnectionData m -> ConnectionSourceM m
getConnectionAcquisitionModeIO :: forall (m :: Type -> Type). HasCallStack => ConnectionData m -> IO ConnectionAcquisitionMode
withConnectionData :: (HasCallStack, MonadBase IO m, MonadMask m) => ConnectionSourceM m -> TransactionSettings -> (ConnectionData m -> m r) -> m r
changeAcquisitionModeTo :: (HasCallStack, MonadBase IO m, MonadMask m) => ConnectionAcquisitionMode -> ConnectionData m -> m ()
withConnection :: (HasCallStack, MonadBase IO m, MonadMask m) => ConnectionData m -> (Connection -> m r) -> m r
data DBState (m :: Type -> Type) = DBState {
- dbConnectionData :: !(ConnectionData m)
- dbConnectionStats :: !ConnectionStats
- dbRestartPredicate :: !(Maybe RestartPredicate)
- dbLastQuery :: !(BackendPid, SomeSQL)
- dbRecordLastQuery :: !Bool
- dbQueryResult :: !(forall row. FromRow row => Maybe (QueryResult row))
}
mkDBState :: forall (m :: Type -> Type). ConnectionData m -> TransactionSettings -> DBState m
updateStateWith :: forall sql (m :: Type -> Type) r. IsSQL sql => Connection -> DBState m -> sql -> (r, ForeignPtr PGresult, ConnectionStats -> ConnectionStats) -> IO (r, DBState m)

ConnectionData

data ConnectionData (m :: Type -> Type) Source #

getConnectionSource :: forall (m :: Type -> Type). ConnectionData m -> ConnectionSourceM m Source #

getConnectionAcquisitionModeIO :: forall (m :: Type -> Type). HasCallStack => ConnectionData m -> IO ConnectionAcquisitionMode Source #

withConnectionData :: (HasCallStack, MonadBase IO m, MonadMask m) => ConnectionSourceM m -> TransactionSettings -> (ConnectionData m -> m r) -> m r Source #

changeAcquisitionModeTo :: (HasCallStack, MonadBase IO m, MonadMask m) => ConnectionAcquisitionMode -> ConnectionData m -> m () Source #

withConnection :: (HasCallStack, MonadBase IO m, MonadMask m) => ConnectionData m -> (Connection -> m r) -> m r Source #

DBState

data DBState (m :: Type -> Type) Source #

Internal DB state.

Constructors

Fields

dbConnectionData :: !(ConnectionData m)
Active connection.
dbConnectionStats :: !ConnectionStats
Statistics associated with the session.
dbRestartPredicate :: !(Maybe RestartPredicate)
Restart predicate from initial TransactionSettings.
dbLastQuery :: !(BackendPid, SomeSQL)
Last SQL query that was executed along with ID of the server process attached to the session that executed it.
dbRecordLastQuery :: !Bool
Whether running query should override dbLastQuery.
dbQueryResult :: !(forall row. FromRow row => Maybe (QueryResult row))
Current query result.

mkDBState :: forall (m :: Type -> Type). ConnectionData m -> TransactionSettings -> DBState m Source #

updateStateWith :: forall sql (m :: Type -> Type) r. IsSQL sql => Connection -> DBState m -> sql -> (r, ForeignPtr PGresult, ConnectionStats -> ConnectionStats) -> IO (r, DBState m) Source #