mongod –dbpath PATH_TO_THE_DIR

通过此安装，还将安装MongoCompass。这是可视化的GUI 组件，您可以使用它来操纵数据库、集合和文档：

pip install pymongo

之后安装MongoEngine：

pip install mongoengine

就是这样。我们已准备好实现。

from pymongo import MongoClient

在UserRepository的构造，我们创建了一个MongoClient的实例并连接到群集。有几种方法可以实现，而在代码中可以看到两种方法。然后选择数据库和集合。该实现的其余部分更不只是包装self._user字段中的函数。

class UserRepository(object):def __init__(self):mongoclient = MongoClient('localhost', 27017)#mongoclient = MongoClient('mongodb://localhost:27017')database = mongoclient.localself._users = database.user

现在，我们可以创建此类的对象，如下所示：

user_repo = UserRepository()

创建操作

接下来，我们实现创建 操作。我们添加了两个方法：insert和insert_many。第一种方法仅将一个用户添加到集合中，而另一种方法从提供的array中添加所有用户。我们可以看到，下面他们只是从PyMongo中利用函数insert_one和insert_many。

class UserRepository(object):def __init__(self):mongoclient = MongoClient('localhost', 27017)#mongoclient = MongoClient('mongodb://localhost:27017')database = mongoclient.localself._users = database.user# Create operationsdef insert(self, user):return self._users.insert_one(user)def insert_many(self, users):return self._users.insert_many(users)

现在，我们可以从对象中使用这些功能。方法insert可以这样使用：

user = {'name':"Rubik",'age':33,'blog':"rubikscode.net"
}result = user_repo.insert(user)
print(result.acknowledged)

当我们使用MongoDB Compass peek此集合时，我们可以看到该文档是在用户集合中创建的。

user_1 = {'name':"Vanja",'age':29,'blog':"eventroom.org"
}user_2 = {'name':"Marko",'age':36,'blog':"rubikscode.net"
}result = user_repo.insert_many([user_1, user_2])
print(result.acknowledged)

再次使用MongoDB Compass检查此操作的结果：

class UserRepository(object):def __init__(self):mongoclient = MongoClient('localhost', 27017)#mongoclient = MongoClient('mongodb://localhost:27017')database = mongoclient.localself._users = database.user# Create operationsdef insert(self, user):return self._users.insert_one(user)def insert_many(self, users):return self._users.insert_many(users)# Read operationsdef 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)

这些函数可以这样使用 ：

print("---Read All---")
all_users = user_repo.read_all()for user in all_users:print(user)
print("--------------\n")print("---Read Many--")
rc_users = user_repo.read_many({'blog':'rubikscode.net'})for user in rc_users:print(user)
print("--------------\n")print("--- Read ---")
one_rc_user = user_repo.read({'blog':'rubikscode.net'})print(one_rc_user)
print("--------------\n")

而输出是这样的：

—Read All—
{‘_id’: ObjectId(‘5dbad5a4dde338d6e1cd3ea7’), ‘name’: ‘Rubik’, ‘age’: 33, ‘blog’: ‘rubikscode.net’}
{‘_id’: ObjectId(‘5dbc2f46ac3310f0215ba277’), ‘name’: ‘Vanja’, ‘age’: 29, ‘blog’: ‘eventroom.org’}
{‘_id’: ObjectId(‘5dbc2f46ac3310f0215ba278’), ‘name’: ‘Marko’, ‘age’: 36, ‘blog’: ‘rubikscode.net’}
————–—Read Many–
{‘_id’: ObjectId(‘5dbad5a4dde338d6e1cd3ea7’), ‘name’: ‘Rubik’, ‘age’: 33, ‘blog’: ‘rubikscode.net’}
{‘_id’: ObjectId(‘5dbc2f46ac3310f0215ba278’), ‘name’: ‘Marko’, ‘age’: 36, ‘blog’: ‘rubikscode.net’}
————–— Read —
{‘_id’: ObjectId(‘5dbad5a4dde338d6e1cd3ea7’), ‘name’: ‘Rubik’, ‘age’: 33, ‘blog’: ‘rubikscode.net’}
————–

更新操作

我们实现了两种更新方法：update和gain_age。第一个目的是演示如何使用条件更新单个文档。另一个功能演示如何将MongoDB更新修饰符封装在函数中，并根据需要定制存储库。可以说，这是这种方法的最大优势。

class UserRepository(object):def __init__(self):mongoclient = MongoClient('localhost', 27017)#mongoclient = MongoClient('mongodb://localhost:27017')database = mongoclient.localself._users = database.user# Create operationsdef insert(self, user):return self._users.insert_one(user)def insert_many(self, users):return self._users.insert_many(users)# Read operationsdef 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 operationsdef 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}})

函数update可用于更新文档名称，如下所示：

result = user_repo.update({'name':'Rubik'}, {'$set': {'name': "Nikola"}})
print(result.acknowledged)

该结果是这样的：

result = user_repo.increment_age({'name':'Nikola'})
print(result.acknowledged)

结果可以在MongoDB Compass中观察到：

class UserRepository(object):def __init__(self):mongoclient = MongoClient('localhost', 27017)#mongoclient = MongoClient('mongodb://localhost:27017')database = mongoclient.localself._users = database.user# Create operationsdef insert(self, user):return self._users.insert_one(user)def insert_many(self, users):return self._users.insert_many(users)# Read operationsdef 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 operationsdef 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 operationsdef delete(self, condition):return self._users.delete_one(condition)def delete_many(self, condition):return self._users.delete_many(condition)

如果要删除一个文档，可以这样操作：

result = user_repo.delete({'name':'Nikola'})
print(result.acknowledged)

该操作的结果：

result = user_repo.delete_many({'blog':'rubikscode.net'})
print(result.acknowledged)

操作结果：

from mongoengine import * connect('local', host='localhost', port=27017)

该函数的第一个参数是数据库的名称，而其他两个参数则定义location。为了“附加”到集合，我们需要实现一个类，该类描述该集合-模型的文档。这非常类似于我们在各种ORM中执行此操作的方式，因此，如果您有使用EntityFramework的经验，这对您来说自然而然的。模型类必须继承Document。 对于我们的用户集合，如下所示：

class User(Document):name = StringField(required=True, max_length=50)age = IntField(required=True)blog = StringField(required=True, max_length=50)

在此模型中，我们告诉MongoEngine 我们希望用户拥有姓名，年龄 和博客。 在下面，文档 基础对象将验证提供的数据。MongoEngine提供了各种字段类型 （这里我们仅使用StringField和IntField）以及这些类型的选项 。

user = User(name = "Rubik",age = 33,blog = "rubikscode.net")# Create Operation
user.save()

请注意，在这种特殊情况下，保存 方法会在用户集合中创建文档。

read_users = User.objectsfor user in User.objects:print("Name: {}; Age: {}; Blog: {}".format(user.name, user.age, user.blog))

使用对象字段，我们可以访问数据库中的所有文档。在这种情况下，只有一个：

Name: Rubik; Age: 33; Blog: rubikscode.net

如果我们要创建各种查询，则可以在此之上使用过滤器功能。

user.name = "Marko"# Update
user.save()

结果：

user.delete()

该结果是这样的：