59

I'm using Dapper 1.31 from Nuget. I have this very simple code snippet,

string connString = "";
string query = "";
int val = 0;
CancellationTokenSource tokenSource = new CancellationTokenSource();
using (IDbConnection conn = new SqlConnection(connString))
{
    conn.Open();
    val = (await conn.QueryAsync<int>(query, tokenSource.Token)).FirstOrDefault();
}

When I press F12 on QueryAsync, it points me to

public static Task<IEnumerable<T>> QueryAsync<T>
     (
        this IDbConnection cnn, 
        string sql, 
        dynamic param = null, 
        IDbTransaction transaction = null, 
        int? commandTimeout = null, 
        CommandType? commandType = null
     );

There is no CancellationToken on its signature.

Questions:

  • Why is the snippet completely buildable assuming that there is no compiler error on the whole solution?
  • Forgive me that I cannot test if calling tokenSource.Cancel() would really cancel the method because I don't know how to generate a long running sql query. Will the .Cancel() really cancel the method and throw OperationCancelledException?

Thank you!

1
  • 1
    dynamic param will take pretty much anything. What you're doing is kind of like passing a cancellation token as a parameter to Console.WriteLine(string, params object[]). Just because you can pass it doesn't mean the function supports cancellation. Aug 28, 2014 at 4:46

4 Answers 4

103

You are passing the cancellation token as the parameter object; that won't work.

The first async methods in dapper did not expose a cancellation token; when I tried to add them as an optional parameter (as a separate overload, to avoid breaking existing assemblies), things got very confused with "ambiguous method" compilation problems. Consequently, I had to expose this via a separate API; enter CommandDefinition:

val = (await conn.QueryAsync<int>(
    new CommandDefinition(query, cancellationToken: tokenSource.Token)
).FirstOrDefault();

This then passes the cancellation-token down the chain to all the expected places; it is the job of the ADO.NET provider to actually use it, but; it seems to work in most cases. Note that it can result in a SqlException rather than an OperationCancelledException if the operation is in progress; this again is down to the ADO.NET provider, but makes a lot of sense: you could have interrupted something important; it surfaces as a critical connection issue.

As for the questions:

Why is the snippet completely buildable assuming that there is no compiler error on the whole solution?

Because... it is valid C#, even if it doesn't do what you expect.

Forgive me as I cannot test if calling tokenSource.Cancel() would really cancel the method because I don't know how to generate long running sql query. Will the .Cancel() really cancels the method and throws OperationCancelledException?

ADO.NET provider-specific, but yes it usually works. As an example of "how to generate long running sql query"; the waitfor delay command on SQL server is somewhat useful here, and is what I use in the integration tests.

10
  • 1
    This is a great answer from the author itself. Thanks Marc for the alternative API! Well, I'm fine with catching SqlException rather than OperationCancelledException, I will handle the logic here. Thanks again!
    – Pedigree
    Aug 30, 2014 at 7:34
  • 1
    @Pedigree I think I've also figured out how to make it work correctly in the primary API too. Aug 30, 2014 at 8:18
  • 1
    @Pedigree it is standard in library code; it means it doesn't need to go to the sync-context - it doesn't depend on anything like adp.net context etc. Library code should almost always use it; application code usually should use sync-context, so should usually omit it. In fact, if library code forgets to do this, it can sometimes cause hard deadlocks (depending on what the calling application code does) Aug 30, 2014 at 11:44
  • 1
    @Pedigree in the next release of dapper, cancellationToken may be available on the original API; but today: it isn't Sep 5, 2014 at 10:48
  • 1
    @Pedigree that is a question for ADO.NET; as I already mentioned, it may surface as SqlException if the operation was in progress Sep 5, 2014 at 10:53
-1

You can fix SqlMapper.cs in Dapper lib by adding these lines:

    internal IDbCommand SetupCommand(IDbConnection cnn, Action<IDbCommand, object> paramReader)
    {
        var cmd = cnn.CreateCommand();

#if ASYNC
        // We will cancel our IDbCommand
        CancellationToken.Register(() => cmd.Cancel());
#endif

Rebuild your own Dapper lib and enjoy :)

1
  • 17
    .. and then maintain it when the Upstream accepts commits with new features/bugfixes...
    – Pure.Krome
    Apr 18, 2019 at 4:34
-1

try using a SqlConnection and catch the exception on cancel

var sqlConn = db.Database.Connection as SqlConnection;
sqlConn.Open();

_cmd = new SqlCommand(textCommand, sqlConn);
_cmd.ExecuteNonQuery();

and cancel the SqlCommand

_cmd.Cancel();
-4

I was using one SqlConnection for multiple threads. And then when I changed it so that each Thread created it's own SqlConnection the error disappeared.

Your Answer

By clicking “Post Your Answer”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Not the answer you're looking for? Browse other questions tagged or ask your own question.