簡(jiǎn)單的介紹一下,我使用MongoDB的場(chǎng)景。
成都創(chuàng)新互聯(lián)公司企業(yè)建站,十多年網(wǎng)站建設(shè)經(jīng)驗(yàn),專注于網(wǎng)站建設(shè)技術(shù),精于網(wǎng)頁(yè)設(shè)計(jì),有多年建站和網(wǎng)站代運(yùn)營(yíng)經(jīng)驗(yàn),設(shè)計(jì)師為客戶打造網(wǎng)絡(luò)企業(yè)風(fēng)格,提供周到的建站售前咨詢和貼心的售后服務(wù)。對(duì)于成都網(wǎng)站建設(shè)、成都網(wǎng)站設(shè)計(jì)中不同領(lǐng)域進(jìn)行深入了解和探索,創(chuàng)新互聯(lián)在網(wǎng)站建設(shè)中充分了解客戶行業(yè)的需求,以靈動(dòng)的思維在網(wǎng)頁(yè)中充分展現(xiàn),通過對(duì)客戶行業(yè)精準(zhǔn)市場(chǎng)調(diào)研,為客戶提供的解決方案。
我們現(xiàn)在的物聯(lián)網(wǎng)環(huán)境下,有部分?jǐn)?shù)據(jù),采樣頻率為2000條記錄/分鐘,這樣下來一天24*60*2000=2880000約等于300萬條數(shù)據(jù),以后必然還會(huì)增加。之前數(shù)據(jù)庫(kù)使用的是mssql,對(duì)于數(shù)據(jù)庫(kù)的壓力很大,同時(shí)又需要保證歷史查詢的響應(yīng)速度,這種情況下,在單表中數(shù)據(jù)量大,同時(shí)存在讀寫操作。不得已采用MongoDB來存儲(chǔ)數(shù)據(jù)。如果使用MongoDB,則至少需要三臺(tái)機(jī)器,兩臺(tái)實(shí)現(xiàn)讀寫分離,一臺(tái)作為仲裁(當(dāng)然條件不允許也可以不用),每臺(tái)機(jī)器的內(nèi)存暫時(shí)配置在16G,公司小,沒辦法,據(jù)說,使用這個(gè)MongoDB需要機(jī)器內(nèi)存最少92G,我沒有驗(yàn)證過,但是吃內(nèi)存是公認(rèn)的,所以內(nèi)存絕對(duì)要保證,就算保證了,也不一定完全就沒有意外發(fā)生。我們上面的這些特殊的數(shù)據(jù)是允許少量的丟失的,這些只是做分析使用的,幾個(gè)月了,暫時(shí)還沒出現(xiàn)數(shù)據(jù)丟失的情況,可能最新版本早就修復(fù)了吧,新手使用建議多看下官網(wǎng)上的說明。下面直接奔入主題:
一、安裝部署和配置環(huán)境
1.安裝部署mongo-server(V3.4)
參考 點(diǎn)擊這里進(jìn)入
這個(gè)時(shí)候不要啟動(dòng),接著配置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
以上是詳細(xì)的配置參數(shù),其中路徑部分根據(jù)需要更改, 這里設(shè)置的oplogsize大小為10G,根據(jù)業(yè)務(wù)場(chǎng)景進(jìn)行調(diào)整,另外auth權(quán)限為null,因?yàn)樵O(shè)置權(quán)限會(huì)增加服務(wù)開銷,影響效率,最下面幾行是內(nèi)存引擎,可以控制副本集同步及內(nèi)存限制,防止內(nèi)存泄露。
3.啟動(dòng)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)
此時(shí)副本集集群配置已經(jīng)完成,然后在命令行中輸入:rs.status(),查看副本集狀態(tài),需要查看同步情況,可以輸入命令:db.serverStatus().
5.設(shè)置副本集可讀寫
Rs.slaveOk()
6..NET操作mongo
連接設(shè)置,請(qǐng)參考個(gè)人封裝Unitoon.Mongo代碼所示。
7.性能對(duì)比
讀寫速度:redis>Mongo>Mssqlserver
可容納數(shù)據(jù)量:Mssqlserver~Mongo>Redis
存儲(chǔ)數(shù)據(jù)類型:Mongo>Mssqlserver>Redis
Note:內(nèi)存持續(xù)上升,內(nèi)部沒有內(nèi)存回收機(jī)制,若限制內(nèi)存 ,則可能出現(xiàn)查詢速度變慢,數(shù)據(jù)丟失等問題,建議優(yōu)化查詢效率,建立索引
Db.test.ensureIndex({"username":1, "age":-1})
強(qiáng)制釋放內(nèi)存命令:db.runCommand({closeAllDatabases:1})
二、倉(cāng)儲(chǔ)設(shè)計(jì)
1.基類BaseEntity
namespace UnitoonIot.Mongo { /// <summary> /// 實(shí)體基類,方便生成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ù)庫(kù)名稱 /// </summary> public string DbName { get; set; } /// <summary> /// 給對(duì)象初值 /// </summary> public BaseEntity() { // this.ObjId = ObjectId.GenerateNewId().ToString(); //this.Id = ObjectId.NewObjectId().ToString(); } } }
這里需要注意時(shí)間格式,MongoDB默認(rèn)時(shí)間格式為國(guó)際時(shí)間,所以在寫入數(shù)據(jù)時(shí)和讀取數(shù)據(jù)時(shí),時(shí)間格式要一致,此例中沒有對(duì)時(shí)間進(jìn)行特殊處理,由傳入的時(shí)間格式確定。
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ù)庫(kù)操作類 /// </summary> public class MongoRepository<T>: IMongoRepository<T> where T : BaseEntity { #region readonly field /// <summary> /// 表名 /// </summary> private readonly IMongoCollection<T> _collection = null; /// <summary> /// 數(shù)據(jù)庫(kù)對(duì)象 /// </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> /// 插入對(duì)象 /// </summary> /// <param name="t">插入的對(duì)象</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">要插入的對(duì)象集合</param> public virtual IEnumerable<T> InsertBatch(IEnumerable<T> ts) { _collection.InsertMany(ts); return ts; } /// <summary> /// 插入對(duì)象 /// </summary> /// <param name="t">插入的對(duì)象</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">要插入的對(duì)象集合</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> /// 按條件表達(dá)式刪除 /// </summary> /// <param name="predicate">條件表達(dá)式</param> /// <returns></returns> public virtual long Delete(Expression<Func<T, bool>> predicate) { var result = _collection.DeleteOne(predicate); return result.DeletedCount; } /// <summary> /// 按條件表達(dá)式刪除 /// </summary> /// <param name="predicate">條件表達(dá)式</param> /// <returns></returns> public virtual void DeleteAsync(Expression<Func<T, bool>> predicate) { _collection.DeleteOneAsync(predicate); } /// <summary> /// 按條件表達(dá)式批量刪除 /// </summary> /// <param name="predicate">條件表達(dá)式</param> /// <returns></returns> public virtual long DeleteBatch(Expression<Func<T, bool>> predicate) { var result = _collection.DeleteMany(predicate); return result.DeletedCount; } /// <summary> /// 按條件表達(dá)式批量刪除 /// </summary> /// <param name="predicate">條件表達(dá)式</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> /// 用新對(duì)象替換新文檔 /// </summary> /// <param name="filter">查詢條件</param> /// <param name="t">對(duì)象</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> /// 用新對(duì)象替換新文檔 /// </summary> /// <param name="filter">查詢條件</param> /// <param name="t">對(duì)象</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> /// 用新對(duì)象替換新文檔 /// </summary> /// <param name="filter">查詢條件</param> /// <param name="t">對(duì)象</param> /// <returns>修改影響文檔數(shù)</returns> public virtual void UpdateAsync(Expression<Func<T, bool>> filter, T t) { _collection.ReplaceOneAsync(filter, t, new UpdateOptions() { IsUpsert = true }); } /// <summary> /// 用新對(duì)象替換新文檔 /// </summary> /// <param name="filter">查詢條件</param> /// <param name="t">對(duì)象</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">對(duì)象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">對(duì)象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> /// 獲取操作對(duì)象的IMongoCollection集合,強(qiáng)類型對(duì)象集合 /// </summary> /// <returns></returns> public virtual IMongoCollection<T> GetCollection() { return _database.GetCollection<T>(typeof(T).Name); } #endregion #region GetSingle /// <summary> /// 查詢數(shù)據(jù)庫(kù),檢查是否存在指定ID的對(duì)象 /// </summary> /// <param name="id">對(duì)象的ID值</param> /// <returns>存在則返回指定的對(duì)象,否則返回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ù)庫(kù),檢查是否存在指定ID的對(duì)象 /// </summary> /// <param name="id">對(duì)象的ID值</param> /// <returns>存在則返回指定的對(duì)象,否則返回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">條件表達(dá)式</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">條件表達(dá)式</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> /// 查詢部分?jǐn)?shù)據(jù) /// </summary> /// <param name="filter">過濾條件</param> /// <returns></returns> public virtual IEnumerable<T> GetMany(FilterDefinition<T> filter) { return _collection.Find(filter).ToEnumerable(); } /// <summary> /// 查詢部分?jǐn)?shù)據(jù) /// </summary> /// <param name="filter">條件表達(dá)式</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> /// 查詢部分?jǐn)?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> /// 查詢部分?jǐn)?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>要查詢的對(duì)象</returns> public virtual IEnumerable<T> GetAll() { var data = _collection.AsQueryable(); return data.ToEnumerable(); } /// <summary> /// 查詢所有記錄,復(fù)雜查詢直接用Linq處理(避免全表掃描) /// </summary> /// <returns>要查詢的對(duì)象</returns> public virtual async Task<IEnumerable<T>> GetAllAsync() { var data = _collection.AsQueryable(); return await data.ToListAsync(); } /// <summary> /// 查詢所有記錄,復(fù)雜查詢直接用Linq處理(避免全表掃描) /// </summary> /// <returns>要查詢的對(duì)象</returns> public virtual IQueryable<T> GetAllQueryable() { return _collection.AsQueryable(); } #endregion #region MapReduce /// <summary> /// MapReduce /// </summary> /// <returns>返回一個(gè)List列表數(shù)據(jù)</returns> public IEnumerable<T> GetMap(BsonJavaScript map,BsonJavaScript reduce) { return _collection.MapReduce<T>(map,reduce).ToList(); } #endregion #endregion } }
好了,就介紹到這里。
當(dāng)前名稱:windows7下使用MongoDB實(shí)現(xiàn)倉(cāng)儲(chǔ)設(shè)計(jì)
本文地址:http://muchs.cn/article20/pdpdjo.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供Google、、品牌網(wǎng)站建設(shè)、用戶體驗(yàn)、網(wǎng)站內(nèi)鏈、網(wǎng)站導(dǎo)航
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)