.net MongoDB的批量更新

　　我Mongodb的批量更新是根据MongoDB的_id的字段来实现的,因为部署在阿里云上,然后_id方面也查了很久的信息,感觉上应该是没有问题的.

　　首先说下思路,就是首先判断id存在否,不存在则直接查前200条,然后记录最后一条的ID,200条批量更新,结束后返回给循环,下次继续使用,如果数量不足200,则返回false,结束循环。

　　下面列出部分关键代码:

                FilterDefinition<BsonDocument> filter;
                if (objectId.Length == 0)
                {
                    filter = Builders<BsonDocument>.Filter.Exists("InsertTimeSpan", true);
                }
                else
                {
                    filter = (Builders<BsonDocument>.Filter.Gt("_id", ObjectId.Parse(objectId)) &
                              Builders<BsonDocument>.Filter.Exists("InsertTimeSpan", true));
                }
                //  string selMaxId = string.Format("select orderId from hei where id=(select max(id) from hei)");                                   
                var collection = MongoAccessService.GetMongoCollection<BsonDocument>("Mongodb", collectionName);
                var projection = Builders<BsonDocument>.Projection
                        .Include("raw_data.mobile_brief.number")
                        .Include("InsertTimeSpan")
                        .Include("orderId")
                        .Include("taskId")
                        .Include("cityName")
                        .Include("operators")
                        .Include("raw_data.mobile_details")
                        .Include("_id")
                    ;
                var result = collection.Find(filter).Project(projection).Limit(200);
                var listResult = result.ToList();
                if (listResult.Count > 0)
                {
                    objectId = listResult[listResult.Count - 1]["_id"].ToString();
}

　　括号可能有些问题,不要在意。

　　批量更新代码:

                    ///批量更新
                    List<UpdateOneModel<BsonDocument>> das = new List<UpdateOneModel<BsonDocument>>();
                    for (int i = 0; i < updateGjjMogos.Count; i++)
                    {
                        var filterUpdate = Builders<BsonDocument>.Filter.Eq("_id", updateGjjMogos[i].Id);
                        var update = Builders<BsonDocument>.Update.Set("data.general_analyzed_data.start_date", updateGjjMogos[i].MinDateTimes).Set("data.general_analyzed_data.end_date",(updateGjjMogos[i].MaxDateTimes));
                      //  var bsonDoc = updateGjjMogos[i].ToBsonDocument();
                        var sd = new UpdateOneModel<BsonDocument>(filterUpdate, update) { IsUpsert = true };
                        das.Add(sd);
                    }
                   var res =  collection.BulkWrite(das);

 　　将要更新的model放到UpdateModel实现list批量更新

　　有什么不足和建议可以和我提,共同进步！