Mar*_*tin 9 sql paging linq-to-sql
我一直在使用LINQ To SQL的.Skip()和.Take()扩展方法一段时间没有问题,但在我使用它们的所有情况下,它一直用于单个表 - 例如:
database.Users.Select(c => c).Skip(10).Take(10);
Run Code Online (Sandbox Code Playgroud)
我的问题是,我现在正在从多个表中投射一组结果,并且我想在整个集合上进行分页(并且仍然可以获得在DB上分页的好处).
我的实体模型如下所示:
一个活动[有很多]小组,一个小组[有很多]联系人
这是通过数据库中的关系建模的
Campaign - > CampaignToGroupMapping - > Group - > GroupToContactMapping - > Contact
我需要生成一个数据结构,其中包含广告系列的详细信息以及通过CampaignToGroupMapping与广告系列相关联的每个联系人的列表,即
Campaign
CampaignName
CampaignFrom
CampaignDate
Recipients
Recipient 1
Recipient 2
Recipient n...
Run Code Online (Sandbox Code Playgroud)
我曾尝试使用.SelectMany编写一个LINQ查询,将每组中的联系人集合投影到一个线性数据集中,希望我能从.Skip().Take()中获取.
我的尝试是:
var schedule = (from c in database.Campaigns
where c.ID == highestPriority.CampaignID
select new PieceOfCampaignSchedule
{
ID = c.ID,
UserID = c.UserID,
Name = c.Name,
Recipients = c.CampaignGroupsMappings.SelectMany(d => d.ContactGroup.ContactGroupMappings.Select(e => new ContactData() { /*Contact Data*/ }).Skip(c.TotalSent).Take(totalRequired)).ToList()
}).SingleOrDefault();
Run Code Online (Sandbox Code Playgroud)
问题是分页(关于Skip()和Take())是针对每个组而不是整个数据集进行的.
这意味着如果我将值200用于参数totalRequired(传递给.Take())并且我有3个与此广告系列相关联的组,则每个组需要200个 - 而不是来自与该组相关联的每个组的总数据中的200个运动.
在SQL中,我可以通过以下查询实现此目的:
select * from
(
select [t1].EmailAddress, ROW_NUMBER() over(order by CampaignID desc) as [RowNumber] from contacts as [t1]
inner join contactgroupmapping as [t2] on [t1].ID = [t2].ContactID
inner join campaigngroupsmapping as [t3] on [t3].ContactGroupID = [t2].GroupID
where [t3].CampaignID = @HighestPriorityCampaignID
) as [Results] where [Results].[RowNumber] between 500 and 3000
Run Code Online (Sandbox Code Playgroud)
通过此查询,我将分配与特定广告系列相关联的每个组的联系人组合.所以我的问题是,如何使用LINQ To SQL语法来实现这一点?