MongoDB 基础教程CURD帮助类

yw6866

　　最近两天在学习MongoDB，强大的文档数据库。给我最大的感觉就是相比于SQL或者MSQ等传统的关系型数据库，在使用和配置上真的是简化了很多。无论是在集群的配置还是故障转移方面，都省去了许多繁琐的步骤，但最重要是的什么呢？是效率，它的出现解决了传统关系型数据库的IO瓶颈，极大的提高了工作效率，适合海量数据的查询。
　　当然，这些老生常谈的话可能你已经听了很多，耳朵都磨出了茧子，废话少说，整点干货。
　　博客园里关于MongoDB的文章搜一下会出来很多，但是大多都是关于如果安装或者复制集、故障转移等，对于已经学会安装但是希望使用的同学会觉得无从下手，博主感同身受，所以在这里分享一下在.NET中如何使用MongoDB来进行基本的CURD，同时自己写了一个基本的通用帮助类，如果觉得有需要的同学可以拿去使用，觉得有用的可以给个赞，真的，给赞比给钱让我更加欢乐！！！
　　1.两种常用的操作介质
　　在.NET中对MongoDB常用的操作介质有两种，分别是BsonDocument对象模型以及自定义的实体类型。
　　（1）BsonDocument
　　MongoDB是文档型数据库，在MongoDB的Collection中，每个文档可以看做是一个Bson（Binary Json）对象，所以在驱动中有一个BsonDocument类型，它的本质name/value的键值对集合，可以通过下面方式生成一个BsonDocument的文档，并通过Add方法添加键值对，通过这种方式生成的BsonDocumen对象可以直接插入Collection。
　　

BsonDocument student1 = new BsonDocument();　　
student1.Add(
"sid", 10);　　
student1.Add(
"name", "Will10");　　
student1.Add(
"gender", "Male");　　
student1.Add(
"age", 26);　　

　　（2）自定义实体类型
　　关于自定义实体类型可能我们每天都在使用，没有什么需要将的，只有一点，如果你想通过自定义的实体类型操作MongoDB中的数据集合，那么你的实体中的字段名要与MongoDB中的字段名保持一致（如_id与ID这样就不一致，则会报错），而且还需要有_id字段。
　　上面两种方式都可以使用，而且各有好处，通过自定义类型的方式，可以使得collection中的文档有比较统一的模式；使用BsonDocument方式则可以支持更多的文档模式，也就是说如果一个collection中的文档拥有各种各样的模式，那么BsonDocument方式就会更灵活。
　　2.连接数据库
　　供.NET使用的的MongoDB驱动不止一个，官方也有推荐的驱动，这里博主选用的是官方推荐的驱动mongocsharpdriver，可以通过NuGet下载安装。
　　数据库的连接代码如下：
　　

public static void GetColloection(string IP, string Port, string Database, string CollectionName)　　
{
string connection = string.Format("mongodb://{0}:{1}", Database, Port);　　MongoClient client
= new MongoClient(connection)var server = client.GetServer();　　collection
= server.GetDatabase(Database).GetCollection(CollectionName);　　
}
　　

　　这里博主自己封装了一个连接方法，这个连接方法并不好，不够灵活，切换数据集合的时候还要重新输入一遍IP和Port，大家可以自己封装适合自己使用的。
　　3.查询
　　（1）查询集合中所有的数据，并返回List集合：
　　

public static List<T> GetList<T>()　　
{
return collection.FindAllAs<T>().ToList();　　
}
　　

　　（2）根据Id查询集合中对应的数据，返回数据实体：（你的VS中需要有对应的实体model）
　　

public static T GetById<T>(int>
{var query = Query.EQ("_id",>return collection.FindOneAs<T>(query);　　
}
　　

　　这里使用了Query Builder的查询方式，相比QueryDocument（这里没有使用）这是一种更简洁的查询方式，EQ的意思表示“==”，其它还有GT（>）等。当通过这种方式查询的时候，我们需要使用driver中的builder来生成query。所以，要引用下面using语句：
　　

using MongoDB.Driver.Builders;　　

　　通过下面的语句，可以查询年龄大于20的学生：
　　

var query = Query.GT("age", 20);foreach (var student in collection.Find(query))　　{
　　Console.WriteLine(student);
　　}
　　

　　（3）根据字段查询对应的数据实体
　　很多时候我们会根据Id查询数据，但是有些情况下我们可能会用到其它的数据来查询，这里封装了一个方法：
　　

public static List<T> GetValueByKey<T>(string key, string value)　　
{
var query = Query.EQ(key, value);return collection.FindAs<T>(query).ToList();　　
}
　　

　　（4）Linq查询

　　在driver的1.8>　　

using MongoDB.Driver.Linq;　　

　　所以，可以查询年龄大于20的学生，也可以通过下面方式实现：
　　

var linquery = from e in collection.AsQueryable<Student>()where e.age > 20　　select e;
　　

　　
var linquery1 = collection.AsQueryable<Student>().Where(e => e.age > 20);
　　

　　4.新增
　　(1)常用的有Insert方法，它有5个重载，可以根据实际情况选取使用，这里使用它的泛型方法Insert<T>(T document)：
　　

public static void Insert<T>(T model)　　
{
try　　{
　　collection.Insert(model);
　　}
catch (Exception ex)　　{
throw new Exception(ex.Message);　　}
　　
}
　　

　　(2)新增实体集合
　　

public static void Insert<T>(List<T> list)　　
{
try　　{
foreach (var model in list)　　{
　　collection.Insert(model);
　　}
　　}
catch (Exception ex)　　{
throw new Exception(ex.Message);　　}
　　
}
　　

　　5.修改
　　修改的方式有两种，分别是Save和Update，这里没有进行方法封装，给出示例。
　　（1）Save
　　

static void Save(MongoCollection collection)　　
{
var query = Query.EQ("_id", 9);var model = collection.FindOneAs<goods>(query);if (model != null)　　{
　　model.title
= "修改测试";　　collection.Save(model);
　　}
　　
}
　　

　　（2）Update
　　

static void Update(MongoCollection collection)　　
{
var query = Query.EQ("_id", 8);var update = Update<goods>.Set(x=>x.title, "Update修改测试");　　collection.Update(query, update);
　　
}
　　

　　6.删除
　　删除就比较简单了，给出示例和封装的方法：
　　(1)示例
　　

static void Remove(MongoCollection collection)　　
{
var query = Query.EQ("_id", 11);　　collection.Remove(query);
　　
}
　　

　　（2）封装的方法
　　

public static void Remove(IMongoQuery query)　　
{
try　　{
　　collection.Remove(query);
　　}
catch (Exception ex)　　{
throw new Exception(ex.Message);　　}
　　
}
　　

　　好了，基本CURD到这里就完成了，希望前面讲的东西能够帮助到你，说实话，MongoDB真的很强大，但是呢，刚开始学习肯定会有一个懵逼的过程，博主现在还处于懵逼的过程，一边分享一边帮自己梳理。下一篇MongoDB会写一下复制集以及分片，但不会写怎么操作，毕竟园子里一搜一大把（主要是博主自己学的也不咋样），会写一下在使用的过程中的出错点以及其中的原理，比如Master宕掉以后是如何从Slave中选举出一个新的Master以及Slave的种类和作用。