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) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment