Skip to content

Commit 441f0db

Browse files
committed
1 parent e6d9864 commit 441f0db

File tree

2 files changed

+9
-15
lines changed

2 files changed

+9
-15
lines changed

src/ShardingCore/Sharding/MergeContexts/QueryableRewriteEngine.cs

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -59,6 +59,15 @@ public IRewriteResult GetRewriteQueryable(IMergeQueryCompilerContext mergeQueryC
5959
var orders = orderByContext.PropertyOrders;
6060

6161
var combineQueryable = mergeQueryCompilerContext.GetQueryCombineResult().GetCombineQueryable();
62+
63+
if (skip is < 0)
64+
{
65+
throw new ShardingCoreException($"queryable:{mergeQueryCompilerContext.GetQueryCombineResult().GetQueryCompilerContext().GetQueryExpression().ShardingPrint()} skip should >= 0");
66+
}
67+
if (take is < 0)
68+
{
69+
throw new ShardingCoreException($"queryable:{mergeQueryCompilerContext.GetQueryCombineResult().GetQueryCompilerContext().GetQueryExpression().ShardingPrint()} take should >= 0");
70+
}
6271
//去除分页,获取前Take+Skip数量
6372
var reWriteQueryable = combineQueryable;
6473
if (take.HasValue || skip.HasValue)

src/ShardingCore/Sharding/ParseEngines/ParseEngine.cs

Lines changed: 0 additions & 15 deletions
This file was deleted.

0 commit comments

Comments
 (0)