diff --git a/pkg/storage/postgres/migrate.go b/pkg/storage/postgres/migrate.go index 61afb8d8f..8ab57107d 100644 --- a/pkg/storage/postgres/migrate.go +++ b/pkg/storage/postgres/migrate.go @@ -139,6 +139,23 @@ var migrations = []func(context.Context, pgx.Tx) error{ return err } + return nil + }, + 5: func(ctx context.Context, tx pgx.Tx) error { + for _, q := range []string{ + `CREATE INDEX ON ` + schemaName + `.` + recordsTableName + ` (type)`, + `CREATE INDEX ON ` + schemaName + `.` + recordsTableName + ` (type, version)`, + `CREATE INDEX ON ` + schemaName + `.` + recordChangesTableName + ` (modified_at)`, + `CREATE INDEX ON ` + schemaName + `.` + recordChangesTableName + ` (version)`, + `CREATE INDEX ON ` + schemaName + `.` + recordChangesTableName + ` (type)`, + `CREATE INDEX ON ` + schemaName + `.` + recordChangesTableName + ` (type, version)`, + } { + _, err := tx.Exec(ctx, q) + if err != nil { + return err + } + } + return nil }, }