如何在 C# 中使用 async 和 await 调用存储过程

Question

我正在使用 Visual Studio 2015 社区版和 MVC 5，实体框架 6。我刚刚学会了如何使用 async 和 await 进行异步调用。

现在在我的项目中，我只有 CRUD 操作，并且对于所有操作，我都编写了存储过程，除了调用存储过程之外，我的 API 中没有更多的业务逻辑。所以我使用 async 和 await 来调用存储过程。

但是这样做，我得到了错误，

'int' does not contain a definition for 'GetAwaiter' and no extension method 'GetAwaiter' accepting a first argument of type 'int' could be found (are you missing a using directive or an assembly reference?)

我的代码是，

 [HttpPost]
        public async Task<IHttpActionResult> AddContactEmails(Contacts data)
        {
            using (JodoDataEntities DB = new JodoDataEntities())
            {
                int Result = await DB.AddContacts(data.userId, data.data);
                return Ok();
            }
        }

我的存储过程非常简单，我从中返回任何东西，仍然 EF 将其作为 int 返回类型。

ALTER PROCEDURE [dbo].[AddContacts]
    @userId nvarchar(128),
    @contacts nvarchar(MAX)
AS
BEGIN
    SET NOCOUNT ON;
    if not exists(select top 1 * from Contacts where userId = @userId)
    begin
        insert into Contacts (userId, contacts) VALUES (@userId, @contacts)
    end
END

EF 代码（自动生成），

 public virtual int AddContacts(string userId, string contacts)
        {
            var userIdParameter = userId != null ?
                new ObjectParameter("userId", userId) :
                new ObjectParameter("userId", typeof(string));

            var contactsParameter = contacts != null ?
                new ObjectParameter("contacts", contacts) :
                new ObjectParameter("contacts", typeof(string));

            return ((IObjectContextAdapter)this).ObjectContext.ExecuteFunction("AddContacts", userIdParameter, contactsParameter);
        }

1)。为什么我在调用方法时收到此错误？

2)。我需要在哪里进行更改才能使其正常工作？

3)。所以当我的 API 中只有 SP 调用时，我真的需要使用 async 和 await 吗？

Answer 1

如果返回Task<int>：

DB.AddContacts(...);

然后this简单地返回一个int：

await DB.AddContacts(...);

所以Result 变量的类型应该是int，而不是Task<int>。

---

编辑：我刚刚注意到您的问题中AddContacts() 的定义。这不是async 方法，所以不能等待。您的代码中没有 async 操作。只需完全删除 async 和 await 尝试，这是同步代码...

int Result = DB.AddContacts(...);

---

顺便说一句，这是个坏主意：

catch (Exception ex)
{
    throw ex;
}

它基本上是在丢弃有用的调试信息。只需完全删除 try/catch 构造，并让最初抛出它的操作抛出异常。