我正在尝试 dapper 中的异步支持,并且在运行一个简单的用例时遇到了以下问题。我有一个 ApiController ,它使用 dapper 触发日志条目以在数据库中创建它。我的数据库连接很好。当我使用 dapper 的 Query 扩展方法运行同步版本时,一切正常。当我将 QueryAsync 与 async/await 结构一起使用时,我得到一个 InvalidOperationException。这是代码的样子
public class BackgroundController : ApiController
{
[HttpGet]
public async Task<HttpResponseMessage> Run(string op)
{
using (var connection = new SqlConnection(ConfigurationManager.ConnectionStrings["Backgrounder"].ConnectionString))
{
const string sql =
"Insert Into SimpleLog (message, threadid, created) Values(@message, @threadid, @created); " +
"SELECT CAST(SCOPE_IDENTITY() as int)";
var results = await (connection.QueryAsync<int>(sql, new { message = "new log record", threadid = "1", created = DateTime.Now }));
var id = results.SingleOrDefault();
Debug.WriteLine("inserted log record id: " + id);
}
return this.Request.CreateResponse(HttpStatusCode.OK);
}
}
此外,堆栈跟踪如下所示:
在 System.Data.SqlClient.SqlCommand.b_ 24(Task 1 result)
at System.Threading.Tasks.ContinuationResultTaskFromResultTask
2.InnerInvoke() at System.Threading.Tasks.Task.Execute() --- 从先前抛出异常的位置结束堆栈跟踪---在 System. Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() 在 System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task) 在 System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task) 在 System.Runtime.CompilerServices.TaskAwaiter.ValidateEnd(Task task ) 在 System.Runtime.CompilerServices.TaskAwaiter1.GetResult()
at Dapper.SqlMapper.<QueryAsync>d__69
1.MoveNext() in c:\Dev\Dapper\Dapper NET45\SqlMapperAsync.cs:line 21 --- 从先前抛出异常的位置结束堆栈跟踪---在 System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw( ) 在 System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task) 在 System.Runtime.CompilerServices 在 System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task) 在 System.Runtime.CompilerServices.TaskAwaiter.ValidateEnd(Task task) 在 System.Runtime.CompilerServices。 WebApiBackgrounder.Controllers.BackgroundController.d _0.MoveNext() 处的TaskAwaiter`1.GetResult()
当 dapper 调用 ExecuteReaderAsync 时,它似乎失败了。有人如何解决这个问题?
编辑
这是连接字符串
<add name="Backgrounder" providerName="System.Data.SqlClient" connectionString="Data Source=LPW7X6530;Initial Catalog=Sandbox;Integrated Security=SSPI;" />