[总结].net操作MongoDb通用基础类1：-白红宇

[总结].net操作MongoDb通用基础类1：

阅读量：5942 次

发布时间：2019-06-19

本文共 4608 字，大约阅读时间需要 15 分钟。

public class MongoDBHelper    {                //定义Mongo服务        private MongoServer mongo = null;        //获取databaseName对应的数据库，不存在则自动创建        private MongoDatabase mongoDatabase;        ///         /// Mongo 数据库连接        /// 
        public MongoDBHelper()        {            mongo = MongoServer.Create(MongoDBConfig.gConnectionString);            mongoDatabase = mongo.GetDatabase(MongoDBConfig.gDatabaseName) as MongoDatabase;            mongo.Connect();        }        ///         /// Mongo 数据库断开连接        /// 
        public void CloseConnection()        {            if (this.mongo != null)            {                this.mongo.Disconnect();                this.mongo = null;            }        }        ///         /// 根据条件查找所有记录        /// 
        /// 
             public IEnumerable
     
       FindAll(IMongoQuery pQuery,int currentpage,int pagesize, string pTable)        {            //获取collectionName对应的集合，不存在则自动创建            MongoCollection
      
        mongoCollection = mongoDatabase.GetCollection
       
        (pTable) as MongoCollection
        
         ;            return mongoCollection.Find(pQuery).SetLimit(pagesize).SetSkip(pagesize * currentpage).ToList(); ;        }        /// 
                 /// 查找所有记录        /// 
        /// 
                 public IEnumerable
         
           FindAll(int currentpage,int pagesize,string pTable)        {            //获取collectionName对应的集合，不存在则自动创建            MongoCollection
          
            mongoCollection = mongoDatabase.GetCollection
           
            (pTable) as MongoCollection
            
             ; return mongoCollection.FindAll().SetLimit(pagesize).SetSkip(pagesize*currentpage).ToList(); } /// 
              /// 根据条件查找所有记录 /// 
 /// 
              public IEnumerable
             
               FindAll(IMongoQuery pQuery, string pTable) { //获取collectionName对应的集合，不存在则自动创建 MongoCollection
              
                mongoCollection = mongoDatabase.GetCollection
               
                (pTable) as MongoCollection
                
                 ; return mongoCollection.Find(pQuery); } /// 
                  /// 查找所有记录 /// 
 /// 
                  public IEnumerable
                 
                   FindAll(string pTable) { //获取collectionName对应的集合，不存在则自动创建 MongoCollection
                  
                    mongoCollection = mongoDatabase.GetCollection
                   
                    (pTable) as MongoCollection
                    
                     ; return mongoCollection.FindAll(); } /// 
                      /// 增加一条记录 /// 
 /// 
                      public void Add(object obj, string pTable) { //获取collectionName对应的集合，不存在则自动创建 MongoCollection
                     
                       mongoCollection = mongoDatabase.GetCollection
                      
                       (pTable) as MongoCollection
                       
                        ; mongoCollection.Insert(obj); } /// 
                         /// 删除一条记录 /// 
 public void Delete(string id, string pTable) { //获取collectionName对应的集合，不存在则自动创建 MongoCollection
                        
                          mongoCollection = mongoDatabase.GetCollection
                         
                          (pTable) as MongoCollection
                          
                           ; mongoCollection.Remove(new QueryDocument { { "_id", id } }); } #region 获取当前连接数据库的指定集合【依据类型】 /// 
                            /// 获取当前连接数据库的指定集合【依据类型】 /// 
 /// 
                            /// 
                            public MongoCollection
                           
                             GetCollection
                            
                             (string name,WriteConcern writeConcern) where T : class { return this.mongoDatabase.GetCollection
                             
                              (name,writeConcern); } /// 
                               /// 获取当前连接数据库的指定集合【根据指定名称】 /// 
 /// 
                               /// 
                              集合名称 /// 
                               public MongoCollection
                              
                                GetCollection
                               
                                (string pTableName) where T : class { return this.mongoDatabase.GetCollection
                                
                                 (pTableName); } #endregion #region GridFs 文件处理 /// 
                                  /// 保存2进制数据到db里面 /// 
 /// 
                                  /// 
                                  public string GridFsSave(byte[] byteFile) { string filename = Guid.NewGuid().ToString(); //这里GridFile构造函数有个重载，bucket参数就是用来替换那个创建集合名中默认的"fs"的。 MongoGridFS gridFile = new MongoGridFS(mongoDatabase); using (MongoGridFSStream gridFileStream = gridFile.Create(filename)) { gridFileStream.Write(byteFile, 0, byteFile.Length); } return filename; } public void SaveGridFsFile(BsonDocument doc, string pTable) { MongoCollection
                                 
                                   mongoCollection =mongoDatabase.GetCollection
                                  
                                   (pTable) as MongoCollection
                                   
                                    ; mongoCollection.Save(doc); } /// 
                                     /// 读取为filename的文件 /// 
 /// 
                                     /// 
                                     public byte[] GridFsRead(string filename) { MongoGridFS gridFile = new MongoGridFS(mongoDatabase); MongoGridFSStream gridFileStream = gridFile.OpenRead(filename); byte[] bytes = new byte[gridFileStream.Length]; gridFileStream.Read(bytes, 0, bytes.Length); return bytes; } /// 
                                     /// 根据条件取一条数据 /// 
 /// 
                                     /// 
                                     /// 
                                     public BsonDocument GetFsFileInfo(QueryDocument fitter, string pTable) { MongoCollection
                                    
                                      mongoCollection = mongoDatabase.GetCollection
                                     
                                      (pTable) as MongoCollection
                                      
                                       ; BsonDocument doc = mongoCollection.FindOne(fitter); return doc; } /// 
                                        /// 删除文件 /// 
 /// 
                                        public void GridFsDelete(string filename) { MongoGridFS gridFile = new MongoGridFS(mongoDatabase); gridFile.Delete(new QueryDocument("filename", filename)); } #endregion }