change pkey, add indexes

pinax-network · Dec 18, 2023 · eebd2f1 · eebd2f1
1 parent db597c1
commit eebd2f1
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 4 deletions.
diff --git a/antelope.trxstats/schema.sql b/antelope.trxstats/schema.sql
@@ -1,6 +1,7 @@
 CREATE TABLE
     IF NOT EXISTS transactions (
-        "trx_id" VARCHAR(64) PRIMARY KEY,
+        "id" VARCHAR(16) PRIMARY KEY,
+        "trx_id" VARCHAR(64),
         "block_num" BIGINT,
         "block_time" TIMESTAMP,
         "status" INT,
@@ -9,4 +10,14 @@ CREATE TABLE
         "net_usage" INT,
         "cpu_usage_micro_seconds" INT,
         "net_usage_words" INT
-    );
+    );
+
+-- Add indexes
+CREATE INDEX
+    idx_cpu_usage ON transactions ("cpu_usage_micro_seconds");
+
+CREATE INDEX idx_net_usage_words ON transactions ("net_usage_words");
+
+CREATE INDEX idx_action_count ON transactions ("action_count");
+
+CREATE INDEX idx_trx_id ON transactions ("trx_id");
diff --git a/antelope.trxstats/src/lib.rs b/antelope.trxstats/src/lib.rs
@@ -34,9 +34,10 @@ fn map_trxs(block: Block) -> Result<Transactions, Error> {
 fn db_out(trxs: Transactions) -> Result<DatabaseChanges, substreams::errors::Error> {
     // Initialize changes container
     let mut tables = DatabaseChangeTables::new();
-    trxs.transactions.into_iter().for_each(|trx| {
+    trxs.transactions.into_iter().enumerate().for_each(|(i, trx)| {
         tables
-            .create_row("transactions", &trx.trx_id)
+            .create_row("transactions", format!("{}-{}", trx.block_num, i))
+            .set("trx_id", trx.trx_id)
             .set("block_time", trx.block_time.unwrap())
             .set("block_num", trx.block_num)
             .set("action_count", trx.action_count)