overhaul projectionist

[DavidBadura]

I rewrote the Projectionist core so that it no longer needs an external lock. The "FOR UPDATE" statement is used to lock the rows when reading as long as the transaction exists. If the row is locked, no other process can read it. This means there is no risk of events being processed twice. In addition, only the rows that were affected by the “fetch” are locked. This means that the projections and thus Projectionist can also be run in groups.

Features:

• Implement row lock
• Allow grouping of projections
• Add new run mode named "once"
• Cleanup code
• Improve performance

resolve: #321

[github-actions]

Hello 👋

here is the most recent benchmark result:

SimpleSetupBench
================

+----------------------------------------+--------------------+--------------------+-----------------+------------+
|                                        | time (kde mode)                         | memory                       |
+----------------------------------------+--------------------+--------------------+-----------------+------------+
| subject                                | Tag: <current>     | Tag: base          | Tag: <current>  | Tag: base  |
+----------------------------------------+--------------------+--------------------+-----------------+------------+
| benchLoad10000Events ()                | 158.710ms (±0.00%) | 157.623ms (±0.00%) | 41.097mb        | 41.096mb   |
| benchSave1Event ()                     | 1.191ms (±0.00%)   | 1.174ms (±0.00%)   | 41.097mb        | 41.097mb   |
| benchSave10000Events ()                | 333.787ms (±0.00%) | 333.175ms (±0.00%) | 41.364mb        | 41.364mb   |
| benchSave10000Aggregates ()            | 12.816s (±0.00%)   | 15.830s (±0.00%)   | 41.097mb        | 41.097mb   |
| benchSave10000AggregatesTransaction () | 931.593ms (±0.00%) | 921.199ms (±0.00%) | 41.097mb        | 41.097mb   |
+----------------------------------------+--------------------+--------------------+-----------------+------------+

SnapshotsBench
==============

+----------------------------------------+--------------------+--------------------+-----------------+------------+
|                                        | time (kde mode)                         | memory                       |
+----------------------------------------+--------------------+--------------------+-----------------+------------+
| subject                                | Tag: <current>     | Tag: base          | Tag: <current>  | Tag: base  |
+----------------------------------------+--------------------+--------------------+-----------------+------------+
| benchLoad10000EventsMissingSnapshot () | 154.069ms (±0.00%) | 154.657ms (±0.00%) | 41.114mb        | 41.114mb   |
| benchLoad10000Events ()                | 211.550μs (±0.00%) | 200.700μs (±0.00%) | 41.113mb        | 41.113mb   |
+----------------------------------------+--------------------+--------------------+-----------------+------------+

SplitStreamBench
================

+-------------------------+--------------------+--------------------+-----------------+------------+
|                         | time (kde mode)                         | memory                       |
+-------------------------+--------------------+--------------------+-----------------+------------+
| subject                 | Tag: <current>     | Tag: base          | Tag: <current>  | Tag: base  |
+-------------------------+--------------------+--------------------+-----------------+------------+
| benchLoad10000Events () | 2.689ms (±0.00%)   | 2.793ms (±0.00%)   | 44.544mb        | 44.544mb   |
| benchSave10000Events () | 352.185ms (±0.00%) | 354.091ms (±0.00%) | 44.842mb        | 44.842mb   |
+-------------------------+--------------------+--------------------+-----------------+------------+

This comment gets update everytime a new commit comes in!