sql >> Databasteknik >  >> NoSQL >> MongoDB

Hur räknar man produktgrupp med fältnamn i Monogodb?

Du kan utnyttja användningen av $arrayToObject operatör inom en serie pipelines och en sista $replaceRoot pipeline för att få önskat resultat.

Obs :hubId konverteras till en sträng under pipelineoperationen som $arrayToObject operatorn fungerar bra om "nyckel"-värdet är en sträng. Så om hubId är ett ObjectId sedan $toString behövs när $arrayToObject tillämpas.

Du skulle behöva köra följande sammanlagda pipeline:

Product.aggregate([
    {  "$group": {
            "_id": {
                "hubId": "$hubId",
                "status": "$ProductStatus"
            },
            "count": { "$sum": 1 }
    } },
    { "$group": {
        "_id": "$_id.hubId",
        "counts": {
            "$push": {
                "k": "$_id.status",
                "v": "$count"
            }
        }
    } },
    { "$group": {
        "_id": null,
        "counts": {
            "$push": {
                "k": { "$toString": "$_id" },
                "v": "$counts"
            }
        }
    } },
    { "$addFields": {
        "counts": {
            "$map": {
                "input": "$counts",
                "in": {
                    "$mergeObjects": [
                        "$$this",
                        { "v":  { "$arrayToObject": "$$this.v" } }
                    ]
                }
            }
        }
        
    } },
    {  "$replaceRoot": {
        "newRoot": { "$arrayToObject": "$counts" }
    } }  
])

vilket ger följande resultatdokument:

{
    "xyz" : {
        "Delivered" : 1,
        "On the Way" : 1
    },
    "mlm" : {
        "On the Way" : 1,
        "Delivered" : 2
    },
    "yyy" : {
        "On the Way" : 1,
        "Delivered" : 1,
        "Cancelled" : 1
    }
}

Detta ger naturligtvis inte den andra statusen som har noll, men lösningen kan vara en bra utgångspunkt.




  1. Azure-funktionen returnerar inte resultat

  2. Hur man använder fältvärde som nyckelnamn i Mongodb-resultat

  3. Hur kan jag kopiera en samling från MongoDB med pymongo och klistra in i en annan tom samling?

  4. Hur förbättrar man prestanda för update() och save() i MongoDB?