mirror of
https://github.com/zitadel/zitadel.git
synced 2024-12-04 23:45:07 +00:00
25dc7bfe72
# Which Problems Are Solved Cache implementation using a PGX connection pool. # How the Problems Are Solved Defines a new schema `cache` in the zitadel database. A table for string keys and a table for objects is defined. For postgreSQL, tables are unlogged and partitioned by cache name for performance. Cockroach does not have unlogged tables and partitioning is an enterprise feature that uses alternative syntax combined with sharding. Regular tables are used here. # Additional Changes - `postgres.Config` can return a pxg pool. See following discussion # Additional Context - Part of https://github.com/zitadel/zitadel/issues/8648 - Closes https://github.com/zitadel/zitadel/issues/8647 --------- Co-authored-by: Silvan <silvan.reusser@gmail.com>
38 lines
848 B
Go
38 lines
848 B
Go
package setup
|
|
|
|
import (
|
|
"context"
|
|
_ "embed"
|
|
"fmt"
|
|
|
|
"github.com/zitadel/zitadel/internal/database"
|
|
"github.com/zitadel/zitadel/internal/eventstore"
|
|
)
|
|
|
|
var (
|
|
//go:embed 34/cockroach/34_cache_schema.sql
|
|
addCacheSchemaCockroach string
|
|
//go:embed 34/postgres/34_cache_schema.sql
|
|
addCacheSchemaPostgres string
|
|
)
|
|
|
|
type AddCacheSchema struct {
|
|
dbClient *database.DB
|
|
}
|
|
|
|
func (mig *AddCacheSchema) Execute(ctx context.Context, _ eventstore.Event) (err error) {
|
|
switch mig.dbClient.Type() {
|
|
case "cockroach":
|
|
_, err = mig.dbClient.ExecContext(ctx, addCacheSchemaCockroach)
|
|
case "postgres":
|
|
_, err = mig.dbClient.ExecContext(ctx, addCacheSchemaPostgres)
|
|
default:
|
|
err = fmt.Errorf("add cache schema: unsupported db type %q", mig.dbClient.Type())
|
|
}
|
|
return err
|
|
}
|
|
|
|
func (mig *AddCacheSchema) String() string {
|
|
return "34_add_cache_schema"
|
|
}
|