Advanced Query

# MapReduce: gasto total realizado por las mujeres que han realizdo EXACTAMENTE
# 3 compras.
@get('/spending_female_3_orders_mr')
def spending_female_3_orders_mr():
	
	mapper = Code("""
			function countryMap() 
			{	
				if (this.gender == "Female") {
					var total = 0;
					var orders = this.orders;

					if (orders) {
						if (orders.length == 3) {
							for (i=0; i < orders.length; i++) {
								total += orders[i].total
							}
						}
					}
					
					emit(this.gender, { count: total });
				}
			}
			""")

	reducer = Code("""
			function countryReduce(key, values) {
				var total = 0;

				for (var i = 0; i < values.length; i++) {
					total += values[i].count;
				}

				return { count: total }
			}
			""")

	results = db.users.inline_map_reduce(mapper, reducer)
	return template('table_map_reduce', results=results, count=len(results));

# Aggregation Pipeline: gasto total realizado por las mujeres que han realizdo 
# EXACTAMENTE 3 compras.
@get('/spending_female_3_orders_agg')
def spending_female_3_orders_agg():
	pipeline = [
		{   
			"$match" : { 
				"gender" : "Female",
				"orders": { "$size" : 3 }
			}
		},
		{ "$unwind": "$orders" },
		{ "$group": {"_id": "$gender", "count": {"$sum": "$orders.total" }}},
		{ "$sort": SON([("count", 1), ("_id", -1)])}
	]
	results= list(db.users.aggregate(pipeline))
	return template('table_pipeline', results=results, count=len(results));