|
|
@ -3,7 +3,7 @@ DO $$ |
|
|
|
total_count integer := 0; |
|
|
|
total_count integer := 0; |
|
|
|
completed_count integer := 0; |
|
|
|
completed_count integer := 0; |
|
|
|
remaining_count integer := 0; |
|
|
|
remaining_count integer := 0; |
|
|
|
batch_size integer := 10; |
|
|
|
batch_size integer := 50; |
|
|
|
iterator integer := batch_size; |
|
|
|
iterator integer := batch_size; |
|
|
|
updated_count integer; |
|
|
|
updated_count integer; |
|
|
|
deleted_count integer; |
|
|
|
deleted_count integer; |
|
|
@ -31,11 +31,13 @@ DO $$ |
|
|
|
); |
|
|
|
); |
|
|
|
|
|
|
|
|
|
|
|
INSERT INTO transactions_dropped_replaced |
|
|
|
INSERT INTO transactions_dropped_replaced |
|
|
|
SELECT transactions.nonce, |
|
|
|
SELECT t1.nonce, |
|
|
|
transactions.from_address_hash, |
|
|
|
t1.from_address_hash, |
|
|
|
ROW_NUMBER() OVER () |
|
|
|
ROW_NUMBER() OVER () |
|
|
|
FROM transactions |
|
|
|
FROM transactions t1 |
|
|
|
WHERE transactions.block_hash IS NULL; |
|
|
|
INNER JOIN transactions t2 |
|
|
|
|
|
|
|
ON t1.from_address_hash = t2.from_address_hash AND t1.nonce = t2.nonce AND t2.block_hash IS NOT NULL |
|
|
|
|
|
|
|
WHERE t1.block_hash IS NULL; |
|
|
|
|
|
|
|
|
|
|
|
temp_end_time := clock_timestamp(); |
|
|
|
temp_end_time := clock_timestamp(); |
|
|
|
temp_elapsed_time := temp_end_time - temp_start_time; |
|
|
|
temp_elapsed_time := temp_end_time - temp_start_time; |
|
|
|