Add non transaction - which does not work.

hamidmayeli · Jan 21, 2023 · fd51e24 · fd51e24
1 parent b626345
commit fd51e24
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 6 deletions.
diff --git a/SimpleDbUp/Program.cs b/SimpleDbUp/Program.cs
@@ -10,10 +10,13 @@
 var connectionString = new Option<string>(new[] { "-c", "--connection-string" }, description: "Connection string to target database");
 connectionString.IsRequired = true;
 
+var nonTransactional = new Option<bool>(new[] { "--non-transactional" }, "Create a transaction per scripts");
+
 command.AddOption(connectionString);
 command.AddOption(scriptDirectory);
+command.AddOption(nonTransactional);
 
-command.SetHandler(EmptyClass.Run, connectionString, scriptDirectory);
+command.SetHandler(Worker.Run, connectionString, scriptDirectory, nonTransactional);
 
 var parser = new CommandLineBuilder(command)
     .UseHelp()

diff --git a/SimpleDbUp/EmptyClass.cs → SimpleDbUp/Worker.cs b/SimpleDbUp/EmptyClass.cs → SimpleDbUp/Worker.cs
@@ -5,10 +5,19 @@
 
 namespace SimpleDbUp;
 
-public class EmptyClass
+public class Worker
 {
-    public static void Run(string connectionString, string scriptsPath)
+    public static void Run(
+        string connectionString,
+        string scriptsPath,
+        bool nonTransactional
+        )
     {
+        Console.WriteLine("Running the upgrade using" +
+            $"{Environment.NewLine}\tConnection String: {connectionString.Length} chars" +
+            $"{Environment.NewLine}\tScripts Path: {new DirectoryInfo(scriptsPath).Name}" +
+            $"{Environment.NewLine}\tNon transactional: {nonTransactional}");
+
         try
         {
             EnsureDatabase.For.MySqlDatabase(connectionString);
@@ -18,7 +27,7 @@ public static void Run(string connectionString, string scriptsPath)
             ExitWithError(exception);
         }
 
-        var upgrade = DeployChanges.To
+        var builder = DeployChanges.To
             .MySqlDatabase(connectionString)
             .WithScriptsFromFileSystem(
                 scriptsPath,
@@ -28,8 +37,14 @@ public static void Run(string connectionString, string scriptsPath)
                     ScriptType = DbUp.Support.ScriptType.RunOnce
                 })
             .LogToConsole()
-            .LogScriptOutput()
-            .Build();
+            .LogScriptOutput();
+
+        if (nonTransactional)
+            builder.WithTransactionPerScript();
+        else
+            builder.WithTransaction();
+
+        var upgrade = builder.Build();
 
         var result = upgrade.PerformUpgrade();