mirror of
https://github.com/zitadel/zitadel.git
synced 2025-01-10 09:13:41 +00:00
f320d18b1a
# Which Problems Are Solved get instance by domain cannot provide an instance id because it is not known at that time. This causes a full table scan on the fields table because current indexes always include the `instance_id` column. # How the Problems Are Solved Added a specific index for this query. # Additional Context If a system has many fields and there is no cache hit for the given domain this query can heaviuly influence database CPU usage, the newly added resolves this problem.
41 lines
946 B
Go
41 lines
946 B
Go
package setup
|
|
|
|
import (
|
|
"context"
|
|
"embed"
|
|
"fmt"
|
|
|
|
"github.com/zitadel/logging"
|
|
|
|
"github.com/zitadel/zitadel/internal/database"
|
|
"github.com/zitadel/zitadel/internal/eventstore"
|
|
)
|
|
|
|
var (
|
|
//go:embed 43/cockroach/*.sql
|
|
//go:embed 43/postgres/*.sql
|
|
createFieldsDomainIndex embed.FS
|
|
)
|
|
|
|
type CreateFieldsDomainIndex struct {
|
|
dbClient *database.DB
|
|
}
|
|
|
|
func (mig *CreateFieldsDomainIndex) Execute(ctx context.Context, _ eventstore.Event) error {
|
|
statements, err := readStatements(createFieldsDomainIndex, "43", mig.dbClient.Type())
|
|
if err != nil {
|
|
return err
|
|
}
|
|
for _, stmt := range statements {
|
|
logging.WithFields("file", stmt.file, "migration", mig.String()).Info("execute statement")
|
|
if _, err := mig.dbClient.ExecContext(ctx, stmt.query); err != nil {
|
|
return fmt.Errorf("%s %s: %w", mig.String(), stmt.file, err)
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (mig *CreateFieldsDomainIndex) String() string {
|
|
return "43_create_fields_domain_index"
|
|
}
|