highperfocused/mempool
1
0
Fork 0
mirror of https://github.com/mempool/mempool.git synced 2025-04-01 00:18:05 +02:00
Code Issues Packages Projects Releases Wiki Activity

Add missing liquid db indexes

Browse Source
This commit is contained in:
Mononaut 2024-11-15 22:31:30 +00:00
parent d9f3611da3
commit e05f5ee751
No known key found for this signature in database
GPG Key ID: A3F058E41374C04E
1 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
backend/src/api/database-migration.ts
View File

@ -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);
}
}
/**