数据库

c#操作mongodb插入数据效率
数据库 2024/12/23 佚名
3 2

mongodb的数据插入速度是其一个亮点，同样的10000条数据，插入的速度要比Mysql和sqlserver都要快，当然这也是要看使用者怎么个使用法，你代码如果10000次写入使用10000次连接，那也是比不过其他数据库使用事务一次性提交的速度的。

同样，mongo也提供的一次性插入巨量数据的方法，因为mongodb没有事务这回事，所以在在C#驱动里，具体方法是InsertManyAsync（）一次性插入多个文档。与之对应的是InsertOneAsync，这个是一次插入一个文档；

InsertManyAsync（）这个方法带入的参数只要是实现了IEnumerable接口的类型就可以，所以可是list<>,这样的数据类型；

同样的10000次插入，两个方法时间差别很大。如图：

c#操作mongodb插入数据效率

使用一次性插入多个文档方法，插入10000条耗时仅1.3秒，分成10000次插入，耗时19.9秒。区别大了个去。同样，前面我做过使用mysql插入10000条记录，要用4秒多，可见，这mongodb插入速度不是吹 的。

具体的代码如下，贴上：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using MongoDB.Bson;
using MongoDB.Driver;
using System.Diagnostics;
namespace sqltomongo
{
  public  class MongoHelp
  {
    private static IMongoClient client
    {
      get
      {
        if (null == _client)
        {
          _client = new MongoClient("mongodb://127.0.0.1:27017");
        }
        return _client;
      }
    }
    public  static IMongoDatabase database
    {
      get {
         _database = client.GetDatabase("HotelPersonInfo");
         return _database;
      }
      set {
        _database = value;
      }
    }
    public  static IMongoCollection<BsonDocument> collection
    {
      get {
        return _collection;
      }
      set {
        _collection = value;
      }
    }
    protected static IMongoClient _client;
    protected static IMongoDatabase _database;
    protected static IMongoCollection<BsonDocument> _collection;
     //测试效率，两个方法用时比较
    public async static void TestMongo()
    {
      //自定义的对象
      RoomInfo roomdata = new RoomInfo();
      List<BsonDocument> docunemts = new List<BsonDocument>();
      collection = database.GetCollection<BsonDocument>("HotelPersonInfo");
      Stopwatch sw = new Stopwatch();
      sw.Start();
      for (int i = 1; i < 10000; i++)
      {
         //mongo对用户自定义的对象扩展了tobasonDocument这个方法，可直接用
        var roomdatadocument = new BsonDocument(roomdata.ToBsonDocument());
        docunemts.Add(roomdatadocument);
      }
      //一次10000条
       //这方法 查看api手册，只要实现了IEnumerable借口的类型就都行
      await collection.InsertManyAsync(docunemts);
      sw.Stop();
       TimeSpan ts2 =sw.Elapsed;
       Console.WriteLine("total is " + ts2.TotalMilliseconds);
      ///一次次插 10000次
       Stopwatch sw2 = new Stopwatch();
       sw2.Start();
       for (int i = 1; i < 10000; i++)
       {
         var roomdatadocument = new BsonDocument(roomdata.ToBsonDocument());
         await collection.InsertOneAsync(roomdatadocument);
       }       
       sw2.Stop();
       TimeSpan ts22 = sw2.Elapsed;
       Console.WriteLine("total is " + ts22.TotalMilliseconds);
     // await collection.InsertOneAsync(roomdatadocument);
      //collection = database.GetCollection<BsonDocument>("HotelPersonInfo");
      // collection.InsertOneAsync(roomdatadocument);
    }
  }
}

里面使用了一个自定义的对象：

代码如下：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using MongoDB.Bson;
namespace sqltomongo
{
  public class RoomInfo 
  {
    public RoomInfo()
    {
     // id = "test"; 
      Name = "nafd"; Moblie = "123456"; EMail = "dd@qq.com"; Tel = "010123"; Fax = "0755-001";
      IdentityId = "616112323231"; RegisterType = "tid"; CardNo = "cardno"; Sex = "男"; Birthday = "1999";
      Address = "china beijing"; ZipCode = "519000"; RegisterDate = "2015-03-03";
      District2 = "District2";
      District3 = "District3";
      District4 = "District4";
    }
   // public string id { get; set; }
    /// <summary>
    /// 名字
    /// </summary>
    public string Name { get; set; }      
     /// <summary>
    /// 手机号码
    /// </summary>
    public string Moblie { get; set; }
    /// <summary>
    /// 邮箱
    /// </summary>
    public string EMail {get;set;}
    /// <summary>
    /// 座机
    /// </summary>
    public string Tel { get; set; }
    /// <summary>
    /// 传真
    /// </summary>
    public string Fax { get; set; }
    /// <summary>
    /// 身份证
    /// </summary>
    public string IdentityId { get; set; }
     /// <summary>
    /// 使用什么注册的
    /// ID --身份证 （只需要id身份证的信息）
    /// </summary>
    public string RegisterType { get; set; }
      /// <summary>
    /// 会员卡号
    /// </summary>
    public string CardNo { get; set; }
    /// <summary>
    /// 性别
    /// </summary>
    public string Sex { get; set; }
    /// <summary>
    /// 生日
    /// </summary>
    public string Birthday { get; set; }
    /// <summary>
    /// 地址
    /// </summary>
    public string Address { get; set; }
    /// <summary>
    /// 邮编
    /// </summary>
    public string ZipCode { get; set; }
    public string District2 { get; set; }
    public string District3 { get; set; }
    public string District4 { get; set; }
    /// <summary>
    /// 注册时间 
    /// </summary>
    public string RegisterDate { get; set; }
  }
}

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对的支持。如果你想了解更多相关内容请查看下面相关链接

标签：
mongodb插入数据效率,c#操作mongodb插入数据效率
免责声明：本站文章均来自网站采集或用户投稿，网站不提供任何软件下载或自行开发的软件！ 如有用户或公司发现本站内容信息存在侵权行为，请邮件告知！ 858582#qq.com
无争山庄资源网 Copyright www.whwtcm.com

评论“c#操作mongodb插入数据效率”

暂无“c#操作mongodb插入数据效率”评论...
www.whwtcm.com 无争山庄资源网
129,905影音资源
244,626技术资源
111,817软件资源
578,645站长资源

更新日志

友情链接

杰晶网络 DDR爱好者之家 桃源资源网 杰网资源 富贵资源网 南强小屋 铁雪资源网 幽灵资源网 万梅资源网 狼山资源网 白云岛资源网 昆仑资源网 相思资源网 明霞山资源网 内蒙古资源网 黑松山资源网 茶园资源网 饿虎岗资源网 大旗谷资源网 常春岛资源网 岱庙资源网 兴国资源网 快活林资源网 蝙蝠岛资源网 帝王谷资源网 白云城资源网 伏龙阁资源网 清风细雨楼 天枫庄资源网 圆月山庄资源网 无争山庄资源网 神水资源网 移花宫资源网 神剑山庄资源网 无为清净楼资源网 金钱帮资源网 丐帮资源网 华山资源网 极乐门资源网 小李飞刀资源网 凤求凰客栈 风云阁资源网 金狮镖局 鸳鸯亭资源网 千金楼资源网 更多链接
无争山庄资源网 Copyright www.whwtcm.com