我需要将几个类存储在MongoDb集合中,这些类具有定义公共字段的公共基类和公共接口。每个类都有一个名称相同但实现不同的计算字段。当我尝试查询该字段时,我收到该字段不受支持的消息
我正在使用最新的MongoDb驱动程序在.Net Core 2.2控制台应用程序上运行它
接口:
public interface ITask
{
ObjectId Id { get; set; }
TaskStatus Status { get; set; }
DateTime Timestamp { get; set; }
string UserId { get; set; }
string ComputedField{ get; }
}
基类:
public abstract class BaseTask : ITask
{
[BsonId(IdGenerator = typeof(ObjectIdGenerator))]
public ObjectId Id { get; set; }
[BsonElement("Status")]
public TaskStatus Status { get; set; }
[BsonElement("Timestamp")]
public DateTime Timestamp { get; set; }
[BsonElement("UserId")]
public string UserId { get; set; }
public virtual string ComputedField
{
get { return CalculateMD5Hash(Id.ToString()); }
}
}
给我问题的实际类
public class MyTask : BaseTask
{
[BsonElement("Field1")]
public Guid Field1{ get; set; }
[BsonElement("ComputedField")]
public override string ComputedField
{
get { return CalculateMD5Hash($"ABC{Field1.ToString()}"); }
}
}
调用 MongoDb 层的包装器
public class TaskService<T> : ITaskService<T> where T : ITask
{
private readonly IPersistanceLayer<ObjectId, object> _pl;
public async Task<T> GetNextTask(string key)
{
var oee = _pl.Mongo.Filter<T>(x => x.ConcurrencyKey==key
, typeof(T).Name).OrderBy(x=> x.Timestamp).FirstOrDefault();
return oee;
}
}
蒙戈德布层
public IEnumerable<T> Filter<T>(System.Linq.Expressions.Expression<Func<T, bool>> lambda, string collection)
{
var filter = Builders<T>.Filter.Where(lambda);
return _db.GetCollection<T>(collection).Find(filter).ToList();
}
我得到的错误是
[ERR] {document}.ComputedField is not supported.
在集合中,我看到插入时保存的文档,但计算文件的值已正确存储,唯一的问题是当我尝试查询该字段时
问题是我找错了集合并投射到错误的类
public class TaskService<T> : ITaskService<T> where T : ITask
{
private readonly IPersistanceLayer<ObjectId, object> _pl;
public async Task<T> GetNextTask(string key)
{
var nextTask= _pl.Mongo.Filter<T>(x => x.ConcurrencyKey==key
, typeof(T).Name).OrderBy(x=> x.Timestamp).FirstOrDefault();
return nextTask;
}
}
在这种方法中,T 的类型是 BaseTask 而不是 MyTask,所以我的计算字段不存在,我已经更正了这一点,现在它可以工作了