Merge pull request IntersectMBO#1203 from input-output-hk/erikd/misc

Consolidate a number of individual PRs

Author: erikd

Readme.md

@@ -72,6 +72,7 @@ possible solutions.
 
 * [BuildingRunning][BuildingRunning]: Building and running the db-sync node.
 * [Docker][Docker]: Instruction for docker-compose, and building the images using nix.
+* [ERD][ERD]: The entity relationship diagram.
 * [Example SQL queries][ExampleQueries]: Some example SQL and Haskell/Esqueleto queries.
 * [PoolOfflineData][PoolOfflineData]: Explanation of how stake pool offline data is retried.
 * [Schema Documentation][Schema Documentation]: The database schema documentation.
@@ -83,6 +84,7 @@ possible solutions.
 [BuildingRunning]: doc/building-running.md
 [DB Schema]: https://hydra.iohk.io/job/Cardano/cardano-db-sync/native.haskellPackages.cardano-db.checks.test-db.x86_64-linux/latest/download/1
 [Docker]: doc/docker.md
+[ERD]: doc/ERG>png
 [ExampleQueries]: doc/interesting-queries.md
 [PostgresView]: https://www.postgresql.org/docs/current/sql-createview.html
 [PoolOfflineData]: doc/pool-offline-data.md

cardano-db-sync/app/cardano-db-sync.hs

@@ -80,7 +80,7 @@ pLedgerStateDir :: Parser LedgerStateDir
 pLedgerStateDir =
   LedgerStateDir <$> Opt.strOption
     (  Opt.long "state-dir"
-    <> Opt.help "The directory for persistung ledger state."
+    <> Opt.help "The directory for persisting ledger state."
     <> Opt.completer (Opt.bashCompleter "directory")
     <> Opt.metavar "FILEPATH"
     )

cardano-db-tool/app/cardano-db-tool.hs

@@ -188,7 +188,7 @@ pLedgerStateDir :: Parser LedgerStateDir
 pLedgerStateDir =
   LedgerStateDir <$> Opt.strOption
     (  Opt.long "state-dir"
-    <> Opt.help "The directory for persistung ledger state."
+    <> Opt.help "The directory for persisting ledger state."
     <> Opt.completer (Opt.bashCompleter "directory")
     <> Opt.metavar "FILEPATH"
     )

doc/ERD.png

@@ -546,6 +546,69 @@ select redeemer.tx_id as tx_id, redeemer.unit_mem, redeemer.unit_steps, redeemer
  asset1mu7h997yyvzrppdwjzhpex6u7khrucspxvjjuw | \x69b30e43bc5401bb34d0b12bd06cd9b537f33065aa49df7e8652739d | \x4c51           |     2 |     1 | 21000000000000 | 2021-02-03 20:22:23
 
 ```
+
+### Get blocks with 0 transactions and the pools that forged it
+```sql
+select distinct on(block.hash) block.hash as block_hash , epoch_no, tx_count, pool_hash.hash_raw as pool_hash,
+                               pool_update.pledge, pool_update.active_epoch_no, pool_metadata_ref.url, pool_offline_data.ticker_name  
+  from block join slot_leader on block.slot_leader_id = slot_leader.id
+    join pool_hash on slot_leader.pool_hash_id = pool_hash.id 
+    join pool_update on pool_update.hash_id = pool_hash.id 
+    left join pool_metadata_ref on pool_update.meta_id = pool_metadata_ref.id 
+    left join pool_offline_data on pool_offline_data.pmr_id = pool_metadata_ref.id  
+  where tx_count = 0 and epoch_no > 150  
+  order by block.hash, pool_update.active_epoch_no desc;
+
+
+                             block_hash                             | epoch_no | tx_count |                         pool_hash                          |     pledge      | active_epoch_no |                               url                                | ticker_name 
+--------------------------------------------------------------------+----------+----------+------------------------------------------------------------+-----------------+-----------------+------------------------------------------------------------------+-------------
+ \x0000f4b44d1484d7280f087c1df94f068a02e23570e8ed9eb5c0dd980d4c46c1 |      165 |        0 | \xe402f5894b8a7073f198bb0710d6294f2ac354ede2577b5ce15159a4 |     50000000000 |             137 | https://www.canadastakes.ca/metadata/can1-testnet-metadata.json  | 
+ \x0001715520d185accd550c7b6c0811a2589e778e6408ffcd75b0f83f4f45c2c0 |      153 |        0 | \xacfd479740bde8289885694e69e3494f7dcbcfdca540aead48c5d653 |  64000000000000 |             100 |                                                                  | 
+ \x00044646beb7d24dce8cd74408c76b9816453a451fc030c42cc9961be55932d9 |      163 |        0 | \x1e2191487bed3de4bf440d5ff80bdae31d7f22798d3a93444302acb3 |  64000000000000 |             100 |                                                                  | 
+ \x000732a2f62e289930c2779559a975566395dcf0cf32130f3852a6e031d13d61 |      154 |        0 | \xd9dc497e633c2f1c665467e1ed7a93e4f8541bfbabe1cc31818fb20f |   1000000000000 |             131 | https://www.uniquestaking.com/pool/uniq9/1ecf39ad-4f3c-4043      | 
+```
 ---
 
+### Query all delegators and some basic info
+```sql
+ SELECT sa.view AS address,
+    nh.view AS delegated_now_poolid,
+    d.active_epoch_no delegated_now_epoch,
+    oh.view AS delegated_before_poolid,
+    od.active_epoch_no AS delegated_before_epoch,
+    d.addr_id,
+    br."time" AS stake_key_registered
+   FROM ( SELECT max(delegation.id) AS id
+           FROM delegation
+          GROUP BY delegation.addr_id) a
+     LEFT JOIN delegation d ON d.id = a.id
+     LEFT JOIN tx txn ON txn.id = d.tx_id
+     LEFT JOIN block bn ON bn.id = txn.block_id
+     LEFT JOIN stake_address sa ON sa.id = d.addr_id
+     LEFT JOIN stake_deregistration de ON de.addr_id = d.addr_id AND de.id = (( SELECT max(stake_deregistration.id) AS max
+           FROM stake_deregistration
+          WHERE stake_deregistration.addr_id = d.addr_id))
+     LEFT JOIN stake_registration re ON re.addr_id = d.addr_id AND re.id = (( SELECT max(stake_registration.id) AS max
+           FROM stake_registration
+          WHERE stake_registration.addr_id = d.addr_id))
+     LEFT JOIN delegation od ON od.addr_id = d.addr_id AND od.id = (( SELECT max(delegation.id) AS max
+           FROM delegation
+          WHERE delegation.addr_id = d.addr_id AND NOT delegation.pool_hash_id = d.pool_hash_id))
+     LEFT JOIN tx txo ON txo.id = od.tx_id
+     LEFT JOIN block bo ON bo.id = txo.block_id
+     LEFT JOIN pool_hash nh ON nh.id = d.pool_hash_id
+     LEFT JOIN pool_hash oh ON oh.id = od.pool_hash_id
+     LEFT JOIN tx txr ON txr.id = re.tx_id
+     LEFT JOIN block br ON br.id = txr.block_id
+  WHERE (de.tx_id < re.tx_id OR de.* IS NULL);
+
+
+                           address                           |                   delegated_now_poolid                   | delegated_now_epoch |                 delegated_before_poolid                  | delegated_before_epoch | addr_id | stake_key_registered
+-------------------------------------------------------------+----------------------------------------------------------+---------------------+----------------------------------------------------------+------------------------+---------+----------------------
+ stake1u9ylzsgxaa6xctf4juup682ar3juj85n8tx3hthnljg47zctvm3rc | pool1pu5jlj4q9w9jlxeu370a3c9myx47md5j5m2str0naunn2q3lkdy |                 210 |                                                          |                        |       1 | 2020-07-29 22:41:31
+ stake1u8mt5gqclkq0swmvzx9lvq4jgwsnx9yh030yrxwqwllu0mq2m0l4n | pool1qqqqzyqf8mlm70883zht60n4q6uqxg4a8x266sewv8ad2grkztl |                 317 | pool1qqqz9vlskay2gv3ec5pyck8c2tq9ty7dpfm60x8shvapguhcemt |                    211 |       3 | 2020-08-06 20:00:11
+```
+---
+
+
 [Query.hs]: https://github.com/input-output-hk/cardano-db-sync/blob/master/cardano-db/src/Cardano/Db/Query.hs