在所有集合

Question

我有一个包含集合的数据库，包含窗体上的文档这些集合查找场最大值：

{ "_id" : 4, "value" : 2 } 

我想找到的最大"_id"在一个有效的方式，所有的藏品。目前，我有一个工作方法：

public long getLastTimestamp() 
{ 
    var tempList = getChannelNames(); 
    var channelList = new List<IMongoCollection<BsonDocument>>(); 
    var docuList = new List<BsonDocument>(); 

    foreach (var channel in tempList) 
    { 
     channelList.Add(_database.GetCollection<BsonDocument>(channel.name)); 
    } 

    foreach (var channel in channelList) 
    { 
     var filter = Builders<BsonDocument>.Filter.Exists("_id"); 
     var result = channel.FindAsync(filter).Result.ToList(); 

     foreach (var docu in result) 
     { 
      docuList.Add(docu); 
     } 
    } 

    var timeList = new List<long>(); 

    foreach (var docu in docuList) 
    { 
     Console.WriteLine(docu); 
     if (!docu["_id"].IsObjectId) 
      timeList.Add(docu["_id"].ToInt64()); 
    } 

    return timeList.Max(); 
} 

它的工作原理，但我不认为它是非常有效的。 有没有人有一些意见或建议？

编辑： 我落得这样做：

public long getLastTimestamp() 
    { 
     var filter = Builders<BsonDocument>.Filter.Exists("value"); 
     return getChannelNames() 
      .Select(channel => _database.GetCollection<BsonDocument>(channel.name)) 
      .SelectMany(channel => channel.FindAsync(filter).Result.ToList()) 
      .Max(docu => docu["_id"].ToInt64()); 
    } 

Answer 1

检查了这一点：

public long getLastTimestamp() 
{ 
    //var tempList = getChannelNames(); 
    var channelList = new List<IMongoCollection<BsonDocument>>(); 
    var docuList = new List<BsonDocument>(); 

    foreach (var channel in getChannelNames()) 
    { 
     var filter = Builders<BsonDocument>.Filter.Exists("_id"); 
     var result = _database.GetCollection<BsonDocument>(channel.name) 
        .FindAsync(filter).Result.ToList(); 

     return result.Where(x => !x["_id"].IsObjectId) 
       .Max(entry => entry["_id"].ToInt64); 
    } 

    return 0; 
} 

不可能测试，因为这些物体ARNT提供给我。在linq部分，您可能必须转换为列表或数组才能获得Where()和Max()。

再次存储和迭代总是比较慢。

public long getLastTimestamp() 
{ 
    var filter = Builders<BsonDocument>.Filter.Exists("_id"); 

    return getChannelNames() 
    .Select(channel => _database.GetCollection<BsonDocument>(channel.name).FindAsync(filter).Result.ToList()) 
    .Where(doc => !doc["_id"].IsObjectId) 
    .Max(doc => doc["_id"].ToInt64); 
} 

Answer 2

这样的事情？

var filter = Builders<BsonDocument>.Filter.Exists("_id"); 

getChannelNames() 
    .SelectMany(channel => _database.GetCollection<BsonDocument>(channel.name)) 
    .SelectMany(channel => channel.FindAsync(filter).Result.ToList()) // Even better w/o ToList 
    .Where(docu => !docu["_id"].IsObjectId) 
    .Max(docu => docu["_id"].ToInt64());