0

我有一个经典的支持 REST 和 ODATA 的 Web API 控制器，它调用基于 MongoDB 的存储库模式实现。

我不断得到

溢出排序阶段缓冲数据使用量 33556193 字节超出内部限制 33554432 字节异常

当我尝试跳过前 12010+ 条记录并获得前 10 名时

?$skip=12020&$top=10&$orderby=Serial

经过一番搜索后，我尝试在 Serial 上实现索引，例如

private void GetCollection() //is like DBSet of some entity
{
  _collection = _dbContext.Database
     .GetCollection<TEntity>(typeof(TEntity).Name);
  Type typeParameterType = typeof(TEntity);
  if (typeParameterType.Name == "StoreCommand")
    if (_collection.IndexExists("Serial") == false)
      _collection.CreateIndex(IndexKeys<StoreCommand>.Ascending(_ => _.Serial));
}

我的存储库实现是这样的。

    public class MongoDbRepository<TEntity> :
    IRepository<TEntity> where
        TEntity : EntityBase
{
    private MongoCollection<TEntity> _collection;

    private SNDbContext _dbContext;
    public MongoDbRepository(SNDbContext dbContext)
    {
        _dbContext = dbContext;
        GetCollection();
    }
    private void GetCollection()
    {
        _collection = _dbContext.Database
            .GetCollection<TEntity>(typeof(TEntity).Name);
    }
    public IQueryable<TEntity> GetAll()
    {
        return _collection.AsQueryable(); 
    }//............And other functions after this

}

来自服务层的调用是这样的

 IQueryable<StoreCommand> GetAllStoreCommands() 
  {
     return _uow.StoreCommands.GetAll(); 
   }

其中 SNDbContext 包含与使用 MongoClient 和连接字符串获取数据库相关的所有代码。

4

1 回答 1

0

问题是，在您的存储库实现（未显示）中，您从 MongoDB 获取所有数据，然后所有这些数据都在缓冲中排序并在内存中排序以允许跳过和获取。

您需要做的是通过以下两种方式中的任何一种来修改您的存储库：

  • 返回一个纯可查询的，以便您可以组合查询的其余部分并仍然在 MongoDB 引擎上执行它
  • 直接暴露一个接收参数的方法skip和take，并在数据库中直接执行查询。

您可以使用游标实现它，如下所示：

var collection = db.GetCollection<YourType>("yourtype");
var sort = SortBy<YourType>
            .Ascending(p => p.YourProperty1)
            .Descending(p => p.YourProperty2);
MongoCursor<YourType> cursor = collection
  .FindAll()
  .SetSortOrder(sort)
  .SetSkip(12010)
  .SetLimit(10);

如果您迭代此游标，您根本不会遇到任何问题。

您还可以定义和执行 a SelectQuery，指定Skip和Take值。请参阅文档：SelectQuery 属性

于 2015-05-22T08:48:16.743 回答