我有一组模拟付款状态，每个状态都有一个付款 ID。

我想获取每个付款 ID 的最新状态。我的测试创建了一些虚拟数据，然后尝试查询它。我已经走到这一步了:

[Test]
public void GetPaymentLatestStatuses()
{
    var client = new TestMongoClient();

    var database = client.GetDatabase("payments");

    var paymentRequestsCollection = database.GetCollection<BsonDocument>("paymentRequests");

    var statusesCollection = database.GetCollection<BsonDocument>("statuses");

    var payment = new BsonDocument { { "amount", RANDOM.Next(10) } };

    paymentRequestsCollection.InsertOne(payment);

    var paymentId = payment["_id"];

    var receivedStatus = new BsonDocument
                         {
                             { "payment", paymentId },
                             { "code", "received" },
                             { "date", DateTime.UtcNow }
                         };
    var acceptedStatus = new BsonDocument
                         {
                             { "payment", paymentId },
                             { "code", "accepted" },
                             { "date", DateTime.UtcNow.AddSeconds(-1) }
                         };
    var completedStatus = new BsonDocument
                          {
                              { "payment", paymentId },
                              { "code", "completed" },
                              { "date", DateTime.UtcNow.AddSeconds(-2) }
                          };

    statusesCollection.InsertMany(new [] { receivedStatus, acceptedStatus, completedStatus });

    var groupByPayments = new BsonDocument { {"_id", "$payment"} };

    var statuses = statusesCollection.Aggregate().Group(groupByPayments);

}

但现在我在一堵砖墙前。

任何朝正确方向的探索都会有所帮助。我不确定我是不是看错了望远镜的一端。

更新

下面给出了正确文档的 ID。

var groupByPayments = new BsonDocument
                      {
                          { "_id", "$payment" },
                          { "id", new BsonDocument { { "$first", "$_id" } } }
                      };

var sort = Builders<BsonDocument>.Sort.Descending(document => document["date"]);

var statuses = statusesCollection.Aggregate().Sort(sort).Group(groupByPayments).ToList();

我可以通过单个查询获取完整文档吗，还是我现在必须重新发出命令以获取该列表中的所有文档？

最佳答案

让我们从实现您想要实现的目标的简单方法开始。在 MongoDB 的 C# 驱动程序 2.X 中，您可以找到 AsQueryable 扩展方法，让您可以从集合中创建 LINQ 查询。这个 Linq 提供程序建立在 MongoDB 的聚合框架之上，因此最后您的链接查询将被转换为聚合管道。所以，如果你有这样一个类:

public class Status
{
  public ObjectId _id { get; set; }
  public ObjectId payment { get; set; }
  public string code { get; set; }
  public DateTime date { get; set; }
}

您可以创建如下查询:

 var statusesCollection = database.GetCollection<Status>("statuses");
 var result= statusesCollection.AsQueryable()
                               .OrderByDescending(e=>e.date)
                               .GroupBy(e=>e.payment)
                               .Select(g=>new Status{_id =g.First()._id,
                                                     payment = g.Key,
                                                     code=g.First().code,
                                                     date=g.First().date
                                                    }
                                       )
                               .ToList();

现在您可能想知道为什么我必须将结果投影到 Status 类的新实例，如果我可以从每个组调用 First 扩展方法获得相同的结果？不幸的是，目前还不支持。原因之一是因为 Linq 提供程序正在使用 $first构建聚合管道时的操作，这就是 $first 操作的工作原理。此外，正如您在链接中看到的那样，当您在 $group 阶段使用 $first 时，$group 阶段应遵循 $sort 阶段，以按定义的顺序输入文档。

现在，假设您不想使用 Linq 而想自己创建聚合管道，您可以执行以下操作:

 var groupByPayments = new BsonDocument
                      {
                          { "_id", "$payment" },
                          { "statusId", new BsonDocument { { "$first", "$_id" } } },
                          { "code", new BsonDocument { { "$first", "$code" } } },
                          { "date", new BsonDocument { { "$first", "$date" } } }
                      };

var sort = Builders<BsonDocument>.Sort.Descending(document => document["date"]);

ProjectionDefinition<BsonDocument> projection = new BsonDocument
        {
            {"payment", "$_id"},
            {"id", "$statusId"},
            {"code", "$code"},
            {"date", "$date"},
        }; 
var statuses = statusesCollection.Aggregate().Sort(sort).Group(groupByPayments).Project(projection).ToList<BsonDocument>();

这个解决方案的优点是你在一次往返中得到数据，缺点是你必须转换你需要的所有字段。我的结论是如果文档没有很多字段或者你没有' 需要文档中的所有字段我会使用此变体。

关于c# - MongoDB C# 从组中获取最新文档，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/35386845/