查询语法中的异步方法

Question

我学习了asp.net身份，async/await，遇到了这个问题：

我有一些IEnumerable<T> list 的功能。我使用查询语法填写的这个列表如下所示：

private IEnumerable<SomeModel> GetPersons(int categoryId) {
IEnumerable<SomeModel> persons = from g in db.Categories
                               join c in db.Persons on g.PersonTypeId equals c.PersonTypeId
                               where g.CategoryId == categoryId
                               select new SomeModel
                               {
                                   PersonName = c.FirstName + " " + c.LastName,
                                   //....etc.
                                   //And here I need call asynchronous function something like this:
                                   IsAdmin = GetPermission(c.Email)
                               }
    if (persons.Any()) {
        return persons;
    }

    return Enumerable.Empty<SomeModel>();
}

在 SomeModel 中将 IsAdmin 设为 bool（当我在 GetPermission 中尝试 Task<bool> 时，我在 SomeModel 中使用 Task<bool>）。 在GetPermission() 中是这样的：

private bool GetPermission(string email) {
    var user = SomeMembershipService.GetUser(email); //SomeMembershipService is Interface with Tasks and so on.
    var roles = SomeMembershipService.GetRoles(user.Id); //user.Id is as string
    bool result = false;
    if (roles != null) {
        var adm = roles.Result.FirstOrDefault(x => x.Name.Contains("Admin"));
        result = adm != null;
    }
    return result;
}

我尝试使用 async/await 和作为 Task 进行写入，但我的两次尝试都是错误的。所以我认为我必须在IEnumerable<SomeModel> persons 之外调用GetPermission()，所以我将这段代码添加到条件之后。所以代码看起来像这样：

private IEnumerable<SomeModel> GetPersons(int categoryId) {
    IEnumerable<SomeModel> persons = from g in db.Categories
                                   join c in db.Persons on g.PersonTypeId equals c.PersonTypeId
                                   where g.CategoryId == categoryId
                                   select new SomeModel
                                   {
                                       PersonName = c.FirstName + " " + c.LastName
                                       //....etc.
                                   }
    if (persons.Any()) 
    {
        //new code
        foreach (var p in persons) 
        {
            p.IsAdmin = GetPermission(p.Email);
        }
        //end of new code
        return persons;
    }

    return Enumerable.Empty<SomeModel>();
}

但这也是错误的。也许我对 asp.net 身份和 async/await 以及它们的使用理解不好...... 你能帮我吗 - 我必须做什么？因为现在，GetPermission 被调用太晚了，所以应用程序崩溃了。当我在人员查询中调用GetPermission 时，函数也被调用得太晚（在填写人员列表之后）。我不知道如何继续。

GetUser() 与 public IUser GetUser(string username) 相同，GetRoles() 与 public async Task<IEnumerable<IRole>> GetRoles(string userId) 相同。我敢肯定，这两种方法都可以正常工作，我在其他代码中使用它们并且没有问题。所以我认为它必须在上面的代码中。

很抱歉，如果这是个愚蠢的问题，但我在此处和 msdn 上阅读了很多内容，但找不到结果。谢谢大家。

---

为什么我要像上面那样使用异步函数

我想要那里的函数，因为当我将整个函数作为异步任务时，另一个调用它的函数不能正常工作。

我有这个功能 - 它是 kendogrid () 的数据绑定：

[HttpPost]
public ActionResult _PersonsBinding([DataSourceRequest]DataSourceRequest request, int id)
{
    DataSourceResult result = GetPersons(id).ToDataSourceResult(request);
    return Json(result);
}

当我将函数 IEnumerable<SomeModel> GetPersons 设为 async Task<IEnumerable<SomeModel>> GetPersons 时，绑定函数不知道 ToDataSourceResult()，当我将此函数设为异步时。如果这里有问题，我该如何解决？ 请耐心等待我，我是新手...

Answer 1

您的问题不在于异步/等待。您的问题是因为您执行的查询不止一个。每个 foreach/ToList/ToArray 等都会从头开始执行查询并创建新对象。因为在 linq 内部，结果是通过 `yield return new { .....}' 产生的，并且会创建新对象。这就是为什么您在下一次 foreach 中丢失 IsAdmin 位的原因。 （方法外）

if (persons.Any()) 
{
    // !HERE! <- foreach. this will run the query.
    foreach (var p in persons) 
    {
        p.IsAdmin = GetPermission(p.Email);
    }

    //Where you foreach in it's caller.
    return persons;
}

您需要先实现查询。您可以使用 ToArray()/ToList() 解决此问题。这样查询就是执行、迭代和存储为数组的查询。

private IEnumerable<SomeModel> GetPersons(int categoryId) 
{
    IEnumerable<SomeModel> persons = (from g in db.Categories
                                     join c in db.Persons on g.PersonTypeId equals c.PersonTypeId
                                     where g.CategoryId == categoryId
                                     select new SomeModel
                                     {
                                        PersonName = c.FirstName + " " + c.LastName
                                        //....etc.
                                     }).ToArray();   // <------ here
    foreach (var p in persons) 
    {
        p.IsAdmin = GetPermission(p.Email);
    }

    //end of new code
    return persons;
}

如果你想结合GetPermission()和查询，你应该创建一个SQL-Function。

Answer 2

好的，我解决了。 上面的代码中没有错误，问题出在async Task<IEnumerable<IRole>> GetRoles(string userId) 中。这种方法效果很好，但对我上面的代码不好。

异步获取角色如下所示：

public async Task<IEnumerable<IRole>> GetRolesAsync(string userId)
{
    return await IdentityManager.Roles.GetRolesForUserAsync(userId);
}

但我必须使用以下代码中的获取角色。 我在 IMembershipService 中创建了新方法 - public IEnumerable<IRole> GetRoles(string userId)（第一个方法重命名为 GetRolesAsync），如下所示：

public IEnumerable<IRole> GetRoles(string userId)
{
    return AsyncHelper.RunSync(() => IdentityManager.Roles.GetRolesForUserAsync(userId));
} 

这将返回常见的IEnumerable<T>。至少我可以在 sql 查询中使用我的函数 GetPermissions。 GetPermission() 现在看起来像这样：

private bool GetPermission(string email) {
    var user = SomeMembershipService.GetUser(email); 
    var roles = SomeMembershipService.GetRoles(user.Id);

    bool result = false;
    if (roles != null) {
        var adm = roles.FirstOrDefault(x => x.Name.Contains("Admin"));
        result = adm != null;
    }
    return result;
}

在 sql 查询中我现在可以使用这个：

....
select new SomeModel
                               {
                                   PersonName = c.FirstName + " " + c.LastName,
                                   IsAdmin = GetPermission(c.Email) // <-- This
                               }
....

感谢所有人，尤其是 Jeroen，他试图提供帮助。