Add MySqlBulkCopy.RowsCopied property. Fixes #809

Author: bgrainger

src/MySqlConnector/MySql.Data.MySqlClient/MySqlBulkCopy.cs

@@ -55,6 +55,11 @@ public MySqlBulkCopy(MySqlConnection connection, MySqlTransaction? transaction =
 		/// </summary>
 		public List<MySqlBulkCopyColumnMapping> ColumnMappings { get; }
 
+		/// <summary>
+		/// Returns the number of rows that were copied (after <code>WriteToServer(Async)</code> finishes).
+		/// </summary>
+		public int RowsCopied { get; private set; }
+
 #if !NETSTANDARD1_3
 		public void WriteToServer(DataTable dataTable)
 		{
@@ -218,7 +223,7 @@ internal async Task SendDataReaderAsync(IOBehavior ioBehavior, CancellationToken
 			var outputIndex = 0;
 
 			// allocate a reusable MySqlRowsCopiedEventArgs if event notification is necessary
-			var rowsCopied = 0;
+			RowsCopied = 0;
 			MySqlRowsCopiedEventArgs? eventArgs = null;
 			if (NotifyAfter > 0 && MySqlRowsCopied is object)
 				eventArgs = new MySqlRowsCopiedEventArgs();
@@ -267,10 +272,10 @@ await m_valuesEnumerator.MoveNextAsync().ConfigureAwait(false) :
 					{
 						buffer[outputIndex++] = (byte) '\n';
 
-						rowsCopied++;
-						if (eventArgs is object && rowsCopied % NotifyAfter == 0)
+						RowsCopied++;
+						if (eventArgs is object && RowsCopied % NotifyAfter == 0)
 						{
-							eventArgs.RowsCopied = rowsCopied;
+							eventArgs.RowsCopied = RowsCopied;
 							MySqlRowsCopied!(this, eventArgs);
 							if (eventArgs.Abort)
 								break;

tests/SideBySide/BulkLoaderAsync.cs

@@ -529,6 +529,7 @@ public async Task BulkCopyNotifyAfter(int notifyAfter, int rowCount, int expecte
 			{
 				eventCount++;
 				rowsCopied = e.RowsCopied;
+				Assert.Equal(bulkCopy.RowsCopied, e.RowsCopied);
 			};
 
 			var dataTable = new DataTable()
@@ -541,6 +542,7 @@ public async Task BulkCopyNotifyAfter(int notifyAfter, int rowCount, int expecte
 			await bulkCopy.WriteToServerAsync(dataTable);
 			Assert.Equal(expectedEventCount, eventCount);
 			Assert.Equal(expectedRowsCopied, rowsCopied);
+			Assert.Equal(rowCount, bulkCopy.RowsCopied);
 		}
 
 		[Theory]

tests/SideBySide/BulkLoaderSync.cs

@@ -725,6 +725,7 @@ public void BulkCopyNotifyAfter(int notifyAfter, int rowCount, int expectedEvent
 			{
 				eventCount++;
 				rowsCopied = e.RowsCopied;
+				Assert.Equal(bulkCopy.RowsCopied, e.RowsCopied);
 			};
 
 			var dataTable = new DataTable()
@@ -737,6 +738,7 @@ public void BulkCopyNotifyAfter(int notifyAfter, int rowCount, int expectedEvent
 			bulkCopy.WriteToServer(dataTable);
 			Assert.Equal(expectedEventCount, eventCount);
 			Assert.Equal(expectedRowsCopied, rowsCopied);
+			Assert.Equal(rowCount, bulkCopy.RowsCopied);
 		}
 
 		[Theory]