Python开发运维：PyMongo 连接操作 MongoDB

2023-12-01 03:12
文章标签 python 操作 连接 开发 运维 mongodb pymongo

本文主要是介绍Python开发运维：PyMongo 连接操作 MongoDB，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

目录

一、理论

1.PyMongo模块

2.Mongo Shell

二、实验

1. Windows11安装MongoDB 7.0.4

2.Windows11安装MongoDB Shell 2.1.0

3.PyMongo 连接 MongoDB（无密码方式）

4.PyMongo 连接 MongoDB（有密码方式）

5.PyMongo 操作 MongoDB (数据库管理)

6.PyMongo 操作 MongoDB (集合管理)

7.PyMongo 操作 MongoDB (文档管理)

三、问题

1.pip安装报错

2.PyCharm如何添加MongoDB插件

一、理论

1.PyMongo模块

（1）概念

在python当中，一般常用于开发中操作monoDB的模块有如下三个：

1）pymongo2）mongoengine3）moter
它是python中基于pymongo实现的异步操作库，类似于aiomysql，aiomysql也是python基于pymysql实现的异步库。

2.Mongo Shell

（1）概念

MongoShell是一个互动的JavaScript接口的MongoDB，可以使用MongoShell来查询和更新数据以及执行管理操作。

MongoShell是MongoDB发行版的一个组件， 安装并启动MongoDB后，将MongoShell连接到正在运行的MongoDB实例，MongoDB手册中的大多数示例使用 MongoShell，然而，许多驱动程序也提供了与MongoDB类似的接口。

二、实验

1. Windows11安装MongoDB 7.0.4

(1)下载

Download MongoDB Community Server | MongoDB

(2)选择版本

92022c0c44df4505953974896bf76e05.png

(3)next下一步

ca5e0b0b431e45f1ba070f1d77dd5a19.png

(4)next下一步

e9c89be4865943dc9edbaa204d20e68d.png

(5)这一步选择Custom

90ef11467b86464d94d7b7e422970175.png

(6)OK

a6e1bcd4d1e94083bdd4f1724b58ef13.png

(7)next下一步

a50c69deba1444769a9eb53aeeab4990.png

(8)next下一步

888806525e79431eb3f830d48e0c4835.png

(9)这里取消Install MongoDB compass,next下一步

24897650cd9c46d5827628cb469fa393.png

(10)Install安装

7abff4d57f8147cc9de92f4b0bfd82c8.png

(11)Finish完成

8e02027e45bb49459ae055fe7dac18c4.png

(12) 服务已自启动

342ee525779749fab2c45e4e84f138f0.png

(13)查看默认配置文件

9381e285ca254f649b03c78f2b1b4466.png

（14）软件目录

c8cc3261c28c4df791a9a947a23b1124.png

2.Windows11安装MongoDB Shell 2.1.0

(1)下载

Try MongoDB Tools - Download Free Here | MongoDB

(2)选择版本

8a25b167754940b0b7173d6cdcdfc567.png

(3)软件目录

42fb16ff9bc3401d9c94520a1eee4abf.png

（4）进入bin目录

01e48d6850bc4b3fab144292ceae62d9.png

（5）双击mongosh.exe进入命令行界面

d0b748d96c3941b48797f502acbd2ce5.png

(4)创建数据库

fa816d0880a147cc9306f16b16ffbec2.png

(5)批量插入数据

142e84887e304a0584c46424bb675ee7.png

(6)完成数据导入

b3501ff6d27d4b9683e1eda0f2eaff2d.png

(7)navicat查看数据

77e31c0233f34dcfa35922116b668b48.png

(8)给Admin数据库创建账户管理员

ef220997842241a18df8a197779aea04.png

(9)创建用户自己的数据库的角色

90449787b87441c2a87b3139ae140efd.png

(10)navicat查看数据

0a71c8922d0c4fe38c4c939172cc6cfa.png

3.PyMongo 连接 MongoDB（无密码方式）

(1)安装PyMongo

0e32f5d36d4046c4a34a757a0b5fcdaa.png

(2)数据库连接

# -*- coding: utf-8 -*-
import pymongo
if __name__ == '__main__':# 无密码连接mongoDBmongo = pymongo.MongoClient('localhost',27017)print(mongo)#切换数据库db = orders = mongo["demo"]#切换数据集orders = db["orders"]#print(orders.find())#查询100条数据for document in orders.find().limit(100):print(document)

① 运行

077146ff756046e5931bd883767b04d9.png

② 输出字典结构.

2829ea1b251a460d808b581047b65c20.png

③运行

0c62c276192d458b89393db5a59f99b1.png

④拿到游标

cbbc067500d44f7da48e7dffd46b6ecd.png

⑤ 运行

5870ace56eef4d1393839b81bdb60f09.png

⑥输出100条数据

60421cb321e84ffa811ec3856c0d0d9c.png

⑦ navicat查看mongodb集合数据

478e7b82c6df4b7cb3a4d8b7a8d6c957.png

4.PyMongo 连接 MongoDB（有密码方式）

(1)数据库连接（方式一）

# -*- coding: utf-8 -*-
import pymongo
from urllib.parse import quote_plusif __name__ == '__main__':# 有密码连接mongoDBusername = quote_plus("david")password = quote_plus("123456")# 获取数据库连接对象mongo = pymongo.MongoClient(f"mongodb://{username}:{password}@127.0.0.1:27017/david")print(mongo)# 获取数据库操作对象db = mongo["david"]print(db)#获取集合操作对象user_list = db["user_list"]# 获取数据for document in user_list.find():print(document)

① 密码连接成功

737348ea341142af800ced00e5b34ac8.png
 

(2)数据库连接（方式二）

# -*- coding: utf-8 -*-import pymongo
from urllib.parse import quote_plusif __name__ == '__main__':#有密码连接mongoDBmongo = pymongo.MongoClient('mongodb://127.0.0.1:27017')db = mongo["david"]username = "david"password = "123456"db.authenticate(username, password)print(db)collection = db["user_list"]print(collection)for document in collection.find():print(document)

 ① 密码连接

d19262f22b794c7489498d03d133641c.png

②查询数据

23deb5ce7b884f9592cf50b90d59511c.png

③ 成功

8dc264fa09e445b1941908407d4fbbf7.png

④ 成功

0d6c54bad4524e66833c5e045b5b1736.png

5.PyMongo 操作 MongoDB (数据库管理)

(1)数据库管理

# -*- coding: utf-8 -*-import pymongo
# from  bson import ObjectIdif __name__ == '__main__':#有密码连接mongoDBmongo = pymongo.MongoClient('mongodb://127.0.0.1:27017')db = mongo["david"]username = "david"password = "123456"db.authenticate(username, password)# 新建一个数据库orders = db["david"]["orders"]# document = {#     # "_id": ObjectId(),#     # "_id": 1,#     "name": "xiaozhao",#     "number": "00000001",# }# ret = orders.insert_one(document)# 查看数据库列表[只会列出有文档数据的数据库]print(mongo.list_database_names())# print(db["david"].list_indexes())      # 查看集合的索引# print(db.list_collection_names())     # 查看所有库下的所有集合# print(mongo["david"])

(2)新建数据库

7dfc818ea0b64ba3bebe66f4d96b08a4.png

(3)成功

fa68bed29fbe4a25b7f667f46cb45dff.png

(4)查看数据库列表（只会列出有文档数据的数据库）

607632f0aae74d679ff3722ff78e5906.png

(5)shop因为没有内容，所以没有被创建的

8f9707b2ffc14b7b8f3ec87fa2a5e9cc.png

(6)查看所有库下的所有集合

4d60f79e444e4abb93f606b88cc2d1dc.png

(7)成功

c8a54830787a4ba99b8df2277d10d8f7.png


 

6.PyMongo 操作 MongoDB (集合管理)

(1)集合管理

# -*- coding: utf-8 -*-import pymongo
# from  bson import ObjectIdif __name__ == '__main__':#有密码连接mongoDBmongo = pymongo.MongoClient('mongodb://127.0.0.1:27017')db = mongo["david"]username = "david"password = "123456"db.authenticate(username, password)# 查看数据库列表[只会列出有文档数据的数据库]print(mongo.list_database_names())# 查看指定数据的集合列表[只会列出有文档数据的集合]print( db.list_collection_names() )# 获取指定名称对应的集合操作对象user_list = db["orders"]#给集合添加数据document = {"name": "xiaoli","password": "123456"}user_list.insert_one(document)# 删除集合db["david.orders"].drop()# 查看指定数据的集合列表[只会列出有文档数据的集合]print( db.list_collection_names() )

① 查看指定数据的集合列表（只会列出有文档数据的集合）

c20e334e3f984b93991e86c1bef3c6f2.png

② 成功

a42bcc459ec2426bb6c27cb82f594c4f.png

③ david库下新建orders表

3f24a8379cf54d3aa4bd888057b5502b.png

④ 删除

2cd6feb7fa614b5cba07ba16ffca83cd.png

7.PyMongo 操作 MongoDB (文档管理)

(1)添加文档

# -*- coding: utf-8 -*-import pymongo
# from  bson import ObjectIdif __name__ == '__main__':#有密码连接mongoDBmongo = pymongo.MongoClient('mongodb://127.0.0.1:27017')db = mongo["david"]username = "david"password = "123456"db.authenticate(username, password)#切换数据集user_list = db["user_list"]# # 添加一个文档# document = {"name": "xiaoming", "mobile": "130XXXXXXXX", "age": 16}# ret = user_list.insert_one(document)# print(ret.inserted_id)  # 返回InsertOneResult对象# 插入文档时，如果没有指定_id，将自动分配一个唯一的id。# 添加多个文档document_list = [{"name": "xiaoqian", "mobile": "136XXXXXXXX", "age": 17},{"name": "xiaosun", "mobile": "135XXXXXXXX", "age": 18},{"name": "xiaowei", "mobile": "139XXXXXXXX", "age": 18},]ret = user_list.insert_many(document_list)# 打印文档_id值列表:print(ret.inserted_ids)

① 添加一个文档

83cdedbd37834b71a00cdfab7ba39f73.png

②成功

40a972a295614249866f0ba162e78ba4.png

③ mongosh查看已插入.

6a822570d9da4298901aa5b7772d972c.png

④ 添加多个文档

d78653bb06dc4cb29927806756aad35a.png

⑤ 最后3个显示已插入

334cbcb57ff042ffb2eb31ac7181ad00.png

(2)删除文档

# -*- coding: utf-8 -*-import pymongo
from  bson import ObjectIdif __name__ == '__main__':#有密码连接mongoDBmongo = pymongo.MongoClient('mongodb://127.0.0.1:27017')db = mongo["david"]username = "david"password = "123456"db.authenticate(username, password)#切换数据集user_list = db["user_list"]# 删除一个文档# query1 = {"_id": ObjectId("656803f10a84aec77e378334")}# ret1 = user_list.delete_one(query1)# print(ret1)# print(ret1.deleted_count)## query2 = {"name": "xiaoming"}# ret2 = user_list.delete_one(query2)# print(ret2)# print(ret2.deleted_count)# 删除多个文档query = {"name": "xiaoming"}ret = user_list.delete_many(query)print(ret)print(ret.deleted_count)    # 删除总数# 可以通过删除集合的方式，达到删除所有文档的效果# user_list.drop()

①查看最后一条数据id，准备删除2b8a208a547b4e81b2879b3ded013e32.png

② 运行删除代码

fc75efafe0bf408a96613b6132ddcdcc.png

③ 已删除

ca38d29e0ba141908c70379ab9cb6d79.png

④ mongosh查看

b6e1303541bd4f258d197743f805ed30.png

⑤ 插入4个xiaoming

879dd6f7a9d84277bea446c6a99a9211.png

⑥显示已插入

4bce662a0ceb40978039256e7afdda6b.png

⑦ 删除多个文档

e19a7000021148a3a0971a519f3a4d5d.png

⑧ 查看运行结果，删除了4个

923c3442993b475884f62123568f6f76.png

⑨ 已删除

3484c5824c1449c5aff243171ec6a2be.png

⑩ navicat显示也已删除

979f470c64f34377853dc51d4335b63a.png

(3)更新文档

# -*- coding: utf-8 -*-import pymongo
from  bson import ObjectIdif __name__ == '__main__':#有密码连接mongoDBmongo = pymongo.MongoClient('mongodb://127.0.0.1:27017')db = mongo["david"]username = "david"password = "123456"#db.authenticate(username, password)#切换数据集user_list = db["user_list"]# #更新一条数据# query = {"name": "xiaobai"}# data = {"$set": {"age": 22}}# ret = user_list.update_one(query, data)# print(ret.modified_count)      #修改数量#更新所有文档query = {"mobile": {"$regex": "^13"}}data = {"$inc": {"age": 2}}ret = user_list.update_many(query, data)print(ret)print(ret.modified_count)

①查看当前xiaobai年龄为16岁

d7cf0269d86642279c318365c878e101.png

②修改数据

 caebe2a4df7c480da71723cdc0ee133f.png

③运行成功

ca200d9db0b34b5188cac468b1bbe8c9.png
 

④查看数据

2c1cd9847a0742689e609c81c69e6531.png

⑤ xiaobai年龄为22岁

4248ad2cdd1845279bf81daed0152654.png

⑥有2人有手机号

68abc4288ba6499c947c6472c054c9fe.png

⑦ 13开头手机号年龄自增2

25e3d30246104556aa16f0739a219706.png

⑧ 运行成功

0ba491d689ca44a1a1c2337b314d484f.png

(4)查询文档

# -*- coding: utf-8 -*-import pymongo
from  bson import ObjectIdif __name__ == '__main__':#有密码连接mongoDBmongo = pymongo.MongoClient('mongodb://127.0.0.1:27017')db = mongo["david"]username = "david"password = "123456"# db.authenticate(username, password)#切换数据集user_list = db["user_list"]# 查看一个文档，返回结果就是一个字典# ret = user_list.find_one()# print(ret["name"])# print(ret["child"])# print(ret["child"]["age"])# 统计文档数量,返回结果就是整数# ret = user_list.count()# print(ret)# # 查看所有文档# for document in user_list.find():#     print(document)# # 投影查询,去掉id# for document in user_list.find({},{"_id":0}):#     print(document)# # 查看文档部分字段，find和find_one的第二个参数表示控制字段的显示隐藏，1为显示，0为隐藏# for document in user_list.find({}, {"_id": 0, "name": 1, "mobile": 1}):#     print(document)# # 条件查询# query = {"age": 20}# document_list = user_list.find(query)# for document in document_list:#     print(document)# # 比较运算符# query = {"age": {"$gt": 17}}# document_list = user_list.find(query)# for document in document_list:#     print(document)# query = {"age": {"$eq": 20}}# document_list = user_list.find(query)# for document in document_list:#     print(document)# # 多个字段排序：# #       sort([("键1",1),("键2",-1)])# document_list = user_list.find().sort("age")# for document in document_list:#     print(document)## # 限制查询结果数量# document_list = user_list.find().limit(3)# for document in document_list:#     print(document)# # 偏移、跳过# #	skip(int)# document_list = user_list.find().limit(3).skip(3)  # 从第3篇文档开始获取3篇文档# for document in document_list:#     print(document)# # 自定义条件函数# document_list = user_list.find({"$where": "this.age==20"})# for document in document_list:#     print(document)document_list = user_list.find({"$where": "this.age>=18"}).sort("age",-1)for document in document_list:print(document)

①查看一个文档

292b53f525694c3d91029ee5409aaf88.png

②返回结果就是一个字典

98913bb380be40c6a33cbe2d82d81bf5.png

③修改

8bf087ffb1374917836257e8581d8f77.png

④运行结果

c99bbfbbe7844c328706054e1a8d131f.png

⑤修改

cc6e8fe5b6f540e5a738e2683e55124e.png

⑥ child

6805d9a7260943c3b9d656a0394e1f9c.png

⑦ 修改

a61aec80b9ad4f6d802f55ac2e103995.png

⑧child的age

ea8008bc33ba426a886e6c2895c4839d.png

⑨修改

9831c8b7c3b94345ac88167e0e720c3c.png

⑩查看所有文档

e3802a3f56094192adccfaede23082af.png

⑪投影查询

9cc11923cff34cdbbb2dfbc36441e56b.png

⑫已去掉id

3120bcacac564155b0fdc357089ea7a0.png

⑬查看文档部分字段

4e6653f7e17a4d67bf675225f0292ef5.png

⑭条件查询

699410015f8842ec82db838a44adf5bc.png

⑮条件查询2

064f67ba262747b3bc5b32bb60ebbb73.png

⑯比较运算符

ef04a8df514248f2b31ae18ce9c3d0d5.png

⑰多个字段排序

dda20ec9562f4c138635765729e892d7.png

⑱限制查询结果数量

96ef7e32241847638a62220ce871ad94.png

⑲偏移、跳过

b98766223f4b488f9e7b23a4b2a60e32.png

⑳偏移、跳过2

45b8eccd2fff4680b49e69b437c47cbe.png

㉑定义条件函数,倒叙排序

1909607bdde142bca86ecea485b9feab.png

三、问题

1.pip安装报错

（1）报错

11554adfe80c4f6eb565c909c097327a.png

（2）原因分析

网络问题

（3）解决方法

修改下载源

pip install pymongo -i http://pypi.douban.com/simple/ --trusted-host pypi.douban.com

2411c56257484a6089477c9987b19fc6.png

2.PyCharm如何添加MongoDB插件

（1）搜索插件

8093711bbfe34ea7a1d54bd38397441b.png

（2）软件左下角进入插件

759f1c62b5114b01a00ea6da05692c2d.png

（3）测试成功

76cf3322d85b4ecf872915077269ce63.png

这篇关于Python开发运维：PyMongo 连接操作 MongoDB的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/439567。

相关文章

Python调用Orator ORM进行数据库操作

Python调用Orator ORM进行数据库操作

《Python调用OratorORM进行数据库操作》OratorORM是一个功能丰富且灵活的PythonORM库,旨在简化数据库操作,它支持多种数据库并提供了简洁且直观的API,下面我们就... 目录Orator ORM 主要特点安装使用示例总结Orator ORM 是一个功能丰富且灵活的 python O
阅读更多...
Nginx设置连接超时并进行测试的方法步骤

Nginx设置连接超时并进行测试的方法步骤

《Nginx设置连接超时并进行测试的方法步骤》在高并发场景下,如果客户端与服务器的连接长时间未响应,会占用大量的系统资源,影响其他正常请求的处理效率,为了解决这个问题,可以通过设置Nginx的连接... 目录设置连接超时目的操作步骤测试连接超时测试方法：总结：设置连接超时目的设置客户端与服务器之间的连接
阅读更多...
Python使用国内镜像加速pip安装的方法讲解

Python使用国内镜像加速pip安装的方法讲解

《Python使用国内镜像加速pip安装的方法讲解》在Python开发中,pip是一个非常重要的工具,用于安装和管理Python的第三方库,然而,在国内使用pip安装依赖时,往往会因为网络问题而导致速... 目录一、pip 工具简介1. 什么是 pip？2. 什么是 -i 参数？二、国内镜像源的选择三、如何
阅读更多...
python使用fastapi实现多语言国际化的操作指南

python使用fastapi实现多语言国际化的操作指南

《python使用fastapi实现多语言国际化的操作指南》本文介绍了使用Python和FastAPI实现多语言国际化的操作指南,包括多语言架构技术栈、翻译管理、前端本地化、语言切换机制以及常见陷阱和... 目录多语言国际化实现指南项目多语言架构技术栈目录结构翻译工作流1. 翻译数据存储2. 翻译生成脚本
阅读更多...
Android 悬浮窗开发示例((动态权限请求 | 前台服务和通知 | 悬浮窗创建 )

Android 悬浮窗开发示例((动态权限请求 | 前台服务和通知 | 悬浮窗创建 )

《Android悬浮窗开发示例((动态权限请求|前台服务和通知|悬浮窗创建)》本文介绍了Android悬浮窗的实现效果,包括动态权限请求、前台服务和通知的使用,悬浮窗权限需要动态申请并引导... 目录一、悬浮窗 动态权限请求1、动态请求权限2、悬浮窗权限说明3、检查动态权限4、申请动态权限5、权限设置完毕后
阅读更多...
如何通过Python实现一个消息队列

如何通过Python实现一个消息队列

《如何通过Python实现一个消息队列》这篇文章主要为大家详细介绍了如何通过Python实现一个简单的消息队列,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录如何通过 python 实现消息队列如何把 http 请求放在队列中执行1. 使用 queue.Queue 和 reque
阅读更多...
Python如何实现PDF隐私信息检测

Python如何实现PDF隐私信息检测

《Python如何实现PDF隐私信息检测》随着越来越多的个人信息以电子形式存储和传输,确保这些信息的安全至关重要,本文将介绍如何使用Python检测PDF文件中的隐私信息,需要的可以参考下... 目录项目背景技术栈代码解析功能说明运行结php果在当今，数据隐私保护变得尤为重要。随着越来越多的个人信息以电子形
阅读更多...
使用Python快速实现链接转word文档

使用Python快速实现链接转word文档

《使用Python快速实现链接转word文档》这篇文章主要为大家详细介绍了如何使用Python快速实现链接转word文档功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 演示代码展示from newspaper import Articlefrom docx import
阅读更多...
Python Jupyter Notebook导包报错问题及解决

Python Jupyter Notebook导包报错问题及解决

《PythonJupyterNotebook导包报错问题及解决》在conda环境中安装包后,JupyterNotebook导入时出现ImportError,可能是由于包版本不对应或版本太高,解决方... 目录问题解决方法重新安装Jupyter NoteBook 更改Kernel总结问题在conda上安装了
阅读更多...
Python如何计算两个不同类型列表的相似度

Python如何计算两个不同类型列表的相似度

《Python如何计算两个不同类型列表的相似度》在编程中,经常需要比较两个列表的相似度,尤其是当这两个列表包含不同类型的元素时,下面小编就来讲讲如何使用Python计算两个不同类型列表的相似度吧... 目录摘要引言数字类型相似度欧几里得距离曼哈顿距离字符串类型相似度Levenshtein距离Jaccard相
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2