Merge pull request #2324 from HicServices/task/sql-merge-colum-types

Task/sql merge colum types

Author: rdteviotdale

CHANGELOG.md

@@ -4,6 +4,9 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [9.2.1] - Unreleased
+- Update Sql Merge component to force destination column types
+
 ## [9.2.0] - 2026-03-10
 - Add Internal Note to Catalogue
 - Fix issue where project associations were not copied when a CIC was cloned

Rdmp.Core/DataExport/DataExtraction/Pipeline/Destinations/MSSqlMergeDestination.cs

@@ -255,10 +255,16 @@ protected override void WriteRows(DataTable toProcess, IDataLoadEventListener jo
             var pkColumns = toProcess.PrimaryKey;
             var nonPkColumns = toProcess.Columns.Cast<DataColumn>().Where(dc => !pkColumns.Contains(dc)).ToArray();
             //merge
+            List<DatabaseColumnRequest> columnTypes = new List<DatabaseColumnRequest>() { };
+            foreach (var column in destinationTable.DiscoverColumns())
+            {
+                columnTypes.Add(new DatabaseColumnRequest(column.GetRuntimeName(), column.DataType.ToString(), column.AllowNulls));
+            }
+
             var tmpTbl = db.CreateTable(
                 out Dictionary<string, Guesser> _dataTypeDictionary,
                 $"mergeTempTable_{tableName}_{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff", CultureInfo.InvariantCulture).Replace('.', '-')}",
-                toProcess, null, true, null);
+                toProcess, columnTypes.ToArray(), true, null);
             var _managedConnection = tmpTbl.Database.Server.GetManagedConnection();
             var _bulkcopy = tmpTbl.BeginBulkInsert(CultureInfo.CurrentCulture, _managedConnection.ManagedTransaction);
             _bulkcopy.Timeout = SQLMergeTimeout;

SharedAssemblyInfo.cs

@@ -10,6 +10,6 @@
 [assembly: AssemblyTrademark("")]
 [assembly: AssemblyCulture("")]
 
-[assembly: AssemblyVersion("9.2.0")]
-[assembly: AssemblyFileVersion("9.2.0")]
-[assembly: AssemblyInformationalVersion("9.2.0")]
+[assembly: AssemblyVersion("9.2.1")]
+[assembly: AssemblyFileVersion("9.2.1")]
+[assembly: AssemblyInformationalVersion("9.2.1")]