DbUp creates multiple connections, so we need to pass in a Func instead to use custom connections

Author: droyad

src/dbup-sqlserver/SqlConnectionManager.cs

@@ -1,3 +1,4 @@
+using System;
 using System.Collections.Generic;
 using Microsoft.Data.SqlClient;
 using DbUp.Engine.Transactions;
@@ -15,22 +16,25 @@ public class SqlConnectionManager : DatabaseConnectionManager
         /// </summary>
         /// <param name="connectionString"></param>
         public SqlConnectionManager(string connectionString)
-            : this(new SqlConnection(connectionString))
-        { }
+            : this(() => new SqlConnection(connectionString))
+        {
+        }
 
         /// <summary>
         /// Manages Sql Database Connections using an existing connection.
         /// </summary>
-        /// <param name="connection">The existing SQL connection to use.</param>
-        public SqlConnectionManager(SqlConnection connection)
+        /// <param name="connectionFactory">A factory function that creates a new SQL connection.</param>
+        public SqlConnectionManager(Func<SqlConnection> connectionFactory)
             : base(new DelegateConnectionFactory((log, dbManager) =>
             {
+                var conn = connectionFactory();
                 if (dbManager.IsScriptOutputLogged)
-                    connection.InfoMessage += (sender, e) => log.LogInformation($"{{0}}", e.Message);
+                    conn.InfoMessage += (sender, e) => log.LogInformation("{0}", e.Message);
 
-                return connection;
+                return conn;
             }))
-        { }
+        {
+        }
 
         /// <inheritdoc/>
         public override IEnumerable<string> SplitScriptIntoCommands(string scriptContents)
@@ -40,4 +44,4 @@ public override IEnumerable<string> SplitScriptIntoCommands(string scriptContent
             return scriptStatements;
         }
     }
-}
+}

src/dbup-sqlserver/SqlServerExtensions.cs

@@ -35,13 +35,13 @@ public static UpgradeEngineBuilder SqlDatabase(this SupportedDatabases supported
     /// Creates an upgrader for SQL Server databases.
     /// </summary>
     /// <param name="supported">Fluent helper type.</param>
-    /// <param name="connection">The sql connection.</param>
+    /// <param name="connectionFactory">A func that create a new SqlConnection</param>
     /// <returns>
     /// A builder for a database upgrader designed for SQL Server databases.
     /// </returns>
-    public static UpgradeEngineBuilder SqlDatabase(this SupportedDatabases supported, SqlConnection connection)
+    public static UpgradeEngineBuilder SqlDatabase(this SupportedDatabases supported, Func<SqlConnection> connectionFactory)
     {
-        return SqlDatabase(supported, connection, null);
+        return SqlDatabase(supported, connectionFactory, null);
     }
 
     /// <summary>
@@ -79,14 +79,14 @@ public static UpgradeEngineBuilder SqlDatabase(this SupportedDatabases supported
     /// Creates an upgrader for SQL Server databases.
     /// </summary>
     /// <param name="supported">Fluent helper type.</param>
-    /// <param name="connection">The sql connection.</param>
+    /// <param name="connectionFactory">A func that create a new SqlConnection</param>
     /// <param name="schema">The SQL schema name to use. Defaults to 'dbo'.</param>
     /// <returns>
     /// A builder for a database upgrader designed for SQL Server databases.
     /// </returns>
-    public static UpgradeEngineBuilder SqlDatabase(this SupportedDatabases supported, SqlConnection connection, string schema)
+    public static UpgradeEngineBuilder SqlDatabase(this SupportedDatabases supported, Func<SqlConnection> connectionFactory, string schema)
     {
-        return SqlDatabase(new SqlConnectionManager(connection), schema);
+        return SqlDatabase(new SqlConnectionManager(connectionFactory), schema);
     }
 
     /// <summary>