@@ -46,13 +46,11 @@ import Control.Exception.Lifted
46import Control.Monad.Base
46import Control.Monad.Base
47import Control.Monad.Trans.Control
47import Control.Monad.Trans.Control
48import Data.ByteString
48import Data.ByteString
50import Data.Monoid
49import Data.Monoid
51import Generics.SOP
50import Generics.SOP
53import qualified Database.PostgreSQL.LibPQ as LibPQ
52import qualified Database.PostgreSQL.LibPQ as LibPQ
55−import Squeal.PostgreSQL.Definition
56import Squeal.PostgreSQL.Manipulation
54import Squeal.PostgreSQL.Manipulation
57import Squeal.PostgreSQL.Prettyprint
55import Squeal.PostgreSQL.Prettyprint
58import Squeal.PostgreSQL.PQ
56import Squeal.PostgreSQL.PQ
@@ -97,10 +95,11 @@ transactionallySchema
97 -> PQ schema0 schema1 io x
95 -> PQ schema0 schema1 io x
98 -> PQ schema0 schema1 io x
96 -> PQ schema0 schema1 io x
99transactionallySchema mode u = PQ $ \ conn -> mask $ \ restore -> do
97transactionallySchema mode u = PQ $ \ conn -> mask $ \ restore -> do
98+ _ <- liftBase . LibPQ.exec (unK conn) $
100− liftBase (LibPQ.exec (unK conn) ("BEGIN" <+> renderTransactionMode mode <> ";"))
99+ "BEGIN" <+> renderTransactionMode mode <> ";"
101 x <- restore (unPQ u conn)
100 x <- restore (unPQ u conn)
102 `onException` (liftBase (LibPQ.exec (unK conn) "ROLLBACK"))
101 `onException` (liftBase (LibPQ.exec (unK conn) "ROLLBACK"))
103− _ <- liftBase (LibPQ.exec (unK conn) "COMMIT")
102+ _ <- liftBase $ LibPQ.exec (unK conn) "COMMIT"
106-- | Run a schema changing computation `transactionallySchema_` in `DefaultMode`.
105-- | Run a schema changing computation `transactionallySchema_` in `DefaultMode`.