From 026ebbfaae7d114d42152fafbaad8780a84137ea Mon Sep 17 00:00:00 2001 From: Denis Tereshkin Date: Wed, 24 Aug 2022 12:32:51 +0700 Subject: [PATCH] Some debug --- src/ATrade/MDS/Database.hs | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/ATrade/MDS/Database.hs b/src/ATrade/MDS/Database.hs index 8bd06b6..e6a68d5 100644 --- a/src/ATrade/MDS/Database.hs +++ b/src/ATrade/MDS/Database.hs @@ -84,8 +84,11 @@ getData db tickerId interval@(TimeInterval start end) (Timeframe tfSec) = do getDataConduit :: (MonadIO m) => MdsHandle -> TickerId -> TimeInterval -> Timeframe -> ConduitT () Bar m () getDataConduit db tickerId (TimeInterval start end) (Timeframe tfSec) = do + liftIO $ debugM "DB" "Preparing query" stmt <- liftIO $ prepare db "SELECT timestamp, timeframe, open, high, low, close, volume FROM bars WHERE ticker LIKE ? AND timeframe == ? AND timestamp >= ? AND timestamp <= ? ORDER BY timestamp ASC;" + liftIO $ debugM "DB" "Executing query" _ <- liftIO $ execute stmt [(toSql. T.unpack) tickerId, toSql tfSec, (toSql . utcTimeToPOSIXSeconds) start, (toSql . utcTimeToPOSIXSeconds) end] + liftIO $ debugM "DB" "Query executed" whileJust_ (liftIO $ fetchRow stmt) $ \row -> case barFromResult tickerId row of Just bar -> yield bar Nothing -> return ()