c# Mongodb批量更新

淡淡回忆

　　public void Put(List<OnlineItem> datas)   
　　{   
　　try   
　　{   
　　string tblName = datas[0].beginTime.ToString(&quot;yyyy-MM-dd&quot;);   
　　MongoCollection<BsonDocument> table = null;
　　if (tables.ContainsKey(tblName))   
　　{   
　　table = tables[tblName];   
　　}   
　　else   
　　{   
　　table = db.GetCollection(tblName);   
　　tables.TryAdd(tblName, table);   
　　}   
　　var bulk = table.InitializeOrderedBulkOperation();   
　　//var update = new UpdateBuilder();
　　foreach (var data in datas)   
　　{   
　　data.UpdateTime = DateTime.Now;   
　　IMongoQuery query = Query.EQ(&quot;Seq&quot;, data.Seq);   
　　var update = new UpdateDocument() { { &quot;$set&quot;, BsonDocumentWrapper.Create(data) } };   
　　bulk.Find(query).Update(update);   
　　}   
　　bulk.Execute();   
　　}   
　　catch (Exception ex)   
　　{   
　　LogHelper.Error(ex, &quot;Put&quot;);   
　　}   
　　}