c# Mongodb批量更新

  1. 云栖社区>
  2. 博客>
  3. 正文

c# Mongodb批量更新

老朱教授 2017-11-26 22:00:00 浏览722
展开阅读全文

public void Put(List<OnlineItem> datas)
{
try
{
string tblName = datas[0].beginTime.ToString("yyyy-MM-dd");
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("Seq", data.Seq);
var update = new UpdateDocument() { { "$set", BsonDocumentWrapper.Create(data) } };
bulk.Find(query).Update(update);
}
bulk.Execute();
}
catch (Exception ex)
{
LogHelper.Error(ex, "Put");
}
}




本文转自94cool博客园博客,原文链接:http://www.cnblogs.com/94cool/p/6387414.html,如需转载请自行联系原作者

网友评论

登录后评论
0/500
评论
老朱教授
+ 关注