The Top 4 Reasons Why You Should Use MongoDB

1
import mysql.connector
2
3
# CONNECT TO THE DB
4
mydb = mysql.connector.connect(
5
   host="localhost",
6
   user="root",
7
   passwd="rootroot",
8
   database="CityHall"
9
)
10
mycursor = mydb.cursor(dictionary=True)
11
12
# THE ID OF THE USER WHOSE PROFILE WE WILL BE RETRIEVING AND UPDATING
13
userId = 1

1
import pymongo
2
from pymongo import MongoClient
3
4
# CONNECT TO THE DB
5
client = MongoClient()
6
client = pymongo.MongoClient("mongodb+srv://root:rootroot@mycluster.mongodb.net/test?retryWrites=true&w=majority")
7
db = client.CityHall
8
9
# THE ID OF THE USER WHOSE PROFILE WE WILL BE RETRIEVING AND UPDATING
10
userId = 1

1
sql = "SELECT * FROM Users LEFT JOIN Hobbies ON Users.ID = Hobbies.user_id WHERE Users.id=%s"
2
values = (userId,)
3
my cursor.execute(sql, values)
4
user = mycursor.fetchone()

1
{u'city': u'Pawnee', u'first_name': u'Leslie', u'last_name': u'Yepp', u'user_id': 1, u'school': None, u'longitude': -86.5366, u'cell': u'8125552344', u'latitude': 39.1703, u'hobby': u'scrapbooking', u'ID': 10}

1
hobbies = []
2
if (user["hobby"]):
3
  hobbies.append(user["hobby"])
4
del user["hobby"]
5
del user["ID"]
6
for result in mycursor:
7
  hobbies.append(result["hobby"])
8
user["hobbies"] = hobbies

1
user = db['Users'].find_one({"_id": userId})

1
{
2
   'city': 'Pawnee', 
3
   'first_name': 'Leslie', 
4
   'last_name': 'Yepp', 
5
   'school': None, 
6
   'cell': '8125552344', 
7
   'latitude': 39.1703,
8
   'longitude': -86.5366,3
9
   'hobbies': ['scrapbooking', 'eating waffles', 'working'],
10
   'user_id': 1
11
}

1
{
2
   'city': 'Pawnee', 
3
   'first_name': 'Leslie', 
4
   'last_name': 'Yepp', 
5
   'cell': '8125552344', 
6
   'location': [-86.536632, 39.170344], 
7
   'hobbies': ['scrapbooking', 'eating waffles', 'working'],
8
   '_id': 1
9
}

1
user.update( {
2
   "city": "Washington, DC",
3
   "latitude": 38.897760,
4
   "longitude": -77.036809,
5
   "hobbies": ["scrapbooking", "eating waffles", "signing bills"]
6
   } )

1
user.update( {
2
   "city": "Washington, DC",
3
   "location": [-77.036809, 38.897760],
4
   "hobbies": ["scrapbooking", "eating waffles", "signing bills"]
5
   } )

1
sql = "UPDATE Users SET first_name=%s, last_name=%s, cell=%s, city=%s, latitude=%s, longitude=%s, school=%s WHERE (ID=%s)"
2
values = (user["first_name"], user["last_name"], user["cell"], user["city"], user["latitude"], user["longitude"], user["school"], userId)
3
mycursor.execute(sql, values)
4
mydb.commit()

1
sql = "DELETE FROM Hobbies WHERE user_id=%s"
2
values = (userId,)
3
mycursor.execute(sql, values)
4
mydb.commit()
5
6
if(len(user["hobbies"]) > 0):
7
   sql = "INSERT INTO Hobbies (user_id, hobby) VALUES (%s, %s)"
8
   values = []
9
   for hobby in user["hobbies"]:
10
      values.append((userId, hobby))
11
   mycursor.executemany(sql,values)
12
   mydb.commit()

1
result = db['Users'].update_one({"_id": userId}, {"$set": user})