preserve order and rename migration

This commit is contained in:
Tim Möhlmann 2025-01-03 16:03:57 +02:00
parent 562b00ad16
commit 763af5ebab
2 changed files with 3 additions and 1 deletions

View File

@ -48,5 +48,5 @@ func (mig *InitPushFunc) Execute(ctx context.Context, _ eventstore.Event) (err e
}
func (mig *InitPushFunc) String() string {
return "40_init_push_func"
return "40_init_push_func_v2"
}

View File

@ -61,6 +61,8 @@ LEFT JOIN max_seq
ON cmds.instance_id = max_seq.instance_id
AND cmds.aggregate_type = max_seq.aggregate_type
AND cmds.aggregate_id = max_seq.aggregate_id
ORDER BY
in_tx_order
$$ LANGUAGE SQL;
CREATE OR REPLACE FUNCTION eventstore.push(commands eventstore.command[]) RETURNS SETOF eventstore.events2 VOLATILE AS $$