C#：筛选MongoDb集合

Question

我有以下问题：我正在学习如何使用MongoDb和C#。可以在集合中插入项，但无法筛选现有集合以检索一个或多个符合查询条件的项。下面是我的类结构：

    public class TransactionRequest
    {
        public Header Header { get; set; }

        public Transaction Transaction { get; set; }
    }

    public class Header
    {
        public string BusinessId { get; set; }
    }

    public class Transaction
    {
        public string Id { get; set; }
        public string Status { get; set; }
    }

下面是我保存对象的方法：

        public async Task<TransactionResponse> SaveAsync(TransactionRequest request)
        {
            var document = new BsonDocument
            {
                {"Request", BsonValue.Create(JsonConvert.SerializeObject(request))}
            };

            await this._mongoClient.GetDatabase("MyDatabase").GetCollection<BsonDocument>("Transactions").InsertOneAsync(document, null, CancellationToken.None);

            return new TransactionResponse
            {
                InternalId = document["_id"].ToString(),
                TransactionId = request.Transaction.Id
            };
        }

并且正确保存了对象,正如您在图像中所看到的：

但是如何检索包含id为1234的对象事务的文档呢？

我使用的是.NET Core2和MongoDb C#驱动程序版本2.5。

编辑：集合是BsonDocument集合，它不是Transactionrequest类型的集合，那么如何将字段id映射到该bson文档？编辑2：下面是我检索文档的方法：

public async Task<string> RetrieveResponse(string id)
{

    var cursor =await  this.mongoClient.GetDatabase("MyDatabase")
        .GetCollection<TransactionRequest>("Transactions")
        .FindAsync(t => t.Transaction.Id.Equals("1234"));

    while (await cursor.MoveNextAsync())
    {
        IEnumerable<TransactionRequest> documents = cursor.Current;
        Console.WriteLine(documents.Count()); //this is empty
    }

    return string.Empty;
}

但是在while循环中，检索到的集合为空

Answer 1

您当前的保存方式在文档的顶层创建了一个“请求”字段，这并不反映在您的实体结构中。为了解决这个问题，您不应该自己执行JSON转换，而是让驱动程序为您执行：

public async Task<TransactionResponse> SaveAsync(TransactionRequest request)
{
    await this._mongoClient.GetDatabase("MyDatabase")
              .GetCollection<TransactionRequest>("Transactions")
              .InsertOneAsync(request, null, CancellationToken.None);

    // load document - not needed, just for illustration purposes
    this._mongoClient.GetDatabase("MyDatabase")
        .GetCollection<TransactionRequest>("Transactions")
        .Find(t => t.Transaction.Id == request.Transaction.Id);

    return new TransactionResponse
    {
        InternalId = request.Id,
        TransactionId = request.Transaction.Id
    };
}

那么你的检索也应该起作用了。