如何在 Web Api 控制器 c# 中使用 Async/await 任务连接数据库并返回值

Question

您好，我正在尝试连接数据库并从 Web api 控制器返回值。如果可能的话，我想一直与新任务异步执行以获得更好的性能。这是我所做的一个示例.我这样做的方式是否正确？我是否使用正确的 using 语句？在 Open、Close 连接和 sda.FillAsync 中的等待是否正确？谢谢！

 public async Task<HttpResponseMessage> Get()
 {
   return await Task.Run(() => GetAllCustomers());
 }

    private async Task <HttpResponseMessage> GetAllCustomers()
    {
        DataTable Customers= new DataTable();

        using (MySqlConnection con = new MySqlConnection(""))
        using (MySqlCommand cmd = new MySqlCommand("SELECT * FROM Customers", con))
        {
            try
            {
                if (con.State == ConnectionState.Closed)
                {
                    await con.OpenAsync();
                    cmd.CommandType = CommandType.Text;
                    MySqlDataAdapter sda = new MySqlDataAdapter(cmd);
                    await sda.FillAsync(Customers);
                }
            }

            catch (MySqlException ex)
            {
                ex.Message.ToString();
            }
            finally
            {
                await con.CloseAsync();
            }
        }
        return ControllerContext.Request
       .CreateResponse(HttpStatusCode.OK, new { Customers });
    }

Answer 1

替换

return await Task.Run(() => GetAllCustomers());

与

return await GetAllCustomers();

您不需要显式运行服务任务（控制器方法已经标记为async）。

将 GetAllCustomers 重命名为 GetAllCustomersAsync（最佳实践命名约定）

我更喜欢这样编写 WebApis：

public async Task<IHttpActionResult> Get() 
{
    try 
    {
         var result = await GetAllCustomersAsync();
         return Ok(result);
    }
    catch(Exception ex) 
    {
        return InternalServerError(ex);
    }
}

更新： 显示如何简化数据库操作的更新：

private async Task<Customers> GetAllCustomersAsync()
{
   var customers = new DataTable();
   using (var con = new MySqlConnection(""))
   using (var cmd = new MySqlCommand("SELECT * FROM Customers", con))
   {
       await con.OpenAsync();
       cmd.CommandType = CommandType.Text;
       var sda = new MySqlDataAdapter(cmd);
       await sda.FillAsync(customers);
   }
   return customers;
}