consistent changes with DapperLib/Dapper#2121

Author: mgravell

src/Dapper.AOT/Internal/AsyncCommandState.cs

@@ -37,6 +37,8 @@ const int
         [MemberNotNull(nameof(Command))]
         public Task<DbDataReader> ExecuteReaderAsync(DbCommand command, CommandBehavior flags, CancellationToken cancellationToken)
         {
+            flags &= ~(CommandBehavior.SingleResult | CommandBehavior.SingleRow); // correctness; these can mask trailing error data
+
             var pending = OnBeforeExecuteAsync(command, cancellationToken);
             return pending.IsCompletedSuccessfully() ? command.ExecuteReaderAsync(flags, cancellationToken)
                 : Awaited(pending, command, flags, cancellationToken);
@@ -113,6 +115,19 @@ static async Task<int> Awaited(Task pending, DbCommand command, CancellationToke
             }
         }
 
+        public void CancelCommand()
+        {
+            try
+            {
+                Command?.Cancel();
+            }
+            catch (Exception ex)
+            {
+                // do not lose any existing exception
+                Debug.WriteLine(ex.Message);
+            }
+        }
+
         public virtual ValueTask DisposeAsync()
         {
             var cmd = Command;

src/Dapper.AOT/Internal/AsyncQueryState.cs

@@ -82,6 +82,8 @@ public override ValueTask DisposeAsync()
             Return();
             if (Reader is not null)
             {
+                CancelCommand();
+
 #if NETCOREAPP3_1_OR_GREATER
                 var pending = Reader.DisposeAsync();
                 if (pending.IsCompletedSuccessfully)
@@ -98,11 +100,14 @@ public override ValueTask DisposeAsync()
             }
             return base.DisposeAsync();
         }
+
+#if NETCOREAPP3_1_OR_GREATER
         private async ValueTask DisposeAsync(ValueTask pending)
         {
             await pending;
             await base.DisposeAsync();
         }
+#endif
 
         public override void Dispose()
         {

src/Dapper.AOT/Internal/SyncCommandState.cs

@@ -1,4 +1,5 @@
-using System.Data;
+using System;
+using System.Data;
 using System.Data.Common;
 using System.Diagnostics;
 using System.Diagnostics.CodeAnalysis;
@@ -28,6 +29,8 @@ const int
         [MemberNotNull(nameof(Command))]
         public DbDataReader ExecuteReader(DbCommand command, CommandBehavior flags)
         {
+            flags &= (CommandBehavior.SingleResult | CommandBehavior.SingleRow); // correctness; these can mask trailing error data
+
             OnBeforeExecute(command);
             return command.ExecuteReader(flags);
         }
@@ -58,6 +61,19 @@ public int ExecuteNonQuery(DbCommand command)
             return command.ExecuteNonQuery();
         }
 
+        public void CancelCommand()
+        {
+            try
+            {
+                Command?.Cancel();
+            }
+            catch (Exception ex)
+            {
+                // do not lose any existing exception
+                Debug.WriteLine(ex.Message);
+            }
+        }
+
         public void Dispose()
         {
             var cmd = Command;

src/Dapper.AOT/Internal/SyncQueryState.cs

@@ -31,7 +31,11 @@ public ValueTask DisposeAsync()
         public void Dispose()
         {
             Return();
-            Reader?.Dispose();
+            if (Reader is not null)
+            {
+                commandState.CancelCommand();
+                Reader.Dispose();
+            }
             commandState.Dispose();
         }
 

test/Dapper.AOT.Test/Integration/BatchPostgresql.cs

@@ -7,7 +7,7 @@ namespace Dapper.AOT.Test.Integration;
 [Collection(SharedPostgresqlClient.Collection)]
 public class BatchPostgresql
 {
-    private PostgresqlFixture _fixture;
+    private readonly PostgresqlFixture _fixture;
 
     public BatchPostgresql(PostgresqlFixture fixture)
     {