Test CommandBehavior.CloseConnection.

This tests a variation of the failing code that reproduces #620.

Author: bgrainger

tests/SideBySide/QueryTests.cs

@@ -1158,6 +1158,30 @@ public void ReservedWordsSchema()
 		}
 #endif
 
+		[Fact]
+		public void CommandBehaviorCloseConnection()
+		{
+			using (var connection = new MySqlConnection(AppConfig.ConnectionString))
+			{
+				Assert.Equal(ConnectionState.Closed, connection.State);
+				connection.Open();
+				Assert.Equal(ConnectionState.Open, connection.State);
+
+				using (var cmd = new MySqlCommand("SELECT 1;", connection))
+				using (var reader = cmd.ExecuteReader(CommandBehavior.CloseConnection))
+				{
+					Assert.True(reader.Read());
+					Assert.Equal(1, reader.GetInt32(0));
+					Assert.False(reader.Read());
+				}
+
+				Assert.Equal(ConnectionState.Closed, connection.State);
+				connection.Open();
+				Assert.Equal(ConnectionState.Open, connection.State);
+				connection.Close();
+			}
+		}
+
 		class BoolTest
 		{
 			public int Id { get; set; }

tests/SideBySide/TransactionScopeTests.cs

@@ -1,6 +1,8 @@
 using System;
 using System.Collections.Generic;
+using System.Data;
 using System.Linq;
+using System.Threading;
 using System.Threading.Tasks;
 using System.Transactions;
 using Dapper;
@@ -636,6 +638,40 @@ public void ReusingConnectionInOneTransactionReusesPhysicalConnection(string con
 			}
 		}
 
+		[Theory]
+		[MemberData(nameof(ConnectionStrings))]
+		public async Task CommandBehaviorCloseConnection(string connectionString)
+		{
+			using (var connection = new MySqlConnection(AppConfig.ConnectionString + ";" + connectionString))
+			using (new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))
+			{
+				using (var command1 = new MySqlCommand("SELECT 1"))
+				using (var command2 = new MySqlCommand("SELECT 2"))
+				{
+					command1.Connection = connection;
+					command2.Connection = connection;
+
+					await connection.OpenAsync();
+					using (var reader = await command1.ExecuteReaderAsync(CommandBehavior.CloseConnection, CancellationToken.None))
+					{
+						Assert.True(await reader.ReadAsync());
+						Assert.Equal(1, reader.GetInt32(0));
+						Assert.False(await reader.ReadAsync());
+					}
+
+					Assert.Equal(ConnectionState.Closed, connection.State);
+
+					await connection.OpenAsync();
+					using (var reader = await command2.ExecuteReaderAsync(CommandBehavior.CloseConnection, CancellationToken.None))
+					{
+						Assert.True(await reader.ReadAsync());
+						Assert.Equal(2, reader.GetInt32(0));
+						Assert.False(await reader.ReadAsync());
+					}
+				}
+			}
+		}
+
 		[SkippableFact(Baseline = "Multiple simultaneous connections or connections with different connection strings inside the same transaction are not currently supported.")]
 		public void CommitTwoTransactions()
 		{
@@ -746,7 +782,7 @@ void UseTransaction()
 			{
 				// This TransactionScope may be overly configured, but let's stick with the one I am actually using
 				using (var transactionScope = new TransactionScope(TransactionScopeOption.Required,
-					new TransactionOptions { IsolationLevel = IsolationLevel.ReadCommitted },
+					new TransactionOptions { IsolationLevel = System.Transactions.IsolationLevel.ReadCommitted },
 					TransactionScopeAsyncFlowOption.Enabled))
 				{
 					using (var connection = new MySqlConnection(connectionString))