Adding evm_chain_id, address and event_sig to data and topic indexes (#…

…12786) * Adding evm_chain_id, address and event_sig to data and topic indexes * Post review fixes * Post review fixes * Post review fixes * Post review fixes * Bumping migration script number --------- Co-authored-by: Domino Valdano <[email protected]>
smartcontractkit · Apr 16, 2024 · fbb705c · fbb705c
1 parent e523aa0
commit fbb705c
Show file tree

Hide file tree

Showing 2 changed files with 70 additions and 0 deletions.
diff --git a/.changeset/rich-jars-flow.md b/.changeset/rich-jars-flow.md
@@ -0,0 +1,5 @@
+---
+"chainlink": patch
+---
+
+Narrowing topic, data_word indexes by adding (evm_chain_id, address, event_sig) to the index definition #db_update
diff --git a/core/store/migrate/migrations/0233_log_poller_word_topic_indexes.sql b/core/store/migrate/migrations/0233_log_poller_word_topic_indexes.sql
@@ -0,0 +1,65 @@
+-- +goose Up
+
+drop index if exists evm.evm_logs_idx_data_word_one;
+drop index if exists evm.evm_logs_idx_data_word_two;
+drop index if exists evm.evm_logs_idx_data_word_three;
+drop index if exists evm.evm_logs_idx_data_word_four;
+drop index if exists evm.evm_logs_idx_topic_two;
+drop index if exists evm.evm_logs_idx_topic_three;
+drop index if exists evm.evm_logs_idx_topic_four;
+
+create index evm_logs_idx_data_word_one
+    on evm.logs (address, event_sig, evm_chain_id, "substring"(data, 1, 32));
+
+create index evm_logs_idx_data_word_two
+    on evm.logs (address, event_sig, evm_chain_id, "substring"(data, 33, 32));
+
+create index evm_logs_idx_data_word_three
+    on evm.logs (address, event_sig, evm_chain_id, "substring"(data, 65, 32));
+
+create index evm_logs_idx_data_word_four
+    on evm.logs (address, event_sig, evm_chain_id, "substring"(data, 97, 32));
+
+create index evm_logs_idx_data_word_five
+    on evm.logs (address, event_sig, evm_chain_id, "substring"(data, 129, 32));
+
+create index evm_logs_idx_topic_two
+    on evm.logs (address, event_sig, evm_chain_id, (topics[2]));
+
+create index evm_logs_idx_topic_three
+    on evm.logs (address, event_sig, evm_chain_id, (topics[3]));
+
+create index evm_logs_idx_topic_four
+    on evm.logs (address, event_sig, evm_chain_id, (topics[4]));
+
+-- +goose Down
+
+drop index if exists evm.evm_logs_idx_data_word_one;
+drop index if exists evm.evm_logs_idx_data_word_two;
+drop index if exists evm.evm_logs_idx_data_word_three;
+drop index if exists evm.evm_logs_idx_data_word_four;
+drop index if exists evm.evm_logs_idx_data_word_five;
+drop index if exists evm.evm_logs_idx_topic_two;
+drop index if exists evm.evm_logs_idx_topic_three;
+drop index if exists evm.evm_logs_idx_topic_four;
+
+create index evm_logs_idx_data_word_one
+    on evm.logs ("substring"(data, 1, 32));
+
+create index evm_logs_idx_data_word_two
+    on evm.logs ("substring"(data, 33, 32));
+
+create index evm_logs_idx_data_word_three
+    on evm.logs ("substring"(data, 65, 32));
+
+create index evm_logs_idx_data_word_four
+    on evm.logs ("substring"(data, 97, 32));
+
+create index evm_logs_idx_topic_two
+    on evm.logs ((topics[2]));
+
+create index evm_logs_idx_topic_three
+    on evm.logs ((topics[3]));
+
+create index evm_logs_idx_topic_four
+    on evm.logs ((topics[4]));