GridReader should respect no-cache flags

Dapper NET40/SqlMapper.cs

@@ -1513,7 +1513,7 @@ private static GridReader QueryMultipleImpl(this IDbConnection cnn, ref CommandD
                 cmd = command.SetupCommand(cnn, info.ParamReader);
                 reader = cmd.ExecuteReader(wasClosed ? CommandBehavior.CloseConnection | CommandBehavior.SequentialAccess : CommandBehavior.SequentialAccess);
 
-                var result = new GridReader(cmd, reader, identity, command.Parameters as DynamicParameters);
+                var result = new GridReader(cmd, reader, identity, command.Parameters as DynamicParameters, command.AddToCache);
                 cmd = null; // now owned by result
                 wasClosed = false; // *if* the connection was closed and we got this far, then we now have a reader
                 // with the CloseConnection flag, so the reader will deal with the connection; we
@@ -4099,13 +4099,15 @@ public partial class GridReader : IDisposable
             private IDataReader reader;
             private IDbCommand command;
             private Identity identity;
+            private bool addToCache;
 
-            internal GridReader(IDbCommand command, IDataReader reader, Identity identity, SqlMapper.IParameterCallbacks callbacks)
+            internal GridReader(IDbCommand command, IDataReader reader, Identity identity, SqlMapper.IParameterCallbacks callbacks, bool addToCache)
             {
                 this.command = command;
                 this.reader = reader;
                 this.identity = identity;
                 this.callbacks = callbacks;
+                this.addToCache = addToCache;
             }
 
 #if !CSHARP30
@@ -4159,7 +4161,7 @@ private IEnumerable<T> ReadImpl<T>(Type type, bool buffered)
                 if (reader == null) throw new ObjectDisposedException(GetType().FullName, "The reader has been disposed; this can happen after all data has been consumed");
                 if (consumed) throw new InvalidOperationException("Query results must be consumed in the correct order, and each result can only be consumed once");
                 var typedIdentity = identity.ForGrid(type, gridIndex);
-                CacheInfo cache = GetCacheInfo(typedIdentity, null, true);
+                CacheInfo cache = GetCacheInfo(typedIdentity, null, addToCache);
                 var deserializer = cache.Deserializer;
 
                 int hash = GetColumnHash(reader);

Dapper NET45/SqlMapperAsync.cs

@@ -539,7 +539,8 @@ private static IEnumerable<T> ExecuteReaderSync<T>(IDataReader reader, Func<IDat
         partial class GridReader
         {
             CancellationToken cancel;
-            internal GridReader(IDbCommand command, IDataReader reader, Identity identity, DynamicParameters dynamicParams, CancellationToken cancel) : this(command, reader, identity, dynamicParams)
+            internal GridReader(IDbCommand command, IDataReader reader, Identity identity, DynamicParameters dynamicParams, bool addToCache, CancellationToken cancel)
+                : this(command, reader, identity, dynamicParams, addToCache)
             {
                 this.cancel = cancel;
             }
@@ -593,7 +594,7 @@ private Task<IEnumerable<T>> ReadAsyncImpl<T>(Type type, bool buffered)
                 if (reader == null) throw new ObjectDisposedException(GetType().FullName, "The reader has been disposed; this can happen after all data has been consumed");
                 if (consumed) throw new InvalidOperationException("Query results must be consumed in the correct order, and each result can only be consumed once");
                 var typedIdentity = identity.ForGrid(type, gridIndex);
-                CacheInfo cache = GetCacheInfo(typedIdentity, null, true);
+                CacheInfo cache = GetCacheInfo(typedIdentity, null, addToCache);
                 var deserializer = cache.Deserializer;
 
                 int hash = GetColumnHash(reader);
@@ -659,7 +660,7 @@ public static async Task<GridReader> QueryMultipleAsync(this IDbConnection cnn,
                 cmd = (DbCommand)command.SetupCommand(cnn, info.ParamReader);
                 reader = await cmd.ExecuteReaderAsync(wasClosed ? CommandBehavior.CloseConnection | CommandBehavior.SequentialAccess : CommandBehavior.SequentialAccess, command.CancellationToken).ConfigureAwait(false);
 
-                var result = new GridReader(cmd, reader, identity, command.Parameters as DynamicParameters, command.CancellationToken);
+                var result = new GridReader(cmd, reader, identity, command.Parameters as DynamicParameters, command.AddToCache, command.CancellationToken);
                 wasClosed = false; // *if* the connection was closed and we got this far, then we now have a reader
                 // with the CloseConnection flag, so the reader will deal with the connection; we
                 // still need something in the "finally" to ensure that broken SQL still results

DapperTests NET45/Tests.cs

@@ -309,6 +309,34 @@ public void RunSequentialVersusParallelSync()
                 System.Console.WriteLine("Pipeline: {0}ms", watch.ElapsedMilliseconds);
             }
         }
+
+        public void AssertNoCacheWorksForQueryMultiple()
+        {
+            int a = 123, b = 456;
+            var cmdDef = new CommandDefinition(@"select @a; select @b;", new
+            {
+                a, b
+            }, commandType: CommandType.Text, flags: CommandFlags.NoCache);
+
+            int c, d;
+            Dapper.SqlMapper.PurgeQueryCache();
+            int before = Dapper.SqlMapper.GetCachedSQLCount();
+            using (var sqlConnection = Program.GetOpenConnection(true))
+            {
+                using (var multi = sqlConnection.QueryMultiple(cmdDef))
+                {
+                    c = multi.Read<int>().Single();
+                    d = multi.Read<int>().Single();
+                }
+            }
+            int after = Dapper.SqlMapper.GetCachedSQLCount();
+            before.IsEqualTo(0);
+            after.IsEqualTo(0);
+            c.IsEqualTo(123);
+            d.IsEqualTo(456);
+
+
+        }
         class Product
         {
             public int Id { get; set; }