使用相同的SQL生成输出将T-SQL转换为Fluent Linq C#

Question

我在我的数据库中有以下架构:

关键是要为每个用户提供他每个线程的最后一次读取日期时间.

如果需要,我还可以通过论坛和Universe查看此日期并进行汇总.

一个论坛被认为是Read,如果所有线程都Read.

如果用户的数量大于或等于上次创建的发布日期(来自),则考虑使用线程.ReadLastviewPost.CreatedAt

我已经发出以下T-SQL请求来实现每个论坛的目标:

SELECT
        F.Id,
        CASE WHEN SUM(V.IsRead) = COUNT(V.IsRead) THEN 1 ELSE 0 END AS IsRead
    FROM Forum F
    LEFT JOIN Thread T ON T.Id_Forum = F.Id
    LEFT JOIN
    (
        SELECT
                P.Id_Thread,
                CASE WHEN MAX(P.CreatedAt) < MAX(V.LastView) THEN 1 ELSE 0 END AS IsRead
            FROM Post P
            INNER JOIN Thread T ON P.Id_Thread = T.Id
            INNER JOIN Forum F ON T.Id_Forum = F.Id
            LEFT JOIN Thread_View V ON P.Id_Thread = V.Id_Thread AND V.Id_User = @Id_User
        WHERE F.Id_Universe = @Id_Universe
        GROUP BY P.Id_Thread
    ) V ON T.Id = V.Id_Thread
WHERE F.Id_Universe = @Id_Universe
GROUP BY F.Id
ORDER BY F.Id

它的工作原理perferctly,但我现在要创建这个请求Linq使用EntityFramework......而且我卡...

这是我所做的,但它产生了一个非常复杂的查询,我害怕性能......

var viewsQuery = context.Posts
    .Where(p => p.Thread.Forum.Id_Universe == idUniverse)
    .GroupJoin
    (
        context.Thread_Views.Where(v => v.Id_User == idUser),
        p => p.Id_Thread,
        v => v.Id_Thread,
        (p, v) => new { Id_Thread = p.Id_Thread, Id_Forum = p.Thread.Id_Forum, CreatedAt = p.CreatedAt, LastView = v.Max(_v => _v.LastView) }
    )
    .Select(r => new { Id_Thread = r.Id_Thread, Id_Forum = r.Id_Forum, IsRead = r.CreatedAt < r.LastView });

var forumQuery = context.Forums.Where(f => f.Id_Universe == idUniverse).GroupJoin
(
    viewsQuery.DefaultIfEmpty(),
    forum => forum.Id,
    view => view.Id_Forum,
    (forum, views) => new
    {
        Forum = forum.Id,
        IsRead = views.Any() && views.All(v => v.IsRead),
    }
);

linq生成的SQL输出是这样的(稍微编辑得更易读),它太丑了......

SELECT 
    [Project1].[Id] AS [Id], 
    CASE WHEN 
    (
        (
            EXISTS
            (
                SELECT 
                    1 AS [C1]
                FROM   ( SELECT 1 AS X ) AS [SingleRowTable1]
                INNER JOIN 
                (
                    SELECT [Extent3].[Id_Forum] AS [Id_Forum], [Extent4].[Id_Universe] AS [Id_Universe]
                    FROM   [dbo].[Post] AS [Extent2]
                    INNER JOIN [dbo].[Thread] AS [Extent3] ON [Extent2].[Id_Thread] = [Extent3].[Id]
                    INNER JOIN [dbo].[Forum] AS [Extent4] ON [Extent3].[Id_Forum] = [Extent4].[Id] ) AS [Join2] ON 1 = 1
                    WHERE ([Join2].[Id_Universe] = 3) AND ([Project1].[Id] = [Join2].[Id_Forum])
            )
        )
        AND
        (
            NOT EXISTS
            (
                SELECT 
                    1 AS [C1]
                FROM   ( SELECT 1 AS X ) AS [SingleRowTable2]
                INNER JOIN 
                (
                    SELECT 
                        [Project3].[CreatedAt] AS [CreatedAt], 
                        [Project3].[Id_Forum] AS [Id_Forum], 
                        (
                            SELECT  MAX([Extent8].[LastView]) AS [A1]
                            FROM    [dbo].[Thread_View] AS [Extent8]
                            WHERE ([Extent8].[Id_User] = 79775) AND ([Project3].[Id_Thread] = [Extent8].[Id_Thread])
                        ) AS [C1]
                    FROM
                    (
                        SELECT 
                            [Extent5].[Id_Thread] AS [Id_Thread], 
                            [Extent5].[CreatedAt] AS [CreatedAt], 
                            [Extent6].[Id] AS [Id], 
                            [Extent6].[Id_Forum] AS [Id_Forum]
                        FROM   [dbo].[Post] AS [Extent5]
                        INNER JOIN [dbo].[Thread] AS [Extent6] ON [Extent5].[Id_Thread] = [Extent6].[Id]
                        INNER JOIN [dbo].[Forum] AS [Extent7] ON [Extent6].[Id_Forum] = [Extent7].[Id]
                        WHERE [Extent7].[Id_Universe] = 3
                    )  AS [Project3]
                ) AS [Project4] ON 1 = 1
                WHERE
                (
                    (
                        (
                            CASE
                                WHEN ([Project4].[CreatedAt] < [Project4].[C1]) THEN cast(1 as bit)
                                WHEN ( NOT ([Project4].[CreatedAt] < [Project4].[C1])) THEN cast(0 as bit)
                            END
                        ) <> 1
                    )
                    OR
                    (
                        CASE
                            WHEN ([Project4].[CreatedAt] < [Project4].[C1]) THEN cast(1 as bit)
                            WHEN ( NOT ([Project4].[CreatedAt] < [Project4].[C1])) THEN cast(0 as bit)
                        END IS NULL
                    )
                ) AND ([Project1].[Id] = [Project4].[Id_Forum])
            )
        )
    ) THEN cast(1 as bit)
    ELSE cast(0 as bit) END AS [C1]
FROM 
(
    SELECT 
        [Extent1].[Id] AS [Id]
    FROM [dbo].[Forum] AS [Extent1]
    WHERE [Extent1].[Id_Universe] = 3
)  AS [Project1]

编辑:发现一个工作的linq查询具有相同的结果,但它是如此丑陋,我非常害怕性能...

Answer 1

var forumsWhichAreUnread = from forum on context.Forums
                           let isUnRead = forum.Threads.All(thread =>
                                thread.ThreadViews
                                     .Where(view => view.UserId = userId)
                                     .Max(view => view.Lastview)
                                <
                                thread.Posts.Max(post => post.CreatedAt))
                           select new {forum, isUnRead};

翻译

各得其所forum​context.Forums

只给我每个线程的论坛...

最大线程浏览.LastView时间小于最新发布日期。

选择出那些forum.