帮助中心/最新通知

质量为本、客户为根、勇于拼搏、务实创新

< 返回文章列表

【服务器相关】c#操作mongodb插入数据效率

发表时间:2025-09-24 16:09:00 小编:油条

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

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

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

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

使用一次性插入多个文档方法,插入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{publicclass MongoHelp{private static IMongoClient client{get{if (null == _client){_client = new MongoClient("mongodb://127.0.0.1:27017");}return _client;}}publicstatic IMongoDatabase database{get { _database = client.GetDatabase("HotelPersonInfo"); return _database;}set {_database = value;}}publicstatic 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; }}}

总结

本篇文章到此结束,如果您有相关技术方面疑问可以联系我们技术人员远程解决,感谢大家支持本站!


联系我们
返回顶部