Database.HDBI.PostgreSQL.Implementation

Types

data PostgreConnection

Constructors

PostgreConnection

Fields

postNative :: MVar (Maybe Connection)

LibPQ connection if established

postStatements :: ChildList PostgreStatement

List of weak refs to statements to finalize on disconnect

postConnString :: Text

Original connection string

Instances

Typeable PostgreConnection

Connection PostgreConnection

data PGStatementState

Constructors

STNew

Newly created or reseted statement

STExecuted

Just executed statement

Fields

pgstResult :: !Result

The result to fetch data from

STFetching

Fetching rows is in progress

Fields

pgstResult :: !Result

The result to fetch data from

pgstColumns :: !Column

Columns count

pgstFormats :: ![Format]

pgstTypes :: ![Oid]

pgstTuples :: !Row

Tuples in result

pgstCurrent :: !Row

Row number waiting to fetch

STFinished

Statement is finished, can still be reseted

data PostgreStatement

Constructors

PostgreStatement

Fields

stQuery :: Query

Initial query

stConnection :: PostgreConnection

Connection this statement working with

stState :: MVar PGStatementState

State of statement

Instances

Typeable PostgreStatement

Statement PostgreStatement

Connection functions

connectPostgreSQL

Arguments

:: Text

Connection string according to the documentation

-> IO PostgreConnection

Establish new PostgreSQL connection

withPGConnection

Arguments

:: PostgreConnection

-> (Connection -> IO a)

action to execute with native LibPQ connection

-> IO a

If connection is opened then execute an action, else throw an error.

Data manipulating functions

sqlValueToNative :: SqlValue -> Maybe (Oid, ByteString, Format)

Convert SqlValue to native libPQ data representation

formatUTC :: UTCTime -> ByteString

Format UTCTime as ByteString

formatDay :: Day -> ByteString

Format Day as ByteString

formatT :: TimeOfDay -> ByteString

format TimeOfDay to ByteString

formatDT :: LocalTime -> ByteString

format LocalTime as ByteString

formatBits :: Word64 -> ByteString

format Word64 as bit field (001010111)

o2b :: Oid -> BuiltinType

convert Oid to BuiltinType if not converted then throw an error

nativeToSqlValue :: ByteString -> Format -> Oid -> IO SqlValue

convert native LibPQ data representation to SqlValue. Now support just Text format completely. Maybe binary protocol will be added in future versions.

parseT :: ByteString -> TimeOfDay

parse ByteString as TimeOfDay

parseDT :: ByteString -> LocalTime

parse ByteString as LocalTime

parseD :: ByteString -> Day

parse ByteString as Day

parseUTC :: ByteString -> UTCTime

parse ByteString as UTCTime

parseBit :: ByteString -> Word64

parse ByteString as 64 bit field (00101110) and convert to Word64

Miscellaneous functions

throwErrorMessage :: Connection -> IO a

get last error code and error message from connection and throw proper SqlError

getPGResult :: Connection -> Maybe Result -> IO Result

Throws appropriate SqlError when no Result is not given, or it is in wrong status

throwResultError :: Result -> IO a

Get error message from the result and throw it as SqlError

pgRun :: PostgreConnection -> Query -> [SqlValue] -> IO Result

pgRunRaw :: PostgreConnection -> Query -> IO Result

pgRunMany :: PostgreConnection -> Query -> [[SqlValue]] -> IO ()

pgstGetResult :: String -> PGStatementState -> Result

get Result from PGStatementState if can. If can not throw an error with specified message