Enable value-level codecs

packages.dhall

@@ -46,7 +46,7 @@ in upstream
         , "validation"
         ]
       , repo = "https://github.com/jordanmartinez/purescript-postgresql-client.git"
-      , version = "updateTov0.14.1"
+      , version = "exposeUnsafeQuery"
       }
     with polyform =
         { dependencies =

spago.dhall

@@ -47,5 +47,5 @@ You can edit this file as you like.
   , "variant"
   ]
 , packages = ./packages.dhall
-, sources = [ "src/**/*.purs", "test/**/*.purs", "guide/src/**/*.purs" ]
+, sources = [ "src/**/*.purs" ]
 }

src/Selda/Lit.purs

@@ -11,8 +11,8 @@ import Selda.Expr (Expr(..), Literal(..), None(..))
 import Selda.Inner (Inner)
 import Selda.PG (litPG)
 import Selda.PG.Class (BackendPGClass)
-import Selda.SQLite3 (litSQLite3)
-import Selda.SQLite3.Class (BackendSQLite3Class)
+-- import Selda.SQLite3 (litSQLite3)
+-- import Selda.SQLite3.Class (BackendSQLite3Class)
 import Simple.JSON (class WriteForeign)
 import Unsafe.Coerce (unsafeCoerce)
 
@@ -48,8 +48,8 @@ else instance litMaybe ∷ Lit b a ⇒ Lit b (Maybe a) where
 else instance ilitPG ∷ ToSQLValue a ⇒ Lit BackendPGClass a where
   litImpl = litPG
 
-else instance ilitSQLite3 ∷ WriteForeign a ⇒ Lit BackendSQLite3Class a where
-  litImpl = litSQLite3
+-- else instance ilitSQLite3 ∷ WriteForeign a ⇒ Lit BackendSQLite3Class a where
+--   litImpl = litSQLite3
 
 else instance litInner ∷ Lit s a ⇒ Lit (Inner s) a where
   litImpl a = case (litImpl a ∷ Col s a) of Col e → Col e

src/Selda/PG/Aff.purs

@@ -1,10 +1,14 @@
 module Selda.PG.Aff
   ( insert_
-  , insert
-  , insert1
+  , insert_'
+  -- , insert
+  -- , insert1
   , insert1_
+  , insert1_'
   , query
+  , query'
   , query1
+  , query1'
   , PGSelda
   , deleteFrom
   , update
@@ -17,16 +21,20 @@ import Control.Monad.Reader (ReaderT)
 import Data.Array (head) as Array
 import Data.Either (Either)
 import Data.Maybe (Maybe)
-import Database.PostgreSQL (class FromSQLRow, Connection, PGError)
+import Database.PostgreSQL (class FromSQLRow, class ToSQLRow, Connection, PGError, fromSQLRow)
 import Effect.Aff (Aff)
+import Foreign (Foreign)
+import Heterogeneous.Folding (class HFoldl)
 import Selda (Col, Table)
 import Selda.Col (class GetCols)
 import Selda.PG.Class (class InsertRecordIntoTableReturning, BackendPGClass)
 import Selda.PG.Class as Selda.PG
 import Selda.Query (limit)
 import Selda.Query.Class (class GenericInsert, runSelda)
 import Selda.Query.Type (FullQuery(..))
-import Selda.Query.Utils (class ColsToPGHandler, class TableToColsWithoutAlias)
+import Selda.Query.Utils (class ColsToPGHandler, class TableToColsWithoutAlias, RecordToArrayForeign, RecordToTuple(..))
+import Selda.Table.Constraint (class CanInsertColumnsIntoTable)
+import Type.Proxy (Proxy(..))
 
 type PGSelda = ExceptT PGError (ReaderT Connection Aff)
 
@@ -35,34 +43,90 @@ type B = BackendPGClass
 insert_
   ∷ ∀ t r
   . GenericInsert BackendPGClass PGSelda t r
+  ⇒ HFoldl
+      (RecordToArrayForeign BackendPGClass)
+      (Array Foreign)
+      { | r }
+      (Array Foreign)
   ⇒ Connection → Table t → Array { | r } → Aff (Either PGError Unit)
-insert_ conn t r = runSelda conn $ Selda.PG.insert_ t r
+insert_ conn t r =
+  runSelda conn $ Selda.PG.insert_ t r
+
+insert_'
+  ∷ ∀ t r
+  . GenericInsert BackendPGClass PGSelda t r
+  ⇒ Connection
+  → Table t
+  → ({ | r } → Array Foreign)
+  → Array { | r }
+  → Aff (Either PGError Unit)
+insert_' conn t decodeRow r =
+  runSelda conn $ Selda.PG.insert_' t decodeRow r
 
 insert1_
   ∷ ∀ r t
   . GenericInsert BackendPGClass PGSelda t r
-  ⇒ Connection → Table t → { | r } → Aff (Either PGError Unit)
+  ⇒ HFoldl
+      (RecordToArrayForeign BackendPGClass)
+      (Array Foreign)
+      { | r }
+      (Array Foreign)
+  ⇒ Connection
+  → Table t
+  → { | r }
+  → Aff (Either PGError Unit)
 insert1_ conn t r = runSelda conn $ Selda.PG.insert1_ t r
 
-insert
-  ∷ ∀ r t tr
-  . InsertRecordIntoTableReturning r t tr
-  ⇒ Connection → Table t → Array { | r } → Aff (Either PGError (Array { | tr }))
-insert conn t r = runSelda conn $ Selda.PG.insert t r
+insert1_'
+  ∷ ∀ r t
+  . GenericInsert BackendPGClass PGSelda t r
+  ⇒ Connection
+  → Table t
+  → ({ | r } → Array Foreign)
+  → { | r }
+  → Aff (Either PGError Unit)
+insert1_' conn t encode r = runSelda conn $ Selda.PG.insert1_' t encode r
+
+-- insert
+--   ∷ ∀ r t ret rTuple tr trTuple s
+--   . InsertRecordIntoTableReturning r t ret
+--   ⇒ ToSQLRow rTuple
+--   ⇒ FromSQLRow trTuple
+--   ⇒ HFoldl RecordToTuple Unit { | r } rTuple
+--   ⇒ ColsToPGHandler s tr trTuple ret
+--   ⇒ TableToColsWithoutAlias s t tr
+--   ⇒ Connection → Table t → Array { | r } → Aff (Either PGError (Array { | ret }))
+-- insert conn t r = runSelda conn $ Selda.PG.insert t r
 
-insert1
-  ∷ ∀ r t tr
-  . InsertRecordIntoTableReturning r t tr
-  ⇒ Connection → Table t → { | r } → Aff (Either PGError { | tr })
-insert1 conn t r = runSelda conn $ Selda.PG.insert1 t r
+-- insert1
+--   ∷ ∀ r t ret rTuple tr trTuple s
+--   . InsertRecordIntoTableReturning r t ret
+--   ⇒ ToSQLRow rTuple
+--   ⇒ FromSQLRow trTuple
+--   ⇒ HFoldl RecordToTuple Unit { | r } rTuple
+--   ⇒ ColsToPGHandler s tr trTuple ret
+--   ⇒ TableToColsWithoutAlias s t tr
+--   ⇒ Connection → Table t → { | r } → Aff (Either PGError { | ret })
+-- insert1 conn t r = runSelda conn $ Selda.PG.insert1 t r
 
 query
   ∷ ∀ o i tup
   . ColsToPGHandler B i tup o
   ⇒ GetCols i
   ⇒ FromSQLRow tup
-  ⇒ Connection → FullQuery B (Record i) → Aff (Either PGError (Array { | o }))
-query conn q = runSelda conn $ Selda.PG.query q
+  ⇒ Connection
+  → FullQuery B (Record i)
+  → Aff (Either PGError (Array { | o }))
+query conn = runSelda conn <<< Selda.PG.query
+
+query'
+  ∷ ∀ o i
+  . GetCols i
+  ⇒ Connection
+  → FullQuery B { | i }
+  → (Array Foreign -> Either String { | o })
+  → Aff (Either PGError (Array { | o }))
+query' conn q decodeRow = runSelda conn $ Selda.PG.query' q decodeRow
 
 query1
   ∷ ∀ o i tup
@@ -72,7 +136,18 @@ query1
   ⇒ Connection
   → FullQuery B (Record i)
   → Aff (Either PGError (Maybe { | o }))
-query1 conn (FullQuery q) = query conn (FullQuery (limit 1 >>= \_ → q)) <#> map Array.head
+query1 conn (FullQuery q) =
+  query conn (FullQuery (limit 1 >>= \_ → q)) <#> map Array.head
+
+query1'
+  ∷ ∀ o i
+  . GetCols i
+  ⇒ Connection
+  → FullQuery B (Record i)
+  → (Array Foreign -> Either String { | o })
+  → Aff (Either PGError (Maybe { | o }))
+query1' conn (FullQuery q) decodeRow =
+  query' conn (FullQuery (limit 1 >>= \_ → q)) decodeRow <#> map Array.head
 
 deleteFrom
   ∷ ∀ r r'