nikita-volkov/hasql
1
1
Fork 0
mirror of https://github.com/nikita-volkov/hasql.git synced 2024-11-22 01:52:45 +03:00
Code Issues Projects Releases Wiki Activity

Remove debugging

Browse Source
This commit is contained in:
Nikita Volkov 2024-04-21 12:26:28 +03:00
parent eac7e7ccb7
commit e76af7c559
1 changed files with 1 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
library/Hasql/Pipeline/Core.hs
View File

@ -14,29 +14,20 @@ import Hasql.IO qualified as IO
import Hasql.Prelude
import Hasql.PreparedStatementRegistry qualified as PreparedStatementRegistry
import Hasql.Statement qualified as Statement
import System.IO (BufferMode (NoBuffering), hSetBuffering, stdout)
run :: Pipeline a -> Connection.Connection -> IO (Either QueryError a)
run (Pipeline send) (Connection.Connection pqConnectionRef integerDatetimes registry) = do
hSetBuffering stdout NoBuffering
run (Pipeline send) (Connection.Connection pqConnectionRef integerDatetimes registry) =
withMVar pqConnectionRef \pqConnection -> do
putStrLn "enterPipelineMode"
runCommandFailing pqConnection $ Pq.enterPipelineMode pqConnection
putStrLn "send"
sendResult <- send pqConnection registry integerDatetimes
case sendResult of
Left err -> do
pure (Left err)
Right recv -> do
putStrLn "pipelineSync"
runCommandFailing pqConnection $ Pq.pipelineSync pqConnection
putStrLn "recv"
recvResult <- recv
putStrLn "pipelineSync"
handleEither =<< Decoders.Results.run (Decoders.Results.single Decoders.Result.pipelineSync) pqConnection integerDatetimes
putStrLn "exitPipelineMode"
runCommandFailing pqConnection $ Pq.exitPipelineMode pqConnection
putStrLn "return"
pure recvResult
where
runCommandFailing :: Pq.Connection -> IO Bool -> IO ()