TheArchive/zitadel
1
0
Fork 0
mirror of https://github.com/zitadel/zitadel.git synced 2025-10-21 12:40:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

drop owner_removed column on useer_metadata

Browse Source
This commit is contained in:
Tim Möhlmann
2023-11-14 15:00:57 +02:00
parent 22204260f1
commit 9cbd0ede9d
5 changed files with 22 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
internal/query/embed/userinfo_by_id.sql
View File

@@ -23,7 +23,7 @@ machine as (
metadata as ( metadata as (
select json_agg(row_to_json(r)) as metadata from ( select json_agg(row_to_json(r)) as metadata from (
select creation_date, change_date, sequence, resource_owner, key, encode(value, 'base64') as value select creation_date, change_date, sequence, resource_owner, key, encode(value, 'base64') as value
from projections.user_metadata4 from projections.user_metadata5
where user_id = $1 where user_id = $1
and instance_id = $2 and instance_id = $2
) r ) r

5
internal/query/projection/user_metadata.go
View File

@@ -13,7 +13,7 @@ import (
) )
const ( const (
UserMetadataProjectionTable = "projections.user_metadata4" UserMetadataProjectionTable = "projections.user_metadata5"
UserMetadataColumnUserID = "user_id" UserMetadataColumnUserID = "user_id"
UserMetadataColumnCreationDate = "creation_date" UserMetadataColumnCreationDate = "creation_date"
@@ -23,7 +23,6 @@ const (
UserMetadataColumnInstanceID = "instance_id" UserMetadataColumnInstanceID = "instance_id"
UserMetadataColumnKey = "key" UserMetadataColumnKey = "key"
UserMetadataColumnValue = "value" UserMetadataColumnValue = "value"
UserMetadataColumnOwnerRemoved = "owner_removed"
) )
type userMetadataProjection struct{} type userMetadataProjection struct{}
@@ -47,11 +46,9 @@ func (*userMetadataProjection) Init() *old_handler.Check {
handler.NewColumn(UserMetadataColumnInstanceID, handler.ColumnTypeText), handler.NewColumn(UserMetadataColumnInstanceID, handler.ColumnTypeText),
handler.NewColumn(UserMetadataColumnKey, handler.ColumnTypeText), handler.NewColumn(UserMetadataColumnKey, handler.ColumnTypeText),
handler.NewColumn(UserMetadataColumnValue, handler.ColumnTypeBytes, handler.Nullable()), handler.NewColumn(UserMetadataColumnValue, handler.ColumnTypeBytes, handler.Nullable()),
handler.NewColumn(UserMetadataColumnOwnerRemoved, handler.ColumnTypeBool, handler.Default(false)),
}, },
handler.NewPrimaryKey(UserMetadataColumnInstanceID, UserMetadataColumnUserID, UserMetadataColumnKey), handler.NewPrimaryKey(UserMetadataColumnInstanceID, UserMetadataColumnUserID, UserMetadataColumnKey),
handler.WithIndex(handler.NewIndex("resource_owner", []string{UserGrantResourceOwner})), handler.WithIndex(handler.NewIndex("resource_owner", []string{UserGrantResourceOwner})),
handler.WithIndex(handler.NewIndex("owner_removed", []string{UserMetadataColumnOwnerRemoved})),
), ),
) )
} }

12
internal/query/projection/user_metadata_test.go
View File

@@ -41,7 +41,7 @@ func TestUserMetadataProjection_reduces(t *testing.T) {
executer: &testExecuter{ executer: &testExecuter{
executions: []execution{ executions: []execution{
{ {
expectedStmt: "INSERT INTO projections.user_metadata4 (instance_id, user_id, key, resource_owner, creation_date, change_date, sequence, value) VALUES ($1, $2, $3, $4, $5, $6, $7, $8) ON CONFLICT (instance_id, user_id, key) DO UPDATE SET (resource_owner, creation_date, change_date, sequence, value) = (EXCLUDED.resource_owner, EXCLUDED.creation_date, EXCLUDED.change_date, EXCLUDED.sequence, EXCLUDED.value)", expectedStmt: "INSERT INTO projections.user_metadata5 (instance_id, user_id, key, resource_owner, creation_date, change_date, sequence, value) VALUES ($1, $2, $3, $4, $5, $6, $7, $8) ON CONFLICT (instance_id, user_id, key) DO UPDATE SET (resource_owner, creation_date, change_date, sequence, value) = (EXCLUDED.resource_owner, EXCLUDED.creation_date, EXCLUDED.change_date, EXCLUDED.sequence, EXCLUDED.value)",
expectedArgs: []interface{}{ expectedArgs: []interface{}{
"instance-id", "instance-id",
"agg-id", "agg-id",
@@ -76,7 +76,7 @@ func TestUserMetadataProjection_reduces(t *testing.T) {
executer: &testExecuter{ executer: &testExecuter{
executions: []execution{ executions: []execution{
{ {
expectedStmt: "DELETE FROM projections.user_metadata4 WHERE (user_id = $1) AND (key = $2) AND (instance_id = $3)", expectedStmt: "DELETE FROM projections.user_metadata5 WHERE (user_id = $1) AND (key = $2) AND (instance_id = $3)",
expectedArgs: []interface{}{ expectedArgs: []interface{}{
"agg-id", "agg-id",
"key", "key",
@@ -104,7 +104,7 @@ func TestUserMetadataProjection_reduces(t *testing.T) {
executer: &testExecuter{ executer: &testExecuter{
executions: []execution{ executions: []execution{
{ {
expectedStmt: "DELETE FROM projections.user_metadata4 WHERE (user_id = $1) AND (instance_id = $2)", expectedStmt: "DELETE FROM projections.user_metadata5 WHERE (user_id = $1) AND (instance_id = $2)",
expectedArgs: []interface{}{ expectedArgs: []interface{}{
"agg-id", "agg-id",
"instance-id", "instance-id",
@@ -131,7 +131,7 @@ func TestUserMetadataProjection_reduces(t *testing.T) {
executer: &testExecuter{ executer: &testExecuter{
executions: []execution{ executions: []execution{
{ {
expectedStmt: "DELETE FROM projections.user_metadata4 WHERE (user_id = $1) AND (instance_id = $2)", expectedStmt: "DELETE FROM projections.user_metadata5 WHERE (user_id = $1) AND (instance_id = $2)",
expectedArgs: []interface{}{ expectedArgs: []interface{}{
"agg-id", "agg-id",
"instance-id", "instance-id",
@@ -158,7 +158,7 @@ func TestUserMetadataProjection_reduces(t *testing.T) {
executer: &testExecuter{ executer: &testExecuter{
executions: []execution{ executions: []execution{
{ {
expectedStmt: "DELETE FROM projections.user_metadata4 WHERE (instance_id = $1) AND (resource_owner = $2)", expectedStmt: "DELETE FROM projections.user_metadata5 WHERE (instance_id = $1) AND (resource_owner = $2)",
expectedArgs: []interface{}{ expectedArgs: []interface{}{
"instance-id", "instance-id",
"agg-id", "agg-id",
@@ -185,7 +185,7 @@ func TestUserMetadataProjection_reduces(t *testing.T) {
executer: &testExecuter{ executer: &testExecuter{
executions: []execution{ executions: []execution{
{ {
expectedStmt: "DELETE FROM projections.user_metadata4 WHERE (instance_id = $1)", expectedStmt: "DELETE FROM projections.user_metadata5 WHERE (instance_id = $1)",
expectedArgs: []interface{}{ expectedArgs: []interface{}{
"agg-id", "agg-id",
}, },

10
internal/query/user_metadata.go
View File

@@ -74,10 +74,6 @@ var (
name: projection.UserMetadataColumnValue, name: projection.UserMetadataColumnValue,
table: userMetadataTable, table: userMetadataTable,
} }
UserMetadataOwnerRemovedCol = Column{
name: projection.UserMetadataColumnOwnerRemoved,
table: userMetadataTable,
}
) )
func (q *Queries) GetUserMetadataByKey(ctx context.Context, shouldTriggerBulk bool, userID, key string, withOwnerRemoved bool, queries ...SearchQuery) (metadata *UserMetadata, err error) { func (q *Queries) GetUserMetadataByKey(ctx context.Context, shouldTriggerBulk bool, userID, key string, withOwnerRemoved bool, queries ...SearchQuery) (metadata *UserMetadata, err error) {
@@ -100,9 +96,6 @@ func (q *Queries) GetUserMetadataByKey(ctx context.Context, shouldTriggerBulk bo
UserMetadataKeyCol.identifier(): key, UserMetadataKeyCol.identifier(): key,
UserMetadataInstanceIDCol.identifier(): authz.GetInstance(ctx).InstanceID(), UserMetadataInstanceIDCol.identifier(): authz.GetInstance(ctx).InstanceID(),
} }
if !withOwnerRemoved {
eq[UserMetadataOwnerRemovedCol.identifier()] = false
}
stmt, args, err := query.Where(eq).ToSql() stmt, args, err := query.Where(eq).ToSql()
if err != nil { if err != nil {
return nil, errors.ThrowInternal(err, "QUERY-aDGG2", "Errors.Query.SQLStatment") return nil, errors.ThrowInternal(err, "QUERY-aDGG2", "Errors.Query.SQLStatment")
@@ -131,9 +124,6 @@ func (q *Queries) SearchUserMetadata(ctx context.Context, shouldTriggerBulk bool
UserMetadataUserIDCol.identifier(): userID, UserMetadataUserIDCol.identifier(): userID,
UserMetadataInstanceIDCol.identifier(): authz.GetInstance(ctx).InstanceID(), UserMetadataInstanceIDCol.identifier(): authz.GetInstance(ctx).InstanceID(),
} }
if !withOwnerRemoved {
eq[UserMetadataOwnerRemovedCol.identifier()] = false
}
stmt, args, err := queries.toQuery(query).Where(eq).ToSql() stmt, args, err := queries.toQuery(query).Where(eq).ToSql()
if err != nil { if err != nil {
return nil, errors.ThrowInternal(err, "QUERY-Egbgd", "Errors.Query.SQLStatment") return nil, errors.ThrowInternal(err, "QUERY-Egbgd", "Errors.Query.SQLStatment")

28
internal/query/user_metadata_test.go
View File

@@ -12,13 +12,13 @@ import (
) )
var ( var (
userMetadataQuery = `SELECT projections.user_metadata4.creation_date,` + userMetadataQuery = `SELECT projections.user_metadata5.creation_date,` +
` projections.user_metadata4.change_date,` + ` projections.user_metadata5.change_date,` +
` projections.user_metadata4.resource_owner,` + ` projections.user_metadata5.resource_owner,` +
` projections.user_metadata4.sequence,` + ` projections.user_metadata5.sequence,` +
` projections.user_metadata4.key,` + ` projections.user_metadata5.key,` +
` projections.user_metadata4.value` + ` projections.user_metadata5.value` +
` FROM projections.user_metadata4` + ` FROM projections.user_metadata5` +
` AS OF SYSTEM TIME '-1 ms'` ` AS OF SYSTEM TIME '-1 ms'`
userMetadataCols = []string{ userMetadataCols = []string{
"creation_date", "creation_date",
@@ -28,14 +28,14 @@ var (
"key", "key",
"value", "value",
} }
userMetadataListQuery = `SELECT projections.user_metadata4.creation_date,` + userMetadataListQuery = `SELECT projections.user_metadata5.creation_date,` +
` projections.user_metadata4.change_date,` + ` projections.user_metadata5.change_date,` +
` projections.user_metadata4.resource_owner,` + ` projections.user_metadata5.resource_owner,` +
` projections.user_metadata4.sequence,` + ` projections.user_metadata5.sequence,` +
` projections.user_metadata4.key,` + ` projections.user_metadata5.key,` +
` projections.user_metadata4.value,` + ` projections.user_metadata5.value,` +
` COUNT(*) OVER ()` + ` COUNT(*) OVER ()` +
` FROM projections.user_metadata4` ` FROM projections.user_metadata5`
userMetadataListCols = []string{ userMetadataListCols = []string{
"creation_date", "creation_date",
"change_date", "change_date",