Merge pull request #250 from adampoit/fix-affected-rows

Properly sum affected row count.

Author: bgrainger

src/MySqlConnector/MySqlClient/Results/ResultSet.cs

@@ -40,7 +40,7 @@ public async Task<ResultSet> ReadResultSetHeaderAsync(IOBehavior ioBehavior)
 					if (firstByte == OkPayload.Signature)
 					{
 						var ok = OkPayload.Create(payload);
-						RecordsAffected = ok.AffectedRowCount;
+						RecordsAffected += ok.AffectedRowCount;
 						LastInsertId = ok.LastInsertId;
 						ColumnDefinitions = null;
 						State = (ok.ServerStatus & ServerStatus.MoreResultsExist) == 0

tests/SideBySide/InsertTests.cs

@@ -36,6 +36,29 @@ public async Task LastInsertedId()
 			}
 		}
 
+		[Fact]
+		public async Task RowsAffected()
+		{
+			await m_database.Connection.ExecuteAsync(@"drop table if exists insert_rows_affected;
+create table insert_rows_affected(id integer not null primary key auto_increment, value text null);");
+
+			try
+			{
+				await m_database.Connection.OpenAsync();
+				using (var command = new MySqlCommand(@"
+INSERT INTO insert_rows_affected (value) VALUES (null);
+INSERT INTO insert_rows_affected (value) VALUES (null);", m_database.Connection))
+				{
+					var rowsAffected = await command.ExecuteNonQueryAsync();
+					Assert.Equal(2, rowsAffected);
+				}
+			}
+			finally
+			{
+				m_database.Connection.Close();
+			}
+		}
+
 		[Fact]
 		public void LastInsertedIdExplicitStart()
 		{