好的，在工作中，我们正在使用 MVC C# 和 MongoDB 开发一个系统。第一次开发时，我们认为遵循存储库模式可能是个好主意(这真是太痛苦了!)，这里的代码可以让您了解当前实现的内容。

MongoRepository 类:

public class MongoRepository { }

public class MongoRepository<T> : MongoRepository, IRepository<T>
where T : IEntity
{
    private MongoClient _client;
    private IMongoDatabase _database;
    private IMongoCollection<T> _collection;

    public string StoreName {
        get {
                return typeof(T).Name;
            }
        }
    }

    public MongoRepository() {

        _client = new MongoClient(ConfigurationManager.AppSettings["MongoDatabaseURL"]);
        _database = _client.GetDatabase(ConfigurationManager.AppSettings["MongoDatabaseName"]);

        /* misc code here */

        Init();
    }

    public void Init() {
        _collection = _database.GetCollection<T>(StoreName);
    }

    public IQueryable<T> SearchFor() {
        return _collection.AsQueryable<T>();
    }
}

IRepository 接口(interface)类:

public interface IRepository { }

public interface IRepository<T> : IRepository
where T : IEntity
{

    string StoreNamePrepend { get; set; }

    string StoreNameAppend { get; set; }

    IQueryable<T> SearchFor();

    /* misc code */

}

然后使用 Ninject 实例化存储库，但如果没有 Ninject，它将看起来像这样(只是为了使这个示例更简单):

MongoRepository<Client> clientCol = new MongoRepository<Client>();

这是用于搜索页面的代码，用于输入 Controller 操作，该操作输出 JSON 供带有要读取的 DataTables 的表使用。请注意，以下使用 DynamicLinq，以便可以从字符串输入构建 linq:

tmpFinalList = clientCol
    .SearchFor()
    .OrderBy(tmpOrder) // tmpOrder = "ClientDescription DESC"
    .Skip(Start) // Start = 99900
    .Take(PageLength) // PageLength = 10
    .ToList();

现在的问题是，如果集合有很多记录(确切地说是 99,905)，如果字段中的数据不是很大，例如我们的关键字段是一个 5 个字符的固定长度字符串，那么一切正常，我可以使用此查询跳过并采取罚款。但是，如果它像 ClientDescription 这样的东西可能会更长，我可以从查询的前面(即第 1 页)“排序”和“获取”，但是当我使用 Skip = 99900 & Take = 10 页到末尾时，它给出了以下内存错误:

An exception of type 'MongoDB.Driver.MongoCommandException' occurred in MongoDB.Driver.dll but was not handled in user code

Additional information: Command aggregate failed: exception: Sort exceeded memory limit of 104857600 bytes, but did not opt in to external sorting. Aborting operation. Pass allowDiskUse:true to opt in..

好吧，我想这很容易理解。我在网上看过，大多数建议都是使用 Aggregation 和“allowDiskUse:true”，但是由于我在 IRepository 中使用了 IQueryable，所以我无法开始使用 IAggregateFluent<>，因为您随后需要将 MongoDB 相关类公开给 IRepository，这将违背 IoC 原则。

有什么方法可以强制 IQueryable 使用它，或者有人知道我可以在不违反 IoC 原则的情况下访问 IAggregateFluent 的方法吗？

我感兴趣的一件事是为什么排序适用于第 1 页(Start = 0，Take = 10)，但当我搜索到末尾时却失败了……当然，所有内容都必须排序才能成为能够按第 1 页的顺序获取项目，但不应该(开始 = 99900，Take = 10)只需要相同数量的“排序”，MongoDB 应该只向我发送最后 5 条左右的记录。为什么两种排序都完成后没有出现这个错误？

回答

好的，在@craig-wilson 的帮助下升级到最新版本的 MongoDB C# 驱动程序并更改 MongoRepository 中的以下内容将解决问题:

public IQueryable<T> SearchFor() {
    return _collection.AsQueryable<T>(new AggregateOptions { AllowDiskUse = true });
}

我遇到了 System.MissingMethodException，但这是由 MongoDB 驱动程序的其他副本也需要更新引起的。

最佳答案

从 IMongoCollection 创建 IQueryable 时，您可以传入允许您设置 AllowDiskUse 的 AggregateOptions。

https://github.com/mongodb/mongo-csharp-driver/blob/master/src/MongoDB.Driver/IMongoCollectionExtensions.cs#L53

关于使用存储库模式时的 MongoDB 和大型数据集，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/42133963/