From e05f5ee751c0877295cfea83eae3b369e4e22386 Mon Sep 17 00:00:00 2001 From: Mononaut Date: Fri, 15 Nov 2024 22:31:30 +0000 Subject: [PATCH] Add missing liquid db indexes --- backend/src/api/database-migration.ts | 21 ++++++++++++++++++++- 1 file changed, 20 insertions(+), 1 deletion(-) diff --git a/backend/src/api/database-migration.ts b/backend/src/api/database-migration.ts index 0c17ab9f1..9ae34aa0a 100644 --- a/backend/src/api/database-migration.ts +++ b/backend/src/api/database-migration.ts @@ -7,7 +7,7 @@ import cpfpRepository from '../repositories/CpfpRepository'; import { RowDataPacket } from 'mysql2'; class DatabaseMigration { - private static currentVersion = 91; + private static currentVersion = 92; private queryTimeout = 3600_000; private statisticsAddedIndexed = false; private uniqueLogs: string[] = []; @@ -775,6 +775,25 @@ class DatabaseMigration { await this.$executeQuery('ALTER TABLE `blocks_audits` ADD INDEX `time` (`time`)'); await this.updateToSchemaVersion(91); } + + if (databaseSchemaVersion < 92 && config.MEMPOOL.NETWORK === 'liquid') { + // elements_pegs + await this.$executeQuery('ALTER TABLE `elements_pegs` ADD INDEX `block` (`block`)'); + await this.$executeQuery('ALTER TABLE `elements_pegs` ADD INDEX `datetime` (`datetime`)'); + await this.$executeQuery('ALTER TABLE `elements_pegs` ADD INDEX `amount` (`amount`)'); + await this.$executeQuery('ALTER TABLE `elements_pegs` ADD INDEX `bitcoinaddress` (`bitcoinaddress`)'); + await this.$executeQuery('ALTER TABLE `elements_pegs` ADD INDEX `bitcointxid` (`bitcointxid`)'); + + // federation_txos + await this.$executeQuery('ALTER TABLE `federation_txos` ADD INDEX `unspent` (`unspent`)'); + await this.$executeQuery('ALTER TABLE `federation_txos` ADD INDEX `lastblockupdate` (`lastblockupdate`)'); + await this.$executeQuery('ALTER TABLE `federation_txos` ADD INDEX `blocktime` (`blocktime`)'); + await this.$executeQuery('ALTER TABLE `federation_txos` ADD INDEX `emergencyKey` (`emergencyKey`)'); + await this.$executeQuery('ALTER TABLE `federation_txos` ADD INDEX `expiredAt` (`expiredAt`)'); + await this.$executeQuery('ALTER TABLE `federation_txos` ADD INDEX `balance` (`balance`)'); + + await this.updateToSchemaVersion(85); + } } /**