HOMEWORK 2 - WEEK 2 - M101P

find_student_data_and_delete_min.py

import pymongo
import datetime
import sys

# establish a connection to the database
connection = pymongo.MongoClient("mongodb://localhost")
        
def find_student_data_and_delete_min(student_id):
    # get a handle to the school database
    db=connection.students
    grades = db.grades
    query = {'student_id':student_id, 'type':'homework'}
    
    print "Searching for student data for student with id = ", student_id
    try:
        cursor = grades.find(query)
    	cursor = cursor.sort('score', pymongo.ASCENDING)
	    cursor = cursor.limit(1)
        for doc in cursor:
        	grades.delete_many(doc)

    except Exception as e:
        print "Exception: ", type(e), e
i = 0
while (i < 200):
	find_student_data_and_delete_min(i)
	i = i + 1