作为系列的最后一篇,得要说说C#驱动对mongodb的操作,目前驱动有两种:官方驱动和samus驱动,不过我个人还是喜欢后者,
因为提供了丰富的linq操作,相当方便。
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(); ; } } } 删除操作