Skip to content

Instantly share code, notes, and snippets.

What would you like to do?
class UserRepository(object):
def __init__(self):
mongoclient = MongoClient('localhost', 27017)
#mongoclient = MongoClient('mongodb://localhost:27017')
database = mongoclient.local
self._users = database.user
# Create operations
def insert(self, user):
return self._users.insert_one(user)
def insert_many(self, users):
return self._users.insert_many(users)
# Read operations
def read_all(self):
return self._users.find()
def read_many(self, conditions):
return self._users.find(conditions)
def read(self, conditions):
return self._users.find_one(conditions)
# Update operations
def update(self, conditions, new_value):
return self._users.update_one(conditions, new_value)
def increment_age(self, conditions):
return self._users.update_one(conditions, {'$inc' : {'age' : 1}})
# Delete operations
def delete(self, condition):
return self._users.delete_one(condition)
def delete_many(self, condition):
return self._users.delete_many(condition)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment