consolidate

cerc-io · Sep 20, 2023 · 245e6d0 · 245e6d0
1 parent 402d279
commit 245e6d0
Show file tree

Hide file tree

Showing 23 changed files with 272 additions and 511 deletions.
diff --git a/Makefile b/Makefile
@@ -77,7 +77,7 @@ migrate: $(GOOSE) checkdbvars
 ## Apply all the migrations used to generate a UML diagram (containing FKs)
 .PHONY: migrate_for_uml
 migrate_for_uml: $(GOOSE) checkdbvars
-	$(GOOSE) -dir db/migrations/uml_support postgres "$(CONNECT_STRING)" up
+	$(GOOSE) -dir db/migrations postgres "$(CONNECT_STRING)" up-to 00018
 
 ## Apply migrations to be ran before a batch processing
 .PHONY: migrate_pre_batch_set

diff --git a/db/migrations/00018_create_foreign_keys.sql b/db/migrations/00018_create_foreign_keys.sql
@@ -0,0 +1,105 @@
+-- +goose Up
+ALTER TABLE eth.header_cids
+ADD CONSTRAINT header_cids_ipld_blocks_fkey
+FOREIGN KEY (cid, block_number)
+REFERENCES ipld.blocks (key, block_number);
+
+ALTER TABLE eth.uncle_cids
+ADD CONSTRAINT uncle_cids_ipld_blocks_fkey
+FOREIGN KEY (cid, block_number)
+REFERENCES ipld.blocks (key, block_number);
+
+ALTER TABLE eth.uncle_cids
+ADD CONSTRAINT uncle_cids_header_cids_fkey
+FOREIGN KEY (header_id, block_number)
+REFERENCES eth.header_cids (block_hash, block_number);
+
+ALTER TABLE eth.transaction_cids
+ADD CONSTRAINT transaction_cids_ipld_blocks_fkey
+FOREIGN KEY (cid, block_number)
+REFERENCES ipld.blocks (key, block_number);
+
+ALTER TABLE eth.transaction_cids
+ADD CONSTRAINT transaction_cids_header_cids_fkey
+FOREIGN KEY (header_id, block_number)
+REFERENCES eth.header_cids (block_hash, block_number);
+
+ALTER TABLE eth.receipt_cids
+ADD CONSTRAINT receipt_cids_ipld_blocks_fkey
+FOREIGN KEY (cid, block_number)
+REFERENCES ipld.blocks (key, block_number);
+
+ALTER TABLE eth.receipt_cids
+ADD CONSTRAINT receipt_cids_transaction_cids_fkey
+FOREIGN KEY (tx_id, header_id, block_number)
+REFERENCES eth.transaction_cids (tx_hash, header_id, block_number);
+
+ALTER TABLE eth.state_cids
+ADD CONSTRAINT state_cids_ipld_blocks_fkey
+FOREIGN KEY (cid, block_number)
+REFERENCES ipld.blocks (key, block_number);
+
+ALTER TABLE eth.state_cids
+ADD CONSTRAINT state_cids_header_cids_fkey
+FOREIGN KEY (header_id, block_number)
+REFERENCES eth.header_cids (block_hash, block_number);
+
+ALTER TABLE eth.storage_cids
+ADD CONSTRAINT storage_cids_ipld_blocks_fkey
+FOREIGN KEY (cid, block_number)
+REFERENCES ipld.blocks (key, block_number);
+
+ALTER TABLE eth.storage_cids
+ADD CONSTRAINT storage_cids_state_cids_fkey
+FOREIGN KEY (state_leaf_key, header_id, block_number)
+REFERENCES eth.state_cids (state_leaf_key, header_id, block_number);
+
+ALTER TABLE eth.log_cids
+ADD CONSTRAINT log_cids_ipld_blocks_fkey
+FOREIGN KEY (cid, block_number)
+REFERENCES ipld.blocks (key, block_number);
+
+ALTER TABLE eth.log_cids
+ADD CONSTRAINT log_cids_receipt_cids_fkey
+FOREIGN KEY (rct_id, header_id, block_number)
+REFERENCES eth.receipt_cids (tx_id, header_id, block_number);
+
+-- +goose Down
+ALTER TABLE eth.log_cids
+DROP CONSTRAINT log_cids_receipt_cids_fkey;
+
+ALTER TABLE eth.log_cids
+DROP CONSTRAINT log_cids_ipld_blocks_fkey;
+
+ALTER TABLE eth.storage_cids
+DROP CONSTRAINT storage_cids_state_cids_fkey;
+
+ALTER TABLE eth.storage_cids
+DROP CONSTRAINT storage_cids_ipld_blocks_fkey;
+
+ALTER TABLE eth.state_cids
+DROP CONSTRAINT state_cids_header_cids_fkey;
+
+ALTER TABLE eth.state_cids
+DROP CONSTRAINT state_cids_ipld_blocks_fkey;
+
+ALTER TABLE eth.receipt_cids
+DROP CONSTRAINT receipt_cids_transaction_cids_fkey;
+
+ALTER TABLE eth.receipt_cids
+DROP CONSTRAINT receipt_cids_ipld_blocks_fkey;
+
+ALTER TABLE eth.transaction_cids
+DROP CONSTRAINT transaction_cids_header_cids_fkey;
+
+ALTER TABLE eth.transaction_cids
+DROP CONSTRAINT transaction_cids_ipld_blocks_fkey;
+
+ALTER TABLE eth.uncle_cids
+DROP CONSTRAINT uncle_cids_header_cids_fkey;
+
+ALTER TABLE eth.uncle_cids
+DROP CONSTRAINT uncle_cids_ipld_blocks_fkey;
+
+ALTER TABLE eth.header_cids
+DROP CONSTRAINT header_cids_ipld_blocks_fkey;
diff --git a/db/migrations/00019_drop_foreign_keys.sql b/db/migrations/00019_drop_foreign_keys.sql
@@ -0,0 +1,105 @@
+-- +goose Up
+ALTER TABLE eth.log_cids
+DROP CONSTRAINT log_cids_receipt_cids_fkey;
+
+ALTER TABLE eth.log_cids
+DROP CONSTRAINT log_cids_ipld_blocks_fkey;
+
+ALTER TABLE eth.storage_cids
+DROP CONSTRAINT storage_cids_state_cids_fkey;
+
+ALTER TABLE eth.storage_cids
+DROP CONSTRAINT storage_cids_ipld_blocks_fkey;
+
+ALTER TABLE eth.state_cids
+DROP CONSTRAINT state_cids_header_cids_fkey;
+
+ALTER TABLE eth.state_cids
+DROP CONSTRAINT state_cids_ipld_blocks_fkey;
+
+ALTER TABLE eth.receipt_cids
+DROP CONSTRAINT receipt_cids_transaction_cids_fkey;
+
+ALTER TABLE eth.receipt_cids
+DROP CONSTRAINT receipt_cids_ipld_blocks_fkey;
+
+ALTER TABLE eth.transaction_cids
+DROP CONSTRAINT transaction_cids_header_cids_fkey;
+
+ALTER TABLE eth.transaction_cids
+DROP CONSTRAINT transaction_cids_ipld_blocks_fkey;
+
+ALTER TABLE eth.uncle_cids
+DROP CONSTRAINT uncle_cids_header_cids_fkey;
+
+ALTER TABLE eth.uncle_cids
+DROP CONSTRAINT uncle_cids_ipld_blocks_fkey;
+
+ALTER TABLE eth.header_cids
+DROP CONSTRAINT header_cids_ipld_blocks_fkey;
+
+-- +goose Down
+ALTER TABLE eth.header_cids
+ADD CONSTRAINT header_cids_ipld_blocks_fkey
+FOREIGN KEY (cid, block_number)
+REFERENCES ipld.blocks (key, block_number);
+
+ALTER TABLE eth.uncle_cids
+ADD CONSTRAINT uncle_cids_ipld_blocks_fkey
+FOREIGN KEY (cid, block_number)
+REFERENCES ipld.blocks (key, block_number);
+
+ALTER TABLE eth.uncle_cids
+ADD CONSTRAINT uncle_cids_header_cids_fkey
+FOREIGN KEY (header_id, block_number)
+REFERENCES eth.header_cids (block_hash, block_number);
+
+ALTER TABLE eth.transaction_cids
+ADD CONSTRAINT transaction_cids_ipld_blocks_fkey
+FOREIGN KEY (cid, block_number)
+REFERENCES ipld.blocks (key, block_number);
+
+ALTER TABLE eth.transaction_cids
+ADD CONSTRAINT transaction_cids_header_cids_fkey
+FOREIGN KEY (header_id, block_number)
+REFERENCES eth.header_cids (block_hash, block_number);
+
+ALTER TABLE eth.receipt_cids
+ADD CONSTRAINT receipt_cids_ipld_blocks_fkey
+FOREIGN KEY (cid, block_number)
+REFERENCES ipld.blocks (key, block_number);
+
+ALTER TABLE eth.receipt_cids
+ADD CONSTRAINT receipt_cids_transaction_cids_fkey
+FOREIGN KEY (tx_id, header_id, block_number)
+REFERENCES eth.transaction_cids (tx_hash, header_id, block_number);
+
+ALTER TABLE eth.state_cids
+ADD CONSTRAINT state_cids_ipld_blocks_fkey
+FOREIGN KEY (cid, block_number)
+REFERENCES ipld.blocks (key, block_number);
+
+ALTER TABLE eth.state_cids
+ADD CONSTRAINT state_cids_header_cids_fkey
+FOREIGN KEY (header_id, block_number)
+REFERENCES eth.header_cids (block_hash, block_number);
+
+ALTER TABLE eth.storage_cids
+ADD CONSTRAINT storage_cids_ipld_blocks_fkey
+FOREIGN KEY (cid, block_number)
+REFERENCES ipld.blocks (key, block_number);
+
+ALTER TABLE eth.storage_cids
+ADD CONSTRAINT storage_cids_state_cids_fkey
+FOREIGN KEY (state_leaf_key, header_id, block_number)
+REFERENCES eth.state_cids (state_leaf_key, header_id, block_number);
+
+ALTER TABLE eth.log_cids
+ADD CONSTRAINT log_cids_ipld_blocks_fkey
+FOREIGN KEY (cid, block_number)
+REFERENCES ipld.blocks (key, block_number);
+
+ALTER TABLE eth.log_cids
+ADD CONSTRAINT log_cids_receipt_cids_fkey
+FOREIGN KEY (rct_id, header_id, block_number)
+REFERENCES eth.receipt_cids (tx_id, header_id, block_number);
diff --git a/...grations/00018_convert_to_hypertables.sql → ...grations/00020_convert_to_hypertables.sql b/...grations/00018_convert_to_hypertables.sql → ...grations/00020_convert_to_hypertables.sql
diff --git a/db/migrations/uml_support/00001_create_ipfs_blocks_table.sql b/db/migrations/uml_support/00001_create_ipfs_blocks_table.sql
diff --git a/db/migrations/uml_support/00002_create_nodes_table.sql b/db/migrations/uml_support/00002_create_nodes_table.sql
diff --git a/db/migrations/uml_support/00003_create_eth_schema.sql b/db/migrations/uml_support/00003_create_eth_schema.sql
diff --git a/db/migrations/uml_support/00004_create_eth_header_cids_table.sql b/db/migrations/uml_support/00004_create_eth_header_cids_table.sql
diff --git a/db/migrations/uml_support/00005_create_eth_uncle_cids_table.sql b/db/migrations/uml_support/00005_create_eth_uncle_cids_table.sql
diff --git a/db/migrations/uml_support/00006_create_eth_transaction_cids_table.sql b/db/migrations/uml_support/00006_create_eth_transaction_cids_table.sql
diff --git a/db/migrations/uml_support/00007_create_eth_receipt_cids_table.sql b/db/migrations/uml_support/00007_create_eth_receipt_cids_table.sql
diff --git a/db/migrations/uml_support/00008_create_eth_state_cids_table.sql b/db/migrations/uml_support/00008_create_eth_state_cids_table.sql
diff --git a/db/migrations/uml_support/00009_create_eth_storage_cids_table.sql b/db/migrations/uml_support/00009_create_eth_storage_cids_table.sql
diff --git a/db/migrations/uml_support/00010_create_eth_log_cids_table.sql b/db/migrations/uml_support/00010_create_eth_log_cids_table.sql