@@ -1,11 +1,12 @@
1−{-# language BangPatterns #-}
2{-# language BlockArguments #-}
1{-# language BlockArguments #-}
2+{-# language DataKinds #-}
3{-# language DeriveAnyClass #-}
3{-# language DeriveAnyClass #-}
4{-# language DeriveGeneric #-}
4{-# language DeriveGeneric #-}
5{-# language DerivingStrategies #-}
5{-# language DerivingStrategies #-}
6+{-# language DisambiguateRecordFields #-}
6{-# language FlexibleContexts #-}
7{-# language FlexibleContexts #-}
7{-# language FlexibleInstances #-}
8{-# language FlexibleInstances #-}
8−{-# language MonoLocalBinds #-}
9+{-# language GADTs #-}
9{-# language NamedFieldPuns #-}
10{-# language NamedFieldPuns #-}
10{-# language OverloadedStrings #-}
11{-# language OverloadedStrings #-}
11{-# language RecordWildCards #-}
12{-# language RecordWildCards #-}
@@ -13,15 +14,17 @@
13{-# language StandaloneDeriving #-}
14{-# language StandaloneDeriving #-}
14{-# language TypeApplications #-}
15{-# language TypeApplications #-}
17+{-# options_ghc -fno-warn-redundant-constraints #-}
16module Main
19module Main
22−import Control.Applicative ( empty, liftA2, liftA3 )
25+import Control.Applicative ( liftA2, liftA3 )
23−import Control.Exception ( bracket, throwIO )
26+import Control.Monad (void)
24−import Control.Monad ( (>=>), void )
27+import Control.Monad.IO.Class ( MonadIO, liftIO )
25import Data.Bifunctor ( bimap )
28import Data.Bifunctor ( bimap )
26import Data.Foldable ( for_ )
29import Data.Foldable ( for_ )
27import Data.Int ( Int32, Int64 )
30import Data.Int ( Int32, Int64 )
@@ -35,27 +38,25 @@ import GHC.Generics ( Generic )
35import qualified Data.ByteString.Lazy
38import qualified Data.ByteString.Lazy
37-- case-insensitive
40-- case-insensitive
38−import Data.CaseInsensitive ( mk )
41+import Data.CaseInsensitive (mk)
40-- containers
43-- containers
41−import Data.Containers.ListUtils ( nubOrdOn )
42import qualified Data.Map.Strict as Map
44import qualified Data.Map.Strict as Map
45−import Hasql.Connection ( Connection, acquire, release )
47+import Hasql.Connection ( Connection, acquire, release )
46import Hasql.Session ( sql, run )
48import Hasql.Session ( sql, run )
49−import Hasql.Transaction ( Transaction, condemn, statement )
50−import qualified Hasql.Transaction.Sessions as Hasql
52-- hedgehog
50-- hedgehog
53import Hedgehog ( property, (===), forAll, cover, diff, evalM, PropertyT, TestT, test, Gen )
51import Hedgehog ( property, (===), forAll, cover, diff, evalM, PropertyT, TestT, test, Gen )
54import qualified Hedgehog.Gen as Gen
52import qualified Hedgehog.Gen as Gen
55import qualified Hedgehog.Range as Range
53import qualified Hedgehog.Range as Range
57−-- mmorph
55+-- lifted-base
56+import Control.Exception.Lifted ( bracket, throwIO, bracket_ )
58−import Control.Monad.Morph ( hoist )
59+import Control.Monad.Trans.Control ( MonadBaseControl )
61import Rel8 ( Result )
62import Rel8 ( Result )
@@ -71,16 +72,12 @@ import Test.Tasty
71import Test.Tasty.Hedgehog ( testProperty )
72import Test.Tasty.Hedgehog ( testProperty )
74−import Data.Text ( Text, pack, unpack )
75+import Data.Text (Text, pack)
75import qualified Data.Text.Lazy
76import qualified Data.Text.Lazy
76−import Data.Text.Encoding ( decodeUtf8 )
79import Data.Time
79import Data.Time
82−import Control.Monad.Trans.Class ( lift )
84-- tmp-postgres
81-- tmp-postgres
85import qualified Database.Postgres.Temp as TmpPostgres
82import qualified Database.Postgres.Temp as TmpPostgres
@@ -116,13 +113,11 @@ tests =
116 , testCatMaybeTable getTestDatabase
113 , testCatMaybeTable getTestDatabase
117 , testCatMaybe getTestDatabase
114 , testCatMaybe getTestDatabase
118 , testMaybeTable getTestDatabase
115 , testMaybeTable getTestDatabase
119− , testAggregateMaybeTable getTestDatabase
120 , testNestedTables getTestDatabase
116 , testNestedTables getTestDatabase
121 , testMaybeTableApplicative getTestDatabase
117 , testMaybeTableApplicative getTestDatabase
122 , testLogicalFixities getTestDatabase
118 , testLogicalFixities getTestDatabase
123 , testUpdate getTestDatabase
119 , testUpdate getTestDatabase
124 , testDelete getTestDatabase
120 , testDelete getTestDatabase
125− , testUpsert getTestDatabase
126 , testSelectNestedPairs getTestDatabase
121 , testSelectNestedPairs getTestDatabase
127 , testSelectArray getTestDatabase
122 , testSelectArray getTestDatabase
128 , testNestedMaybeTable getTestDatabase
123 , testNestedMaybeTable getTestDatabase
@@ -138,7 +133,6 @@ tests =
138 flip run conn do
133 flip run conn do
139 sql "CREATE EXTENSION citext"
134 sql "CREATE EXTENSION citext"
140 sql "CREATE TABLE test_table ( column1 text not null, column2 bool not null )"
135 sql "CREATE TABLE test_table ( column1 text not null, column2 bool not null )"
141− sql "CREATE TABLE unique_table ( \"key\" text not null unique, \"value\" text not null )"
142 sql "CREATE SEQUENCE test_seq"
136 sql "CREATE SEQUENCE test_seq"
144 return db
138 return db
@@ -146,21 +140,19 @@ tests =
146 stopTestDatabase = TmpPostgres.stop
140 stopTestDatabase = TmpPostgres.stop
149−connect :: TmpPostgres.DB -> IO Connection
150−connect = acquire . TmpPostgres.toConnectionString >=> either (maybe empty (fail . unpack . decodeUtf8)) pure
153databasePropertyTest
143databasePropertyTest
154 :: TestName
144 :: TestName
155− -> ((TestT Transaction () -> PropertyT IO ()) -> PropertyT IO ())
145+ -> (((Connection -> TestT IO ()) -> PropertyT IO ()) -> PropertyT IO ())
156 -> IO TmpPostgres.DB -> TestTree
146 -> IO TmpPostgres.DB -> TestTree
157databasePropertyTest testName f getTestDatabase =
147databasePropertyTest testName f getTestDatabase =
158− withResource (connect =<< getTestDatabase) release $ \c ->
148+ withResource connect release $ \c ->
159 testProperty testName $ property do
149 testProperty testName $ property do
160− connection <- lift c
150+ connection <- liftIO c
161− f $ test . hoist \m -> do
151+ f \g -> test $ rollingBack connection $ g connection
162− e <- run (Hasql.transaction Hasql.Serializable Hasql.Write (m <* condemn)) connection
152+
163− either throwIO pure e
153+ where
155+ connect = either (error . show) return =<< acquire . TmpPostgres.toConnectionString =<< getTestDatabase
166data TestTable f = TestTable
158data TestTable f = TestTable
@@ -192,17 +184,17 @@ testSelectTestTable :: IO TmpPostgres.DB -> TestTree
192testSelectTestTable = databasePropertyTest "Can SELECT TestTable" \transaction -> do
184testSelectTestTable = databasePropertyTest "Can SELECT TestTable" \transaction -> do
193 rows <- forAll $ Gen.list (Range.linear 0 10) genTestTable
185 rows <- forAll $ Gen.list (Range.linear 0 10) genTestTable
195− transaction do
187+ transaction \connection -> do
196− selected <- lift do
188+ liftIO $ Rel8.insert connection
197− statement () $ Rel8.insert Rel8.Insert
189+ Rel8.Insert
198 { into = testTableSchema
190 { into = testTableSchema
199 , rows = Rel8.values $ map Rel8.lit rows
191 , rows = Rel8.values $ map Rel8.lit rows
200 , onConflict = Rel8.DoNothing
192 , onConflict = Rel8.DoNothing
201 , returning = pure ()
193 , returning = pure ()
204− statement () $ Rel8.select do
196+ selected <- liftIO $ Rel8.select connection do
205− Rel8.each testTableSchema
197+ Rel8.each testTableSchema
207 sort selected === sort rows
199 sort selected === sort rows
@@ -219,12 +211,11 @@ testWhere_ = databasePropertyTest "WHERE (Rel8.where_)" \transaction -> do
220 let expected = filter (\t -> testTableColumn2 t == magicBool) rows
212 let expected = filter (\t -> testTableColumn2 t == magicBool) rows
222− transaction do
214+ transaction \connection -> do
224− statement () $ Rel8.select do
215+ selected <- liftIO $ Rel8.select connection do
225− t <- Rel8.values $ Rel8.lit <$> rows
216+ t <- Rel8.values $ Rel8.lit <$> rows
226− Rel8.where_ $ testTableColumn2 t Rel8.==. Rel8.lit magicBool
217+ Rel8.where_ $ testTableColumn2 t Rel8.==. Rel8.lit magicBool
227− return t
218+ return t
229 sort selected === sort expected
220 sort selected === sort expected
@@ -237,12 +228,11 @@ testFilter :: IO TmpPostgres.DB -> TestTree
237testFilter = databasePropertyTest "filter" \transaction -> do
228testFilter = databasePropertyTest "filter" \transaction -> do
238 rows <- forAll $ Gen.list (Range.linear 1 10) genTestTable
229 rows <- forAll $ Gen.list (Range.linear 1 10) genTestTable
240− transaction do
231+ transaction \connection -> do
241 let expected = filter testTableColumn2 rows
232 let expected = filter testTableColumn2 rows
243− selected <- lift do
234+ selected <- liftIO $ Rel8.select connection
244− statement () $ Rel8.select do
245− Rel8.filter testTableColumn2 =<< Rel8.values (Rel8.lit <$> rows)
235+ $ Rel8.filter testTableColumn2 =<< Rel8.values (Rel8.lit <$> rows)
247 sort selected === sort expected
237 sort selected === sort expected
@@ -257,10 +247,9 @@ testLimit = databasePropertyTest "LIMIT (Rel8.limit)" \transaction -> do
258 n <- forAll $ Gen.integral (Range.linear 0 10)
248 n <- forAll $ Gen.integral (Range.linear 0 10)
260− transaction do
250+ transaction \connection -> do
261− selected <- lift do
251+ selected <- liftIO $ Rel8.select connection do
262− statement () $ Rel8.select do
263− Rel8.limit n $ Rel8.values (Rel8.lit <$> rows)
252+ Rel8.limit n $ Rel8.values (Rel8.lit <$> rows)
265 diff (length selected) (<=) (fromIntegral n)
254 diff (length selected) (<=) (fromIntegral n)
@@ -278,10 +267,9 @@ testUnion = databasePropertyTest "UNION (Rel8.union)" \transaction -> evalM do
278 left <- forAll $ Gen.list (Range.linear 0 10) genTestTable
267 left <- forAll $ Gen.list (Range.linear 0 10) genTestTable
279 right <- forAll $ Gen.list (Range.linear 0 10) genTestTable
268 right <- forAll $ Gen.list (Range.linear 0 10) genTestTable
281− transaction do
270+ transaction \connection -> do
282− selected <- lift do
271+ selected <- liftIO $ Rel8.select connection do
283− statement () $ Rel8.select do
284− Rel8.values (Rel8.lit <$> nub left) `Rel8.union` Rel8.values (Rel8.lit <$> nub right)
272+ Rel8.values (Rel8.lit <$> nub left) `Rel8.union` Rel8.values (Rel8.lit <$> nub right)
286 sort selected === sort (nub (left ++ right))
274 sort selected === sort (nub (left ++ right))
@@ -290,11 +278,9 @@ testDistinct :: IO TmpPostgres.DB -> TestTree
290testDistinct = databasePropertyTest "DISTINCT (Rel8.distinct)" \transaction -> do
278testDistinct = databasePropertyTest "DISTINCT (Rel8.distinct)" \transaction -> do
291 rows <- forAll $ Gen.list (Range.linear 0 10) genTestTable
279 rows <- forAll $ Gen.list (Range.linear 0 10) genTestTable
293− transaction do
281+ transaction \connection -> do
295− statement () $ Rel8.select do
296− Rel8.distinct do
282+ selected <- liftIO $ Rel8.select connection $ Rel8.distinct do
297− Rel8.values (Rel8.lit <$> rows)
283+ Rel8.values (Rel8.lit <$> rows)
299 sort selected === nub (sort rows)
285 sort selected === nub (sort rows)
@@ -307,10 +293,8 @@ testExists :: IO TmpPostgres.DB -> TestTree
307testExists = databasePropertyTest "EXISTS (Rel8.exists)" \transaction -> do
293testExists = databasePropertyTest "EXISTS (Rel8.exists)" \transaction -> do
308 rows <- forAll $ Gen.list (Range.linear 0 10) genTestTable
294 rows <- forAll $ Gen.list (Range.linear 0 10) genTestTable
310− transaction do
296+ transaction \connection -> do
312− statement () $ Rel8.select do
313− Rel8.exists $ Rel8.values $ Rel8.lit <$> rows
297+ exists <- liftIO $ Rel8.select connection $ Rel8.exists $ Rel8.values $ Rel8.lit <$> rows
315 case rows of
299 case rows of
316 [] -> exists === [False]
300 [] -> exists === [False]
@@ -321,10 +305,9 @@ testOptional :: IO TmpPostgres.DB -> TestTree
321testOptional = databasePropertyTest "Rel8.optional" \transaction -> do
305testOptional = databasePropertyTest "Rel8.optional" \transaction -> do
322 rows <- forAll $ Gen.list (Range.linear 0 10) genTestTable
306 rows <- forAll $ Gen.list (Range.linear 0 10) genTestTable
324− transaction do
308+ transaction \connection -> do
325− selected <- lift do
309+ selected <- liftIO $ Rel8.select connection do
326− statement () $ Rel8.select do
327− Rel8.optional $ Rel8.values (Rel8.lit <$> rows)
310+ Rel8.optional $ Rel8.values (Rel8.lit <$> rows)
329 case rows of
312 case rows of
330 [] -> selected === [Nothing]
313 [] -> selected === [Nothing]
@@ -335,10 +318,9 @@ testAnd :: IO TmpPostgres.DB -> TestTree
335testAnd = databasePropertyTest "AND (&&.)" \transaction -> do
318testAnd = databasePropertyTest "AND (&&.)" \transaction -> do
336 (x, y) <- forAll $ liftA2 (,) Gen.bool Gen.bool
319 (x, y) <- forAll $ liftA2 (,) Gen.bool Gen.bool
338− transaction do
321+ transaction \connection -> do
339− [result] <- lift do
322+ [result] <- liftIO $ Rel8.select connection $ pure $
340− statement () $ Rel8.select do
341− pure $ Rel8.lit x Rel8.&&. Rel8.lit y
323+ Rel8.lit x Rel8.&&. Rel8.lit y
343 result === (x && y)
325 result === (x && y)
@@ -347,10 +329,9 @@ testOr :: IO TmpPostgres.DB -> TestTree
347testOr = databasePropertyTest "OR (||.)" \transaction -> do
329testOr = databasePropertyTest "OR (||.)" \transaction -> do
348 (x, y) <- forAll $ liftA2 (,) Gen.bool Gen.bool
330 (x, y) <- forAll $ liftA2 (,) Gen.bool Gen.bool
350− transaction do
332+ transaction \connection -> do
352− statement () $ Rel8.select $ pure $
333+ [result] <- liftIO $ Rel8.select connection $ pure $
353− Rel8.lit x Rel8.||. Rel8.lit y
334+ Rel8.lit x Rel8.||. Rel8.lit y
355 result === (x || y)
336 result === (x || y)
@@ -359,10 +340,9 @@ testLogicalFixities :: IO TmpPostgres.DB -> TestTree
359testLogicalFixities = databasePropertyTest "Logical operator fixities" \transaction -> do
340testLogicalFixities = databasePropertyTest "Logical operator fixities" \transaction -> do
360 (u, v, w, x) <- forAll $ (,,,) <$> Gen.bool <*> Gen.bool <*> Gen.bool <*> Gen.bool
341 (u, v, w, x) <- forAll $ (,,,) <$> Gen.bool <*> Gen.bool <*> Gen.bool <*> Gen.bool
362− transaction do
343+ transaction \connection -> do
363− [result] <- lift do
344+ [result] <- liftIO $ Rel8.select connection $ pure $
364− statement () $ Rel8.select do
365− pure $ Rel8.lit u Rel8.||. Rel8.lit v Rel8.&&. Rel8.lit w Rel8.==. Rel8.lit x
345+ Rel8.lit u Rel8.||. Rel8.lit v Rel8.&&. Rel8.lit w Rel8.==. Rel8.lit x
367 result === (u || v && w == x)
347 result === (u || v && w == x)
@@ -371,10 +351,9 @@ testNot :: IO TmpPostgres.DB -> TestTree
371testNot = databasePropertyTest "NOT (not_)" \transaction -> do
351testNot = databasePropertyTest "NOT (not_)" \transaction -> do
372 x <- forAll Gen.bool
352 x <- forAll Gen.bool
374− transaction do
354+ transaction \connection -> do
375− [result] <- lift do
355+ [result] <- liftIO $ Rel8.select connection $ pure $
376− statement () $ Rel8.select do
377− pure $ Rel8.not_ $ Rel8.lit x
356+ Rel8.not_ $ Rel8.lit x
379 result === not x
358 result === not x
@@ -383,10 +362,9 @@ testBool :: IO TmpPostgres.DB -> TestTree
383testBool = databasePropertyTest "ifThenElse_" \transaction -> do
362testBool = databasePropertyTest "ifThenElse_" \transaction -> do
384 (x, y, z) <- forAll $ liftA3 (,,) Gen.bool Gen.bool Gen.bool
363 (x, y, z) <- forAll $ liftA3 (,,) Gen.bool Gen.bool Gen.bool
386− transaction do
365+ transaction \connection -> do
387− [result] <- lift do
366+ [result] <- liftIO $ Rel8.select connection $ pure $
388− statement () $ Rel8.select do
389− pure $ Rel8.bool (Rel8.lit z) (Rel8.lit y) (Rel8.lit x)
367+ Rel8.bool (Rel8.lit z) (Rel8.lit y) (Rel8.lit x)
391 result === if x then y else z
369 result === if x then y else z
@@ -398,10 +376,9 @@ testAp = databasePropertyTest "Cartesian product (<*>)" \transaction -> do
398 (Gen.list (Range.linear 1 10) genTestTable)
376 (Gen.list (Range.linear 1 10) genTestTable)
399 (Gen.list (Range.linear 1 10) genTestTable)
377 (Gen.list (Range.linear 1 10) genTestTable)
401− transaction do
379+ transaction \connection -> do
402− result <- lift do
380+ result <- liftIO $ Rel8.select connection $ do
403− statement () $ Rel8.select do
404− liftA2 (,) (Rel8.values (Rel8.lit <$> rows1)) (Rel8.values (Rel8.lit <$> rows2))
381+ liftA2 (,) (Rel8.values (Rel8.lit <$> rows1)) (Rel8.values (Rel8.lit <$> rows2))
406 sort result === sort (liftA2 (,) rows1 rows2)
383 sort result === sort (liftA2 (,) rows1 rows2)
@@ -430,22 +407,21 @@ testDBType getTestDatabase = testGroup "DBType instances"
431 dbTypeTest :: (Eq a, Show a, Rel8.DBType a) => TestName -> Gen a -> TestTree
408 dbTypeTest :: (Eq a, Show a, Rel8.DBType a) => TestName -> Gen a -> TestTree
432 dbTypeTest name generator = testGroup name
409 dbTypeTest name generator = testGroup name
433− [ databasePropertyTest name (t generator) getTestDatabase
410+ [ databasePropertyTest name (t (==) generator) getTestDatabase
434− , databasePropertyTest ("Maybe " <> name) (t (Gen.maybe generator)) getTestDatabase
411+ , databasePropertyTest ("Maybe " <> name) (t (==) (Gen.maybe generator)) getTestDatabase
437− t :: forall a b. (Eq a, Show a, Rel8.Sql Rel8.DBType a)
414+ t :: forall a b. (Show a, Rel8.Sql Rel8.DBType a)
438− => Gen a
416+ -> Gen a
439− -> (TestT Transaction () -> PropertyT IO b)
417+ -> ((Connection -> TestT IO ()) -> PropertyT IO b)
440 -> PropertyT IO b
418 -> PropertyT IO b
441− t generator transaction = do
419+ t eq generator transaction = do
442 x <- forAll generator
420 x <- forAll generator
444− transaction do
422+ transaction \connection -> do
446− statement () $ Rel8.select do
447− pure (Rel8.litExpr x)
423+ [res] <- liftIO $ Rel8.select connection $ pure (Rel8.litExpr x)
448− diff res (==) x
424+ diff res eq x
450 genDay :: Gen Day
426 genDay :: Gen Day
451 genDay = do
427 genDay = do
@@ -487,15 +463,13 @@ testDBEq getTestDatabase = testGroup "DBEq instances"
488 t :: forall a. (Eq a, Show a, Rel8.Sql Rel8.DBEq a)
464 t :: forall a. (Eq a, Show a, Rel8.Sql Rel8.DBEq a)
490− -> (TestT Transaction () -> PropertyT IO ())
466+ -> ((Connection -> TestT IO ()) -> PropertyT IO ())
491 -> PropertyT IO ()
467 -> PropertyT IO ()
492 t generator transaction = do
468 t generator transaction = do
493 (x, y) <- forAll (liftA2 (,) generator generator)
469 (x, y) <- forAll (liftA2 (,) generator generator)
495− transaction do
471+ transaction \connection -> do
497− statement () $ Rel8.select do
498− pure $ Rel8.litExpr x Rel8.==. Rel8.litExpr y
472+ [res] <- liftIO $ Rel8.select connection $ pure $ Rel8.litExpr x Rel8.==. Rel8.litExpr y
499 res === (x == y)
473 res === (x == y)
@@ -503,10 +477,9 @@ testTableEquality :: IO TmpPostgres.DB -> TestTree
503testTableEquality = databasePropertyTest "TestTable equality" \transaction -> do
477testTableEquality = databasePropertyTest "TestTable equality" \transaction -> do
504 (x, y) <- forAll $ liftA2 (,) genTestTable genTestTable
478 (x, y) <- forAll $ liftA2 (,) genTestTable genTestTable
506− transaction do
480+ transaction \connection -> do
507− [eq] <- lift do
481+ [eq] <- liftIO $ Rel8.select connection do
508− statement () $ Rel8.select do
509− pure $ Rel8.lit x Rel8.==: Rel8.lit y
482+ pure $ Rel8.lit x Rel8.==: Rel8.lit y
511 eq === (x == y)
484 eq === (x == y)
@@ -515,10 +488,8 @@ testFromString :: IO TmpPostgres.DB -> TestTree
515testFromString = databasePropertyTest "FromString" \transaction -> do
488testFromString = databasePropertyTest "FromString" \transaction -> do
516 str <- forAll $ Gen.list (Range.linear 0 10) Gen.unicode
489 str <- forAll $ Gen.list (Range.linear 0 10) Gen.unicode
518− transaction do
491+ transaction \connection -> do
520− statement () $ Rel8.select do
521− pure $ fromString str
492+ [result] <- liftIO $ Rel8.select connection $ pure $ fromString str
522 result === pack str
493 result === pack str
@@ -526,11 +497,10 @@ testCatMaybeTable :: IO TmpPostgres.DB -> TestTree
526testCatMaybeTable = databasePropertyTest "catMaybeTable" \transaction -> do
497testCatMaybeTable = databasePropertyTest "catMaybeTable" \transaction -> do
527 rows <- forAll $ Gen.list (Range.linear 0 10) genTestTable
498 rows <- forAll $ Gen.list (Range.linear 0 10) genTestTable
529− transaction do
500+ transaction \connection -> do
531− statement () $ Rel8.select do
501+ selected <- liftIO $ Rel8.select connection do
532− testTable <- Rel8.values $ Rel8.lit <$> rows
502+ testTable <- Rel8.values $ Rel8.lit <$> rows
533− Rel8.catMaybeTable $ Rel8.bool Rel8.nothingTable (pure testTable) (testTableColumn2 testTable)
503+ Rel8.catMaybeTable $ Rel8.bool Rel8.nothingTable (pure testTable) (testTableColumn2 testTable)
535 sort selected === sort (filter testTableColumn2 rows)
505 sort selected === sort (filter testTableColumn2 rows)
@@ -539,10 +509,9 @@ testCatMaybe :: IO TmpPostgres.DB -> TestTree
539testCatMaybe = databasePropertyTest "catMaybe" \transaction -> evalM do
509testCatMaybe = databasePropertyTest "catMaybe" \transaction -> evalM do
540 rows <- forAll $ Gen.list (Range.linear 0 10) $ Gen.maybe Gen.bool
510 rows <- forAll $ Gen.list (Range.linear 0 10) $ Gen.maybe Gen.bool
542− transaction do
512+ transaction \connection -> do
543− selected <- lift do
513+ selected <- evalM $ liftIO $ Rel8.select connection do
544− statement () $ Rel8.select do
545− Rel8.catNull =<< Rel8.values (map Rel8.lit rows)
514+ Rel8.catNull =<< Rel8.values (map Rel8.lit rows)
547 sort selected === sort (catMaybes rows)
516 sort selected === sort (catMaybes rows)
@@ -551,38 +520,15 @@ testMaybeTable :: IO TmpPostgres.DB -> TestTree
551testMaybeTable = databasePropertyTest "maybeTable" \transaction -> evalM do
520testMaybeTable = databasePropertyTest "maybeTable" \transaction -> evalM do
552 (rows, def) <- forAll $ liftA2 (,) (Gen.list (Range.linear 0 10) genTestTable) genTestTable
521 (rows, def) <- forAll $ liftA2 (,) (Gen.list (Range.linear 0 10) genTestTable) genTestTable
554− transaction do
523+ transaction \connection -> do
555− selected <- lift do
524+ selected <- liftIO $ Rel8.select connection $
556− statement () $ Rel8.select do
557− Rel8.maybeTable (Rel8.lit def) id <$> Rel8.optional (Rel8.values (Rel8.lit <$> rows))
525+ Rel8.maybeTable (Rel8.lit def) id <$> Rel8.optional (Rel8.values (Rel8.lit <$> rows))
559 case rows of
527 case rows of
560 [] -> selected === [def]
528 [] -> selected === [def]
561 _ -> sort selected === sort rows
529 _ -> sort selected === sort rows
564−testAggregateMaybeTable :: IO TmpPostgres.DB -> TestTree
565−testAggregateMaybeTable = databasePropertyTest "aggregateMaybeTable" \transaction -> evalM do
566− rows <- forAll $ Gen.list (Range.linear 0 10) (Gen.maybe (Gen.int64 (Range.linear 0 10)))
569− aggregate = go 0 False False
571− go !n nothing _ (Just a : as) = go (n + a) nothing True as
572− go n _ just (Nothing : as) = go n True just as
573− go _ False False [] = []
574− go _ True False [] = [Nothing]
575− go n False True [] = [Just n]
576− go n True True [] = [Nothing, Just n]
580− statement () $ Rel8.select do
581− Rel8.aggregate $ Rel8.aggregateMaybeTable Rel8.sum <$> Rel8.values (Rel8.lit <$> rows)
583− sort selected === aggregate rows
586data TwoTestTables f =
532data TwoTestTables f =
587 TwoTestTables
533 TwoTestTables
588 { testTable1 :: TestTable f
534 { testTable1 :: TestTable f
@@ -603,10 +549,9 @@ testNestedTables = databasePropertyTest "Nested TestTables" \transaction -> eval
603 Gen.list (Range.linear 0 10) $
549 Gen.list (Range.linear 0 10) $
604 liftA2 TwoTestTables genTestTable genTestTable
550 liftA2 TwoTestTables genTestTable genTestTable
606− transaction do
552+ transaction \connection -> do
607− selected <- lift do
553+ selected <- liftIO $ Rel8.select connection do
608− statement () $ Rel8.select do
609− Rel8.values (Rel8.lit <$> rows)
554+ Rel8.values (Rel8.lit <$> rows)
611 sort selected === sort rows
556 sort selected === sort rows
@@ -616,12 +561,11 @@ testMaybeTableApplicative = databasePropertyTest "MaybeTable (<*>)" \transaction
616 rows1 <- genRows
561 rows1 <- genRows
617 rows2 <- genRows
562 rows2 <- genRows
619− transaction do
564+ transaction \connection -> do
621− statement () $ Rel8.select do
565+ selected <- liftIO $ Rel8.select connection do
622− as <- Rel8.optional (Rel8.values (Rel8.lit <$> rows1))
566+ as <- Rel8.optional (Rel8.values (Rel8.lit <$> rows1))
623− bs <- Rel8.optional (Rel8.values (Rel8.lit <$> rows2))
567+ bs <- Rel8.optional (Rel8.values (Rel8.lit <$> rows2))
624− pure $ liftA2 (,) as bs
568+ pure $ liftA2 (,) as bs
626 case (rows1, rows2) of
570 case (rows1, rows2) of
627 ([], []) -> selected === [Nothing]
571 ([], []) -> selected === [Nothing]
@@ -633,6 +577,14 @@ testMaybeTableApplicative = databasePropertyTest "MaybeTable (<*>)" \transaction
633 genRows = forAll do
577 genRows = forAll do
634 Gen.list (Range.linear 0 10) $ liftA2 TestTable (Gen.text (Range.linear 0 10) Gen.unicode) (pure True)
578 Gen.list (Range.linear 0 10) $ liftA2 TestTable (Gen.text (Range.linear 0 10) Gen.unicode) (pure True)
581+ :: (MonadBaseControl IO m, MonadIO m)
582+ => Connection -> m a -> m a
583+rollingBack connection =
585+ (liftIO (run (sql "BEGIN") connection))
586+ (liftIO (run (sql "ROLLBACK") connection))
637genTestTable :: Gen (TestTable Result)
589genTestTable :: Gen (TestTable Result)
638genTestTable = do
590genTestTable = do
@@ -645,16 +597,17 @@ testUpdate :: IO TmpPostgres.DB -> TestTree
645testUpdate = databasePropertyTest "Can UPDATE TestTable" \transaction -> do
597testUpdate = databasePropertyTest "Can UPDATE TestTable" \transaction -> do
646 rows <- forAll $ Gen.map (Range.linear 0 5) $ liftA2 (,) genTestTable genTestTable
598 rows <- forAll $ Gen.map (Range.linear 0 5) $ liftA2 (,) genTestTable genTestTable
648− transaction do
600+ transaction \connection -> do
649− selected <- lift do
601+ liftIO $ Rel8.insert connection
650− statement () $ Rel8.insert Rel8.Insert
602+ Rel8.Insert
651 { into = testTableSchema
603 { into = testTableSchema
652 , rows = Rel8.values $ map Rel8.lit $ Map.keys rows
604 , rows = Rel8.values $ map Rel8.lit $ Map.keys rows
653 , onConflict = Rel8.DoNothing
605 , onConflict = Rel8.DoNothing
654 , returning = pure ()
606 , returning = pure ()
609+ liftIO $ Rel8.update connection
657− statement () $ Rel8.update Rel8.Update
610+ Rel8.Update
658 { target = testTableSchema
611 { target = testTableSchema
659 , from = pure ()
612 , from = pure ()
660 , set = \_ r ->
613 , set = \_ r ->
@@ -675,8 +628,8 @@ testUpdate = databasePropertyTest "Can UPDATE TestTable" \transaction -> do
675 , returning = pure ()
628 , returning = pure ()
678− statement () $ Rel8.select do
631+ selected <- liftIO $ Rel8.select connection do
679− Rel8.each testTableSchema
632+ Rel8.each testTableSchema
681 sort selected === sort (Map.elems rows)
634 sort selected === sort (Map.elems rows)
@@ -689,96 +642,30 @@ testDelete :: IO TmpPostgres.DB -> TestTree
689testDelete = databasePropertyTest "Can DELETE TestTable" \transaction -> do
642testDelete = databasePropertyTest "Can DELETE TestTable" \transaction -> do
690 rows <- forAll $ Gen.list (Range.linear 0 5) genTestTable
643 rows <- forAll $ Gen.list (Range.linear 0 5) genTestTable
692− transaction do
645+ transaction \connection -> do
693− (deleted, selected) <- lift do
646+ liftIO $ Rel8.insert connection
694− statement () $ Rel8.insert Rel8.Insert
647+ Rel8.Insert
695 { into = testTableSchema
648 { into = testTableSchema
696 , rows = Rel8.values $ map Rel8.lit rows
649 , rows = Rel8.values $ map Rel8.lit rows
697 , onConflict = Rel8.DoNothing
650 , onConflict = Rel8.DoNothing
698 , returning = pure ()
651 , returning = pure ()
655+ liftIO $ Rel8.delete connection
701− deleted <- statement () $ Rel8.delete Rel8.Delete
656+ Rel8.Delete
702 { from = testTableSchema
657 { from = testTableSchema
703 , using = pure ()
658 , using = pure ()
704 , deleteWhere = const testTableColumn2
659 , deleteWhere = const testTableColumn2
705 , returning = Rel8.Projection id
660 , returning = Rel8.Projection id
708− selected <- statement () $ Rel8.select do
663+ selected <- liftIO $ Rel8.select connection do
709− Rel8.each testTableSchema
664+ Rel8.each testTableSchema
711− pure (deleted, selected)
713 sort (deleted <> selected) === sort rows
666 sort (deleted <> selected) === sort rows
716−data UniqueTable f = UniqueTable
717− { uniqueTableKey :: Rel8.Column f Text
718− , uniqueTableValue :: Rel8.Column f Text
720− deriving stock Generic
721− deriving anyclass Rel8.Rel8able
724−deriving stock instance Eq (UniqueTable Result)
725−deriving stock instance Ord (UniqueTable Result)
726−deriving stock instance Show (UniqueTable Result)
729−uniqueTableSchema :: Rel8.TableSchema (UniqueTable Rel8.Name)
732− { name = "unique_table"
734− , columns = UniqueTable
735− { uniqueTableKey = "key"
736− , uniqueTableValue = "value"
741−genUniqueTable :: Gen (UniqueTable Result)
743− uniqueTableKey <- Gen.text (Range.linear 0 5) Gen.alphaNum
744− uniqueTableValue <- Gen.text (Range.linear 0 5) Gen.alphaNum
745− pure UniqueTable {..}
748−testUpsert :: IO TmpPostgres.DB -> TestTree
749−testUpsert = databasePropertyTest "Can UPSERT UniqueTable" \transaction -> do
750− as <- unique $ forAll $ Gen.list (Range.linear 0 20) genUniqueTable
751− bs <- unique $ forAll $ Gen.list (Range.linear 0 20) genUniqueTable
755− statement () $ Rel8.insert Rel8.Insert
756− { into = uniqueTableSchema
757− , rows = Rel8.values $ Rel8.lit <$> as
758− , onConflict = Rel8.DoNothing
759− , returning = pure ()
762− statement () $ Rel8.insert Rel8.Insert
763− { into = uniqueTableSchema
764− , rows = Rel8.values $ Rel8.lit <$> bs
765− , onConflict = Rel8.DoUpdate Rel8.Upsert
766− { index = uniqueTableKey
767− , set = \UniqueTable {uniqueTableValue} old -> old {uniqueTableValue}
768− , updateWhere = \_ _ -> Rel8.true
770− , returning = pure ()
773− statement () $ Rel8.select do
774− Rel8.each uniqueTableSchema
776− fromUniqueTables selected === fromUniqueTables bs <> fromUniqueTables as
778− unique = fmap (nubOrdOn uniqueTableKey)
779− fromUniqueTables = Map.fromList . map \(UniqueTable key value) -> (key, value)
782newtype HKNestedPair f = HKNestedPair { pairOne :: (TestTable f, TestTable f) }
669newtype HKNestedPair f = HKNestedPair { pairOne :: (TestTable f, TestTable f) }
783 deriving stock Generic
670 deriving stock Generic
784 deriving anyclass Rel8.Rel8able
671 deriving anyclass Rel8.Rel8able
@@ -792,10 +679,9 @@ testSelectNestedPairs :: IO TmpPostgres.DB -> TestTree
792testSelectNestedPairs = databasePropertyTest "Can SELECT nested pairs" \transaction -> do
679testSelectNestedPairs = databasePropertyTest "Can SELECT nested pairs" \transaction -> do
793 rows <- forAll $ Gen.list (Range.linear 0 10) $ HKNestedPair <$> liftA2 (,) genTestTable genTestTable
680 rows <- forAll $ Gen.list (Range.linear 0 10) $ HKNestedPair <$> liftA2 (,) genTestTable genTestTable
795− transaction do
682+ transaction \connection -> do
796− selected <- lift do
683+ selected <- liftIO $ Rel8.select connection do
797− statement () $ Rel8.select do
798− Rel8.values $ map Rel8.lit rows
684+ Rel8.values $ map Rel8.lit rows
800 sort selected === sort rows
686 sort selected === sort rows
@@ -804,20 +690,18 @@ testSelectArray :: IO TmpPostgres.DB -> TestTree
804testSelectArray = databasePropertyTest "Can SELECT Arrays (with aggregation)" \transaction -> do
690testSelectArray = databasePropertyTest "Can SELECT Arrays (with aggregation)" \transaction -> do
805 rows <- forAll $ Gen.list (Range.linear 1 10) Gen.bool
691 rows <- forAll $ Gen.list (Range.linear 1 10) Gen.bool
807− transaction do
693+ transaction \connection -> do
808− selected <- lift do
694+ selected <- liftIO $ Rel8.select connection do
809− statement () $ Rel8.select do
810− Rel8.many $ Rel8.values (map Rel8.lit rows)
695+ Rel8.many $ Rel8.values (map Rel8.lit rows)
812 selected === [foldMap pure rows]
697 selected === [foldMap pure rows]
814− selected' <- lift do
815− statement () $ Rel8.select do
699+ selected' <- liftIO $ Rel8.select connection $ do
816− a <- Rel8.catListTable =<< do
700+ a <- Rel8.catListTable =<< do
817− Rel8.many $ Rel8.values (map Rel8.lit rows)
701+ Rel8.many $ Rel8.values (map Rel8.lit rows)
818− b <- Rel8.catListTable =<< do
702+ b <- Rel8.catListTable =<< do
819− Rel8.many $ Rel8.values (map Rel8.lit rows)
703+ Rel8.many $ Rel8.values (map Rel8.lit rows)
820− pure (a, b)
704+ pure (a, b)
822 selected' === liftA2 (,) rows rows
706 selected' === liftA2 (,) rows rows
@@ -839,11 +723,10 @@ testNestedMaybeTable :: IO TmpPostgres.DB -> TestTree
839testNestedMaybeTable = databasePropertyTest "Can nest MaybeTable within other tables" \transaction -> do
723testNestedMaybeTable = databasePropertyTest "Can nest MaybeTable within other tables" \transaction -> do
840 let example = NestedMaybeTable { nmt1 = True, nmt2 = Just (TestTable "Hi" True) }
724 let example = NestedMaybeTable { nmt1 = True, nmt2 = Just (TestTable "Hi" True) }
842− transaction do
726+ transaction \connection -> do
844− statement () $ Rel8.select do
727+ selected <- liftIO $ Rel8.select connection do
845− x <- Rel8.values [Rel8.lit example]
728+ x <- Rel8.values [Rel8.lit example]
846− pure $ Rel8.maybeTable (Rel8.lit False) (\_ -> Rel8.lit True) (nmt2 x)
729+ pure $ Rel8.maybeTable (Rel8.lit False) (\_ -> Rel8.lit True) (nmt2 x)
848 selected === [True]
731 selected === [True]
@@ -851,12 +734,11 @@ testNestedMaybeTable = databasePropertyTest "Can nest MaybeTable within other ta
851testEvaluate :: IO TmpPostgres.DB -> TestTree
734testEvaluate :: IO TmpPostgres.DB -> TestTree
852testEvaluate = databasePropertyTest "evaluate has the evaluation order we expect" \transaction -> do
735testEvaluate = databasePropertyTest "evaluate has the evaluation order we expect" \transaction -> do
854− transaction do
737+ transaction \connection -> do
856− statement () $ Rel8.select do
738+ selected <- liftIO $ Rel8.select connection do
857− x <- Rel8.values (Rel8.lit <$> ['a', 'b', 'c'])
739+ x <- Rel8.values (Rel8.lit <$> ['a', 'b', 'c'])
858− y <- Rel8.evaluate (Rel8.nextval "test_seq")
740+ y <- Rel8.evaluate (Rel8.nextval "test_seq")
859− pure (x, (y, y))
741+ pure (x, (y, y))
861 normalize selected ===
743 normalize selected ===
862 [ ('a', (0, 0))
744 [ ('a', (0, 0))
@@ -864,12 +746,11 @@ testEvaluate = databasePropertyTest "evaluate has the evaluation order we expect
864 , ('c', (2, 2))
746 , ('c', (2, 2))
867− selected' <- lift do
868− statement () $ Rel8.select do
749+ selected' <- liftIO $ Rel8.select connection do
869− x <- Rel8.values (Rel8.lit <$> ['a', 'b', 'c'])
750+ x <- Rel8.values (Rel8.lit <$> ['a', 'b', 'c'])
870− y <- Rel8.values (Rel8.lit <$> ['d', 'e', 'f'])
751+ y <- Rel8.values (Rel8.lit <$> ['d', 'e', 'f'])
871− z <- Rel8.evaluate (Rel8.nextval "test_seq")
752+ z <- Rel8.evaluate (Rel8.nextval "test_seq")
872− pure ((x, y), (z, z))
753+ pure ((x, y), (z, z))
874 normalize selected' ===
755 normalize selected' ===
875 [ (('a', 'd'), (0, 0))
756 [ (('a', 'd'), (0, 0))
@@ -887,3 +768,13 @@ testEvaluate = databasePropertyTest "evaluate has the evaluation order we expect
887 normalize :: [(x, (Int64, Int64))] -> [(x, (Int64, Int64))]
768 normalize :: [(x, (Int64, Int64))] -> [(x, (Int64, Int64))]
888 normalize [] = []
769 normalize [] = []
889 normalize xs@((_, (i, _)) : _) = map (fmap (\(a, b) -> (a - i, b - i))) xs
770 normalize xs@((_, (i, _)) : _) = map (fmap (\(a, b) -> (a - i, b - i))) xs
773+ selected <- liftIO $ Rel8.select connection do
774+ x <- Rel8.values (Rel8.lit <$> ['a', 'b', 'c'])
775+ x <- Rel8.values (Rel8.lit <$> ['d', 'e', 'f'])
776+ y <- Rel8.evaluate (Rel8.nextval "test_seq")
779+ selected === [('a', 1, 1), ('b', 2, 2), ('c', 3, 3)]