最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

windows7下使用MongoDB實現(xiàn)倉儲設(shè)計

 更新時間:2017年09月29日 08:41:57   作者:八百  
本文給大家介紹了本人在物聯(lián)網(wǎng)環(huán)境下基于MongoDB實現(xiàn)的倉儲的配置信息及具體的使用示例,非常的實用,有需要的小伙伴可以參考下

簡單的介紹一下,我使用MongoDB的場景。

我們現(xiàn)在的物聯(lián)網(wǎng)環(huán)境下,有部分數(shù)據(jù),采樣頻率為2000條記錄/分鐘,這樣下來一天24*60*2000=2880000約等于300萬條數(shù)據(jù),以后必然還會增加。之前數(shù)據(jù)庫使用的是mssql,對于數(shù)據(jù)庫的壓力很大,同時又需要保證歷史查詢的響應(yīng)速度,這種情況下,在單表中數(shù)據(jù)量大,同時存在讀寫操作。不得已采用MongoDB來存儲數(shù)據(jù)。如果使用MongoDB,則至少需要三臺機器,兩臺實現(xiàn)讀寫分離,一臺作為仲裁(當(dāng)然條件不允許也可以不用),每臺機器的內(nèi)存暫時配置在16G,公司小,沒辦法,據(jù)說,使用這個MongoDB需要機器內(nèi)存最少92G,我沒有驗證過,但是吃內(nèi)存是公認的,所以內(nèi)存絕對要保證,就算保證了,也不一定完全就沒有意外發(fā)生。我們上面的這些特殊的數(shù)據(jù)是允許少量的丟失的,這些只是做分析使用的,幾個月了,暫時還沒出現(xiàn)數(shù)據(jù)丟失的情況,可能最新版本早就修復(fù)了吧,新手使用建議多看下官網(wǎng)上的說明。下面直接奔入主題:

一、安裝部署和配置環(huán)境

1.安裝部署mongo-server(V3.4)

參考 點擊這里進入

這個時候不要啟動,接著配置config文件

2.配置Config文件

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

以上是詳細的配置參數(shù),其中路徑部分根據(jù)需要更改, 這里設(shè)置的oplogsize大小為10G,根據(jù)業(yè)務(wù)場景進行調(diào)整,另外auth權(quán)限為null,因為設(shè)置權(quán)限會增加服務(wù)開銷,影響效率,最下面幾行是內(nèi)存引擎,可以控制副本集同步及內(nèi)存限制,防止內(nèi)存泄露。

3.啟動mongo-server

4.添加副本集配置

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)

此時副本集集群配置已經(jīng)完成,然后在命令行中輸入:rs.status(),查看副本集狀態(tài),需要查看同步情況,可以輸入命令:db.serverStatus().

5.設(shè)置副本集可讀寫

Rs.slaveOk()

6..NET操作mongo

連接設(shè)置,請參考個人封裝Unitoon.Mongo代碼所示。

7.性能對比

讀寫速度:Redis>Mongo>Mssqlserver

可容納數(shù)據(jù)量:Mssqlserver~Mongo>Redis

存儲數(shù)據(jù)類型:Mongo>Mssqlserver>Redis

Note:內(nèi)存持續(xù)上升,內(nèi)部沒有內(nèi)存回收機制,若限制內(nèi)存 ,則可能出現(xiàn)查詢速度變慢,數(shù)據(jù)丟失等問題,建議優(yōu)化查詢效率,建立索引

Db.test.ensureIndex({"username":1, "age":-1})

強制釋放內(nèi)存命令:db.runCommand({closeAllDatabases:1})

二、倉儲設(shè)計

1.基類BaseEntity

namespace UnitoonIot.Mongo
{
  /// <summary>
  /// 實體基類,方便生成ObjId
  /// </summary>
  [Serializable]
  [ProtoContract(ImplicitFields = ImplicitFields.AllPublic)]
  //[ProtoInclude(10, typeof(NormalHistory))]
  public class BaseEntity
  {
    //[BsonRepresentation(BsonType.ObjectId)]
    public ObjectId Id { get; set; }
 
    /// <summary>
    /// 數(shù)據(jù)庫名稱
    /// </summary>
    public string DbName { get; set; }
 
    /// <summary>
    /// 給對象初值
    /// </summary>
    public BaseEntity()
    {
      // this.ObjId = ObjectId.GenerateNewId().ToString();
      //this.Id = ObjectId.NewObjectId().ToString();
    }
  }
}


這里需要注意時間格式,MongoDB默認時間格式為國際時間,所以在寫入數(shù)據(jù)時和讀取數(shù)據(jù)時,時間格式要一致,此例中沒有對時間進行特殊處理,由傳入的時間格式確定。

2.Repository繼承接口IMongoRepository

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


3.MongoRepository

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();
    /// <summary>
    /// mongodb初始化
    /// </summary>
    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;
    }
  }
  /// <summary>
  /// MongoDb 數(shù)據(jù)庫操作類
  /// </summary>
  public class MongoRepository<T>: IMongoRepository<T> where T : BaseEntity
  {
    #region readonly field
    /// <summary>
    /// 表名
    /// </summary>
    private readonly IMongoCollection<T> _collection = null;
    /// <summary>
    /// 數(shù)據(jù)庫對象
    /// </summary>
    private readonly IMongoDatabase _database;
    #endregion
 
    /// <summary>
    /// 構(gòu)造函數(shù)
    /// </summary>
    public MongoRepository()
    {
      this._database = MongoDb.GetDb(Activator.CreateInstance<T>().DbName, "readPreference =secondaryPreferred ");//primaryPreferred/secondaryPreferred/nearest
      _collection = _database.GetCollection<T>(typeof(T).Name);
    }
   
 
    #region 增加
    /// <summary>
    /// 插入對象
    /// </summary>
    /// <param name="t">插入的對象</param>
    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;
    }
    /// <summary>
    /// 批量插入
    /// </summary>
    /// <param name="ts">要插入的對象集合</param>
    public virtual IEnumerable<T> InsertBatch(IEnumerable<T> ts)
    {
      _collection.InsertMany(ts);
      return ts;
    }
 
    /// <summary>
    /// 插入對象
    /// </summary>
    /// <param name="t">插入的對象</param>
    public virtual void InsertAsync(T t)
    {
      //var flag = ObjectId.GenerateNewId();
      // t.GetType().GetProperty("Id").SetValue(t, flag);
      // t.Time = DateTime.Now;
       _collection.InsertOneAsync(t);
    }
    /// <summary>
    /// 批量插入
    /// </summary>
    /// <param name="ts">要插入的對象集合</param>
    public virtual void InsertBatchAsync(IEnumerable<T> ts)
    {
       _collection.InsertManyAsync(ts);
    }
    #endregion
 
    #region 刪除
    /// <summary>
    /// 刪除
    /// </summary>
    /// <returns></returns>
    public virtual long Delete(T t)
    {
      var filter = Builders<T>.Filter.Eq("Id", t.Id);
      var result = _collection.DeleteOne(filter);
      return result.DeletedCount;     
    }
    /// <summary>
    /// 刪除
    /// </summary>
    /// <returns></returns>
    public virtual void DeleteAsync(T t)
    {
      var filter = Builders<T>.Filter.Eq("Id", t.Id);
      _collection.DeleteOneAsync(filter);
    }
 
    /// <summary>
    /// 按條件表達式刪除
    /// </summary>
    /// <param name="predicate">條件表達式</param>
    /// <returns></returns>
    public virtual long Delete(Expression<Func<T, bool>> predicate)
    {
      var result = _collection.DeleteOne(predicate);
      return result.DeletedCount;
    }
    /// <summary>
    /// 按條件表達式刪除
    /// </summary>
    /// <param name="predicate">條件表達式</param>
    /// <returns></returns>
    public virtual void DeleteAsync(Expression<Func<T, bool>> predicate)
    {
      _collection.DeleteOneAsync(predicate);
    }
 
 
    /// <summary>
    /// 按條件表達式批量刪除
    /// </summary>
    /// <param name="predicate">條件表達式</param>
    /// <returns></returns>
    public virtual long DeleteBatch(Expression<Func<T, bool>> predicate)
    {
      var result = _collection.DeleteMany(predicate);
      return result.DeletedCount;
    }
    /// <summary>
    /// 按條件表達式批量刪除
    /// </summary>
    /// <param name="predicate">條件表達式</param>
    /// <returns></returns>
    public virtual void DeleteBatchAsync(Expression<Func<T, bool>> predicate)
    {
       _collection.DeleteManyAsync(predicate);
    }
 
    /// <summary>
    /// 按檢索條件刪除
    /// 建議用Builders<T>構(gòu)建復(fù)雜的查詢條件
    /// </summary>
    /// <param name="filter">條件</param>
    /// <returns></returns>
    public virtual long Delete(FilterDefinition<T> filter)
    {
      var result = _collection.DeleteOne(filter);
      return result.DeletedCount;
    }
 
    /// <summary>
    /// 按檢索條件刪除
    /// 建議用Builders<T>構(gòu)建復(fù)雜的查詢條件
    /// </summary>
    /// <param name="filter">條件</param>
    /// <returns></returns>
    public virtual void DeleteAsync(FilterDefinition<T> filter)
    {
       _collection.DeleteOneAsync(filter);
    }
    #endregion
 
    #region 修改
    /// <summary>
    /// 修改(Id不變)
    /// </summary>  
    /// <returns></returns>
    public virtual long Update(T t)
    {     
      var filterBuilder = Builders<T>.Filter;
      var filter = filterBuilder.Eq("Id",t.Id);
      var update = _collection.ReplaceOne(filter, t, new UpdateOptions() { IsUpsert = true });
      return update.ModifiedCount;
    }
    /// <summary>
    /// 修改(Id不變)
    /// </summary>  
    /// <returns></returns>
    public virtual void UpdateAsync(T t)
    {
      var filterBuilder = Builders<T>.Filter;
      var filter = filterBuilder.Eq("Id", t.Id);
       _collection.ReplaceOneAsync(filter, t, new UpdateOptions() { IsUpsert = true });
       
    }
 
 
    /// <summary>
    /// 用新對象替換新文檔
    /// </summary>
    /// <param name="filter">查詢條件</param>
    /// <param name="t">對象</param>
    /// <returns>修改影響文檔數(shù)</returns>
    public virtual long Update(Expression<Func<T, bool>> filter, T t)
    {
      var update = _collection.ReplaceOne(filter, t, new UpdateOptions() { IsUpsert = true });
      return update.ModifiedCount;
    }
 
 
    /// <summary>
    /// 用新對象替換新文檔
    /// </summary>
    /// <param name="filter">查詢條件</param>
    /// <param name="t">對象</param>
    /// <returns>修改影響文檔數(shù)</returns>
    public virtual long Update(FilterDefinition<T> filter, T t)
    {
      var update = _collection.ReplaceOne(filter, t, new UpdateOptions() { IsUpsert = true });
      return update.ModifiedCount;
    }
    /// <summary>
    /// 用新對象替換新文檔
    /// </summary>
    /// <param name="filter">查詢條件</param>
    /// <param name="t">對象</param>
    /// <returns>修改影響文檔數(shù)</returns>
    public virtual void UpdateAsync(Expression<Func<T, bool>> filter, T t)
    {
      _collection.ReplaceOneAsync(filter, t, new UpdateOptions() { IsUpsert = true });
      
    }
    /// <summary>
    /// 用新對象替換新文檔
    /// </summary>
    /// <param name="filter">查詢條件</param>
    /// <param name="t">對象</param>
    /// <returns>修改影響文檔數(shù)</returns>
    public virtual void UpdateAsync(FilterDefinition<T> filter, T t)
    {
       _collection.ReplaceOneAsync(filter, t, new UpdateOptions() { IsUpsert = true });
       
    }
    /// <summary>
    /// 根據(jù)Id和條件文檔
    /// </summary>
    /// <param name="update">修改條件-形如:Builders/<T/>.Update.Set(filed, value)</param>
    /// <param name="id">對象Id</param>
    /// <returns>修改影響文檔數(shù)</returns>
    public virtual long Update(string id, UpdateDefinition<T> update)
    {
      var filterBuilder = Builders<T>.Filter;
      var filter = filterBuilder.Eq("Id", new ObjectId(id));
      var result = _collection.UpdateOne(filter, update, new UpdateOptions() { IsUpsert = true });
      return result.ModifiedCount;
    }
    /// <summary>
    /// 根據(jù)Id和條件文檔
    /// </summary>
    /// <param name="update">修改條件-形如:Builders/<T/>.Update.Set(filed, value)</param>
    /// <param name="id">對象Id</param>
    /// <returns>修改影響文檔數(shù)</returns>
    public virtual void UpdateAsync(string id, UpdateDefinition<T> update)
    {
      var filterBuilder = Builders<T>.Filter;
      var filter = filterBuilder.Eq("Id", new ObjectId(id));
      _collection.UpdateOneAsync(filter, update, new UpdateOptions() { IsUpsert = true });    
    }
    /// <summary>
    /// 根據(jù)條件修改文檔
    /// </summary>
    /// <param name="update">修改條件-形如:Builders/<T/>.Update.Set(filed, value)</param>
    /// <param name="filter">查詢條件Builders/<T/>.Filter.Eq(filed, value)</param>
    /// <returns>修改影響文檔數(shù)</returns>
    public virtual void Update(UpdateDefinition<T> update,Expression<Func<T, bool>> filter)
    {
      _collection.UpdateOne(filter, update, new UpdateOptions() { IsUpsert = true });
    }
    /// <summary>
    /// 根據(jù)條件修改文檔
    /// </summary>
    /// <param name="update">修改條件-形如:Builders/<T/>.Update.Set(filed, value)</param>
    /// <param name="filter">查詢條件Builders/<T/>.Filter.Eq(filed, value)</param>
    /// <returns>修改影響文檔數(shù)</returns>
    public virtual long Update(UpdateDefinition<T> update, FilterDefinition<T> filter)
    {
      var result = _collection.UpdateOne(filter, update, new UpdateOptions() { IsUpsert = true });
      return result.ModifiedCount;
    }
    /// <summary>
    /// 根據(jù)條件修改文檔
    /// </summary>
    /// <param name="update">修改條件-形如:Builders/<T/>.Update.Set(filed, value)</param>
    /// <param name="filter">查詢條件Builders/<T/>.Filter.Eq(filed, value)</param>
    /// <returns>修改影響文檔數(shù)</returns>
    public virtual void UpdateAsync(UpdateDefinition<T> update, Expression<Func<T, bool>> filter)
    {
      _collection.UpdateOneAsync(filter, update, new UpdateOptions() { IsUpsert = true });
    }
    /// <summary>
    /// 根據(jù)條件修改文檔
    /// </summary>
    /// <param name="update">修改條件-形如:Builders/<T/>.Update.Set(filed, value)</param>
    /// <param name="filter">查詢條件Builders/<T/>.Filter.Eq(filed, value)</param>
    /// <returns>修改影響文檔數(shù)</returns>
    public virtual void UpdateAsync(UpdateDefinition<T> update, FilterDefinition<T> filter)
    {
       _collection.UpdateOneAsync(filter, update, new UpdateOptions() { IsUpsert = true });
    }
 
    /// <summary>
    /// 根據(jù)條件批量修改文檔
    /// </summary>
    /// <param name="update">修改條件-形如:Builders/<T/>.Update.Set(filed, value)</param>
    /// <param name="filter">查詢條件Builders/<T/>.Filter.Eq(filed, value)</param>
    /// <returns>修改影響文檔數(shù)</returns>
    public virtual long UpdateBatch(UpdateDefinition<T> update, Expression<Func<T, bool>> filter)
    {
      var result = _collection.UpdateMany(filter, update, new UpdateOptions() { IsUpsert = true });
      return result.ModifiedCount;
    }
 
    /// <summary>
    /// 根據(jù)條件批量修改文檔
    /// </summary>
    /// <param name="update">修改條件-形如:Builders/<T/>.Update.Set(filed, value)</param>
    /// <param name="filter">查詢條件Builders/<T/>.Filter.Eq(filed, value)</param>
    /// <returns>修改影響文檔數(shù)</returns>
    public virtual long UpdateBatch(UpdateDefinition<T> update, FilterDefinition<T> filter)
    {
      var result = _collection.UpdateMany(filter, update, new UpdateOptions() { IsUpsert = true });
      return result.ModifiedCount;
    }
    /// <summary>
    /// 根據(jù)條件批量修改文檔
    /// </summary>
    /// <param name="update">修改條件-形如:Builders/<T/>.Update.Set(filed, value)</param>
    /// <param name="filter">查詢條件Builders/<T/>.Filter.Eq(filed, value)</param>
    /// <returns>修改影響文檔數(shù)</returns>
    public virtual void UpdateBatchAsync(UpdateDefinition<T> update, Expression<Func<T, bool>> filter)
    {
       _collection.UpdateManyAsync(filter, update, new UpdateOptions() { IsUpsert = true });
    }
 
    /// <summary>
    /// 根據(jù)條件批量修改文檔
    /// </summary>
    /// <param name="update">修改條件-形如:Builders/<T/>.Update.Set(filed, value)</param>
    /// <param name="filter">查詢條件Builders/<T/>.Filter.Eq(filed, value)</param>
    /// <returns>修改影響文檔數(shù)</returns>
    public virtual void UpdateBatchAsync(UpdateDefinition<T> update, FilterDefinition<T> filter)
    {
      _collection.UpdateManyAsync(filter, update, new UpdateOptions() { IsUpsert = true });
    }
    #endregion
 
    #region 查詢 
 
    #region GetCollection
 
    /// <summary>
    /// 獲取操作對象的IMongoCollection集合,強類型對象集合
    /// </summary>
    /// <returns></returns>
    public virtual IMongoCollection<T> GetCollection()
    {
      return _database.GetCollection<T>(typeof(T).Name);
    }
 
    #endregion
 
    #region GetSingle
    /// <summary>
    /// 查詢數(shù)據(jù)庫,檢查是否存在指定ID的對象
    /// </summary>
    /// <param name="id">對象的ID值</param>
    /// <returns>存在則返回指定的對象,否則返回Null</returns>
    public virtual T GetById(string id)
    {
      var filterBuilder = Builders<T>.Filter;
      var filter = filterBuilder.Eq("Id", new ObjectId(id));
      var data = _collection.Find(filter).FirstOrDefault();
      return data;
    }
    /// <summary>
    /// 查詢數(shù)據(jù)庫,檢查是否存在指定ID的對象
    /// </summary>
    /// <param name="id">對象的ID值</param>
    /// <returns>存在則返回指定的對象,否則返回Null</returns>
    public virtual async Task<T> GetAsyncById(string id)
    {
      var filterBuilder = Builders<T>.Filter;
      var filter = filterBuilder.Eq("Id", new ObjectId(id));
      var data = await _collection.FindAsync(filter);
      return await data.SingleOrDefaultAsync();
    }
    /// <summary>
    /// 查詢數(shù)據(jù)
    /// </summary>
    /// <param name="filter">過濾條件</param>
    /// <returns></returns>
    public virtual T Get(FilterDefinition<T> filter)
    {
      return _collection.Find(filter).FirstOrDefault();
    }
    /// <summary>
    /// 查詢數(shù)據(jù)
    /// </summary>
    /// <param name="filter">條件表達式</param>
    /// <returns></returns>
    public virtual T Get(Expression<Func<T,bool>> filter)
    {
      return _collection.Find(filter).FirstOrDefault();
    }
    /// <summary>
    /// 查詢數(shù)據(jù)
    /// </summary>
    /// <param name="filter">過濾條件</param>
    /// <returns></returns>
    public virtual async Task<T> GetAsync(FilterDefinition<T> filter)
    {
      var data = await _collection.FindAsync(filter);
      return await data.SingleOrDefaultAsync();
    }
    /// <summary>
    /// 查詢數(shù)據(jù)
    /// </summary>
    /// <param name="filter">條件表達式</param>
    /// <returns></returns>
    public virtual async Task<T> GetAsync(Expression<Func<T, bool>> filter)
    {
      var data = await _collection.FindAsync(filter);
      return await data.SingleOrDefaultAsync();
    }
 
 
    #endregion
 
    #region GetMany
    /// <summary>
    /// 查詢部分數(shù)據(jù)
    /// </summary>
    /// <param name="filter">過濾條件</param>
    /// <returns></returns>
    public virtual IEnumerable<T> GetMany(FilterDefinition<T> filter)
    {
      return _collection.Find(filter).ToEnumerable();
    }
 
    /// <summary>
    /// 查詢部分數(shù)據(jù)
    /// </summary>
    /// <param name="filter">條件表達式</param>
    /// <returns></returns>
    public virtual IEnumerable<T> GetMany(Expression<Func<T,bool>> filter)
    {
      //return _collection.AsQueryable().Where(filter).ToList();
      //return _collection.AsQueryable().Where(filter);
      return _collection.Find(filter).ToEnumerable(); //.ToEnumerable(); 
    }
 
    /// <summary>
    /// 查詢部分數(shù)據(jù)
    /// </summary>
    /// <param name="filter">過濾條件</param>
    /// <returns></returns>
    public virtual async Task<IEnumerable<T>> GetManyAsync(FilterDefinition<T> filter)
    {
      var data = await _collection.FindAsync(filter);
      return await data.ToListAsync();
    }
 
    /// <summary>
    /// 查詢部分數(shù)據(jù)
    /// </summary>
    /// <param name="filter">過濾條件</param>
    /// <returns></returns>
    public virtual async Task<IEnumerable<T>> GetManyAsync(Expression<Func<T, bool>> filter)
    {
      var data = await _collection.FindAsync(filter);
      return await data.ToListAsync();
    }
     
    #endregion
 
    #region GetAll
 
    /// <summary>
    /// 查詢所有記錄,復(fù)雜查詢直接用Linq處理(避免全表掃描)
    /// </summary>
    /// <returns>要查詢的對象</returns>
    public virtual IEnumerable<T> GetAll()
    {
      var data = _collection.AsQueryable();
      return data.ToEnumerable();
    }
    /// <summary>
    /// 查詢所有記錄,復(fù)雜查詢直接用Linq處理(避免全表掃描)
    /// </summary>
    /// <returns>要查詢的對象</returns>
    public virtual async Task<IEnumerable<T>> GetAllAsync()
    {
      var data = _collection.AsQueryable();
      return await data.ToListAsync();
    }
 
    /// <summary>
    /// 查詢所有記錄,復(fù)雜查詢直接用Linq處理(避免全表掃描)
    /// </summary>
    /// <returns>要查詢的對象</returns>
    public virtual IQueryable<T> GetAllQueryable()
    {
      return _collection.AsQueryable();
    }
 
    #endregion
 
    #region MapReduce
    /// <summary> 
    /// MapReduce
    /// </summary>   
    /// <returns>返回一個List列表數(shù)據(jù)</returns> 
    public IEnumerable<T> GetMap(BsonJavaScript map,BsonJavaScript reduce)
    {
      return _collection.MapReduce<T>(map,reduce).ToList();
    }
 
 
    #endregion
 
    #endregion
  }
 
}


好了,就介紹到這里。

相關(guān)文章

  • Mongodb基本操作與Python連接mongodb并進行基礎(chǔ)操作的方法

    Mongodb基本操作與Python連接mongodb并進行基礎(chǔ)操作的方法

    mongodb是基于分布式文件存儲的nosql(非關(guān)系型)數(shù)據(jù)庫,本文分享了mongodb的基礎(chǔ)操作和Python連接并操作mongodb的基礎(chǔ)方法,基礎(chǔ)的不能再基礎(chǔ)了
    2018-09-09
  • java操作mongoDB查詢的實例詳解

    java操作mongoDB查詢的實例詳解

    這篇文章主要介紹了java操作mongo查詢的實例詳解的相關(guān)資料,希望通過本文能幫助到大家,需要的朋友可以參考下
    2017-09-09
  • mongodb?數(shù)據(jù)塊的遷移流程分析

    mongodb?數(shù)據(jù)塊的遷移流程分析

    這篇文章主要介紹了mongodb?數(shù)據(jù)塊的遷移流程介紹,包括數(shù)據(jù)塊遷移對集群性能的影響,建議設(shè)置平衡器的活躍時間窗口,設(shè)置為業(yè)務(wù)低估時進行,具體操作步驟文中有介紹,需要的朋友可以參考下
    2022-04-04
  • MongoDB 常用的數(shù)據(jù)類型和基本操作

    MongoDB 常用的數(shù)據(jù)類型和基本操作

    這篇文章主要介紹了MongoDB 常用的數(shù)據(jù)類型和基本操作,幫助大家更好的理解和學(xué)習(xí)使用MongoDB數(shù)據(jù)庫,感興趣的朋友可以了解下
    2021-03-03
  • MongoDB入門教程之常用的運維技術(shù)介紹

    MongoDB入門教程之常用的運維技術(shù)介紹

    這篇文章主要介紹了MongoDB入門教程之常用的運維技術(shù)介紹,講解了安裝部署、狀態(tài)監(jiān)控、安全認證、備份和恢復(fù)等內(nèi)容,需要的朋友可以參考下
    2014-08-08
  • NoSQL反模式 - 文檔數(shù)據(jù)庫篇

    NoSQL反模式 - 文檔數(shù)據(jù)庫篇

    我們設(shè)計關(guān)系數(shù)據(jù)庫Schema的都有一套完整的方案,而NoSQL卻沒有這些。半年前筆者讀了本《SQL反模式》的書,覺得非常好。就開始留意,對于NoSQL是否也有反模式?好的反模式可以在我們設(shè)計Schema告訴哪里是陷阱和懸崖。
    2014-08-08
  • CentOS8?安裝MongoDB?本地連接的操作方法

    CentOS8?安裝MongoDB?本地連接的操作方法

    MongoDB 是一個由 C++ 語言編寫的基于分布式文件存儲的數(shù)據(jù)庫,MongoDB 是一個介于關(guān)系數(shù)據(jù)庫和非關(guān)系數(shù)據(jù)庫之間的產(chǎn)品,是非關(guān)系數(shù)據(jù)庫當(dāng)中功能最豐富,最像關(guān)系數(shù)據(jù)庫的,這篇文章主要介紹了CentOS8?安裝MongoDB?本地連接,需要的朋友可以參考下
    2022-11-11
  • mongodb啟動方法小結(jié)

    mongodb啟動方法小結(jié)

    這篇文章主要介紹了mongodb啟動方法小結(jié),啟動Mongodb服務(wù)有兩種方式,前臺啟動或者Daemon方式啟動,每種方式給大家介紹的非常詳細,對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2022-01-01
  • MongoDB連接和創(chuàng)建數(shù)據(jù)庫的方法講解

    MongoDB連接和創(chuàng)建數(shù)據(jù)庫的方法講解

    這篇文章介紹了MongoDB連接和創(chuàng)建數(shù)據(jù)庫的方法,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2022-03-03
  • MongoDB基礎(chǔ)之集合操作

    MongoDB基礎(chǔ)之集合操作

    這篇文章介紹了MongoDB基礎(chǔ)之集合操作,文中通過示例代碼介紹的非常詳細。對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2022-06-06

最新評論

封开县| 九江市| 牙克石市| 井冈山市| 乐平市| 安康市| 当阳市| 辛集市| 会理县| 沧源| 信丰县| 黄龙县| 昌图县| 凭祥市| 阿克苏市| 容城县| 霍林郭勒市| 洛南县| 循化| 广南县| 时尚| 阳高县| 富锦市| 瑞金市| 霍山县| 固阳县| 孟连| 广元市| 中方县| 宣恩县| 大安市| 集安市| 广平县| 麻栗坡县| 咸阳市| 宜宾县| 托克托县| 嘉峪关市| 卢氏县| 嘉荫县| 富源县|