windows7下使用MongoDB实现仓储设计_MongoDB_

 dbpath=C:/Program Files/MongoDB/Server/3.4/bin/data/db logpath=C:/Program Files/MongoDB/Server/3.4/bin/data/log/master.log pidfilepath=C:/Program Files/MongoDB/Server/3.4/bin/master.pid directoryperdb=true logappend=true replSet=testrs bind_ip=10.1.5.25 port=27016 oplogSize=10000 noauth = true storageEngine = wiredTiger wiredTigerCacheSizeGB = 2 syncdelay = 30 wiredTigerCollectionBlockCompressor = snappy 

 conf= { "_id" : "testrs", "members" : [ { "_id" : 0, "host" : "10.1.5.25:27016" }, { "_id" : 1, "host" : "10.1.5.26:27016" }, { "_id" : 2, "host" : "10.1.5.27:27016" } ] } rs.initiate(conf) 

 namespace UnitoonIot.Mongo { /// 
 /// 实体基类，方便生成ObjId /// 
 [Serializable] [ProtoContract(ImplicitFields = ImplicitFields.AllPublic)] //[ProtoInclude(10, typeof(NormalHistory))] public class BaseEntity { //[BsonRepresentation(BsonType.ObjectId)] public ObjectId Id { get; set; } /// 
 /// 数据库名称 /// 
 public string DbName { get; set; } /// 
 /// 给对象初值 /// 
 public BaseEntity() { // this.ObjId = ObjectId.GenerateNewId().ToString(); //this.Id = ObjectId.NewObjectId().ToString(); } } } 

 namespace UnitoonIot.Mongo { public interface IMongoRepository where TEntity : class { } } 

 using MongoDB.Driver; using MongoDB.Bson; using System; using System.Collections.Generic; using System.Linq; using System.Linq.Expressions; using System.Text; using System.Threading.Tasks; using MongoDB.Bson.Serialization.Attributes; using MongoDB.Driver.Linq; using System.Configuration; using System.IO; using UnitoonIot.AppSetting; namespace UnitoonIot.Mongo { public class MongoDb { private static string ConnectionStringHost ; private static string UserName ; private static string Password; private static IMongoDatabase _db = null; private static readonly object LockHelper = new object(); /// 
 /// mongodb初始化 /// 
 public static void Init() { ConnectionStringHost = "10.1.5.24:27016,10.1.5.24:27016,10.1.5.26:27017"; //AppSettings.GetConfigValue("MongoHost");//"10.1.5.24:27016"; UserName = AppSettings.GetConfigValue("MongoUserName"); Password = AppSettings.GetConfigValue("MongoPwd"); } static MongoDb() { } public static IMongoDatabase GetDb(string dbName,string options=null) { if (_db != null) return _db; lock (LockHelper) { if (_db != null) return _db; var database = dbName; var userName = UserName; var password = Password; var authentication = string.Empty; var host = string.Empty; if (!string.IsNullOrWhiteSpace(userName)) { authentication = string.Concat(userName, ':', password, '@'); } if (!string.IsNullOrEmpty(options) && !options.StartsWith("?")) { options = string.Concat('?', options); } host = string.IsNullOrEmpty(ConnectionStringHost) ? "localhost" : ConnectionStringHost; database = database ?? "testdb"; //mongodb://[username:password@]host1[:port1][,host2[:port2],…[,hostN[:portN]]][/[database][?options]] var conString = options!=null? $"mongodb://{authentication}{host}/{database}{options}" : $"mongodb://{authentication}{host}/{database}"; var url = new MongoUrl(conString); var mcs = MongoClientSettings.FromUrl(url); mcs.MaxConnectionLifeTime = TimeSpan.FromMilliseconds(1000); var client = new MongoClient(mcs); _db = client.GetDatabase(url.DatabaseName); } return _db; } } /// 
 /// MongoDb 数据库操作类 /// 
 public class MongoRepository: IMongoRepository where T : BaseEntity { #region readonly field /// 
 /// 表名 /// 
 private readonly IMongoCollection _collection = null; /// 
 /// 数据库对象 /// 
 private readonly IMongoDatabase _database; #endregion /// 
 /// 构造函数 /// 
 public MongoRepository() { this._database = MongoDb.GetDb(Activator.CreateInstance().DbName, "readPreference =secondaryPreferred ");//primaryPreferred/secondaryPreferred/nearest _collection = _database.GetCollection(typeof(T).Name); } #region 增加 /// 
 /// 插入对象 /// 
 /// 插入的对象 public virtual T Insert(T t) { // var flag = ObjectId.GenerateNewId(); // t.GetType().GetProperty("Id").SetValue(t, flag); //t.Time = DateTime.Now; _collection.InsertOne(t); return t; } /// 
 /// 批量插入 /// 
 /// 要插入的对象集合 public virtual IEnumerable InsertBatch(IEnumerable ts) { _collection.InsertMany(ts); return ts; } /// 
 /// 插入对象 /// 
 /// 插入的对象 public virtual void InsertAsync(T t) { //var flag = ObjectId.GenerateNewId(); // t.GetType().GetProperty("Id").SetValue(t, flag); // t.Time = DateTime.Now; _collection.InsertOneAsync(t); } /// 
 /// 批量插入 /// 
 /// 要插入的对象集合 public virtual void InsertBatchAsync(IEnumerable ts) { _collection.InsertManyAsync(ts); } #endregion #region 删除 /// 
 /// 删除 /// 
 ///  public virtual long Delete(T t) { var filter = Builders.Filter.Eq("Id", t.Id); var result = _collection.DeleteOne(filter); return result.DeletedCount; } /// 
 /// 删除 /// 
 ///  public virtual void DeleteAsync(T t) { var filter = Builders.Filter.Eq("Id", t.Id); _collection.DeleteOneAsync(filter); } /// 
 /// 按条件表达式删除 /// 
 /// 条件表达式 ///  public virtual long Delete(Expression> predicate) { var result = _collection.DeleteOne(predicate); return result.DeletedCount; } /// 
 /// 按条件表达式删除 /// 
 /// 条件表达式 ///  public virtual void DeleteAsync(Expression> predicate) { _collection.DeleteOneAsync(predicate); } /// 
 /// 按条件表达式批量删除 /// 
 /// 条件表达式 ///  public virtual long DeleteBatch(Expression> predicate) { var result = _collection.DeleteMany(predicate); return result.DeletedCount; } /// 
 /// 按条件表达式批量删除 /// 
 /// 条件表达式 ///  public virtual void DeleteBatchAsync(Expression> predicate) { _collection.DeleteManyAsync(predicate); } /// 
 /// 按检索条件删除 /// 建议用Builders构建复杂的查询条件 /// 
 /// 条件 ///  public virtual long Delete(FilterDefinition filter) { var result = _collection.DeleteOne(filter); return result.DeletedCount; } /// 
 /// 按检索条件删除 /// 建议用Builders构建复杂的查询条件 /// 
 /// 条件 ///  public virtual void DeleteAsync(FilterDefinition filter) { _collection.DeleteOneAsync(filter); } #endregion #region 修改 /// 
 /// 修改(Id不变) /// 
 ///  public virtual long Update(T t) { var filterBuilder = Builders.Filter; var filter = filterBuilder.Eq("Id",t.Id); var update = _collection.ReplaceOne(filter, t, new UpdateOptions() { IsUpsert = true }); return update.ModifiedCount; } /// 
 /// 修改(Id不变) /// 
 ///  public virtual void UpdateAsync(T t) { var filterBuilder = Builders.Filter; var filter = filterBuilder.Eq("Id", t.Id); _collection.ReplaceOneAsync(filter, t, new UpdateOptions() { IsUpsert = true }); } /// 
 /// 用新对象替换新文档 /// 
 /// 查询条件 /// 对象 /// 修改影响文档数 public virtual long Update(Expression> filter, T t) { var update = _collection.ReplaceOne(filter, t, new UpdateOptions() { IsUpsert = true }); return update.ModifiedCount; } /// 
 /// 用新对象替换新文档 /// 
 /// 查询条件 /// 对象 /// 修改影响文档数 public virtual long Update(FilterDefinition filter, T t) { var update = _collection.ReplaceOne(filter, t, new UpdateOptions() { IsUpsert = true }); return update.ModifiedCount; } /// 
 /// 用新对象替换新文档 /// 
 /// 查询条件 /// 对象 /// 修改影响文档数 public virtual void UpdateAsync(Expression> filter, T t) { _collection.ReplaceOneAsync(filter, t, new UpdateOptions() { IsUpsert = true }); } /// 
 /// 用新对象替换新文档 /// 
 /// 查询条件提示：
                    本文由神整理自网络，如有侵权请联系本站删除！
                    

                    本站声明： 

                    1、本站所有资源均来源于互联网，不保证100%完整、不提供任何技术支持； 

                    2、本站所发布的文章以及附件仅限用于学习和研究目的;不得将用于商业或者非法用途；否则由此产生的法律后果，本站概不负责！
                

                

                

                                            
上一篇：java操作mongoDB查询的实例详解_MongoDB_
                                                                
下一篇：关于Mongodb 认证鉴权你需要知道的一些事_MongoDB_