簡單的介紹一下，我使用MongoDB的場景。
我們現在的物聯網環境下，有部分數據，采樣頻率為2000條記錄/分鐘，這樣下來一天24*60*2000=2880000約等于300萬條數據，以后必然還會增加。之前數據庫使用的是mssql，對于數據庫的壓力很大，同時又需要保證歷史查詢的響應速度，這種情況下，在單表中數據量大，同時存在讀寫操作。不得已采用MongoDB來存儲數據。如果使用MongoDB，則至少需要三臺機器，兩臺實現讀寫分離，一臺作為仲裁（當然條件不允許也可以不用），每臺機器的內存暫時配置在16G，公司小，沒辦法，據說，使用這個MongoDB需要機器內存最少92G，我沒有驗證過，但是吃內存是公認的，所以內存絕對要保證，就算保證了，也不一定完全就沒有意外發生。我們上面的這些特殊的數據是允許少量的丟失的，這些只是做分析使用的，幾個月了，暫時還沒出現數據丟失的情況，可能最新版本早就修復了吧，新手使用建議多看下官網上的說明。下面直接奔入主題：
一、安裝部署和配置環境
1.安裝部署mongo-server（V3.4）
參考 點擊這里進入
這個時候不要啟動，接著配置config文件
2.配置Config文件
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
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.25port=27016 oplogSize=10000noauth = true storageEngine = wiredTigerwiredTigerCacheSizeGB = 2syncdelay = 30wiredTigerCollectionBlockCompressor = snappy |
以上是詳細的配置參數，其中路徑部分根據需要更改， 這里設置的oplogsize大小為10G，根據業務場景進行調整，另外auth權限為null，因為設置權限會增加服務開銷，影響效率，最下面幾行是內存引擎，可以控制副本集同步及內存限制，防止內存泄露。
3.啟動mongo-server
4.添加副本集配置
|
1
2
3
4
5
6
7
8
9
10
11
|
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) |
此時副本集集群配置已經完成，然后在命令行中輸入：rs.status()，查看副本集狀態，需要查看同步情況，可以輸入命令：db.serverStatus().
5.設置副本集可讀寫
Rs.slaveOk()
6..NET操作mongo
連接設置，請參考個人封裝Unitoon.Mongo代碼所示。
7.性能對比
讀寫速度：Redis>Mongo>Mssqlserver
可容納數據量：Mssqlserver~Mongo>Redis
存儲數據類型：Mongo>Mssqlserver>Redis
Note：內存持續上升，內部沒有內存回收機制，若限制內存 ，則可能出現查詢速度變慢，數據丟失等問題，建議優化查詢效率，建立索引
Db.test.ensureIndex({"username":1, "age":-1})
強制釋放內存命令：db.runCommand({closeAllDatabases:1})
二、倉儲設計
1.基類BaseEntity
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
|
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> /// 數據庫名稱 /// </summary> public string DbName { get; set; } /// <summary> /// 給對象初值 /// </summary> public BaseEntity() { // this.ObjId = ObjectId.GenerateNewId().ToString(); //this.Id = ObjectId.NewObjectId().ToString(); } }} |
這里需要注意時間格式，MongoDB默認時間格式為國際時間，所以在寫入數據時和讀取數據時，時間格式要一致，此例中沒有對時間進行特殊處理，由傳入的時間格式確定。
2.Repository繼承接口IMongoRepository
|
1
2
3
4
5
6
|
namespace UnitoonIot.Mongo{ public interface IMongoRepository<TEntity> where TEntity : class { }} |
3.MongoRepository
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
|
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 數據庫操作類 /// </summary> public class MongoRepository<T>: IMongoRepository<T> where T : BaseEntity { #region readonly field /// <summary> /// 表名 /// </summary> private readonly IMongoCollection<T> _collection = null; /// <summary> /// 數據庫對象 /// </summary> private readonly IMongoDatabase _database; #endregion /// <summary> /// 構造函數 /// </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>構建復雜的查詢條件 /// </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>構建復雜的查詢條件 /// </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>修改影響文檔數</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>修改影響文檔數</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>修改影響文檔數</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>修改影響文檔數</returns> public virtual void UpdateAsync(FilterDefinition<T> filter, T t) { _collection.ReplaceOneAsync(filter, t, new UpdateOptions() { IsUpsert = true }); } /// <summary> /// 根據Id和條件文檔 /// </summary> /// <param name="update">修改條件-形如：Builders/<T/>.Update.Set(filed, value)</param> /// <param name="id">對象Id</param> /// <returns>修改影響文檔數</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> /// 根據Id和條件文檔 /// </summary> /// <param name="update">修改條件-形如：Builders/<T/>.Update.Set(filed, value)</param> /// <param name="id">對象Id</param> /// <returns>修改影響文檔數</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> /// 根據條件修改文檔 /// </summary> /// <param name="update">修改條件-形如：Builders/<T/>.Update.Set(filed, value)</param> /// <param name="filter">查詢條件Builders/<T/>.Filter.Eq(filed, value)</param> /// <returns>修改影響文檔數</returns> public virtual void Update(UpdateDefinition<T> update,Expression<Func<T, bool>> filter) { _collection.UpdateOne(filter, update, new UpdateOptions() { IsUpsert = true }); } /// <summary> /// 根據條件修改文檔 /// </summary> /// <param name="update">修改條件-形如：Builders/<T/>.Update.Set(filed, value)</param> /// <param name="filter">查詢條件Builders/<T/>.Filter.Eq(filed, value)</param> /// <returns>修改影響文檔數</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> /// 根據條件修改文檔 /// </summary> /// <param name="update">修改條件-形如：Builders/<T/>.Update.Set(filed, value)</param> /// <param name="filter">查詢條件Builders/<T/>.Filter.Eq(filed, value)</param> /// <returns>修改影響文檔數</returns> public virtual void UpdateAsync(UpdateDefinition<T> update, Expression<Func<T, bool>> filter) { _collection.UpdateOneAsync(filter, update, new UpdateOptions() { IsUpsert = true }); } /// <summary> /// 根據條件修改文檔 /// </summary> /// <param name="update">修改條件-形如：Builders/<T/>.Update.Set(filed, value)</param> /// <param name="filter">查詢條件Builders/<T/>.Filter.Eq(filed, value)</param> /// <returns>修改影響文檔數</returns> public virtual void UpdateAsync(UpdateDefinition<T> update, FilterDefinition<T> filter) { _collection.UpdateOneAsync(filter, update, new UpdateOptions() { IsUpsert = true }); } /// <summary> /// 根據條件批量修改文檔 /// </summary> /// <param name="update">修改條件-形如：Builders/<T/>.Update.Set(filed, value)</param> /// <param name="filter">查詢條件Builders/<T/>.Filter.Eq(filed, value)</param> /// <returns>修改影響文檔數</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> /// 根據條件批量修改文檔 /// </summary> /// <param name="update">修改條件-形如：Builders/<T/>.Update.Set(filed, value)</param> /// <param name="filter">查詢條件Builders/<T/>.Filter.Eq(filed, value)</param> /// <returns>修改影響文檔數</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> /// 根據條件批量修改文檔 /// </summary> /// <param name="update">修改條件-形如：Builders/<T/>.Update.Set(filed, value)</param> /// <param name="filter">查詢條件Builders/<T/>.Filter.Eq(filed, value)</param> /// <returns>修改影響文檔數</returns> public virtual void UpdateBatchAsync(UpdateDefinition<T> update, Expression<Func<T, bool>> filter) { _collection.UpdateManyAsync(filter, update, new UpdateOptions() { IsUpsert = true }); } /// <summary> /// 根據條件批量修改文檔 /// </summary> /// <param name="update">修改條件-形如：Builders/<T/>.Update.Set(filed, value)</param> /// <param name="filter">查詢條件Builders/<T/>.Filter.Eq(filed, value)</param> /// <returns>修改影響文檔數</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> /// 查詢數據庫,檢查是否存在指定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> /// 查詢數據庫,檢查是否存在指定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> /// 查詢數據 /// </summary> /// <param name="filter">過濾條件</param> /// <returns></returns> public virtual T Get(FilterDefinition<T> filter) { return _collection.Find(filter).FirstOrDefault(); } /// <summary> /// 查詢數據 /// </summary> /// <param name="filter">條件表達式</param> /// <returns></returns> public virtual T Get(Expression<Func<T,bool>> filter) { return _collection.Find(filter).FirstOrDefault(); } /// <summary> /// 查詢數據 /// </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> /// 查詢數據 /// </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> /// 查詢部分數據 /// </summary> /// <param name="filter">過濾條件</param> /// <returns></returns> public virtual IEnumerable<T> GetMany(FilterDefinition<T> filter) { return _collection.Find(filter).ToEnumerable(); } /// <summary> /// 查詢部分數據 /// </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> /// 查詢部分數據 /// </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> /// 查詢部分數據 /// </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> /// 查詢所有記錄，復雜查詢直接用Linq處理(避免全表掃描) /// </summary> /// <returns>要查詢的對象</returns> public virtual IEnumerable<T> GetAll() { var data = _collection.AsQueryable(); return data.ToEnumerable(); } /// <summary> /// 查詢所有記錄，復雜查詢直接用Linq處理(避免全表掃描) /// </summary> /// <returns>要查詢的對象</returns> public virtual async Task<IEnumerable<T>> GetAllAsync() { var data = _collection.AsQueryable(); return await data.ToListAsync(); } /// <summary> /// 查詢所有記錄，復雜查詢直接用Linq處理(避免全表掃描) /// </summary> /// <returns>要查詢的對象</returns> public virtual IQueryable<T> GetAllQueryable() { return _collection.AsQueryable(); } #endregion #region MapReduce /// <summary> /// MapReduce /// </summary> /// <returns>返回一個List列表數據</returns> public IEnumerable<T> GetMap(BsonJavaScript map,BsonJavaScript reduce) { return _collection.MapReduce<T>(map,reduce).ToList(); } #endregion #endregion } } |
好了，就介紹到這里。
原文鏈接：http://www.cnblogs.com/lianming37/p/7606707.html
