8天学通MongoDB——第八天驱动实践

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

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

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

samus驱动：。

下面就具体看看samus驱动，上面提供了

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

一：实践

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

数据实体 Person { [MongoAlias()] ID { ; ; } Name { ; ; } Age { ; ; } DateTime CreateTime { ; ; } }

2：初始化一些变量

connectionString = .Empty; databaseName = .Empty; collectionName = .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代码很类似，写起来好舒服。

插入操作 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(); ; } } } 更新操作 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(); ; } } } 获取集合获取集合 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(); ; } } } 读取单条记录 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(); ; } } } 删除操作删除操作 Delete(Expression>> func) { (Mongo mongo = Mongo(configuration)) { { mongo.Connect(); db = mongo.GetDatabase(databaseName); collection = db.GetCollection(collectionName); 加上T参数，否则会当作object类型处理删除失败 collection.Remove(func); mongo.Disconnect(); } (Exception) { mongo.Disconnect(); ; } } }

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

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

<1> Add:

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

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

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

Main([] args) { MongodbHelper helper = MongodbHelper(); 修改jack941改成mary single = helper.Single(i => i.Name == ); single.Name = ; helper.Update(single,i => i.ID == single.ID); Console.WriteLine(修改成功); Console.Read(); }

<3>Delete：删除mary这条记录

Main([] args) { MongodbHelper helper = MongodbHelper(); 删除mary这个记录 helper.Delete(i => i.Name == ); Console.WriteLine(删除成功); Console.Read(); }

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

Main([] args) { MongodbHelper helper = MongodbHelper(); pagecount; 获取名字里面带9的人数 list = helper.List(,,i => i.Name.Contains(), pagecount); Console.Read(); }

总的运行代码

System; System.Collections.Generic; System.Linq; System.Text; System.Configuration; System.Linq.Expressions; MongoDB.Configuration; MongoDB.Linq; MongoDB.Attributes; MongoDB.Test { MongodbHelper T : { connectionString = .Empty; databaseName = .Empty; collectionName = .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(); } } 插入操作 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(); ; } } } 更新操作 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(); ; } } } 获取集合获取集合 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(); ; } } } 读取单条记录 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(); ; } } } 删除操作删除操作 Delete(Expression>> func) { (Mongo mongo = Mongo(configuration)) { { mongo.Connect(); db = mongo.GetDatabase(databaseName); collection = db.GetCollection(collectionName); 加上T参数，否则会当作object类型处理删除失败

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

8天学通MongoDB——第八天 驱动实践

猜你在找的MongoDB相关文章

8天学通MongoDB——第八天驱动实践