我在mongodb集合中有以下文档，称为“项目”
"_id": {
"$oid": "5fcfa614d588d46ec44cc375"
},
"ProductId": {
"$binary": {
"base64": "LredEr/+9UGY3g5oIDWhPw==",
"subType": "03"
}
},
"ProductName": "ModelProductTest",
"AccountId": {
"$binary": {
"base64": "Gzmr+JvFq0y0YRBOfkj57w==",
"subType": "03"
}
},
"Skus": [
{
"_id": {
"$oid": "5fcfa614d588d46ec44cc376"
},
"ProductSkuId": {
"$binary": {
"base64": "MBLj5bL6C0Cph0fMkpbDZA==",
"subType": "03"
}
},
"ProductId": {
"$binary": {
"base64": "LredEr/+9UGY3g5oIDWhPw==",
"subType": "03"
}
},
"SkuCode": "kkss",
"Barcode": "12345",
"Description": "test",
"StockQuantity": {
"$numberInt": "2"
},
"Costs": [
{
"_id": {
"$oid": "5fcfa614d588d46ec44cc378"
},
"ProductPriceId": {
"$binary": {
"base64": "81rqEsKc9k6y2IQQjE1DJg==",
"subType": "03"
}
},
"ProductSkuId": {
"$binary": {
"base64": "MBLj5bL6C0Cph0fMkpbDZA==",
"subType": "03"
}
},
"DateValidFrom": {
"$date": {
"$numberLong": "1607443988489"
}
},
"Cost": "33"
},
{
"_id": {
"$oid": "5fcfa614d588d46ec44cc379"
},
"ProductPriceId": {
"$binary": {
"base64": "aqdf9S6yUUCIZEjLY/1pvw==",
"subType": "03"
}
},
"ProductSkuId": {
"$binary": {
"base64": "MBLj5bL6C0Cph0fMkpbDZA==",
"subType": "03"
}
},
"DateValidFrom": {
"$date": {
"$numberLong": "1607443988492"
}
},
"Cost": "39"
}
]
},
{
"_id": {
"$oid": "5fcfa614d588d46ec44cc377"
},
"ProductSkuId": {
"$binary": {
"base64": "XFkTknYw2Uyy2ae/F/yj1A==",
"subType": "03"
}
},
"ProductId": {
"$binary": {
"base64": "LredEr/+9UGY3g5oIDWhPw==",
"subType": "03"
}
},
"SkuCode": "kksass",
"Barcode": "12346",
"Description": "test",
"StockQuantity": {
"$numberInt": "6"
},
"Costs": [
{
"_id": {
"$oid": "5fcfa614d588d46ec44cc37a"
},
"ProductPriceId": {
"$binary": {
"base64": "hxWucmMsnkOkRb1j9/EtGA==",
"subType": "03"
}
},
"ProductSkuId": {
"$binary": {
"base64": "XFkTknYw2Uyy2ae/F/yj1A==",
"subType": "03"
}
},
"DateValidFrom": {
"$date": {
"$numberLong": "1607443988492"
}
},
"Cost": "31"
},
{
"_id": {
"$oid": "5fcfa614d588d46ec44cc37b"
},
"ProductPriceId": {
"$binary": {
"base64": "ExyZdI6suE2Zs5oRdeiK9w==",
"subType": "03"
}
},
"ProductSkuId": {
"$binary": {
"base64": "XFkTknYw2Uyy2ae/F/yj1A==",
"subType": "03"
}
},
"DateValidFrom": {
"$date": {
"$numberLong": "1607443988492"
}
},
"Cost": "36"
}
]
}
]
我想获取通过条形码搜索时返回的主要对象和特定的sku（不是所有的skus）。如何在C＃中使用mongo驱动程序执行此操作？
您可以使用AsQueryable官方驱动程序的界面轻松完成此操作，如下所示：
collection.AsQueryable()
.Where(i => i.Skus.Any(s => s.Barcode == "22222222")))
.Select(i => new Item
{
Id = i.Id,
ProductName = i.ProductName,
Skus = i.Skus.Where(s => s.Description == "second sku")
})
.ToListAsync();
您需要对需要返回的主要实体的每个属性进行手动投影，并只需使用Where子句过滤Skus 。
上面的代码将转换为这样的聚合管道：
[
{
"$match": {
"Skus": {
"$elemMatch": {
"Barcode": "22222222"
}
}
}
},
{
"$project": {
"_id": "$_id",
"ProductName": "$ProductName",
"Skus": {
"$filter": {
"input": "$Skus",
"as": "s",
"cond": {
"$eq": [
"$$s.Barcode",
"22222222"
]
}
}
}
}
}
]
使用mongodb.entities的测试程序：
using MongoDB.Bson;
using MongoDB.Driver;
using MongoDB.Driver.Linq;
using MongoDB.Entities;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
namespace TestApplication
{
public class Item : Entity
{
public string ProductName { get; set; }
public IEnumerable<Sku> Skus { get; set; }
}
public class Sku
{
[ObjectId]
public string Id { get; set; }
public string Barcode { get; set; }
}
public static class Program
{
private static async Task Main()
{
await DB.InitAsync("test");
await new Item
{
ProductName = "test product",
Skus = new[] {
new Sku { Id = ObjectId.GenerateNewId().ToString(), Barcode = "11111111" },
new Sku { Id = ObjectId.GenerateNewId().ToString(), Barcode = "22222222" },
new Sku { Id = ObjectId.GenerateNewId().ToString(), Barcode = "33333333" }
}
}.SaveAsync();
var item = await DB.Queryable<Item>()
.Where(i => i.Skus.Any(s => s.Barcode == "22222222"))
.Select(i => new Item
{
ID = i.ID,
ProductName = i.ProductName,
Skus = i.Skus.Where(s => s.Barcode == "22222222")
})
.ToListAsync();
}
}
}本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句