mirror of
https://github.com/hasura/graphql-engine.git
synced 2024-12-17 20:41:49 +03:00
e0c0043e76
PR-URL: https://github.com/hasura/graphql-engine-mono/pull/9284 GitOrigin-RevId: 2f2cf2ad01900a54e4bdb970205ac0ef313c7e00
98 lines
3.3 KiB
Haskell
98 lines
3.3 KiB
Haskell
-- | Postgres Translate Update
|
|
--
|
|
-- Translates IR update to Postgres-specific SQL UPDATE statements.
|
|
module Hasura.Backends.Postgres.Translate.Update
|
|
( mkUpdateCTE,
|
|
UpdateCTE (..),
|
|
)
|
|
where
|
|
|
|
import Data.HashMap.Strict qualified as HashMap
|
|
import Hasura.Backends.Postgres.SQL.DML qualified as S
|
|
import Hasura.Backends.Postgres.SQL.Types
|
|
import Hasura.Backends.Postgres.Translate.BoolExp
|
|
import Hasura.Backends.Postgres.Translate.Insert
|
|
import Hasura.Backends.Postgres.Translate.Returning
|
|
import Hasura.Backends.Postgres.Types.Update
|
|
import Hasura.Prelude
|
|
import Hasura.RQL.IR.BoolExp
|
|
import Hasura.RQL.IR.Update
|
|
import Hasura.RQL.IR.Update.Batch
|
|
import Hasura.RQL.Types.Backend
|
|
import Hasura.RQL.Types.BackendType
|
|
import Hasura.RQL.Types.Column
|
|
import Hasura.SQL.Types
|
|
|
|
data UpdateCTE
|
|
= -- | Used for /update_table/ and /update_table_by_pk/.
|
|
Update S.TopLevelCTE
|
|
| -- | Used for /update_table_many/.
|
|
MultiUpdate [S.TopLevelCTE]
|
|
deriving (Show)
|
|
|
|
-- | Create the update CTE.
|
|
mkUpdateCTE ::
|
|
forall pgKind.
|
|
(Backend ('Postgres pgKind)) =>
|
|
AnnotatedUpdate ('Postgres pgKind) ->
|
|
UpdateCTE
|
|
mkUpdateCTE (AnnotatedUpdateG tn permFltr chk updateVariant _ columnsInfo _tCase) =
|
|
case updateVariant of
|
|
SingleBatch update ->
|
|
Update $ translateUpdate update
|
|
MultipleBatches updates ->
|
|
MultiUpdate $ translateUpdate <$> updates
|
|
where
|
|
mkWhere :: AnnBoolExp ('Postgres pgKind) S.SQLExp -> Maybe S.WhereFrag
|
|
mkWhere =
|
|
Just
|
|
. S.WhereFrag
|
|
. S.simplifyBoolExp
|
|
. toSQLBoolExp (S.QualTable tn)
|
|
. andAnnBoolExps permFltr
|
|
|
|
checkConstraint :: Maybe S.RetExp
|
|
checkConstraint =
|
|
Just
|
|
$ S.RetExp
|
|
[ S.selectStar,
|
|
asCheckErrorExtractor
|
|
. insertCheckConstraint
|
|
. toSQLBoolExp (S.QualTable tn)
|
|
$ chk
|
|
]
|
|
|
|
translateUpdate :: UpdateBatch ('Postgres pgKind) UpdateOpExpression S.SQLExp -> S.TopLevelCTE
|
|
translateUpdate UpdateBatch {..} =
|
|
S.CTEUpdate
|
|
S.SQLUpdate
|
|
{ upTable = tn,
|
|
upSet =
|
|
S.SetExp $ map (expandOperator columnsInfo) (HashMap.toList _ubOperations),
|
|
upFrom = Nothing,
|
|
upWhere = mkWhere _ubWhere,
|
|
upRet = checkConstraint
|
|
}
|
|
|
|
expandOperator :: [ColumnInfo ('Postgres pgKind)] -> (PGCol, UpdateOpExpression S.SQLExp) -> S.SetExpItem
|
|
expandOperator infos (column, op) = S.SetExpItem
|
|
$ (column,)
|
|
$ case op of
|
|
UpdateSet e -> e
|
|
UpdateInc e -> S.mkSQLOpExp S.incOp identifier (asNum e)
|
|
UpdateAppend e -> S.mkSQLOpExp S.jsonbConcatOp identifier (asJSON e)
|
|
UpdatePrepend e -> S.mkSQLOpExp S.jsonbConcatOp (asJSON e) identifier
|
|
UpdateDeleteKey e -> S.mkSQLOpExp S.jsonbDeleteOp identifier (asText e)
|
|
UpdateDeleteElem e -> S.mkSQLOpExp S.jsonbDeleteOp identifier (asInt e)
|
|
UpdateDeleteAtPath a -> S.mkSQLOpExp S.jsonbDeleteAtPathOp identifier (asArray a)
|
|
where
|
|
identifier = S.SEIdentifier $ toIdentifier column
|
|
asInt e = S.SETyAnn e S.intTypeAnn
|
|
asText e = S.SETyAnn e S.textTypeAnn
|
|
asJSON e = S.SETyAnn e S.jsonbTypeAnn
|
|
asArray a = S.SETyAnn (S.SEArray a) S.textArrTypeAnn
|
|
asNum e = S.SETyAnn e
|
|
$ case find (\info -> ciColumn info == column) infos <&> ciType of
|
|
Just (ColumnScalar s) -> S.mkTypeAnn $ CollectableTypeScalar s
|
|
_ -> S.numericTypeAnn
|