c# - EF.Core 3.x生成窗口函数而不是JOIN,导致MySQL语法错误

标签 c# entity-framework-core window-functions ef-core-3.0 pomelo-entityframeworkcore-mysql

运行以下 EF Core 查询:

var groupData = await _dbContext.Groups.AsNoTracking()
    .Where(g => g.Id == groupId)
    .Select(g => new
    {
        /* ...some other fields are queried here... */
        ActiveLab = g.ActiveLabs.FirstOrDefault(al => al.LabId == labId)
    })
    .FirstAsync(cancellationToken);

导致此错误:

MySqlException: You have an error in your SQL syntax; check the manual that corresponds to your
MySQL server version for the right syntax to use near
'(PARTITION BY `l`.`GroupId` ORDER BY `l`.`GroupId`, `l`.`LabId`) AS `row`'
at line 6

检查生成的 SQL 会发现 EF 由于某种原因插入了 PARTITION 指令:

SELECT `g`.`Name`, `t0`.`GroupId`, `t0`.`LabId`, `t0`.`StartTime`
FROM `Groups` AS `g`
LEFT JOIN (
    SELECT `t`.`GroupId`, `t`.`LabId`, `t`.`StartTime`
    FROM (
        SELECT `l`.`GroupId`, `l`.`LabId`, `l`.`StartTime`, ROW_NUMBER() OVER(PARTITION BY `l`.`GroupId` ORDER BY `l`.`GroupId`, `l`.`LabId`) AS `row`
        FROM `ActiveLabs` AS `l`
        WHERE `l`.`LabId` = @__labId_1
    ) AS `t`
    WHERE `t`.`row` <= 1
) AS `t0` ON `g`.`Id` = `t0`.`GroupId`
WHERE `g`.`Id` = @__groupId_0
LIMIT 1

我宁愿期待这样的查询:

SELECT `g`.`Name`, `l`.`GroupId`, `l`.`LabId`, `l`.`StartTime`
FROM `Groups` AS `g`
LEFT JOIN `ActiveLabs` AS `l`
ON `l`.`GroupId` = `g`.`Id`
WHERE `l`.`LabId` = @__labId_1 AND `g`.`Id` = @__groupId_0
LIMIT 1

为什么 EF 会生成如此复杂的查询,而 ActiveLabs 上的简单 JOIN 就足够了?

我正在使用 EF Core 3.1.2、Pomelo MySQL 3.1.1 和 MySQL 5.7.14 进行测试。


我的数据库如下所示:我有两个表

+----+--------+
| Id |  Name  |
+----+--------+
|  1 | Group1 |
|  2 | Group2 |
+----+--------+

ActiveLabs

+---------+-------+----------------------------+
| GroupId | LabId |         StartTime          |
+---------+-------+----------------------------+
|       1 |     1 | 2020-03-01 00:00:00.000000 |
|       2 |     1 | 2020-03-01 00:00:00.000000 |
|       1 |     2 | 2020-03-08 00:00:00.000000 |
+---------+-------+----------------------------+

后者代表多对多关系,它跟踪哪个实验室对哪个组活跃。因此,Group 对象具有导航属性 ActiveLabs,它指向该组的事件实验室。类/表结构和外键是正确的,并且在所有用例中都运行良好。


编辑: 看起来 MySQL 5.7.14 根本不支持 PARTITION(related issue 在 Pomelo 的 GitHub 存储库上)。升级到 MySQL 8.0 消除了错误消息,查询现在可以工作了;但是,我仍然不明白为什么 EF 会生成 PARTITION(窗口函数)语句

最佳答案

实际上,EF Core 根据您的 LINQ 查询生成了正确的 SQL,并且做得非常好。

为了更接近预期的 SQL,您可以按以下方式重写此查询:

var query = 
    from g in _dbContext.Groups
    from al in g.ActiveLabs
    where g.Id == groupId && al.LabId == labId
    select new 
    {
        /* ...some other fields are queried here... */
        ActiveLab = al
    };

var groupDate = await query.FirstAsync(cancellationToken);

稍微解释一下它是如何工作的

它可能不是直接的 EF Core 翻译技术,但它可以非常相似

首先,翻译器生成您定义的所有需要​​的连接 - 将其称为主查询。然后,在投影生成(选择)过程中,Translator 发现您已向一些相关实体请求了 FirstOrDefault。但是主查询已经定义了,我们可以做些什么来选择第一个子查询并且不损害主查询结果 - 使 OUTER APPLY JOIN 到有限的记录集。但是OUTER APPLY JOIN的效果不是那么好,所以我们可以尝试将OUTER APPLY JOIN转换为LEFT JOIN。对于这种特定情况,可以使用窗口函数轻松完成 - 瞧。

关于c# - EF.Core 3.x生成窗口函数而不是JOIN,导致MySQL语法错误,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/60854920/

相关文章:

c# - Microsoft.ReportViewer.*.dll 未出现在引用中(v11 或 12)

c# - 为什么这些枚举不好

c# - Desalinizing 初始化列表

c# - 如何使 MySql 和 EF Core 将 tinyint 或 bit 映射到 bool 值?

c# - 从页面绑定(bind)到窗口

c# - 具有依赖注入(inject)的 EF core DbContext

.net-core - 如何测试我的模型是否已更改并需要迁移?

sql-server - 递归查询使用初始查询中返回的日期作为后续查询中的限制

sql - 如何将前向填充作为 PL/PGSQL 函数

java - 在 Apache Spark SQL 中对多行进行操作