<gh_stars>0
#!/usr/bin/env python3
# -*- coding: utf-8 -*-
"""
Created on Tue Oct 10 14:25:47 2017

@author: <NAME>
"""

import pymongo
import pprint
from pymongo import MongoClient
client=MongoClient()
db=client.Northwind

##Query for Exercise 5.1
query=db.orders.aggregate([
    {"$match":{"CustomerID":"ALFKI"}},
    {"$lookup":{"from": "order-details",
                "localField": "OrderID",
                "foreignField": "OrderID",
                "as": "Order-details"}},
    {"$unwind": {
                "path": "$Order-details",
                "preserveNullAndEmptyArrays":True}},
    {"$lookup":{"from": "products",
                "localField": "Order-details.ProductID",
                "foreignField": "ProductID",
                "as": "Order-details.Product-details"}},
    {"$group":{
                "_id":"$OrderID",
                "OrderID":{"$first":"$OrderID"},
                "CustomerID":{"$first":"$CustomerID"},
                "Products":{"$push":"$Order-details"}}},
    {"$project":{
                "_id":0,
                "CustomerID": 1,
                "OrderID": 1,
                "Products.Product-details.ProductID": 1,
                "Products.Product-details.ProductName": 1}}
    ])

for item in query:
    pprint.pprint(item)


#Query for Exercise 5.2

a=[i['OrderID'] for i in db["orders"].find({"CustomerID": "ALFKI"})]
b=[i["_id"] for i in db["order-details"].aggregate([
    {"$match":{"OrderID":{"$in":a}}},
    {"$group":{"_id":"$OrderID", "amount_of_diff_products":{"$sum":1}}},
    {"$match":{"amount_of_diff_products":{"$gte":2}}}])]


query=db.orders.aggregate([
    {"$match":{"OrderID":{"$in":b}}},
    {"$lookup":{"from": "order-details",
                "localField": "OrderID",
                "foreignField": "OrderID",
                "as": "Order-details"}},
    {"$unwind": {
                "path": "$Order-details",
                "preserveNullAndEmptyArrays":True}},
    {"$lookup":{"from": "products",
                "localField": "Order-details.ProductID",
                "foreignField": "ProductID",
                "as": "Order-details.Product-details"}},
    {"$group":{
                "_id":"$OrderID",
                "OrderID":{"$first":"$OrderID"},
                "CustomerID":{"$first":"$CustomerID"},
                "Products":{"$push":"$Order-details"}}},
    {"$project": {
                "_id": 0,
                "CustomerID": 1,
                "OrderID": 1,
                "Products.Product-details.ProductID": 1,
                "Products.Product-details.ProductName": 1}}
    ])

for item in query:
    pprint.pprint(item)

##Query for Exercise 5.3

query=db.orders.aggregate([
    # Only request documents with that particular CustomerID
    {"$match":{"CustomerID":"ALFKI"}},
    # Lookup/Find the order details from the table "order-details", matching on OrderID
    {"$lookup":{"from": "order-details",
                "localField": "OrderID",
                "foreignField": "OrderID",
                "as": "Order-details"}},
    # Extract the results from the joined table "order-details" to allow queries on these
    {"$unwind": {
                "path": "$Order-details",
                "preserveNullAndEmptyArrays":True}},
    # Lookup the products matching those from the above obtained "order-details",
    # based on ProductID
    {"$lookup":{"from": "products",
                "localField": "Order-details.ProductID",
                "foreignField": "ProductID",
                "as": "Order-details.Product-details"}},
    # Group/Summarize all the single documents generated by the queries above,
    # based on their OrderID and CustomerID
    {"$group":{
                "_id":{"CustomerID":"$CustomerID", "EmployeeID":"$EmployeeID"},
                # Create the attribute total amount and sum up all calculations
                # for each row
                "total_Amount":{"$sum":\
                # Make the internal multiplication according to the formula in the
                # description for each row of the group
                {"$multiply":["$Order-details.Quantity","$Order-details.UnitPrice",
                              {"$subtract":[1,"$Order-details.Discount"]}]}},
                "CustomerID":{"$first":"$CustomerID"},
                'EmployeeID':{"$first":'$EmployeeID'},
                "Products":{"$push":"$Order-details.Product-details.ProductName"}}},
    # Leave the attribute ''_id'' out of the results
    {"$project":{
                "_id":0}}
    ])

# Now we just have to iteratively print all query results with pretty printer
for item in query:
    pprint.pprint(item)
#!/usr/bin/env python3
# -*- coding: utf-8 -*-
"""
Created on Tue Oct 10 14:25:47 2017

@author: <NAME>
"""

import pymongo
import pprint
from pymongo import MongoClient
client=MongoClient()
db=client.Northwind

##Query for Exercise 5.1
query=db.orders.aggregate([
    {"$match":{"CustomerID":"ALFKI"}},
    {"$lookup":{"from": "order-details",
                "localField": "OrderID",
                "foreignField": "OrderID",
                "as": "Order-details"}},
    {"$unwind": {
                "path": "$Order-details",
                "preserveNullAndEmptyArrays":True}},
    {"$lookup":{"from": "products",
                "localField": "Order-details.ProductID",
                "foreignField": "ProductID",
                "as": "Order-details.Product-details"}},
    {"$group":{
                "_id":"$OrderID",
                "OrderID":{"$first":"$OrderID"},
                "CustomerID":{"$first":"$CustomerID"},
                "Products":{"$push":"$Order-details"}}},
    {"$project":{
                "_id":0,
                "CustomerID": 1,
                "OrderID": 1,
                "Products.Product-details.ProductID": 1,
                "Products.Product-details.ProductName": 1}}
    ])

for item in query:
    pprint.pprint(item)


#Query for Exercise 5.2

a=[i['OrderID'] for i in db["orders"].find({"CustomerID": "ALFKI"})]
b=[i["_id"] for i in db["order-details"].aggregate([
    {"$match":{"OrderID":{"$in":a}}},
    {"$group":{"_id":"$OrderID", "amount_of_diff_products":{"$sum":1}}},
    {"$match":{"amount_of_diff_products":{"$gte":2}}}])]


query=db.orders.aggregate([
    {"$match":{"OrderID":{"$in":b}}},
    {"$lookup":{"from": "order-details",
                "localField": "OrderID",
                "foreignField": "OrderID",
                "as": "Order-details"}},
    {"$unwind": {
                "path": "$Order-details",
                "preserveNullAndEmptyArrays":True}},
    {"$lookup":{"from": "products",
                "localField": "Order-details.ProductID",
                "foreignField": "ProductID",
                "as": "Order-details.Product-details"}},
    {"$group":{
                "_id":"$OrderID",
                "OrderID":{"$first":"$OrderID"},
                "CustomerID":{"$first":"$CustomerID"},
                "Products":{"$push":"$Order-details"}}},
    {"$project": {
                "_id": 0,
                "CustomerID": 1,
                "OrderID": 1,
                "Products.Product-details.ProductID": 1,
                "Products.Product-details.ProductName": 1}}
    ])

for item in query:
    pprint.pprint(item)

##Query for Exercise 5.3

query=db.orders.aggregate([
    # Only request documents with that particular CustomerID
    {"$match":{"CustomerID":"ALFKI"}},
    # Lookup/Find the order details from the table "order-details", matching on OrderID
    {"$lookup":{"from": "order-details",
                "localField": "OrderID",
                "foreignField": "OrderID",
                "as": "Order-details"}},
    # Extract the results from the joined table "order-details" to allow queries on these
    {"$unwind": {
                "path": "$Order-details",
                "preserveNullAndEmptyArrays":True}},
    # Lookup the products matching those from the above obtained "order-details",
    # based on ProductID
    {"$lookup":{"from": "products",
                "localField": "Order-details.ProductID",
                "foreignField": "ProductID",
                "as": "Order-details.Product-details"}},
    # Group/Summarize all the single documents generated by the queries above,
    # based on their OrderID and CustomerID
    {"$group":{
                "_id":{"CustomerID":"$CustomerID", "EmployeeID":"$EmployeeID"},
                # Create the attribute total amount and sum up all calculations
                # for each row
                "total_Amount":{"$sum":\
                # Make the internal multiplication according to the formula in the
                # description for each row of the group
                {"$multiply":["$Order-details.Quantity","$Order-details.UnitPrice",
                              {"$subtract":[1,"$Order-details.Discount"]}]}},
                "CustomerID":{"$first":"$CustomerID"},
                'EmployeeID':{"$first":'$EmployeeID'},
                "Products":{"$push":"$Order-details.Product-details.ProductName"}}},
    # Leave the attribute ''_id'' out of the results
    {"$project":{
                "_id":0}}
    ])

# Now we just have to iteratively print all query results with pretty printer
for item in query:
    pprint.pprint(item)
#!/usr/bin/env python3 # -*- coding: utf-8 -*- Created on Tue Oct 10 14:25:47 2017  @author: <NAME> ##Query for Exercise 5.1 #Query for Exercise 5.2 ##Query for Exercise 5.3 # Only request documents with that particular CustomerID # Lookup/Find the order details from the table "order-details", matching on OrderID # Extract the results from the joined table "order-details" to allow queries on these # Lookup the products matching those from the above obtained "order-details", # based on ProductID # Group/Summarize all the single documents generated by the queries above, # based on their OrderID and CustomerID # Create the attribute total amount and sum up all calculations # for each row # Make the internal multiplication according to the formula in the # description for each row of the group # Leave the attribute ''_id'' out of the results # Now we just have to iteratively print all query results with pretty printer