MongoDB CRUD操作:批量写操作
from pymongo import MongoClient
# 连接到MongoDB
client = MongoClient('mongodb://localhost:27017/')
db = client['test_database'] # 选择数据库
collection = db['test_collection'] # 选择集合
# 插入文档
documents = [
{"name": "Alice", "age": 25, "address": "123 Park Street"},
{"name": "Bob", "age": 30, "address": "321 Park Street"},
{"name": "Charlie", "age": 35, "address": "456 Park Street"}
]
# 批量插入文档
insert_result = collection.insert_many(documents)
print(f'Inserted {len(insert_result.inserted_ids)} documents.')
# 更新文档
update_result = collection.update_many(
{"address": "456 Park Street"}, # 查询条件
{"$set": {"address": "789 Park Street"}} # 更新操作
)
print(f'Updated {update_result.modified_count} documents.')
# 删除文档
delete_result = collection.delete_many({"name": "Alice"})
print(f'Deleted {delete_result.deleted_count} documents.')
这段代码展示了如何在MongoDB中进行批量写操作。首先,我们连接到本地的MongoDB实例,并选择相应的数据库和集合。然后,我们使用insert_many()
方法来批量插入文档,使用update_many()
方法来批量更新文档,并使用delete_many()
方法来批量删除文档。这些操作都返回了结果对象,我们可以从中提取有关操作影响的文档数量的信息。
评论已关闭