blockworks-foundation
/
BankingStageErrorsTrackingSidecar
mirror of https://github.com/blockworks-foundation/BankingStageErrorsTrackingSidecar.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

partition accounts_map_transaction_latest table

This commit is contained in:
GroovieGermanikus 2024-01-13 14:07:38 +01:00
parent abbf805726
commit 743f175f26
No known key found for this signature in database
GPG Key ID: 5B6EB831A5CD2015
1 changed files with 20 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
migration.sql
View File

@ -126,11 +126,26 @@ CLUSTER banking_stage_results_2.transactions using transactions_pkey;
CLUSTER banking_stage_results_2.accounts using accounts_pkey;
CREATE TABLE banking_stage_results_2.accounts_map_transaction_latest(
acc_id BIGINT PRIMARY KEY,
-- sorted: oldest to latest, max 1000
tx_ids BIGINT[]
);
CREATE TABLE banking_stage_results_2.accounts_map_transaction_latest_parted(
acc_id BIGINT PRIMARY KEY,
tx_ids BIGINT[]
) PARTITION BY HASH (acc_id);
DO $$
DECLARE part_no integer;
DECLARE num_parts integer := 4;
BEGIN
for part_no in 0..num_parts-1 loop
EXECUTE format(
'
CREATE TABLE banking_stage_results_2.accounts_map_transaction_latest_part%s
PARTITION OF banking_stage_results_2.accounts_map_transaction_latest_parted
FOR VALUES WITH (MODULUS %s, REMAINDER %s)
WITH (FILLFACTOR=80)
', part_no, num_parts, part_no);
end loop;
END; $$;
ALTER TABLE banking_stage_results_2.accounts_map_transaction_latest_parted RENAME TO accounts_map_transaction_latest;
CREATE OR REPLACE FUNCTION array_dedup_append(base bigint[], append bigint[], n_limit int)
RETURNS bigint[]