.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批量更新

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