C# MongoDb - Как обновить одно поле во вложенных документах? - PullRequest
Новая
       62

C# MongoDb - Как обновить одно поле во вложенных документах?

1 голос
/ 18 марта 2020

Чего я хочу добиться, так это предоставить List<JobList> содержащий идентификатор клиента и внутренние идентификаторы заданий для метода Finish(). Затем я хочу перебрать клиентов и обновить все задания, соответствующие JobInternalIds, и установить текущую дату и время в поле FinishedAt. Проблема в том, что я совершенно не знаю, как обновить вложенные объекты.

Я пробовал что-то вроде ниже, но безуспешно. 

public class Client
{
    [BsonId]
    public ObjectId Id { get; set;}
    public string Name { get; set;}
    public List<Job> Jobs { get; set;}
}

public class Job
{
    public string InternalId { get; set;}
    public string Name { get; set;}
    public DateTime? FinishedAt { get; set;}
}

public class JobList
{
    public string ClientId { get; set; }
    List<string> JobInternalIds { get; set; }
}

public async Task Finish(List<JobList> joblist)
{   
    var updateDefinition = new UpdateDefinitionBuilder<Client>()
        .Set(x => x.Job[0].FinishedAt, DateTime.UtcNow); // don't know how to set datetime to finishedAt for each elements of collection that matches InternalIds

    foreach(var item in joblist)
    {
        await _db.Collection.UpdateManyAsync(item.ClientId, updateDefinition);
    }   
}

----------EDITED----------
public async Task Finish(List<JobList> joblist)
{
    var updateDefinition = Builders<Client>.Update
        .Set(x => x.Jobs[-1].FinishedAt, DateTime.UtcNow);

    foreach (var item in joblist)
    {
        var internalIds = item.JobInternalIds.Select(x => x.InternalId).ToList();   
        var idFilter = Builders<Client>.Filter.Eq(x => x.Id, item.ClientId);
        var internalIdsFilter = Builders<Client>.Filter.ElemMatch(x => x.Jobs, y => internalIds.Contains(y.InternalId));
        var combinedFilters = Builders<Client>.Filter.And(idFilter, internalIdsFilter);

        await _db.Collection.UpdateManyAsync(combinedFilters, updateDefinition);
    }
}

1 Ответ

0 голосов
/ 20 марта 2020

Вы можете использовать отфильтрованный позиционный оператор, чтобы обновить все элементы, которые соответствуют условию в массиве: 

var internalIds = new[] { "1", "2" };
var idFilter = Builders<Client>.Filter.Eq(x => x.Id, objectId);
var updateDefinition = Builders<Client>.Update
    .Set("Jobs.$[job].FinishedAt", DateTime.UtcNow);

await collection.UpdateManyAsync(idFilter, updateDefinition,
     new UpdateOptions
     {
         ArrayFilters = new []
         {
             new BsonDocumentArrayFilterDefinition<BsonDocument>(new BsonDocument("job.groupName", new BsonDocument("$in", new BsonArray(internalIds)))),
         }
     });

Посмотрите этот пост в блоге для некоторых примеров - https://kevsoft.net/2020/03/23/updating-arrays-in-mongodb-with-csharp.html

...