当前位置: 代码网 > it编程>前端脚本>Python > Python与MongoDB交互的代码实现

Python与MongoDB交互的代码实现

2024年10月08日 Python 我要评论
python与mongodb的交互通常通过pymongo库来实现。pymongo是一个官方的python驱动程序,用于与mongodb数据库进行交互。以下是一个简单的示例,展示了如何使用pymongo

python与mongodb的交互通常通过pymongo库来实现。pymongo是一个官方的python驱动程序,用于与mongodb数据库进行交互。以下是一个简单的示例,展示了如何使用pymongo来连接到mongodb数据库,执行一些基本的数据库操作(如插入、查询、更新和删除文档)。

安装pymongo

pip install pymongo

python连接mongodb

from pymongo import mongoclient
 
# 创建一个mongoclient对象,该对象用于连接mongodb数据库服务器
client = mongoclient('mongodb://admin:password@localhost:27017/')

向数据库中添加数据

from mongo_db import client
 
# client.school.teacher.insert_one({"name": "露娜"})
 
# client.school.teacher.insert_many([{"name":"兰陵王"}, {"name": "百里玄策"}])
 
client.school.teacher.find({})

查询数据

from mongo_db import client
 
try:
    teachers = client.school.teacher.find()
    # print(teachers)
    for one in teachers:
        print(one["_id"],one["name"])
 
    # 有条件查询
    teacher = client.school.teacher.find_one({"name":"兰陵王"})
    print(teacher["_id"],teacher["name"])
 
except exception  as e:
    print(e)

更新修改数据

from mongo_db import client
 
try:
    # 全表修改,表中无此列时会增加此列
    # client.school.teacher.update_many({}, {'$set': {"role":["班主任"]}})
    # client.school.teacher.update_one({"name": "露娜"},{"$set":{"sex": "女"}})
 
    # push追加(列表)
    client.school.teacher.update_one({"name": "露娜"},{"$push":{"role": "年级王主任"}})
 
except exception as e:
    print(e)

删除数据

from mongo_db import client
 
try:
    # 有条件查询
    # client.school.teacher.delete_one({"name": "露娜"})
    # 删除多条数据
    client.school.teacher.delete_many({})
except exception as e:
    print(e)

索引 

创建索引以优化查询性能。

collection.create_index([("name", pymongo.ascending)])

聚合框架 

使用聚合框架进行复杂的数据聚合操作

pipeline = [
    {"$match": {"age": {"$gt": 25}}},
    {"$group": {"_id": "$city", "count": {"$sum": 1}}}
]
results = collection.aggregate(pipeline)
for result in results:
    print(result)

事务 

从mongodb 4.0开始,支持多文档事务,确保数据的一致性和完整性。

with client.start_session() as session:
    with session.start_transaction():
        collection.update_one({"name": "john"}, {"$set": {"age": 32}}, session=session)
        collection.update_one({"name": "alice"}, {"$set": {"age": 26}}, session=session)
        session.commit_transaction()

关闭连接

client.close()

注意事项

在使用pymongo进行mongodb操作时,需要确保mongodb服务已经启动并且网络连接正常。

在进行数据插入、更新和删除操作时,需要注意数据的完整性和一致性。

mongodb的集合是动态创建的,即当向一个不存在的集合插入数据时,mongodb会自动创建该集合。

到此这篇关于python与mongodb交互的代码实现的文章就介绍到这了,更多相关python与mongodb交互内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网!

(0)

相关文章:

版权声明:本文内容由互联网用户贡献,该文观点仅代表作者本人。本站仅提供信息存储服务,不拥有所有权,不承担相关法律责任。 如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 2386932994@qq.com 举报,一经查实将立刻删除。

发表评论

验证码:
Copyright © 2017-2025  代码网 保留所有权利. 粤ICP备2024248653号
站长QQ:2386932994 | 联系邮箱:2386932994@qq.com