2018-05-23 13:33:34 +03:00
|
|
|
module Hasql.Statement
|
2022-06-20 13:54:54 +03:00
|
|
|
( Statement (..),
|
|
|
|
refineResult,
|
2019-05-27 20:44:00 +03:00
|
|
|
|
2022-06-20 13:54:54 +03:00
|
|
|
-- * Recipies
|
2019-05-27 20:44:00 +03:00
|
|
|
|
2022-06-20 13:54:54 +03:00
|
|
|
-- ** Insert many
|
|
|
|
-- $insertMany
|
|
|
|
|
|
|
|
-- ** IN and NOT IN
|
|
|
|
-- $inAndNotIn
|
|
|
|
)
|
2015-11-08 21:09:42 +03:00
|
|
|
where
|
|
|
|
|
2015-12-05 09:09:31 +03:00
|
|
|
import qualified Hasql.Decoders as Decoders
|
2024-01-27 00:23:09 +03:00
|
|
|
import qualified Hasql.Decoders.All as Decoders
|
2015-12-05 09:09:31 +03:00
|
|
|
import qualified Hasql.Encoders as Encoders
|
2024-01-27 00:23:09 +03:00
|
|
|
import Hasql.Prelude
|
2015-11-08 21:09:42 +03:00
|
|
|
|
2022-06-20 13:54:54 +03:00
|
|
|
-- |
|
|
|
|
-- Specification of a strictly single-statement query, which can be parameterized and prepared.
|
|
|
|
--
|
|
|
|
-- Consists of the following:
|
|
|
|
--
|
|
|
|
-- * SQL template,
|
|
|
|
-- * params encoder,
|
|
|
|
-- * result decoder,
|
|
|
|
-- * a flag, determining whether it should be prepared.
|
|
|
|
--
|
|
|
|
-- The SQL template must be formatted according to Postgres' standard,
|
|
|
|
-- with any non-ASCII characters of the template encoded using UTF-8.
|
|
|
|
-- According to the format,
|
|
|
|
-- parameters must be referred to using a positional notation, as in the following:
|
|
|
|
-- @$1@, @$2@, @$3@ and etc.
|
|
|
|
-- Those references must be used in accordance with the order in which
|
|
|
|
-- the value encoders are specified in 'Encoders.Params'.
|
|
|
|
--
|
|
|
|
-- Following is an example of a declaration of a prepared statement with its associated codecs.
|
|
|
|
--
|
|
|
|
-- @
|
|
|
|
-- selectSum :: 'Statement' (Int64, Int64) Int64
|
|
|
|
-- selectSum = 'Statement' sql encoder decoder True where
|
|
|
|
-- sql = "select ($1 + $2)"
|
|
|
|
-- encoder =
|
|
|
|
-- ('fst' '>$<' Encoders.'Hasql.Encoders.param' (Encoders.'Hasql.Encoders.nonNullable' Encoders.'Hasql.Encoders.int8')) '<>'
|
|
|
|
-- ('snd' '>$<' Encoders.'Hasql.Encoders.param' (Encoders.'Hasql.Encoders.nonNullable' Encoders.'Hasql.Encoders.int8'))
|
|
|
|
-- decoder = Decoders.'Hasql.Decoders.singleRow' (Decoders.'Hasql.Decoders.column' (Decoders.'Hasql.Decoders.nonNullable' Decoders.'Hasql.Decoders.int8'))
|
|
|
|
-- @
|
|
|
|
--
|
|
|
|
-- The statement above accepts a product of two parameters of type 'Int64'
|
|
|
|
-- and produces a single result of type 'Int64'.
|
|
|
|
data Statement a b
|
|
|
|
= Statement ByteString (Encoders.Params a) (Decoders.Result b) Bool
|
2018-05-23 12:15:34 +03:00
|
|
|
|
2018-05-23 13:33:34 +03:00
|
|
|
instance Functor (Statement a) where
|
2018-05-23 12:15:34 +03:00
|
|
|
{-# INLINE fmap #-}
|
|
|
|
fmap = rmap
|
2015-11-08 21:09:42 +03:00
|
|
|
|
2018-05-23 13:33:34 +03:00
|
|
|
instance Profunctor Statement where
|
2018-05-23 12:15:34 +03:00
|
|
|
{-# INLINE dimap #-}
|
2018-05-23 13:33:34 +03:00
|
|
|
dimap f1 f2 (Statement template encoder decoder preparable) =
|
|
|
|
Statement template (contramap f1 encoder) (fmap f2 decoder) preparable
|
2019-05-20 19:24:27 +03:00
|
|
|
|
2022-06-20 13:54:54 +03:00
|
|
|
-- |
|
|
|
|
-- Refine a result of a statement,
|
|
|
|
-- causing the running session to fail with the `UnexpectedResult` error in case of refinement failure.
|
|
|
|
--
|
|
|
|
-- This function is especially useful for refining the results of statements produced with
|
|
|
|
-- <http://hackage.haskell.org/package/hasql-th the \"hasql-th\" library>.
|
2020-03-21 20:54:13 +03:00
|
|
|
refineResult :: (a -> Either Text b) -> Statement params a -> Statement params b
|
|
|
|
refineResult refiner (Statement template encoder decoder preparable) =
|
|
|
|
Statement template encoder (Decoders.refineResult refiner decoder) preparable
|
|
|
|
|
2022-06-20 13:54:54 +03:00
|
|
|
-- $insertMany
|
|
|
|
--
|
|
|
|
-- It is not currently possible to pass in an array of encodable values
|
|
|
|
-- to use in an insert many statement. Instead, PostgreSQL's
|
|
|
|
-- (9.4 or later) @unnest@ function can be used in an analogous way
|
|
|
|
-- to haskell's `zip` function by passing in multiple arrays of values
|
|
|
|
-- to be zipped into the rows we want to insert:
|
|
|
|
--
|
|
|
|
-- @
|
|
|
|
-- insertMultipleLocations :: 'Statement' (Vector (UUID, Double, Double)) ()
|
|
|
|
-- insertMultipleLocations = 'Statement' sql encoder decoder True where
|
|
|
|
-- sql = "insert into location (id, x, y) select * from unnest ($1, $2, $3)"
|
|
|
|
-- encoder =
|
|
|
|
-- contramap Vector.'Data.Vector.unzip3' $
|
|
|
|
-- contrazip3 (vector Encoders.'Encoders.uuid') (vector Encoders.'Encoders.float8') (vector Encoders.'Encoders.float8')
|
|
|
|
-- where
|
|
|
|
-- vector =
|
|
|
|
-- Encoders.'Encoders.param' .
|
|
|
|
-- Encoders.'Encoders.nonNullable' .
|
|
|
|
-- Encoders.'Encoders.array' .
|
|
|
|
-- Encoders.'Encoders.dimension' 'foldl'' .
|
|
|
|
-- Encoders.'Encoders.element' .
|
|
|
|
-- Encoders.'Encoders.nonNullable'
|
|
|
|
-- decoder = Decoders.'Decoders.noResult'
|
|
|
|
-- @
|
|
|
|
--
|
|
|
|
-- This approach is much more efficient than executing a single-row Insert
|
|
|
|
-- statement multiple times.
|
|
|
|
|
|
|
|
-- $inAndNotIn
|
|
|
|
--
|
|
|
|
-- There is a common misconception that Postgresql supports array
|
|
|
|
-- as a parameter for the @IN@ operator.
|
|
|
|
-- However Postgres only supports a syntactical list of values with it,
|
|
|
|
-- i.e., you have to specify each option as an individual parameter
|
|
|
|
-- (@something IN ($1, $2, $3)@).
|
|
|
|
--
|
|
|
|
-- Clearly it would be much more convenient to provide an array as a single parameter,
|
|
|
|
-- but the @IN@ operator does not support that.
|
|
|
|
-- Fortunately, Postgres does provide such functionality with other operators:
|
|
|
|
--
|
|
|
|
-- * Use @something = ANY($1)@ instead of @something IN ($1)@
|
|
|
|
-- * Use @something <> ALL($1)@ instead of @something NOT IN ($1)@
|
|
|
|
--
|
|
|
|
-- For details see
|
|
|
|
-- <https://www.postgresql.org/docs/9.6/static/functions-comparisons.html#AEN20944 the Postgresql docs>.
|