Autotest
/
sharding
mirror of https://gitee.com/dotnetchina/sharding-core.git
1
0
Fork 0
Code Issues Releases Wiki Activity

1

This commit is contained in:
xuejiaming 2021-08-25 13:22:32 +08:00
parent 229d5c1d3d
commit 7cd4ceb736
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/ShardingCore/Sharding/ReWrite/ReWriteEngine.cs
View File

@ -30,18 +30,18 @@ namespace ShardingCore.Core.Internal.StreamMerge.ReWrite
//去除分页,获取前Take+Skip数量 //去除分页,获取前Take+Skip数量
var reWriteQueryable = _queryable; var reWriteQueryable = _queryable;
if (skip.HasValue) if (take.HasValue)
{
reWriteQueryable = _queryable.RemoveSkip();
}
if (take.HasValue&& skip.GetValueOrDefault()>0)
{ {
reWriteQueryable = _queryable.RemoveTake(); reWriteQueryable = _queryable.RemoveTake();
} }
if (skip.HasValue)
{
reWriteQueryable = _queryable.RemoveSkip();
}
//if (take.HasValue) if (take.HasValue)
// reWriteQueryable = reWriteQueryable.Take(take.Value + skip.GetValueOrDefault()); reWriteQueryable = reWriteQueryable.Take(take.Value + skip.GetValueOrDefault());
//包含group by //包含group by
if (extraEntry.GroupByContext.GroupExpression != null) if (extraEntry.GroupByContext.GroupExpression != null)
{ {