kylefang/stacks-blockchain-api
1
0
Fork 0
mirror of https://github.com/alexgo-io/stacks-blockchain-api.git synced 2026-01-12 16:53:19 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: re-enable indexes when finishing the replay

Browse Source
This commit is contained in:
Chris Guimaraes
2023-07-19 17:45:47 +01:00
parent 62a48ae37d
commit fc379ebab9
1 changed files with 20 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/event-replay/parquet-based/post-replay-db.ts
View File

@@ -1,6 +1,8 @@
import { logger } from '../../logger';
import { PgWriteStore } from '../../datastore/pg-write-store';
const MIGRATIONS_TABLE = 'pgmigrations';
(async () => {
const db = await PgWriteStore.connect({
usageName: 'post-event-replay',
@@ -9,6 +11,24 @@ import { PgWriteStore } from '../../datastore/pg-write-store';
isEventReplay: true,
});
// Re-enable indexes
const dbName = db.sql.options.database;
const tableSchema = db.sql.options.connection.search_path ?? 'public';
const tablesQuery = await db.sql<{ tablename: string }[]>`
SELECT tablename FROM pg_catalog.pg_tables
WHERE tablename != ${MIGRATIONS_TABLE}
AND schemaname = ${tableSchema}`;
if (tablesQuery.length === 0) {
const errorMsg = `No tables found in database '${dbName}', schema '${tableSchema}'`;
console.error(errorMsg);
throw new Error(errorMsg);
}
const tables: string[] = tablesQuery.map((r: { tablename: string }) => r.tablename);
logger.info({ component: 'event-replay' }, 'Re-enabling indexes and constraints on tables');
await db.toggleTableIndexes(db.sql, tables, true);
logger.info({ component: 'event-replay' }, `Indexes re-enabled on tables: ${tables.join(', ')}`);
// Refreshing materialized views
logger.info({ component: 'event-replay' }, `Refreshing materialized views`);
await db.finishEventReplay();