Added DbBatch support #148
Conversation
|
cc @CumpsD any thoughts on this? |
There was a problem hiding this comment.
Some of your new unit tests are failing, but also - how do we handle this for users who can't upgrade to newer driver versions due to Entity Framework diamond dependencies?
I'd love to incorporate this change but I sincerely need community members to weigh in.
| @@ -4,7 +4,7 @@ | |||
| <PropertyGroup> | |||
| <AssemblyTitle>Akka.Persistence.PostgreSql</AssemblyTitle> | |||
| <Description>Akka Persistence journal and snapshot store backed by PostgreSql database.</Description> | |||
| <TargetFrameworks>$(NetStandardLibVersion)</TargetFrameworks> | |||
| <TargetFrameworks>$(NetStandardLibVersion);$(NetVersion)</TargetFrameworks> | |||
There was a problem hiding this comment.
We're generally planning on making dual targeting to .NET 6 available for Akka.NET v1.5, but I guess it doesn't harm much to have it here.
src/Akka.Persistence.PostgreSql/Journal/PostgreSqlDbBatchQueryExecutor.cs
Show resolved
Hide resolved
| @@ -46,8 +46,9 @@ public PostgreSqlQueryExecutor(PostgreSqlQueryConfiguration configuration, Akka. | |||
| {Configuration.TagsColumnName} VARCHAR(100) NULL, | |||
| {Configuration.SerializerIdColumnName} INTEGER NULL, | |||
| CONSTRAINT {Configuration.JournalEventsTableName}_uq UNIQUE ({Configuration.PersistenceIdColumnName}, {Configuration.SequenceNrColumnName}) | |||
| );"; | |||
|
|
|||
| ); CREATE INDEX IF NOT EXISTS IX_{Configuration.JournalEventsTableName}_{Configuration.SequenceNrColumnName} ON {Configuration.FullJournalTableName} USING btree ( | |||
There was a problem hiding this comment.
Can we add a migration SQL script to apply this to existing journal configs?
There was a problem hiding this comment.
Sure, automatically or just a SQL file ? This index is needed for large Journals
There was a problem hiding this comment.
@jarlebh a SQL file is fine - users should apply it manually.
src/common.props
Outdated
| @@ -14,11 +14,12 @@ | |||
| <PropertyGroup> | |||
| <XunitVersion>2.4.1</XunitVersion> | |||
| <XunitRunnerVersion>2.4.3</XunitRunnerVersion> | |||
| <AkkaVersion>1.4.35</AkkaVersion> | |||
| <PostgresLowVersion>5.0.11</PostgresLowVersion> | |||
There was a problem hiding this comment.
How do we reconcile that change with this one? #125
.NET Core 3.1 support sunsets this December.
There was a problem hiding this comment.
Actually we might be able to compile with lower version, I could try. However it will not work if you try to use the new PostgreSqlDbBatchQueryExecutor
If it passes the test, I'm all for it, since it is opt-in anyway via HOCON I do have to mention I am not busy with akka.net on postgresql (or akka.net in general) right now due to lack of time |
…ng if newtonsoft json is enabled for jsonb
…alize-jsonb-as-jobject # Conflicts: # src/Akka.Persistence.PostgreSql.Performance.Tests/PostgreSqlDbBatchJournalPerfSpec.cs # src/Akka.Persistence.PostgreSql/Journal/PostgreSqlQueryExecutor.cs # src/common.props
Fixes #147
Changes
Added new PostgreDbBatchSqlJournal that uses DbBatch when persisting, this increases performane of PersistAll x 20, also added .net6 support as this is needed to get right version of DbBatch in .net6
Checklist
For significant changes, please ensure that the following have been completed (delete if not relevant):
Latest
devBenchmarksInclude data from the relevant benchmark prior to this change here.
This PR's Benchmarks
Include data from after this change here.