sql >> Databasteknik >  >> NoSQL >> MongoDB

MongoDB-grupp och summa med id som nyckel

Med MongoDb 3.6 och senare kan du utnyttja $arrayToObject operator och en $replaceRoot pipeline för att få önskat resultat. Du skulle behöva köra följande sammanlagda pipeline:

db.users.aggregate([
    { 
        "$group": {
            "_id": { "$toLower": "$role" },
            "count": { "$sum": 1 }
        }
    },
    { 
        "$group": {
            "_id": null,
            "counts": {
                "$push": {
                    "k": "$_id",
                    "v": "$count"
                }
            }
        }
    },
    { 
        "$replaceRoot": {
            "newRoot": { "$arrayToObject": "$counts" }
        } 
    }    
])

För äldre versioner, $cond operatorn i $group pipeline-steget kan användas effektivt för att utvärdera antalet baserat på rollfältets värde. Din övergripande aggregeringspipeline kan konstrueras enligt följande för att producera resultatet i önskat format:

db.users.aggregate([    
    { 
        "$group": { 
            "_id": null,             
            "moderator_count": {
                "$sum": {
                    "$cond": [ { "$eq": [ "$role", "moderator" ] }, 1, 0 ]
                }
            },
            "superadmin_count": {
                "$sum": {
                    "$cond": [ { "$eq": [ "$role", "superadmin" ] }, 1, 0 ]
                }
            },
            "user_count": {
                "$sum": {
                    "$cond": [ { "$eq": [ "$role", "user" ] }, 1, 0 ]
                }
            },
            "admin_count": {
                "$sum": {
                    "$cond": [ { "$eq": [ "$role", "admin" ] }, 1, 0 ]
                }
            } 
        }  
    },
    {
        "$project": {
            "_id": 0, 
            "moderator": "$moderator_count",
            "superadmin": "$superadmin_count",
            "user": "$user_count",
            "admin": "$admin_count"
        }
    }
])

Från kommentarspåret, om du inte känner till rollerna i förväg och vill skapa pipeline-arrayen dynamiskt, kör distinct kommando på rollfältet. Detta ger dig ett objekt som innehåller en lista över de distinkta rollerna:

var result = db.runCommand ( { distinct: "users", key: "role" } )
var roles = result.values;
printjson(roles); // this will print ["moderator", "superadmin", "user",  "admin"]

Med tanke på listan ovan kan du sätta ihop din pipeline genom att skapa ett objekt som har dess egenskaper inställda med JavaScripts reduce() metod. Följande visar detta:

var groupObj = { "_id": null },
    projectObj = { "_id": 0 }

var groupPipeline = roles.reduce(function(obj, role) { // set the group pipeline object 
    obj[role + "_count"] = {
        "$sum": {
            "$cond": [ { "$eq": [ "$role", role ] }, 1, 0 ]
        }
    };
    return obj;
}, groupObj );

var projectPipeline = roles.reduce(function(obj, role) { // set the project pipeline object 
    obj[role] = "$" + role + "_count";
    return obj;
}, projectObj );

Använd dessa två dokument i din slutliga aggregeringspipeline som:

db.users.aggregate([groupPipeline, projectPipeline]);

Kolla demon nedan.

var roles = ["moderator", "superadmin", "user",  "admin"],
	groupObj = { "_id": null },
	projectObj = { "_id": 0 };

var groupPipeline = roles.reduce(function(obj, role) { // set the group pipeline object 
	obj[role + "_count"] = {
		"$sum": {
			"$cond": [ { "$eq": [ "$role", role ] }, 1, 0 ]
		}
	};
	return obj;
}, groupObj );

var projectPipeline = roles.reduce(function(obj, role) { // set the project pipeline object 
	obj[role] = "$" + role + "_count";
	return obj;
}, projectObj );

var pipeline = [groupPipeline, projectPipeline]

pre.innerHTML = JSON.stringify(pipeline, null, 4);
<pre id="pre"></pre>


  1. Vad är det bästa sättet att göra ajax-paginering med MongoDb och Nodejs?

  2. Fråga Mongodb om månad, dag, år... för ett datum och tid

  3. Hur pausar eller återupptar man selleriuppgiften?

  4. Memcache vs Java Memory