Merge pull request #7 from anttih/fix-query

Fix `query` to lift ForeignErrors to Aff errors

Author: epost

MODULE.md

@@ -24,13 +24,27 @@ data DB :: !
 ```
 
 
+#### `ConnectionString`
+
+``` purescript
+type ConnectionString = String
+```
+
+
 #### `ConnectionInfo`
 
 ``` purescript
 type ConnectionInfo = { password :: String, user :: String, port :: Number, db :: String, host :: String }
 ```
 
 
+#### `mkConnectionString`
+
+``` purescript
+mkConnectionString :: ConnectionInfo -> ConnectionString
+```
+
+
 #### `connect`
 
 ``` purescript
@@ -58,7 +72,7 @@ Runs a query and returns nothing
 #### `query`
 
 ``` purescript
-query :: forall eff a p. (IsForeign a) => Query a -> [SqlValue] -> Client -> Aff (db :: DB | eff) [F a]
+query :: forall eff a p. (IsForeign a) => Query a -> [SqlValue] -> Client -> Aff (db :: DB | eff) [a]
 ```
 
 Runs a query and returns all results.

src/Database/Postgres.purs

@@ -70,10 +70,10 @@ execute_ (Query sql) client = void $ runQuery_ sql client
 -- | Runs a query and returns all results.
 query :: forall eff a p
   . (IsForeign a)
-  => Query a -> [SqlValue] -> Client -> Aff (db :: DB | eff) [F a]
+  => Query a -> [SqlValue] -> Client -> Aff (db :: DB | eff) [a]
 query (Query sql) params client = do
   rows <- runQuery sql params client
-  pure $ read <$> rows
+  either liftError pure (sequence $ read <$> rows)
 
 -- | Just like `query` but does not make any param replacement
 query_ :: forall eff a. (IsForeign a) => Query a -> Client -> Aff (db :: DB | eff) [a]