zoukankan      html  css  js  c++  java
  • 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");
                }
            }

  • 相关阅读:
    mybatis批量更新报错
    Axure8破解码
    小程序开发-Step1
    2018新年计划
    java 写 Excel(不生成实体文件,写为流的形式)
    git 生成公钥 使用命令行无需输入用户名密码(windows)
    Node.js:上传文件,服务端如何获取文件上传进度
    Express:模板引擎深入研究
    windows下nginx的安装及使用
    Chrome开发者工具详解-Network面板
  • 原文地址:https://www.cnblogs.com/94cool/p/6387414.html
Copyright © 2011-2022 走看看