wip

Author: c-neto

python/mongodb-mini-book/.gitignore

@@ -0,0 +1,8 @@
+.venv/
+.vscode/
+.idea/
+__pypackages__/
+__pycache__/
+*.py[cod]
+*$py.class
+*log

python/mongodb-mini-book/.images/objectId.jpg

@@ -0,0 +1,12 @@
+
+use school
+db.scores.drop();
+var types = ['exam', 'homework', 'quiz']
+for (student_id = 0; student_id < 100; student_id++) {
+    for (type=0; type < 3; type++) {
+    var r = {'student_id':student_id, 'type':types[type], 'score':Math.random() * 100};
+    db.scores.insert(r);
+    }
+}
+
+

python/mongodb-mini-book/00-ScriptJS-insercaoDados/create_student_collection.js

@@ -0,0 +1,49 @@
+#!/usr/bin/env python
+import pymongo
+
+# It is not necessary to import sys
+
+# establish a connection to the database
+connection = pymongo.MongoClient("mongodb://localhost")
+
+# get a handle to the school database
+db = connection.school
+scores = db.scores
+
+
+def find():
+
+    print "find(), reporting for duty"
+
+    query = {'type': 'exam'}
+
+    try:
+        cursor = scores.find(query)
+
+    except Exception as e:
+        print "Unexpected error:", type(e), e
+
+    sanity = 0
+    for doc in cursor:
+        print doc
+        sanity += 1
+        if (sanity > 10):
+            break
+
+
+def find_one():
+
+    print "find_one(), reporting for duty"
+    query = {'student_id': 10}
+    
+    try:
+        doc = scores.find_one(query)
+        
+    except Exception as e:
+        print "Unexpected error:", type(e), e
+    
+    print doc
+
+
+if __name__ == '__main__':
+    find()  # Change this to find_one() to run that function, instead.

python/mongodb-mini-book/01-QuerySimples/using_find.py

@@ -0,0 +1,33 @@
+#!/usr/bin/env python
+import pymongo
+
+# establish a connection to the database
+connection = pymongo.MongoClient("mongodb://localhost")
+
+# get a handle to the school database
+db = connection.school
+scores = db.scores
+
+
+def find():
+
+    print "find, reporting for duty"
+
+    query = {'type': 'exam', 'score': {'$gt': 50, '$lt': 70}}
+
+    try:
+        cursor = scores.find(query)
+
+    except Exception as e:
+        print "Unexpected error:", type(e), e
+
+    sanity = 0
+    for doc in cursor:
+        print doc
+        sanity += 1
+        if (sanity > 10):
+            break
+
+
+if __name__ == '__main__':
+    find()

python/mongodb-mini-book/02-Gt-Lt/find_using_gt_lt.py

@@ -0,0 +1,26 @@
+#!/usr/bin/env python
+
+import json
+import urllib2
+import pymongo
+
+# connect to mongo
+connection = pymongo.MongoClient("mongodb://localhost")
+
+# get a handle to the reddit database
+db = connection.reddit
+stories = db.stories
+
+# drop existing collection
+stories.drop()
+
+# get the reddit home page
+reddit_page = urllib2.urlopen("http://www.reddit.com/r/technology/.json")
+
+# parse the json into python objects
+parsed = json.loads(reddit_page.read())
+
+# iterate through every news item on the page
+for item in parsed['data']['children']:
+    # put it in mongo
+    stories.insert_one(item['data'])

python/mongodb-mini-book/03-InsertPegandoDadosDoReddit/read_reddit.py

@@ -0,0 +1,32 @@
+#!/usr/bin/env python
+import pymongo
+
+# no need to import sys
+
+# establish a connection to the database
+connection = pymongo.MongoClient("mongodb://localhost")
+
+# get a handle to the school database
+db = connection.school
+scores = db.scores
+
+
+def find():
+    print "find, reporting for duty"
+    query = {}
+    try:
+        cursor = scores.find(query).skip(4)
+        cursor.limit(1)
+#        cursor.sort('student_id', pymongo.ASCENDING).skip(4).limit(1)
+        cursor.sort([('student_id', pymongo.ASCENDING),
+                     ('score', pymongo.DESCENDING)])
+
+    except Exception as e:
+        print "Unexpected error:", type(e), e
+
+    for doc in cursor:
+        print doc
+
+
+if __name__ == '__main__':
+    find()

python/mongodb-mini-book/03-InsertPegandoDadosDoReddit/reddit.json

@@ -0,0 +1,34 @@
+#!/usr/bin/env python
+import pymongo
+
+# establish a connection to the database
+connection = pymongo.MongoClient("mongodb://localhost")
+
+
+def insert_two():
+
+    # get a handle to the school database
+    db = connection.school
+    people = db.people
+
+    print "insert, reporting for duty"
+
+    richard = {"name": "Richard Kreuter", "company": "MongoDB",
+               "interests": ['horses', 'skydiving', 'fencing']}
+    andrew = {"_id": "erlichson", "name": "Andrew Erlichson",
+              "company": "MongoDB", "interests": ['running', 'cycling',
+                                                  'photography']}
+
+    try:
+        people.insert_one(richard)
+        people.insert_one(andrew)
+
+    except Exception as e:
+        print "Unexpected error:", type(e), e
+
+    print(richard)
+    print(andrew)
+
+
+if __name__ == '__main__':
+    insert_two()

python/mongodb-mini-book/04-SkipSortLimit/using_limit_skip_sort.py

@@ -0,0 +1,40 @@
+#!/usr/bin/env python
+
+import pymongo
+
+# establish a connection to the database
+connection = pymongo.MongoClient("mongodb://localhost")
+
+
+def insert_many():
+    # get a handle to the school database
+    db = connection.school
+    people = db.people
+
+    print "insert_many, reporting for duty"
+    andrew = {"_id": "erlichson", "name": "Andrew Erlichson",
+              "company": "MongoDB",
+              "interests": ['running', 'cycling', 'photography']}
+    richard = {"name": "Richard Kreuter", "company": "MongoDB",
+               "interests": ['horses', 'skydiving', 'fencing']}
+    people_to_insert = [andrew, richard]
+    try:
+        people.insert_many(people_to_insert, ordered=False)
+    except Exception as e:
+        print "Unexpected error:", type(e), e
+
+
+def print_people():
+    # get a handle to the school database
+    db = connection.school
+    people = db.people
+    cur = people.find({}, {'name': 1})
+    for doc in cur:
+        print doc
+
+if __name__ == '__main__':
+    print "Before the insert_many, here are the people"
+    print_people()
+    insert_many()
+    print "\n\nAfter the insert_many, here are the people"
+    print_people()