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_666_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_777_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_777_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_777_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_777_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(); ; } } } 删除操作 
