Preql.Wire.Query

Documentation

type TypeCache = IORef (HashMap Text Oid)

data Connection

We make the type cache part of the Connection to offer the option of per-Connection (or striped) caches. It's also reasonable to share a single cache for an entire multi-threaded program; the IORef supports this usage.

Constructors

Connection

Fields

• rawConnection :: !Connection
• typeCache :: !TypeCache

Instances

SQL (ReaderT Connection IO)

Most larger applications will define an instance; this one is suitable to test out the library. A safer version would use MVar Connection to ensure only one thread using it.

Defined in Preql.Effect

Methods

runTransaction' :: IsolationLevel -> Transaction a -> ReaderT Connection IO a

withConnection :: (Connection -> ReaderT Connection IO a) -> ReaderT Connection IO a

queryOn :: (ToSql p, FromSql r, KnownNat (Width r)) => Connection -> (Query (Width r), p) -> ReaderT Connection IO (Vector r)

queryOn_ :: ToSql p => Connection -> (Query 0, p) -> ReaderT Connection IO ()

connectdbSharedCache :: ByteString -> IO Connection

connectdbNewCache :: ByteString -> IO Connection

finish :: Connection -> IO ()

globalCache :: TypeCache

queryWith :: KnownNat (Width r) => RowEncoder p -> RowDecoder (Width r) r -> Connection -> Query (Width r) -> p -> IO (Either QueryError (Vector r))

queryWith_ :: RowEncoder p -> Connection -> Query n -> p -> IO (Either QueryError ())

query :: (ToSql p, FromSql r, KnownNat (Width r)) => Connection -> Query (Width r) -> p -> IO (Either QueryError (Vector r))

query_ :: ToSql p => Connection -> Query n -> p -> IO (Either QueryError ())

execParams :: RowEncoder p -> Connection -> ByteString -> p -> IO (Either QueryError Result)

connectionError :: Connection -> Maybe a -> IO (Either Text a)

decodeVector :: KnownNat n => Connection -> RowDecoder n a -> Result -> IO (Either QueryError (Vector a))

lookupType :: Connection -> PgType -> IO LookupResult

data LookupResult

Constructors

Cached Oid

FromDb Oid

LookupError QueryError

lookupTypeIgnoreCache :: Connection -> PgType -> IO (Either QueryError Oid)

data IsolationLevel

Constructors

ReadCommitted

RepeatableRead

Serializable

Instances

Bounded IsolationLevel

Defined in Preql.Wire.Query

Methods

minBound :: IsolationLevel

maxBound :: IsolationLevel

Enum IsolationLevel

Defined in Preql.Wire.Query

Methods

succ :: IsolationLevel -> IsolationLevel

pred :: IsolationLevel -> IsolationLevel

toEnum :: Int -> IsolationLevel

fromEnum :: IsolationLevel -> Int

enumFrom :: IsolationLevel -> [IsolationLevel]

enumFromThen :: IsolationLevel -> IsolationLevel -> [IsolationLevel]

enumFromTo :: IsolationLevel -> IsolationLevel -> [IsolationLevel]

enumFromThenTo :: IsolationLevel -> IsolationLevel -> IsolationLevel -> [IsolationLevel]

Eq IsolationLevel

Defined in Preql.Wire.Query

Methods

(==) :: IsolationLevel -> IsolationLevel -> Bool

(/=) :: IsolationLevel -> IsolationLevel -> Bool

Ord IsolationLevel

Defined in Preql.Wire.Query

Methods

compare :: IsolationLevel -> IsolationLevel -> Ordering

(<) :: IsolationLevel -> IsolationLevel -> Bool

(<=) :: IsolationLevel -> IsolationLevel -> Bool

(>) :: IsolationLevel -> IsolationLevel -> Bool

(>=) :: IsolationLevel -> IsolationLevel -> Bool

max :: IsolationLevel -> IsolationLevel -> IsolationLevel

min :: IsolationLevel -> IsolationLevel -> IsolationLevel

Read IsolationLevel

Defined in Preql.Wire.Query

Methods

readsPrec :: Int -> ReadS IsolationLevel

readList :: ReadS [IsolationLevel]

readPrec :: ReadPrec IsolationLevel

readListPrec :: ReadPrec [IsolationLevel]

Show IsolationLevel

Defined in Preql.Wire.Query

Methods

showsPrec :: Int -> IsolationLevel -> ShowS

show :: IsolationLevel -> String

showList :: [IsolationLevel] -> ShowS

begin :: Connection -> IsolationLevel -> IO (Either QueryError ())

commit :: Connection -> IO (Either QueryError ())

rollback :: Connection -> IO (Either QueryError ())