add all insert + variant + start adding queries

Author: Cmdv

cardano-chain-gen/test/Test/Cardano/Db/Mock/Validate.hs

@@ -204,7 +204,7 @@ assertCurrentEpoch :: DBSyncEnv -> Word64 -> IO ()
 assertCurrentEpoch env expected =
   assertEqBackoff env q (Just expected) defaultDelays "Unexpected epoch stake counts"
   where
-    q = queryCurrentEpochNo
+    q = queryBlocksForCurrentEpochNo
 
 assertAddrValues ::
   (EraCertState era, Core.EraTxOut era) =>

cardano-db-sync/src/Cardano/DbSync/Era/Universal/Insert/Other.hs

@@ -187,7 +187,7 @@ insertScript ::
   Generic.TxScript ->
   ReaderT SqlBackend m DB.ScriptId
 insertScript tracer txId script = do
-  mScriptId <- DB.queryScript $ Generic.txScriptHash script
+  mScriptId <- DB.queryScriptWithId $ Generic.txScriptHash script
   case mScriptId of
     Just scriptId -> pure scriptId
     Nothing -> do

cardano-db-tool/src/Cardano/DbTool/Report/Balance.hs

@@ -114,7 +114,7 @@ queryStakeAddressBalance txOutTableType address = do
 
     queryRewardsSum :: MonadIO m => StakeAddressId -> ReaderT SqlBackend m Ada
     queryRewardsSum saId = do
-      currentEpoch <- queryLatestEpochNo
+      currentEpoch <- queryLatestEpochNoFromBlock
       res <- select $ do
         rwd <- from $ table @Reward
         where_ (rwd ^. RewardAddrId ==. val saId)

cardano-db/cardano-db.cabal

@@ -30,6 +30,7 @@ library
                         -Wunused-packages
 
   exposed-modules:      Cardano.Db
+                        Cardano.Db.Schema.Core
                         Cardano.Db.Schema.Variants
 
   other-modules:        Cardano.Db.Error
@@ -52,7 +53,6 @@ library
                         Cardano.Db.Operations.TxOut.TxOutQuery
                         Cardano.Db.PGConfig
                         Cardano.Db.Run
-                        Cardano.Db.Schema.Core
                         Cardano.Db.Schema.Core.Base
                         Cardano.Db.Schema.Core.EpochAndProtocol
                         Cardano.Db.Schema.Core.GovernanceAndVoting
@@ -61,6 +61,7 @@ library
                         Cardano.Db.Schema.Core.Pool
                         Cardano.Db.Schema.Core.StakeDeligation
                         Cardano.Db.Schema.Ids
+                        Cardano.Db.Schema.MinIds
                         Cardano.Db.Schema.Orphans
                         Cardano.Db.Schema.Types
                         Cardano.Db.Schema.Variants.TxOutAddress
@@ -69,6 +70,7 @@ library
                         Cardano.Db.Schema.Variants.TxOutUtxoHdAddress
                         Cardano.Db.Statement
                         Cardano.Db.Statement.Function.Core
+                        Cardano.Db.Statement.Function.Delete
                         Cardano.Db.Statement.Function.Query
                         Cardano.Db.Statement.Function.Insert
                         Cardano.Db.Statement.Base
@@ -77,8 +79,10 @@ library
                         Cardano.Db.Statement.MultiAsset
                         Cardano.Db.Statement.OffChain
                         Cardano.Db.Statement.Pool
+                        Cardano.Db.Statement.Rollback
                         Cardano.Db.Statement.StakeDeligation
                         Cardano.Db.Statement.Types
+                        Cardano.Db.Statement.Variants.TxOut
                         Cardano.Db.Types
 
   build-depends:        aeson

cardano-db/src/Cardano/Db.hs

@@ -13,19 +13,10 @@ import Cardano.Db.Git.Version (gitRev)
 import Cardano.Db.Migration as X
 import Cardano.Db.Migration.Version as X
 import Cardano.Db.Operations.AlterTable as X
-import Cardano.Db.Operations.Delete as X
-import Cardano.Db.Operations.Insert as X
-import Cardano.Db.Operations.Other.ConsumedTxOut as X
-import Cardano.Db.Operations.Other.JsonbQuery as X
-import Cardano.Db.Operations.Other.MinId as X
-import Cardano.Db.Operations.Query as X
-import Cardano.Db.Operations.QueryHelper as X
-import Cardano.Db.Operations.TxOut.TxOutDelete as X
-import Cardano.Db.Operations.TxOut.TxOutInsert as X
-import Cardano.Db.Operations.TxOut.TxOutQuery as X
-import Cardano.Db.Operations.Types as X
 import Cardano.Db.PGConfig as X
 import Cardano.Db.Run as X
 import Cardano.Db.Schema.Core as X
 import Cardano.Db.Schema.Types as X
+import Cardano.Db.Schema.Variants as X
+import Cardano.Db.Statement as X
 import Cardano.Db.Types as X