c# winforms 如何使用 LINQ 使用异步等待

Question

我想使用异步等待功能按年龄分组。没有 aync 等待它工作正常，但我想要 使用异步等待。 如果我在第一行中排除 ToList() ...从 db.Patient.ToList() 中的 u ... 那么我会遇到 CalculateAge 函数的问题 错误 LINQ Entities 在方法 CalculateAge(system.String).. 中无法识别 这就是为什么在那里使用它。 CalculateAge 函数是计算年龄，这里是代码函数

private int CalculateAge(string birthday)
        {
            int age;
            if (string.IsNullOrWhiteSpace(birthday)) return 0;

            DateTime empBirthday = Convert.ToDateTime(birthday);
            DateTime today = DateTime.Today;
            age = today.Year - empBirthday.Year;
            if (empBirthday > today.AddYears(-age))
                age--;
            return age;
        }

没有异步等待也可以正常工作

private void btnByAge_Click(object sender, EventArgs e)
{
    var result = (from u in db.Patient.ToList() // 
                  join a in db.Analys on u.PatientId equals a.PatientId
                  where a.Status == Active
                  group u by CalculateAge(u.DOB.ToString()) into g
                  select new
                  {
                      Age = g.Key,
                      Amount = g.Count(),
                  }).Tolist();

    if (result != null)
    {
        dgvResult.DataSource = result;
    }
}

但异步等待不是这个

private async void btnByAge_Click(object sender, EventArgs e)
{
    var result = (from u in db.Patient.ToListAsync()
                  join a in db.Analys on u.PatientId equals a.PatientId
                  where a.Status == Active
                  group u by CalculateAge(u.DOB.ToString()) into g
                  select new
                  {
                      Age = g.Key,
                      Amount = g.Count(),
                  });

    var data = await result.ToListAsync();
    if (data != null)
    {
        dgvResult.DataSource = data;
    }
}

我得到的错误是错误 CS1936 找不到源类型“任务>”的查询模式的实现。未找到“加入”... 我什至使用过 Using.System.Data.Linq ，但同样的问题。请帮忙，提前谢谢！

Answer 1

修复错误所需要做的就是在db.Patient.ToListAsync() 之前添加一个await。但是，最好不要这样做ToList，以便可以在数据库中完成连接。另请注意，您不需要null 检查，因为结果永远不会是null（可能为空或可能会引发异常，但它们永远不应为空）

var dobs = await (from u in db.Patient
                  join a in db.Analys on u.PatientId equals a.PatientId
                  where a.Status == Active
                  select u.DOB).ToListAsync();
var data = dobs
    .GroupBy(x => CalculateAge(x.toString())
    .Select(grp => new
    {
        Age = grp.Key,
        Amount = grp.Count(),
    })
    .ToList();

dgvResult.DataSource = data;    

这将对状态进行连接和过滤，并选择数据库中的 DOB 并异步获取 DOB。然后您可以在内存中进行分组，因为CalculateAge 无法转换为 SQL。但更好的办法是在数据库中进行年龄计算。

var now = DateTime.UtcNow(); // or .Now() if you don't store UTC in the DB
var result =  from u in db.Patient
              join a in db.Analys on u.PatientId equals a.PatientId
              where a.Status == Active
              let age = now.Year - u.DOB.Year -
                  ((u.DOB.Month < now.Month || 
                      (u.DOB.Month == now.Month && u.DOB.Day < now.Day))
                  ? 1 : 0)
              group u by age into g
              select new
              {
                  Age = g.Key,
                  Amount = g.Count(),
              };

dgvResult.DataSource = await result.ToListAsync();    

通过从当前年份减去 DOB 年份来确定年龄，如果当前日期在 DOB 的月份和日期之前，则减去 1。

此外，如果您打算使用CalculateAge，则只需将DateTime 传递给它，而不是将其格式化为string，然后将其解析回DateTime。如果可能是null，您可以传递DateTime?。

private int CalculateAge(DateTime? birthday)
{
    int age;
    if (!birthday.HasValue) return 0;

    DateTime today = DateTime.Today;
    age = today.Year - birthday.Value.Year;
    if (birthday.Value > today.AddYears(-age))
        age--;
    return age;
}

Answer 2

没有什么特别的，你可以用 C# 来实现这个代码，看看下面的代码。

private async void button1_Click(object sender, EventArgs e)
    {
        var query = (from p in db.Patient
                     join An in db.Analys on p.PatientId equals An.PatientId
                     where An.Status == Active
                     select p.DOB)



       var Result=await query.GroupBy(x => CalculateAge(x.toString())
           .Select(g => new {
               Age = g.Key,
               Amount = g.Count(),
           }).ToListAsync();
 dgvResult.DataSource = Result
    }