c# - IMongoCollection当我传入 Func 的谓词时抛出
问题描述
我正在尝试对 ASP.NET Core Web 控制器进行单元测试。这是天真的数据访问的样子:
var database = configuration.GetSection("MongoDb:Database").Value;
var mongoSettings = new MongoCollectionSettings() { AssignIdOnInsert = true };
var users = client.GetDatabase(database).GetCollection<User>("User", mongoSettings);
var user = users.Find(u => u.EmailAddress == emailAddress).SingleOrDefault();
这工作正常。它不容易进行单元测试(Find
不能用 Moq 模拟),而且我更喜欢我的数据访问的间接层,所以我尝试像这样重构为存储库类:
public interface IRepository<T>
{
T SingleOrDefault(Func<T, bool> predicate);
}
public class MongoRepository<T> : IRepository<T>
{
// ...
public T SingleOrDefault(Func<T, bool> predicate)
{
var objects = client.GetDatabase(this.databaseName).GetCollection<T>(this.repositoryName, this.settings);
var toReturn = objects.Find(o => predicate(o) == true).SingleOrDefault();
return toReturn;
}
}
当我更新我的控制器以改为使用MongoRepository<User>
时,它会抛出:
var usersRepo = new MongoRepository<User>(this.configuration, this.client);
var user = usersRepo.SingleOrDefault(u => u.EmailAddress == emailAddress);
具体来说,在存储库代码中,objects.Find(o => predicate(o) == true).SingleOrDefault();
抛出异常:An exception of type 'System.InvalidOperationException' occurred in MongoDB.Driver.dll but was not handled in user code: 'Invoke(value(System.Func
2[AutoDungeoners.Web.Models.User,System.Boolean]), {document}) is not supported.'`
我不知道如何解决这个问题。我怀疑我的谓词的定义Func<T, bool>
不正确,因为如果我只是调用objects.Find(o => true)
,它会毫无问题地返回第一个对象。
下面是完整的异常堆栈。
An exception of type 'System.InvalidOperationException' occurred in MongoDB.Driver.dll but was not handled in user code: 'Invoke(value(System.Func`2[AutoDungeoners.Web.Models.User,System.Boolean]), {document}) is not supported.'
at MongoDB.Driver.Linq.Translators.PredicateTranslator.GetFieldExpression(Expression expression)
at MongoDB.Driver.Linq.Translators.PredicateTranslator.TranslateComparison(Expression variableExpression, ExpressionType operatorType, ConstantExpression constantExpression)
at MongoDB.Driver.Linq.Translators.PredicateTranslator.TranslateComparison(BinaryExpression binaryExpression)
at MongoDB.Driver.Linq.Translators.PredicateTranslator.Translate(Expression node)
at MongoDB.Driver.Linq.Translators.PredicateTranslator.Translate(Expression node, IBsonSerializerRegistry serializerRegistry)
at MongoDB.Driver.Linq.Translators.PredicateTranslator.Translate[TDocument](Expression`1 predicate, IBsonSerializer`1 parameterSerializer, IBsonSerializerRegistry serializerRegistry)
at MongoDB.Driver.ExpressionFilterDefinition`1.Render(IBsonSerializer`1 documentSerializer, IBsonSerializerRegistry serializerRegistry)
at MongoDB.Driver.MongoCollectionImpl`1.CreateFindOperation[TProjection](FilterDefinition`1 filter, FindOptions`2 options)
at MongoDB.Driver.MongoCollectionImpl`1.FindSync[TProjection](IClientSessionHandle session, FilterDefinition`1 filter, FindOptions`2 options, CancellationToken cancellationToken)
at MongoDB.Driver.MongoCollectionImpl`1.<>c__DisplayClass41_0`1.<FindSync>b__0(IClientSessionHandle session)
at MongoDB.Driver.MongoCollectionImpl`1.UsingImplicitSession[TResult](Func`2 func, CancellationToken cancellationToken)
at MongoDB.Driver.MongoCollectionImpl`1.FindSync[TProjection](FilterDefinition`1 filter, FindOptions`2 options, CancellationToken cancellationToken)
at MongoDB.Driver.FindFluent`2.ToCursor(CancellationToken cancellationToken)
at MongoDB.Driver.IAsyncCursorSourceExtensions.SingleOrDefault[TDocument](IAsyncCursorSource`1 source, CancellationToken cancellationToken)
at MongoDB.Driver.IFindFluentExtensions.SingleOrDefault[TDocument,TProjection](IFindFluent`2 find, CancellationToken cancellationToken)
解决方案
Find(...)
您可以在此处使用的方法的唯一实现是(文档):
public static IFindFluent<TDocument, TDocument> Find<TDocument>(this IMongoCollection<TDocument> collection, Expression<Func<TDocument, bool>> filter, FindOptions options = null)
这里描述了Func
和之间的区别。基本上返回一个对MongoDB集合的引用,这里方法的作用是将表达式树转换为MongoDB查询。您的查询在数据库中执行的时刻就是您调用的时刻,这就是您将获得异常的地方。Expression<Func>
GetCollection
Find
SingleOrDefault()
由于和您之间没有隐式转换Func<T,bool>
,Expression<Func<T,bool>>
您尝试使用o => predicate(o) == true
它创建另一个表达式并使您的代码可编译,但如前所述 - MongoDB .NET 驱动程序将无法弄清楚如何将此类表达式转换为 MongoDB 查询。
您需要将实现更改为:
public T SingleOrDefault(Expression<Func<T, bool>> predicate)
{
var objects = client.GetDatabase(this.databaseName).GetCollection<T>(this.repositoryName, this.settings);
var toReturn = objects.Find(predicate).SingleOrDefault();
return toReturn;
}
请记住,这仅适用于那些可以翻译成 MongoDB 查询语言的表达式。u => u.EmailAddress == emailAddress
看起来不错。
推荐阅读
- python - 将字符串分成对
- oracle - oracle11g 中的 PL/SQL 块
- api - Jira API 批量创建 - 创建全部或无
- php - Http POST 请求返回状态码 500
- scala - 在scala中加载和设置json的值
- twitter-bootstrap - 覆盖 Bootstrap 的单选按钮
- javascript - 为什么这个窗口在关闭后没有打开(chrome 扩展)?
- javascript - 如何在存储过程中将容器名称作为 Azure cosmos DB 查询的参数传递?
- python-3.x - 如何使用 Python 中的 Plotly Express 在同一 y 轴上绘制多条线并放置 y 标签、垂直线
- html - Mathjax3 溢出引导列