Agrégation Mongodb sur JSON Array (JAVA)

Question

J'ai une application web typique dans laquelle j'essaie de générer des facettes à partir de la collection mongodb. Ceci est actuellement fait en utilisant le framework d'agrégation en utilisant le pilote Java (v2.10.1). Les facettes sont générées correctement, à l'exception des documents contenant des sous-réseaux, par exemple, j'ai les documents JSON suivants:

1. {name: polo, fueltypes:[benzin, lpg], color: black}
2. {name: golf, fueltypes:[benzin, cng], color: blue}
3. {name: a4, fueltypes:[diesel], color: blue}

Le jeu de résultat retourné est :

nom:

{_id: polo, count: 1} 
{_id: golf, count: 1} 
{_id: a4, count: 1} 

couleur:

{_id: black, count: 1} 
{_id: blue, count: 2} 

fueltypes:

{_id: [benzin,lpg,cng,diesel], count: 3} 

Le résultat agrégé du champ fueltypes contient tous les champs du tableau.

Cependant le résultat souhaité doit être:

fueltypes:

{_id: benzin, count: 2} 
{_id: lpg, count: 1}  
{_id: diesel, count: 1}  
{_id: cng, count: 1}  

et le code Java correspondant:

String str = "name" ; //or fueltypes, color 
// create match 
BasicDBObject match = new BasicDBObject(); 
match.put("$match", new BasicDBObject()); 

// build the $projection operation 
DBObject fields = new BasicDBObject(); 

// fields.put("count", 1); 
DBObject project = new BasicDBObject(); 

// Now the $group operation 
DBObject groupFields = new BasicDBObject(); 

DBObject unwindFields = new BasicDBObject(); 
// build the $projection operation 
fields.put(str, 1); 
project.put("$project", fields); 

// Now the $group operation 
groupFields.put("_id", "$" + str); 

// performing sum and storing it in the count attribute 
groupFields.put("count", new BasicDBObject("$sum", 1)); 

DBObject group = new BasicDBObject("$group", groupFields); 
AggregationOutput output = serviceCollection.aggregate(match, project, group); 

Answer 1

Regroupement par le réseau "fueltypes" vous donne le nombre d'occurrences du tableau en tant que tel.

Pour compter, il est individuellement des éléments, vous devrez utiliser l'opérateur de dérouleur de $, comme suit:

// create unwind 
BasicDBObject unwind = new BasicDBObject(); 
unwind.put("$unwind", "$" + str); 

et comprennent ce avant que l'opérateur de groupe $. Alternativement, vous pouvez appeler le $ dérouler seulement si str est "fueltypes". Pour plus d'informations sur le déroulement, voir http://docs.mongodb.org/manual/reference/aggregation/