时间戳

首页 > 解决方案 > UpdateOneAsync 不支持表达式树

c# - UpdateOneAsync 不支持表达式树

问题描述

在调用 UpdateOneAsync 时，使用此包装器：

    public async Task<UpdateResult> UpdateDocument<T>(
        string sCollectionName, 
        Expression<Func<T, bool>> filter, 
        UpdateDefinition<T> update,
        bool bUpsert,
        System.Threading.CancellationToken cancellationToken
        )
    {
        IMongoDatabase db = _mongoClient.GetDatabase(_optionsMonitor.CurrentValue.databasename);

        IMongoCollection<T> collection = db.GetCollection<T>(sCollectionName);

        return await collection.UpdateOneAsync<T>(filter, update, new UpdateOptions() { IsUpsert = bUpsert }, cancellationToken);
    }

像这样：

private async Task<Models.Errors> UpdateDbOnSyncServerToBoardUpdate(
        CancellationToken cancel,
        MongoDB.Bson.BsonDocument bsonDocConfigurationToUpdate,
        DateTime dtUpdated,
        string sId,
        int iObjectId,
        string sAppName,
        string sModelName
        )
    {
        MongoDB.Driver.UpdateResult updateResult = null;
        Models.Errors errors = null;

        try
        {
            updateResult = await _db.UpdateDocument<Models.Database.NodeBoardModel>(
                Constants.NodeBoardCollectionName,
                node => node.Id == sId && 
                node.RemoteBoard.apps.SingleOrDefault(
                    app => app.appname == sAppName).objects.
                    SingleOrDefault(model => model.name == sModelName).config_docs.
                    Any(config => config.config_id == iObjectId),
                MongoDB.Driver.Builders<Models.Database.NodeBoardModel>.Update.
                Set(
                    node => node.RemoteBoard.apps[-1].objects[-1].config_docs[-1].config_doc, bsonDocConfigurationToUpdate).
                Set(
                    node => node.RemoteBoard.apps[-1].objects[-1].config_docs[-1].config_dt, dtUpdated),
                false,
                cancel
                );

我收到 NotSupportedException：

不支持表达式树： {document}{RemoteBoard}{apps}.SingleOrDefault(app => (app.appname == "eACM")).objects.SingleOrDefault(model => (model.name == "tag" )).config_docs

我感觉我以错误的方式使用了 LINQ 关键字，或者以 MongoDb 不支持的方式使用了 LINQ 关键字，但很难准确判断问题出在哪里。

我无法对堆栈跟踪进行任何处理：

在 MongoDB.Driver.Linq.Processors.PipelineBinderBase 的 MongoDB.Driver.Linq.Processors.EmbeddedPipeline.EmbeddedPipelineBinder.BindNonMethodCall（表达式节点）1.BindPipeline(Expression node) at MongoDB.Driver.Linq.Processors.PipelineBinderBase1.BindMethodCall(MethodCallExpression node) at MongoDB.Driver.Linq.Processors.EmbeddedPipeline.EmbeddedPipelineBinder.Bind(Expression node, IBindingContext parent) at MongoDB.Driver.Linq.Processors.SerializationBinder.VisitMethodCall(MethodCallExpression node) at System.Linq.Expressions .MethodCallExpression.Accept(ExpressionVisitor visitor) at MongoDB.Driver.Linq.Processors.SerializationBinder.Visit(Expression node) at System.Linq.Expressions.ExpressionVisitor.VisitBinary(BinaryExpression node) at MongoDB.Driver.Linq.Processors.SerializationBinder.VisitBinary （BinaryExpression 节点）在 System.Linq.Expressions.BinaryExpression.Accept（ExpressionVisitor 访问者）在 MongoDB.Driver.Linq.Processors.SerializationBinder.Visit（表达式节点）在 MongoDB.Driver.Linq.Translators.PredicateTranslator。翻译[TDocument](表达式1 predicate, IBsonSerializer1 parameterSerializer, IBsonSerializerRegistry serializerRegistry) at MongoDB.Driver.MongoCollectionImpl 1.ConvertWriteModelToWriteRequest(WriteModel1 model, Int32 index) at System.Linq.Enumerable.SelectIterator[TSource,TResult](IEnumerable 1 source, Func3 selector)+MoveNext() at System.Collections.Generic.List 1.AddEnumerable(IEnumerable1 enumerable ) 在 System.Linq.Enumerable.ToList[TSource](IEnumerable 1 source) at MongoDB.Driver.Core.Operations.BulkMixedWriteOperation..ctor(CollectionNamespace collectionNamespace, IEnumerable1 请求，MessageEncoderSettings messageEncoderSettings) 在 MongoDB.Driver.MongoCollectionImpl 1.CreateBulkWriteOperation(IEnumerable1 请求，BulkWriteOptions 选项）在 MongoDB.Driver.MongoCollectionImpl 1.BulkWriteAsync(IClientSessionHandle session, IEnumerable1 请求，BulkWriteOptions 选项，CancellationToken 取消令牌）在 MongoDB。 Driver.MongoCollectionImpl 1.UsingImplicitSessionAsync[TResult](Func2 funcAsync, CancellationToken cancelToken) 在 MongoDB.Driver.MongoCollectionBase1.UpdateOneAsync(FilterDefinition1 过滤器，UpdateDefinition 1 update, UpdateOptions options, Func3 bulkWriteAsync) 在 C:\GIT\app-manager\APIMM\ServerLevelConfiguration\WebApplication\Services\ 中的 WebApplication.Services.ConcreteDatabase.UpdateDocument[T](String sCollectionName, Expression 1 filter, UpdateDefinition1 update, Boolean bUpsert, CancellationToken cancelToken) ConcreteDatabase.cs：第 131 行 WebApplication.Services.SyncBoardDatabaseBackgroundService.UpdateDbOnSyncServerToBoardUpdate(CancellationToken cancel, BsonDocument bsonDocConfigurationToUpdate, DateTime dtUpdated, String sId, Int32 iObjectId, String sAppName, String sModelName) 在 C:\GIT\app-manager\APIMM\ServerLevelConfiguration\ WebApplication\Services\SyncBoardDatabaseBackgroundService.cs：第 353 行

模型类：

public class NodeBoardModel
{
    [BsonId]
    [BsonRepresentation(BsonType.ObjectId)]
    public string Id { get; set; }

    [BsonElement]
    public NodeBoardRemoteModel RemoteBoard { get; set; }
}

public class NodeBoardRemoteModel
{
    [BsonElement]
    public List<NodeBoardAppModel> apps { get; set; }
}

public class NodeBoardAppModel
{
    [BsonElement]
    public string appname { get; set; }

    [BsonElement]
    public List<NodeBoardObjectModel> objects { get; set; }
}

public class NodeBoardObjectModel
{
    [BsonElement]
    public string name { get; set; }

    [BsonElement]
    public List<NodeBoardObjectConfigurationModel> config_docs { get; set; }
}

public class NodeBoardObjectConfigurationModel
{
    [BsonElement]
    public BsonDocument config_doc { get; set; }

    [BsonElement]
    public DateTime config_dt { get; set; }

    [BsonElement]
    public int config_id { get; set; }
}

标签： c#mongodblinqmongodb-.net-driver

解决方案

当您尝试构建Update语句时，问题就开始了。正如您可能知道-1的那样，作为索引传递将被转换为$ 位置运算符。文件说_

位置 $ 运算符不能用于遍历多个数组的查询，例如遍历嵌套在其他数组中的数组的查询，因为 $ 占位符的替换是单个值

此外，您正在尝试使用SingleOrDefault.NET MongoDB 驱动程序构建过滤条件，但无法将其转换为任何 MongoDB 查询语法运算符。

如何解决？

您可以尝试使用位置过滤运算符语法，而不是使用位置运算符。

var filter = Builders<NodeBoardModel>.Filter.Eq(f => f.Id, sId);
var update = Builders<NodeBoardModel>.Update.Set("RemoteBoard.apps.$[app].objects.$[object].config_docs.$[configdoc].config_dt", dtUpdated);

var arrayFilters = new List<ArrayFilterDefinition>();
ArrayFilterDefinition<BsonDocument> appFilter = new BsonDocument("app.appname", new BsonDocument("$eq", sAppName));
ArrayFilterDefinition<BsonDocument> objectFilter = new BsonDocument("object.name", new BsonDocument("$eq", sModelName));
ArrayFilterDefinition<BsonDocument> configDocFilter = new BsonDocument("configdoc.config_id", new BsonDocument("$eq", iObjectId));

arrayFilters.AddRange(new[] { appFilter, objectFilter, configDocFilter });

var updateOptions = new UpdateOptions { ArrayFilters = arrayFilters };

var res = Col.UpdateOne(filter, update, updateOptions);

推荐阅读