MongoDB   发布时间:2019-11-06  发布网站:大佬教程  code.js-code.com
大佬教程收集整理的这篇文章主要介绍了8天学通MongoDB——第八天 驱动实践大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。

     作为系列的最后一篇,得要说说C#驱动对mongodb的操作,目前驱动有两种:官方驱动和samus驱动,不过我个人还是喜欢后者,

因为提供了丰富的linq操作,相当方便

官方驱动:。下载后,还提供了一个酷似msdn的帮助文档。

samus驱动:。 

下面就具体看看samus驱动,https://github.com/samus/mongodb-csharp/blob/master/examples/Simple/Main.cs">https://github.com/samus/mongodb-csharp/blob/master/examples/Simple/Main.cs上面提供了

一个简单的demo,大体上看看我们就知道怎么玩了。

一: 实践

1:我们建立一个Person实体,MongoAlias特性表示取别名,这里的ID值将会覆盖掉数据库自动生成的_id。

数据实体 Person { [MongoAlias()] String ID { ; ; } String Name { ; ; } Age { ; ; } datetiR_287_11845@e CreateTime { ; ; } }

2:初始化一些变量

String connectionString = String.Empty; String databasename = String.Empty; String collectionName = String.Empty; MongodbHelper mongodb; 初始化操作 MongodbHelper() { connectionString = ; databasename = ; collectionName = ; }

3:为了方便T的继承类使用linq功能,我们还需要映射一下。

实现linq查询的映射配置 MongoConfiguration configuration { { config = MongoConfigurationBuilder(); config.Mapping(mapping => { mapping.DefaultProfile(profile => { profile.SubClassesAre(t => t.IsSubclassOf((T))); }); mapping.Map(); mapping.Map(); }); config.ConnectionString(connectionString); config.buildConfiguration(); } }

4:下面是一些基本的CURD的代码,跟写EF代码很类似,写起来好舒服。

插入操作 @H_341_197@ Insert(T t) { (Mongo mongo = Mongo(configuration)) { { mongo.Connect(); db = mongo.GetDatabase(databaseName); collection = db.GetCollection(collectionName); collection.Insert(t,); mongo.Disconnect(); } (Exception) { mongo.Disconnect(); ; } } } 更新操作 @H_341_197@ update(T t,Expression>> funC) { (Mongo mongo = Mongo(configuration)) { { mongo.Connect(); db = mongo.GetDatabase(databaseName); collection = db.GetCollection(collectionName); collection.update(t,func,); mongo.Disconnect(); } (Exception) { mongo.Disconnect(); ; } } } 获取集合 @H_341_197@ List List( pageIndex, pageSize,>> func, PageCount) { PageCount = ; (Mongo mongo = Mongo(configuration)) { { mongo.Connect(); db = mongo.GetDatabase(databaseName); collection = db.GetCollection(collectionName); PageCount = Convert.ToInt32(collection.Count()); personList = collection.Linq().Where(funC).Skip(pageSize * (pageIndex - )) .Take(pageSizE).SELEct(i => i).ToList(); mongo.Disconnect(); personList; } (Exception) { mongo.Disconnect(); ; } } } 读取单条记录 @H_341_197@ T Single(Expression>> funC) { (Mongo mongo = Mongo(configuration)) { { mongo.Connect(); db = mongo.GetDatabase(databaseName); collection = db.GetCollection(collectionName); single = collection.Linq().FirstOrDefault(func); mongo.Disconnect(); single; } (Exception) { mongo.Disconnect(); ; } } } 删除操作 @H_341_197@ delete(Expression>> funC) { (Mongo mongo = Mongo(configuration)) { { mongo.Connect(); db = mongo.GetDatabase(databaseName); collection = db.GetCollection(collectionName); ject类型处理 collection.Remove(func); mongo.Disconnect(); } (Exception) { mongo.Disconnect(); ; } } }

5.   好,我们开一下2222端口,由于前前篇我已经把这个mongodb做成了服务,现在就直接连过去了,并做一下对Name的索引。

title="8天学通MongoDB——第八天 驱动实践" alt="8天学通MongoDB——第八天 驱动实践" src="https://cn.js-code.com/res/2019/02-17/00/886c299141725f57dcc438422b3f2c5f.png" >

6. 一切准备妥当,我们做下基本的操作,比如这里我添加一千条数据,注意我开启的是安全模式,如果插入不成功,将会抛出异常。

 <1> Add:

Main(String[] args) { MongodbHelper Helper = MongodbHelper(); ( i = ; i < ; i++) { Helper.Insert( Person() { ID = Guid.NewGuid().ToString(), Name = + i, Age = i, CreateTime = datetiR_287_11845@e.Now }); } Console.WriteLine(); Console.Read(); }

title="8天学通MongoDB——第八天 驱动实践" alt="8天学通MongoDB——第八天 驱动实践" src="https://cn.js-code.com/res/2019/02-17/00/dc3ece7fd8b33ef35747c723532ba472.png" >

乍一看显示的数据以为有问题,为什么没有出现jack0或者jack999,不过find的一下后心情舒坦了。

<2> update:   这里就把jack941的名字改掉“Mary

Main(String[] args) { MongodbHelper Helper = MongodbHelper(); Mary single = Helper.Single(i => i.Name == ); single.Name = Mary; Helper.update(single,i => i.ID == single.ID); Console.WriteLine(); Console.Read(); }

title="8天学通MongoDB——第八天 驱动实践" alt="8天学通MongoDB——第八天 驱动实践" src="https://cn.js-code.com/res/2019/02-17/00/ad1a1a6c74a355124c13a472e510af4b.png" >

<3>delete:  删除Mary这条记录

Main(String[] args) { MongodbHelper Helper = MongodbHelper(); Mary这个记录 Helper.delete(i => i.Name == Mary); Console.WriteLine(); Console.Read(); }

title="8天学通MongoDB——第八天 驱动实践" alt="8天学通MongoDB——第八天 驱动实践" src="https://cn.js-code.com/res/2019/02-17/00/4e40d03fb3847451ec4d44a76913acd3.png" >

<4> list操作: 这里我获取一下名字里面带9的人数列表

Main(String[] args) { MongodbHelper Helper = MongodbHelper(); PageCount; list = Helper.List(,,i => i.Name.Contains(), PageCount); Console.Read(); }

title="8天学通MongoDB——第八天 驱动实践" alt="8天学通MongoDB——第八天 驱动实践" src="https://cn.js-code.com/res/2019/02-17/00/deb180231f2bce63ef0cfe7510577f33.png" >

总的运行代码

0-9a3b-7e1a18ce68d9')"> 0-9a3b-7e1a18ce68d9" class="code_img_closed" src="https://cn.js-code.com/res/2019/02-17/00/1c53668bcee393edac0d7b3b3daff1ae.gif" alt="">0-9a3b-7e1a18ce68d9" class="code_img_opened" style="display: none;" onclick="cnblogs_code_hide('631eaf89-0036-4160-9a3b-7e1a18ce68d9',event)" src="https://cn.js-code.com/res/2019/02-17/00/405b18b4b6584ae338e0f6ecaf736533.gif" alt="">
0-9a3b-7e1a18ce68d9" class="cnblogs_code_hide">
  System;  System.Collections.Generic;  System.Linq;  System.Text;  System.Configuration;  System.Linq.Expressions;   MongoDB.Configuration;  MongoDB.Linq;  MongoDB.Attributes;    MongoDB.Test {       MongodbHelper  T :      {         String connectionString = String.Empty;          String databasename = String.Empty;          String collectionName = String.Empty;           MongodbHelper mongodb;           初始化操作                       MongodbHelper()         {             connectionString = ;             databasename = ;             collectionName = ;         }                    实现linq查询的映射配置                       MongoConfiguration configuration         {                          {                  config =  MongoConfigurationBuilder();                  config.Mapping(mapping =>                 {                     mapping.DefaultProfile(profile =>                     {                         profile.SubClassesAre(t => t.IsSubclassOf((T)));                     });                     mapping.Map();                     mapping.Map();                 });                  config.ConnectionString(connectionString);                   config.buildConfiguration();             }         }                    插入操作                 @H_341_197@           Insert(T t)         {              (Mongo mongo =  Mongo(configuration))             {                                  {                     mongo.Connect();                       db = mongo.GetDatabase(databaseName);                       collection = db.GetCollection(collectionName);                      collection.Insert(t,);                      mongo.Disconnect();                  }                  (Exception)                 {                     mongo.Disconnect();                     ;                 }             }         }                    更新操作                 @H_341_197@           update(T t,>> funC)         {              (Mongo mongo =  Mongo(configuration))             {                                  {                     mongo.Connect();                       db = mongo.GetDatabase(databaseName);                       collection = db.GetCollection(collectionName);                      collection.update(t,);                      mongo.Disconnect();                  }                  (Exception)                 {                     mongo.Disconnect();                     ;                 }             }         }                    获取集合                 @H_341_197@          List List( pageIndex,  PageCount)         {             PageCount = ;               (Mongo mongo =  Mongo(configuration))             {                                  {                     mongo.Connect();                       db = mongo.GetDatabase(databaseName);                       collection = db.GetCollection(collectionName);                      PageCount = Convert.ToInt32(collection.Count());                       personList = collection.Linq().Where(funC).Skip(pageSize * (pageIndex - ))                                                    .Take(pageSizE).SELEct(i => i).ToList();                      mongo.Disconnect();                       personList;                  }                  (Exception)                 {                     mongo.Disconnect();                     ;                 }             }         }                    读取单条记录                 @H_341_197@          T Single(Expression>> funC)         {              (Mongo mongo =  Mongo(configuration))             {                                  {                     mongo.Connect();                       db = mongo.GetDatabase(databaseName);                       collection = db.GetCollection(collectionName);                       single = collection.Linq().FirstOrDefault(func);                      mongo.Disconnect();                       single;                  }                  (Exception)                 {                     mongo.Disconnect();                     ;                 }197             }         }                    删除操作                 @H_341_197@           delete(Expression>> funC)         {              (Mongo mongo =  Mongo(configuration))             {                                  {                     mongo.Connect();                       db = mongo.GetDatabase(databaseName);                       collection = db.GetCollection(collectionName);                      ject类型处理                      collection.Remove(func);                      mongo.Disconnect();                  }                  (Exception)                 {                     mongo.Disconnect();                     ;                 }             }         }              }       数据实体                Person     {         [MongoAlias()]          String ID { ; ; }           String Name { ; ; }            Age { ; ; }           datetiR_287_11845@e CreateTime { ; ; }     }      }

wow,趁着3天的休假,不断的努力终于把这个系列写完了,很感谢一直关注此系列的朋友。

title="8天学通MongoDB——第八天 驱动实践" alt="8天学通MongoDB——第八天 驱动实践" src="https://cn.js-code.com/res/2019/02-17/00/6bf0f8a795001449c96a88f824a5876a.gif" >

大佬总结

以上是大佬教程为你收集整理的8天学通MongoDB——第八天 驱动实践全部内容,希望文章能够帮你解决8天学通MongoDB——第八天 驱动实践所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。
标签: