diff --git a/internal/query/query.go b/internal/query/query.go index c7270f256..e69311b63 100644 --- a/internal/query/query.go +++ b/internal/query/query.go @@ -44,10 +44,11 @@ func StartQueries(ctx context.Context, es *eventstore.Eventstore, projections pr return nil, err } - err = projection.Start(ctx, es, projections) - if err != nil { - return nil, err - } + // turned off for this release + // err = projection.Start(ctx, es, projections) + // if err != nil { + // return nil, err + // } return repo, nil } diff --git a/migrations/cockroach/V1.63__es_previous_agg_root_seq.sql b/migrations/cockroach/V1.63__es_previous_agg_root_seq.sql deleted file mode 100644 index 607663997..000000000 --- a/migrations/cockroach/V1.63__es_previous_agg_root_seq.sql +++ /dev/null @@ -1,40 +0,0 @@ -BEGIN; - -ALTER TABLE eventstore.events - RENAME COLUMN previous_sequence TO previous_aggregate_sequence, - ADD COLUMN previous_aggregate_type_sequence INT8, - ADD CONSTRAINT prev_agg_type_seq_unique UNIQUE(previous_aggregate_type_sequence); - -COMMIT; - -SET CLUSTER SETTING kv.closed_timestamp.target_duration = '2m'; - -BEGIN; -WITH data AS ( - SELECT - event_sequence, - LAG(event_sequence) - OVER ( - PARTITION BY aggregate_type - ORDER BY event_sequence - ) as prev_seq, - aggregate_type - FROM eventstore.events - ORDER BY event_sequence -) UPDATE eventstore.events - SET previous_aggregate_type_sequence = data.prev_seq - FROM data - WHERE data.event_sequence = events.event_sequence; -COMMIT; - -SET CLUSTER SETTING kv.closed_timestamp.target_duration TO DEFAULT; - --- validation by hand: --- SELECT --- event_sequence, --- previous_aggregate_sequence, --- previous_aggregate_type_sequence, --- aggregate_type, --- aggregate_id, --- event_type --- FROM eventstore.events ORDER BY event_sequence; \ No newline at end of file diff --git a/migrations/cockroach/V1.64__zitadel_schema.sql b/migrations/cockroach/V1.63__zitadel_schema.sql similarity index 100% rename from migrations/cockroach/V1.64__zitadel_schema.sql rename to migrations/cockroach/V1.63__zitadel_schema.sql diff --git a/migrations/cockroach/V1.65__first_projections.sql b/migrations/cockroach/V1.64__first_projections.sql similarity index 100% rename from migrations/cockroach/V1.65__first_projections.sql rename to migrations/cockroach/V1.64__first_projections.sql diff --git a/migrations/cockroach/V1.67__project_private_labeling.sql b/migrations/cockroach/V1.65__project_private_labeling.sql similarity index 100% rename from migrations/cockroach/V1.67__project_private_labeling.sql rename to migrations/cockroach/V1.65__project_private_labeling.sql diff --git a/migrations/cockroach/V1.66__agg_type_idx.sql b/migrations/cockroach/V1.66__agg_type_idx.sql deleted file mode 100644 index 556b415c3..000000000 --- a/migrations/cockroach/V1.66__agg_type_idx.sql +++ /dev/null @@ -1 +0,0 @@ -CREATE INDEX agg_type ON eventstore.events (aggregate_type); \ No newline at end of file diff --git a/migrations/cockroach/V1.66__events_cols.sql b/migrations/cockroach/V1.66__events_cols.sql new file mode 100644 index 000000000..5871d7f67 --- /dev/null +++ b/migrations/cockroach/V1.66__events_cols.sql @@ -0,0 +1,8 @@ +BEGIN; + +ALTER TABLE eventstore.events + RENAME COLUMN previous_sequence TO previous_aggregate_sequence, + ADD COLUMN previous_aggregate_type_sequence INT8, + ADD CONSTRAINT prev_agg_type_seq_unique UNIQUE(previous_aggregate_type_sequence); + +COMMIT; \ No newline at end of file