C# Mongo DB 修改嵌套集合中的字段

虽然c#的mongo 驱动很强大，而且还支持linq，但是一些复杂的操作语句还是比较困难

这里我用Bson实现功能

这是模型(我这里有多层嵌套)

public class CtStreetPurpose

    {

        public long Id { get; set; }

        public List<StreetPurpose> StreetPurposes { get; set; }

    }

 public class StreetPurpose

    {

        public long BuyerId { get; set; }

        public string Remark { get; set; }

        public string RemarkName { get; set; }

        public List<PurposeStreetId> StreetIds { get; set; }

        public string PurposeCategory { get; set; }

        public int Top { get; set; }

        public string Content { get; set; }

        public long FollowTime { get; set; }

        public long UpdateTime { get; set; }

 }

public class PurposeStreetId

    {

        public long Id { get; set; }

        public long StreetId { get; set; }

   }

直接上代码

public async Task UpdateStreetPurpose(CtStreetPurpose create)

        {

           var writeModels = new List<WriteModel<CtStreetPurpose>>();
 

            foreach (var purpose in create.StreetPurposes)

            {
                //过滤条件

                var filter = new BsonDocument

                {

                    {"_id",create.Id},//在monogo db 里面id是_id
                    //第一层嵌套中的字段过滤

                    {

                        "StreetPurposes",new BsonDocument

                        {

                            {"$elemMatch",new BsonDocument{{ "BuyerId", purpose.BuyerId}}}

                        }

                    },

                };

               //构建一个bson数组存放需要插入集合的数据

                var streetIdsBsonArray = new BsonArray();

                foreach (var streetIds in purpose.StreetIds)

                {

                    var streetIdsBson = new BsonDocument

                    {

                        {"_id", streetIds.Id},

                        {nameof(PurposeStreetId.StreetId), streetIds.StreetId}

                    };

                    streetIdsBsonArray.Add(streetIdsBson);

                }

                //更新

                var update = new BsonDocument

                {

                    {
                        //插入集合

                        "$push",new BsonDocument

                        {

                            {
                                //如果不是插入集合--这里需要修改

                                "StreetPurposes.$.StreetIds",new BsonDocument

                                {

                                    {"$each",streetIdsBsonArray}

                                }

                            }

                        }

                    }

                };

                writeModels.Add(new UpdateManyModel<CtStreetPurpose>(filter, update) { IsUpsert = true });  // IsUpsert--强制更新

            } 

          await collection.BulkWriteAsync(session, writeModels); 
}

第一次写问随笔没什么经验 ^ - ^

巴特西

C# Mongo DB 修改多层嵌套集合中的字段

C# Mongo DB 修改嵌套集合中的字段

这是模型(我这里有多层嵌套)

直接上代码

最新文章

热门文章