Gruppierung Mongo-Dokumente mit Elementen der Array-Feld

Question

Ich habe unter 3 Dokumente. Jeweils ein Kontakt für einen Benutzer:

{ 
    "_id" : ObjectId("57f9f9f3b91d070315273d0d"), 
    "profileId" : "test", 
    "displayName" : "duplicateTest", 
    "email" : [ 
     { 
      "emailId" : "a@a.com" 
     }, 
     { 
      "emailId" : "b@b.com" 
     }, 
     { 
      "emailId" : "c@c.com" 
     } 
    ] 
} 
{ 
    "_id" : ObjectId("57f9fab2b91d070315273d11"), 
    "profileId" : "test", 
    "displayName" : "duplicateTest2", 
    "email" : [ 
     { 
      "emailId" : "a@a.com" 
     } 
    ] 
} 
{ 
    "_id" : ObjectId("57f9fcefb91d070315273d15"), 
    "profileId" : "test", 
    "displayName" : "duplicateTest2", 
    "email" : [ 
     { 
      "emailId" : "b@b.com" 
     } 
    ] 
} 

ich aggregieren müssen/Gruppe sie von Array-Elementen, so dass ich den doppelten Kontakt (auf E-Mail-ID basiert) identifizieren kann. Da es eine gemeinsame E-Mail-ID zwischen doc (1 & 2) und doc (1 & 3) gibt, repräsentieren diese 3 einen Kontakt und sollten in einem als ein Kontakt zusammengeführt werden.

Ich versuchte dies, wie unten mit zu tun $ entspannen und $ Gruppe in java:

List<DBObject> aggList = new ArrayList<DBObject>(); 

     BasicDBObject dbo = new BasicDBObject("$match", new BasicDBObject("profileId", "0fb72dcf-292b-4343-a0e7-1d613a803b1e")); 

     aggList.add(dbo); 

     BasicDBObject dboUnwind = new BasicDBObject("$unwind", "$email"); 
     aggList.add(dboUnwind); 



     BasicDBObject dboGroup = new BasicDBObject("$group", 
       new BasicDBObject().append("_id", new BasicDBObject("name", "$email.emailId")) 
         .append("uniqueIds", new BasicDBObject("$addToSet", "$_id")) 
         .append("count", new BasicDBObject("$sum", 1))); 

     aggList.add(dboGroup); 

     BasicDBObject dboCount = new BasicDBObject("$match", new BasicDBObject("count", new BasicDBObject("$gte", 2))); 
     aggList.add(dboCount); 


     BasicDBObject dboSort = new BasicDBObject("$sort", new BasicDBObject("count",-1)); 
     aggList.add(dboSort); 


     BasicDBObject dboLimit = new BasicDBObject("$limit", 10); 
     aggList.add(dboLimit); 


     AggregationOutput output = collection.aggregate(aggList); 


    System.out.println(output.results()); 

Diese Gruppen docs per E-Mail-ID (und zu Recht), aber dient nicht dem Zweck.

Jede Hilfe würde sehr geschätzt werden.

Ich muss die Funktion implementieren, wo Benutzer über die möglichen doppelten Kontakte in seinem Repository aufgefordert werden können. Ich brauche Aggregation Ergebnis so etwas wie:

[ 
    { 
     "_id":{ 
     "name":[ 
      { 
      "emailId" : "a@a.com" 
     }, 
     { 
      "emailId" : "b@b.com" 
     }, 
     { 
      "emailId" : "c@c.com" 
     } 
     ] 
     }, 
     "uniqueIds":[ 
     { 
      "$oid":"57f9fcefb91d070315273d15" 
     }, 
{ 
      "$oid":"57f9fcefb91d070315273d11" 
     }, 
{ 
      "$oid":"57f9fcefb91d070315273d15" 
     } 
     ], 
     "count":3 
    }, 

Also im Grunde, ich brauche _id für alle möglichen doppelten Kontakte (es könnte wie oben eine andere Gruppe von Duplikaten mit _ids Liste sein), so dass ich es Benutzer auffordern kann und Benutzer kann sie nach seinem Willen zusammenführen. Hoffe es ist jetzt klarer. Vielen Dank!

Answer 1

Nun, Ihre Frage unterscheidet sich ein wenig von dem Ergebnis, das Sie suchen. Ihre inital Frage wies mich auf die folgende Aggregation:

db.table.aggregate(
    [ 
    { 
     $unwind: "$email" 
    }, 
    { 
     $group: { 
     _id : "$email.emailId", 
     duplicates : { $addToSet : "$_id"} 
     } 
    } 
    ] 
); 

Daraus ergibt sich:

{ 
    "_id" : "c@c.com", 
    "duplicates" : [ 
     ObjectId("57f9f9f3b91d070315273d0d") 
    ] 
} 
{ 
    "_id" : "b@b.com", 
    "duplicates" : [ 
     ObjectId("57f9fcefb91d070315273d15"), 
     ObjectId("57f9f9f3b91d070315273d0d") 
    ] 
} 
{ 
    "_id" : "a@a.com", 
    "duplicates" : [ 
     ObjectId("57f9fab2b91d070315273d11"), 
     ObjectId("57f9f9f3b91d070315273d0d") 
    ] 
} 

per EMail gruppierte.

Aber die Beispielausgabe Sie zu Ihrer Frage hinzugefügt haben diese Aggregation:

db.table.aggregate(
    [ 
    { 
     $unwind: "$email" 
    }, 
    { 
     $group: { 
     _id : "$profileId", 
     emails : { $addToSet : "$email.emailId"}, 
     duplicates : { $addToSet : "$_id"} 
     } 
    } 
    ] 
); 

was zur Folge hat:

{ 
    "_id" : "test", 
    "emails" : [ 
     "c@c.com", 
     "b@b.com", 
     "a@a.com" 
    ], 
    "duplicates" : [ 
     ObjectId("57f9fcefb91d070315273d15"), 
     ObjectId("57f9fab2b91d070315273d11"), 
     ObjectId("57f9f9f3b91d070315273d0d") 
    ] 
}