From bfd771056d31acc13a23d8f56ab9a3a9e3c5f5db Mon Sep 17 00:00:00 2001 From: Mononaut Date: Sat, 16 Nov 2024 00:01:13 +0000 Subject: [PATCH] split new liquid db indexes into separate migrations --- backend/src/api/database-migration.ts | 40 ++++++++++++++++----------- 1 file changed, 24 insertions(+), 16 deletions(-) diff --git a/backend/src/api/database-migration.ts b/backend/src/api/database-migration.ts index 9ae34aa0a..35d45433c 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 = 92; + private static currentVersion = 93; private queryTimeout = 3600_000; private statisticsAddedIndexed = false; private uniqueLogs: string[] = []; @@ -776,23 +776,31 @@ class DatabaseMigration { await this.updateToSchemaVersion(91); } + // elements_pegs indexes 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`)'); + await this.$executeQuery(` + ALTER TABLE \`elements_pegs\` + ADD INDEX \`block\` (\`block\`), + ADD INDEX \`datetime\` (\`datetime\`), + ADD INDEX \`amount\` (\`amount\`), + ADD INDEX \`bitcoinaddress\` (\`bitcoinaddress\`), + ADD INDEX \`bitcointxid\` (\`bitcointxid\`) + `); + await this.updateToSchemaVersion(92); + } - // 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); + // federation_txos indexes + if (databaseSchemaVersion < 93 && config.MEMPOOL.NETWORK === 'liquid') { + await this.$executeQuery(` + ALTER TABLE \`federation_txos\` + ADD INDEX \`unspent\` (\`unspent\`), + ADD INDEX \`lastblockupdate\` (\`lastblockupdate\`), + ADD INDEX \`blocktime\` (\`blocktime\`), + ADD INDEX \`emergencyKey\` (\`emergencyKey\`), + ADD INDEX \`expiredAt\` (\`expiredAt\`), + ADD INDEX \`balance\` (\`balance\`) + `); + await this.updateToSchemaVersion(93); } }