diff --git a/src/Dynamicweb.DataIntegration.Providers.OrderProvider.csproj b/src/Dynamicweb.DataIntegration.Providers.OrderProvider.csproj index c0069db..2723692 100644 --- a/src/Dynamicweb.DataIntegration.Providers.OrderProvider.csproj +++ b/src/Dynamicweb.DataIntegration.Providers.OrderProvider.csproj @@ -1,6 +1,6 @@  - 10.7.0 + 10.8.0 1.0.0.0 Order Provider Order Provider @@ -23,8 +23,8 @@ snupkg - - + + diff --git a/src/OrderProvider.cs b/src/OrderProvider.cs index 1c5e62c..489597d 100644 --- a/src/OrderProvider.cs +++ b/src/OrderProvider.cs @@ -336,24 +336,6 @@ internal static List GetMappingsByName(MappingCollection collection, st } } - private static IEnumerable ReplaceKeyColumnsWithAutoIdIfExists(Mapping mapping) - { - //will move this to MappingExtensions - US https://dev.azure.com/dynamicwebsoftware/Dynamicweb/_workitems/edit/20900 - if (mapping == null) return []; - - var autoIdDestinationColumnName = MappingExtensions.GetAutoIdColumnName(mapping.DestinationTable?.Name ?? ""); - if (string.IsNullOrEmpty(autoIdDestinationColumnName)) return mapping.GetColumnMappings(); - - var columnMappings = mapping.GetColumnMappings().ToList(); - var autoIdColumnMapping = columnMappings.Where(obj => obj.DestinationColumn.Name.Equals(autoIdDestinationColumnName, StringComparison.OrdinalIgnoreCase)).FirstOrDefault(); - if (autoIdColumnMapping != null) - { - columnMappings.ForEach(obj => obj.IsKey = false); - autoIdColumnMapping.IsKey = true; - } - return columnMappings; - } - public override bool RunJob(Job job) { OrderTablesInJob(job, false); @@ -375,7 +357,7 @@ public override bool RunJob(Job job) Logger.Log("Starting import to temporary table for " + mapping.DestinationTable.Name + "."); using (var reader = job.Source.GetReader(mapping)) { - var columnMappings = new ColumnMappingCollection(ReplaceKeyColumnsWithAutoIdIfExists(mapping)); + var columnMappings = new ColumnMappingCollection(MappingExtensions.ReplaceKeyColumnsWithAutoIdIfExists(mapping)); var writer = new OrderDestinationWriter(mapping, Connection, Logger, SkipFailingRows, DiscardDuplicates); while (!reader.IsDone()) {