mirror of
https://github.com/hasura/graphql-engine.git
synced 2024-12-18 04:51:35 +03:00
f194c47156
PR-URL: https://github.com/hasura/graphql-engine-mono/pull/8287 Co-authored-by: Karthikeyan Chinnakonda <15602904+codingkarthik@users.noreply.github.com> GitOrigin-RevId: d4ae6a517da63f2f43567dc16fda135b3cd1d7e6
60 lines
2.0 KiB
Haskell
60 lines
2.0 KiB
Haskell
{-# LANGUAGE QuasiQuotes #-}
|
|
|
|
-- | Postgres DDL Source Version
|
|
--
|
|
-- Deals with catalog version - used by 'Hasura.Backends.Postgres.DDL.Source'.
|
|
module Hasura.Backends.Postgres.DDL.Source.Version
|
|
( SourceCatalogVersion,
|
|
initialSourceCatalogVersion,
|
|
latestSourceCatalogVersion,
|
|
previousSourceCatalogVersions,
|
|
getSourceCatalogVersion,
|
|
setSourceCatalogVersion,
|
|
)
|
|
where
|
|
|
|
import Data.Text qualified as T
|
|
import Database.PG.Query qualified as PG
|
|
import Hasura.Backends.Postgres.Connection
|
|
import Hasura.Base.Error
|
|
import Hasura.Prelude
|
|
import Hasura.SQL.Backend (BackendType (Postgres), PostgresKind)
|
|
import Hasura.Server.Migrate.Version qualified as Version
|
|
|
|
type SourceCatalogVersion (pgKind :: PostgresKind) = Version.SourceCatalogVersion ('Postgres pgKind)
|
|
|
|
initialSourceCatalogVersion :: SourceCatalogVersion pgKind
|
|
initialSourceCatalogVersion = Version.SourceCatalogVersion 0
|
|
|
|
latestSourceCatalogVersion :: SourceCatalogVersion pgKind
|
|
latestSourceCatalogVersion = Version.SourceCatalogVersion 4
|
|
|
|
previousSourceCatalogVersions :: [SourceCatalogVersion pgKind]
|
|
previousSourceCatalogVersions = [initialSourceCatalogVersion .. pred latestSourceCatalogVersion]
|
|
|
|
setSourceCatalogVersion :: MonadTx m => m ()
|
|
setSourceCatalogVersion =
|
|
liftTx $
|
|
PG.unitQE
|
|
defaultTxErrorHandler
|
|
[PG.sql|
|
|
INSERT INTO hdb_catalog.hdb_source_catalog_version(version, upgraded_on)
|
|
VALUES ($1, NOW())
|
|
ON CONFLICT ((version IS NOT NULL))
|
|
DO UPDATE SET version = $1, upgraded_on = NOW()
|
|
|]
|
|
(Identity (tshow latestSourceCatalogVersion))
|
|
False
|
|
|
|
getSourceCatalogVersion :: MonadTx m => m (SourceCatalogVersion postgres)
|
|
getSourceCatalogVersion = do
|
|
versionText <-
|
|
liftTx $
|
|
runIdentity . PG.getRow
|
|
<$> PG.withQE
|
|
defaultTxErrorHandler
|
|
[PG.sql| SELECT version FROM hdb_catalog.hdb_source_catalog_version |]
|
|
()
|
|
False
|
|
readEither (T.unpack versionText) `onLeft` (throw500 . (("Invalid source catalog version in the metadata: " <>) . T.pack))
|