{-# language BlockArguments #-} {-# language DataKinds #-} {-# language DisambiguateRecordFields #-} {-# language FlexibleContexts #-} {-# language NamedFieldPuns #-} {-# language RankNTypes #-} {-# language TypeFamilies #-} {-# language ViewPatterns #-} {-# options_ghc -Wno-deprecations #-} module Rel8.Table.Opaleye ( aggregator , attributes , binaryspec , distinctspec , exprs , exprsWithNames , table , tableFields , unpackspec , valuesspec , view , castTable ) where -- base import Data.Functor.Const ( Const( Const ), getConst ) import Data.List.NonEmpty ( NonEmpty ) import Prelude hiding ( undefined ) -- opaleye import qualified Opaleye.Internal.Aggregate as Opaleye import qualified Opaleye.Internal.Binary as Opaleye import qualified Opaleye.Internal.Distinct as Opaleye import qualified Opaleye.Internal.HaskellDB.PrimQuery as Opaleye import qualified Opaleye.Internal.PackMap as Opaleye import qualified Opaleye.Internal.Unpackspec as Opaleye import qualified Opaleye.Internal.Values as Opaleye import qualified Opaleye.Internal.Table as Opaleye -- profunctors import Data.Profunctor ( dimap, lmap ) -- rel8 import Rel8.Aggregate ( Aggregate( Aggregate ), Aggregates ) import Rel8.Expr ( Expr ) import Rel8.Expr.Opaleye ( fromPrimExpr, toPrimExpr , traversePrimExpr , fromColumn, toColumn , scastExpr ) import Rel8.Schema.HTable ( htabulateA, hfield, htraverse, hspecs, htabulate ) import Rel8.Schema.Name ( Name( Name ), Selects, ppColumn ) import Rel8.Schema.Spec ( Spec(..) ) import Rel8.Schema.Table ( TableSchema(..), ppTable ) import Rel8.Table ( Table, fromColumns, toColumns ) import Rel8.Table.Undefined ( undefined ) -- semigroupoids import Data.Functor.Apply ( WrappedApplicative(..) ) aggregator :: Aggregates aggregates exprs => Opaleye.Aggregator aggregates exprs aggregator = Opaleye.Aggregator $ Opaleye.PackMap $ \f aggregates -> fmap fromColumns $ unwrapApplicative $ htabulateA $ \field -> WrapApplicative $ case hfield (toColumns aggregates) field of Aggregate (Opaleye.Aggregator (Opaleye.PackMap inner)) -> inner f () attributes :: Selects names exprs => TableSchema names -> exprs attributes schema@TableSchema {columns} = fromColumns $ htabulate $ \field -> case hfield (toColumns columns) field of Name column -> fromPrimExpr $ Opaleye.ConstExpr $ Opaleye.OtherLit $ show (ppTable schema) <> "." <> show (ppColumn column) binaryspec :: Table Expr a => Opaleye.Binaryspec a a binaryspec = Opaleye.Binaryspec $ Opaleye.PackMap $ \f (as, bs) -> fmap fromColumns $ unwrapApplicative $ htabulateA $ \field -> WrapApplicative $ case (hfield (toColumns as) field, hfield (toColumns bs) field) of (a, b) -> fromPrimExpr <$> f (toPrimExpr a, toPrimExpr b) distinctspec :: Table Expr a => Opaleye.Distinctspec a a distinctspec = Opaleye.Distinctspec $ Opaleye.Aggregator $ Opaleye.PackMap $ \f -> fmap fromColumns . unwrapApplicative . htraverse (\a -> WrapApplicative $ fromPrimExpr <$> f (Nothing, toPrimExpr a)) . toColumns exprs :: Table Expr a => a -> NonEmpty Opaleye.PrimExpr exprs (toColumns -> as) = getConst $ htabulateA $ \field -> case hfield as field of expr -> Const (pure (toPrimExpr expr)) exprsWithNames :: Selects names exprs => names -> exprs -> NonEmpty (String, Opaleye.PrimExpr) exprsWithNames names as = getConst $ htabulateA $ \field -> case (hfield (toColumns names) field, hfield (toColumns as) field) of (Name name, expr) -> Const (pure (name, toPrimExpr expr)) table :: Selects names exprs => TableSchema names -> Opaleye.Table exprs exprs table (TableSchema name schema columns) = case schema of Nothing -> Opaleye.Table name (tableFields columns) Just schemaName -> Opaleye.TableWithSchema schemaName name (tableFields columns) tableFields :: Selects names exprs => names -> Opaleye.TableFields exprs exprs tableFields (toColumns -> names) = dimap toColumns fromColumns $ unwrapApplicative $ htabulateA $ \field -> WrapApplicative $ case hfield names field of name -> lmap (`hfield` field) (go name) where go :: Name a -> Opaleye.TableFields (Expr a) (Expr a) go (Name name) = dimap (toColumn . toPrimExpr) (fromPrimExpr . fromColumn) $ Opaleye.requiredTableField name unpackspec :: Table Expr a => Opaleye.Unpackspec a a unpackspec = Opaleye.Unpackspec $ Opaleye.PackMap $ \f -> fmap fromColumns . unwrapApplicative . htraverse (WrapApplicative . traversePrimExpr f) . toColumns {-# INLINABLE unpackspec #-} valuesspec :: Table Expr a => Opaleye.Valuesspec a a valuesspec = Opaleye.ValuesspecSafe (toPackMap undefined) unpackspec view :: Selects names exprs => names -> exprs view columns = fromColumns $ htabulate $ \field -> case hfield (toColumns columns) field of Name column -> fromPrimExpr $ Opaleye.BaseTableAttrExpr column toPackMap :: Table Expr a => a -> Opaleye.PackMap Opaleye.PrimExpr Opaleye.PrimExpr () a toPackMap as = Opaleye.PackMap $ \f () -> fmap fromColumns $ unwrapApplicative . htraverse (WrapApplicative . traversePrimExpr f) $ toColumns as -- | Transform a table by adding 'CAST' to all columns. This is most useful for -- finalising a SELECT or RETURNING statement, guaranteed that the output -- matches what is encoded in each columns TypeInformation. castTable :: Table Expr a => a -> a castTable (toColumns -> as) = fromColumns $ htabulate \field -> case hfield hspecs field of Spec {info} -> case hfield as field of expr -> scastExpr info expr