diff --git a/util/Migrator/DbMigrator.cs b/util/Migrator/DbMigrator.cs index fb27764ba3..e6b155461f 100644 --- a/util/Migrator/DbMigrator.cs +++ b/util/Migrator/DbMigrator.cs @@ -24,6 +24,8 @@ public class DbMigrator } public bool MigrateMsSqlDatabaseWithRetries(bool enableLogging = true, + bool rerunable = false, + string folderName = "DbScripts", CancellationToken cancellationToken = default(CancellationToken)) { var attempt = 1; @@ -32,7 +34,7 @@ public class DbMigrator { try { - var success = MigrateDatabase(enableLogging, cancellationToken); + var success = MigrateDatabase(enableLogging, rerunable, folderName, cancellationToken); return success; } catch (SqlException ex) @@ -54,6 +56,8 @@ public class DbMigrator } public bool MigrateDatabase(bool enableLogging = true, + bool rerunable = false, + string folderName = "DbScripts", CancellationToken cancellationToken = default(CancellationToken)) { if (_logger != null) @@ -98,9 +102,9 @@ public class DbMigrator cancellationToken.ThrowIfCancellationRequested(); var builder = DeployChanges.To .SqlDatabase(_connectionString) - .JournalRerunableToSqlTable("dbo", "Migration") + .JournalRerunableToSqlTable("dbo", "Migration", rerunable) .WithScriptsAndCodeEmbeddedInAssembly(Assembly.GetExecutingAssembly(), - s => s.Contains($".DbScripts.") && !s.Contains(".Archive.")) + s => s.Contains($".{folderName}.") && !s.Contains(".Archive.")) .WithTransaction() .WithExecutionTimeout(new TimeSpan(0, 5, 0));