c# Mongodb批量更新
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");
}
}
相关文章
- WinForm实现简单的拖拽功能(C#)
- 【Mongodb】如何创建mongodb的replica set
- logstash-out-mongodb实现elasticsearch到Mongodb的数据同步
- C#----汉字转拼音
- C# Protobuf-Net 序列化
- C# 移除字符串末尾指定字符
- Atitit。Cas机制 软件开发 编程语言 无锁机制 java c# php
- Atitit. 二进制数据ascii表示法,与base64编码解码api 设计标准化总结java php c#.net
- C# 引用类型、值类型
- mongoDB BI 分析利器 - PostgreSQL FDW (MongoDB Connector for BI)
- SQL SERVER类型与C#类型对照
- (二十)c#Winform自定义控件-有后退的窗体-HZHControls
- 【MongoDB】The Access control of mongodb
- 【MongoDB】在windows平台mongodb切片集群(三)
- C#+无unsafe的非托管大数组(large unmanaged array in c# without 'unsafe' keyword)
- (57)C#里的WEBAPI的客户端怎么样与Python服务器联调
- 使用C#对MongoDB中的数据进行查询,改动等操作
- C# Resources文件中内容的使用
- C# 操作mongodb 分组
- C# Task详解