Merge pull request #17 from akkadotnet/dev

v0.90.1 release
akkadotnet · Feb 3, 2021 · e06499a · e06499a
2 parents 9a89bb0 + 3a08414
commit e06499a
Show file tree

Hide file tree

Showing 25 changed files with 93 additions and 14 deletions.
diff --git a/RELEASE_NOTES.md b/RELEASE_NOTES.md
@@ -1,2 +1,12 @@
-#### 0.1.0 October 05 2019 ####
-First release
+#### 0.90.1 Feb 3 2021 ####
+**Preview Release for Akka.Persistence.Linq2Db**
+
+Akka.Persistence.Linq2Db is an Akka.Net Persistence plug-in that is designed for both high performance as well as easy cross-database compatibility.
+
+This is currently marked as a preview release, with tests passing for MS Sql Server, Postgres, and SQLite. We are looking for community help with adding tests, as well as trying out the new plugin and [providing feedback](https://github.com/akkadotnet/Akka.Persistence.Linq2Db/issues).
+
+There is a compatibility mode also available for those who wish to migrate from the existing Sql.Common journals.
+
+[Please refer to the project page](https://github.com/akkadotnet/Akka.Persistence.Linq2Db/) for information on configuration.
+
+
diff --git a/build-system/windows-release.yaml b/build-system/windows-release.yaml
@@ -14,18 +14,18 @@ variables:
   - group: signingSecrets #create this group with SECRET variables `signingUsername` and `signingPassword`
   - group: nugetKeys #create this group with SECRET variables `nugetKey`
   - name: githubConnectionName
-    value: yourConnection #replace this
+    value: AkkaDotNet_Releases
   - name: projectName
-    value: yourProjectName #replace this
+    value: Akka.Persistence.SqlServer
   - name: githubRepositoryName
-    value: yourOrganization/yourRepo #replace this
+    value: akkadotnet/Akka.Persistence.Linq2Db
 
 steps:
 - task: BatchScript@1
   displayName: 'FAKE Build'
   inputs:
     filename: build.cmd
-    arguments: 'nuget SignClientUser=$(signingUsername) SignClientSecret=$(signingPassword) nugetpublishurl=https://www.nuget.org/api/v2/package nugetkey=$(nugetKey)'
+    arguments: 'nuget nugetpublishurl=https://www.nuget.org/api/v2/package nugetkey=$(nugetKey)'
 
 - task: GitHubRelease@0
   displayName: 'GitHub release (create)'

diff --git a/...ce.Linq2Db.Benchmark.DockerTests/Docker/Linq2Db/DockerLinq2DbPostgreSQLJournalPerfSpec.cs b/...ce.Linq2Db.Benchmark.DockerTests/Docker/Linq2Db/DockerLinq2DbPostgreSQLJournalPerfSpec.cs
@@ -31,6 +31,7 @@ class = ""{0}""
                         use-clone-connection = true
                         tables.journal {{ 
                            auto-init = true
+                           warn-on-auto-init-fail = false
                            table-name = ""{2}"" 
                            }}
                     }}

diff --git a/...nce.Linq2Db.Benchmark.DockerTests/Docker/Linq2Db/DockerLinq2DbSqlServerJournalPerfSpec.cs b/...nce.Linq2Db.Benchmark.DockerTests/Docker/Linq2Db/DockerLinq2DbSqlServerJournalPerfSpec.cs
@@ -35,6 +35,7 @@ class = ""{0}""
                         use-clone-connection = true
                         tables.journal {{ 
                            auto-init = true
+                           warn-on-auto-init-fail = false
                            table-name = ""{2}"" 
                            }}
                     }}

diff --git a/...rsistence.Linq2Db.Compatibility.DockerTests/SqlServer/SqlServerCompatibilitySpecConfig.cs b/...rsistence.Linq2Db.Compatibility.DockerTests/SqlServer/SqlServerCompatibilitySpecConfig.cs
@@ -54,6 +54,7 @@ class = ""{typeof(Linq2DbSnapshotStore).AssemblyQualifiedName}""
                         {{
                         snapshot {{ 
                            auto-init = true
+                           warn-on-auto-init-fail = false
                            table-name = ""{tablename}""    
                           }}
                         }}
@@ -94,6 +95,7 @@ class = ""{typeof(Linq2DbWriteJournal).AssemblyQualifiedName}""
                         table-compatibility-mode = ""sqlserver""
                         tables.journal {{ 
                            auto-init = true
+                           warn-on-auto-init-fail = false
                            table-name = ""{tablename}"" 
                            metadata-table-name = ""{metadatatablename}""
                            

diff --git a/src/Akka.Persistence.Linq2Db.Compatibility.Tests/Sqlite/SQLiteCompatibilitySpecConfig.cs b/src/Akka.Persistence.Linq2Db.Compatibility.Tests/Sqlite/SQLiteCompatibilitySpecConfig.cs
@@ -55,6 +55,7 @@ class = ""{typeof(Linq2DbSnapshotStore).AssemblyQualifiedName}""
                         {{
                         snapshot {{ 
                            auto-init = true
+                           warn-on-auto-init-fail = false
                            table-name = ""{tablename}""    
                           }}
                         }}
@@ -94,6 +95,7 @@ class = ""{typeof(Linq2DbWriteJournal).AssemblyQualifiedName}""
                         table-compatibility-mode = ""sqlite""
                         tables.journal {{ 
                            auto-init = true
+                           warn-on-auto-init-fail = false
                            table-name = ""{tablename}"" 
                            metadata-table-name = ""{metadatatablename}""
                            

diff --git a/src/Akka.Persistence.Linq2Db.Journal.Query.Tests/SqliteAllEventsSpec.cs b/src/Akka.Persistence.Linq2Db.Journal.Query.Tests/SqliteAllEventsSpec.cs
@@ -36,6 +36,7 @@ public static Config Config(int id)
                      table-name = event_journal
                      metadata-table-name = journal_metadata
                      auto-init = true 
+                           warn-on-auto-init-fail = false
                    }} 
                 }}
                 connection-string = ""{connString}""
@@ -49,6 +50,7 @@ public static Config Config(int id)
                    journal {{
                    table-name = event_journal
                                    metadata-table-name = journal_metadata
+                           warn-on-auto-init-fail = false
                    }}
                 }}
             }}

diff --git a/src/Akka.Persistence.Linq2Db.Journal.Query.Tests/SqliteCurrentAllEventsSpec.cs b/src/Akka.Persistence.Linq2Db.Journal.Query.Tests/SqliteCurrentAllEventsSpec.cs
@@ -36,6 +36,7 @@ public static Config Config(int id)
                      table-name = event_journal
                      metadata-table-name = journal_metadata
                      auto-init = true 
+                           warn-on-auto-init-fail = false
                    }} 
                 }}
                 connection-string = ""{connString}""
@@ -49,6 +50,7 @@ public static Config Config(int id)
                    journal {{
                      table-name = event_journal
                      metadata-table-name = journal_metadata 
+                           warn-on-auto-init-fail = false
                    }} 
                 }}
             }}

diff --git a/src/Akka.Persistence.Linq2Db.Journal.Query.Tests/SqliteCurrentEventsByPersistenceIdSpec.cs b/src/Akka.Persistence.Linq2Db.Journal.Query.Tests/SqliteCurrentEventsByPersistenceIdSpec.cs
@@ -49,6 +49,7 @@ class = ""{typeof(Linq2DbWriteJournal).AssemblyQualifiedName}""
                      table-name = event_journal
                      metadata-table-name = journal_metadata
                      auto-init = true 
+                           warn-on-auto-init-fail = false
                    }} 
                 }}
                 }}
@@ -66,6 +67,7 @@ class = ""{typeof(Linq2DbWriteJournal).AssemblyQualifiedName}""
                          table-name = event_journal
                          metadata-table-name = journal_metadata
                          auto-init = true 
+                           warn-on-auto-init-fail = false
                        }} 
                     }}
                   }}

diff --git a/src/Akka.Persistence.Linq2Db.Journal.Query.Tests/SqliteCurrentEventsByTagSpec.cs b/src/Akka.Persistence.Linq2Db.Journal.Query.Tests/SqliteCurrentEventsByTagSpec.cs
@@ -51,6 +51,7 @@ class = ""{typeof(Linq2DbWriteJournal).AssemblyQualifiedName}""
                 tables {{
                    journal {{
                      table-name = event_journal
+                           warn-on-auto-init-fail = false
                      metadata-table-name = journal_metadata
                      auto-init = true 
                    }} 
@@ -65,6 +66,7 @@ class = ""{typeof(Linq2DbWriteJournal).AssemblyQualifiedName}""
                    journal {{
                      table-name = event_journal
                      metadata-table-name = journal_metadata
+                           warn-on-auto-init-fail = false
                    }} 
                 }}
             }}

diff --git a/src/Akka.Persistence.Linq2Db.Journal.Query.Tests/SqliteCurrentPersistenceIdsSpec.cs b/src/Akka.Persistence.Linq2Db.Journal.Query.Tests/SqliteCurrentPersistenceIdsSpec.cs
@@ -42,6 +42,7 @@ public static Config Config(int id)
                      table-name = event_journal
                      metadata-table-name = journal_metadata
                      auto-init = true 
+                           warn-on-auto-init-fail = false
                    }} 
                 }}
             }}
@@ -53,6 +54,7 @@ public static Config Config(int id)
                    journal {{
                      table-name = event_journal
                      metadata-table-name = journal_metadata 
+                           warn-on-auto-init-fail = false
                    }} 
                 }}
             }}

diff --git a/src/Akka.Persistence.Linq2Db.Journal.Query.Tests/SqliteEventsByPersistenceIdSpec.cs b/src/Akka.Persistence.Linq2Db.Journal.Query.Tests/SqliteEventsByPersistenceIdSpec.cs
@@ -40,6 +40,7 @@ public static Config Config(int id)
                      table-name = event_journal
                      metadata-table-name = journal_metadata
                      auto-init = true 
+                     warn-on-auto-init-fail = false
                    }} 
                 }}
             }}
@@ -51,6 +52,7 @@ public static Config Config(int id)
                    journal {{
                      table-name = event_journal
                      metadata-table-name = journal_metadata 
+                     warn-on-auto-init-fail = false
                    }} 
                 }}
             }}

diff --git a/src/Akka.Persistence.Linq2Db.Journal.Query.Tests/SqliteEventsByTagSpec.cs b/src/Akka.Persistence.Linq2Db.Journal.Query.Tests/SqliteEventsByTagSpec.cs
@@ -44,6 +44,7 @@ public static Config Config(int id)
                      table-name = event_journal
                      metadata-table-name = journal_metadata
                      auto-init = true 
+                     warn-on-auto-init-fail = false
                    }} 
                 }}
                 connection-string = ""{connString}""
@@ -57,6 +58,7 @@ public static Config Config(int id)
                    journal {{
                      table-name = event_journal
                      metadata-table-name = journal_metadata 
+                     warn-on-auto-init-fail = false
                    }} 
                 }}
             }}

diff --git a/src/Akka.Persistence.Linq2Db.Journal.Query.Tests/SqlitePersistenceIdsSpec.cs b/src/Akka.Persistence.Linq2Db.Journal.Query.Tests/SqlitePersistenceIdsSpec.cs
@@ -58,6 +58,7 @@ public static Config Config
                      table-name = event_journal
                      metadata-table-name = journal_metadata
                      auto-init = true 
+                     warn-on-auto-init-fail = false
                    }} 
                 }}
                     }}
@@ -81,6 +82,7 @@ class = ""Akka.Persistence.Sqlite.Snapshot.SqliteSnapshotStore, Akka.Persistence
                    journal {{
                      table-name = event_journal
                      metadata-table-name = journal_metadata 
+                     warn-on-auto-init-fail = false
                    }} 
                 }}
                 write-plugin = ""akka.persistence.journal.linq2db""

diff --git a/src/Akka.Persistence.Sql.Linq2Db.DockerTests/Postgres/PostgreSQLJournalSpec.cs b/src/Akka.Persistence.Sql.Linq2Db.DockerTests/Postgres/PostgreSQLJournalSpec.cs
@@ -34,6 +34,7 @@ class = ""{0}""
                         use-clone-connection = true
                         tables.snapshot {{ 
                            auto-init = true
+                           warn-on-auto-init-fail = false
                            table-name = ""{2}"" 
                            }}
                     }}
@@ -91,6 +92,7 @@ class = ""{0}""
                         use-clone-connection = true
                         tables.journal {{ 
                            auto-init = true
+                           warn-on-auto-init-fail = false
                            table-name = ""{2}"" 
                            }}
                     }}

diff --git a/src/Akka.Persistence.Sql.Linq2Db.DockerTests/Postgres/PostgreSQLJournalSpecConfig.cs b/src/Akka.Persistence.Sql.Linq2Db.DockerTests/Postgres/PostgreSQLJournalSpecConfig.cs
@@ -18,7 +18,10 @@ class = ""{0}""
 #connection-string = ""FullUri=file:test.db&cache=shared""
                         provider-name = ""{2}""
                         use-clone-connection = false
-                        tables.journal {{ auto-init = true }}
+                        tables.journal {{ 
+                           auto-init = true 
+                           warn-on-auto-init-fail = false
+                        }}
                     }}
                 }}
             }}

diff --git a/src/Akka.Persistence.Sql.Linq2Db.DockerTests/SqlServer/SQLServerJournalSpecConfig.cs b/src/Akka.Persistence.Sql.Linq2Db.DockerTests/SqlServer/SQLServerJournalSpecConfig.cs
@@ -23,6 +23,7 @@ class = ""{0}""
                         #use-clone-connection = true
                         tables.journal {{ 
                            auto-init = true
+                           warn-on-auto-init-fail = false
                            table-name = ""{2}"" 
                            }}
                     }}
@@ -40,7 +41,7 @@ public static Configuration.Config Create(string connString, string tableName, i
 
     public static class SQLServerSnapshotSpecConfig
     {
-        public static string _journalBaseConfig = @"
+        public static string _snapshotBaseConfig = @"
 akka.persistence {{
                 publish-plugin-commands = on
                 snapshot-store {{
@@ -57,6 +58,7 @@ class = ""{0}""
                         #use-clone-connection = true
                         tables.snapshot {{ 
                            auto-init = true
+                           warn-on-auto-init-fail = false
                            table-name = ""{2}""
                            column-names {{
                            }} 
@@ -68,7 +70,7 @@ class = ""{0}""
         public static Configuration.Config Create(string connString, string tableName, int batchSize = 100, int parallelism = 2)
         {
             return ConfigurationFactory.ParseString(
-                string.Format(_journalBaseConfig,
+                string.Format(_snapshotBaseConfig,
                     typeof(Linq2DbSnapshotStore).AssemblyQualifiedName,
                     connString,tableName,batchSize, parallelism));
         }

diff --git a/src/Akka.Persistence.Sql.Linq2Db.Tests/Linq2DbJournalDefaultSpecConfig.cs b/src/Akka.Persistence.Sql.Linq2Db.Tests/Linq2DbJournalDefaultSpecConfig.cs
@@ -16,6 +16,7 @@ class = ""Akka.Persistence.Sql.Linq2Db.Journal.Linq2DbWriteJournal, Akka.Persist
  tables{{
   journal{{
     auto-init = true
+    warn-on-auto-init-fail = false
     table-name = ""{journalTableName}""
     metadata-table-name = ""{metadatatablename}""
   }}
@@ -32,6 +33,7 @@ public static string _journalBaseConfig(string tablename, string metadatatablena
  tables{{
   journal{{
     auto-init = true
+    warn-on-auto-init-fail = false
     table-name = ""{tablename}""
     metadata-table-name = ""{metadatatablename}""
   }}

diff --git a/src/Akka.Persistence.Sql.Linq2Db.Tests/Sqlite/SQLiteJournalSpecConfig.cs b/src/Akka.Persistence.Sql.Linq2Db.Tests/Sqlite/SQLiteJournalSpecConfig.cs
@@ -21,7 +21,10 @@ class = ""{0}""
                         provider-name = ""{2}""
                         parallelism = 1
                         max-row-by-row-size = 100
-                        tables.journal {{ auto-init = true }}
+                        tables.snapshot {{ 
+                          auto-init = true 
+                          warn-on-auto-init-fail = false
+                        }}
                         use-clone-connection = ""{3}""
                     }}
                 }}
@@ -52,7 +55,10 @@ class = ""{0}""
                         provider-name = ""{2}""
                         parallelism = 1
                         max-row-by-row-size = 100
-                        tables.journal {{ auto-init = true }}
+                        tables.journal {{ 
+                          auto-init = true
+                          warn-on-auto-init-fail = false 
+                        }}
                         use-clone-connection = ""{3}""
                     }}
                 }}

diff --git a/src/Akka.Persistence.Sql.Linq2Db/Config/JournalTableConfig.cs b/src/Akka.Persistence.Sql.Linq2Db/Config/JournalTableConfig.cs
@@ -12,6 +12,7 @@ public class JournalTableConfig
         public bool AutoInitialize { get; protected set; }
         public string MetadataTableName { get; protected set; }
         public MetadataTableColumnNames MetadataColumnNames { get; protected set; }
+        public bool WarnOnAutoInitializeFail { get; }
         public JournalTableConfig(Configuration.Config config)
         {
 
@@ -25,14 +26,20 @@ public JournalTableConfig(Configuration.Config config)
                 "journal_metadata");
             SchemaName = localcfg.GetString("schema-name", null);
             AutoInitialize = localcfg.GetBoolean("auto-init", false);
+            WarnOnAutoInitializeFail =
+                localcfg.GetBoolean("warn-on-auto-init-fail", true);
         }
+
+
+
         protected bool Equals(JournalTableConfig other)
         {
             return Equals(ColumnNames, other.ColumnNames) &&
                    TableName == other.TableName &&
                    SchemaName == other.SchemaName &&
                    AutoInitialize == other.AutoInitialize &&
                    MetadataTableName == other.MetadataTableName &&
+                   WarnOnAutoInitializeFail == other.WarnOnAutoInitializeFail &&
                    Equals(MetadataColumnNames, other.MetadataColumnNames);
         }
 

diff --git a/src/Akka.Persistence.Sql.Linq2Db/Config/SnapshotTableConfiguration.cs b/src/Akka.Persistence.Sql.Linq2Db/Config/SnapshotTableConfiguration.cs
@@ -17,7 +17,11 @@ public SnapshotTableConfiguration(Configuration.Config config)
             TableName = localcfg.GetString("table-name", "snapshot");
             SchemaName = localcfg.GetString("schema-name", null);
             AutoInitialize = localcfg.GetBoolean("auto-init", false);
+            WarnOnAutoInitializeFail =
+                localcfg.GetBoolean("warn-on-auto-init-fail", true);
         }
+
+        public bool WarnOnAutoInitializeFail { get; protected set; }
         public SnapshotTableColumnNames ColumnNames { get; protected set; }
         public string TableName { get; protected set; }
         public string SchemaName { get; protected set; }

diff --git a/src/Akka.Persistence.Sql.Linq2Db/Journal/DAO/ByteArrayJournalDao.cs b/src/Akka.Persistence.Sql.Linq2Db/Journal/DAO/ByteArrayJournalDao.cs
@@ -32,7 +32,11 @@ public void InitializeTables()
                 }
                 catch (Exception e)
                 {
-                    _logger.Warning(e,$"Could not Create Journal Table {_journalConfig.TableConfig.TableName} as requested by config.");
+                    if (_journalConfig.TableConfig.WarnOnAutoInitializeFail)
+                    {
+                        _logger.Warning(e,$"Could not Create Journal Table {_journalConfig.TableConfig.TableName} as requested by config.");    
+                    }
+
                 }
 
                 if (_journalConfig.DaoConfig.SqlCommonCompatibilityMode)
@@ -43,7 +47,10 @@ public void InitializeTables()
                     }
                     catch (Exception e)
                     {
-                        _logger.Warning(e,$"Could not Create Journal Metadata Table {_journalConfig.TableConfig.TableName} as requested by config.");
+                        if (_journalConfig.TableConfig.WarnOnAutoInitializeFail)
+                        {
+                            _logger.Warning(e,$"Could not Create Journal Metadata Table {_journalConfig.TableConfig.TableName} as requested by config.");    
+                        }
                     }
                 }
             }

diff --git a/src/Akka.Persistence.Sql.Linq2Db/Snapshot/ByteArraySnapshotDao.cs b/src/Akka.Persistence.Sql.Linq2Db/Snapshot/ByteArraySnapshotDao.cs
@@ -29,7 +29,10 @@ public void InitializeTables()
                 }
                 catch (Exception e)
                 {
-                    _logger.Warning(e,$"Could not Create Snapshot Table {_snapshotConfig.TableConfig.TableName} as requested by config.");
+                    if (_snapshotConfig.TableConfig.WarnOnAutoInitializeFail)
+                    {
+                        _logger.Warning(e,$"Could not Create Snapshot Table {_snapshotConfig.TableConfig.TableName} as requested by config.");    
+                    }
                 }
             }
         }