diff --git a/database/migrate/migrate_test.go b/database/migrate/migrate_test.go index 4434ce334f..df449a927c 100644 --- a/database/migrate/migrate_test.go +++ b/database/migrate/migrate_test.go @@ -63,7 +63,7 @@ func testResetDB(t *testing.T) { cur, err := Current(pgDB.DB) assert.NoError(t, err) // total number of tables. - assert.Equal(t, 13, int(cur)) + assert.Equal(t, 14, int(cur)) } func testMigrate(t *testing.T) { diff --git a/database/migrate/migrations/00014_add_chunk_get_task_index.sql b/database/migrate/migrations/00014_add_chunk_get_task_index.sql new file mode 100644 index 0000000000..23050e1e8f --- /dev/null +++ b/database/migrate/migrations/00014_add_chunk_get_task_index.sql @@ -0,0 +1,27 @@ +-- +goose Up +-- +goose StatementBegin + +drop index if exists idx_total_attempts_active_attempts_end_block_number; +drop index if exists idx_total_attempts_active_attempts_chunk_proofs_status; + +create index if not exists idx_chunk_proving_status_index on chunk (proving_status, index) where deleted_at IS NULL; +create index if not exists idx_batch_proving_status_index on batch (proving_status, chunk_proofs_status, index) where deleted_at IS NULL; + +-- +goose StatementEnd + +-- +goose Down +-- +goose StatementBegin + +create index if not exists idx_total_attempts_active_attempts_end_block_number + on chunk (total_attempts, active_attempts, end_block_number) + where deleted_at IS NULL; + +create index if not exists idx_total_attempts_active_attempts_chunk_proofs_status + on batch (total_attempts, active_attempts, chunk_proofs_status) + where deleted_at IS NULL; + + +drop index if exists idx_chunk_proving_status_index; +drop index if exists idx_batch_proving_status_index; + +-- +goose StatementEnd