带有鉴别器问题的MongoDB反序列化

本文关键字：MongoDB 反序列化 问题 鉴别 | 更新日期: 2025-03-16 11:46:07

我有以下类：

[BsonIgnoreExtraElements]
public class WidgetCollection
{
    [BsonId]
    public int AccountId { get; set; }
    public ReadOnlyCollection<Widget> Widgets { get; set; }
}

[BsonIgnoreExtraElements]
[BsonDiscriminator(RootClass = true)]
[BsonKnownTypes(typeof(OtherObject1), ...)]
public class Widget
{
    public ObjectId Id { get; set; }
    public string Title { get; set; }
    public int Position { get; set; }
    public WidgetKind Kind { get; set; }
    public bool IsActive { get; set; }
}

DB中的一个例子是：

{ "_id" : 2993644, "Widgets" : [        {       "_t" : "Widget",        "_id" : ObjectId("504797b327e10b1e80c838ac"),   "Title" : "My Notes",   "Position" : 1,         "Kind" : 0,     "IsActive" : true } ] }

然后我有一个聚合命令，它过滤掉"Widgets"数组中的元素，只返回"IsActive"为true的元素。在这种情况下，该命令只返回整个对象。

var command = new CommandDocument
                        {
                            {"aggregate", "myCollection" },
                            {"pipeline", commandArray }
                        };
        var result = database.RunCommandAs<AggregateResult<WidgetCollection>>(command).Result;
        return result;

这是AggregateResult类：

public class AggregateResult<T> : CommandResult
{
    public T Result
    {
        get
        {
           var result = Response["result"].AsBsonArray.SingleOrDefault().AsBsonDocument;
           return BsonSerializer.Deserialize<T>(result);
         }
     }
 }

是的，我知道SingleOrDefault（）.AsBsonDocument可能是NRE的情况，但现在不是问题所在。我已经将代码调试到反序列化的地步，并验证了"result"变量包含与上面显示的完全相同的BSON。尝试反序列化结果时收到以下消息："反序列化类Community.Widgets.WidgetCollection的Widgets属性时出错：元素名称应为'_v'，而不是'_id'"。

为什么反序列化程序需要一个"_v"元素？

更新
我通过将Widgets属性的类型更改为ICollection解决了上述问题。我现在收到这个错误：Unknown discriminator value 'Widget'.对我来说，这毫无意义，因为文档有"_t" : "Widget"元素。

我还尝试插入一个派生类，之后"_t"元素的值现在如预期的那样为"[ "Widget", "DerivedClass"]，但我得到了相同的错误。同样，当使用database.FindOneAs<>()时不会发生这种情况，只有当显式使用BsonSerializer.Deserialize<>()时才会发生这种情况。我尝试在调用Deserialize():之前添加此代码

BsonClassMap.RegisterClassMap<Widget>(cm => { cm.AutoMap(); cm.SetIsRootClass(true); });
BsonClassMap.RegisterClassMap<RssFeedWidget>();

但我不确定初始化代码应该放在哪里，我认为如果我在类上使用discriminator属性，就不需要它了。

这是我的聚合命令

BsonDocument documentMatch = new BsonDocument{{"$match", new BsonDocument{{"_id", documentId}}}};
BsonDocument unwindArray = new BsonDocument{{"$unwind", "$Widgets"}};
BsonDocument arrayMatch = new BsonDocument{{"$match", new BsonDocument{{"Widgets.IsActive", true}}}});
BsonArray commandArray = new BsonArray();
commandArray.Add(documentMatch);
commandArray.Add(unwindArray),
commandArray.Add(arrayMatch);
var command = new CommandDocument
                  {
                      {"aggregate", collectionName},
                      {"pipeline", commandArray}
                  }
var result = database.RunCommandAs<AggregateResult<WidgetCollection>>(command).Result;

带有鉴别器问题的MongoDB反序列化

我无法重现此问题。我使用了下面的程序。因此，由于我在这里使用的是一个相对琐碎的管道，所以您的问题可能是在映射后聚合文档没有返回。你能发布聚合命令吗？

using MongoDB.Bson;
using MongoDB.Bson.Serialization;
using MongoDB.Bson.Serialization.Attributes;
using MongoDB.Driver;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Linq;
namespace TestConsole_Source
{
    class Program
    {
        [BsonIgnoreExtraElements]
        public class WidgetCollection
        {
            [BsonId]
            public int AccountId { get; set; }
            public ReadOnlyCollection<Widget> Widgets { get; set; }
        }

        [BsonIgnoreExtraElements]
        [BsonDiscriminator(RootClass = true)]
        public class Widget
        {
            public string Title { get; set; }
            public int Position { get; set; }
            public bool IsActive { get; set; }
        }
        static void Main(string[] args)
        {
            var server = MongoServer.Create();
            server.Connect();
            var db = server.GetDatabase("widgettest");
            var collection = db.GetCollection<WidgetCollection>("widgets");
            collection.Drop();
            var widgets = new WidgetCollection();
            var widget1 = new Widget { Title = "One", Position = 0, IsActive = true };
            var widget2 = new Widget { Title = "Two", Position = 1, IsActive = true };
            var widget3 = new Widget { Title = "Three", Position = 2, IsActive = false };
            widgets.Widgets = new List<Widget> { widget1, widget2, widget3 }.AsReadOnly();
            collection.Save(widgets);
            var command = new CommandDocument(
                new BsonElement("aggregate", "widgets"),
                new BsonElement("pipeline", new BsonArray(new [] {
                    new BsonDocument(
                        new BsonElement("$project", new BsonDocument("Widgets", 1)))})));
            var response = db.RunCommand(command);
            var rawDoc = response.Response["result"].AsBsonArray.SingleOrDefault().AsBsonDocument;
            var doc = BsonSerializer.Deserialize<WidgetCollection>(rawDoc);
            //Console.ReadKey();
        }
    }
}

更新：使用上面的新信息，我已经更正了您的聚合查询，使其正常工作。您需要使用一个组，以便将结果恢复到驱动程序所期望的格式。

    var command = new CommandDocument(
        new BsonElement("aggregate", "widgets"),
        new BsonElement("pipeline", new BsonArray(new[] {
            new BsonDocument(
                new BsonElement("$unwind", "$Widgets")),
            new BsonDocument(
                new BsonElement("$match", new BsonDocument("Widgets.IsActive", true))),
            new BsonDocument(
                new BsonElement("$group", new BsonDocument(
                    new BsonElement("_id", "$_id"),
                    new BsonElement("Widgets", new BsonDocument("$addToSet", "$Widgets")))))})));

即使这样，我仍然建议不要经历这个过程，只过滤Widgets客户端。

相关文章：