chore: modify some migrations

Author: gfyrag

internal/storage/bucket/migrations/17-moves-fill-transaction-id/up.sql

@@ -22,7 +22,7 @@ do $$
 
 		perform pg_notify('migrations-{{ .Schema }}', 'init: ' || _max);
 
-		for i in 0.._max-1 by _batch_size loop
+		for i in 1.._max by _batch_size loop
 			with _rows as (
 				select *
 				from transactions_ids

internal/storage/bucket/migrations/28-fix-pcv-missing-asset/up.sql

@@ -27,7 +27,7 @@ do $$
 		) data
 		group by transactions_seq;
 
-		create index moves_view_idx on moves_view(transactions_seq);
+		create index moves_view_idx on moves_view(row_number) include (transactions_seq, volumes);
 		-- speed up hash join when updating rows later
 		alter table moves_view add foreign key(transactions_seq) references transactions(seq);
 

internal/storage/bucket/migrations/29-fix-invalid-metadata-on-reverts/up.sql

@@ -17,7 +17,7 @@ do $$
 			from logs
 			where type = 'REVERTED_TRANSACTION'
 		)
-		select reversed.ledger, reversed.reversedTransactionID, reversed.revertedTransactionID, reversed.revertedAt
+		select row_number() over (order by transactions.seq) as row_number, reversed.ledger, reversed.reversedTransactionID, reversed.revertedTransactionID, reversed.revertedAt
 		from transactions
 		join reversed on
 			reversed.reversedTransactionID = transactions.id and
@@ -37,9 +37,7 @@ do $$
 			with data as (
 				select ledger, reversedTransactionID, revertedTransactionID, revertedAt
 				from txs_view
-				order by ledger, reversedTransactionID, revertedTransactionID
-				offset _offset
-				limit _batch_size
+				where row_number >= _offset and row_number < _offset + _batch_size
 			)
 			update transactions
 			set

internal/storage/bucket/migrations/31-fix-transaction-updated-at/up.sql

@@ -8,7 +8,7 @@ do $$
 		drop table if exists txs_view;
 
 		create table txs_view as
-		select *
+		select row_number() over (order by transactions.seq) as row_number, *
 		from transactions
 		where updated_at is null;
 
@@ -26,9 +26,7 @@ do $$
 			with data as (
 				select *
 				from txs_view
-				order by seq
-				offset _offset
-				limit _batch_size
+				where row_number >= _offset and row_number < _offset+_batch_size
 			)
 			update transactions
 			set updated_at = transactions.inserted_at

internal/storage/bucket/migrations/32-fix-log-data-for-reverted-transactions/up.sql

@@ -16,7 +16,8 @@ do $$
 			from logs
 			where type = 'REVERTED_TRANSACTION' and data->>'revertedTransactionID' is not null
 		)
-		select reversed.id as log_id, transactions.*
+		select row_number() over (order by transactions.seq) as row_number,
+		       reversed.id as log_id, transactions.*
 		from transactions
 		join reversed on
 			reversed.revertedTransactionID = transactions.id and
@@ -34,9 +35,7 @@ do $$
 			with data as (
 				select *
 				from txs_view
-				order by ledger, log_id, id
-				offset _offset
-				limit _batch_size
+				where row_number >= _offset and row_number < _offset + _batch_size
 			)
 			update logs
 			set data = data || jsonb_build_object('revertedTransaction', jsonb_build_object(

internal/storage/bucket/migrations/33-fix-invalid-date-format/up.sql

@@ -16,7 +16,7 @@ do $$
 			from logs
 			where type = 'REVERTED_TRANSACTION' and data->>'revertedTransactionID' is not null
 		)
-		select reversed.id as log_id, transactions.*
+		select row_number() over (order by transactions.seq) as row_number, reversed.id as log_id, transactions.*
 		from transactions
 		join reversed on
 			reversed.revertedTransactionID = transactions.id and
@@ -34,9 +34,7 @@ do $$
 			with data as (
 				select *
 				from txs_view
-				order by ledger, log_id, id
-				offset _offset
-				limit _batch_size
+				where row_number >= _offset and row_number < _offset + _batch_size
 			)
 			update logs
 			set data = data || jsonb_build_object('revertedTransaction', jsonb_build_object(