在MySQL 8上使用CTE更新linq2db

问题描述

这个问题是关于linq2db.MysqL 3.1.5和MysqL 8.0.21

按如下所示，尝试在MysqL上使用CTE运行更新（标记重复的电子邮件）时，出现“您的sql语法有错误...”

                var cte = (
                        from x in db.GetTable<PEmailCleanupJobItem>()
                        group x by x.EmailAddress into eGroup
                        where eGroup.Count() > 1
                        select new { EmailAddress = eGroup.Key }
                ).AsCte();

                var qry = (
                    from e in db.GetTable<PEmailCleanupJobItem>()
                    from d in cte
                        .InnerJoin(d => e.EmailAddress == d.EmailAddress)
                    select e
                );

                await qry
                    .Set(e => e.IsDuplicate,true)
                    .UpdateAsync();

这将生成以下内容并将其发送到MysqL

--  MysqL.Official MysqL (asynchronously)
DECLARE @IsDuplicate UByte -- Boolean
SET     @IsDuplicate = 1

UPDATE `CTE_1` (`EmailAddress`)
AS
(
        SELECT
                `t1`.`email_address`
        FROM
                `emails` `t1`
        GROUP BY
                `t1`.`email_address`
        HAVING
                Count(*) > 1
)
FROM
        `emails` `d`
                INNER JOIN `CTE_1` `e` ON (`d`.`email_address` IS NULL AND `e`.`EmailAddress` IS NULL OR `d`.`email_address` = `e`.`EmailAddress`)
SET
        `d`.`is_duplicate` = @IsDuplicate

注意如何生成UPDATE `CTE_1` (`EmailAddress`)而不是WITH `CTE_1` (`EmailAddress`)

我将手动编写此查询（有效）为

WITH `CTE_1` (`EmailAddress`)
AS
(
        SELECT
                `t1`.`email_address`
        FROM
                `emails` `t1`
        GROUP BY
                `t1`.`email_address`
        HAVING
                Count(*) > 1
)
UPDATE 
    `emails` `d`
            INNER JOIN `CTE_1` `e` ON (`d`.`email_address` IS NULL AND `e`.`EmailAddress` IS NULL OR `d`.`email_address` = `e`.`EmailAddress`)
SET
    `d`.`is_duplicate` = 1

这是linq2db的错误，还是我缺少什么？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）