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

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/188057.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

传教士与野人过河问题

代码模块参考文章:传教士与野人过河问题(numpy、pandas)_python过河问题_醉蕤的博客-CSDN博客 问题描述 一般的传教士和野人问题(Missionaries and Cannibals):有N个传教士和C个野人来到河边准 备渡河。…

【分布式事务】Seata 开源的分布式事务解决方案

1. 什么是seata Seata 是一款开源的分布式事务解决方案,致力于提供高性能和简单易用的分布式事务服务。Seata 将为用户提供了 AT、TCC、SAGA 和 XA 事务模式,为用户打造一站式的分布式解决方案。 2. seata发展历程 阿里巴巴作为国内最早一批进行应用分…

视频中的文字水印怎么去除?这三招学会轻松去视频水印

短视频与我们生活,工作息息相关,日常在在刷短视频时,下载保存后发现带有文字logo水印,如果直接拿来进行二次创作,不仅影响观看效果,平台流量还会受限制。怎么去除视频中的文字水印就成为了当下热门话题之一…

【代码】CNN-GRU-Attention基于卷积神经网络和门控循环单元网络结合注意力机制的多变量回归预测

程序名称:CNN-GRU-Attention基于卷积神经网络和门控循环单元网络结合注意力机制的多变量回归预测 实现平台:matlab 代码简介:为更准确地预测,提出基于注意力机制的CNN-GRU预测模型。该模型主要借助一维卷积单元提取数…

浅聊langchain-chatchat

个人的一点经验和总结,希望能帮助到大家。有不对的地方请留言和指正! langchain-GLM是什么 langchain-GLM是一个本地知识库应用解决方案,支持以cli、web、api方式提供以本地知识库或在线资源为知识素材的对话服务,对中英文场景对…

【AIOps】一种全新的日志异常检测评估框架:LightAD,相关成果已被软工顶会ICSE 2024录用

深度学习(DL)虽然在日志异常检测中得到了不少应用,但在实际轻量级运维模型选择中,必须仔细考虑异常检测方法与计算成本的关系。具体来说,尽管深度学习方法在日志异常检测方面取得了出色的性能,但它们通常需…

【Linux】awk 使用

awk 输出 // 打印所有列 $ awk {print $0} file // 打印第一列 $ awk {print $1} file // 打印第一和第三列 $ awk {print $1, $3} file // 打印第三列和第一列,注意先后顺序 $ cat file | awk {print $3, $1} …

探索数据之美:深入学习Plotly库的强大可视化

1. 引言: Plotly 是一个交互性可视化库,可以用于创建各种漂亮的图表和仪表板。它支持多种编程语言,包括Python、R、JavaScript。在Python中,Plotly提供了Plotly Express和Graph Objects两个主要的绘图接口。 2. Plotly库简介&am…

音乐播放器Swinsian mac功能介绍

Swinsian mac是一款音乐播放器,它的特点是轻量级、快速、易用。Swinsian支持多种音频格式,包括MP3、AAC、FLAC、WAV等。它还具有iTunes集成功能,可以自动导入iTunes音乐库中的音乐,并支持智能播放列表、标签编辑、自定义快捷键等功…

STM32Cube高效开发教程<基础篇>(十)----USART/UART通信

声明:本人水平有限,博客可能存在部分错误的地方,请广大读者谅解并向本人反馈错误。    本专栏博客参考《STM32Cube高效开发教程(基础篇)》,有意向的读者可以购买正版书籍进行学习,本书籍由王维波老师、鄢志丹老师、王钊老师倾力打造,书籍内容干货满满。 一、 功能概述…

Linux shell for jar test

Linux shell 脚本,循环解析命令行传入的所有参数,并按照不同的传参实现对不同的 java jar文件 进行测试执行。 [rootlocalhost demo]# cat connTest.sh #!/bin/bash# Linux shell for qftool java jar test# modes DEFAULT_MODE2jarfiles[1]common-1.0…

OpenAI公布CEO和董事会成员:微软加入,Ilya出局

11月30日,OpenAI在官网公布了新一届领导层和初始董事会成员:Sam Altman重新担任CEO,Mira Murati继续担任首席技术官,Greg Brockman继续担任总裁。 新的董事会成员包括:Bret Taylor(主席)、Larr…

docker部署elasticsearch+kibana+head

前言 最近,项目需要使用elasticsearch,所以就想快速安装一个使用,最开始是docker安装了7.10.1版本。 后面计划使用Java开发,发现有 RestHighLevelClient 和 Elasticsearch Java API Client两种客户端连接方式。 然后网上查阅了一…

深入剖析:知识付费系统源码解读与技术实现

知识付费系统源码是构建一个高效、稳定平台的关键。在本文中,我们将深入解析知识付费系统的源码,同时提供一些关键技术代码,以助你更好地理解和实现这一系统。 1. 知识付费系统的基本结构 首先,让我们看一下知识付费系统的基本…

论文学习-Bert 和GPT 有什么区别?

Foundation Models, Transformers, BERT and GPT 总结一下: Bert 是学习向量表征,让句子中某个词的Embedding关联到句子中其他重要词。最终学习下来,就是词向量的表征。这也是为什么Bert很容易用到下游任务,在做下游任务的时候&a…

经验分享:JMeter控制RPS

一、前言 ​ RPS (Request Per Second)一般用来衡量服务端的吞吐量,相比于并发模式,更适合用来摸底服务端的性能。我们可以通过使用 JMeter 的常数吞吐量定时器来限制每个线程的RPS。对于RPS,我们可以把他理解为我们的TPS,我们就…

数组?NO 系Vector啊!

文章目录 前言一、vector的介绍二、vector的使用2.1 vector求容量的用法2.2 vector的增删查改用法2.2.1 尾插2.2.2 尾删2.2.3 头插2.2.4 任意位置删除 2.3 vector的iterator是什么以及失效问题 三、vector的模拟实现3.1 成员变量3.2 成员函数3.2.1 构造函数3.2.2 拷贝构造3.2.3…

一起学docker系列之十五深入了解 Docker Network:构建容器间通信的桥梁

目录 1 前言2 什么是 Docker Network3 Docker Network 的不同模式3.1 桥接模式(Bridge)3.2 Host 模式3.3 无网络模式(None)3.4 容器模式(Container) 4 Docker Network 命令及用法4.1 docker network ls4.2 …

MSSQL注入

目录 基本的UNION注入: 错误基于的注入: 时间基于的盲注入: 堆叠查询: 理解MSSQL注入是学习网络安全的一部分,前提是您在合法、授权的环境中进行,用于了解如何保护您的应用程序免受此类攻击。以下是有关…

【linux】/etc/security/limits.conf配置文件详解、为什么限制、常见限制查看操作

文章目录 一. limits.conf常见配置项详解二. 文件描述符(file descriptor)简述三. 为什么限制四. 相关操作1. 展示当前资源限制2. 查看系统当前打开的文件描述符数量3. 查看某个进程打开的文件描述符数量4. 各进程占用的文件描述符 /etc/security/limits…