updated references to use BaseSqlProvider.TotalRowsAffected

dynamicweb · Jul 3, 2024 · 326b3bf · 326b3bf
1 parent 99f8c13
commit 326b3bf
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/src/Dynamicweb.DataIntegration.Providers.SqlProvider.csproj b/src/Dynamicweb.DataIntegration.Providers.SqlProvider.csproj
@@ -23,7 +23,7 @@
 		<SymbolPackageFormat>snupkg</SymbolPackageFormat>
 	</PropertyGroup>
 	<ItemGroup>
-		<PackageReference Include="Dynamicweb.DataIntegration" Version="10.6.2" />
+		<PackageReference Include="Dynamicweb.DataIntegration" Version="10.6.3" />
 		<PackageReference Include="Microsoft.SourceLink.GitHub" Version="1.1.1" PrivateAssets="All" />
 	</ItemGroup>
 </Project>
diff --git a/src/SQLProvider.cs b/src/SQLProvider.cs
@@ -500,7 +500,7 @@ public override bool RunJob(Job job)
                     if (rowsAffected > 0)
                     {
                         Logger.Log($"The number of rows affected: {rowsAffected} in the {writer.Mapping.DestinationTable.Name} table");
-                        writer.RowsAffected += rowsAffected;
+                        TotalRowsAffected += rowsAffected;
                     }
                 }
                 else
@@ -518,7 +518,7 @@ public override bool RunJob(Job job)
                     if (rowsAffected > 0)
                     {
                         Logger.Log($"The number of deleted rows: {rowsAffected} for the destination {writer.Mapping.DestinationTable.Name} table mapping");
-                        writer.RowsAffected += (int)rowsAffected;
+                        TotalRowsAffected += rowsAffected;
                     }
                 }
             }
@@ -549,6 +549,7 @@ public override bool RunJob(Job job)
                 Logger.Log("Import job failed: " + msg);
             }
             RollbackTransaction();
+            TotalRowsAffected = 0;
             return false;
         }
         finally