13.PyMongo安装与使用
- 1.安装 PyMongo
- 2.使用PyMongo
- 2.1连接数据库和集合
- 2.2增加数据
- 2.3修改数据
- 2.4查询数据
- 2.5删除数据
- 3.总结
MongoDB 安装可以看这篇文章MongoDB安装配置教程(详细版)
1.安装 PyMongo
PyMongo 是Python中用于连接MongoDB数据库的库,安装起来非常简单。通常情况下,只需要在命令行中执行以下命令即可:
pip install PyMongo
如果你使用的是Python 3,可能需要使用pip3来安装:
pip3 install PyMongo
2.使用PyMongo
使用 PyMongo 连接 MongoDB 的第一步是创建一个 MongoClient 对象。可以通过以下方式创建连接
2.1连接数据库和集合
import pymongo
mongo = pymongo.MongoClient('localhost', 27017)
# 选择数据库
db = mongo.test
print(db)
col = db.table
print(col)
执行结果:
Database(MongoClient(host=['localhost:27017'], document_class=dict, tz_aware=False, connect=True), 'test')
Collection(Database(MongoClient(host=['localhost:27017'], document_class=dict, tz_aware=False, connect=True), 'test'), 'table')
2.2增加数据
插入文档可以使用 insert_one()
或 insert_many()
方法
1.insert_one() 添加一个
# 添加
import pymongo
mongo = pymongo.MongoClient('localhost', 27017)
# 选择数据库
db = mongo.test
col = db.table
col.insert_one({"name": "John",'age':23}) #添加一个
执行结果:
2.insert_many() 添加一些
col.insert_many([{"name": "John",'age':23},{"name": "Jane",'age':24},{"name": "bob",'age':25}])
执行结果:
2.3修改数据
常见参数包括:
filter
:定义了更新条件的查询对象。update
:包含了更新内容的对象,通常使用 $set 操作符来更新字段。**kwargs
:可选参数,如 upsert (在未找到匹配文档时的插入行为) 等。
更新数据可以使用 update_one()
或 update_many()
方法:
1.update_one() 更新一个,我们更新 name=John 的 age=30
# 修改
col.update_one({"name": "John"}, {"$set": {"age": 30}})
执行结果:
2.update_many() 更新一些 我们更新 name=John 的 age=31
# 修改
col.update_many()({"name": "John"}, {"$set": {"age": 30}})
执行结果:
2.4查询数据
常见参数包括:
filter
: 查询条件,用于指定要检索的文档。projection
: 投影条件,用于指定要返回的字段。sort
: 排序条件,用于指定返回文档的排序方式。skip
: 跳过的文档数量。limit
: 返回文档的最大数量。batch_size
: 每次从服务器读取的文档数量。max_time_ms
: 查询的最大执行时间(毫秒)。
1.查询所有
results = col.find()
执行结果:
{'_id': ObjectId('6677b7d499f1e427419c2d07'), 'name': 'John', 'age': 31}
{'_id': ObjectId('6677b91125406ce9b6fae3ea'), 'name': 'John', 'age': 31}
{'_id': ObjectId('6677b91125406ce9b6fae3eb'), 'name': 'Jane', 'age': 24}
{'_id': ObjectId('6677b91125406ce9b6fae3ec'), 'name': 'bob', 'age': 25}
2.查询 name = bob 的数据
result = col.find({'name':'bob'})
print(list(result))
执行结果:
[{'_id': ObjectId('6677b91125406ce9b6fae3ec'), 'name': 'bob', 'age': 25}]
3.使用 $gt
运算符来查询年龄大于20岁的学生,并指定返回结果中包含的字段。同时,我们指定了排序和跳过的文档数量,以及限制返回文档的数量
results = col.find({"age": {"$gt": 20}}, {"_id": 0, "name": 1, "age": 1}).sort("age", pymongo.ASCENDING).skip(1).limit(3)
执行结果:
{'name': 'bob', 'age': 25}
{'name': 'John', 'age': 31}
{'name': 'John', 'age': 31}
2.5删除数据
PyMongo 提供了 delete_one()
和 delete_many()
方法来删除 MongoDB 集合中的文档
1.delete_one() 删除 name = bob 的 数据
results = col.delete_one({'name': 'bob'})
print(results)
执行结果:
DeleteResult({'n': 1, 'ok': 1.0}, acknowledged=True)
2.delete_many() 删除 name = John 的 数据
results = col.delete_many()({'name': 'John'})
print(results)
执行结果:
DeleteResult({'n': 2, 'ok': 1.0}, acknowledged=True)
3.总结
PyMongo 为 Python 程序员提供了一个强大且易于使用的 MongoDB 接口。通过上述教程,你可以学会如何安装 PyMongo、连接 MongoDB、创建数据库和集合、插入和查询文档、更新和删除数据,以及如何对结果进行排序、跳过和限制。这些操作构成了与 MongoDB 数据库交互的基础。