module Main.Statements where

import Rebase.Prelude
import Hasql.Statement
import qualified Hasql.Encoders as A
import qualified Hasql.Decoders as B


countPGType :: Statement () Int
countPGType =
  Statement sql encoder decoder True
  where
    sql =
      "select count(*) from pg_type"
    encoder =
      A.unit
    decoder =
      B.singleRow (B.column (fmap fromIntegral B.int8))
      
slectOIDAndTypeName :: Statement () [(Int64, Text)]
slectOIDAndTypeName =
  Statement sql encoder decoder True
  where
    sql =
      "select oid, typname from pg_type"
    encoder =
      A.unit
    decoder =
      B.rowList rowDecoder
      where
        rowDecoder =
          (,) <$> B.column B.int8 <*> B.column B.text