[#45] Add function for inserting issues into DB

Resolves #45
kowainik · Jun 18, 2019 · 3b481ba · 3b481ba
1 parent 41f7748
commit 3b481ba
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 2 deletions.
diff --git a/src/IW/Core/Issue.hs b/src/IW/Core/Issue.hs
@@ -13,5 +13,5 @@ data Issue = Issue
     , issueUrl    :: Text
     , issueRepoId :: Int
     } deriving stock (Generic, Show, Eq)
-      deriving anyclass (FromRow)
+      deriving anyclass (FromRow, ToRow)
       deriving (FromJSON, ToJSON) 
diff --git a/src/IW/Db/Issue.hs b/src/IW/Db/Issue.hs
@@ -10,7 +10,11 @@ module IW.Db.Issue
 
 import IW.App (WithError)
 import IW.Core.Issue (Issue)
-import IW.Db.Functions (WithDb, asSingleRow, query, queryRaw)
+import IW.Db.Functions (WithDb, asSingleRow, executeMany, query, queryRaw)
+
+-----------
+-- QUERY --
+-----------
 
 getIssues :: (WithDb env m, WithError m) => m [Issue]
 getIssues = queryRaw [sql|
@@ -33,3 +37,13 @@ getIssuesByLabel label = query [sql|
     JOIN labels ON labels.id = issues_labels.label_id 
     WHERE labels.label_name = ?
 |] (Only label)
+
+------------
+-- INSERT --
+------------
+
+insertIssues :: (WithDb env m, WithError m) => [Issue] -> m ()
+insertIssues = executeMany [sql|
+    INSERT INTO issues (issue_number, issue_title, issue_body, issue_url, repo_id) 
+    VALUES (?,?,?,?,?)
+|]