Come cancellare i documenti restituiti dal gruppo in mongodb?

Question

Sono principiante MongoDB e sto lavorando su un problema compiti a casa, il set di dati assomiglia a questo

{ "_id" : { "$oid" : "50906d7fa3c412bb040eb577" }, "student_id" : 0, "type" : "exam", "score" : 54.6535436362647 } 
{ "_id" : { "$oid" : "50906d7fa3c412bb040eb578" }, "student_id" : 0, "type" : "quiz", "score" : 31.95004496742112 } 
{ "_id" : { "$oid" : "50906d7fa3c412bb040eb579" }, "student_id" : 0, "type" : "homework", "score" : 14.8504576811645 } 
{ "_id" : { "$oid" : "50906d7fa3c412bb040eb57a" }, "student_id" : 0, "type" : "homework", "score" : 63.98402553675503 } 
{ "_id" : { "$oid" : "50906d7fa3c412bb040eb57b" }, "student_id" : 1, "type" : "exam", "score" : 74.20010837299897 } 
{ "_id" : { "$oid" : "50906d7fa3c412bb040eb57c" }, "student_id" : 1, "type" : "quiz", "score" : 96.76851542258362 } 
{ "_id" : { "$oid" : "50906d7fa3c412bb040eb57d" }, "student_id" : 1, "type" : "homework", "score" : 21.33260810416115 } 
{ "_id" : { "$oid" : "50906d7fa3c412bb040eb57e" }, "student_id" : 1, "type" : "homework", "score" : 44.31667452616328 } 

Come parte del problema che ho da eliminare per ogni studente, il documento 'compiti a casa' con il punteggio più basso. Qui è la mia strategia

In cantiere aggregato
1: primo filtro tutti i documenti di tipo: HomeWorks
2: Ordina per student_id, segnare
3: fare un gruppo su student_id, trovare il primo elemento

Questo mi darà tutti i documenti con il punteggio più basso,

tuttavia come faccio a eliminare questi elementi dal dataset originale? Qualche consiglio o suggerimento?

Answer 1

utilizzare il risultato cursore dalla aggregazione per scorrere i documenti con il metodo del cursore forEach() e quindi rimuovere ogni documento della collezione utilizzando il _id come la query nel metodo remove(). Qualcosa di simile a questo:

var cursor = db.grades.aggregate(pipeline); 
cursor.forEach(function (doc){ 
    db.grades.remove({"_id": doc._id}); 
}); 

Un altro approccio è quello di creare un array di _id s del documento utilizzando il metodo map() e rimuovere i documenti come:

var cursor = db.grades.aggregate(pipeline), 
    ids = cursor.map(function (doc) { return doc._id; }); 
db.grades.remove({"_id": { "$in": ids }}); 

---

- UPDATE -

Per le operazioni di eliminazione di grandi dimensioni, può essere più efficiente copiare i documenti che si desidera ep a una nuova collezione e quindi utilizzare drop() sulla raccolta originale. Per copiare i documenti essenziali, la pipeline di aggregazione deve restituire i documenti senza il doc più basso e copiarli in un'altra raccolta utilizzando l'operatore $out come fase finale della pipeline. Si consideri il seguente gasdotto di aggregazione:

db.grades.aggregate([  
    { 
     '$group':{ 
      '_id': { 
       "student_id": "$student_id", 
       "type": "$type" 
      }, 
      'lowest_score': { "$min": '$score'}, 
      'data': { 
       '$push': '$$ROOT' 
      } 
     } 
    },  
    { 
     "$unwind": "$data" 
    }, 
    { 
     "$project": { 
      "_id": "$data._id", 
      "student_id" : "$data.student_id", 
      "type" : "$data.type", 
      "score" : "$data.score", 
      'lowest_score': 1,    
      "isHomeworkLowest": { 
       "$cond": [ 
        { 
         "$and": [ 
          { "$eq": [ "$_id.type", "homework" ] }, 
          { "$eq": [ "$data.score", "$lowest_score" ] } 
         ] 
        }, 
        true, 
        false 
       ] 
      } 
     } 
    }, 
    { 
     "$match": {"isHomeworkLowest" : false} 
    }, 
    { 
     "$project": {   
      "student_id": 1, 
      "type": 1, 
      "score": 1 
     } 
    }, 
    { 
     "$out": "new_grades" 
    } 
]) 

in cui si può quindi cadere la vecchia collezione da db.grades.drop() e poi interrogare sulle db.new_grades.find()

Answer 2

Penso che questa sia la parte di un database di compiti di MongoDB per sviluppatori Java fornito da MongoDB University. Dove il requisito è quello di eliminare il punteggio più basso da ogni singolo studente. comunque ho risolto in questo modo. Spero ti sarà d'aiuto. È anche possibile clonare il mio codice dal mio link github (riportato di seguito)

public class Homework2Week2 { 

public static void main(String[] args) { 
    // TODO Auto-generated method stub 
    // Here the the documentation is used for mongo-jva-driver-3.2.2.jar 
    /*If you want to use different versionof mongo-jva-driver 
     then you have look for that version specificatios.*/ 
    MongoClient mongoClient = new MongoClient(); 
    // get handle to "students" database 
    MongoDatabase database = mongoClient.getDatabase("students"); 
    // get a handle to the "grades" collection 
    MongoCollection<Document> collection = database.getCollection("grades"); 
    /* 
    * Write a program in the language of your choice that will remove the grade of type "homework" with the lowest score for each student from the dataset in the handout. 
    * Since each document is one grade, it should remove one document per student. 
    * This will use the same data set as the last problem, but if you don't have it, you can download and re-import. 
    * The dataset contains 4 scores each for 200 students. 
    * First, letâs confirm your data is intact; the number of documents should be 800. 

    *Hint/spoiler: If you select homework grade-documents, sort by student 
     and then by score, you can iterate through and find the lowest score 
     for each student by noticing a change in student id. As you notice 
     that change of student_id, remove the document. 
    */ 
    MongoCursor<Document> cursor = collection.find(eq("type", "homework")).sort(new Document("student_id", 1).append("score", 1)).iterator(); 
    int curStudentId = -1; 
    try 
    { 
    while (cursor.hasNext()) { 
     Document doc = cursor.next(); 
     int studentId=(int) doc.get("student_id"); 
     if (studentId != curStudentId) { 
      collection.deleteMany(doc); 
      curStudentId = studentId; 
     } 
    } 
    }finally { 
     //Close cursor 
     cursor.close(); 
    } 
    //Close mongoClient 
    mongoClient.close(); 
} 

}

Nel mio conto Github Ho il codice progetto completo. Se qualcuno vuole puoi provare da questo link.

Answer 3

int studentId = (int) doc.get ("student_id");

restituisce un errore di tipo convertito. È possibile controllare di nuovo?

Come so che possiamo fare come di seguito.

int studentId = Integer.valueOf (doc.get ("student_id"). ToString());

Answer 4

db.grades.aggregate([ 
          { 
           $match:{type:'homework'} 
          }, 
          { $group: 
           { _id: {student_id:"$student_id",type:'$type'},         
            score: { $max: "$score" } 
           } 
          } 
          ]).forEach(function(doc){ 
db.grades.remove({'student_id':doc._id.student_id,'score':doc.score}) 

})