Add merge generator tool

src/DacFXTool/Program.cs

@@ -210,6 +210,18 @@ public static async System.Threading.Tasks.Task<int> Main(string[] args)
 
                         return 0;
                     }
+
+                    // merge "projectpath" "connectionString" "tableName" "schema"
+                    if (args.Length == 5
+                        && (args[0] == "merge"))
+                    {
+                        MergeGenerator.Generate(args[1], args[2], args[3], args[4]);
+
+                        await Console.Out.WriteLineAsync("Result:");
+                        await Console.Out.WriteLineAsync("OK");
+
+                        return 0;
+                    }
                 }
                 else
                 {

src/DacFXTool/Properties/launchSettings.json

@@ -2,7 +2,7 @@
   "profiles": {
     "DacFXTool": {
       "commandName": "Project",
-      "commandLineArgs": "compare false \"C:\\dev\\GitHub\\SqlProjectPowerTools\\test\\SmokeTest\\SdkStyle\\bin\\Debug\\net8.0\\SdkStyle.dacpac\" \"Data Source=.\\SQLEXPRESS;Initial catalog=Chinook;Integrated Security=True;Encrypt=false\""
+      "commandLineArgs": "merge \"C:\\Temp\\test.csproj\" \"Data Source=.\\SQLEXPRESS;Initial catalog=Chinook;Integrated Security=True;Encrypt=false\" \"Album\" \"dbo\""
     }
   }
 }

src/DacFXToolLib/DacFXToolLib.csproj

@@ -6,6 +6,14 @@
     <Nullable>enable</Nullable>
   </PropertyGroup>
 
+  <ItemGroup>
+    <None Remove="sp_generate_merge.sql" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <EmbeddedResource Include="sp_generate_merge.sql" />
+  </ItemGroup>
+
   <ItemGroup>
     <PackageReference Include="ErikEJ.EntityFrameworkCore.SqlServer.Dacpac" Version="8.0.10" />
     <PackageReference Include="Microsoft.Data.SqlClient" Version="6.1.2" />

src/DacFXToolLib/MergeGenerator.cs

@@ -0,0 +1,68 @@
+using System.Data;
+using System.Text;
+using Microsoft.Data.SqlClient;
+
+namespace DacFXToolLib
+{
+    public static class MergeGenerator
+    {
+        public static void Generate(string projectPath, string connectionString, string tableName, string schema)
+        {
+            var script = ReadScript();
+
+            using var connection = new SqlConnection(connectionString);
+            connection.Open();
+#pragma warning disable CA2100 // Review SQL queries for security vulnerabilities
+            using var command = new SqlCommand(script, connection);
+#pragma warning restore CA2100 // Review SQL queries for security vulnerabilities
+            command.ExecuteNonQuery();
+
+            // Sample: EXEC [#sp_generate_merge] @schema = 'dbo', @table_name = 'Album', @results_to_text = 1, @include_use_db = 0
+            using var mergeCommand = new SqlCommand("[#sp_generate_merge]", connection);
+            mergeCommand.CommandType = CommandType.StoredProcedure;
+            mergeCommand.Parameters.AddWithValue("@table_name", tableName);
+            mergeCommand.Parameters.AddWithValue("@schema", schema);
+            mergeCommand.Parameters.AddWithValue("@results_to_text", 1);
+            mergeCommand.Parameters.AddWithValue("@include_use_db", 0);
+            var result = mergeCommand.ExecuteScalar();
+
+            connection.Close();
+
+            WriteResult(projectPath, tableName, result);
+        }
+
+        private static void WriteResult(string projectPath, string tableName, object result)
+        {
+            var projectDirectory = Path.GetDirectoryName(projectPath);
+
+            if (!Directory.Exists(Path.Join(projectDirectory, "Post-Deployment")))
+            {
+                Directory.CreateDirectory(Path.Join(projectDirectory, "Post-Deployment"));
+            }
+
+            var outputPath = Path.Combine(Path.GetDirectoryName(projectPath)!, "Post-Deployment", $"{tableName}_merge.sql");
+
+            if (File.Exists(outputPath))
+            {
+                throw new InvalidOperationException($"The file {outputPath} already exists.");
+            }
+
+            File.WriteAllText(outputPath, result.ToString(), Encoding.UTF8);
+        }
+
+        private static string ReadScript()
+        {
+            var resourceName = "DacFXToolLib.sp_generate_merge.sql";
+            using var stream = System.Reflection.Assembly.GetAssembly(typeof(MergeGenerator))!.GetManifestResourceStream(resourceName);
+            using var reader = new StreamReader(stream!);
+            var sql = reader.ReadToEnd();
+
+            if (string.IsNullOrWhiteSpace(sql))
+            {
+                throw new InvalidOperationException("Could not load the embedded SQL resource.");
+            }
+
+            return sql;
+        }
+    }
+}